Add SqliteMessageQueue and related tests #526
Conversation
Summary of ChangesHello @2chanhaeng, I'm Gemini Code Assist1! I'm currently reviewing this pull request and will post my feedback shortly. In the meantime, here's a summary to help you and other reviewers quickly get up to speed! This pull request significantly enhances the message queuing capabilities by introducing a new SQLite-based message queue implementation. Concurrently, it establishes a robust and standardized testing framework for message queues, which has been applied to existing implementations. This dual approach not only expands the available message queue options but also improves the consistency, reliability, and maintainability of message queue tests across the project, making future integrations and testing more efficient. Highlights
Using Gemini Code AssistThe full guide for Gemini Code Assist can be found on our documentation page, here are some quick tips. Invoking Gemini You can request assistance from Gemini at any point by creating a comment using either
Customization To customize Gemini Code Assist for GitHub experience, repository maintainers can create a configuration file and/or provide a custom code review style guide (such as PEP-8 for Python) by creating and adding files to a Limitations & Feedback Gemini Code Assist may make mistakes. Please leave feedback on any instances where its feedback is incorrect or counter productive. You can react with 👍 and 👎 on @gemini-code-assist comments. If you're interested in giving your feedback about your experience with Gemini Code Assist for Github and other Google products, sign up here. You can also get AI-powered code generation, chat, as well as code reviews directly in the IDE at no cost with the Gemini Code Assist IDE Extension. Footnotes
|
![gemini-code-assist[bot]](https://avatars.githubusercontent.com/in/956858?s=60&v=4){kind=small}
There was a problem hiding this comment.
Code Review
This pull request introduces a new SqliteMessageQueue and a standardized testing utility, testMessageQueue, to unify message queue tests across the repository. The refactoring of existing tests to use this new utility is a great step towards reducing code duplication and ensuring consistent test coverage.
My review focuses on the new implementations. I've found a couple of critical issues in the SqliteMessageQueue related to race conditions and error handling that could lead to message loss and listener crashes. I've also identified areas for improvement in the new testMessageQueue utility to make it more robust and align with the MessageQueue interface. Additionally, I've suggested a minor improvement to the SQLite test to ensure proper cleanup of temporary database files.
Codecov Report❌ Patch coverage is
... and 2 files with indirect coverage changes 🚀 New features to boost your workflow:
|
|
How about adding |
That's a good idea, but it seems to go beyond #477. How about you create a separate issue for it? |
SqliteMessageQueue.listen fedify-dev#526 (comment)
Well, the cleanup method belongs to |
2chanhaeng
left a comment
2chanhaeng
left a comment
There was a problem hiding this comment.
How about adding
[Symbol.dispose]()for consistency with other MessageQueue implementations?That's a good idea, but it seems to go beyond #477. How about you create a separate issue for it?
Well, the cleanup method belongs to
sqlite/src/ mq.tsso i don't think that's out of scope if you implement it for only SqliteMessageQueue. It seems quite simple but caring other message queues should be handled in other PR like you said. (Neither amqp has that)
Oh, OK. I added it at 80e11c6!
SqliteMessageQueue.listen fedify-dev#526 (comment)
SqliteMessageQueue.listen fedify-dev#526 (comment)
- Remove `let Temporal ...` - Export `@fedify/sqlite` - Add missing dependencies
SqliteMessageQueue.listen fedify-dev#526 (comment)
fedify-dev#526 (review) - Fixed `testMessageQueue` to pass `{ signal }` options object instead of `AbortController` directly to `listen()` method - Fixed PostgreSQL test to share same table and channel between `mq1` and `mq2` instances by moving key generation outside factory function - Fixed Redis test to share same queue keys between `mq1` and `mq2` instances by moving key generation outside factory function - Fixed SQLite test cleanup to dispose both `mq1` and `mq2` instances, preventing resource leak, and removed redundant `mq2.drop()` call
|
/gemini review |
There was a problem hiding this comment.
Code Review
This pull request introduces a SqliteMessageQueue and a standardized testing utility, testMessageQueue, which is a significant improvement for maintainability and consistency across message queue implementations. The existing tests for AMQP, DenoKV, PostgreSQL, and Redis message queues have been refactored to use this new utility, which greatly simplifies the test code. The new SqliteMessageQueue is well-designed, featuring a polling mechanism with in-process notifications for efficiency and robust error handling for SQLITE_BUSY states. My review has identified a potential memory leak in the polling logic and a design consideration regarding database connection management that should be addressed.
dahlia
left a comment
dahlia
left a comment
There was a problem hiding this comment.
Looks good in general. Great job! Thanks!
3 participants
Summary
Introduce the
SqliteMessageQueueclass along with a testing framework formessage queues. Refactor existing tests to utilize the new
testMessageQueueutility for improved test structure and readability.
Related issue
SqliteMessageQueuefor single-node deployments #477Changes
SqliteMessageQueueclass to@fedify/sqlitepackage implementingthe
MessageQueueinterface using SQLite as the backing storetestMessageQueue()utility function to@fedify/testingpackagefor standardized testing of
MessageQueueimplementationswaitFor()andgetRandomKey()helper functions to@fedify/testingtestMessageQueue:@fedify/amqp@fedify/denokv@fedify/postgres@fedify/redisSqliteMessageQueueBenefits
a reusable test harness
MessageQueueimplementationsMessageQueueimplementations in the futurewith standardized testing
Checklist
mise teston your machine?