import type { ActiveRecord } from '@oinone/kunlun-engine';
import { http } from '@oinone/kunlun-service';

interface WorkflowTandemActionParams {
  workflowCode: string;
  model: string;
  modelDataList: ActiveRecord[];
}

export const executeWorkflowTandemMutation = async (
  params: WorkflowTandemActionParams,
  sessionPath?: string
): Promise<{ workflowCode?: string }> => {
  const mutation = `mutation{
    workflowTriggerTransientMutation {
      startWorkflow(
        data: {
          workflowCode: "${params.workflowCode}"
          model: "${params.model}"
          modelDataList: ${JSON.stringify(JSON.stringify(params.modelDataList))}
        }
      ) {
        workflowCode
      }
    }
  }`;
  const result = await http.mutate('workflow', mutation, {
    path: sessionPath
  });
  return result.data.workflowTriggerTransientMutation.startWorkflow;
};