iching-broker-level1/broker.ts
Christopher Hase 1a7d09c17e
All checks were successful
ci / build (push) Successful in 1m3s
schedule next run part 7
2025-03-28 14:11:57 +01:00

239 lines
No EOL
6.8 KiB
TypeScript

import { exec } from 'child_process';
import * as fs from 'fs';
interface Config {
daysInterval: number;
timeOfDay: string;
}
var config : Config;
const nodemailer = require('nodemailer');
// Create Transporter
const transporter = nodemailer.createTransport({
host: "mailhog.mailhog.svc.cluster.local", // MailHog ClusterIP
port: 1025, // Standard-MailHog SMTP-Port
secure: false // MailHog needs no encryption
});
function executeCommand(): void {
exec('iching divine', (error, stdout, stderr) => {
console.log(`Begin`);
if (error) {
console.error(`Error: ${error.message}`);
return;
}
if (stderr) {
console.error(`Stderr: ${stderr}`);
return;
}
console.log(`Send E-Mail`);
sendEmail(stdout);
if (config == undefined) {
config = loadConfig();
} else { //TODO: JUST FOR DEBUGGING
console.log(`Config already read...`);
}
console.log(config.daysInterval, config.timeOfDay);
//sleep();
// Berechne das nächste Ausführungsdatum
const nextRunDate = calculateNextRunDate(config.daysInterval, config.timeOfDay);
console.log(`Gegenwärtig: ` + new Date());
console.log(`Nächste Ausführung: ${nextRunDate}`);
// Starte das Scheduling
scheduleNextRun(nextRunDate);
});
}
// **Hier rufen wir die Funktion beim Start der Datei auf**
executeCommand();
// Funktion, um die Konfiguration zu laden
function loadConfig(): Config {
console.log(`Load Config`);
const data = fs.readFileSync('config.json', 'utf-8');
return JSON.parse(data);
}
// Send E-Mail
async function sendEmail(content: string) {
try {
const info = await transporter.sendMail({
from: '"The Oracle" <the.oracle@holy.mountain>',
to: "Christopher.Hase@telekom.com;test@mailhog.local",
subject: "Your Horoscope Is Ready",
text: content,
html: html(content)
});
console.log("E-Mail sent: ", info.messageId);
} catch (error) {
console.error("Error Sending E-Mail:", error);
}
}
//Sleep. To avoid issue in pod: Completed -> Terminated -> CrashLoopBackOff
async function sleep() {
console.log("Go to sleep: ", new Date().toISOString());
// sleep 1h (3600000 ms)
setTimeout(() => {
sleep(); // recursion after 1h
}, 3600000);
}
function calculateNextRunDate(daysInterval: number, timeOfDay: string): Date {
const currentDate = new Date();
/*// Splitte die Uhrzeit in Stunden und Minuten
const [hours, minutes] = timeOfDay.split(':').map(Number);
// Berechne das Datum für die nächste Ausführung
currentDate.setHours(hours, minutes, 0, 0); // Setze die Uhrzeit auf Y (z.B. 14:30)
// Wenn die Uhrzeit bereits vorbei ist, verschiebe das Datum auf den nächsten Tag
if (currentDate < new Date()) {
currentDate.setDate(currentDate.getDate() + 1); // Setze auf den nächsten Tag
}
// Berechne das Datum für den nächsten Ausführungszeitpunkt unter Berücksichtigung von X Tagen
currentDate.setDate(currentDate.getDate() + daysInterval);
return currentDate;*/
currentDate.setMinutes(currentDate.getMinutes() + 1); //TODO: JUST FOR DEBUGGING!!!
return currentDate;
}
function scheduleNextRun(nextRunDate: Date) {
const now = new Date();
const timeUntilNextRun = nextRunDate.getTime() - now.getTime();
if (timeUntilNextRun > 0) {
setTimeout(() => {
// Hier wird der Prozess ausgeführt
console.log('Prozess wird ausgeführt!');
//exec('iching divine'); //TODO: ÜBERPRÜFEN!!!
executeCommand();
// Berechne das nächste Ausführungsdatum und plane es erneut
//TODO: TESTWEISE ENTFERNEN...
//const newNextRunDate = calculateNextRunDate(config.daysInterval, config.timeOfDay);
//scheduleNextRun(newNextRunDate);
}, timeUntilNextRun);
}
}
//node structure for the Parse Tree (it's a degenerated tree with one or zero children per node)
interface Node {
type: "Root" | "Hexagram" | "Judgement" | "Images" | "ChangingLines" ;
child?: Node;
value?: string;
}
//generate 1) Parse Tree and 2) HTML
function html(inputText: string): string {
const parseTree = parse(inputText);
const htmlOutput = render(parseTree);
return htmlOutput;
}
//generate the Parse Tree
function parse(input: string): Node {
console.log("Parse input text");
const root: Node = { type: "Root"};
var currentNode: Node = root;
const lines = input.split("\n");
for (const line of lines) {
if (line.startsWith("Hexagram")) {
const hexagram: Node = { type: "Hexagram"};
currentNode.child = hexagram;
currentNode = hexagram;
currentNode.value = "<h1>" + line + "</h1>";
} else if (line.startsWith("Judgement")) {
const judgement: Node = { type: "Judgement"};
currentNode.child = judgement;
currentNode = judgement;
currentNode.value = "<h3>" + line + "</h3>";
} else if (line.startsWith("Images")) {
const images: Node = { type: "Images"};
currentNode.child = images;
currentNode = images;
currentNode.value = "<h3>" + line + "</h3>";
} else if (line.startsWith("~") && currentNode.type != "ChangingLines") {
const changingLines: Node = { type: "ChangingLines"};
currentNode.child = changingLines;
currentNode = changingLines;
currentNode.value = line + "<br>";
} else {
currentNode.value = currentNode.value + line + "<br>";
}
}
return root;
}
//generate HTML from Parse Tree
function render(node: Node): string {
if (node == undefined) {
console.log("...finished...")
return "";
}
console.log("Render node" + node.type);
var outputHTML: string = "";
switch (node.type) {
case "Root":
return render(node.child!);
case "Hexagram":
node.value = node.value?.replace("</h1>", "</h1><div style=\"border: 1px solid gray; border-radius: 25px; padding-left: 30px; padding-right: 30px; padding-top: 20px; width: auto; display: inline-block; text-align: center; box-shadow: 4px 4px 10px rgba(0, 0, 0, 0.2);\"><h2>");
node.value = node.value?.replace("<br>", " - ");
outputHTML = "<br><p>" + node.value + "</h2></div></p>";
outputHTML = outputHTML + render(node.child!);
return outputHTML;
case "ChangingLines" :
const regex = new RegExp("~", "g");
node.value = node.value?.replace(regex, "");
outputHTML = "<p><div style=\"border: 1px dashed gray; border-radius: 10px; padding-left: 10px; padding-right: 10px; padding-top: 10px; width: auto; display: inline-block; color: gray; text-align: center; box-shadow: 4px 4px 10px rgba(0, 0, 0, 0.2);\">" + node.value + "</div></p>";
outputHTML = outputHTML + render(node.child!);
return outputHTML;
default:
outputHTML = "<p>" + node.value + "</p>";
outputHTML = outputHTML + render(node.child!);
return outputHTML;
}
}