cic-stack/apps/data-seeding/cic_meta/import_meta_custom.js

const fs = require('fs');
const path = require('path');
const http = require('http');

const cic = require('cic-client-meta');
const vcfp = require('vcard-parser');

//const conf = JSON.parse(fs.readFileSync('./cic.conf'));

const config = new cic.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, identifier) {
	const signer = new cic.PGPSigner(keystore);

	const o = 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 o = fs.readFileSync(filePath, 'utf-8');

	const s = new cic.Syncable(identifier, o);
	s.setSigner(signer);
	s.onwrap = (env) => {
		sendit(identifier, 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 cic.PGPKeyStore(
	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);
		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.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;
			setTimeout(importMeta, batchDelay, keystore);
			return;
		}
	}
	if (count == total) {
		return;
	}
	setTimeout(importMetaCustom, 100, keystore);
}