return null;

}

export type AnthropicPayloadLogger = {

type AnthropicPayloadLogger = {

enabled: true;

wrapStreamFn: (streamFn: StreamFn) => StreamFn;

recordUsage: (messages: AgentMessage[], error?: unknown) => void;

});

}

export function createAnthropicVertexStreamFn(

projectId: string | undefined,

region: string,

baseURL?: string,

): StreamFn {

return loadAnthropicVertexStreamFacade().createAnthropicVertexStreamFn(

projectId,

region,

baseURL,

);

}

export function createAnthropicVertexStreamFnForModel(

model: { baseUrl?: string },

env: NodeJS.ProcessEnv = process.env,

import { stripHeartbeatToken } from "../auto-reply/heartbeat.js";

import { isSilentReplyText } from "../auto-reply/tokens.js";

export const TOOL_RESULT_REAL_CONVERSATION_LOOKBACK = 20;

const TOOL_RESULT_REAL_CONVERSATION_LOOKBACK = 20;

const NON_CONVERSATION_BLOCK_TYPES = new Set([

"toolCall",

"toolUse",

return nextLines.join("\n").replace(/\n*$/, "\n");

}

export function loadIdentityFromFile(identityPath: string): AgentIdentityFile | null {

function loadIdentityFromFile(identityPath: string): AgentIdentityFile | null {

try {

const content = fs.readFileSync(identityPath, "utf-8");

const parsed = parseIdentityMarkdown(content);

);

}

export function isOpenClawRuntimeContextCustomMessage(message: unknown): boolean {

function isOpenClawRuntimeContextCustomMessage(message: unknown): boolean {

if (!message || typeof message !== "object") {

return false;

}

return raw.replace(/\/+$/, "");

}

export function mergeProviderRequestHeaders(

function mergeProviderRequestHeaders(

...headerSets: Array<Record<string, string> | undefined>

): Record<string, string> | undefined {

let merged: Record<string, string> | undefined;

return undefined;

}

export function extractRequesterPeer(

function extractRequesterPeer(

channelId: string | undefined,

requesterTo: string | undefined,

): { peerId?: string; peerKind?: ChatType } {

return !hasSubagentRunEnded(entry) && !isStaleUnendedSubagentRun(entry, now);

}

export function isRecentlyEndedSubagentRun(

function isRecentlyEndedSubagentRun(

entry: Pick<SubagentRunRecord, "endedAt">,

now = Date.now(),

recentMs = RECENT_ENDED_SUBAGENT_CHILD_SESSION_MS,

return `${trimmed}...`;

}

export function isToolDocBlockStart(line: string): boolean {

function isToolDocBlockStart(line: string): boolean {

const normalized = line.trim().toUpperCase();

if (!normalized) {

return false;