We run the AI stack. You focus on customers.

import { DataClient } from "@schift-io/sdk";

const apiKey = process.env.SCHIFT_API_KEY!;
const data = new DataClient({ apiKey });

// Append: rows are queryable as they land, then compacted into Parquet
await data.put("custom/app-events", [
  { user_id: "u_42", event: "checkout", latency_ms: 184 },
]);

// Read: filter and range conditions, right away
const rows = await data.search("custom/app-events", {
  where: { event: "checkout", latency_ms: { gte: 150 } },
});

import { VectorClient } from "@schift-io/sdk";

const apiKey = process.env.SCHIFT_API_KEY!;
const vectors = new VectorClient({ apiKey });
const model = "your-embedding-model"; // embedding: number[] from that model

// Upsert: each vector space checks its dimension and model
await vectors.upsert("custom/support-docs", [
  { id: "refund-policy", text: "Refunds within 14 days", vectors: { text: embedding } },
], { models: { text: model } });

// Search: nearest records with scores
const { hits } = await vectors.search("custom/support-docs", {
  queryVector: queryEmbedding,
  topK: 5,
});

import { readFile } from "node:fs/promises";
import { StructifyClient } from "@schift-io/sdk/structify";

const docs = new StructifyClient({ gatewayUrl: "https://gw.schift.io" });

// Send a PDF and a schema
const result = await docs.structify({
  file: await readFile("invoice.pdf"),
  schema: {
    type: "object",
    properties: { vendor: { type: "string" }, total: { type: "number" } },
  },
});
// Every field returns a value, a confidence and its source block

import { ObserverClient } from "@schift-io/context";

const observer = new ObserverClient(); // SCHIFT_OBSERVER_API_KEY
const run = observer.startRun({
  agentId: "support-agent", sessionId, model: "gpt-4.1-mini", provider: "openai",
});

// Record the context your agent picked and each model turn
run.recordSelection(true, { srn: "srn:document:refund-policy" });
run.record("model_turn", { tokenUsage: 2210, latencyMs: 930 });

// The session timeline lands in the console
run.endRun({ status: "completed" });
await observer.close();