部署別コパイロット（ロジスティクス）

type Department = 'finance' | 'dispatch' | 'warehouse' | 'fleet';

const departmentUserId = (dept: Department) => `dept-${dept}`;
// "dept-finance", "dept-dispatch", "dept-warehouse", "dept-fleet"

// server/departments.ts
interface DeptSpec {
  label: string;
  connectors: string[]; // カタログの slug
}

export const DEPARTMENTS: Record<Department, DeptSpec> = {
  finance:   { label: '財務',     connectors: ['netsuite', 'stripe', 'gmail'] },
  dispatch:  { label: '配車',     connectors: ['sap', 'slack', 'google-sheets'] },
  warehouse: { label: '倉庫',     connectors: ['wms', 'google-sheets', 'jira'] },
  fleet:     { label: '車両運用', connectors: ['telematics', 'servicemax', 'slack'] },
};

import { vinkius } from './vinkius';
import { DEPARTMENTS, type Department } from './departments';

async function bootstrapDepartment(dept: Department) {
  const user = vinkius.user(`dept-${dept}`);

  // 後でフィルタ/監査できるように、非機密のメタデータを添付する
  await user.ensure({ kind: 'department', label: DEPARTMENTS[dept].label });

  for (const slug of DEPARTMENTS[dept].connectors) {
    const connector = user.connector(slug);
    await connector.connect();
    // api_key コネクター: connector.credentials.set({ API_KEY: ... })
    // oauth コネクター: connect() はプロバイダーの同意後に戻ってくる
  }

  // コネクターごとの準備状況を報告し、管理者は認証情報がまだ足りないものを見つけられるようにする
  return Promise.all(
    DEPARTMENTS[dept].connectors.map(async (slug) => ({
      slug,
      status: await user.connector(slug).status(),
    })),
  );
}

async function departmentCapabilities(dept: Department) {
  const spec = DEPARTMENTS[dept];
  return vinkius.user(`dept-${dept}`).capabilities({
    include: spec.connectors,
    onConnectorError: (slug, error) => {
      // 管理者に表示する。応答を中断しない
      console.warn(`${dept}/${slug}`, (error as Error).message);
    },
  });
}

// server/copilot.ts
import OpenAI from 'openai';
import { toOpenAITools, runOpenAIToolCall } from '@vinkius/connect/openai';
import { type Department } from './departments';
import { departmentCapabilities } from './capabilities';

const openai = new OpenAI({ apiKey: process.env.OPENAI_API_KEY! });

const SYSTEM_PROMPT: Record<Department, string> = {
  finance: 'あなたは財務のコパイロットです。接続済みの会計ツールを使って請求書を照合し、請求に関する質問に答えてください。',
  dispatch: 'あなたは配車コパイロットです。積載の所在地を答え、TMS と Slack を使って ETA を更新してください。',
  warehouse: 'あなたは倉庫コパイロットです。WMS とスプレッドシートを使ってバースの数量と未完了タスクを報告してください。',
  fleet: 'あなたは車両運用のコパイロットです。テレマティクスと ServiceMax を使って車両の健康状態と整備状況を報告してください。',
};

export async function ask(dept: Department, question: string) {
  const capabilities = await departmentCapabilities(dept);

  const completion = await openai.chat.completions.create({
    model: '[MODEL_ID]',
    messages: [
      { role: 'system', content: SYSTEM_PROMPT[dept] },
      { role: 'user', content: question },
    ],
    tools: toOpenAITools(capabilities),
  });

  const call = completion.choices[0]?.message.tool_calls?.[0];
  if (!call) return { answer: completion.choices[0].message.content };

  const result = await runOpenAIToolCall(capabilities, call); // この部署として実行される
  return { answer: result.content, tool: call.function.name };
}

// 配車は自分の TMS について質問する。財務の NetSuite には到達できない。
await ask('dispatch', '積載 4412 の ETA はいつで、どのドライバーが担当ですか?');
await ask('finance', '30 日を超える顧客請求書のうち、今月もまだ未処理のものはどれですか?');

async function askAs(dept: Department, operator: string, question: string) {
  const answer = await ask(dept, question);
  // 自前の監査ストア — SDK はオペレーターを一切見ない
  await audit.record({
    actor: operator,
    on_behalf_of: `dept-${dept}`,
    question,
  });
  return answer;
}

async function retireConnector(dept: Department, slug: string) {
  await vinkius.user(`dept-${dept}`).connector(slug).disconnect();
}

// 集約済みセットから:
const sheetsOnly = capabilities.forConnector('google-sheets');

// もしくはすべての接続を列挙すること自体を避ける:
const tmsOnly = await vinkius.user(`dept-${dept}`).connector('sap').capabilities();

const profile = await vinkius.user('dept-finance').get();
console.log(profile.metadata); // { kind: 'department', label: '財務' }
console.log(profile.status);   // active | ...