From 1208e72d1a24c8493296ac9853754d13368e6e1e Mon Sep 17 00:00:00 2001
From: alex <alex@alexloehr.net>
Date: Mon, 07 Jul 2025 07:52:10 +0000
Subject: [PATCH] GS-2199

---
 app.js |   71 ++++++++++++++++++++++++++++-------
 1 files changed, 57 insertions(+), 14 deletions(-)

diff --git a/app.js b/app.js
index e31d23f..dd1065a 100644
--- a/app.js
+++ b/app.js
@@ -29,26 +29,37 @@
       return res.send({status: "error", error: "access denied"})
    }
    else {
-      console.log("NO AUTH FOR ", req.url)
+      console.log("AUTH FOR ", req.url)
    }
 })
 
 /////// SEARCH ////////////////////////////////////////////////////////////////
 
 const searchLib = require("./lib/search")
+const {setStatus} = require("./lib/db")
 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 ////////////////////////////////////////////////////////////////
@@ -99,6 +110,11 @@
       }
    })
 
+   .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()
@@ -191,11 +207,38 @@
    //    }
    // })
 
+   /** set passed and status for a kurs TN */
+   .post("/api/kurs/:refId/status/:usrId", async function (req, res) {
+      const {refId, usrId} = req.params
+      const {passed, status} = req.body
+      if (!refId || !usrId || _.isEmpty(passed) || _.isEmpty(status)) {
+         throw {
+            statusCode: 400,
+            status: "error",
+            msg: "argument error"
+         }
+      }
+      try {
+         const {obj_id: course_id} = await db.getObjIdFromRefId(refId)
+         const data = await setStatus(course_id, usrId, passed, status)
+         return res.send(data)
+      } 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, statusCode: ex.statusCode})
+         }
+         return res.code(500).send({status: "error", msg})
+      }
+   })
+
    .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)
+         const {obj_id: course_id} = await db.getObjIdFromRefId(refId)
+         let data = await libIlias.abmelden(usrId, course_id)
+         // let data = await libIlias.deleteTeilnahme(refId, usrId)
          if (!data) throw {statusCode: 404, message: "Teilnahme not found"}
          return res.send(data)
       } catch (ex) {

--
Gitblit v1.8.0