Compare commits
3 Commits
12e57a97f5
...
feature/no
| Author | SHA1 | Date | |
|---|---|---|---|
| 4bbda5dcf8 | |||
| a57e4efd4c | |||
| 9ec83d8b87 |
@@ -90,7 +90,14 @@ async function events_check_for_notification() {
|
|||||||
for ( const ev of list_of_events ) {
|
for ( const ev of list_of_events ) {
|
||||||
console.log("loop list_of_events - ev: " + [ ev.uid, ev.title, ev.date_at, "notification: " + ev.notification ].join( ", " ) );
|
console.log("loop list_of_events - ev: " + [ ev.uid, ev.title, ev.date_at, "notification: " + ev.notification ].join( ", " ) );
|
||||||
console.log("loop list_of_events - ev 'title': " + ev.get_title() );
|
console.log("loop list_of_events - ev 'title': " + ev.get_title() );
|
||||||
await sendNotification( ev.get_title(), ev.get_body() );
|
const notificationOptions = {
|
||||||
|
ntfy: null,
|
||||||
|
discord: {
|
||||||
|
avatar_url: ( process.env.dc_avatar_url as string),
|
||||||
|
botname: ( process.env.dc_botname as string)
|
||||||
|
}
|
||||||
|
};
|
||||||
|
await sendNotification( ev.get_title(), ev.get_body(), notificationOptions );
|
||||||
if ( ev.notification == "removed" ) {
|
if ( ev.notification == "removed" ) {
|
||||||
ev.set_deleted( db );
|
ev.set_deleted( db );
|
||||||
}
|
}
|
||||||
|
|||||||
16
src/config.ts
Normal file
16
src/config.ts
Normal file
@@ -0,0 +1,16 @@
|
|||||||
|
export const config = {
|
||||||
|
apprise: {
|
||||||
|
services: {
|
||||||
|
ntfy: {
|
||||||
|
url: `ntfys://${process.env.ntfy_username}:${process.env.ntfy_password}@${process.env.ntfy_host}/${process.env.ntfy_topic}`,
|
||||||
|
defaults: {
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
|
urls: [
|
||||||
|
`ntfys://${process.env.ntfy_username}:${process.env.ntfy_password}@${process.env.ntfy_host}/${process.env.ntfy_topic}`,
|
||||||
|
`discord://${process.env.dc_webhook}?avatar_url=${process.env.dc_avatar_url}&botname=${process.env.dc_botname}`
|
||||||
|
]
|
||||||
|
}
|
||||||
|
} as const
|
||||||
@@ -1,11 +1,27 @@
|
|||||||
export async function sendNotification(title: string, body: string, link?: string | null) {
|
import { createQS } from "./util";
|
||||||
|
|
||||||
|
type TSendNotificationOptions = {
|
||||||
|
ntfy: {
|
||||||
|
link?: string;
|
||||||
|
} | null,
|
||||||
|
discord: {
|
||||||
|
href?: string
|
||||||
|
avatar_url: string,
|
||||||
|
botname: string
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function sendNotification( title: string, body: string, options: TSendNotificationOptions ) {
|
||||||
console.dir({
|
console.dir({
|
||||||
sendNotification: {
|
sendNotification: {
|
||||||
title,
|
title,
|
||||||
body,
|
body
|
||||||
link
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
const QS = {
|
||||||
|
ntfy: options.ntfy ? createQS(options.ntfy) : null,
|
||||||
|
discord: createQS(options.discord)
|
||||||
|
}
|
||||||
if ( ! ( process.env.notification_mock == "true" ) ) {
|
if ( ! ( process.env.notification_mock == "true" ) ) {
|
||||||
const response = await fetch(`${ process.env.apprise_https == "true" ? "https" : "http"}://${process.env.apprise_host ? process.env.apprise_host : "apprise"}:${process.env.apprise_port ? String(process.env.apprise_port) : "80" }/notify`, {
|
const response = await fetch(`${ process.env.apprise_https == "true" ? "https" : "http"}://${process.env.apprise_host ? process.env.apprise_host : "apprise"}:${process.env.apprise_port ? String(process.env.apprise_port) : "80" }/notify`, {
|
||||||
method: "POST",
|
method: "POST",
|
||||||
@@ -14,8 +30,8 @@ export async function sendNotification(title: string, body: string, link?: strin
|
|||||||
},
|
},
|
||||||
body: JSON.stringify({
|
body: JSON.stringify({
|
||||||
urls: [
|
urls: [
|
||||||
`ntfys://${process.env.ntfy_username}:${process.env.ntfy_password}@${process.env.ntfy_host}/${process.env.ntfy_topic}${ link ? `?click=${link}`: "?click=https://77th-jsoc.com/#/events" }`,
|
`ntfys://${process.env.ntfy_username}:${process.env.ntfy_password}@${process.env.ntfy_host}/${process.env.ntfy_topic}${ QS.ntfy ? "?" + QS.ntfy : ""}`,
|
||||||
`discord://${process.env.dc_webhook}?avatar_url=${process.env.dc_avatar_url}&botname=${process.env.dc_botname}`
|
`discord://${process.env.dc_webhook}?${QS.discord}`
|
||||||
].join(","),
|
].join(","),
|
||||||
title: title,
|
title: title,
|
||||||
body: body,
|
body: body,
|
||||||
|
|||||||
@@ -89,3 +89,10 @@ export function isEuropeanDST( date: Date ) {
|
|||||||
// Return true if within DST period
|
// Return true if within DST period
|
||||||
return date >= start && date < end;
|
return date >= start && date < end;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export function createQS (params: Record<string, string | number | boolean>): string {
|
||||||
|
const queryString = Object.entries(params)
|
||||||
|
.map(([key, value]) => `${encodeURIComponent(key)}=${encodeURIComponent(value)}`)
|
||||||
|
.join("&");
|
||||||
|
return queryString;
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user