-
Notifications
You must be signed in to change notification settings - Fork 2
/
makePreSuc.js
73 lines (66 loc) · 2.32 KB
/
makePreSuc.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
const fs = require('fs');
const superagent = require('superagent');
const readline = require('readline');
const path = require('path');
const { getAuthToken } = require('./lib/login');
let inFile = process.argv[2];
(async () => {
try {
const start = new Date().valueOf();
if (!inFile) {
throw 'Usage: node makePreSuc.js <jsonl_file>';
} else if (!fs.existsSync(inFile)) {
throw new Error('Can\'t find input file');
}
const config = (fs.existsSync('./config.js')) ? require('./config.js') : require('./config.default.js');
const workingDir = path.dirname(inFile);
const baseName = path.basename(inFile, '.jsonl');
const outPath = `${workingDir}/${baseName}_done.jsonl`;
if (fs.existsSync(outPath)) {
fs.unlinkSync(outPath);
}
const authToken = await getAuthToken(superagent, config.okapi, config.tenant, config.authpath, config.username, config.password);
const fileStream = fs.createReadStream(inFile);
const rl = readline.createInterface({
input: fileStream,
crlfDelay: Infinity
});
let x = 0;
for await (const line of rl) {
x++;
let rec = JSON.parse(line);
if (rec.succeedingInstanceId) {
let ids = rec.identifiers || [];
for (y = 0; y < ids.length; y++) {
let linkId = '';
let idType = ids[y].identifierTypeId;
let idVal = ids[y].value;
let url = `${config.okapi}/instance-storage/instances?query=(identifiers%20=/@value/@identifierTypeId=${idType}%20%22${idVal}%22)`
console.log(`[${x}.${y}] GET ${url}`);
try {
let res = await superagent
.get(url)
.set('x-okapi-token', authToken)
.set('accept', 'application/json');
let inst = res.body.instances;
if (inst.length > 0) {
linkId = inst[0].id;
rec.precedingInstanceId = linkId;
console.log(`INFO match found for ${linkId}`);
break;
}
} catch (e) {
console.log(e);
}
}
}
let out = JSON.stringify(rec) + '\n';
fs.writeFileSync(outPath, out, { flag: 'as' })
}
const end = new Date().valueOf();
const ms = end - start;
const time = Math.floor(ms / 1000);
} catch (e) {
console.error(e);
}
})();