logging update
This commit is contained in:
@@ -53,9 +53,13 @@ export default defineEventHandler(async (event) => {
|
|||||||
}
|
}
|
||||||
await saveNews(newsEntry)
|
await saveNews(newsEntry)
|
||||||
if (!id && !newsEntry.isHidden) {
|
if (!id && !newsEntry.isHidden) {
|
||||||
sendNewNewsPush(newsEntry).catch(error => {
|
sendNewNewsPush(newsEntry)
|
||||||
console.error('News-Push konnte nicht gesendet werden:', error)
|
.then(result => {
|
||||||
})
|
console.info('News-Push Ergebnis:', { newsId: newsEntry.id, ...result })
|
||||||
|
})
|
||||||
|
.catch(error => {
|
||||||
|
console.error('News-Push konnte nicht gesendet werden:', error)
|
||||||
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
return {
|
return {
|
||||||
|
|||||||
@@ -124,6 +124,10 @@ export async function sendNewNewsPush(news) {
|
|||||||
const accessToken = await getAccessToken(serviceAccount)
|
const accessToken = await getAccessToken(serviceAccount)
|
||||||
const users = await readUsers()
|
const users = await readUsers()
|
||||||
let sent = 0
|
let sent = 0
|
||||||
|
let failed = 0
|
||||||
|
let removed = 0
|
||||||
|
let recipients = 0
|
||||||
|
let tokenCount = 0
|
||||||
let changed = false
|
let changed = false
|
||||||
const title = 'Neue News'
|
const title = 'Neue News'
|
||||||
const body = String(news.title || 'Neue Nachricht vom Harheimer TC').slice(0, 120)
|
const body = String(news.title || 'Neue Nachricht vom Harheimer TC').slice(0, 120)
|
||||||
@@ -139,7 +143,9 @@ export async function sendNewNewsPush(news) {
|
|||||||
if (isHiddenUser(user)) continue
|
if (isHiddenUser(user)) continue
|
||||||
const settings = notificationSettingsForUser(user)
|
const settings = notificationSettingsForUser(user)
|
||||||
if (!settings.newNews) continue
|
if (!settings.newNews) continue
|
||||||
|
recipients += 1
|
||||||
const tokens = pushTokensForUser(user)
|
const tokens = pushTokensForUser(user)
|
||||||
|
tokenCount += tokens.length
|
||||||
const validTokens = []
|
const validTokens = []
|
||||||
for (const entry of tokens) {
|
for (const entry of tokens) {
|
||||||
try {
|
try {
|
||||||
@@ -147,10 +153,12 @@ export async function sendNewNewsPush(news) {
|
|||||||
sent += 1
|
sent += 1
|
||||||
validTokens.push(entry)
|
validTokens.push(entry)
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
|
failed += 1
|
||||||
console.error('FCM News-Push fehlgeschlagen:', error.message)
|
console.error('FCM News-Push fehlgeschlagen:', error.message)
|
||||||
if (!/UNREGISTERED|NOT_FOUND|INVALID_ARGUMENT/.test(String(error.message))) {
|
if (!/UNREGISTERED|NOT_FOUND|INVALID_ARGUMENT/.test(String(error.message))) {
|
||||||
validTokens.push(entry)
|
validTokens.push(entry)
|
||||||
} else {
|
} else {
|
||||||
|
removed += 1
|
||||||
changed = true
|
changed = true
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -161,5 +169,5 @@ export async function sendNewNewsPush(news) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (changed) await writeUsers(users)
|
if (changed) await writeUsers(users)
|
||||||
return { sent, skipped: false }
|
return { sent, failed, removed, recipients, tokenCount, skipped: false }
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user