Na}{

File Content: `owner.js`

const npa = require('npm-package-arg')
const npmFetch = require('npm-registry-fetch')
const pacote = require('pacote')
const log = require('../utils/log-shim')
const otplease = require('../utils/otplease.js')
const pkgJson = require('@npmcli/package-json')
const BaseCommand = require('../base-command.js')

const readJson = async (path) => {
  try {
    const { content } = await pkgJson.normalize(path)
    return content
  } catch {
    return {}
  }
}

class Owner extends BaseCommand {
  static description = 'Manage package owners'
  static name = 'owner'
  static params = [
    'registry',
    'otp',
    'workspace',
    'workspaces',
  ]

  static usage = [
    'add <user> <package-spec>',
    'rm <user> <package-spec>',
    'ls <package-spec>',
  ]

  static workspaces = true
  static ignoreImplicitWorkspace = false

  static async completion (opts, npm) {
    const argv = opts.conf.argv.remain
    if (argv.length > 3) {
      return []
    }

    if (argv[1] !== 'owner') {
      argv.unshift('owner')
    }

    if (argv.length === 2) {
      return ['add', 'rm', 'ls']
    }

    // reaches registry in order to autocomplete rm
    if (argv[2] === 'rm') {
      if (npm.global) {
        return []
      }
      const { name } = await readJson(npm.prefix)
      if (!name) {
        return []
      }

      const spec = npa(name)
      const data = await pacote.packument(spec, {
        ...npm.flatOptions,
        fullMetadata: true,
      })
      if (data && data.maintainers && data.maintainers.length) {
        return data.maintainers.map(m => m.name)
      }
    }
    return []
  }

  async exec ([action, ...args]) {
    if (action === 'ls' || action === 'list') {
      await this.ls(args[0])
    } else if (action === 'add') {
      await this.changeOwners(args[0], args[1], 'add')
    } else if (action === 'rm' || action === 'remove') {
      await this.changeOwners(args[0], args[1], 'rm')
    } else {
      throw this.usageError()
    }
  }

  async execWorkspaces ([action, ...args]) {
    await this.setWorkspaces()
    // ls pkg or owner add/rm package
    if ((action === 'ls' && args.length > 0) || args.length > 1) {
      const implicitWorkspaces = this.npm.config.get('workspace', 'default')
      if (implicitWorkspaces.length === 0) {
        log.warn(`Ignoring specified workspace(s)`)
      }
      return this.exec([action, ...args])
    }

    for (const [name] of this.workspaces) {
      if (action === 'ls' || action === 'list') {
        await this.ls(name)
      } else if (action === 'add') {
        await this.changeOwners(args[0], name, 'add')
      } else if (action === 'rm' || action === 'remove') {
        await this.changeOwners(args[0], name, 'rm')
      } else {
        throw this.usageError()
      }
    }
  }

  async ls (pkg) {
    pkg = await this.getPkg(this.npm.prefix, pkg)
    const spec = npa(pkg)

    try {
      const packumentOpts = { ...this.npm.flatOptions, fullMetadata: true, preferOnline: true }
      const { maintainers } = await pacote.packument(spec, packumentOpts)
      if (!maintainers || !maintainers.length) {
        this.npm.output('no admin found')
      } else {
        this.npm.output(maintainers.map(m => `${m.name} <${m.email}>`).join('\n'))
      }
    } catch (err) {
      log.error('owner ls', "Couldn't get owner data", npmFetch.cleanUrl(pkg))
      throw err
    }
  }

  async getPkg (prefix, pkg) {
    if (!pkg) {
      if (this.npm.global) {
        throw this.usageError()
      }
      const { name } = await readJson(prefix)
      if (!name) {
        throw this.usageError()
      }

      return name
    }
    return pkg
  }

  async changeOwners (user, pkg, addOrRm) {
    if (!user) {
      throw this.usageError()
    }

    pkg = await this.getPkg(this.npm.prefix, pkg)
    log.verbose(`owner ${addOrRm}`, '%s to %s', user, pkg)

    const spec = npa(pkg)
    const uri = `/-/user/org.couchdb.user:${encodeURIComponent(user)}`
    let u

    try {
      u = await npmFetch.json(uri, this.npm.flatOptions)
    } catch (err) {
      log.error('owner mutate', `Error getting user data for ${user}`)
      throw err
    }

    // normalize user data
    u = { name: u.name, email: u.email }

    const data = await pacote.packument(spec, {
      ...this.npm.flatOptions,
      fullMetadata: true,
      preferOnline: true,
    })

    const owners = data.maintainers || []
    let maintainers
    if (addOrRm === 'add') {
      const existing = owners.find(o => o.name === u.name)
      if (existing) {
        log.info(
          'owner add',
          `Already a package owner: ${existing.name} <${existing.email}>`
        )
        return
      }
      maintainers = [
        ...owners,
        u,
      ]
    } else {
      maintainers = owners.filter(o => o.name !== u.name)

      if (maintainers.length === owners.length) {
        log.info('owner rm', 'Not a package owner: ' + u.name)
        return false
      }

      if (!maintainers.length) {
        throw Object.assign(
          new Error(
            'Cannot remove all owners of a package. Add someone else first.'
          ),
          { code: 'EOWNERRM' }
        )
      }
    }

    const dataPath = `/${spec.escapedName}/-rev/${encodeURIComponent(data._rev)}`
    try {
      const res = await otplease(this.npm, this.npm.flatOptions, opts => {
        return npmFetch.json(dataPath, {
          ...opts,
          method: 'PUT',
          body: {
            _id: data._id,
            _rev: data._rev,
            maintainers,
          },
          spec,
        })
      })
      if (addOrRm === 'add') {
        this.npm.output(`+ ${user} (${spec.name})`)
      } else {
        this.npm.output(`- ${user} (${spec.name})`)
      }
      return res
    } catch (err) {
      throw Object.assign(
        new Error('Failed to update package: ' + JSON.stringify(err.message)),
        { code: 'EOWNERMUTATE' }
      )
    }
  }
}

module.exports = Owner

Name	Size	Permission
access.js	6176 bytes	0644
adduser.js	1350 bytes	0644
audit.js	15470 bytes	0644
bugs.js	847 bytes	0644
cache.js	7163 bytes	0644
ci.js	3859 bytes	0644
completion.js	9081 bytes	0644
config.js	10357 bytes	0644
dedupe.js	1448 bytes	0644
deprecate.js	2074 bytes	0644
diff.js	8349 bytes	0644
dist-tag.js	5654 bytes	0644
docs.js	447 bytes	0644
doctor.js	12083 bytes	0644
edit.js	2052 bytes	0644
exec.js	3191 bytes	0644
explain.js	3654 bytes	0644
explore.js	2362 bytes	0644
find-dupes.js	637 bytes	0644
fund.js	6700 bytes	0644
get.js	580 bytes	0644
help-search.js	5630 bytes	0644
help.js	3666 bytes	0644
hook.js	3860 bytes	0644
init.js	7121 bytes	0644
install-ci-test.js	373 bytes	0644
install-test.js	370 bytes	0644
install.js	5395 bytes	0644
link.js	5468 bytes	0644
ll.js	234 bytes	0644
login.js	1347 bytes	0644
logout.js	1465 bytes	0644
ls.js	17161 bytes	0644
org.js	4250 bytes	0644
outdated.js	9009 bytes	0644
owner.js	5955 bytes	0644
pack.js	2577 bytes	0644
ping.js	917 bytes	0644
pkg.js	3643 bytes	0644
prefix.js	303 bytes	0644
profile.js	11463 bytes	0644
prune.js	798 bytes	0644
publish.js	7071 bytes	0644
query.js	3565 bytes	0644
rebuild.js	2207 bytes	0644
repo.js	1272 bytes	0644
restart.js	310 bytes	0644
root.js	258 bytes	0644
run-script.js	6562 bytes	0644
sbom.js	4775 bytes	0644
search.js	2812 bytes	0644
set.js	674 bytes	0644
shrinkwrap.js	2709 bytes	0644
star.js	1911 bytes	0644
stars.js	1052 bytes	0644
start.js	300 bytes	0644
stop.js	295 bytes	0644
team.js	4552 bytes	0644
test.js	295 bytes	0644
token.js	6829 bytes	0644
uninstall.js	1567 bytes	0644
unpublish.js	5075 bytes	0644
unstar.js	182 bytes	0644
update.js	1780 bytes	0644
version.js	3669 bytes	0644
view.js	14890 bytes	0644
whoami.js	474 bytes	0644

File Content: owner.js

File Content: `owner.js`