8 Commits

8 changed files with 25 additions and 14 deletions

View File

@@ -1,6 +1,6 @@
services: services:
app: app:
image: chiko/77th_eventcalendarntfy:v0.1.3 image: chiko/77th_eventcalendarntfy:v0.1.5
build: . build: .
volumes: volumes:
- ./data/db:/opt/app/data/db - ./data/db:/opt/app/data/db

View File

@@ -2,4 +2,3 @@ SHELL=/bin/bash
MAILTO="" MAILTO=""
0 8 * * * root . /etc/cron-env.sh && /opt/app/run-task.sh --today >> /proc/1/fd/1 2>&1 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 */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

View File

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

View File

@@ -1,5 +1,5 @@
{ {
"version": "0.1.3", "version": "0.1.5",
"name": "77th_eventcalendarnotification", "name": "77th_eventcalendarnotification",
"module": "./src/app.ts", "module": "./src/app.ts",
"type": "module", "type": "module",
@@ -16,7 +16,7 @@
"typescript-eslint": "^8.46.2" "typescript-eslint": "^8.46.2"
}, },
"scripts": { "scripts": {
"prod": "NODE_ENV=production bun run ./src/app.ts", "start": "bun run ./src/app.ts",
"dev": "NODE_ENV=development bun ./src/app.ts", "dev": "NODE_ENV=development bun ./src/app.ts",
"db:init": "bun run ./run/db_init.ts", "db:init": "bun run ./run/db_init.ts",
"db:deleteall": "bun run ./run/db_event_deleteall.ts", "db:deleteall": "bun run ./run/db_event_deleteall.ts",

View File

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

View File

@@ -1,7 +1,7 @@
import db from "../src/sql"; import db from "../src/sql";
const run_migration = db.transaction(() => { const run_migration = db.transaction(() => {
// SQL 1: Insert a new user // SQL 1: remove duplicates by uid
db.run(`DELETE FROM events db.run(`DELETE FROM events
WHERE rowid NOT IN ( WHERE rowid NOT IN (
SELECT MIN(rowid) SELECT MIN(rowid)
@@ -9,7 +9,7 @@ const run_migration = db.transaction(() => {
GROUP BY uid GROUP BY uid
);`); );`);
// SQL 2: Update product stock // SQL 2: create new table with unique key
db.run(`CREATE TABLE events_new ( db.run(`CREATE TABLE events_new (
"event_uid" INTEGER PRIMARY KEY, "event_uid" INTEGER PRIMARY KEY,
"uid" TEXT NOT NULL UNIQUE, "uid" TEXT NOT NULL UNIQUE,

View File

@@ -19,10 +19,12 @@ async function events_update_db() {
console.log("events_fetched.length: " + events_fetched.length ); console.log("events_fetched.length: " + events_fetched.length );
const events_fetched_list_of_uids = events_fetched.map( event => { return event.uid; }); const events_fetched_list_of_uids = events_fetched.map( event => { return event.uid; });
console.dir({events_fetched_list_of_uids} ); 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_currentMonth = Event.get_events({month: {year: TODAY.year, month: TODAY.month}}, db);
const events_removed: Event[] = events_db_currentMonth.filter( (ev) => { 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); return ! events_fetched_list_of_uids.includes(ev.uid);
}); });
@@ -43,7 +45,7 @@ async function events_update_db() {
console.log("loop ev " + ev.uid + " : " + [ ev.title, ev.date_at ].join( ", " ) ); console.log("loop ev " + ev.uid + " : " + [ ev.title, ev.date_at ].join( ", " ) );
const found = AllRelevantEvents.find(event => event.uid === ev.uid); const found = AllRelevantEvents.find(event => event.uid === ev.uid);
if ( found ) { if ( found ) {
console.log("loop ev " + ev.uid + " found: " + [ found.title, found.date_at ].join( ", " ) ); console.log("loop ev " + ev.uid + " f: " + [ found.title, found.date_at ].join( ", " ) );
if ( if (
found.title != ev.title || found.title != ev.title ||
found.description != ev.description || found.description != ev.description ||
@@ -56,12 +58,12 @@ async function events_update_db() {
found.timezone != ev.timezone || found.timezone != ev.timezone ||
found.link != ev.link found.link != ev.link
) { ) {
console.log("loop ev " + ev.uid + " different (changed): " + [ 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"}; const newEventToInsert: TEventEntityNew = {... ev, notification: "changed"};
eventsToInsert.push( newEventToInsert ); eventsToInsert.push( newEventToInsert );
} }
} else { } else {
console.log("loop ev " + ev.uid + " added (new): " + [ 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"}; const newEventToInsert: TEventEntityNew = {... ev, notification: "new"};
eventsToInsert.push( newEventToInsert ); eventsToInsert.push( newEventToInsert );
} }

View File

@@ -89,12 +89,12 @@ export class Event implements TEventEntity {
return events; return events;
} }
static get_events (options: TGetEventsOptions, db: Database ) { static get_events ( options: TGetEventsOptions, db: Database ) {
const whereConditions: string[] = []; const whereConditions: string[] = [];
if ( options.notification ) { if ( options.notification ) {
whereConditions.push( `notification IN ('${ options.notification.join("', '") }')` ) 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}"`); whereConditions.push(`date_at = "${options.date.year}-${options.date.month}-${options.date.day}"`);
} }
if ( options.month ) { if ( options.month ) {
@@ -114,6 +114,7 @@ export class Event implements TEventEntity {
return null; return null;
})() })()
const query = db.query(`SELECT * FROM events${ where ? ( " " + where ) : ""};`).as(Event); const query = db.query(`SELECT * FROM events${ where ? ( " " + where ) : ""};`).as(Event);
console.dir({ db: { action: {get_events: query} } })
return query.all(); return query.all();
} }
@@ -175,7 +176,8 @@ export class Event implements TEventEntity {
set_notification ( newValue: TEventEntity["notification"], db: Database ) { set_notification ( newValue: TEventEntity["notification"], db: Database ) {
const query = db.prepare( const query = db.prepare(
`UPDATE events `UPDATE events
SET notification = $notification SET notification = $notification,
deleteDate = NULL
WHERE event_uid = $event_uid;` WHERE event_uid = $event_uid;`
); );
query.get({$notification: newValue, $event_uid: this.event_uid }); query.get({$notification: newValue, $event_uid: this.event_uid });