aboutsummaryrefslogtreecommitdiff
path: root/src/trigger
diff options
context:
space:
mode:
authorFuwn <[email protected]>2024-10-09 00:41:20 -0700
committerFuwn <[email protected]>2024-10-09 00:41:43 -0700
commit998b63a35256ac985a5a2714dd1ca451af4dfd8a (patch)
tree50796121a9d5ab0330fdc5d7e098bda2860d9726 /src/trigger
parentfeat(graphql): add badgeCount field (diff)
downloaddue.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.ts62
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 {};
+ }
});