From dd0395995f53c4e43a9d26d38d47056eda539dc7 Mon Sep 17 00:00:00 2001 From: Rory Powell Date: Tue, 9 Aug 2022 14:01:55 +0100 Subject: [PATCH] Rename async to emit --- .../src/events/{async => emit}/BBEventEmitter.ts | 0 packages/backend-core/src/events/{async => emit}/index.ts | 0 packages/backend-core/src/events/events.ts | 8 ++++---- 3 files changed, 4 insertions(+), 4 deletions(-) rename packages/backend-core/src/events/{async => emit}/BBEventEmitter.ts (100%) rename packages/backend-core/src/events/{async => emit}/index.ts (100%) 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 }