adding user-defined-fields

alex

2025-05-16 1729ad5f15bcac23ed6114db0ed302efcb54ddcf

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
const mysql = require("mysql2/promise")
 
const {host, port, user, database, password} = require("./../settings").db
 
/////////////////////////////////////////////////////////////////////////
 
let poolP = initPool()
 
async function initPool () {
   return mysql.createPool({
      host,
      port,
      database,
      user,
      password,
   })
}
 
/////////////////////////////////////////////////////////////////////////
 
module.exports = {
   getUsers,
   getUserCount,
   getUserByLogin,
   getUserByUserId,
   getUserDefinedFields,
   getUserDefinedField,
}
 
/////////////////////////////////////////////////////////////////////////
 
async function getUsers (offset = 0, limit = 10) {
   const sel = `usr_id, login, firstname, lastname, gender, email, institution, street, city, zipcode, country, department, active`
   // TODO user defined fields
   // TODO check args for SQL Injection
 
   const pool = await poolP
   const [results, fields] = await pool.query(
      `SELECT ${sel}
       FROM ilias.usr_data AS ud
       WHERE login REGEXP '^[0-9]+$'
       LIMIT ${limit}
       OFFSET ${offset}
      `
   )
   const count = await getUserCount()
   return {
      total: count,
      offset, limit,
      data: results,
   }
}
 
async function getUserCount () {
   const pool = await poolP
   const [results, fields] = await pool.query(
      `SELECT COUNT(*)
       FROM ilias.usr_data AS ud
       WHERE login REGEXP '^[0-9]+$'`
   )
   return results[0]["COUNT(*)"]
}
 
async function getUserByLogin (login) {
   const sel = `usr_id, login, firstname, lastname, gender, email, institution, street, city, zipcode, country, department, active`
   // TODO user defined fields
   // TODO check args for SQL Injection
 
   const pool = await poolP
   const [results, fields] = await pool.query(
      `SELECT ${sel}
       FROM ilias.usr_data AS ud
       WHERE login = '${login}'
         AND login REGEXP '^[0-9]+$'`
   )
   return joinUDF(results[0])
}
 
async function getUserByUserId (userId) {
   const sel = `usr_id, login, firstname, lastname, gender, email, institution, street, city, zipcode, country, department, active`
   // TODO user defined fields
   // TODO check args for SQL Injection
 
   const pool = await poolP
   const [results, fields] = await pool.query(
      `SELECT ${sel}
       FROM ilias.usr_data AS ud
       WHERE usr_id = '${userId}'
         AND login REGEXP '^[0-9]+$'`
   )
   return joinUDF(results[0])
}
 
async function getUserDefinedFields () {
   const pool = await poolP
   const [results] = await pool.query(
      `SELECT ut.usr_id, ud.field_name, ut.value
        FROM ilias.udf_definition ud  
        JOIN ilias.udf_text ut ON ut.field_id = ud.field_id`
   )
   return results
}
 
async function getUserDefinedField (usr_id) {
   const pool = await poolP
   const [results] = await pool.query(
      `SELECT ut.usr_id, ud.field_name, ut.value
        FROM ilias.udf_definition ud  
        JOIN ilias.udf_text ut ON ut.field_id = ud.field_id
        WHERE ut.usr_id = '${usr_id}'
        `
   )
   return results
}
 
/////////////////////////////////////////////////////////////////////////
 
async function promiseDelay (ms) {
   return new Promise(resolve => setTimeout(resolve, ms))
}
 
async function joinUDF (user) {
   const fields = await getUserDefinedField(user.usr_id)
   for(const field of fields) {
      user[field.field_name] = field.value
   }
   return user
}