Log even more garbage
Test / test (push) Failing after 54s Details

This commit is contained in:
Jeff 2024-10-12 17:40:06 -04:00
parent 3ff16c58b2
commit 121cc90de9
1 changed files with 48 additions and 36 deletions

View File

@ -100,18 +100,25 @@ export default function start(self: ServiceWorkerGlobalScope) {
})() })()
) )
}) })
}
async function submitSubscription( async function submitSubscription(
registration: ServiceWorkerRegistration, registration: ServiceWorkerRegistration,
subscription: PushSubscription | null subscription: PushSubscription | null
) { ) {
const db = database() const db = database()
await sendMessage({
message: `Is subscription null? ${subscription === null}`,
})
if (subscription === null) return if (subscription === null) return
const existingSubscriptionId = await db.subscriptions.get(1) const existingSubscriptionId = await db.subscriptions.get(1)
await sendMessage({
message: `Existing subscription ID ${existingSubscriptionId}`,
})
const applicationServerKey = urlB64ToUint8Array(pushPublicKey) const applicationServerKey = urlB64ToUint8Array(pushPublicKey)
const newSubscription = await registration.pushManager.subscribe({ const newSubscription = await registration.pushManager.subscribe({
userVisibleOnly: true, userVisibleOnly: true,
@ -123,28 +130,33 @@ async function submitSubscription(
: putSubscription(newSubscription, existingSubscriptionId.subscriptionId)) : putSubscription(newSubscription, existingSubscriptionId.subscriptionId))
return newSubscription return newSubscription
} }
async function postSubscription( async function postSubscription(
subscription: PushSubscription, subscription: PushSubscription,
db: ReturnType<typeof database> db: ReturnType<typeof database>
) { ) {
const response = await fetch(`${process.env.BASE_URL}/api/subscription/`, { const response = await fetch(`${process.env.BASE_URL}/api/subscription/`, {
method: "POST", method: "POST",
body: JSON.stringify(subscription), body: JSON.stringify(subscription),
}) })
await sendMessage({
message: `Response status ${response.status}`,
})
db.subscriptions.put({ db.subscriptions.put({
id: 1, id: 1,
subscriptionId: (await response.json()).subscriptionId, subscriptionId: (await response.json()).subscriptionId,
}) })
} }
function putSubscription(subscription: PushSubscription, id: number) { function putSubscription(subscription: PushSubscription, id: number) {
return fetch(`${process.env.BASE_URL}/api/subscription/${id}`, { return fetch(`${process.env.BASE_URL}/api/subscription/${id}`, {
method: "PUT", method: "PUT",
body: JSON.stringify(subscription), body: JSON.stringify(subscription),
}) })
}
} }
function database() { function database() {