Spaces:
Sleeping
Sleeping
| const DEFAULT_MAX_ACTIONS = 20; | |
| const DEFAULT_MAX_TEXT_LENGTH = 2000; | |
| export const availableProviderActions = [ | |
| "say", | |
| "startTyping", | |
| "stopTyping", | |
| "moveTo", | |
| "teleport", | |
| "setStatus", | |
| "emitEvent", | |
| "interruptAudioStream", | |
| ]; | |
| export function normalizeProviderActions(value, options = {}) { | |
| const maxActions = options.maxActions ?? DEFAULT_MAX_ACTIONS; | |
| if (Array.isArray(value)) { | |
| const actions = []; | |
| for (const entry of value.slice(0, maxActions)) { | |
| const action = normalizeProviderAction(entry, options); | |
| if (action) { | |
| actions.push(action); | |
| } | |
| } | |
| return actions; | |
| } | |
| if (isRecord(value)) { | |
| if (Array.isArray(value.actions)) { | |
| return normalizeProviderActions(value.actions, options); | |
| } | |
| const action = normalizeProviderAction(value, options); | |
| return action ? [action] : []; | |
| } | |
| return []; | |
| } | |
| export function actionsFromProviderResponse(value, options = {}) { | |
| const normalized = normalizeProviderActions(value, options); | |
| if (normalized.length > 0) { | |
| return normalized; | |
| } | |
| const responseText = extractResponseText(value); | |
| if (!responseText) { | |
| return []; | |
| } | |
| const actionsFromText = extractActionsFromText(responseText, options); | |
| if (actionsFromText.length > 0) { | |
| return actionsFromText; | |
| } | |
| return [ | |
| { | |
| type: "say", | |
| channel: options.defaultChannel ?? "bubble", | |
| text: truncateText(responseText, options.maxTextLength ?? DEFAULT_MAX_TEXT_LENGTH), | |
| }, | |
| ]; | |
| } | |
| export function extractActionsFromText(text, options = {}) { | |
| const candidates = jsonCandidatesFromText(text); | |
| for (const candidate of candidates) { | |
| try { | |
| const parsed = JSON.parse(candidate); | |
| const actions = normalizeProviderActions(parsed, options); | |
| if (actions.length > 0) { | |
| return actions; | |
| } | |
| } | |
| catch (_error) { | |
| // Try the next candidate. | |
| } | |
| } | |
| return []; | |
| } | |
| export function shouldRespondToChat(observation, names, respondToAllBubbleMessages) { | |
| if (observation.type !== "chatMessage" || observation.scope !== "bubble") { | |
| return false; | |
| } | |
| if (respondToAllBubbleMessages) { | |
| return true; | |
| } | |
| const normalized = observation.message.toLowerCase(); | |
| return names | |
| .filter((name) => name.trim().length > 0) | |
| .some((name) => normalized.includes(name.toLowerCase()) || normalized.includes(`@${name.toLowerCase()}`)); | |
| } | |
| function normalizeProviderAction(value, options) { | |
| if (!isRecord(value) || typeof value.type !== "string") { | |
| return undefined; | |
| } | |
| const maxTextLength = options.maxTextLength ?? DEFAULT_MAX_TEXT_LENGTH; | |
| switch (value.type) { | |
| case "say": { | |
| if (typeof value.text !== "string" || value.text.trim().length === 0) { | |
| return undefined; | |
| } | |
| const channel = value.channel === "local" || value.channel === "bubble" ? value.channel : options.defaultChannel ?? "bubble"; | |
| const action = { | |
| type: "say", | |
| channel, | |
| text: truncateText(value.text, maxTextLength), | |
| }; | |
| if (typeof value.author === "string") { | |
| action.author = truncateText(value.author, 100); | |
| } | |
| return action; | |
| } | |
| case "startTyping": { | |
| const channel = value.channel === "local" || value.channel === "bubble" ? value.channel : options.defaultChannel ?? "bubble"; | |
| const action = { | |
| type: "startTyping", | |
| channel, | |
| }; | |
| if (typeof value.author === "string") { | |
| action.author = truncateText(value.author, 100); | |
| } | |
| return action; | |
| } | |
| case "stopTyping": { | |
| const channel = value.channel === "local" || value.channel === "bubble" ? value.channel : options.defaultChannel ?? "bubble"; | |
| const action = { | |
| type: "stopTyping", | |
| channel, | |
| }; | |
| if (typeof value.author === "string") { | |
| action.author = truncateText(value.author, 100); | |
| } | |
| return action; | |
| } | |
| case "moveTo": { | |
| if (!isFiniteNumber(value.x) || !isFiniteNumber(value.y)) { | |
| return undefined; | |
| } | |
| const action = { | |
| type: "moveTo", | |
| x: value.x, | |
| y: value.y, | |
| }; | |
| if (isFiniteNumber(value.speed) && value.speed > 0) { | |
| action.speed = value.speed; | |
| } | |
| return action; | |
| } | |
| case "teleport": { | |
| if (!isFiniteNumber(value.x) || !isFiniteNumber(value.y)) { | |
| return undefined; | |
| } | |
| return { type: "teleport", x: value.x, y: value.y }; | |
| } | |
| case "setStatus": { | |
| if (value.status !== "ONLINE" && | |
| value.status !== "BUSY" && | |
| value.status !== "DO_NOT_DISTURB" && | |
| value.status !== "BACK_IN_A_MOMENT") { | |
| return undefined; | |
| } | |
| return { type: "setStatus", status: value.status }; | |
| } | |
| case "emitEvent": { | |
| if (typeof value.name !== "string" || value.name.trim().length === 0) { | |
| return undefined; | |
| } | |
| return { | |
| type: "emitEvent", | |
| name: truncateText(value.name, 200), | |
| data: toJsonValue(value.data), | |
| }; | |
| } | |
| case "speakPcm": { | |
| if (!isFiniteNumber(value.sampleRate) || typeof value.pcm16Base64 !== "string" || value.pcm16Base64.length === 0) { | |
| return undefined; | |
| } | |
| return { | |
| type: "speakPcm", | |
| sampleRate: value.sampleRate, | |
| pcm16Base64: value.pcm16Base64, | |
| }; | |
| } | |
| case "closeAudioStream": { | |
| return { type: "closeAudioStream" }; | |
| } | |
| case "interruptAudioStream": { | |
| return { type: "interruptAudioStream" }; | |
| } | |
| default: | |
| return undefined; | |
| } | |
| } | |
| function extractResponseText(value) { | |
| if (typeof value === "string") { | |
| return value.trim() || undefined; | |
| } | |
| if (!isRecord(value)) { | |
| return undefined; | |
| } | |
| for (const key of ["text", "reply", "message", "content", "response", "output", "result"]) { | |
| const entry = value[key]; | |
| if (typeof entry === "string" && entry.trim().length > 0) { | |
| return entry.trim(); | |
| } | |
| const nested = extractResponseText(entry); | |
| if (nested) { | |
| return nested; | |
| } | |
| } | |
| return undefined; | |
| } | |
| function jsonCandidatesFromText(text) { | |
| const trimmed = text.trim(); | |
| const candidates = [trimmed]; | |
| for (const match of trimmed.matchAll(/```(?:json)?\s*([\s\S]*?)```/gi)) { | |
| if (match[1]) { | |
| candidates.push(match[1].trim()); | |
| } | |
| } | |
| const objectStart = trimmed.indexOf("{"); | |
| const objectEnd = trimmed.lastIndexOf("}"); | |
| if (objectStart >= 0 && objectEnd > objectStart) { | |
| candidates.push(trimmed.slice(objectStart, objectEnd + 1)); | |
| } | |
| const arrayStart = trimmed.indexOf("["); | |
| const arrayEnd = trimmed.lastIndexOf("]"); | |
| if (arrayStart >= 0 && arrayEnd > arrayStart) { | |
| candidates.push(trimmed.slice(arrayStart, arrayEnd + 1)); | |
| } | |
| return Array.from(new Set(candidates)); | |
| } | |
| function truncateText(value, maxLength) { | |
| if (value.length <= maxLength) { | |
| return value; | |
| } | |
| return `${value.slice(0, Math.max(0, maxLength - 3))}...`; | |
| } | |
| function toJsonValue(value) { | |
| if (value === undefined) { | |
| return null; | |
| } | |
| return JSON.parse(JSON.stringify(value)); | |
| } | |
| function isRecord(value) { | |
| return typeof value === "object" && value !== null && !Array.isArray(value); | |
| } | |
| function isFiniteNumber(value) { | |
| return typeof value === "number" && Number.isFinite(value); | |
| } | |
| //# sourceMappingURL=agentProvider.js.map |