From eae5d24d9e79e59a19d4721caaeaa0ca650ecb33 Mon Sep 17 00:00:00 2001 From: Fuwn Date: Sun, 1 Mar 2026 16:20:51 -0800 Subject: chore(biome): drop formatter style overrides --- src/trigger/notifications.ts | 90 +++++++++++++++++++++++++++++--------------- 1 file changed, 60 insertions(+), 30 deletions(-) (limited to 'src/trigger') 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 {}; + }, }); -- cgit v1.2.3