Method startWorkflow

backend/src/temporal/temporal.service.ts:115–145

(options: StartWorkflowOptions)

  }

  async startWorkflow(options: StartWorkflowOptions): Promise<WorkflowStartResult> {
    const client = await this.getClient();
    const workflowId = options.workflowId ?? `shipsec-workflow-${randomUUID()}`;
    const taskQueue = options.taskQueue ?? this.defaultTaskQueue;

    const argsSummary = this.formatArgsSummary(options.args);
    this.logger.log(
      `Starting Temporal workflow ${options.workflowType} (workflowId=${workflowId}, taskQueue=${taskQueue}, args=${argsSummary})`,
    );

    // Map workflow type string to function reference
    const workflowFn = this.getWorkflowFunction(options.workflowType);

    const handle = await client.start(workflowFn, {
      workflowId,
      taskQueue,
      args: (options.args ?? []) as any,
      memo: options.memo,
      searchAttributes: options.searchAttributes as any,
    });

    this.logger.log(
      `Started Temporal workflow ${handle.workflowId} (run ${handle.firstExecutionRunId})`,
    );

    return {
      workflowId: handle.workflowId,
      runId: handle.firstExecutionRunId,
      taskQueue,
    };
  }

  private getWorkflowFunction(workflowType: string) {
    switch (workflowType) {