-
Notifications
You must be signed in to change notification settings - Fork 23
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Send events to per-message event urls #31
Send events to per-message event urls #31
Conversation
…essage forwarding worker
Ready for review. |
['application/json']) | ||
|
||
self.assertEqual(req.method, 'POST') | ||
self.assertEqual(body, api_from_event(self.worker.channel_id, event)) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Wonder if it's worthwhile writing a helper method for this request checking?
One very minor comment, otherwise looks good. |
Ready for re-review. |
👍 |
from junebug.workers import MessageForwardingWorker | ||
from junebug.channel import ( | ||
Channel, ChannelNotFound, InvalidChannelType, MessageNotFound) | ||
from junebug.tests.helpers import JunebugTestBase | ||
from junebug.tests.utils import conjoin | ||
from junebug.utils import conjoin |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can we combine this import with the one on line 6?
#30 will allow us to store the per-message event urls given to the api when sending a message. This ticket is for fetching these stored event urls in
MessageForwardingWorker
when we consume an event, and sending the event to the url.