MrUnknownDE/VRCX
1
0
Fork 0
mirror of https://github.com/MrUnknownDE/VRCX.git synced 2026-05-06 06:46:04 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix style

Browse Source
This commit is contained in:
pa
2026-03-11 21:38:40 +09:00
parent b51aef91cb
commit bf9b66bdf4
12 changed files with 955 additions and 150 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/stores/notification/index.js
+31 -37
View File
@@ -437,7 +437,6 @@ export const useNotificationStore = defineStore('Notification', () => {
const seeQueue = [];
const seenIds = new Set();
let seeProcessing = false;
const SEE_CONCURRENCY = 2;
/**
*
@@ -445,48 +444,43 @@ export const useNotificationStore = defineStore('Notification', () => {
async function processSeeQueue() {
if (seeProcessing) return;
seeProcessing = true;
const worker = async () => {
let item;
while ((item = seeQueue.shift())) {
const { id, version } = item;
try {
await executeWithBackoff(
async () => {
if (version >= 2) {
const args =
await notificationRequest.seeNotificationV2(
{ notificationId: id }
);
handleNotificationV2Update({
params: { notificationId: id },
json: { ...args.json, seen: true }
});
} else {
await notificationRequest.seeNotification({
let item;
while ((item = seeQueue.shift())) {
const { id, version } = item;
try {
await executeWithBackoff(
async () => {
if (version >= 2) {
const args =
await notificationRequest.seeNotificationV2({
notificationId: id
});
handleNotificationSee(id);
}
},
{
maxRetries: 3,
baseDelay: 1000,
shouldRetry: (err) =>
err?.status === 429 ||
(err?.message || '').includes('429')
handleNotificationV2Update({
params: { notificationId: id },
json: { ...args.json, seen: true }
});
} else {
await notificationRequest.seeNotification({
notificationId: id
});
handleNotificationSee(id);
}
);
} catch (err) {
console.warn('Failed to mark notification as seen:', id);
if (version >= 2) {
handleNotificationV2Hide(id);
},
{
maxRetries: 3,
baseDelay: 1000,
shouldRetry: (err) =>
err?.status === 429 ||
(err?.message || '').includes('429')
}
);
} catch (err) {
console.warn('Failed to mark notification as seen:', id);
if (version >= 2) {
handleNotificationV2Hide(id);
}
}
};
await Promise.all(
Array.from({ length: SEE_CONCURRENCY }, () => worker())
);
}
seeProcessing = false;
}