move app

2024-06-06 21:19:25 +02:00
parent a6b12dda33
commit bdcbb1336f
12 changed files with 6 additions and 941 deletions
--- a/src/dependencies.js
+++ b/src/dependencies.js
@@ -0,0 +1,77 @@
+const fs = require('fs');
+
+const databaseFile = "sqlite.db"
+
+
+fs.readFile(databaseFile, (err, data) => {
+    if (err) {
+        fs.openSync(databaseFile, 'w');
+        const db = require('better-sqlite3')(databaseFile);
+        // Bootstrap the db
+        db.exec(`
+        CREATE TABLE IF NOT EXISTS accounts (
+        number integer NOT NULL,
+        name text NOT NULL,
+        qualifiedName text NOT NULL UNIQUE,
+        parentAccount text,
+        description text NOT NULL,
+        type TEXT NOT NULL
+        );
+
+        CREATE TABLE IF NOT EXISTS transactions (
+        transaction_id integer PRIMARY KEY,
+        postingDate text NOT NULL,
+        valueDate text,
+        title text NOT NULL
+        );
+
+        CREATE TABLE IF NOT EXISTS transaction_entries (
+        transaction_id int,
+        account_name text NOT NULL,
+        amount float,
+        label text,
+        FOREIGN KEY (transaction_id) REFERENCES transactions (transaction_id) FOREIGN KEY (account_name) REFERENCES accounts (qualifiedName) PRIMARY KEY (transaction_id, account_name)
+        );
+`)
+
+        create_initial_accounts()
+    }
+    })
+// DB
+const db = require('better-sqlite3')(databaseFile);
+
+function create_initial_accounts() {
+    fs.readFile("accounts.json", "utf8", (err, jsonString) => {
+        if (err) {
+            console.log("Error reading the JSON file:", err);
+            response.send("error")
+        }
+        try {
+            account_data = JSON.parse(jsonString);
+            for (let i = 0; i < account_data.length; i++) {
+                account = account_data[i]
+                console.log(account_data[i]["qualifiedName"])
+                parentAccount = account["qualifiedName"].split(":")
+                parentAccount.pop()
+                parentAccount = parentAccount.join(":")
+                if (parentAccount == "") {
+                    parentAccount = undefined
+                }
+                const new_acc = db
+                    .prepare(
+                        `INSERT INTO accounts (number, name, qualifiedName, description, type, parentAccount) VALUES (?, ?, ? ,?, ?, ?)`,
+                    )
+                    .run(account["number"], account["name"], account["qualifiedName"], "Initial Account", account["type"], parentAccount);
+
+            }
+        }
+            catch (err) {
+                console.log("Error parsing JSON string:", err);
+        }
+    });
+}
+
+
+
+
+module.exports = { db, create_initial_accounts }
--- a/src/index.js
+++ b/src/index.js
@@ -0,0 +1,69 @@
+const express = require("express");
+const OpenApiValidator = require("express-openapi-validator");
+const app = express();
+const port = 3000;
+const cors = require("cors")
+const path = require("path")
+
+//// Swagger
+const swaggerUi = require("swagger-ui-express");
+const YAML = require("yaml");
+const fs = require("fs");
+
+const file = fs.readFileSync(path.join(__dirname, "../open_api.yaml"), "utf8");
+const swaggerDocument = YAML.parse(file);
+
+// Serve the swagger ui
+app.use("/docs", swaggerUi.serve, swaggerUi.setup(swaggerDocument));
+
+// use cors middleware
+app.use(cors())
+
+    
+// Validator
+app.use(express.json())
+app.use(
+    OpenApiValidator.middleware({
+        apiSpec: './open_api.yaml',
+        validateResponses: true
+    })
+);
+
+app.use((err, req, res, next) => {
+    res.status(err.status || 500).json ({
+        code: err.status,
+        message: err.message,
+        additionalPropl: err.errors,
+    });
+});
+
+
+// Routes
+app.use(express.json());
+app.use(express.urlencoded({ extended: true }))
+
+app.use( express.static( path.join(__dirname, '../frontend')))
+
+
+const accountsRoute = require("./routes/accounts");
+const transactionsRoute = require("./routes/transactions");
+const resetRoute = require("./routes/reset")
+const { sse } = require("./sse")
+
+const basepath = "/api/v1";
+
+app.use(`${basepath}/accounts`, accountsRoute);
+app.use(`${basepath}/transactions`, transactionsRoute);
+app.use(`${basepath}/`, resetRoute.router);
+
+app.get("/live", sse)
+
+
+app.get("/", (req, res) => {
+    res.sendFile( path.join( __dirname, 'client', 'index.html'))
+});
+
+app.listen(port, () => {
+    console.log(`App listening on port ${port}`);
+});
+
--- a/src/routes/accounts.js
+++ b/src/routes/accounts.js
@@ -0,0 +1,182 @@
+const express = require("express");
+const router = express.Router();
+
+const {db} = require("../dependencies");
+const {send_sse_update} = require("../sse")
+
+// Fix if balance is null
+function fix_balance_is_null(acc) {
+    if (acc["localBalance"] == null) {
+        acc["localBalance"] = 0;
+    }
+    if (acc["balance"] == null) {
+        acc["balance"] = 0;
+    }
+}
+
+// Get subaccounts from database, recursivly calls return_account
+// Fuck IO we ball
+function get_subaccounts(acc) {
+    var base_query = `SELECT number, name, qualifiedName, description, type, tf.balance, te.localBalance, parentAccount  FROM accounts 
+    LEFT JOIN (SELECT SUM(amount) as localBalance, account_name FROM transaction_entries GROUP BY account_name) te ON te.account_name = qualifiedName
+    LEFT JOIN (SELECT SUM(amount) as balance, account_name FROM transaction_entries GROUP BY account_name) tf ON tf.account_name = qualifiedName
+    WHERE parentAccount = ?`;
+
+    var subs = [];
+    const accs = db.prepare(base_query).all(acc["qualifiedName"]);
+    for (let i = 0; i < accs.length; i++) {
+        var one_sub = return_account(accs[i]);
+        fix_balance_is_null(one_sub);
+        acc["balance"] = acc["balance"] + one_sub["balance"];
+        subs.push(one_sub);
+    }
+    return subs;
+}
+
+// Get important account info out of account, recursivly calls get_subaccounts
+function return_account(acc) {
+    test = {
+        number: acc["number"],
+        name: acc["name"],
+        qualifiedName: acc["qualifiedName"],
+        description: acc["description"],
+        type: acc["type"],
+        localBalance: acc["localBalance"],
+        subaccounts: get_subaccounts(acc),
+        balance: acc["balance"],
+    };
+    return test;
+}
+
+router.get("/", (req, res) => {
+    var base_query = `SELECT number, name, qualifiedName, description, type, tf.balance, te.localBalance, parentAccount  FROM accounts 
+    LEFT JOIN (SELECT SUM(amount) as localBalance, account_name FROM transaction_entries GROUP BY account_name) te ON te.account_name = qualifiedName
+    LEFT JOIN (SELECT SUM(amount) as balance, account_name FROM transaction_entries GROUP BY account_name) tf ON tf.account_name = qualifiedName`;
+    const accs = db.prepare(base_query).all();
+    console.log(accs)
+
+    var real_accs = [];
+
+    for (let i = 0; i < accs.length; i++) {
+        fix_balance_is_null(accs[i]);
+
+        if (accs[i]["parentAccount"] == null) {
+            real_accs.push(return_account(accs[i]));
+        }
+    }
+    res.send(real_accs);
+});
+
+router.post("/", (req, res) => {
+    const number = req.body.number;
+    const name = req.body.name;
+    const des = req.body.description;
+    const type = req.body.type;
+    var qualifiedName;
+    if (req.body.parentAccount =="--- Wurzel Konto ---") {
+        qualifiedName = name;
+    } else {
+        qualifiedName = req.body.parentAccount + ":" + name;
+    }
+    const new_acc = db
+        .prepare(
+            `INSERT INTO accounts (number, name, qualifiedName, description, type, parentAccount) VALUES (?, ?, ? ,?, ?, ?)`,
+        )
+        .run(number, name, qualifiedName, des, type, req.body.parentAccount);
+    
+    res.status(204).send();
+    send_sse_update();
+    
+});
+
+router.get("/:account", (req, res) => {
+    var base_query = `SELECT number, name, qualifiedName, description, type, tf.balance, te.localBalance  FROM accounts 
+    LEFT JOIN (SELECT SUM(amount) as localBalance, account_name FROM transaction_entries GROUP BY account_name) te ON te.account_name = qualifiedName
+    LEFT JOIN (SELECT SUM(amount) as balance, account_name FROM transaction_entries GROUP BY account_name) tf ON tf.account_name = qualifiedName
+    WHERE qualifiedName = ?`;
+    const acc = db.prepare(base_query).get(req.params.account);
+
+    if (acc == undefined) {
+        res.status(404).send({
+            code: 404,
+            message: "Account not found",
+            additionalPropl: {},
+        });
+    } else {
+        fix_balance_is_null(acc);
+        
+        var real_acc;
+
+        fix_balance_is_null(acc);
+
+        if (acc["parentAccount"] == null) {
+            real_acc = return_account(acc);
+        }
+        acc["balance"] = real_acc["balance"]
+
+        entries = db
+            .prepare(
+                `
+                SELECT 
+	        transaction_entries.transaction_id as id,
+                offsetAccounts,
+                transaction_entries.amount,
+                transaction_entries.label,
+                postingDate,
+                valueDate,
+                title
+                from transaction_entries 
+                JOIN transactions ON transaction_entries.transaction_id = transactions.transaction_id
+                JOIN (SELECT account_name as offsetAccounts, transaction_id FROM transaction_entries) te ON te.transaction_id = id  AND offsetAccounts IS NOT transaction_entries.account_name
+                WHERE transaction_entries.account_name = ?`,
+            )
+            .all(req.params.account);
+        acc["entries"] = entries;
+        res.send(acc);
+    }
+});
+
+router.put("/:account", (req, res) => {
+    const oldname = req.params.account;
+    const name = req.body.name;
+    const description = req.body.description;
+    const type = req.body.type;
+    const qualifiedName = req.body.parentAccount + ":" + name;
+
+    const acc = db
+        .prepare(
+            `UPDATE accounts SET description = ?, name = ?, type = ?, number = ?, qualifiedName = ? WHERE qualifiedName = ?`,
+        )
+        .run(description, name, type, req.body.number, qualifiedName, req.params.account);
+
+    if (acc == undefined) {
+        res.status(404).send({
+            code: 404,
+            message: "Account not found",
+            additionalPropl: {},
+        });
+    } else {
+        res.status(204).send();
+        send_sse_update();
+
+    }
+});
+
+router.delete("/:account", (req, res) => {
+    const acc = db
+        .prepare("DELETE FROM accounts WHERE qualifiedName = ? RETURNING *")
+        .run(req.params.account);
+
+    if (acc["changes"] == 0) {
+        res.status(404).send({
+            code: 404,
+            message: "Account not found",
+            additionalPropl: {},
+        })
+    } else {
+        res.status(200).send();
+    }
+    send_sse_update();
+});
+
+module.exports = router;
--- a/src/routes/reset.js
+++ b/src/routes/reset.js
@@ -0,0 +1,15 @@
+const express = require('express');
+const router = express.Router();
+
+const {db, create_initial_accounts} = require("../dependencies");
+const {send_sse_update} = require("../sse")
+
+router.post("/reset", (req, res) => {
+    db.exec("DELETE FROM transaction_entries; DELETE FROM transactions; DELETE FROM accounts")
+    create_initial_accounts()
+
+    res.status(204).send()
+    send_sse_update()
+})
+
+module.exports = { router};
--- a/src/routes/transactions.js
+++ b/src/routes/transactions.js
@@ -0,0 +1,69 @@
+const express = require('express');
+const router = express.Router();
+
+const {db} = require("../dependencies");
+const {send_sse_update} = require("../sse")
+
+router.get("/", (req, res) => {
+    const transactions = db.prepare("SELECT transaction_id as id, postingDate, valueDate, title FROM transactions").all();
+
+    res.send(transactions)
+
+})
+
+
+router.post("/", (req, res) => {
+    const transaction = {
+        postingDate: req.body.postingDate,
+        valueDate: req.body.valueDate,
+        title: req.body.title,
+        entries: req.body.entries
+    }
+
+    const db_transaction = db.prepare("INSERT INTO transactions (postingDate, valueDate, title) VALUES (?, ?, ?) RETURNING transaction_id").run(transaction.postingDate, transaction.valueDate, transaction.title)
+
+    for (let i = 0; i < transaction.entries.length; i++) {
+        const db_entries = db.prepare("INSERT INTO transaction_entries (transaction_id, account_name, amount, label) VALUES (?, ?, ?, ?)").run(db_transaction.lastInsertRowid, transaction.entries[i].account, transaction.entries[i].amount, transaction.entries[i].label)
+    }
+
+
+    res.send({
+        id: db_transaction.lastInsertRowid
+    })
+    send_sse_update()
+
+})
+
+router.get("/:id", (req, res) => {
+    const transaction = db.prepare("SELECT postingDate, valueDate, title FROM transactions WHERE transaction_id = ?").get(req.params.id);
+    const entries = db.prepare("SELECT account_name as account, amount, label FROM transaction_entries WHERE transaction_id = ?").all(req.params.id)
+
+    transaction["entries"] = entries
+
+    res.send(transaction)
+})
+
+router.put("/:id", (req, res) => {
+    const transaction = db.prepare("UPDATE transactions SET postingDate = ?, valueDate = ?, title = ? WHERE transaction_id = ?").run(req.body.postingDate, req.body.valueDate, req.body.title, req.params.id)
+
+
+    const delete_entries = db.prepare("DELETE FROM transaction_entries WHERE transaction_id = ?").run(req.params.id)
+    for (let i = 0; i < req.body.entries.length; i++) {
+        const db_entries = db.prepare("INSERT INTO transaction_entries (transaction_id, account_name, amount, label) VALUES (?, ?, ?, ?)").run(req.params.id, req.body.entries[i].account, req.body.entries[i].amount, req.body.entries[i].label)
+    }
+
+    send_sse_update()
+    res.status(204).send()
+
+})
+
+router.delete("/:id", (req, res) => {
+    const delete_entries = db.prepare("DELETE FROM transaction_entries WHERE transaction_id = ?").run(req.params.id)
+    const delete_transaction = db.prepare("DELETE FROM transactions WHERE transaction_id = ?").run(req.params.id)
+
+
+    res.status(204).send()
+    send_sse_update()
+})
+
+module.exports = router;
--- a/src/sse.js
+++ b/src/sse.js
@@ -0,0 +1,51 @@
+var newcode;
+//helferfunktion die das richtige format für das event erstellt 
+function sendMessage(response, eventname, datacontent) {
+    //response.write ist ein append, also schreibt was ans ende der seite 
+    
+    response.write('event: ' + eventname + '\n' + 'data: ' + JSON.stringify(datacontent) + '\n\n')
+    newcode = false;
+}
+
+function send_sse_update() {
+    newcode = true;
+}
+
+function delay(message) {
+    return new Promise((resolve) => setTimeout(function () {
+        console.log(message);
+        resolve();
+    }, 5000))
+}
+const timeout = (ms) => new Promise(resolve => setTimeout(resolve, ms));
+
+
+// The while loop doesnt wait for the promise so sometimes it doesnt send the update
+async function sse(request, response) {
+
+    //header so setzen 
+    response.set({
+        'Cache-Control': 'no-cache',
+        'Content-Type': 'text/event-stream',
+        'Connection': 'keep-alive'
+    })
+    response.flushHeaders();
+    //loop, schickt ein event, wartet 5 sekunden, schickt dann erneut. 
+    // so abändern, dass anderer code in den loop hineingreifen kann (variable bool "newcode" oder so)
+    //dann wenn newcode = true, schicke ein eben via sendlive)
+    //der loop muss glaube ich bestehen bleiben
+    
+    while (true){
+        if (newcode) {
+            message = "update"
+            console.log("update send")
+        } else {
+            message = "hello"
+        }
+        sendMessage(response,message, {})
+        await timeout(3000);
+    }
+
+}
+
+module.exports = { sse, send_sse_update }