alteropen/streamyfin
1
0
Fork 0
mirror of https://github.com/streamyfin/streamyfin.git synced 2026-07-16 17:33:00 +01:00
Code Issues Actions 8 Packages Projects Releases Wiki Activity

fix: add return type

Browse Source
This commit is contained in:
Fredrik Burmester
2025-02-21 10:49:14 +01:00
parent f3b77b8547
commit b402cf7f10
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
utils/recently-added-notifications.ts
View File

@@ -66,7 +66,7 @@ export async function fetchAndStoreRecentlyAdded(
userId: string, userId: string,
basePath: string, basePath: string,
token: string token: string
) { ): Promise<number> {
try { try {
const deviceName = await getDeviceName(); const deviceName = await getDeviceName();
const id = getOrSetDeviceId(); const id = getOrSetDeviceId();
@@ -153,7 +153,7 @@ export async function fetchAndStoreRecentlyAdded(
RECENTLY_ADDED_SENT_NOTIFICATIONS_ITEM_IDS_KEY, RECENTLY_ADDED_SENT_NOTIFICATIONS_ITEM_IDS_KEY,
JSON.stringify(items.map((item) => item.Id)) JSON.stringify(items.map((item) => item.Id))
); );
return; return 0;
} else { } else {
// Only send notifications for items that haven't been sent yet // Only send notifications for items that haven't been sent yet
for (const newItem of items) { for (const newItem of items) {
@@ -176,8 +176,12 @@ export async function fetchAndStoreRecentlyAdded(
RECENTLY_ADDED_SENT_NOTIFICATIONS_ITEM_IDS_KEY, RECENTLY_ADDED_SENT_NOTIFICATIONS_ITEM_IDS_KEY,
JSON.stringify([...new Set([...alreadySentItemIds, ...newIds])]) JSON.stringify([...new Set([...alreadySentItemIds, ...newIds])])
); );
return newIds.length;
} }
} catch (error) { } catch (error) {
console.error("Error fetching recently added items:", error); console.error("Error fetching recently added items:", error);
} }
return 0;
} }