rs-cli.js

const yargs = require('yargs');
const { execSync } = require('child_process');
const cliProgress = require('cli-progress');
const { exit } = require('process');

const WEBHOOK_NAME = 'reactivesearch';

const options = yargs
	.usage(
		'Usage: --private-api-key <private api key> --api-key <public api key> --app-id <application id>',
	)
	.option('private-api-key', {
		alias: 'private_api_key',
		describe: 'Private API Key',
		type: 'string',
		demandOption: true,
	})
	.option('api-key', {
		alias: 'api_key',
		describe: 'Public API Key',
		type: 'string',
		demandOption: true,
	})
	.option('app-id', {
		alias: 'app_id',
		describe: 'Application ID',
		type: 'string',
		demandOption: true,
	})
	.option('app-authentication', {
		alias: 'app_authentication',
		describe: 'Application Authentication',
		type: 'string',
		demandOption: false,
	})
	.option('v', {
		alias: 'verbose',
		describe: 'Verbose',
		demandOption: false,
	})
	.check((argv, options) => {
		const { app_authentication } = argv;
		if (app_authentication) {
			const appAuthentication = app_authentication.split(':');
			console.log(app_authentication);
			if (
				appAuthentication.length < 2 ||
				appAuthentication[0].length < 1 ||
				appAuthentication[1].length < 1
			) {
				throw new Error(
					'Invalid app authentication credential format : --app-authentication format should $user:$password, $user and $password should contain at least one character',
				);
			}
		}
		return true;
	}).argv;

const { api_key, private_api_key, app_id, app_authentication, verbose } =
	options;
const bar = new cliProgress.SingleBar({}, cliProgress.Presets.shades_classic);

let webhookEndpoint;
console.log('\nDeploying ReactiveSearch API as a Realm function\n');
let step = -1;
try {
	bar.start(5, ++step);
	execSync(
		`./node_modules/mongodb-realm-cli/realm-cli login --api-key=${api_key} --private-api-key=${private_api_key} -y`,
	);
	bar.update(++step);
	execSync(
		`rm -rf realm-app && ./node_modules/mongodb-realm-cli/realm-cli pull --local=./realm-app  --remote=${app_id}`,
	);
	bar.update(++step);
	execSync(
		`node build --name=${WEBHOOK_NAME}` +
			(app_authentication ? ` --app-authentication=${app_authentication}` : ''),
	);
	bar.update(++step);
	execSync(
		`./node_modules/mongodb-realm-cli/realm-cli push --local=./realm-app --yes`,
	);
	bar.update(++step);
	const appDescription = JSON.parse(
		execSync(
			`./node_modules/mongodb-realm-cli/realm-cli app describe --app=${app_id}`,
		)
			.toString()
			.replace('App description', ''),
	);
	let { http_endpoints } = appDescription;
	http_endpoints.map((endpoint) =>{
		if (endpoint.route === '/http_endpoint_reactivesearch') {
			webhookEndpoint = endpoint.url;
		}
	});
	bar.update(++step);
	bar.stop();
	console.info('\n Successfully deployed webhook.');
} catch (error) {
	switch (step) {
		case 0:
			console.error(
				'\n Deployment Failed: Please check you public and private api keys',
			);
			break;
		case 1:
			console.error(
				'\n Deployment Failed: Unable to pull application configuration. Please check your application id.',
			);
			break;
		case 2:
			console.error(
				'\n Deployment Failed: Please make sure to run yarn install or npm install',
			);
			break;
		case 3:
			console.error(
				'\n Deployment Failed: Unable to push application configuration. Please check your application id.',
			);
			break;
		case 4:
			console.error(
				'\n Deployment Failed: Unable to find endpoint of http webhook',
			);
			break;
	}
	if (verbose) {
		console.log('\n');
		console.log(error.toString());
	}

	console.error('\n Failed to deploy webhook');
	bar.stop();
	exit();
}

if (webhookEndpoint) {
	console.info(`\n Deployed webhook endpoint : ${webhookEndpoint}`);
	console.log(
		`\n You can make a test request to this webhook using this curl command \n`,
	);
	console.log(`curl -XPOST ${webhookEndpoint} ${
		app_authentication ? `-u ${app_authentication}` : ``
	} \\
        -H "Content-Type: application/json" \\
        -d '{
	"query": [{
		"id": "search",
		"dataField": "*",
		"size": 5
	}],
	"mongodb": {
		"db": "'"$database"'",
		"collection": "'"$collection"'"
	}
}'
     `);
} else {
	console.error("\n Something went wrong. We aren't able to find endpoint");
}