index.js

#!/usr/bin/env node
const program = require('commander');
const { merge } = require('rxjs/observable/merge');
const { from } = require('rxjs/observable/from');
const {
  tap,
  switchMap,
  reduce,
  mergeMap,
  partition
} = require('rxjs/operators');

const { VERSION } = require('./src/constants');
const commit = require('./src/commit');
const {
  createCommitTemplate,
  getCommitTemplateFor
} = require('./src/create-commit-template');
const search = require('./src/search');

program
  .version(VERSION)
  .name('commit-with')
  .option('-a, --all', 'commit all changed files')
  .option(
    '-f, --force',
    'ignore cached commit templates, look up user again on github'
  )
  .arguments('<github-usernames...>')
  .description(
    'Searches Github for the user and auto generates a co-authored tag for your commit message'
  )
  .parse(process.argv);

const usernames = program.args;
const args = [program.all && '-a'].filter(v => v);
const cwd = process.cwd();

if (!usernames.length > 0) {
  program.help();
  process.exit(1);
}

const [filepath$, noFilepath$] = getCommitTemplateFor(usernames).pipe(
  partition(filepath => filepath && !program.force)
);

merge(
  filepath$,
  noFilepath$.pipe(
    switchMap(filepath =>
      from(usernames).pipe(
        mergeMap(search),
        reduce(
          (users, user) => Object.assign(users, { [user.login]: user }),
          {}
        ),
        tap(us => console.log({ us })),
        switchMap(createCommitTemplate)
      )
    )
  )
)
  .pipe(switchMap(filepath => commit(cwd, { args, filepath })))
  .subscribe(
    (code = 0) => process.exit(code),
    ({ message, code }) => {
      console.log(message);
      process.exit(code);
    }
  );