83 lines
2.4 KiB
TypeScript
83 lines
2.4 KiB
TypeScript
import Step from '../models/step';
|
|
import Flow from '../models/flow';
|
|
import Execution from '../models/execution';
|
|
import ExecutionStep from '../models/execution-step';
|
|
import computeParameters from '../helpers/compute-parameters';
|
|
import globalVariable from '../helpers/global-variable';
|
|
import { logger } from '../helpers/logger';
|
|
import HttpError from '../errors/http';
|
|
import EarlyExitError from '../errors/early-exit';
|
|
import AlreadyProcessedError from '../errors/already-processed';
|
|
|
|
type ProcessActionOptions = {
|
|
flowId: string;
|
|
executionId: string;
|
|
stepId: string;
|
|
};
|
|
|
|
export const processAction = async (options: ProcessActionOptions) => {
|
|
const { flowId, stepId, executionId } = options;
|
|
|
|
const flow = await Flow.query().findById(flowId).throwIfNotFound();
|
|
const execution = await Execution.query()
|
|
.findById(executionId)
|
|
.throwIfNotFound();
|
|
|
|
const step = await Step.query().findById(stepId).throwIfNotFound();
|
|
|
|
const $ = await globalVariable({
|
|
flow,
|
|
app: await step.getApp(),
|
|
step: step,
|
|
connection: await step.$relatedQuery('connection'),
|
|
execution,
|
|
});
|
|
|
|
const priorExecutionSteps = await ExecutionStep.query().where({
|
|
execution_id: $.execution.id,
|
|
});
|
|
|
|
const computedParameters = computeParameters(
|
|
$.step.parameters,
|
|
priorExecutionSteps
|
|
);
|
|
|
|
const actionCommand = await step.getActionCommand();
|
|
|
|
$.step.parameters = computedParameters;
|
|
|
|
try {
|
|
await actionCommand.run($);
|
|
} catch (error) {
|
|
const shouldEarlyExit = error instanceof EarlyExitError;
|
|
const shouldNotProcess = error instanceof AlreadyProcessedError;
|
|
const shouldNotConsiderAsError = shouldEarlyExit || shouldNotProcess;
|
|
|
|
if (!shouldNotConsiderAsError) {
|
|
logger.error(error);
|
|
|
|
if (error instanceof HttpError) {
|
|
$.actionOutput.error = error.details;
|
|
} else {
|
|
try {
|
|
$.actionOutput.error = JSON.parse(error.message);
|
|
} catch {
|
|
$.actionOutput.error = { error: error.message };
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
const executionStep = await execution
|
|
.$relatedQuery('executionSteps')
|
|
.insertAndFetch({
|
|
stepId: $.step.id,
|
|
status: $.actionOutput.error ? 'failure' : 'success',
|
|
dataIn: computedParameters,
|
|
dataOut: $.actionOutput.error ? null : $.actionOutput.data?.raw,
|
|
errorDetails: $.actionOutput.error ? $.actionOutput.error : null,
|
|
});
|
|
|
|
return { flowId, stepId, executionId, executionStep, computedParameters };
|
|
};
|