diff options
| author | Fuwn <[email protected]> | 2026-03-01 16:20:51 -0800 |
|---|---|---|
| committer | Fuwn <[email protected]> | 2026-03-01 16:21:02 -0800 |
| commit | eae5d24d9e79e59a19d4721caaeaa0ca650ecb33 (patch) | |
| tree | 1b685bb248e051dfa26d2bfdebe6689402dd93c5 /src/trigger | |
| parent | chore(tooling): remove legacy eslint and prettier (diff) | |
| download | due.moe-eae5d24d9e79e59a19d4721caaeaa0ca650ecb33.tar.xz due.moe-eae5d24d9e79e59a19d4721caaeaa0ca650ecb33.zip | |
chore(biome): drop formatter style overrides
Diffstat (limited to 'src/trigger')
| -rw-r--r-- | src/trigger/notifications.ts | 90 |
1 files changed, 60 insertions, 30 deletions
diff --git a/src/trigger/notifications.ts b/src/trigger/notifications.ts index 77b8713f..62c6e2e2 100644 --- a/src/trigger/notifications.ts +++ b/src/trigger/notifications.ts @@ -1,38 +1,68 @@ -import { schedules, envvars } from '@trigger.dev/sdk/v3'; -import * as webpush from 'web-push'; -import { createClient } from '@supabase/supabase-js'; +import { schedules, envvars } from "@trigger.dev/sdk/v3"; +import * as webpush from "web-push"; +import { createClient } from "@supabase/supabase-js"; export const notificationsTask = schedules.task({ - id: 'notifications', - run: async (_payload, { ctx }) => { - const environment = ctx.environment.slug; - const triggerProjectReference = ctx.project.ref; - const getUserSubscriptions = async () => { - const { data, error } = await createClient( - (await envvars.retrieve(triggerProjectReference, environment, 'SUPABASE_URL')).value, - (await envvars.retrieve(triggerProjectReference, environment, 'SUPABASE_ANON_KEY')).value - ) - .from('user_notifications') - .select('*'); + id: "notifications", + run: async (_payload, { ctx }) => { + const environment = ctx.environment.slug; + const triggerProjectReference = ctx.project.ref; + const getUserSubscriptions = async () => { + const { data, error } = await createClient( + ( + await envvars.retrieve( + triggerProjectReference, + environment, + "SUPABASE_URL", + ) + ).value, + ( + await envvars.retrieve( + triggerProjectReference, + environment, + "SUPABASE_ANON_KEY", + ) + ).value, + ) + .from("user_notifications") + .select("*"); - if (error) return []; + if (error) return []; - return data; - }; + return data; + }; - webpush.setVapidDetails( - (await envvars.retrieve(triggerProjectReference, environment, 'VAPID_SUBJECT')).value, - (await envvars.retrieve(triggerProjectReference, environment, 'VAPID_PUBLIC_KEY')).value, - (await envvars.retrieve(triggerProjectReference, environment, 'VAPID_PRIVATE_KEY')).value - ); + webpush.setVapidDetails( + ( + await envvars.retrieve( + triggerProjectReference, + environment, + "VAPID_SUBJECT", + ) + ).value, + ( + await envvars.retrieve( + triggerProjectReference, + environment, + "VAPID_PUBLIC_KEY", + ) + ).value, + ( + await envvars.retrieve( + triggerProjectReference, + environment, + "VAPID_PRIVATE_KEY", + ) + ).value, + ); - for (const subscription of await getUserSubscriptions()) - try { - await webpush.sendNotification(subscription['subscription'], '.'); - } catch (error) { - console.error(error); - } + for (const subscription of await getUserSubscriptions()) + try { + await webpush.sendNotification(subscription["subscription"], "."); + } catch (error) { + console.error(error); + } - return {}; - } + return {}; + }, }); |