test: speed up telegram and nextcloud talk channel tests

extensions/nextcloud-talk/src/channel.adapters.ts

@@ -0,0 +1,56 @@
+import { formatAllowFromLowercase } from "openclaw/plugin-sdk/allow-from";
+import {
+  adaptScopedAccountAccessor,
+  createScopedChannelConfigAdapter,
+  createScopedDmSecurityResolver,
+} from "openclaw/plugin-sdk/channel-config-helpers";
+import { createPairingPrefixStripper } from "openclaw/plugin-sdk/channel-pairing";
+import { normalizeLowercaseStringOrEmpty } from "openclaw/plugin-sdk/text-runtime";
+import {
+  listNextcloudTalkAccountIds,
+  resolveDefaultNextcloudTalkAccountId,
+  resolveNextcloudTalkAccount,
+  type ResolvedNextcloudTalkAccount,
+} from "./accounts.js";
+import type { CoreConfig } from "./types.js";
+
+export const nextcloudTalkConfigAdapter = createScopedChannelConfigAdapter<
+  ResolvedNextcloudTalkAccount,
+  ResolvedNextcloudTalkAccount,
+  CoreConfig
+>({
+  sectionKey: "nextcloud-talk",
+  listAccountIds: listNextcloudTalkAccountIds,
+  resolveAccount: adaptScopedAccountAccessor(resolveNextcloudTalkAccount),
+  defaultAccountId: resolveDefaultNextcloudTalkAccountId,
+  clearBaseFields: ["botSecret", "botSecretFile", "baseUrl", "name"],
+  resolveAllowFrom: (account) => account.config.allowFrom,
+  formatAllowFrom: (allowFrom) =>
+    formatAllowFromLowercase({
+      allowFrom,
+      stripPrefixRe: /^(nextcloud-talk|nc-talk|nc):/i,
+    }),
+});
+
+export const nextcloudTalkSecurityAdapter = {
+  resolveDmPolicy: createScopedDmSecurityResolver<ResolvedNextcloudTalkAccount>({
+    channelKey: "nextcloud-talk",
+    resolvePolicy: (account) => account.config.dmPolicy,
+    resolveAllowFrom: (account) => account.config.allowFrom,
+    policyPathSuffix: "dmPolicy",
+    normalizeEntry: (raw) =>
+      raw
+        .trim()
+        .replace(/^(nextcloud-talk|nc-talk|nc):/i, "")
+        .trim()
+        .toLowerCase(),
+  }),
+};
+
+export const nextcloudTalkPairingTextAdapter = {
+  idLabel: "nextcloudUserId",
+  message: "OpenClaw: your access has been approved.",
+  normalizeAllowEntry: createPairingPrefixStripper(/^(nextcloud-talk|nc-talk|nc):/i, (entry) =>
+    normalizeLowercaseStringOrEmpty(entry),
+  ),
+};

extensions/nextcloud-talk/src/channel.core.test.ts

@@ -1,5 +1,9 @@
 import { describe, expect, it, vi } from "vitest";
-import { nextcloudTalkPlugin } from "./channel.js";
+import {
+  nextcloudTalkConfigAdapter,
+  nextcloudTalkPairingTextAdapter,
+  nextcloudTalkSecurityAdapter,
+} from "./channel.adapters.js";
 import { NextcloudTalkConfigSchema } from "./config-schema.js";
 import type { CoreConfig } from "./types.js";
 
