Contract Analysis

import { Anyformat, Schema } from "@anyformat/sdk";

const af = new Anyformat({ apiKey: process.env.ANYFORMAT_API_KEY! });

// 1. Build the workflow — the typed graph is assembled by the fluent builder.
const builder = af
  .workflow("Contract Analyzer", "Extract key terms and clauses from contracts")
  .parse()
  .extract([
    Schema.enum("contract_type", "The type of legal agreement", [
      Schema.option("nda",               "Non-disclosure agreement"),
      Schema.option("service_agreement", "Service or consulting agreement"),
      Schema.option("employment",        "Employment contract"),
      Schema.option("lease",             "Lease or rental agreement"),
      Schema.option("partnership",       "Partnership agreement"),
      Schema.option("licensing",         "Licensing agreement"),
    ]),
    Schema.date("effective_date",            "Date the contract takes effect"),
    Schema.date("expiration_date",           "Date the contract expires or terminates"),
    Schema.boolean("auto_renewal",           "Whether the contract automatically renews at expiration"),
    Schema.string("governing_law",           "State or jurisdiction whose laws govern this contract"),
    Schema.integer("termination_notice_days","Number of days advance notice required to terminate"),
    Schema.multiSelect("key_clauses", "Standard contract clauses present in this agreement", [
      Schema.option("confidentiality",         "Confidentiality or NDA clause"),
      Schema.option("non_compete",             "Non-compete restriction"),
      Schema.option("indemnification",         "Indemnification or hold-harmless clause"),
      Schema.option("limitation_of_liability", "Cap on damages or liability"),
      Schema.option("force_majeure",           "Force majeure or act-of-God clause"),
      Schema.option("arbitration",             "Mandatory arbitration clause"),
      Schema.option("intellectual_property",   "IP ownership or assignment clause"),
      Schema.option("non_solicitation",        "Non-solicitation of employees or clients"),
    ]),
    Schema.float("liability_cap", "Maximum liability amount in dollars, if a cap is specified"),
  ]);

// 2. Create the workflow + a webhook (one-time setup). Webhook endpoints
//    aren't on the SDK surface yet — call them via fetch and store the secret.
const workflow = await builder.create();

const webhookResponse = await fetch("https://api.anyformat.ai/v2/webhooks/", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.ANYFORMAT_API_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    url: "https://your-server.com/webhooks/anyformat",
    events: ["extraction.completed", "extraction.failed"],
  }),
});
const webhook = await webhookResponse.json();
// STORE webhook.secret securely — it is only returned once.

// 3. Submit each contract against the existing workflow handle. Skip .wait()
//    — the webhook delivers the result.
const file: File = /* a File with .name set, e.g. new File([bytes], "contract.pdf") */;
const run = await workflow.run(file);
console.log(`Submitted ${run.id}; waiting for webhook…`);

import os
import httpx
from anyformat.sdk import Client
from anyformat.workflow import Schema

api_key = os.environ["ANYFORMAT_API_KEY"]
client = Client(api_key=api_key)

# 1. Create the workflow (once)
workflow = (
    client.workflow("Contract Analyzer")
    .parse()
    .extract([
        Schema.enum("contract_type", "The type of legal agreement", options=[
            Schema.option("nda",               "Non-disclosure agreement"),
            Schema.option("service_agreement", "Service or consulting agreement"),
            Schema.option("employment",        "Employment contract"),
            Schema.option("lease",             "Lease or rental agreement"),
            Schema.option("partnership",       "Partnership agreement"),
            Schema.option("licensing",         "Licensing agreement"),
        ]),
        Schema.date("effective_date",            "Date the contract takes effect"),
        Schema.date("expiration_date",           "Date the contract expires or terminates"),
        Schema.boolean("auto_renewal",           "Whether the contract automatically renews at expiration"),
        Schema.string("governing_law",           "State or jurisdiction whose laws govern this contract"),
        Schema.integer("termination_notice_days","Number of days advance notice required to terminate"),
        Schema.multi_select("key_clauses", "Standard contract clauses present in this agreement", options=[
            Schema.option("confidentiality",         "Confidentiality or NDA clause"),
            Schema.option("non_compete",             "Non-compete restriction"),
            Schema.option("indemnification",         "Indemnification or hold-harmless clause"),
            Schema.option("limitation_of_liability", "Cap on damages or liability"),
            Schema.option("force_majeure",           "Force majeure or act-of-God clause"),
            Schema.option("arbitration",             "Mandatory arbitration clause"),
            Schema.option("intellectual_property",   "IP ownership or assignment clause"),
            Schema.option("non_solicitation",        "Non-solicitation of employees or clients"),
        ]),
        Schema.float("liability_cap", "Maximum liability amount in dollars, if a cap is specified"),
    ])
    .create()
)

# 2. Register a webhook (once). Webhook endpoints aren't on the SDK surface
#    yet — call them via httpx and store the returned secret.
webhook = httpx.post(
    "https://api.anyformat.ai/v2/webhooks/",
    headers={"Authorization": f"Bearer {api_key}"},
    json={
        "url": "https://your-server.com/webhooks/anyformat",
        "events": ["extraction.completed", "extraction.failed"],
    },
).json()
# STORE webhook["secret"] securely — it is only returned once.

# 3. Submit each contract. Skip .wait() — the webhook will fire when done.
workflow.run("contract.pdf")