서버 계약

// lib/brandapp-server.ts
import "server-only";

import { createLazySDK } from "@reopt-ai/brandapp-sdk";
import { createBrandappProvider } from "@reopt-ai/brandapp-sdk/ai-provider";

function requireEnv(name: string) {
  const value = process.env[name];
  if (!value) throw new Error(name + " is required");
  return value;
}

function getBrandappConfig() {
  return {
    clientId: requireEnv("BRANDAPP_CLIENT_ID"),
    clientSecret: requireEnv("BRANDAPP_CLIENT_SECRET"),
    brandappId: requireEnv("BRANDAPP_ID"),
  };
}

// 첫 접근 때 초기화되는 SDK 싱글턴 — module scope에서 env를 읽지 않습니다.
const sdk = createLazySDK(getBrandappConfig);

export function getBrandappSDK() {
  return sdk;
}

let provider: ReturnType<typeof createBrandappProvider> | null = null;

export function getBrandappProvider() {
  provider ??= createBrandappProvider(getBrandappConfig());
  return provider;
}

// app/api/chat/route.ts
import { APICallError } from "@ai-sdk/provider";
import {
  isCreditLimitError,
  isModelAccessError,
} from "@reopt-ai/brandapp-sdk";
import {
  convertToModelMessages,
  createUIMessageStreamResponse,
  streamText,
  toUIMessageStream,
} from "ai";

import { getBrandappProvider } from "@/lib/brandapp-server";

export async function POST(req: Request) {
  const { messages, model, agentId } = await req.json();
  const brandapp = getBrandappProvider();

  const result = streamText({
    model: brandapp(model ?? "anthropic/claude-haiku-4.5"),
    messages: await convertToModelMessages(messages),
    // agentId는 BrandApp agent routing 정책에 맞게 route에서 해석합니다.
  });

  return createUIMessageStreamResponse({
    stream: toUIMessageStream({
      stream: result.stream,
      onError: (error) => {
        const cause = APICallError.isInstance(error) ? error.cause : error;
        if (isCreditLimitError(cause)) return "AI 크레딧을 모두 사용했습니다.";
        if (isModelAccessError(cause)) {
          return "현재 플랜에서 사용할 수 없는 모델입니다.";
        }
        return cause instanceof Error
          ? cause.message
          : "생성 중 오류가 발생했습니다.";
      },
    }),
  });
}

// app/api/brandapp-models/route.ts
import type { ReoptAiModelsResponse } from "@/components/reopt-ai-chat";
import { getBrandappSDK } from "@/lib/brandapp-server";

export async function GET() {
  const sdk = getBrandappSDK();
  const models = await sdk.ai.models();

  // Surface가 export하는 응답 계약 타입으로 shape를 고정합니다.
  const body: ReoptAiModelsResponse = models
    .filter((model) => model.modality === "chat")
    .sort((a, b) => Number(b.isDefault) - Number(a.isDefault))
    .map((model) => ({
      id: model.id,
      label: model.displayName,
      description: model.description,
      provider: model.provider,
      ...(model.isDefault ? { badge: "기본" } : {}),
    }));

  return Response.json(body);
}

// app/api/brandapp-image/route.ts
import { isReoptSDKError } from "@reopt-ai/brandapp-sdk";

import type {
  ReoptImageGenerateRequest,
  ReoptImageGenerateResponse,
} from "@/components/reopt-ai-image-studio";
import { getBrandappSDK } from "@/lib/brandapp-server";

export async function POST(req: Request) {
  const sdk = getBrandappSDK();
  const body = (await req.json()) as ReoptImageGenerateRequest;

  try {
    const result: ReoptImageGenerateResponse = await sdk.ai.generateImage(body);
    return Response.json(result);
  } catch (error) {
    if (isReoptSDKError(error)) {
      return Response.json(
        { error: { code: error.code, message: error.message } },
        { status: error.status },
      );
    }
    throw error;
  }
}

// app/api/brandapp-records/route.ts
import type { ReoptRecordsResponse } from "@/components/reopt-record-table";
import { getBrandappSDK } from "@/lib/brandapp-server";

export async function GET(req: Request) {
  const sdk = getBrandappSDK();
  const { searchParams } = new URL(req.url);
  const entityId = searchParams.get("entityId");
  if (!entityId) return Response.json({ records: [] });

  // list limit은 최대 100. record.values는 attribute id 키입니다.
  const [entity, result] = await Promise.all([
    sdk.eav.entities.get(entityId),
    sdk.eav.records.list(entityId, {
      page: Number(searchParams.get("page") ?? 1),
      limit: 50,
    }),
  ]);

  const body: ReoptRecordsResponse = {
    ...result,
    // id → 라벨 맵을 함께 내려주면 자동 추론 컬럼 헤더가 읽기 쉬워집니다.
    attributeLabels: Object.fromEntries(
      entity.attributes.map((a) => [a.id, a.label ?? a.name]),
    ),
  };

  return Response.json(body);
}

// lib/protected-fetch.ts
import { withSessionExpiry } from "@/components/session-expired-dialog";

// 401을 받으면 notifySessionExpired()를 호출하는 fetch. 데이터 Surface의
// fetcher prop에 그대로 넘겨도 됩니다: <ReoptRecordTable fetcher={protectedFetch} />
export const protectedFetch = withSessionExpiry(fetch);