-
Notifications
You must be signed in to change notification settings - Fork 2
/
usersActiveToggle.js
84 lines (77 loc) · 2.67 KB
/
usersActiveToggle.js
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
/*
This script takes a checkout-by-barcode file and sets user.active to true if currently false (and vice-versa)
*/
const fs = require('fs');
const superagent = require('superagent');
const { getAuthToken } = require('./lib/login');
const readline = require('readline');
const fn = process.argv[2];
const tf = process.argv[3];
(async () => {
try {
if (!fn) {
throw new Error(`Usage: node usersActiveToggle.js <inactive_users_jsonl> [true|false]`);
}
let config = await getAuthToken(superagent);
let seen = {};
const fileStream = fs.createReadStream(fn);
const rl = readline.createInterface({
input: fileStream,
crlfDelay: Infinity
});
let d = 0;
for await (const line of rl) {
d++;
let data = JSON.parse(line);
let bc = data.barcode || data.userBarcode;
if (!seen[bc]) {
seen[bc] = 1;
let url = `${config.okapi}/users?query=%28barcode%3D%3D%22${bc}%22%29`;
try {
console.log(`[${d}] GET ${url}...`);
let res = await superagent
.get(url)
.timeout({ response: 5000 })
.set('accept', 'application/json')
.set('x-okapi-token', config.token)
let userRecs = res.body;
if (userRecs.resultInfo.totalRecords !== 1) throw new Error(`Did not fetch a single record for barcode ${bc}`);
let user = userRecs.users[0];
try {
let purl = `${config.okapi}/users/${user.id}`;
if (tf === 'false') {
user.active = false
user.expirationDate = (data.experationDate) ? data.expirationDate : null;
} else if (tf === 'true') {
user.active = true
user.expirationDate = '2025-12-31T00:00:00.000+0000'
} else if (!user.active) {
user.active = true;
user.expirationDate = '2025-12-31T00:00:00.000+0000'
} else {
user.active = false;
user.expirationDate = (data.experationDate) ? data.expirationDate : null;
}
console.log(` POST ${purl}...`);
console.log(` Changing user.active to "${user.active}"...`);
await superagent
.put(purl)
.timeout({ response: 5000 })
.set('accept', 'text/plain')
.set('x-okapi-token', config.token)
.set('content-type', 'application/json')
.send(user);
} catch (e) {
console.log(e);
}
} catch (e) {
console.log(e);
}
} else {
console.log(`[${d}] SKIPPING ${bc} already changed...`)
}
}
} catch (e) {
console.error(e.message);
}
})();