Files
openclaw/extensions/feishu/src/targets.ts
Josh Avant 1c200ca7ae follow-up: align ingress, atomic paths, and channel tests with credential semantics (#33733)
Merged via squash.

Prepared head SHA: c290c2ab6a
Co-authored-by: joshavant <830519+joshavant@users.noreply.github.com>
Co-authored-by: joshavant <830519+joshavant@users.noreply.github.com>
Reviewed-by: @joshavant
2026-03-03 20:29:46 -06:00

108 lines
2.9 KiB
TypeScript

import type { FeishuIdType } from "./types.js";
const CHAT_ID_PREFIX = "oc_";
const OPEN_ID_PREFIX = "ou_";
const USER_ID_REGEX = /^[a-zA-Z0-9_-]+$/;
function stripProviderPrefix(raw: string): string {
return raw.replace(/^(feishu|lark):/i, "").trim();
}
export function detectIdType(id: string): FeishuIdType | null {
const trimmed = id.trim();
if (trimmed.startsWith(CHAT_ID_PREFIX)) {
return "chat_id";
}
if (trimmed.startsWith(OPEN_ID_PREFIX)) {
return "open_id";
}
if (USER_ID_REGEX.test(trimmed)) {
return "user_id";
}
return null;
}
export function normalizeFeishuTarget(raw: string): string | null {
const trimmed = raw.trim();
if (!trimmed) {
return null;
}
const withoutProvider = stripProviderPrefix(trimmed);
const lowered = withoutProvider.toLowerCase();
if (lowered.startsWith("chat:")) {
return withoutProvider.slice("chat:".length).trim() || null;
}
if (lowered.startsWith("group:")) {
return withoutProvider.slice("group:".length).trim() || null;
}
if (lowered.startsWith("channel:")) {
return withoutProvider.slice("channel:".length).trim() || null;
}
if (lowered.startsWith("user:")) {
return withoutProvider.slice("user:".length).trim() || null;
}
if (lowered.startsWith("dm:")) {
return withoutProvider.slice("dm:".length).trim() || null;
}
if (lowered.startsWith("open_id:")) {
return withoutProvider.slice("open_id:".length).trim() || null;
}
return withoutProvider;
}
export function formatFeishuTarget(id: string, type?: FeishuIdType): string {
const trimmed = id.trim();
if (type === "chat_id" || trimmed.startsWith(CHAT_ID_PREFIX)) {
return `chat:${trimmed}`;
}
if (type === "open_id" || trimmed.startsWith(OPEN_ID_PREFIX)) {
return `user:${trimmed}`;
}
return trimmed;
}
export function resolveReceiveIdType(id: string): "chat_id" | "open_id" | "user_id" {
const trimmed = id.trim();
const lowered = trimmed.toLowerCase();
if (
lowered.startsWith("chat:") ||
lowered.startsWith("group:") ||
lowered.startsWith("channel:")
) {
return "chat_id";
}
if (lowered.startsWith("open_id:")) {
return "open_id";
}
if (lowered.startsWith("user:") || lowered.startsWith("dm:")) {
const normalized = trimmed.replace(/^(user|dm):/i, "").trim();
return normalized.startsWith(OPEN_ID_PREFIX) ? "open_id" : "user_id";
}
if (trimmed.startsWith(CHAT_ID_PREFIX)) {
return "chat_id";
}
if (trimmed.startsWith(OPEN_ID_PREFIX)) {
return "open_id";
}
return "user_id";
}
export function looksLikeFeishuId(raw: string): boolean {
const trimmed = stripProviderPrefix(raw.trim());
if (!trimmed) {
return false;
}
if (/^(chat|group|channel|user|dm|open_id):/i.test(trimmed)) {
return true;
}
if (trimmed.startsWith(CHAT_ID_PREFIX)) {
return true;
}
if (trimmed.startsWith(OPEN_ID_PREFIX)) {
return true;
}
return false;
}