AI 스트리밍

"use client";

import { useCalendarSuggestion } from "@reopt-ai/opt-calendar";

const ai = useCalendarSuggestion(store);
// { suggestion, start, approve, reject, refine, abort,
//   approveEntity, rejectEntity }

// NDJSON 패치 스트림을 격리된 shadow draft로 흘려보냄 (라이브 spec은 그대로)
await ai.start(patchStream);

// 승인 — draft 전체가 하나의 undo 엔트리로 라이브 store에 적용
ai.approve();

// 폐기 — draft를 버리고 라이브 spec 유지
ai.reject();

// 이어붙이기 — 기존 draft에 패치를 추가로 스트리밍
await ai.refine(morePatches);

// 진행 중 스트림 중단 (지금까지 받은 draft는 ready 상태로 유지)
ai.abort();

// CalendarSuggestion 형태
// {
//   status: "streaming" | "ready" | "error",
//   draftSpec: CalendarSpec,        // AI 변경이 반영된 draft
//   changedIds: ReadonlySet<string>, // "events/standup" 같은 키
//   patches: JsonPatchOp[],          // 누적 패치
//   error: Error | null,
//   appliedCount: number,            // 지금까지 적용된 op 수
// }

// draft를 그리드에 pending으로 오버레이 (라이브 spec은 불변)
<Calendar store={store} suggestion={ai.suggestion} timeZone="Asia/Seoul" />;

// 엔티티 단위 검토 — 리뷰 UI에 사용
ai.approveEntity({ container: "events", id: "standup" }); // 이 변경만 적용
ai.rejectEntity({ container: "events", id: "standup" }); // 이 변경만 되돌림

{"op":"add","path":"/availability/wk","value":{"id":"wk","name":"Working hours","timeZone":"Asia/Seoul","rules":[{"day":1,"start":"09:00","end":"18:00"},{"day":3,"start":"09:00","end":"18:00"}]}}
{"op":"add","path":"/eventTypes/sync30","value":{"id":"sync30","slug":"30min","title":"30 Minute Sync","durationMinutes":30,"availabilityId":"wk"}}
{"op":"add","path":"/events/standup","value":{"id":"standup","title":"Team Standup","start":"2026-07-06T09:00:00+09:00","end":"2026-07-06T09:15:00+09:00","rrule":"FREQ=WEEKLY;BYDAY=MO,TU,WE,TH,FR"}}
{"op":"replace","path":"/events/standup/start","value":"2026-07-06T09:30:00+09:00"}

import {
  StreamCompiler,
  normalizeCalendarPatchSource,
} from "@reopt-ai/opt-calendar";

// StreamCompiler — 부분 청크를 버퍼링하고 완전한 줄만 파싱
const compiler = new StreamCompiler();
const ops1 = compiler.feed('{"op":"replace","path":'); // [] — 불완전
const ops2 = compiler.feed('"/events/standup/start","value":"2026-07-06T09:30:00+09:00"}\n');
// → [{ op: "replace", path: "/events/standup/start", value: "..." }]
const remaining = compiler.flush(); // 남은 버퍼 flush + status "done"
compiler.appliedCount; // 파싱된 op 수

// normalizeCalendarPatchSource — 어떤 PatchSource든 배치 단위로 정규화
// PatchSource: ReadableStream<Uint8Array> (fetch body) | ReadableStream<string>
//            | AsyncIterable<string> | AsyncIterable<JsonPatchOp>
for await (const ops of normalizeCalendarPatchSource(source)) {
  store.applyPatch(ops);
}

import { defaultCalendarCatalog } from "@reopt-ai/opt-calendar";

// 모델에게 줄 시스템 프롬프트 (스펙 구조 + 스트리밍 규칙 + 예제)
const systemPrompt = defaultCalendarCatalog.prompt();
// → "# Calendar Schema\n## Entity Kinds\n..."

// Structured Output용 JSON Schema (5개 맵 + timeZone + version)
const jsonSchema = defaultCalendarCatalog.jsonSchema();
// → { $schema: "...", title: "CalendarSpec", ... }

// 기본 카탈로그가 다루는 종류:
// event / all-day-event / task / calendar / availability / event-type / booking
// validateAttrs(spec) 로 모든 엔티티를 스키마 대비 검증할 수 있습니다.

// app/api/calendar-ai/route.ts
import { createCalendarHandler } from "@reopt-ai/opt-calendar/server";
import { anthropic } from "@ai-sdk/anthropic";

export const POST = createCalendarHandler({
  model: anthropic("claude-sonnet-4-5"),
  timeZone: "Asia/Seoul",
  weekStartsOn: 1,
  // catalog?, systemContext?, maxTokens?, temperature?, now?
});

"use client";

import { useCalendarAI } from "@reopt-ai/opt-calendar/ai-sdk";

const ai = useCalendarAI({ store, api: "/api/calendar-ai" });

// 자연어 → 패치 → shadow draft
await ai.schedule("다음 주 화요일 오후 2시에 30분 팀 싱크 잡아줘");

// 선택 범위 편집 (selection + prompt → 패치)
await ai.edit("이 이벤트들을 1시간씩 미뤄줘", {
  type: "events",
  eventIds: ["standup"],
});

ai.approve(); // draft를 라이브에 적용

// 오버레이는 useCalendarSuggestion과 동일하게 동작
<Calendar store={store} suggestion={ai.suggestion} timeZone="Asia/Seoul" />;