deploy-keys.js

Filename	Percent	Threshold	Total	Covered	Uncovered
plugins/deploy-keys.js	100.00%	80%	194	194	0

//@ts-check
import { cloneDeep, filter, forEach, get, isEmpty,
  upperFirst } from 'lodash-es';
import async from 'async';
import path from 'node:path';
import * as utils from '../src/utils.js';
import { fileURLToPath } from 'node:url';

const service = path.parse(fileURLToPath(import.meta.url)).name;

/**
 * @param  {GitConfig.Env} env
 * @param  {GitConfig.$DeployKeySchema[]} projectKeys
 * @param  {Plugins.DeployKeyConfig[]} confKeys
 */
function diffDeployKeys(env, projectKeys, confKeys) {
  /** @type {{
    new: Plugins.DeployKeyConfig[],
    old: GitConfig.$DeployKeySchema[],
    update: Array<{ ck: Plugins.DeployKeyConfig, pk: GitConfig.$DeployKeySchema }> }} */
  const ret /*: DeployKeysMod */ = { new: [], old: [], update: [] };
  confKeys = cloneDeep(confKeys);

  forEach(projectKeys, (pk) => {
    /** @type {Plugins.DeployKeyConfig|undefined} */
    let ck;
    confKeys = filter(confKeys, (k) => {
      if (k.key === pk.key) {
        ck = k;
        return false;
      }
      return true;
    });
    if (!ck) {
      ret.old.push(pk);
    }
    else if ((ck.title !== pk.title) || (Boolean(ck.can_push) !== pk.can_push)) {
      ret.update.push({ pk, ck });
    }
  });

  ret.new = confKeys;
  return ret;
}

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

  env.spin.start(`Fetching ${service} configuration: ${project.name}`);
  const projectKeys = /** @type {GitConfig.$DeployKeySchema[]} */
    (await env.gitlab.DeployKeys.all({ projectId: project.id }));
  const mods = diffDeployKeys(env, projectKeys,
    get(settings, [ 'config', 'keys' ], []));

  env.spin.debug(`${upperFirst(service)} modifications: %o`, mods);
  if (env.opts.dryRun) {
    if (!isEmpty(mods.new)) {
      env.spin.warn(`${upperFirst(service)} addition required: ${project.name}`);
    }
    if (!isEmpty(mods.update)) {
      env.spin.warn(`${upperFirst(service)} update required: ${project.name}`);
    }
    if (!isEmpty(mods.old)) {
      env.spin.warn(`${upperFirst(service)} removal required: ${project.name}`);
    }
  }
  else {
    var updated = false;
    await async.eachSeries(mods.old, async function(pk) {
      await env.gitlab.DeployKeys.remove(project.id, pk.id);
      updated = true;
    });
    await async.eachSeries(mods.new, async function(ck) {
      // @ts-ignore correct parameters
      await env.gitlab.DeployKeys.create(project.id, ck.title, ck.key, { can_push: ck.can_push ?? false });
      updated = true;
    });
    await async.eachSeries(mods.update, async function({ ck, pk }) {
      await env.gitlab.DeployKeys.edit(project.id, pk.id, ck);
      updated = true;
    });
    if (updated) {
      env.spin.succeed(`${upperFirst(service)} updated: ${project.name}`);
    }
  }
}

export default update;

[]

TypeScript Coverage Report generated by type-coverage and typescript-coverage-report at Sun, 23 Jun 2024 00:34:34 GMT

TypeScript coverage report