Function registerCrystallizeFunction

src/functions/crystallize.ts:18–229

(
  sdk: ISdk,
  kv: StateKV,
  provider: MemoryProvider,
)

Return as JSON: { "narrative": "...", "keyOutcomes": ["..."], "filesAffected": ["..."], "lessons": ["..."] }`;

export function registerCrystallizeFunction(
  sdk: ISdk,
  kv: StateKV,
  provider: MemoryProvider,
): void {
  sdk.registerFunction("mem::crystallize", 
    async (data: {
      actionIds: string[];
      sessionId?: string;
      project?: string;
    }) => {
      if (!data.actionIds || data.actionIds.length === 0) {
        return { success: false, error: "actionIds is required" };
      }

      const actions: Action[] = [];
      for (const id of data.actionIds) {
        const action = await kv.get<Action>(KV.actions, id);
        if (!action) {
          return { success: false, error: `action not found: ${id}` };
        }
        if (action.status !== "done" && action.status !== "cancelled") {
          return {
            success: false,
            error: `action ${id} has status "${action.status}", expected "done" or "cancelled"`,
          };
        }
        actions.push(action);
      }

      const allEdges = await kv.list<ActionEdge>(KV.actionEdges);
      const idSet = new Set(data.actionIds);
      const relevantEdges = allEdges.filter(
        (e) => idSet.has(e.sourceActionId) || idSet.has(e.targetActionId),
      );

      const prompt = buildChainText(actions, relevantEdges);

      try {
        const response = await provider.summarize(CRYSTALLIZE_SYSTEM, prompt);
        const digest = parseDigest(response);

        const crystal: Crystal = {
          id: generateId("crys"),
          narrative: digest.narrative,
          keyOutcomes: digest.keyOutcomes,
          filesAffected: digest.filesAffected,
          lessons: digest.lessons,
          sourceActionIds: data.actionIds,
          sessionId: data.sessionId,
          project: data.project,
          createdAt: new Date().toISOString(),
        };

        await kv.set(KV.crystals, crystal.id, crystal);

        await Promise.all(
          digest.lessons.map((lesson) =>