@@ -47,7 +51,7 @@ describe("nextcloud talk channel core", () => {
   });
 
   it("normalizes trimmed DM allowlist prefixes to lowercase ids", () => {
-    const resolveDmPolicy = nextcloudTalkPlugin.security?.resolveDmPolicy;
+    const resolveDmPolicy = nextcloudTalkSecurityAdapter.resolveDmPolicy;
     if (!resolveDmPolicy) {
       throw new Error("resolveDmPolicy unavailable");
     }
@@ -65,7 +69,7 @@ describe("nextcloud talk channel core", () => {
 
     const result = resolveDmPolicy({
       cfg,
-      account: nextcloudTalkPlugin.config.resolveAccount(cfg, "default"),
+      account: nextcloudTalkConfigAdapter.resolveAccount(cfg, "default"),
     });
     if (!result) {
       throw new Error("nextcloud-talk resolveDmPolicy returned null");
@@ -74,7 +78,7 @@ describe("nextcloud talk channel core", () => {
     expect(result.policy).toBe("allowlist");
     expect(result.allowFrom).toEqual(["  nc:User-Id  "]);
     expect(result.normalizeEntry?.("  nc:User-Id  ")).toBe("user-id");
-    expect(nextcloudTalkPlugin.pairing?.normalizeAllowEntry?.("  nextcloud-talk:User-Id  ")).toBe(
+    expect(nextcloudTalkPairingTextAdapter.normalizeAllowEntry("  nextcloud-talk:User-Id  ")).toBe(
       "user-id",
     );
   });

extensions/nextcloud-talk/src/channel.ts

@@ -1,30 +1,20 @@
 import { describeWebhookAccountSnapshot } from "openclaw/plugin-sdk/account-helpers";
-import { formatAllowFromLowercase } from "openclaw/plugin-sdk/allow-from";
-import {
-  adaptScopedAccountAccessor,
-  createScopedChannelConfigAdapter,
-  createScopedDmSecurityResolver,
-} from "openclaw/plugin-sdk/channel-config-helpers";
 import { createChatChannelPlugin } from "openclaw/plugin-sdk/channel-core";
-import {
-  createLoggedPairingApprovalNotifier,
-  createPairingPrefixStripper,
-} from "openclaw/plugin-sdk/channel-pairing";
+import { createLoggedPairingApprovalNotifier } from "openclaw/plugin-sdk/channel-pairing";
 import { createAllowlistProviderRouteAllowlistWarningCollector } from "openclaw/plugin-sdk/channel-policy";
 import {
   buildWebhookChannelStatusSummary,
   createComputedAccountStatusAdapter,
   createDefaultChannelRuntimeState,
 } from "openclaw/plugin-sdk/status-helpers";
-import { normalizeLowercaseStringOrEmpty } from "openclaw/plugin-sdk/text-runtime";
-import {
-  listNextcloudTalkAccountIds,
-  resolveDefaultNextcloudTalkAccountId,
-  resolveNextcloudTalkAccount,
-  type ResolvedNextcloudTalkAccount,
-} from "./accounts.js";
+import { resolveNextcloudTalkAccount, type ResolvedNextcloudTalkAccount } from "./accounts.js";
 import { nextcloudTalkApprovalAuth } from "./approval-auth.js";
 import { buildChannelConfigSchema, DEFAULT_ACCOUNT_ID, type ChannelPlugin } from "./channel-api.js";
+import {
+  nextcloudTalkConfigAdapter,
+  nextcloudTalkPairingTextAdapter,
+  nextcloudTalkSecurityAdapter,
+} from "./channel.adapters.js";
 import { NextcloudTalkConfigSchema } from "./config-schema.js";
 import { nextcloudTalkDoctor } from "./doctor.js";
 import { nextcloudTalkGatewayAdapter } from "./gateway.js";
@@ -53,37 +43,6 @@ const meta = {
   quickstartAllowFrom: true,
 };
 
-const nextcloudTalkConfigAdapter = createScopedChannelConfigAdapter<
-  ResolvedNextcloudTalkAccount,
-  ResolvedNextcloudTalkAccount,
-  CoreConfig
->({
-  sectionKey: "nextcloud-talk",
-  listAccountIds: listNextcloudTalkAccountIds,
-  resolveAccount: adaptScopedAccountAccessor(resolveNextcloudTalkAccount),
-  defaultAccountId: resolveDefaultNextcloudTalkAccountId,
-  clearBaseFields: ["botSecret", "botSecretFile", "baseUrl", "name"],
-  resolveAllowFrom: (account) => account.config.allowFrom,
-  formatAllowFrom: (allowFrom) =>
-    formatAllowFromLowercase({
-      allowFrom,
-      stripPrefixRe: /^(nextcloud-talk|nc-talk|nc):/i,
-    }),
-});
-
-const resolveNextcloudTalkDmPolicy = createScopedDmSecurityResolver<ResolvedNextcloudTalkAccount>({
-  channelKey: "nextcloud-talk",
-  resolvePolicy: (account) => account.config.dmPolicy,
-  resolveAllowFrom: (account) => account.config.allowFrom,
-  policyPathSuffix: "dmPolicy",
-  normalizeEntry: (raw) =>
-    raw
-      .trim()
-      .replace(/^(nextcloud-talk|nc-talk|nc):/i, "")
-      .trim()
-      .toLowerCase(),
-});
-
 const collectNextcloudTalkSecurityWarnings =
   createAllowlistProviderRouteAllowlistWarningCollector<ResolvedNextcloudTalkAccount>({
     providerConfigPresent: (cfg) =>
@@ -194,19 +153,14 @@ export const nextcloudTalkPlugin: ChannelPlugin<ResolvedNextcloudTalkAccount> =
     },
     pairing: {
       text: {
-        idLabel: "nextcloudUserId",
-        message: "OpenClaw: your access has been approved.",
-        normalizeAllowEntry: createPairingPrefixStripper(
-          /^(nextcloud-talk|nc-talk|nc):/i,
-          (entry) => normalizeLowercaseStringOrEmpty(entry),
-        ),
+        ...nextcloudTalkPairingTextAdapter,
         notify: createLoggedPairingApprovalNotifier(
           ({ id }) => `[nextcloud-talk] User ${id} approved for pairing`,
         ),
       },
     },
     security: {
-      resolveDmPolicy: resolveNextcloudTalkDmPolicy,
+      ...nextcloudTalkSecurityAdapter,
       collectWarnings: collectNextcloudTalkSecurityWarnings,
     },
     outbound: {

extensions/telegram/src/channel.ts

@@ -21,7 +21,6 @@ import {
   resolveOutboundSendDep,
   type OutboundSendDeps,
 } from "openclaw/plugin-sdk/outbound-runtime";
-import { chunkMarkdownText } from "openclaw/plugin-sdk/reply-runtime";
 import {
   buildOutboundBaseSessionKey,
   normalizeOutboundThreadId,
@@ -57,6 +56,7 @@ import { resolveTelegramInlineButtonsScope } from "./inline-buttons.js";
 import * as monitorModule from "./monitor.js";
 import { looksLikeTelegramTargetId, normalizeTelegramMessagingTarget } from "./normalize.js";
 import { sendTelegramPayloadMessages } from "./outbound-adapter.js";
+import { telegramOutboundBaseAdapter } from "./outbound-base.js";
 import { parseTelegramReplyToMessageId, parseTelegramThreadId } from "./outbound-params.js";
 import type { TelegramProbe } from "./probe.js";
 import * as probeModule from "./probe.js";
@@ -996,11 +996,7 @@ export const telegramPlugin = createChatChannelPlugin({
   },
   outbound: {
     base: {
-      deliveryMode: "direct",
-      chunker: chunkMarkdownText,
-      chunkerMode: "markdown",
-      textChunkLimit: 4000,
-      pollMaxOptions: 10,
+      ...telegramOutboundBaseAdapter,
       shouldSuppressLocalPayloadPrompt: ({ cfg, accountId, payload }) =>
         shouldSuppressLocalTelegramExecApprovalPrompt({
           cfg,

extensions/telegram/src/outbound-base.ts

@@ -0,0 +1,9 @@
+import { chunkMarkdownText } from "openclaw/plugin-sdk/reply-runtime";
+
+export const telegramOutboundBaseAdapter = {
+  deliveryMode: "direct" as const,
+  chunker: chunkMarkdownText,
+  chunkerMode: "markdown" as const,
+  textChunkLimit: 4000,
+  pollMaxOptions: 10,
+};

extensions/telegram/src/telegram-outbound.test.ts

@@ -1,6 +1,6 @@
 import { chunkMarkdownText } from "openclaw/plugin-sdk/reply-runtime";
 import { describe, expect, it } from "vitest";
-import { telegramPlugin } from "./channel.js";
+import { telegramOutboundBaseAdapter } from "./outbound-base.js";
 import { clearTelegramRuntime } from "./runtime.js";
 
 describe("telegramPlugin outbound", () => {
@@ -9,6 +9,9 @@ describe("telegramPlugin outbound", () => {
     const text = `${"hello\n".repeat(1200)}tail`;
     const expected = chunkMarkdownText(text, 4000);
 
-    expect(telegramPlugin.outbound?.chunker?.(text, 4000)).toEqual(expected);
+    expect(telegramOutboundBaseAdapter.chunker(text, 4000)).toEqual(expected);
+    expect(telegramOutboundBaseAdapter.deliveryMode).toBe("direct");
+    expect(telegramOutboundBaseAdapter.chunkerMode).toBe("markdown");
+    expect(telegramOutboundBaseAdapter.textChunkLimit).toBe(4000);
   });
 });