1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
import { createClient } from "@supabase/supabase-js";
import { envvars, schedules } from "@trigger.dev/sdk";
import * as webpush from "web-push";
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_SERVICE_ROLE_KEY",
)
).value,
)
.from("user_notifications")
.select("*");
if (error) return [];
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,
);
for (const subscription of await getUserSubscriptions())
try {
await webpush.sendNotification(subscription.subscription, ".");
} catch (error) {
console.error(error);
}
return {};
},
});
|