feat: Add dynamic fields structure to step arguments

packages/backend/src/graphql/queries/get-dynamic-fields.ts

@@ -0,0 +1,53 @@
+import { IDynamicFields, IJSONObject } from '@automatisch/types';
+import Context from '../../types/express/context';
+import App from '../../models/app';
+import globalVariable from '../../helpers/global-variable';
+
+type Params = {
+  stepId: string;
+  key: string;
+  parameters: IJSONObject;
+};
+
+const getDynamicFields = async (
+  _parent: unknown,
+  params: Params,
+  context: Context
+) => {
+  const step = await context.currentUser
+    .$relatedQuery('steps')
+    .withGraphFetched({
+      connection: true,
+      flow: true,
+    })
+    .findById(params.stepId);
+
+  if (!step) return null;
+
+  const connection = step.connection;
+
+  if (!connection || !step.appKey) return null;
+
+  const app = await App.findOneByKey(step.appKey);
+  const $ = await globalVariable({ connection, app, flow: step.flow, step });
+
+  const command = app.dynamicFields.find(
+    (data: IDynamicFields) => data.key === params.key
+  );
+
+  for (const parameterKey in params.parameters) {
+    const parameterValue = params.parameters[parameterKey];
+    $.step.parameters[parameterKey] = parameterValue;
+  }
+
+  const existingArguments = await step.getSetupFields();
+  const remainingArguments = await command.run($);
+
+  if (remainingArguments.error) {
+    throw new Error(JSON.stringify(remainingArguments.error));
+  }
+
+  return [...existingArguments, ...remainingArguments.data];
+};
+
+export default getDynamicFields;