// OpenAI-compatible embeddings HTTP endpoint.

// Bridges /v1/embeddings requests to configured OpenClaw memory providers.

import { Buffer } from "node:buffer";

import type { IncomingMessage, ServerResponse } from "node:http";

import {

}

function encodeEmbeddingBase64(embedding: number[]): string {

// OpenAI-compatible base64 embeddings are raw float32 bytes, not JSON.

const float32 = Float32Array.from(embedding);

return Buffer.from(float32.buffer).toString("base64");

}

// MCP loopback HTTP request helpers.

// Authenticates local MCP POST requests and extracts scoped Gateway context.

import type { IncomingMessage, ServerResponse } from "node:http";

import { normalizeOptionalString } from "@openclaw/normalization-core/string-coerce";

import type { SourceReplyDeliveryMode } from "../auto-reply/get-reply-options.types.js";

const chunks: Buffer[] = [];

let received = 0;

let settled = false;

// Remove listeners on every terminal path; oversized bodies keep the error

// listener briefly so Node can deliver the pause/error safely.

const cleanup = (options?: { keepErrorListener?: boolean }) => {

req.off("data", onData);

req.off("end", onEnd);

// MCP loopback runtime scope cache.

// Resolves Gateway-visible tools for MCP clients with short-lived schema caching.

import type { SourceReplyDeliveryMode } from "../auto-reply/get-reply-options.types.js";

import type { InboundEventKind } from "../channels/inbound-event/kind.js";

import type { OpenClawConfig } from "../config/types.openclaw.js";

// MCP loopback tool schema projection.

// Converts gateway-scoped tools into MCP tools/list-compatible schemas.

import { isRecord } from "@openclaw/normalization-core/record-coerce";

import { uniqueValues } from "@openclaw/normalization-core/string-normalization";

import { logWarn } from "../logger.js";

}

function flattenUnionSchema(raw: Record<string, unknown>): Record<string, unknown> {

// MCP clients vary in union-schema support. Merge only safe object variants

// and keep common required fields so generated forms remain usable.

const variants = (raw.anyOf ?? raw.oneOf) as unknown[] | undefined;

if (!Array.isArray(variants) || variants.length === 0) {

return raw;

// MCP loopback HTTP server.

// Exposes Gateway-scoped tools to local MCP clients over bearer-auth loopback.

import crypto from "node:crypto";

import {

createServer as createHttpServer,

if (!address || typeof address === "string") {

throw new Error("mcp loopback did not bind to a TCP port");

}

// Register tokens only after the TCP listener is live so clients never learn

// a bearer token for a server that failed to bind.

setActiveMcpLoopbackRuntime({ port: address.port, ownerToken, nonOwnerToken });

logDebug(`mcp loopback listening on 127.0.0.1:${address.port}`);

// OpenResponses file-content boundary helper.

// Marks uploaded/read file text as untrusted external model input.

import { wrapExternalContent } from "../security/external-content.js";

// OpenResponses file content is untrusted model input. The wrapper preserves