Function queueAnnotationPrompt

src/plugin.ts:314–379

(sessionId: string, annotation: any)

}

async function queueAnnotationPrompt(sessionId: string, annotation: any): Promise<void> {
  if (!pluginClient) {
    setLastAnnotationStatus({ ok: false, sessionId, error: "No OpenCode client is available" });
    throw new Error("No OpenCode client is available");
  }

  setLastAnnotationStatus({
    ok: null,
    sessionId,
    phase: "received",
    commentLength: typeof annotation?.comment === "string" ? annotation.comment.length : 0,
  });

  let promptText = buildAnnotationPrompt(annotation);
  const screenshot = annotation?.screenshot;
  if (screenshot?.dataUrl) {
    mkdirSync(ANNOTATION_DIR, { recursive: true });
    const { mime, bytes } = decodeDataUrl(screenshot.dataUrl);
    const ext = mime === "image/jpeg" ? "jpg" : mime === "image/webp" ? "webp" : "png";
    const stem = sanitizeFileStem(annotation?.page?.title || annotation?.element?.tag || "annotation");
    const filePath = join(ANNOTATION_DIR, `${Date.now()}-${stem}.${ext}`);
    writeFileSync(filePath, bytes);
    promptText += `\n\nScreenshot: ${filePath}`;
  }

  const promptBody = { parts: [{ type: "text", text: promptText }] };

  if (typeof pluginClient?.session?.promptAsync === "function") {
    const response = await pluginClient.session.promptAsync({
      path: { id: sessionId },
      query: { directory: pluginDirectory },
      body: promptBody,
    });
    const data = unwrapClientResult(response, "session prompt");
    if (isExplicitFalse(data)) throw new Error("OpenCode rejected session prompt submission");
    setLastAnnotationStatus({ ok: true, sessionId, transport: "session.promptAsync", response: data ?? null });
    return;
  }

  if (typeof pluginClient?.session?.prompt === "function") {
    const response = await pluginClient.session.prompt({
      path: { id: sessionId },
      query: { directory: pluginDirectory },
      body: promptBody,
    });
    const data = unwrapClientResult(response, "session prompt");
    if (isExplicitFalse(data)) throw new Error("OpenCode rejected session prompt submission");
    setLastAnnotationStatus({ ok: true, sessionId, transport: "session.prompt", response: data ?? null });
    return;
  }

  const text = promptText;

  const appended = await pluginClient.tui.appendPrompt({
    query: { directory: pluginDirectory },
    body: { text },
  });
  const appendedData = unwrapClientResult(appended, "tui append prompt");