Function main

worker/scripts/workflow-runner.ts:179–223

()

}

async function main() {
  const { workflowRecordId, fileId, limit, shouldRun, list } = parseArgs();

  const __dirname = dirname(fileURLToPath(import.meta.url));
  config({ path: join(__dirname, '..', '.env') });

  const pool = new Pool({
    connectionString:
      process.env.DATABASE_URL ?? 'postgresql://shipsec:shipsec@localhost:5433/shipsec',
  });

  const definition = await loadDefinition(pool, workflowRecordId);

  const address = process.env.TEMPORAL_ADDRESS ?? 'localhost:7233';
  const namespace = process.env.TEMPORAL_NAMESPACE ?? 'shipsec-dev';

  const connection = await Connection.connect({ address });
  const client = new Client({ connection, namespace });

  try {
    if (list) {
      const runs = await listRuns(client, workflowRecordId, definition, limit);
      console.log('--- Existing Runs ---');
      if (runs.length === 0) {
        console.log('No runs found for workflow', workflowRecordId);
      } else {
        for (const run of runs) {
          console.log(JSON.stringify(run, null, 2));
        }
      }
      console.log('---------------------');
    }

    if (shouldRun && fileId) {
      console.log('Starting new workflow run...');
      const { runId, result } = await runWorkflow(client, definition, workflowRecordId, fileId);
      console.log('--- New Run Result ---');
      console.log(JSON.stringify({ runId, result }, null, 2));
      console.log('----------------------');
    }
  } finally {
    await connection.close();
    await pool.end();
  }
}

main().catch((error) => {
  console.error(error);