initial commit

[squeep-indie-auther] / bin / authUserAdd.js

diff --git a/bin/authUserAdd.js b/bin/authUserAdd.js
new file mode 100644 (file)
index 0000000..cc71552
--- /dev/null
+++ b/bin/authUserAdd.js
@@ -0,0 +1,70 @@
+'use strict';
+
+const argon2 = require('argon2');
+const readline = require('readline');
+const stream = require('stream');
+const DB = require('../src/db');
+const Logger = require('../src/logger');
+const Config = require('../config');
+const config = new Config(process.env.NODE_ENV);
+
+const logger = new Logger(config);
+const db = new DB(logger, config);
+
+const flags = {
+  isPAM: false,
+};
+if (process.argv.includes('-P')) {
+  flags.isPAM = true;
+  process.argv.splice(process.argv.indexOf('-P'), 1);
+}
+
+const identifier = process.argv[2];
+
+if (!identifier) {
+  console.log('missing user to add');
+  throw new Error('missing argument');
+}
+
+async function readPassword(prompt) {
+  const input = process.stdin;
+  const output = new stream.Writable({
+    write: function (chunk, encoding, callback) {
+      if (!this.muted) {
+        process.stdout.write(chunk, encoding);
+      }
+      callback();
+    },
+  });
+  const rl = readline.createInterface({ input, output, terminal: !!process.stdin.isTTY });
+  rl.setPrompt(prompt);
+  rl.prompt();
+  output.muted = true;
+
+  return new Promise((resolve) => {
+    rl.question('', (answer) => {
+      output.muted = false;
+      rl.close();
+      output.write('\n');
+      resolve(answer);
+    });
+  });
+}
+
+(async () => {
+  await db.initialize();
+  let credential;
+  if (flags.isPAM) {
+    credential = '$PAM$';
+  } else {
+    const password = await readPassword('password: ');
+    credential = await argon2.hash(password, { type: argon2.argon2id });
+  }
+  console.log(`\t${identifier}:${credential}`);
+  await db.context(async (dbCtx) => {
+    const result = await db.authenticationUpsert(dbCtx, identifier, credential);
+    console.log(result);
+  });
+  console.log('done');
+  await db._closeConnection();
+})();