Function main

worker/src/temporal/workers/dev.worker.ts:79–399

()

}

async function main() {
  const address = process.env.TEMPORAL_ADDRESS ?? 'localhost:7233';
  const taskQueue = process.env.TEMPORAL_TASK_QUEUE ?? 'shipsec-default';
  const namespace = process.env.TEMPORAL_NAMESPACE ?? 'shipsec-dev';
  const workflowsPath = join(dirname(fileURLToPath(import.meta.url)), '../workflows');

  console.log(`🔌 Connecting to Temporal at ${address}...`);
  console.log(`📋 Worker Configuration:`);
  console.log(`   - Address: ${address}`);
  console.log(`   - Namespace: ${namespace}`);
  console.log(`   - Task Queue: ${taskQueue}`);
  console.log(`   - Workflows Path: ${workflowsPath}`);
  console.log(`   - Node ENV: ${process.env.NODE_ENV}`);

  // Create connection first
  console.log(`🔗 Establishing connection to Temporal...`);
  const connection = await NativeConnection.connect({
    address,
  });

  console.log(`✅ Connected to Temporal at ${address}`);

  await ensureTemporalNamespace(connection, namespace);

  // Initialize database connection for worker
  const connectionString = process.env.DATABASE_URL;
  if (!connectionString) {
    throw new ConfigurationError('DATABASE_URL is not set', {
      configKey: 'DATABASE_URL',
    });
  }
  const pool = new Pool({ connectionString });
  const db = drizzle(pool, { schema });
  console.log(`✅ Connected to database`);

  // Initialize MinIO client
  const minioEndpoint = process.env.MINIO_ENDPOINT ?? 'localhost';
  const minioPort = parseInt(process.env.MINIO_PORT ?? '9000', 10);
  const minioAccessKey = process.env.MINIO_ACCESS_KEY ?? 'minioadmin';
  const minioSecretKey = process.env.MINIO_SECRET_KEY ?? 'minioadmin';
  const minioUseSSL = process.env.MINIO_USE_SSL === 'true';
  const minioBucketName = process.env.MINIO_BUCKET_NAME ?? 'shipsec-files';

  const minioClient = new Client({
    endPoint: minioEndpoint,
    port: minioPort,
    useSSL: minioUseSSL,
    accessKey: minioAccessKey,
    secretKey: minioSecretKey,
  });

  console.log(`✅ Connected to MinIO at ${minioEndpoint}:${minioPort}`);

  // Create service adapters (implementing SDK interfaces)
  const storageAdapter = new FileStorageAdapter(minioClient, db, minioBucketName);
  const artifactAdapter = new ArtifactAdapter(minioClient, db, minioBucketName);
  const secretsAdapter = new SecretsAdapter(db);