import { formatInboundFromLabel as formatInboundFromLabelShared } from "openclaw/plugin-sdk/channel-inbound";

import { createDedupeCache, type OpenClawConfig } from "openclaw/plugin-sdk/core";

import { createDedupeCache } from "openclaw/plugin-sdk/core";

import { resolveThreadSessionKeys as resolveThreadSessionKeysShared } from "openclaw/plugin-sdk/routing";

import {

normalizeLowercaseStringOrEmpty,

normalizeOptionalString,

} from "openclaw/plugin-sdk/text-runtime";

import { rawDataToString } from "openclaw/plugin-sdk/webhook-ingress";

export { createDedupeCache, rawDataToString };

identityName?: string;

};

export function extractShortModelName(fullModel: string): string {

const slash = fullModel.lastIndexOf("/");

const modelPart = slash >= 0 ? fullModel.slice(slash + 1) : fullModel;

return modelPart.replace(/-\d{8}$/, "").replace(/-latest$/, "");

}

export const formatInboundFromLabel = formatInboundFromLabelShared;

function normalizeAgentId(value: string | undefined | null): string {

const trimmed = (value ?? "").trim();

if (!trimmed) {

return "main";

}

if (/^[a-z0-9][a-z0-9_-]{0,63}$/i.test(trimmed)) {

return trimmed;

}

return (

normalizeLowercaseStringOrEmpty(trimmed)

.replace(/[^a-z0-9_-]+/g, "-")

.replace(/^-+/, "")

.replace(/-+$/, "")

.slice(0, 64) || "main"

);

}

type AgentEntry = NonNullable<NonNullable<OpenClawConfig["agents"]>["list"]>[number];

function isAgentEntry(entry: unknown): entry is AgentEntry {

return Boolean(entry && typeof entry === "object");

}

function listAgents(cfg: OpenClawConfig): AgentEntry[] {

return Array.isArray(cfg.agents?.list) ? cfg.agents.list.filter(isAgentEntry) : [];

}

function resolveAgentEntry(cfg: OpenClawConfig, agentId: string): AgentEntry | undefined {

const id = normalizeAgentId(agentId);

return listAgents(cfg).find((entry) => normalizeAgentId(entry.id) === id);

}

export function resolveIdentityName(cfg: OpenClawConfig, agentId: string): string | undefined {

const entry = resolveAgentEntry(cfg, agentId);

return normalizeOptionalString(entry?.identity?.name);

}

export function resolveThreadSessionKeys(params: {

baseSessionKey: string;

threadId?: string | null;