Turning Business Workflows into Automated Systems with AI

┌─────────────┐     ┌─────────────┐     ┌─────────────┐
│   Trigger   │────▶│  Pipeline   │────▶│   Output    │
│  (Input)    │     │ (AI Logic)  │     │  (Action)   │
└─────────────┘     └─────────────┘     └─────────────┘
       │                   │                   │
       ▼                   ▼                   ▼
   Webhooks            Validation           Slack
   Emails              Enrichment           Email
   Forms               Classification       Database
   Uploads             Generation           API calls
   Schedules           Extraction           Documents

// lib/invoice-automation/extract.ts
import { generateObject } from "ai";
import { openai } from "@ai-sdk/openai";
import { z } from "zod";

const InvoiceSchema = z.object({
  vendor: z.object({
    name: z.string(),
    address: z.string().optional(),
    taxId: z.string().optional(),
  }),
  invoiceNumber: z.string(),
  invoiceDate: z.string(),
  dueDate: z.string().optional(),
  lineItems: z.array(
    z.object({
      description: z.string(),
      quantity: z.number(),
      unitPrice: z.number(),
      total: z.number(),
    })
  ),
  subtotal: z.number(),
  tax: z.number().optional(),
  total: z.number(),
  currency: z.string(),
});

export async function extractInvoiceData(pdfText: string) {
  const { object } = await generateObject({
    model: openai("gpt-4-turbo"),
    schema: InvoiceSchema,
    prompt: `Extract structured invoice data from this document:

${pdfText}

Be precise with numbers. If a field is unclear, make your best inference.`,
  });

  return object;
}

// lib/analytics/automation-metrics.ts
export async function getAutomationMetrics(automationId: string) {
  const metrics = {
    totalRuns: runs.length,
    successRate: runs.filter((r) => r.status === "success").length / runs.length,
    avgProcessingTime: average(runs.map((r) => r.processing_time_ms)),
    humanInterventionRate: runs.filter((r) => r.required_review).length / runs.length,
    estimatedTimeSaved: runs.length * MANUAL_TASK_MINUTES,
    estimatedCostSaved: runs.length * MANUAL_TASK_MINUTES * HOURLY_COST / 60,
  };

  return metrics;
}