// Gateway RPC handlers for Talk voice, transcription, and speech synthesis surfaces.

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

import {

normalizeLowercaseStringOrEmpty,

normalizeOptionalLowercaseString,

} from "../../tts/tts.js";

import { ADMIN_SCOPE, TALK_SECRETS_SCOPE } from "../operator-scopes.js";

import { formatForLog } from "../ws-log.js";

import { asRecord } from "./record-shared.js";

import { talkClientHandlers } from "./talk-client.js";

import { talkSessionHandlers } from "./talk-session.js";

import {

}

function asStringRecord(value: unknown): Record<string, string> | undefined {

const record = asRecord(value);

const record = asOptionalRecord(value);

if (!record) {

return undefined;

}

baseTts: Record<string, unknown>,

): Record<string, unknown> {

const next = withSpeakerSelectionCompat(baseTts);

const providers = asRecord(baseTts.providers);

const providers = asOptionalRecord(baseTts.providers);

if (providers) {

next.providers = Object.fromEntries(

Object.entries(providers).map(([providerId, providerConfig]) => [

providerId,

withSpeakerSelectionCompat(asRecord(providerConfig) ?? {}),

withSpeakerSelectionCompat(asOptionalRecord(providerConfig) ?? {}),

]),

);

}

for (const [key, value] of Object.entries(baseTts)) {

if (key === "providers") {

continue;

}

const record = asRecord(value);

const record = asOptionalRecord(value);

if (record) {

next[key] = withSpeakerSelectionCompat(record);

}

}

const baseTts = withTalkBaseTtsSpeakerSelectionCompat(

asRecord(config.messages?.tts) ?? {},

asOptionalRecord(config.messages?.tts) ?? {},

) as TtsConfig;

const providerConfig = withSpeakerSelectionFallbackCompat(resolved.config);

const resolvedProviderConfig =

auto: "always",

provider,

providers: {

...((asRecord(baseTts.providers) ?? {}) as TtsProviderConfigMap),

...((asOptionalRecord(baseTts.providers) ?? {}) as TtsProviderConfigMap),

[provider]: resolvedProviderConfig,

},

};

const speechProvider = getSpeechProvider(provider, params.runtimeConfig);

const sourceBaseTts = withTalkBaseTtsSpeakerSelectionCompat(

asRecord(params.sourceConfig.messages?.tts) ?? {},

asOptionalRecord(params.sourceConfig.messages?.tts) ?? {},

);

const runtimeBaseTts = withTalkBaseTtsSpeakerSelectionCompat(

asRecord(params.runtimeConfig.messages?.tts) ?? {},

asOptionalRecord(params.runtimeConfig.messages?.tts) ?? {},

);

const sourceProviderConfig = withSpeakerSelectionFallbackCompat(sourceResolved?.config);

const runtimeProviderConfig = withSpeakerSelectionFallbackCompat(runtimeResolved?.config);

function stripUnresolvedSecretApiKeysFromBaseTtsProviders(

base: Record<string, unknown>,

): Record<string, unknown> {

const providers = asRecord(base.providers);

const providers = asOptionalRecord(base.providers);

if (!providers) {

return base;

}

// they're already validated upstream.

const cleaned: Record<string, unknown> = Object.create(null);

for (const [providerId, providerConfig] of Object.entries(providers)) {

const cfg = asRecord(providerConfig);

const cfg = asOptionalRecord(providerConfig);

if (!cfg) {

cleaned[providerId] = providerConfig;

continue;