tkmind/memind_adm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: wire admin recharge WeChat notifications

Browse Source
This commit is contained in:
john
2026-07-23 18:14:10 +08:00
parent 4f708d10bd
commit 00a4855715
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/bootstrap.mjs
+9
View File
@@ -18,6 +18,7 @@ export async function bootstrapAdminServices() {
const createLlmProviderService = await loadCreateLlmProviderService(); const createLlmProviderService = await loadCreateLlmProviderService();
const { createWechatAdminService } = await importMemind('wechat-admin.mjs'); const { createWechatAdminService } = await importMemind('wechat-admin.mjs');
const { createWechatMpService, loadWechatMpConfig } = await importMemind('wechat-mp.mjs'); const { createWechatMpService, loadWechatMpConfig } = await importMemind('wechat-mp.mjs');
const { createNotificationDispatcher } = await importMemind('notification-dispatcher.mjs');
const { createPlazaPostService, formatPostRow } = await importMemind('plaza-posts.mjs'); const { createPlazaPostService, formatPostRow } = await importMemind('plaza-posts.mjs');
const { createPlazaInteractionService } = await importMemind('plaza-interactions.mjs'); const { createPlazaInteractionService } = await importMemind('plaza-interactions.mjs');
const { createPlazaOpsService } = await importMemind('plaza-ops.mjs'); const { createPlazaOpsService } = await importMemind('plaza-ops.mjs');
@@ -119,6 +120,14 @@ export async function bootstrapAdminServices() {
throw new Error('admin api does not proxy WeChat chat sessions'); throw new Error('admin api does not proxy WeChat chat sessions');
}, },
}); });
const notificationDispatcher = createNotificationDispatcher({
sendWechatTextToUser: wechatMpService?.enabled
? (userId, text) => wechatMpService.sendTextToUser(userId, text)
: null,
});
userAuth.setRechargeNotifier(async ({ userId, title, body, dedupeKey }) => {
await notificationDispatcher.sendRechargeSuccess({ userId, title, body, dedupeKey });
});
const wechatAdmin = createWechatAdminService(pool, { const wechatAdmin = createWechatAdminService(pool, {
config: wechatMpConfig, config: wechatMpConfig,
scheduleEnabled: process.env.H5_SCHEDULE_ENABLED === '1', scheduleEnabled: process.env.H5_SCHEDULE_ENABLED === '1',