// Tool summary metadata tests cover canvas actions and shouldEmitToolResult

// overrides in subscribed embedded sessions.

import { describe, expect, it, vi } from "vitest";

import { createSubscribedSessionHarness } from "./embedded-agent-subscribe.e2e-harness.js";

describe("subscribeEmbeddedAgentSession", () => {

it("includes canvas action metadata in tool summaries", async () => {

// Canvas actions need their JSONL path in summaries so users can inspect the

// generated artifact without verbose tool output.

const onToolResult = vi.fn();

const toolHarness = createSubscribedSessionHarness({

// AssistantTexts final-answer tests ensure reasoning-mode subscriptions keep

// stored assistant text aligned to the final answer when block replies are off.

import { describe, expect, it, vi } from "vitest";

import {

createReasoningFinalAnswerMessage,

expect(subscription.assistantTexts).toEqual(["Final answer"]);

});

it("suppresses partial replies when reasoning is enabled and block replies are disabled", () => {

// With reasoning enabled, streamed draft text stays private until the final

// message_end answer is available.

const { session, emit } = createStubSessionHarness();

const onPartialReply = vi.fn();

// Fenced block chunking tests ensure indented and longer Markdown fences remain

// intact when paragraph block replies are split.

import { describe, expect, it, vi } from "vitest";

import {

createParagraphChunkedBlockReplyHarness,

describe("subscribeEmbeddedAgentSession", () => {

it("keeps indented fenced blocks intact", () => {

// Indented fences are still code blocks for block-reply chunking and should

// not be split into malformed fragments.

const onBlockReply = vi.fn();

const { emit } = createParagraphChunkedBlockReplyHarness({

onBlockReply,

// Fenced block reopen tests cover safe Markdown chunking when code fences are

// too long to fit in one block reply.

import { describe, expect, it, vi } from "vitest";

import {

createParagraphChunkedBlockReplyHarness,

describe("subscribeEmbeddedAgentSession", () => {

it("reopens fenced blocks when splitting inside them", () => {

// Oversized code blocks are split with reopened fences so every emitted

// chunk remains valid Markdown.

const onBlockReply = vi.fn();

const { emit } = createParagraphChunkedBlockReplyHarness({

onBlockReply,

// Long fenced block and compaction retry tests cover Markdown-safe chunking and

// subscription state reset around automatic compaction retries.

import type { AssistantMessage } from "openclaw/plugin-sdk/llm";

import { describe, expect, it, vi } from "vitest";

import {

expectFencedChunks(onBlockReply.mock.calls, "```json");

});

it("waits for auto-compaction retry and clears buffered text", async () => {

// A retrying compaction invalidates any assistant text buffered from the

// failed attempt; waiters resolve only after the retry path reaches agent_end.

const listeners: SessionEventHandler[] = [];

const session = {

subscribe: (listener: SessionEventHandler) => {

});

it("resets assistant usage to a zero snapshot after compaction without retry", () => {

// When compaction ends the active assistant message is synthetic, so usage

// should reset to a zero snapshot instead of carrying stale token totals.

const listeners: SessionEventHandler[] = [];

const session = {

messages: [