diff --git a/packages/backend-core/src/events/async/BBEventEmitter.ts b/packages/backend-core/src/events/emit/BBEventEmitter.ts similarity index 100% rename from packages/backend-core/src/events/async/BBEventEmitter.ts rename to packages/backend-core/src/events/emit/BBEventEmitter.ts diff --git a/packages/backend-core/src/events/async/index.ts b/packages/backend-core/src/events/emit/index.ts similarity index 100% rename from packages/backend-core/src/events/async/index.ts rename to packages/backend-core/src/events/emit/index.ts diff --git a/packages/backend-core/src/events/events.ts b/packages/backend-core/src/events/events.ts index 1d532c092b..63fedf4754 100644 --- a/packages/backend-core/src/events/events.ts +++ b/packages/backend-core/src/events/events.ts @@ -2,17 +2,17 @@ import { Event } from "@budibase/types" import { processors } from "./processors" import * as identification from "./identification" import * as backfill from "./backfill" -import { emitter, EmittedEvent } from "./async" +import { emitter, EmittedEvent } from "./emit" import * as context from "../context" import * as logging from "../logging" -const USE_ASYNC: any[] = [ +const USE_EMITTER: any[] = [ Event.SERVED_BUILDER, Event.SERVED_APP, Event.SERVED_APP_PREVIEW, ] -for (let event of USE_ASYNC) { +for (let event of USE_EMITTER) { emitter.on(event, async (props: EmittedEvent) => { try { await context.doInTenant(props.tenantId, async () => { @@ -46,7 +46,7 @@ export const publishEvent = async ( // in future this should use async events via a distributed queue. const identity = await identification.getCurrentIdentity() - if (USE_ASYNC.includes(event)) { + if (USE_EMITTER.includes(event)) { emitter.emitEvent(event, properties, identity) return }