adding cli prog getObjId.js

alex

2025-06-02 4d7b17561bf7a11572f31e9a51818a5de4f73528

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
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
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,
 
   getObjIdFromRefId,
   getRefIdFromObjId,
}
 
/////////////////////////////////////////////////////////////////////////
 
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 ${database}.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 ${database}.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 ${database}.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 ${database}.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 ${database}.udf_definition ud  
        JOIN ${database}.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 ${database}.udf_definition ud  
        JOIN ${database}.udf_text ut ON ut.field_id = ud.field_id
        WHERE ut.usr_id = '${usr_id}'
        `
   )
   return results
}
 
/////// obj_id / ref_id ////////////////////////////////////////////////////////////////
 
async function getObjIdFromRefId (refId) {
   const pool = await poolP
   const [results] = await pool.query(
      `SELECT ref_id, obj_id
       FROM ${database}.object_reference as obr
       WHERE obr.ref_id = ${refId}
      `
   )
   return results.length ? results[0] : undefined
}
 
async function getRefIdFromObjId (objId) {
   const pool = await poolP
   const [results] = await pool.query(
      `SELECT ref_id, obj_id
       FROM ${database}.object_reference as obr
       WHERE obr.obj_id = ${objId}
      `
   )
   return results.length ? results[0] : undefined
}
 
/////////////////////////////////////////////////////////////////////////
 
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
}