Add utils

packages/backend-core/src/events/processors/AuditLogsProcessor.ts

@@ -17,6 +17,10 @@ export default class AuditLogsProcessor implements EventProcessor {
   static auditLogsEnabled = false
   static auditLogQueue: BullQueue.Queue<AuditLogQueueEvent>
 
+  get queue() {
+    return AuditLogsProcessor.auditLogQueue
+  }
+
   // can't use constructor as need to return promise
   static init(fn: AuditLogFn) {
     AuditLogsProcessor.auditLogsEnabled = true

packages/backend-core/src/events/processors/index.ts

@@ -5,8 +5,8 @@ import Processors from "./Processors"
 import { AuditLogFn } from "@budibase/types"
 
 export const analyticsProcessor = new AnalyticsProcessor()
-const loggingProcessor = new LoggingProcessor()
-const auditLogsProcessor = new AuditLogsProcessor()
+export const loggingProcessor = new LoggingProcessor()
+export const auditLogsProcessor = new AuditLogsProcessor()
 
 export function init(auditingFn: AuditLogFn) {
   return AuditLogsProcessor.init(auditingFn)

packages/backend-core/tests/core/utilities/index.ts

@@ -4,3 +4,4 @@ export { generator } from "./structures"
 export * as testContainerUtils from "./testContainerUtils"
 export * as utils from "./utils"
 export * from "./jestUtils"
+export * as queue from "./queue"

packages/backend-core/tests/core/utilities/queue.ts

@@ -0,0 +1,9 @@
+import { Queue } from "bull"
+
+export async function processMessages(queue: Queue) {
+  do {
+    await queue.whenCurrentJobsFinished()
+  } while (await queue.count())
+
+  await queue.whenCurrentJobsFinished()
+}

packages/worker/src/api/routes/global/tests/auditLogs.spec.ts

@@ -1,4 +1,4 @@
-import { mocks, structures } from "@budibase/backend-core/tests"
+import { mocks, structures, queue } from "@budibase/backend-core/tests"
 import { context, events, features } from "@budibase/backend-core"
 import { Event, IdentityType } from "@budibase/types"
 import { TestConfiguration } from "../../../../tests"
@@ -54,6 +54,11 @@ describe("/api/global/auditlogs (%s)", () => {
             await context.doInAppContext(APP_ID, async () => {
               await events.app.created(structures.apps.app(APP_ID))
             })
+
+            await queue.processMessages(
+              events.processors.auditLogsProcessor.queue
+            )
+
             // fetch the user created events
             const response = await config.api.auditLogs.search({
               events: [Event.USER_CREATED],