diff --git a/packages/backend/src/controllers/api/v1/flows/import-flow.js b/packages/backend/src/controllers/api/v1/flows/import-flow.js index 4fbdea54..5b6a2383 100644 --- a/packages/backend/src/controllers/api/v1/flows/import-flow.js +++ b/packages/backend/src/controllers/api/v1/flows/import-flow.js @@ -1,8 +1,8 @@ import { renderObject } from '../../../../helpers/renderer.js'; -import importFlow from '../../../../helpers/import-flow.js'; +import Flow from '../../../../models/flow.js'; export default async function importFlowController(request, response) { - const flow = await importFlow(request.currentUser, flowParams(request)); + const flow = await Flow.import(request.currentUser, flowParams(request)); return renderObject(response, flow, { status: 201 }); } diff --git a/packages/backend/src/models/flow.js b/packages/backend/src/models/flow.js index bd4a8058..51a90a3a 100644 --- a/packages/backend/src/models/flow.js +++ b/packages/backend/src/models/flow.js @@ -9,6 +9,7 @@ import globalVariable from '../helpers/global-variable.js'; import logger from '../helpers/logger.js'; import Telemetry from '../helpers/telemetry/index.js'; import exportFlow from '../helpers/export-flow.js'; +import importFlow from '../helpers/import-flow.js'; import flowQueue from '../queues/flow.js'; import { REMOVE_AFTER_30_DAYS_OR_150_JOBS, @@ -39,6 +40,10 @@ class Flow extends Base { }, }; + static async import(user, flowData) { + return importFlow(user, flowData); + } + static relationMappings = () => ({ steps: { relation: Base.HasManyRelation,