GS-2251

alex

2025-08-13 a0228eb7c0d7df0f41ac3a36243eb7d46c6ed09b

 lib/search.js

@@ -1,7 +1,9 @@
const fs = require("node:fs")
const _ = require("lodash")
const {Index, Document, Worker} = require("flexsearch")

const settings = require("../settings")
const fs = require("node:fs")
const log = require("../logger")

/////////////////////////////////////////////////////////////////////////

@@ -67,21 +69,22 @@
}

// run()
// .then(console.log)
// .then(log.info)
// .catch(console.error)

async function run () {
   await doIndex()
   console.log(search("latu"))
   log.info(search("latu"))
}

/////////////////////////////////////////////////////////////////////////

let indexed = false
async function doIndex () {
   const start = Date.now()
   console.log("++ START indexing Users...")

   log.info("++ START indexing Users...")
   const {readFromFile, file} = settings.search
   clearIndex(idxUser)

   let users
   if (readFromFile) {
@@ -89,24 +92,31 @@
      users = JSON.parse(users)
   }
   else {
      // TODO zweite möglichkeit "readFromApi" implementieren
      log.info("~~~ reading users from DB ... ~~~")
      const db = require("./db")
      const {data} = await db.getUsers(0, 100000)
      log.info(`loaded ${data.length} users from DB...`)
      users = data
   }

   for (const user of users) {
      addUser(user)
      // addTags(user)
   }
   console.log(`++ END indexing Users in ${Date.now() - start}ms`)
   indexed = true
   log.info(`++ END indexing Users in ${Date.now() - start}ms`)
}

function search (query) {
async function search (query) {
   // when called from a cli program the search index is not initalized
   if(!indexed) await doIndex()
   const searchLimit = 10000
   return idxUser.search(query, searchLimit)
}

function searchUsers (query, user) {
   // query = query.split(" ").join(" OR ") // ohne das "OR" scheint immer nur "AND" zu sein | die search option {bool:"or"} wird ignoriert
   // console.log(`searching messages for "${query}"`)
   // log.info(`searching messages for "${query}"`)
   return idxUser.search(`${user} ${query}`, {suggest: true})
}

@@ -122,7 +132,9 @@

function getUserString (user) {
   const {usr_id, firstname, lastname, login, institution, department} = user
   return `${usr_id} ${login} ${firstname} ${lastname} ${institution} ${department}`.trim()
   // if(firstname.trim()==="Adolfo") log.info(user)
   return `${login} ${firstname} ${lastname} ${institution} ${department}`.trim()
   // return `${usr_id} ${login} ${firstname} ${lastname} ${institution} ${department}`.trim() // KEINE usr_id
   // return `${usr_id} ${firstname} ${lastname}`.trim()
}

@@ -138,6 +150,10 @@
   remove(idxUser, usr_id)
}

function clearIndex(index) {
   index.clear()
}


/////// idxTags FNS ////////////////////////////////////////////////////////////////