diff --git a/packages/server/src/automations/triggers.ts b/packages/server/src/automations/triggers.ts index a9317772d9..2ac90f3f9c 100644 --- a/packages/server/src/automations/triggers.ts +++ b/packages/server/src/automations/triggers.ts @@ -1,7 +1,7 @@ import emitter from "../events/index" import { getAutomationParams, isDevAppID } from "../db/utils" import { coerce } from "../utilities/rowProcessor" -import { definitions } from "./triggerInfo" +import { automations } from "@budibase/shared-core" // need this to call directly, so we can get a response import { automationQueue } from "./bullboard" import { checkTestFlag } from "../utilities/redis" @@ -26,7 +26,7 @@ import { import { executeInThread } from "../threads/automation" import { dataFilters, sdk } from "@budibase/shared-core" -export const TRIGGER_DEFINITIONS = definitions +export const TRIGGER_DEFINITIONS = automations.triggers.definitions const JOB_OPTS = { removeOnComplete: true, removeOnFail: true, @@ -273,8 +273,8 @@ async function checkTriggerFilters( } if ( - trigger.stepId === definitions.ROW_UPDATED.stepId || - trigger.stepId === definitions.ROW_SAVED.stepId + trigger.stepId === automations.triggers.definitions.ROW_UPDATED.stepId || + trigger.stepId === automations.triggers.definitions.ROW_SAVED.stepId ) { const newRow = await automationUtils.cleanUpRow(tableId, event.row) return rowPassesFilters(newRow, filters) diff --git a/packages/server/src/automations/utils.ts b/packages/server/src/automations/utils.ts index 292b288a70..9bfcc6cf8a 100644 --- a/packages/server/src/automations/utils.ts +++ b/packages/server/src/automations/utils.ts @@ -1,5 +1,5 @@ import { Thread, ThreadType } from "../threads" -import { definitions } from "./triggerInfo" +import { automations } from "@budibase/shared-core" import { automationQueue } from "./bullboard" import { updateEntityMetadata } from "../utilities" import { context, db as dbCore, utils } from "@budibase/backend-core" @@ -19,7 +19,7 @@ import { automationsEnabled } from "../features" import { helpers, REBOOT_CRON } from "@budibase/shared-core" import tracer from "dd-trace" -const CRON_STEP_ID = definitions.CRON.stepId +const CRON_STEP_ID = automations.triggers.definitions.CRON.stepId let Runner: Thread if (automationsEnabled()) { Runner = new Thread(ThreadType.AUTOMATION) @@ -255,7 +255,10 @@ export async function cleanupAutomations(appId: any) { * @return if it is recurring (cron). */ export function isRecurring(automation: Automation) { - return automation.definition.trigger.stepId === definitions.CRON.stepId + return ( + automation.definition.trigger.stepId === + automations.triggers.definitions.CRON.stepId + ) } export function isErrorInOutput(output: { diff --git a/packages/server/src/sdk/app/automations/crud.ts b/packages/server/src/sdk/app/automations/crud.ts index d16ae2d042..cd8af1e548 100644 --- a/packages/server/src/sdk/app/automations/crud.ts +++ b/packages/server/src/sdk/app/automations/crud.ts @@ -13,7 +13,7 @@ import { HTTPError, db as dbCore, } from "@budibase/backend-core" -import { definitions } from "../../../automations/triggerInfo" +import { automations as sharedAutomations } from "@budibase/shared-core" import automations from "." export interface PersistedAutomation extends Automation { @@ -202,7 +202,7 @@ export async function remove(automationId: string, rev: string) { * written to DB (this does not write to DB as it would be wasteful to repeat). */ async function checkForWebhooks({ oldAuto, newAuto }: any) { - const WH_STEP_ID = definitions.WEBHOOK.stepId + const WH_STEP_ID = sharedAutomations.triggers.definitions.WEBHOOK.stepId const appId = context.getAppId() if (!appId) { diff --git a/packages/server/src/sdk/app/rowActions/crud.ts b/packages/server/src/sdk/app/rowActions/crud.ts index 1153677685..64bb4729ce 100644 --- a/packages/server/src/sdk/app/rowActions/crud.ts +++ b/packages/server/src/sdk/app/rowActions/crud.ts @@ -9,7 +9,7 @@ import { } from "@budibase/types" import { generateRowActionsID } from "../../../db/utils" import automations from "../automations" -import { definitions as TRIGGER_DEFINITIONS } from "../../../automations/triggerInfo" +import { automations as sharedAutomations } from "@budibase/shared-core" import * as triggers from "../../../automations/triggers" import sdk from "../.." @@ -59,7 +59,7 @@ export async function create(tableId: string, rowAction: { name: string }) { definition: { trigger: { id: "trigger", - ...TRIGGER_DEFINITIONS.ROW_ACTION, + ...sharedAutomations.triggers.definitions.ROW_ACTION, stepId: AutomationTriggerStepId.ROW_ACTION, inputs: { tableId, diff --git a/packages/server/src/threads/automation.ts b/packages/server/src/threads/automation.ts index 2790d8fda6..174efa0fe0 100644 --- a/packages/server/src/threads/automation.ts +++ b/packages/server/src/threads/automation.ts @@ -11,7 +11,7 @@ import { replaceFakeBindings } from "../automations/loopUtils" import { dataFilters, helpers, utils } from "@budibase/shared-core" import { default as AutomationEmitter } from "../events/AutomationEmitter" import { generateAutomationMetadataID, isProdAppID } from "../db/utils" -import { definitions as triggerDefs } from "../automations/triggerInfo" +import { automations } from "@budibase/shared-core" import { AutomationErrors, MAX_AUTOMATION_RECURRING_ERRORS } from "../constants" import { storeLog } from "../automations/logging" import { @@ -50,7 +50,7 @@ import env from "../environment" import tracer from "dd-trace" threadUtils.threadSetup() -const CRON_STEP_ID = triggerDefs.CRON.stepId +const CRON_STEP_ID = automations.triggers.definitions.CRON.stepId const STOPPED_STATUS = { success: true, status: AutomationStatus.STOPPED } function getLoopIterations(loopStep: LoopStep) { diff --git a/packages/shared-core/src/automations/index.ts b/packages/shared-core/src/automations/index.ts index 064796845e..db38233494 100644 --- a/packages/shared-core/src/automations/index.ts +++ b/packages/shared-core/src/automations/index.ts @@ -1 +1,2 @@ export * as steps from "./steps/index" +export * as triggers from "./triggers/index" diff --git a/packages/server/src/automations/triggerInfo/app.ts b/packages/shared-core/src/automations/triggers/app.ts similarity index 100% rename from packages/server/src/automations/triggerInfo/app.ts rename to packages/shared-core/src/automations/triggers/app.ts diff --git a/packages/server/src/automations/triggerInfo/cron.ts b/packages/shared-core/src/automations/triggers/cron.ts similarity index 100% rename from packages/server/src/automations/triggerInfo/cron.ts rename to packages/shared-core/src/automations/triggers/cron.ts diff --git a/packages/server/src/automations/triggerInfo/index.ts b/packages/shared-core/src/automations/triggers/index.ts similarity index 100% rename from packages/server/src/automations/triggerInfo/index.ts rename to packages/shared-core/src/automations/triggers/index.ts diff --git a/packages/server/src/automations/triggerInfo/rowAction.ts b/packages/shared-core/src/automations/triggers/rowAction.ts similarity index 100% rename from packages/server/src/automations/triggerInfo/rowAction.ts rename to packages/shared-core/src/automations/triggers/rowAction.ts diff --git a/packages/server/src/automations/triggerInfo/rowDeleted.ts b/packages/shared-core/src/automations/triggers/rowDeleted.ts similarity index 100% rename from packages/server/src/automations/triggerInfo/rowDeleted.ts rename to packages/shared-core/src/automations/triggers/rowDeleted.ts diff --git a/packages/server/src/automations/triggerInfo/rowSaved.ts b/packages/shared-core/src/automations/triggers/rowSaved.ts similarity index 100% rename from packages/server/src/automations/triggerInfo/rowSaved.ts rename to packages/shared-core/src/automations/triggers/rowSaved.ts diff --git a/packages/server/src/automations/triggerInfo/rowUpdated.ts b/packages/shared-core/src/automations/triggers/rowUpdated.ts similarity index 100% rename from packages/server/src/automations/triggerInfo/rowUpdated.ts rename to packages/shared-core/src/automations/triggers/rowUpdated.ts diff --git a/packages/server/src/automations/triggerInfo/webhook.ts b/packages/shared-core/src/automations/triggers/webhook.ts similarity index 100% rename from packages/server/src/automations/triggerInfo/webhook.ts rename to packages/shared-core/src/automations/triggers/webhook.ts