vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-05 17:40:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: tighten plugin sdk channel surfaces

Browse Source
This commit is contained in:
Peter Steinberger
2026-03-19 00:46:29 +00:00
parent f19cb738af
commit 002cc07322
18 changed files with 72 additions and 72 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
extensions/imessage/src/monitor/monitor-provider.ts
View File

@@ -1,5 +1,6 @@
import fs from "node:fs/promises";
import { resolveHumanDelayConfig } from "openclaw/plugin-sdk/agent-runtime";
import { createChannelPairingChallengeIssuer } from "openclaw/plugin-sdk/channel-pairing";
import {
createChannelInboundDebouncer,
shouldDebounceTextInbound,
@@ -13,7 +14,6 @@ import {
warnMissingProviderGroupPolicyFallbackOnce,
} from "openclaw/plugin-sdk/config-runtime";
import { readSessionUpdatedAt, resolveStorePath } from "openclaw/plugin-sdk/config-runtime";
import { issuePairingChallenge } from "openclaw/plugin-sdk/conversation-runtime";
import {
readChannelAllowFromStore,
upsertChannelPairingRequest,
@@ -292,14 +292,8 @@ export async function monitorIMessageProvider(opts: MonitorIMessageOpts = {}): P
if (!sender) {
return;
}
await issuePairingChallenge({
await createChannelPairingChallengeIssuer({
channel: "imessage",
senderId: decision.senderId,
senderIdLine: `Your iMessage sender id: ${decision.senderId}`,
meta: {
sender: decision.senderId,
chatId: chatId ? String(chatId) : undefined,
},
upsertPairingRequest: async ({ id, meta }) =>
await upsertChannelPairingRequest({
channel: "imessage",
@@ -307,6 +301,13 @@ export async function monitorIMessageProvider(opts: MonitorIMessageOpts = {}): P
accountId: accountInfo.accountId,
meta,
}),
})({
senderId: decision.senderId,
senderIdLine: `Your iMessage sender id: ${decision.senderId}`,
meta: {
sender: decision.senderId,
chatId: chatId ? String(chatId) : undefined,
},
onCreated: () => {
logVerbose(`imessage pairing request sender=${decision.senderId}`);
},