cic-internal-integration/apps/data-seeding/cic_meta/import_meta_custom.js

134 lines
3.2 KiB
JavaScript
Raw Permalink Normal View History

2021-04-24 08:14:24 +02:00
const fs = require('fs');
const path = require('path');
const http = require('http');
2021-05-21 11:42:08 +02:00
const cic = require('@cicnet/cic-client-meta');
const crdt = require('@cicnet/crdt-meta');
2021-04-24 08:14:24 +02:00
//const conf = JSON.parse(fs.readFileSync('./cic.conf'));
2021-05-21 11:42:08 +02:00
const config = new crdt.Config('./config');
2021-04-24 08:14:24 +02:00
config.process();
console.log(config);
function sendit(uid, envelope) {
const d = envelope.toJSON();
const contentLength = (new TextEncoder().encode(d)).length;
const opts = {
method: 'PUT',
headers: {
'Content-Type': 'application/json',
'Content-Length': contentLength,
'X-CIC-AUTOMERGE': 'client',
},
};
let url = config.get('META_URL');
url = url.replace(new RegExp('^(.+://[^/]+)/*$'), '$1/');
console.log('posting to url: ' + url + uid);
const req = http.request(url + uid, opts, (res) => {
res.on('data', process.stdout.write);
res.on('end', () => {
console.log('result', res.statusCode, res.headers);
});
});
if (!req.write(d)) {
console.error('foo', d);
process.exit(1);
}
req.end();
}
function doOne(keystore, filePath, identifier) {
2021-05-21 11:42:08 +02:00
const signer = new crdt.PGPSigner(keystore);
2021-04-24 08:14:24 +02:00
const o = JSON.parse(fs.readFileSync(filePath).toString());
2021-05-21 11:42:08 +02:00
cic.Custom.toKey(identifier).then((uid) => {
const s = new crdt.Syncable(uid, o);
s.setSigner(signer);
s.onwrap = (env) => {
sendit(identifier, env);
};
s.sign();
});
2021-04-24 08:14:24 +02:00
}
const privateKeyPath = path.join(config.get('PGP_EXPORTS_DIR'), config.get('PGP_PRIVATE_KEY_FILE'));
const publicKeyPath = path.join(config.get('PGP_EXPORTS_DIR'), config.get('PGP_PRIVATE_KEY_FILE'));
pk = fs.readFileSync(privateKeyPath);
pubk = fs.readFileSync(publicKeyPath);
2021-05-21 11:42:08 +02:00
new crdt.PGPKeyStore(
2021-04-24 08:14:24 +02:00
config.get('PGP_PASSPHRASE'),
pk,
pubk,
undefined,
undefined,
importMetaCustom,
);
const batchSize = 16;
const batchDelay = 1000;
const total = parseInt(process.argv[3]);
const dataDir = process.argv[2];
const workDir = path.join(dataDir, 'custom/meta');
const userDir = path.join(dataDir, 'custom/new');
let count = 0;
let batchCount = 0;
function importMetaCustom(keystore) {
let err;
let files;
try {
err, files = fs.readdirSync(workDir);
} catch {
console.error('source directory not yet ready', workDir);
2021-05-21 11:42:08 +02:00
setTimeout(importMetaCustom, batchDelay, keystore);
2021-04-24 08:14:24 +02:00
return;
}
let limit = batchSize;
if (files.length < limit) {
limit = files.length;
}
for (let i = 0; i < limit; i++) {
const file = files[i];
if (file.length < 3) {
console.debug('skipping file', file);
continue;
}
//const identifier = file.substr(0,file.length-5);
const identifier = file;
const filePath = path.join(workDir, file);
console.log(filePath);
//const address = fs.readFileSync(filePath).toString().substring(2).toUpperCase();
const custom = JSON.parse(fs.readFileSync(filePath).toString());
const customFilePath = path.join(
userDir,
identifier.substring(0, 2),
identifier.substring(2, 4),
identifier + '.json',
);
doOne(keystore, filePath, identifier);
fs.unlinkSync(filePath);
count++;
batchCount++;
if (batchCount == batchSize) {
console.debug('reached batch size, breathing');
batchCount=0;
2021-05-21 11:42:08 +02:00
setTimeout(importMetaCustom, batchDelay, keystore);
2021-04-24 08:14:24 +02:00
return;
}
}
if (count == total) {
return;
}
setTimeout(importMetaCustom, 100, keystore);
}