invitations.js

'use strict';

const fetch = require('../fetch');
const figgy = require('figgy-pudding');
const { whoAmI } = require('../utils');

module.exports = invitations;

// usage: ds invitations namespace
// list all invitations for the given namespace, if the logged-in user has permission

const invitationsOpts = figgy({
  argv: true,
  registry: { default: 'https://registry.entropic.dev' },
  registries: { default: [] },
  token: true,
  packages: true,
  log: { default: require('npmlog') }
});

const getUrl = (packages, registry, invitee) =>
  packages
    ? `${registry}/v1/namespaces/namespace/${invitee}/maintainerships?status=pending`
    : `${registry}/v1/users/user/${invitee}/memberships?status=pending`;

async function invitations(opts) {
  opts = invitationsOpts(opts);
  let invitee = opts.argv[0] || (await whoAmI(opts));
  if (!invitee) {
    console.log('Usage: ds invitations <namespace|user> [--packages]');
    process.exit(1);
  }

  if (!invitee.includes('@')) {
    invitee += '@' + opts.registry.replace(/^https?:\/\//, '');
  }

  const response = await fetch(getUrl(opts.packages, opts.registry, invitee), {
    headers: { authorization: `Bearer ${opts.token}` }
  });

  const pkg = await response.json();
  let result = [];
  if (Array.isArray(pkg.objects)) {
    result = pkg.objects;
  }

  const qualifier = opts.packages ? 'package ' : '';

  if (result.length === 0) {
    console.log(`${invitee} has no ${qualifier}invitations.`);
    return 0;
  }

  console.log(
    `${invitee} has ` +
      (result.length === 1
        ? `one ${qualifier}invitation.`
        : `${result.length} ${qualifier}invitations.`) +
      '\nTo accept:\n'
  );

  result.forEach(dest => {
    console.log(`  ds join ${dest.name} --as ${invitee}`);
  });

  console.log(
    `\nTo decline an invitation: ds decline <group|package> --as ${invitee}`
  );
}