// Common parameter tests cover shared action gates and typed argument readers

// used by channel/tool adapters.

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

import {

createActionGate,

});

it("keeps partial parse behavior by default", () => {

// Some legacy channel tools pass identifiers with numeric prefixes; strict

// parsing is opt-in for new bounded fields.

const params = { messageId: "42abc" };

expect(readNumberParam(params, "messageId")).toBe(42);

});

// Cron flat-parameter tests cover model-friendly shorthand recovery before

// gateway cron RPC dispatch.

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

const { callGatewayToolMock } = vi.hoisted(() => ({

});

it("leaves out-of-range flat atMs for gateway validation", async () => {

// The gateway owns final schedule validation; flat recovery should preserve

// the supplied value instead of silently coercing an invalid date.

const tool = createCronTool(undefined, { callGatewayTool: callGatewayToolMock });

const invalidAtMs = 8_640_000_000_000_001;

// Cron tool schema tests cover the provider-facing parameter shape and runtime

// validation compatibility for cron jobs.

import { Value } from "typebox/value";

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

import { normalizeToolParameterSchema } from "../agent-tools.schema.js";

});

it("describes cron expressions as local wall-clock time in the supplied timezone", () => {

// Cron expressions are interpreted by the gateway scheduler; model-facing

// docs must not encourage UTC conversion by the agent.

const jobExpr = propertyAt(schemaRecord, "job.schedule.expr");

const patchExpr = propertyAt(schemaRecord, "patch.schedule.expr");

const jobTz = propertyAt(schemaRecord, "job.schedule.tz");

// Goal tool tests cover goal accounting projection and correct session-store

// routing for global and scoped sessions.

import fs from "node:fs/promises";

import os from "node:os";

import path from "node:path";

describe("goal tools", () => {

it("keeps get_goal read-only when accounting changes are projected", async () => {

// Budget-limited status can be derived for display without mutating the

// stored active goal record.

const { config, template } = await createStoreConfig();

const storePath = resolveStorePath(template, { agentId: "research" });

await upsertSessionEntry({

// Background media generation tests cover detached task completion, requester

// wake delivery, and direct media fallback behavior.

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

const subagentAnnounceDeliveryMocks = vi.hoisted(() => ({

describe("scheduleMediaGenerationTaskCompletion", () => {

it("keeps a generated media task active until completion delivery finishes", async () => {

// Mark completion only after the requester wake has been attempted; otherwise

// task status can say done before the visible media reaches the requester.

const order: string[] = [];

const scheduled: Array<() => Promise<void>> = [];

const completeTaskRun = vi.fn(() => {

});

it("does not direct-deliver generated media after requester abandonment", async () => {

// Abandoned requester sessions are terminal; direct delivery would re-open a

// conversation the task lifecycle already decided to stop.

subagentAnnounceDeliveryMocks.deliverSubagentAnnouncement.mockResolvedValueOnce({

delivered: false,

path: "none",

// Shared media tool tests cover root separation, provider availability, and

// model-registry normalization for generation/understanding tools.

import path from "node:path";

import { pathToFileURL } from "node:url";

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

});

it("keeps channel inbound attachment roots separate from local roots", () => {

// Inbound channel roots may include broad chat attachment folders; keep them

// out of local filesystem allowlists unless the channel context asks.

const accountRoot = path.join("/tmp", "openclaw-imessage-work");

const sharedRoot = path.join("/tmp", "openclaw-imessage-shared");

const cfg = {

});

it("falls back to provider-prefixed custom model IDs", () => {

// Custom providers can store ids with provider prefixes; try both forms so

// callers can pass the short local model id.

const foundModel = { provider: "kimchi", id: "kimchi/claude-opus-4-6" };

const { calls, registry } = createModelRegistryStub((_, modelId) =>

modelId === "kimchi/claude-opus-4-6" ? foundModel : null,

// Music generation status tests cover duplicate guards and explicit status

// actions for background music tasks.

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

import * as musicGenerationRuntime from "../../music-generation/runtime.js";

import {

});

it("returns active task status instead of starting a duplicate generation", () => {

// Duplicate guard responses prevent agents from launching parallel provider

// jobs while a matching request is still running.

taskRuntimeInternalMocks.listTasksForOwnerKey.mockReturnValue([

{

taskId: "task-active",

// Video generation status tests cover duplicate guards and explicit status

// actions for background video tasks.

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

import * as videoGenerationRuntime from "../../video-generation/runtime.js";

import {

});

it("returns recent succeeded video status instead of starting a duplicate generation", () => {

// A recently completed request is still a duplicate from the user's

// perspective; report status instead of spending another provider call.

const now = Date.now();

recordRecentMediaGenerationTaskStartForSession({

sessionKey: "agent:main:discord:direct:123",