create-workflow.ts

import { SimplexClient, Action, Variable, StructuredOutput } from 'simplex-ts';
import * as dotenv from 'dotenv';
import * as path from 'path';
import * as fs from 'fs';

dotenv.config({ path: path.resolve(__dirname, '.env') });

const WORKFLOW_ID_FILE = path.resolve(__dirname, 'workflow-id.txt');

async function createWorkflow(client: SimplexClient): Promise<string> {
  console.log('=== Creating Workflow ===\n');

  const variables: Variable[] = [
    {
      name: 'patient_info',
      type: 'object',
      required: true,
      description: 'Patient demographic information'
    },
    {
      name: 'procedure_info',
      type: 'object',
      required: true,
      description: 'Procedure details'
    }
  ];

  const structuredOutput: StructuredOutput[] = [
    {
      name: 'authorization_number',
      type: 'string',
      description: 'The prior authorization number received after submission'
    },
    {
      name: 'submission_status',
      type: 'enum',
      enumValues: ['approved', 'pending', 'denied', 'requires_additional_info'],
      description: 'The status of the prior authorization submission'
    },
    {
      name: 'confirmation_code',
      type: 'string',
      description: 'Any confirmation or reference code provided by the system'
    },
    {
      name: 'file_downloaded',
      type: 'boolean',
      description: 'Whether a file was successfully downloaded'
    },
    {
      name: 'urgency_level',
      type: 'enum',
      enumValues: ['routine', 'urgent', 'emergent'],
      description: 'The urgency level assigned to the authorization request'
    }
  ];

  const actions: Action[] = [
    {
      function: 'run_beta_agent',
      params: {
        prompt: 'Read the information on the page.'
      },
      options: {}
    }
  ];

  const workflow = await client.workflows.create({
    name: 'Prior Authorization Submission Page',
    url: 'https://simplex.sh/authorization-result.html',
    actions: actions,
    variables: variables,
    structured_output: structuredOutput,
    metadata: JSON.stringify({ portal: 'Carelon' })
  });

  console.log('Workflow created:');
  console.log(`  ID: ${workflow.id}`);
  console.log(`  Name: ${workflow.name}`);

  if (workflow.structured_output && workflow.structured_output.length > 0) {
    console.log('\n  Structured Output Fields:');
    workflow.structured_output.forEach(field => {
      if (field.type === 'enum' && field.enumValues) {
        console.log(`    - ${field.name} (enum: [${field.enumValues.join(', ')}]): ${field.description}`);
      } else {
        console.log(`    - ${field.name} (${field.type}): ${field.description}`);
      }
    });
  }
  console.log();

  return workflow.id;
}

async function main() {
  const apiKey = process.env.SIMPLEX_API_KEY;
  if (!apiKey) {
    console.error('Please set SIMPLEX_API_KEY in .env');
    process.exit(1);
  }

  const client = new SimplexClient({ apiKey });

  try {
    const workflowId = await createWorkflow(client);
    fs.writeFileSync(WORKFLOW_ID_FILE, workflowId);
    console.log(`Workflow ID saved to: ${WORKFLOW_ID_FILE}`);
  } catch (error: unknown) {
    const err = error as { message: string; statusCode?: number; data?: unknown };
    console.error('Error:', err.message);
    if (err.statusCode) {
      console.error('Status:', err.statusCode);
    }
    if (err.data) {
      console.error('Details:', JSON.stringify(err.data, null, 2));
    }
  }
}

main().catch(console.error);