From e2dc64672428e599d45c70c6c560e06501477e0b Mon Sep 17 00:00:00 2001
From: alex <alex@alexloehr.net>
Date: Fri, 20 Jun 2025 15:43:41 +0000
Subject: [PATCH] GS-2156

---
 app.js |   94 ++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 72 insertions(+), 22 deletions(-)

diff --git a/app.js b/app.js
index 7c2142b..3db466b 100644
--- a/app.js
+++ b/app.js
@@ -6,6 +6,7 @@
 const fs = require("node:fs")
 
 const db = require("./lib/db")
+const libIlias = require("./lib/libIlias")
 const settings = require("./settings")
 const search = require("./lib/search.js")
 
@@ -36,27 +37,37 @@
 
 const searchLib = require("./lib/search")
 searchLib.doIndex().catch(console.error)
-fastify.get("/api/search/user", async function (req, res) {
-   console.log(req.query)
-   const search = req.query?.search
-   if (!search) {
-      return res.code(422).send({status: "error", msg: "no search"})
-   }
-   else {
-      console.log(search)
-      const data = await searchLib.search(search)
-      return res.send(data)
-   }
-})
+fastify
+   .get("/api/search/user", async function (req, res) {
+      console.log(req.query)
+      const search = req.query?.search
+      if (!search) {
+         return res.code(422).send({status: "error", msg: "no search"})
+      }
+      else {
+         console.log(search)
+         const data = await searchLib.search(search)
+         return res.send(data)
+      }
+   })
+   .post("/api/search/reindex", async function (req, res) {
+      console.log("REINDEX ++++")
+      const start = Date.now()
+      await searchLib.doIndex().catch(console.error)
+      return res.send({
+         status: "ok",
+         msg: `reindexed in ${Date.now() - start} ms`,
+      })
+   })
 
 fastify
    /////// USER ////////////////////////////////////////////////////////////////
-   .get('/api/users', async function (req, res) {
+   .get('/api/user', async function (req, res) {
       const {offset, limit, search} = req.query
       const users = await db.getUsers(offset, limit, search)
       return res.send(users)
    })
-   .get("/api/users/count", async function (req, res) {
+   .get("/api/user/count", async function (req, res) {
       const count = await db.getUserCount()
       return res.send(count)
    })
@@ -95,6 +106,28 @@
       }
       else {
          return res.code(404).send({status: "error", msg: "not found"})
+      }
+   })
+
+   .post("/api/user", async function (req, res) {
+      const user = req.body
+      const res2 = await libIlias.importIliasUser(user) // TODO import or update if already available
+      return res.send(res2)
+   })
+
+   .delete("/api/user", async function (req, res) { // DELETE ALL users
+      const res2 = await libIlias.deleteAllUsers()
+      return res.send(res2)
+   })
+   .delete("/api/user/:usr_id", async function (req, res) {
+      const {usr_id} = req.params
+      if (!usr_id || isNaN(Number(usr_id))) {
+         return res.code(500).send({status: "error", msg: "userId error"})
+      }
+      else {
+         const res2 = await libIlias.deleteUser(usr_id)
+         console.log(res2)
+         return res.send(res2)
       }
    })
 
@@ -152,7 +185,7 @@
          return res.code(404).send({status: "error", msg: "not found"})
       }
    })
-   .get("/api/kurs/teilnehmer/:refId", async function (req, res) {
+   .get("/api/kurs/:refId/teilnehmer", async function (req, res) {
       const {refId} = req.params
       let data = await db.getKursTeilnehmer(refId)
       if (data) {
@@ -162,14 +195,31 @@
          return res.code(404).send({status: "error", msg: "not found"})
       }
    })
-   .get("/api/kurs/teilnehmer/:refId/count", async function (req, res) {
-      const {refId} = req.params
-      let data = await db.getKursTeilnehmerCount(refId)
-      if (data) {
+   // .get("/api/kurs/:refId/teilnehmer/count", async function (req, res) {
+   //    const {refId} = req.params
+   //    let data = await db.getKursTeilnehmerCount(refId)
+   //    if (data) {
+   //       return res.send(data)
+   //    }
+   //    else {
+   //       return res.code(404).send({status: "error", msg: "not found"})
+   //    }
+   // })
+
+   .delete("/api/kurs/:refId/teilnehmer/:usrId", async function (req, res) {
+      const {refId, usrId} = req.params
+      if (!refId || !usrId) throw {status: "error", msg: "refId and usrId requried"}
+      try {
+         let data = await libIlias.deleteTeilnahme(refId, usrId)
+         if (!data) throw {statusCode: 404, message: "Teilnahme not found"}
          return res.send(data)
-      }
-      else {
-         return res.code(404).send({status: "error", msg: "not found"})
+      } catch (ex) {
+         console.error(ex)
+         const msg = ex.msg ?? ex.message ?? ex.toString()
+         if (ex.statusCode) {
+            return res.code(ex.statusCode).send({status: "error", msg})
+         }
+         return res.code(500).send({status: "error", msg})
       }
    })
 

--
Gitblit v1.8.0