135 lines
3.1 KiB
JavaScript
135 lines
3.1 KiB
JavaScript
const fs = require('fs');
|
|
const path = require('path');
|
|
const http = require('http');
|
|
|
|
const cic = require('cic-client-meta');
|
|
const vcfp = require('vcard-parser');
|
|
const crdt = require('crdt-meta');
|
|
|
|
//const conf = JSON.parse(fs.readFileSync('./cic.conf'));
|
|
|
|
const config = new crdt.Config('./config');
|
|
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, address) {
|
|
const signer = new crdt.PGPSigner(keystore);
|
|
|
|
const j = JSON.parse(fs.readFileSync(filePath).toString());
|
|
const b = Buffer.from(j['vcard'], 'base64');
|
|
const s = b.toString();
|
|
const o = vcfp.parse(s);
|
|
const phone = o.tel[0].value;
|
|
|
|
cic.Phone.toKey(phone).then((uid) => {
|
|
|
|
const s = new crdt.Syncable(uid, address);
|
|
s.setSigner(signer);
|
|
s.onwrap = (env) => {
|
|
sendit(uid, env);
|
|
};
|
|
s.sign();
|
|
});
|
|
}
|
|
|
|
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);
|
|
|
|
new crdt.PGPKeyStore(
|
|
config.get('PGP_PASSPHRASE'),
|
|
pk,
|
|
pubk,
|
|
undefined,
|
|
undefined,
|
|
importMetaPhone,
|
|
);
|
|
|
|
const batchSize = 16;
|
|
const batchDelay = 1000;
|
|
const total = parseInt(process.argv[3]);
|
|
const dataDir = process.argv[2];
|
|
const workDir = path.join(dataDir, 'phone/meta');
|
|
const userDir = path.join(dataDir, 'new');
|
|
let count = 0;
|
|
let batchCount = 0;
|
|
|
|
|
|
function importMetaPhone(keystore) {
|
|
let err;
|
|
let files;
|
|
|
|
try {
|
|
err, files = fs.readdirSync(workDir);
|
|
} catch {
|
|
console.error('source directory not yet ready', workDir);
|
|
setTimeout(importMetaPhone, batchDelay, keystore);
|
|
return;
|
|
}
|
|
let limit = batchSize;
|
|
if (files.length < limit) {
|
|
limit = files.length;
|
|
}
|
|
for (let i = 0; i < limit; i++) {
|
|
const file = files[i];
|
|
if (file.substr(0) == '.') {
|
|
console.debug('skipping file', file);
|
|
}
|
|
const filePath = path.join(workDir, file);
|
|
|
|
const address = fs.readFileSync(filePath).toString().substring(2).toUpperCase();
|
|
const metaFilePath = path.join(
|
|
userDir,
|
|
address.substring(0, 2),
|
|
address.substring(2, 4),
|
|
address + '.json',
|
|
);
|
|
|
|
doOne(keystore, metaFilePath, address);
|
|
fs.unlinkSync(filePath);
|
|
count++;
|
|
batchCount++;
|
|
if (batchCount == batchSize) {
|
|
console.debug('reached batch size, breathing');
|
|
batchCount=0;
|
|
setTimeout(importMetaPhone, batchDelay, keystore);
|
|
return;
|
|
}
|
|
}
|
|
if (count == total) {
|
|
return;
|
|
}
|
|
setTimeout(importMetaPhone, 100, keystore);
|
|
}
|