feature/notification-more-options #7
@@ -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 );
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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,
|
||||||
|
|||||||
Reference in New Issue
Block a user