Insurance Application Processing Pipeline: Overview

import { createApplicationPipeline } from "@claritylabs/cl-sdk";

const pipeline = createApplicationPipeline({
  generateText,
  generateObject,
  applicationStore,
  documentStore,
  memoryStore,
  orgContext: [
    { key: "company_name", value: "Acme Corp", category: "company_info" },
    { key: "company_address", value: "123 Main St", category: "company_info" },
  ],
});

// Process a new application PDF
const { state } = await pipeline.processApplication({
  pdfBase64: "...",
  applicationId: "app-123",
  sourceSpans,
});

// Generate the outbound email for the current batch of questions
const { text: emailBody } = await pipeline.generateCurrentBatchEmail("app-123");

// Process the client's reply
const { fieldsFilled, responseText } = await pipeline.processReply({
  applicationId: "app-123",
  replyText: "1. Yes\n2. $1,000,000\n3. Check our website",
});

classifying → extracting → auto_filling → batching → collecting
    → confirming → mapping → packet_ready / submitted / complete

import {
  extractQuestionGraphFromFields,
  getActiveApplicationFields,
  planNextApplicationQuestions,
} from "@claritylabs/cl-sdk";

// Build a dependency graph from the extracted fields
const graph = extractQuestionGraphFromFields(state.fields, {
  id: "template-1:graph",
  title: state.title,
});

// Plan the next set of questions based on current fill state
const next = planNextApplicationQuestions({
  ...state,
  questionGraph: graph,
});