aboutsummaryrefslogtreecommitdiff
path: root/src/trigger
diff options
context:
space:
mode:
authorFuwn <[email protected]>2026-03-01 16:20:51 -0800
committerFuwn <[email protected]>2026-03-01 16:21:02 -0800
commiteae5d24d9e79e59a19d4721caaeaa0ca650ecb33 (patch)
tree1b685bb248e051dfa26d2bfdebe6689402dd93c5 /src/trigger
parentchore(tooling): remove legacy eslint and prettier (diff)
downloaddue.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.ts90
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 {};
+ },
});