vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-18 04:31:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(plugins): clean xai and qqbot lint

Browse Source
This commit is contained in:
Vincent Koc
2026-04-06 15:13:10 +01:00
parent 0f075e1b8a
commit 9502642f47
5 changed files with 30 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
extensions/qqbot/src/api.ts
View File

@@ -437,7 +437,7 @@ export async function sendChannelMessage(
channelId: string,
content: string,
msgId?: string,
): Promise<{ id: string; timestamp: string }> {
): Promise<MessageResponse> {
return apiRequest(accessToken, "POST", `/channels/${channelId}/messages`, {
content,
...(msgId ? { msg_id: msgId } : {}),
@@ -499,9 +499,11 @@ export async function sendProactiveGroupMessage(
accessToken: string,
groupOpenid: string,
content: string,
): Promise<{ id: string; timestamp: string }> {
): Promise<MessageResponse> {
const body = buildProactiveMessageBody(appId, content);
return apiRequest(accessToken, "POST", `/v2/groups/${groupOpenid}/messages`, body);
return sendAndNotify(appId, accessToken, "POST", `/v2/groups/${groupOpenid}/messages`, body, {
text: content,
});
}
// Rich media message support.

32
extensions/qqbot/src/outbound.ts
View File

@@ -50,8 +50,18 @@ interface MessageReplyRecord {
firstReplyAt: number;
}
type QQMessageResult = {
ext_info?: {
ref_idx?: string;
};
};
const messageReplyTracker = new Map<string, MessageReplyRecord>();
function getRefIdx(result: QQMessageResult): string | undefined {
return result.ext_info?.ref_idx;
}
/** Result of the passive-reply limit check. */
export interface ReplyLimitResult {
allowed: boolean;
@@ -1012,7 +1022,7 @@ export async function sendText(ctx: OutboundContext): Promise<OutboundResult> {
channel: "qqbot",
messageId: result.id,
timestamp: result.timestamp,
refIdx: (result as { ext_info?: { ref_idx?: string } }).ext_info?.ref_idx,
refIdx: getRefIdx(result),
};
}
} else {
@@ -1029,7 +1039,7 @@ export async function sendText(ctx: OutboundContext): Promise<OutboundResult> {
channel: "qqbot",
messageId: result.id,
timestamp: result.timestamp,
refIdx: (result as any).ext_info?.ref_idx,
refIdx: getRefIdx(result),
};
} else if (target.type === "group") {
const result = await sendProactiveGroupMessage(
@@ -1042,7 +1052,7 @@ export async function sendText(ctx: OutboundContext): Promise<OutboundResult> {
channel: "qqbot",
messageId: result.id,
timestamp: result.timestamp,
refIdx: (result as any).ext_info?.ref_idx,
refIdx: getRefIdx(result),
};
} else {
const result = await sendChannelMessage(accessToken, target.id, item.content);
@@ -1050,7 +1060,7 @@ export async function sendText(ctx: OutboundContext): Promise<OutboundResult> {
channel: "qqbot",
messageId: result.id,
timestamp: result.timestamp,
refIdx: (result as any).ext_info?.ref_idx,
refIdx: getRefIdx(result),
};
}
}
@@ -1123,7 +1133,7 @@ export async function sendText(ctx: OutboundContext): Promise<OutboundResult> {
channel: "qqbot",
messageId: result.id,
timestamp: result.timestamp,
refIdx: (result as any).ext_info?.ref_idx,
refIdx: getRefIdx(result),
};
} else if (target.type === "group") {
const result = await sendProactiveGroupMessage(account.appId, accessToken, target.id, text);
@@ -1131,7 +1141,7 @@ export async function sendText(ctx: OutboundContext): Promise<OutboundResult> {
channel: "qqbot",
messageId: result.id,
timestamp: result.timestamp,
refIdx: (result as any).ext_info?.ref_idx,
refIdx: getRefIdx(result),
};
} else {
const result = await sendChannelMessage(accessToken, target.id, text);
@@ -1139,7 +1149,7 @@ export async function sendText(ctx: OutboundContext): Promise<OutboundResult> {
channel: "qqbot",
messageId: result.id,
timestamp: result.timestamp,
refIdx: (result as any).ext_info?.ref_idx,
refIdx: getRefIdx(result),
};
}
return outResult;
@@ -1170,7 +1180,7 @@ export async function sendText(ctx: OutboundContext): Promise<OutboundResult> {
channel: "qqbot",
messageId: result.id,
timestamp: result.timestamp,
refIdx: (result as any).ext_info?.ref_idx,
refIdx: getRefIdx(result),
};
}
} catch (err) {
@@ -1222,7 +1232,7 @@ export async function sendProactiveMessage(
channel: "qqbot",
messageId: result.id,
timestamp: result.timestamp,
refIdx: (result as any).ext_info?.ref_idx,
refIdx: getRefIdx(result),
};
} else if (target.type === "group") {
debugLog(
@@ -1236,7 +1246,7 @@ export async function sendProactiveMessage(
channel: "qqbot",
messageId: result.id,
timestamp: result.timestamp,
refIdx: (result as any).ext_info?.ref_idx,
refIdx: getRefIdx(result),
};
} else {
debugLog(
@@ -1250,7 +1260,7 @@ export async function sendProactiveMessage(
channel: "qqbot",
messageId: result.id,
timestamp: result.timestamp,
refIdx: (result as any).ext_info?.ref_idx,
refIdx: getRefIdx(result),
};
}
return outResult;

2
extensions/qqbot/src/utils/platform.ts
View File

@@ -223,7 +223,7 @@ export function sanitizeFileName(name: string): string {
result = result.normalize("NFC");
// Drop ASCII control characters while keeping printable Unicode content.
result = result.replace(/[\x00-\x1F\x7F]/g, "");
result = result.replace(/\p{Cc}/gu, "");
return result;
}

2
extensions/xai/index.ts
View File

@@ -210,7 +210,7 @@ export default defineSingleProviderPluginEntry({
// private config layout. Callers may receive a real key from the active
// runtime snapshot or a non-secret SecretRef marker from source config.
resolveSyntheticAuth: ({ config }) => {
const fallbackAuth = resolveFallbackXaiAuth(config as OpenClawConfig | undefined);
const fallbackAuth = resolveFallbackXaiAuth(config);
if (!fallbackAuth) {
return undefined;
}

7
extensions/xai/web-search.ts
View File

@@ -243,14 +243,11 @@ export function createXaiWebSearchProvider(): WebSearchProviderPlugin {
model: resolveXaiWebSearchModel(searchConfig),
apiKey,
timeoutSeconds: resolveTimeoutSeconds(
(searchConfig?.timeoutSeconds as number | undefined) ?? undefined,
searchConfig?.timeoutSeconds,
DEFAULT_TIMEOUT_SECONDS,
),
inlineCitations: resolveXaiInlineCitations(searchConfig),
cacheTtlMs: resolveCacheTtlMs(
(searchConfig?.cacheTtlMinutes as number | undefined) ?? undefined,
DEFAULT_CACHE_TTL_MINUTES,
),
cacheTtlMs: resolveCacheTtlMs(searchConfig?.cacheTtlMinutes, DEFAULT_CACHE_TTL_MINUTES),
});
},
};