members.js

Filename	Percent	Threshold	Total	Covered	Uncovered
plugins/members.js	98.58%	80%	211	208	3

//@ts-check

import { assign, get, isEmpty, isNil, transform, upperFirst } from 'lodash-es';
import async from 'async';
import * as utils from '../src/utils.js';
import { AccessLevel } from '../src/Consts.js';

const service = 'members';

/**
 * @param  {GitConfig.Env} env
 * @param  {GitConfig.$ProjectSchema} project
 * @param  {GitConfig.Settings} settings
 */
export async function update(env /*: Env */, project /*: $ProjectDesc */, settings /*: $Settings */) {
  if (utils.isIgnored(env, project, settings, upperFirst(service))) {
    return;
  }

  env.spin.start(`Fetching ${service} config: ${project.name}`);
  var current = /** @type {GitConfig.$MemberSchema[]} */ (
    await env.gitlab.ProjectMembers.all(project.id, { includeInherited: true }));

  const isStrict = get(settings, 'config.strict');
  var perms = transform(AccessLevel, (ret, level, levelName) => {
    transform(get(settings, [ 'config', levelName ]), (ret, user) => {
      ret[user] = level;
    }, ret);
  }, /** @type {{ [user:string]: GitConfig.$AccessLevel }} */ ({}));

  var updated = false;
  await async.eachSeries(current, async function(member) {
    const perm = perms[member.username];
    delete perms[member.username];
    return updatePerm(env, project, member, perm, isStrict)
    .then((up) => (updated = (updated || up)));
  });

  await async.eachOfSeries(perms, async function(perm, username) {
    const ret = /** @type {GitConfig.$UserSchema[]} */ (
      await env.gitlab.Users.all({ username: /** @type {string} */ (username) }));
    if (!ret || isEmpty(ret)) { throw 'user not found: ' + username; }
    const user = assign(ret[0], { access_level: 0 });

    if (await updatePerm(env, project, user, perm, isStrict)) {
      updated = true;
    }
  });
  if (updated) {
    env.spin.succeed(`${upperFirst(service)} updated: ${project.name}`);
  }
}

/**
 * @param {GitConfig.Env} env
 * @param {GitConfig.$ProjectSchema} project
 * @param {GitConfig.$MemberSchema} member
 * @param {GitConfig.$AccessLevel|undefined|null} perm
 * @param {boolean} [isStrict]
 */
async function updatePerm(env, project, member, perm, isStrict) {
  var updated = false;

  if (isNil(perm)) {
    if (isStrict) {
      if (env.opts.dryRun) {
        env.spin.warn(`${upperFirst(service)} ${member.username} should be removed from: ${project.name}`);
      }
      else {
        /* ldap users are hard to remove */
        await env.gitlab.ProjectMembers.remove(project.id, member.id)
        .catch(() => env.gitlab.ProjectMembers.edit(project.id, member.id, AccessLevel.guest))
        .catch(() => env.gitlab.ProjectMembers.add(project.id, member.id, AccessLevel.guest));
        updated = true;
      }
    }
  }
  else if (member.access_level === AccessLevel.owner) {
    /* can't modify owner */
  }
  else if (member.access_level !== perm) {
    if (env.opts.dryRun) {
      const type = (perm > member.access_level) ? "promoted" : "demoted";
      env.spin.warn(`${upperFirst(service)} ${member.username} should be ${type} on: ${project.name}`);
    }
    else {
      await env.gitlab.ProjectMembers.edit(project.id, member.id, perm)
      // @ts-ignore
      .catch(() => env.gitlab.ProjectMembers.add(project.id, member.id, perm));
      updated = true;
    }
  }
  return updated;
}

export default update;

[{"file":"plugins/members.js","line":23,"character":8,"text":"isStrict","kind":1},{"file":"plugins/members.js","line":25,"character":60,"text":"user","kind":1},{"file":"plugins/members.js","line":26,"character":10,"text":"user","kind":1}]

TypeScript coverage report