Merge branch 'main' into dev

Reviewed-on: #9

.dockerignore

@@ -9,7 +9,7 @@ LICENSE
 .vscode
 Makefile
 helm-charts
-.env
+.env*
 .editorconfig
 .idea
 coverage*

.env.sample

@@ -1,9 +1,15 @@
+TZ=Europe/Berlin
+DB_FILEPATH=./data/db
+DB_FILENAME=77th_eventntfy.db
+apprise_https=false
+apprise_hostname=apprise
+apprise_port=8000
+notification_mock=true
 ntfy_on=true
 ntfy_username=chiko
 ntfy_password=Blub
 ntfy_host=ntfy.some-service.com
 ntfy_topic=SomeTopic
-
 dc_on=true
 dc_webhook=123123123123123/ABCDEFABCDEFABCDEFABCDEFABCDEFABCDEFABCDEF
 dc_botname=Botname Here

.gitignore

@@ -23,6 +23,7 @@ report.[0-9]_.[0-9]_.[0-9]_.[0-9]_.json
 .env.test.local
 .env.production.local
 .env.local
+.env.*
 
 # caches
 .eslintcache

Dockerfile

@@ -3,6 +3,7 @@ ARG BUILD_DATE
 ARG VERSION
 LABEL build_version="77th_eventcalendarntfy ${VERSION}, Build-date:- ${BUILD_DATE}"
 LABEL maintainer="chiko <chiko@xcsone.de>"
+ENV TZ=Europe/Berlin
 WORKDIR /opt/app
 RUN set -eux && \
     echo "Updating APT" && \
@@ -10,12 +11,12 @@ RUN set -eux && \
         apt-get upgrade -y -qq && \
     echo "Installing tools" && \
         apt-get install -y -qq \
-            curl unzip cron ca-certificates logrotate dos2unix && \
+            curl unzip cron ca-certificates logrotate dos2unix tzdata && \
     echo "Remove exim" && \
         apt-get remove -y -qq exim4 exim4-base exim4-daemon-light && \
     echo "Cleaning up" && \
-        apt-get --yes autoremove --purge && \
-        apt-get clean --yes && \
+        apt-get --yes autoremove --purge -qq && \
+        apt-get clean --yes -qq && \
         rm --recursive --force --verbose /var/lib/apt/lists/* && \
         rm --recursive --force --verbose /tmp/* && \
         rm --recursive --force --verbose /var/tmp/* && \

README.md

@@ -1,15 +1,27 @@
-# 77th Event Calender Notifcations
+# 77th Event Calendar Notifcations
 
 To install dependencies:
 
-```bashe
+```bash
 bun install
 ```
 
 To run:
 
 ```bash
-bun run index.ts
+bun run ./src/app.ts
+bun run start
+bun run dev
 ```
 
-This project was created using `bun init` in bun v1.3.0. [Bun](https://bun.com) is a fast all-in-one JavaScript runtime.
+## Docker
+
+```bash
+docker compose build
+docker compose up -d
+```
+
+## Parameter
+
+### --today
+fetch all Events, track all Changes (new, changed and deleted Events) and additionally Send a Notification for todays mission

docker-compose.yml

@@ -1,5 +1,6 @@
 services:
   app:
+    image: chiko/77th_eventcalendarntfy:v0.1.5
     build: .
     volumes:
       - ./data/db:/opt/app/data/db
@@ -12,7 +13,7 @@ services:
     links: 
       - apprise
   apprise:
-    image: caronc/apprise:latest
+    image: caronc/apprise:1.2.2
     hostname: apprise
     environment:
       - APPRISE_WORKER_COUNT=1
@@ -30,7 +31,3 @@ services:
       interval: 5s
       timeout: 3s
       retries: 5
-# networks:
-#   default:
-#     external: true
-#     name: npm

docker/Crontab

@@ -2,4 +2,3 @@ SHELL=/bin/bash
 MAILTO=""
 0 8 * * * root . /etc/cron-env.sh && /opt/app/run-task.sh --today >> /proc/1/fd/1 2>&1
 */15 * * * * root . /etc/cron-env.sh && /opt/app/run-task.sh >> /proc/1/fd/1 2>&1
