Merge remote-tracking branch 'origin/main' into fix-open-api

youngsecurity · Aug 14, 2024 · f39d35f · f39d35f
2 parents 55239f0 + 1ca1404
commit f39d35f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,7 +1,7 @@
 {
   "name": "activepieces",
   "version": "0.29.1",
-  "rcVersion": "0.30.0-rc.6",
+  "rcVersion": "0.30.0-rc.7",
   "scripts": {
     "prepare": "husky install",
     "serve:frontend": "nx serve ui-core",

diff --git a/packages/server/api/src/app/app-event-routing/app-event-routing.module.ts b/packages/server/api/src/app/app-event-routing/app-event-routing.module.ts
@@ -16,6 +16,7 @@ import { FastifyRequest } from 'fastify'
 import { StatusCodes } from 'http-status-codes'
 import { DEFAULT_PRIORITY } from '../workers/queue/queue-manager'
 import { appEventRoutingService } from './app-event-routing.service'
+import { flowQueue } from '../workers/queue'
 
 const appWebhooks: Record<string, Piece> = {
     slack,
@@ -97,7 +98,7 @@ export const appEventRoutingController: FastifyPluginAsyncTypebox = async (
             })
             const eventsQueue = listeners.map(async (listener) => {
                 const requestId = apId()
-                return {
+                return flowQueue.add({
                     id: requestId,
                     type: JobType.WEBHOOK,
                     data: {
@@ -110,7 +111,7 @@ export const appEventRoutingController: FastifyPluginAsyncTypebox = async (
                         simulate: false,
                     },
                     priority: DEFAULT_PRIORITY,
-                }
+                })
             })
             rejectedPromiseHandler(Promise.all(eventsQueue))
             return requestReply.status(StatusCodes.OK).send({})