Allow a list of users

Author: ericadamski

index.js

@@ -1,7 +1,14 @@
 #!/usr/bin/env node
 const program = require('commander');
 const { merge } = require('rxjs/observable/merge');
-const { switchMap, partition } = require('rxjs/operators');
+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');
@@ -17,32 +24,40 @@ program
   .option('-a, --all', 'commit all changed files')
   .option(
     '-f, --force',
-    'ignore cached commit templates, look up user again on githup'
+    'ignore cached commit templates, look up user again on github'
   )
-  .arguments('<github-username>')
+  .arguments('<github-usernames...>')
   .description(
     'Searches Github for the user and auto generates a co-authored tag for your commit message'
   )
   .parse(process.argv);
 
-const username = program.args[0];
+const usernames = program.args;
 const args = [program.all && '-a'].filter(v => v);
 const cwd = process.cwd();
 
-if (!username) {
+if (!usernames.length > 0) {
   program.help();
   process.exit(1);
 }
 
-const [filepath$, noFilepath$] = getCommitTemplateFor(username).pipe(
+const [filepath$, noFilepath$] = getCommitTemplateFor(usernames).pipe(
   partition(filepath => filepath && !program.force)
 );
 
 merge(
   filepath$,
   noFilepath$.pipe(
     switchMap(filepath =>
-      search(username).pipe(switchMap(createCommitTemplate))
+      from(usernames).pipe(
+        mergeMap(search),
+        reduce(
+          (users, user) => Object.assign(users, { [user.login]: user }),
+          {}
+        ),
+        tap(us => console.log({ us })),
+        switchMap(createCommitTemplate)
+      )
     )
   )
 )

src/create-commit-template.js

@@ -11,33 +11,38 @@ const access = bindNodeCallback(fs.access);
 const mkdir = bindNodeCallback(fs.mkdir);
 const writeFile = bindNodeCallback(fs.writeFile);
 
-function getTemplatePath(login) {
-  return path.join(TEMPLATE_ROOT, `.${login}`);
+function getTemplatePath(logins) {
+  return path.join(TEMPLATE_ROOT, `.${logins.join('-')}`);
 }
 
-function coauthor({ name, email }) {
+function coauthor(users) {
   return dedent`
     # Commiting with commit-with 🤗
     
-    Co-Authored-By: ${name} <${email}>
+    ${users
+      .map(({ name, email }) => `Co-Authored-By: ${name} <${email}>`)
+      .join('\n')}
     
     # ${Date.now()}-${VERSION}
   `;
 }
 
 module.exports = {
-  createCommitTemplate({ login, name, email }) {
+  createCommitTemplate(users) {
+    console.log({ users });
+
     return access(TEMPLATE_ROOT).pipe(
       catchError(() => mkdir(TEMPLATE_ROOT)),
       switchMap(() => {
-        const p = getTemplatePath(login);
+        const logins = Object.keys(users);
+        const p = getTemplatePath(logins);
 
-        return writeFile(p, coauthor({ name, email })).pipe(mapTo(p));
+        return writeFile(p, coauthor(Object.values(users))).pipe(mapTo(p));
       })
     );
   },
-  getCommitTemplateFor(login) {
-    const p = getTemplatePath(login);
+  getCommitTemplateFor(logins) {
+    const p = getTemplatePath(logins);
 
     return access(p).pipe(map(() => p), catchError(() => of(false)));
   }

src/helpers/get.js

@@ -4,7 +4,7 @@ const url = require('url');
 const { merge } = require('rxjs/observable/merge');
 const { fromEvent } = require('rxjs/observable/fromEvent');
 const { bindCallback } = require('rxjs/observable/bindCallback');
-const { map, switchMap, tap } = require('rxjs/operators');
+const { take, map, switchMap, tap } = require('rxjs/operators');
 
 const bufferToJson = require('./buffer-to-json');
 
@@ -33,7 +33,7 @@ module.exports = function get(uri) {
       merge(
         fromEvent(r, 'end').pipe(map(() => buffer), bufferToJson),
         fromEvent(r, 'error')
-      )
+      ).pipe(take(1))
     )
   );
 };

src/search.js

@@ -1,18 +1,26 @@
 const https = require('https');
-const { switchMap, zip, map } = require('rxjs/operators');
+const { tap, switchMap, zip, map } = require('rxjs/operators');
 
 const { GITHUB_URL } = require('./constants');
 const get = require('./helpers/get');
 const getEmail = require('./get-email');
 
+function findMatchingUser(username, users) {
+  const filteredUsers = users.filter(({ login }) => login === username);
+
+  return filteredUsers && filteredUsers.length > 0 ? filteredUsers[0] : {};
+}
+
 module.exports = function search(username) {
   return get(
     `${GITHUB_URL}/search/users?q=${username}+${encodeURIComponent(
       'in:login'
     )}&type=Users`
   ).pipe(
     switchMap(({ total_count, items }) =>
-      getEmail(username).pipe(zip((total_count > 0 && [items[0]]) || [{}]))
+      getEmail(username).pipe(
+        zip((total_count > 0 && [findMatchingUser(username, items)]) || [{}])
+      )
     ),
     switchMap(
       ([email, { url }]) =>