-* * * * * root echo "cron test ran at $(date)" >> /proc/1/fd/1 2>&1

docker/docker-entrypoint.sh

@@ -7,6 +7,14 @@ chmod +x /etc/cron-env.sh
 # Write the Env Vars into a file for cron. happens during runtime of the container and not build.
 # List your environment variables here
 env_vars=(
+  NODE_ENV
+  TZ
+  DB_FILEPATH
+  DB_FILENAME
+  apprise_https
+  apprise_hostname
+  apprise_port
+  notification_mock
   ntfy_on
   ntfy_username
   ntfy_password

package.json

@@ -1,6 +1,6 @@
 {
-  "version": "0.1.1",
-  "name": "eventcalender",
+  "version": "0.1.5",
+  "name": "77th_eventcalendarnotification",
   "module": "./src/app.ts",
   "type": "module",
   "private": true,
@@ -16,12 +16,13 @@
     "typescript-eslint": "^8.46.2"
   },
   "scripts": {
-    "dev": "bun run ./src/app.ts",
-    "dev:init": "bun run ./src/app.ts --init",
+    "start": "bun run ./src/app.ts",
+    "dev": "NODE_ENV=development bun ./src/app.ts",
     "db:init": "bun run ./run/db_init.ts",
-    "db:deleteall": "bun run ./run/db_deleteall.ts",
-    "build": "bun build --compile --minify --sourcemap ./src/app.ts --outfile ./build/77th_event_calendar_notification",
-    "build:linux": "bun build --compile --minify --sourcemap --target=bun-linux-arm64 ./src/app.ts --outfile ./build/77th_event_calendar_notification",
+    "db:deleteall": "bun run ./run/db_event_deleteall.ts",
+    "db:event:dedup": "bun run ./run/db_event_delete_duplicates.ts",
+    "build": "bun build --compile --minify --sourcemap ./src/app.ts --outfile ./build/77th_eventcalendarnotification",
+    "build:linux": "bun build --compile --minify --sourcemap --target=bun-linux-arm64 ./src/app.ts --outfile ./build/77th_eventcalendarnotification",
     "docker:build": "docker build -t chiko/77th_eventcalendarntfy:0.1.0 ."
   },
   "peerDependencies": {

run-task.sh

@@ -18,7 +18,7 @@ log_info "Starting task with args: $*"
 
 cd /opt/app
 
-if bun run ./src/app.ts "$@" >> /proc/1/fd/1 2>> /proc/1/fd/2; then
+if bun run start "$@" >> /proc/1/fd/1 2>> /proc/1/fd/2; then
     log_info "Task completed successfully."
 else
     log_error "Task failed!"

run/db_event_delete_duplicates.ts

@@ -0,0 +1,10 @@
+import * as db from "../src/sql";
+
+const query = db.db.query(`DELETE FROM events
+WHERE rowid NOT IN (
+  SELECT MIN(rowid)
+  FROM events
+  GROUP BY uid
+);`);
+
+query.run();

run/db_fix_events_deleted_set_done.ts

@@ -0,0 +1,7 @@
+import db from "../src/sql";
+
+db.run(
+  `UPDATE events
+  SET notification = 'done'
+  WHERE deleteDate IS NOT NULL;`
+);

run/db_migration_v0.1.3.ts

@@ -0,0 +1,39 @@
+import db from "../src/sql";
+
+const run_migration = db.transaction(() => {
+  // SQL 1: remove duplicates by uid
+  db.run(`DELETE FROM events
+    WHERE rowid NOT IN (
+      SELECT MIN(rowid)
+      FROM events
+      GROUP BY uid
+    );`);
+
+  // SQL 2: create new table with unique key
+  db.run(`CREATE TABLE events_new (
+    "event_uid" INTEGER PRIMARY KEY,
+    "uid" TEXT NOT NULL UNIQUE,
+    "title" TEXT NOT NULL,
+    "date_at" DATETIME NOT NULL,
+    "time_start" TEXT NOT NULL,
+    "time_end" TEXT NOT NULL,
+    "posted_by" TEXT NOT NULL,
+    "location" TEXT NOT NULL,
+    "event_type" TEXT NOT NULL,
+    "link" TEXT NOT NULL,
+    "description" TEXT NOT NULL,
+    "timezone" TEXT NOT NULL,
+    "notification" TEXT NOT NULL,
+    "deleteDate" INTEGER NULL
+  );`);
+
+  // SQL 3: Log the transaction
+  db.run(`INSERT INTO events_new (event_uid, uid, title, date_at, time_start, time_end, posted_by, location, event_type, link, description, timezone, notification, deleteDate)
+    SELECT event_uid, uid, title, date_at, time_start, time_end, posted_by, location, event_type, link, description, timezone, notification, deleteDate FROM events;
+  `);
+  db.run(`DROP TABLE events;
+    ALTER TABLE events_new RENAME TO events;`);
+});
+
+// Run the transaction
+run_migration();

sql/events/events_create_unique_index_uid.sql

@@ -0,0 +1 @@
+CREATE UNIQUE INDEX idx_events_uid ON events(uid);

sql/events/events_delete_duplicate_rows.sql

@@ -0,0 +1,6 @@
+DELETE FROM events
+WHERE rowid NOT IN (
+  SELECT MIN(rowid)
+  FROM events
+  GROUP BY uid
+);

sql/events/events_find_duplicate_uid.sql

@@ -0,0 +1,4 @@
+SELECT uid, COUNT(*) AS count
+FROM events
+GROUP BY uid
+HAVING COUNT(*) > 1;

sql/sql_migration_v0.1.3.sql

@@ -0,0 +1,29 @@
+DELETE FROM events
+WHERE rowid NOT IN (
+  SELECT MIN(rowid)
+  FROM events
+  GROUP BY uid
+);
+
+CREATE TABLE events_new (
+  "event_uid" INTEGER PRIMARY KEY,
+  "uid" TEXT NOT NULL UNIQUE,
+  "title" TEXT NOT NULL,
+  "date_at" DATETIME NOT NULL,
+  "time_start" TEXT NOT NULL,
+  "time_end" TEXT NOT NULL,
+  "posted_by" TEXT NOT NULL,
+  "location" TEXT NOT NULL,
+  "event_type" TEXT NOT NULL,
+  "link" TEXT NOT NULL,
+  "description" TEXT NOT NULL,
+  "timezone" TEXT NOT NULL,
+  "notification" TEXT NOT NULL,
+  "deleteDate" INTEGER NULL
+);
+
+INSERT INTO events_new (event_uid, uid, title, date_at, time_start, time_end, posted_by, location, event_type, link, description, timezone, notification, deleteDate)
+SELECT event_uid, uid, title, date_at, time_start, time_end, posted_by, location, event_type, link, description, timezone, notification, deleteDate FROM events;
+
+DROP TABLE events;
+ALTER TABLE events_new RENAME TO events;

src/app.ts

@@ -1,45 +1,51 @@
-import { TEventType } from "./component/event/event.types";
 import { db } from "./sql";
 import { Event, type TEventEntityNew, type TGetEventsOptions } from "./component/event/events";
-import { createPlaceholders, getTsNow, pad_l2 } from "./util";
+import { createPlaceholders, getTsNow } from "./util";
 import { sendNotification } from "./sendNotification";
-
-const argv = require('minimist')(process.argv.slice(2));
+import minimist from "minimist";
+const argv = minimist(process.argv.slice(2))
 console.log("App started");
 console.dir({argv})
 
-async function main ( ) {
-  console.log("Excecuting main()");
-  const TODAY = getTsNow();
-  console.dir(TODAY);
-  const events_currentMonth = await Event.fetch_events( TODAY.year, TODAY.month , -120 );
-  console.log("events_currentMonth.length:" + events_currentMonth.length );
-  const events_nextMonth = await Event.fetch_events( TODAY.year, TODAY.month + 1 , -120 );
-  console.log("events_nextMonth.length:" + events_nextMonth.length );
-  const events = [...events_currentMonth, ...events_nextMonth];
-  console.log("events.length:" + events.length );
+const TODAY = getTsNow();
+console.dir({TODAY});
 
-  // const TS_TODAY = new Date();
-  // Write to JSON File Section START
-  // const data = JSON.stringify(events, null, 2);
-  // const TS = `${TS_TODAY.getFullYear()}-${TS_TODAY.getMonth() + 1}-${TS_TODAY.getDate()}_${TS_TODAY.getHours()}-${TS_TODAY.getMinutes()}-${TS_TODAY.getSeconds()}`;
-  // await Bun.write(path.join(import.meta.dir, "output", `output_${TS}.json`), data );
-  // Write to JSON File Section END
+async function events_update_db() {
+  const events_fetched_currentMonth = await Event.fetch_events( TODAY.year, TODAY.month , -120 );
+  console.log("events_fetched_currentMonth.length: " + events_fetched_currentMonth.length );
+  const events_fetched_nextMonth = await Event.fetch_events( TODAY.year, TODAY.month + 1 , -120 );
+  console.log("events_fetched_nextMonth.length: " + events_fetched_nextMonth.length );
+  const events_fetched = [...events_fetched_currentMonth, ...events_fetched_nextMonth];
+  console.log("events_fetched.length: " + events_fetched.length );
 
-  const allEventUids = events.map( event => { return event.uid; });
-  console.dir(allEventUids );
-  const placeholders = createPlaceholders( allEventUids );
+  const events_fetched_list_of_uids = events_fetched.map( event => { return event.uid; });
+  console.dir( {events_fetched_list_of_uids} );
+
+  const events_db_currentMonth = Event.get_events({month: {year: TODAY.year, month: TODAY.month}}, db);
+  const events_db_nextMonth = Event.get_events({month: {year: TODAY.year, month: (TODAY.month + 1)}}, db);
+  const events_db = [... events_db_currentMonth, ... events_db_nextMonth];
+  const events_removed: Event[] = events_db.filter( (ev) => {
+    return ! events_fetched_list_of_uids.includes(ev.uid);
+  });
+
+  console.dir({events_removed});
+
+  events_removed.forEach( ev => {
+    ev.set_notification("removed", db);
+  });
+
+  const placeholders = createPlaceholders( events_fetched_list_of_uids );
   const getAllRelevantEventsQuery = db.query(
-    `SELECT * FROM events WHERE uid IN (${placeholders}); `
+    `SELECT * FROM events WHERE uid IN (${placeholders}) AND deleteDate IS NULL;`
   ).as(Event );
-  const AllRelevantEvents = getAllRelevantEventsQuery.all(...allEventUids);
-  console.log("AllRelevantEvents.length:" + AllRelevantEvents.length );
+  const AllRelevantEvents = getAllRelevantEventsQuery.all(...events_fetched_list_of_uids);
+  console.log("AllRelevantEvents.length: " + AllRelevantEvents.length );
   const eventsToInsert: TEventEntityNew[] = [];
-  for ( const ev of events ) {
-    console.log("loop ev: " + [ ev.uid, ev.title, ev.date_at ].join( ", " ) );
+  for ( const ev of events_fetched ) {
+    console.log("loop ev  " + ev.uid + " : " + [ ev.title, ev.date_at ].join( ", " ) );
     const found = AllRelevantEvents.find(event => event.uid === ev.uid);
     if ( found ) {
-      console.log("loop ev found: " + [ found.uid, found.title, found.date_at ].join( ", " ) );
+      console.log("loop ev  " + ev.uid + " f: " + [ found.title, found.date_at ].join( ", " ) );
       if (
         found.title != ev.title ||
         found.description != ev.description ||
@@ -52,20 +58,25 @@ async function main ( ) {
         found.timezone != ev.timezone ||
         found.link != ev.link
       ) {
-        console.log("loop ev different (changed): " + [ ev.uid, ev.title, ev.date_at ].join( ", " ) );
+        console.log("loop ev " + ev.uid + " c: " + [ ev.title, ev.date_at ].join( ", " ) );
         const newEventToInsert: TEventEntityNew = {... ev, notification: "changed"};
         eventsToInsert.push( newEventToInsert );
       }
     } else {
-      console.log("loop ev added (new): " + [ ev.uid, ev.title, ev.date_at ].join( ", " ) );
+      console.log("loop ev  " + ev.uid + " n: " + [ ev.title, ev.date_at ].join( ", " ) );
       const newEventToInsert: TEventEntityNew = {... ev, notification: "new"};
       eventsToInsert.push( newEventToInsert );
     }
   }
-  console.dir(eventsToInsert)
+  console.dir({eventsToInsert})
   Event.insert( eventsToInsert, db);
-  const where: TGetEventsOptions = {}
-  where.notification = ["new", "changed"]
+}
+
+async function events_check_for_notification() {
+  const where: TGetEventsOptions = {
+    notification: ["new", "changed", "removed"],
+    deleted: false
+  }
   if ( argv.today ) {
     where.date = {
       year: TODAY.year,
@@ -79,46 +90,28 @@ async function main ( ) {
     where
   });
   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( ", " ) );
-    const body = [
-      `Title: ${ev.title}`,
-      `Location: ${ev.location}`,
-      `Type: ${ TEventType[ ev.event_type ] }`,
-      `Date: ${ev.date_at}`,
-      `Time: ${ev.time_start}`,
-      `By: ${ev.posted_by}`,
-      `Link: ${ev.link}`,
-    ].join("\n");
-    console.log("loop list_of_events - ev 'body': " + body );
-    const notification_prefix = ( (event: Event) => {
-      switch( event.notification) {
-        case "new":
-          return "New";
-        case "changed":
-          return "Changed";
-        case "deleted":
-          return "Deleted";
-        default:
-          return null;
+    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() );
+    const notificationOptions = {
+      ntfy: null,
+      discord: {
+        avatar_url: ( process.env.dc_avatar_url as string),
+        botname: ( process.env.dc_botname as string)
       }
-    } ) ( ev );
-
-    const today_prefix = ( (ev: Event) => {
-      const now = getTsNow();
-      const [year, month, day] = ev.date_at.split("-")
-      if ( 
-        year == String(now.year) &&
-        month == pad_l2( String(now.month) ) &&
-        day == pad_l2( String( now.day ) )
-      ) {
-        return true;
-      }
-      return false;
-    })( ev );
-    const title = `${today_prefix ? "TODAY " : ""}${notification_prefix ? notification_prefix + ": " : ""} ${ev.title} (${ TEventType[ ev.event_type ] })`;
-    console.log("loop list_of_events - ev 'title': " + title );
-    await sendNotification( title, body, ev.link ? ev.link : null);
+    };
+    await sendNotification( ev.get_title(), ev.get_body(), notificationOptions );
+    if ( ev.notification == "removed" ) {
+      ev.set_deleted( db );
+    } else {
       ev.set_notification("done", db);
     }
+  }
+}
+
+async function main ( ) {
+  console.log("Excecuting main()");
+  await events_update_db();
+  await events_check_for_notification();
 };
+
 main();

src/component/event/event.types.ts

@@ -15,5 +15,6 @@ export type TEvent = {
     location: string,
     event_type: keyof typeof TEventType,
     timezone: string,
-    link: string
+    link: string,
+    deleteDate?: number | null
 };

src/component/event/events.ts

@@ -1,6 +1,6 @@
 import { Database } from "bun:sqlite";
-import type { TEvent } from "./event.types";
-import { transformArray } from "../../util";
+import { TEventType, type TEvent } from "./event.types";
+import { getTsNow, pad_l2, transformArray, formatTimeDiff, isEuropeanDST, subtractHours } from "../../util";
 
 const BASE_URL = "https://77th-jsoc.com/service.php?action=get_events";
 
@@ -10,38 +10,64 @@ export type TGetEventsOptions = {
     year: number,
     month: number,
     day: number
-  }
+  },
+  month?: {
+    year: number,
+    month: number,
+  },
+  deleted?: boolean
 }
 export type TEventEntity = TEvent & {
   event_uid: number
-  notification: "new" | "changed" | "deleted" | "done"
+  notification: "new" | "changed" | "removed" | "done" | "deleted"
 }
 
 export type TEventEntityNew = Omit<TEventEntity, "event_uid">
 
 export class Event implements TEventEntity {
   static table_name: "events"
+  event_uid: number;
+  uid: string;
+  title: string;
+  description: string;
+  date_at: string;
+  time_start: string;
+  time_end: string;
+  posted_by: string;
+  location: string;
+  event_type: TEventEntity["event_type"];
+  timezone: string;
+  link: string;
+  notification: TEventEntity["notification"];
+  deleteDate: TEventEntity["deleteDate"];
+
   static createTable (db: Database): void {
-    const query = db.query(`CREATE TABLE IF NOT EXISTS events (
-      event_uid INTEGER PRIMARY KEY,
-      uid TEXT NOT NULL UNIQUE,
-      title TEXT NOT NULL,
-      date_at DATETIME NOT NULL,
-      time_start TEXT NOT NULL,
-      time_end TEXT NOT NULL,
-      posted_by TEXT NOT NULL,
-      location TEXT NOT NULL,
-      event_type TEXT NOT NULL,
-      link TEXT NOT NULL,
-      description TEXT NOT NULL,
-      timezone TEXT NOT NULL,
-      notification TEXT NOT NULL DEFAULT "new"
+    const query = db.query(`CREATE TABLE IF NOT EXISTS "events" (
+	    "event_uid" INTEGER PRIMARY KEY,
+      "uid" TEXT NOT NULL UNIQUE,
+      "title" TEXT NOT NULL,
+      "date_at" DATETIME NOT NULL,
+      "time_start" TEXT NOT NULL,
+      "time_end" TEXT NOT NULL,
+      "posted_by" TEXT NOT NULL,
+      "location" TEXT NOT NULL,
+      "event_type" TEXT NOT NULL,
+      "link" TEXT NOT NULL,
+      "description" TEXT NOT NULL,
+      "timezone" TEXT NOT NULL,
+      "notification" TEXT NOT NULL,
+      "deleteDate" INTEGER NULL
     );`);
     query.run(); 
   }
 
   static insert ( events: TEventEntityNew[], db: Database ) {
-    const insert = db.prepare("INSERT OR REPLACE INTO events (uid, title, date_at, time_start, time_end, posted_by, location, event_type, link, description, timezone, notification) VALUES ($uid, $title, $date_at, $time_start, $time_end, $posted_by, $location, $event_type, $link, $description, $timezone, $notification)");
+    const insert = db.prepare( [
+      "INSERT OR REPLACE INTO events",
+        "(uid, title, date_at, time_start, time_end, posted_by, location, event_type, link, description, timezone, notification)",
+      "VALUES",
+        "($uid, $title, $date_at, $time_start, $time_end, $posted_by, $location, $event_type, $link, $description, $timezone, $notification)"
+    ].join(" "));
     const insertEvents = db.transaction(events => {
         for (const event of events) insert.run(event);
         return events.length;
@@ -63,40 +89,36 @@ export class Event implements TEventEntity {
     return events;
   }
 
-  static get_events (options: TGetEventsOptions, db: Database ) {
+  static get_events ( options: TGetEventsOptions, db: Database ) {
     const whereConditions: string[] = [];
     if ( options.notification ) {
         whereConditions.push( `notification IN ('${ options.notification.join("', '") }')` )
     }
-    if (options.date) {
+    if ( options.date ) {
       whereConditions.push(`date_at = "${options.date.year}-${options.date.month}-${options.date.day}"`);
     }
+    if ( options.month ) {
+      whereConditions.push( `strftime('%Y-%m', date_at) = '${options.month.year}-${options.month.month}'`)
+    }
+
     const where = ( () => {
       let str = "WHERE ";
-      if ( whereConditions.length >= 1 ) {
-          str += whereConditions.join(" OR ");
+      if ( options.deleted === true ) {
+        str += "deleteDate IS NOT NULL AND ";
+      } else if ( options.deleted === false ) {
+        str += "deleteDate IS NULL AND ";
       }
-      return str;
+      if ( whereConditions.length >= 1 ) {
+        return str += `( ${ whereConditions.join(" OR ") } )`;
+      }
+      return null;
     })()
     const query = db.query(`SELECT * FROM events${ where ? ( " " + where ) : ""};`).as(Event);
+    console.dir({ db: { action: {get_events: query} } })
     return query.all(); 
   }
 
-  event_uid: number;
-  uid: string;
-  title: string;
-  description: string;
-  date_at: string;
-  time_start: string;
-  time_end: string;
-  posted_by: string;
-  location: string;
-  event_type: TEventEntity["event_type"];
-  timezone: string;
-  link: string;
-  notification: TEventEntity["notification"]
-
-  constructor(event_uid: number, uid: string, title: string, description: string, date_at: string, time_start: string, time_end: string, posted_by: string, location: string, event_type: TEventEntity["event_type"], timezone: string, link: string, notification: TEventEntity["notification"]) {
+  constructor(event_uid: number, uid: string, title: string, description: string, date_at: string, time_start: string, time_end: string, posted_by: string, location: string, event_type: TEventEntity["event_type"], timezone: string, link: string, notification: TEventEntity["notification"], deleteDate: TEventEntity["deleteDate"]) {
     this.event_uid = event_uid;
     this.uid = uid;
     this.title = title;
@@ -110,9 +132,29 @@ export class Event implements TEventEntity {
     this.timezone = timezone;
     this.link = link;
     this.notification = notification;
+    this.deleteDate = deleteDate;
   }
+  toString() {
+    return {
+      event_uid: this.event_uid,
+      uid: this.uid,
+      title: this.title,
+      description: this.description,
+      date_at: this.date_at,
+      time_start: this.time_start,
+      time_end: this.time_end,
+      posted_by: this.posted_by,
+      location: this.location,
+      event_type: this.event_type,
+      timezone: this.timezone,
+      link: this.link,
+      notification: this.notification,
+      deleteDate: this.deleteDate
+    }
+  }
+
   syncWithDb ( db: Database ) {
-    const query = db.prepare( `SELECT * FROM ${Event.table_name} WHERE event_uid = $event_uid;`).as(Event);
+    const query = db.prepare( `SELECT * FROM events WHERE event_uid = $event_uid;`).as(Event);
     const entity = query.get({$event_uid: this.event_uid });
     if ( ! entity ) { throw new Error(`Could not find Event with event_uid ${this.event_uid} in DB!`); }
     this.uid = entity.uid;
@@ -127,6 +169,7 @@ export class Event implements TEventEntity {
     this.timezone = entity.timezone;
     this.link = entity.link;
     this.notification = entity.notification;
+    this.deleteDate = entity.deleteDate;
     return this;
   }
 
@@ -137,5 +180,76 @@ export class Event implements TEventEntity {
         WHERE event_uid = $event_uid;`
     );
     query.get({$notification: newValue, $event_uid: this.event_uid });
+    return this.syncWithDb( db );
+  }
+  set_deleted ( db: Database ) {
+    const query = db.prepare(
+        `UPDATE events
+        SET notification = 'deleted',
+        deleteDate = $deleteDate
+        WHERE event_uid = $event_uid;`
+    );
+    query.get({
+      $deleteDate: Math.floor((new Date()).getTime() / 1000),
+      $event_uid: this.event_uid
+    });
+    return this.syncWithDb( db );
+  }
+  get_title() {
+    const type_of_notification = ( (event: Event) => {
+      switch ( event.notification ) {
+        case "new":
+          return "New";
+        case "changed":
+          return "Changed";
+        case "removed":
+          return "Removed";
+        default:
+          return null;
+      }
+    } ) ( this );
+    const title_prefix_arr = [];
+    if ( type_of_notification ) title_prefix_arr.push( "<" + type_of_notification + ">" );
+    if ( this.isEventToday() ) title_prefix_arr.push( "<TODAY>" )
+    return `${title_prefix_arr.length >= 1 ? ( title_prefix_arr.join(" " ) + " - ") : "" }${this.title} (${ TEventType[ this.event_type ] })`;
+  }
+  get_body() {
+    const BaseTime = new Date(`${this.date_at} 21:00`);
+    const RelativeEventTime = new Date(`${this.date_at} ${this.get_time_start()}`);
+    const TimeDiff = formatTimeDiff( BaseTime, RelativeEventTime);
+    const body = [
+      `Title: ${this.title}`,
+      `Date: ${this.date_at}`,
+      `Time: ${this.get_time_start()} (OP Time${ TimeDiff != "00:00" ? ` ${TimeDiff}` : "" })`,
+      `Type: ${ TEventType[ this.event_type ] }`,
+      `Location: ${this.location}`,
+      `By: ${this.posted_by}`,
+      `Link: ${this.link}`,
+    ].join("\n");
+    return body;
+  }
+
+  isEventToday ( ) {
+    const now = getTsNow();
+    const [year, month, day] = this.date_at.split("-")
+    if ( 
+      year == String(now.year) &&
+      month == pad_l2( String(now.month) ) &&
+      day == pad_l2( String( now.day ) )
+    ) {
+      return true;
+    }
+    return false;
+  }
+
+  get_time_start () {
+    const date = new Date( `${this.date_at} ${this.time_start}` );
+    if ( ! isEuropeanDST( date ) ) {
+      const newDate = subtractHours( date, 1);
+      const hours = newDate.getHours();
+      const minutes = newDate.getMinutes();
+      return `${pad_l2(hours)}:${pad_l2(minutes)}`;
+    }
+    return this.time_start;
   }
 }

src/config.ts

@@ -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

src/sendNotification.ts

@@ -1,26 +1,49 @@
-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({
     sendNotification: {
       title,
-      body,
-      link
+      body
     }
   });
-  const response = await fetch("http://apprise:8000/notify", {
+  const QS = {
+    ntfy: options.ntfy ? createQS(options.ntfy) : null,
+    discord: createQS(options.discord)
+  }
+  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`, {
         method: "POST",
         headers: {
           "Content-Type": "application/json"
         },
         body: JSON.stringify({
         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" }`,
-        `discord://${process.env.dc_webhook}?avatar_url=${process.env.dc_avatar_url}&botname=${process.env.dc_botname}`
+            `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}?${QS.discord}`
         ].join(","),
         title: title,
         body: body,
-    format: "text"
+        format: "markdown"
         })
       });
       const responseBody = await response.json();
       return responseBody;
