schiwagoa/tianji
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: fix problem of send notification

Browse Source
This commit is contained in:
moonrailgun 2024-07-17 00:38:21 +08:00
parent a2cb8b0538
commit 82bb2ad267
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/server/cache/index.ts vendored
View File

@ -37,7 +37,9 @@ export function buildQueryWithCache<T, Args extends any[]>(
const realValue = await fetchFn(...args); const realValue = await fetchFn(...args);
await cacheManager.set(key, JSON.stringify(cachedValue)); if (realValue) {
await cacheManager.set(key, JSON.stringify(realValue));
}
return realValue; return realValue;
}; };

5
src/server/model/feed/event.ts
View File

@ -10,6 +10,7 @@ import { serializeJSON } from '../../utils/json';
import { buildQueryWithCache } from '../../cache'; import { buildQueryWithCache } from '../../cache';
import { sendNotification } from '../notification'; import { sendNotification } from '../notification';
import { token } from '../notification/token'; import { token } from '../notification/token';
import { logger } from '../../utils/logger';
const { get: getFeedEventNotify, del: delFeedEventNotifyCache } = const { get: getFeedEventNotify, del: delFeedEventNotifyCache } =
buildQueryWithCache(async (channelId: string) => { buildQueryWithCache(async (channelId: string) => {
@ -69,7 +70,9 @@ export async function sendFeedEventsNotify(
await Promise.all( await Promise.all(
notifications.map((notification) => notifications.map((notification) =>
sendNotification(notification, 'Feed Report', eventTokens) sendNotification(notification, 'Feed Report', eventTokens).catch((err) =>
logger.error('[Notification] sendFeedEventsNotify', err)
)
) )
); );
} }