-
Notifications
You must be signed in to change notification settings - Fork 7.1k
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
refactor(core): Simplify webhook pubsub message handler #11048
Conversation
const subscriber = Container.get(Subscriber); | ||
await subscriber.subscribe('n8n.commands'); | ||
subscriber.setCommandMessageHandler(); | ||
|
||
Container.get(PubSubHandler).init(); |
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.
const subscriber = Container.get(Subscriber); | |
await subscriber.subscribe('n8n.commands'); | |
subscriber.setCommandMessageHandler(); | |
Container.get(PubSubHandler).init(); | |
Container.get(PubSubHandler).init(); | |
const subscriber = Container.get(Subscriber); | |
subscriber.setCommandMessageHandler(); | |
await subscriber.subscribe('n8n.commands'); |
Would this order also work and prevent use form missing messages?
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.
Thanks! It's a tiny window - I'll address in the next PR 👍🏻
n8n Run #7141
Run Properties:
|
Project |
n8n
|
Branch Review |
simplify-webhook-pubsub-msg-handler
|
Run status |
Passed #7141
|
Run duration | 04m 27s |
Commit |
d6f3629a39: 🌳 🖥️ browsers:node18.12.0-chrome107 🤖 ivov 🗃️ e2e/*
|
Committer | Iván Ovejero |
View all properties for this run ↗︎ |
Test results | |
---|---|
Failures |
0
|
Flaky |
0
|
Pending |
0
|
Skipped |
0
|
Passing |
437
|
View all changes introduced in this branch ↗︎ |
✅ All Cypress E2E specs passed |
Got released with |
1 similar comment
Got released with |
Simplfy pubsub message handling in a
webhook
process using typed event emitter, add tests, and deletehandleCommandMessageWebhook
andOrchestrationHandlerWebhookService
.https://linear.app/n8n/issue/PAY-2023
Ref: #10566