+  } else {
+    console.dir({
+      sendNotification: "mocking"
+    })
+  }
+  
 }

src/sql.ts

@@ -8,6 +8,8 @@ console.log(db_filepath);
 
 export const db = new Database(db_filepath);
 
+export default db;
+
 export function init () {
   Event.createTable(db);
 }

src/util.ts

@@ -39,3 +39,60 @@ export function getTsNow() {
   }
   return rtn;
 }
+
+export function unixToDate( unix_timestamp: number ) { return new Date(unix_timestamp * 1000) }
+export function dateToUnix( date: Date ) { return Math.round( date.getTime()/1000 ) }
+
+export function formatTimeDiff(dateA: Date, dateB: Date) {
+  // Difference in milliseconds
+  const diffMs = dateB.getTime() - dateA.getTime();
+
+  // Get sign (+ or -)
+  const sign = diffMs < 0 ? "-" : "";
+
+  // Convert to absolute minutes
+  const diffMinutes = Math.floor(Math.abs(diffMs) / 60000);
+
+  // Split into hours and minutes
+  const hours = Math.floor(diffMinutes / 60);
+  const minutes = diffMinutes % 60;
+
+  // Return formatted string
+  return `${sign}${String(hours).padStart(2, "0")}:${String(minutes).padStart(2, "0")}`;
+}
+
+export function subtractHours(date: Date, hours: number) {
+  // Create a new Date so we don't mutate the original
+  return new Date(date.getTime() - hours * 60 * 60 * 1000);
+}
+
+// Helper: get last Sunday of a given month
+function lastSundayOfMonth(year: number, month: number ) {
+  const lastDay = new Date(Date.UTC(year, month + 1, 0)); // last day of month
+  const day = lastDay.getUTCDay(); // 0 = Sunday
+  const diff = day === 0 ? 0 : day; // how far back to go to reach Sunday
+  lastDay.setUTCDate(lastDay.getUTCDate() - diff);
+  return lastDay;
+}
+
+export function isEuropeanDST( date: Date ) {
+  const year = date.getFullYear();
+
+  // DST starts: last Sunday in March, 01:00 UTC
+  const start = lastSundayOfMonth(year, 2); // March (month = 2)
+  start.setUTCHours(1, 0, 0, 0);
+
+  // DST ends: last Sunday in October, 01:00 UTC
+  const end = lastSundayOfMonth(year, 9); // October (month = 9)
+  end.setUTCHours(1, 0, 0, 0);
+
+  // Return true if within DST period
+  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;
+}