OpenAI

import { createFabric } from "@fabricorg/integrations";
import { openai } from "@fabricorg/integrations/plugins";

const fabric = createFabric({
  plugins: [openai({ apiKey: process.env.OPENAI_API_KEY })],
});

// Chat completion
const completion = await fabric.openai.api.chat.completions.create({
  model: "gpt-4o",
  messages: [
    { role: "system", content: "You are a helpful assistant." },
    { role: "user", content: "What is the capital of France?" },
  ],
});

// Embeddings
const { data: embeddings } = await fabric.openai.api.embeddings.create({
  model: "text-embedding-3-small",
  input: "The quick brown fox",
});

// Assistants flow
const thread = await fabric.openai.api.threads.create({
  messages: [{ role: "user", content: "Explain quantum computing" }],
});

const run = await fabric.openai.api.runs.create({
  threadId: thread.id,
  assistant_id: "asst_abc123",
});

// Poll until complete
let status = run.status;
while (status === "queued" || status === "in_progress") {
  await new Promise((r) => setTimeout(r, 1000));
  const updated = await fabric.openai.api.runs.get({
    threadId: thread.id,
    runId: run.id,
  });
  status = updated.status;
}

interface ChatCompletionMessage {
  role: "system" | "user" | "assistant" | "tool";
  content: string | null;
  name?: string;
  tool_call_id?: string;
  tool_calls?: Array<{
    id: string;
    type: "function";
    function: { name: string; arguments: string };
  }>;
}

interface ChatCompletion {
  id: string;
  object: "chat.completion";
  created: number;
  model: string;
  choices: Array<{
    index: number;
    message: ChatCompletionMessage;
    finish_reason: string | null;
  }>;
  usage?: {
    prompt_tokens: number;
    completion_tokens: number;
    total_tokens: number;
  };
}

interface Embedding {
  object: "embedding";
  embedding: number[];
  index: number;
}

interface AssistantThread {
  id: string;
  object: "thread";
  created_at: number;
  metadata?: Record<string, string>;
}

interface AssistantMessage {
  id: string;
  object: "thread.message";
  thread_id: string;
  role: "user" | "assistant";
  content: Array<{ type: string; text?: { value: string } }>;
  created_at: number;
}

interface AssistantRun {
  id: string;
  object: "thread.run";
  thread_id: string;
  assistant_id: string;
  status: "queued" | "in_progress" | "requires_action" | "cancelling" | "cancelled" | "failed" | "completed" | "expired";
  created_at: number;
  required_action?: {
    type: "submit_tool_outputs";
    submit_tool_outputs: {
      tool_calls: Array<{
        id: string;
        type: "function";
        function: { name: string; arguments: string };
      }>;
    };
  };
}