diff options
| author | Fuwn <[email protected]> | 2024-10-09 00:41:20 -0700 |
|---|---|---|
| committer | Fuwn <[email protected]> | 2024-10-09 00:41:43 -0700 |
| commit | 998b63a35256ac985a5a2714dd1ca451af4dfd8a (patch) | |
| tree | 50796121a9d5ab0330fdc5d7e098bda2860d9726 /src/trigger | |
| parent | feat(graphql): add badgeCount field (diff) | |
| download | due.moe-998b63a35256ac985a5a2714dd1ca451af4dfd8a.tar.xz due.moe-998b63a35256ac985a5a2714dd1ca451af4dfd8a.zip | |
chore(prettier): use spaces instead of tabs
Diffstat (limited to 'src/trigger')
| -rw-r--r-- | src/trigger/notifications.ts | 62 |
1 files changed, 31 insertions, 31 deletions
diff --git a/src/trigger/notifications.ts b/src/trigger/notifications.ts index 0e1e415f..ba0e6a27 100644 --- a/src/trigger/notifications.ts +++ b/src/trigger/notifications.ts @@ -3,40 +3,40 @@ import * as webpush from 'web-push'; import { createClient } from '@supabase/supabase-js'; export const notificationsTask = schedules.task({ - id: 'notifications', - run: async (_payload: any, { 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: any, { 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 {}; + } }); |