123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165 |
- 'use strict'
- const BB = require('bluebird')
- const hookApi = require('libnpm/hook')
- const npmConfig = require('./config/figgy-config.js')
- const output = require('./utils/output.js')
- const otplease = require('./utils/otplease.js')
- const pudding = require('figgy-pudding')
- const relativeDate = require('tiny-relative-date')
- const Table = require('cli-table3')
- const validate = require('aproba')
- const npm = require('./npm')
- hook.usage = [
- 'npm hook add <pkg> <url> <secret> [--type=<type>]',
- 'npm hook ls [pkg]',
- 'npm hook rm <id>',
- 'npm hook update <id> <url> <secret>'
- ].join('\n')
- hook.completion = (opts, cb) => {
- validate('OF', [opts, cb])
- return cb(null, []) // fill in this array with completion values
- }
- const HookConfig = pudding({
- json: {},
- loglevel: {},
- parseable: {},
- silent: {},
- unicode: {}
- })
- function UsageError () {
- throw Object.assign(new Error(hook.usage), {code: 'EUSAGE'})
- }
- module.exports = (args, cb) => BB.try(() => hook(args)).then(
- val => cb(null, val),
- err => err.code === 'EUSAGE' ? cb(err.message) : cb(err)
- )
- function hook (args) {
- if (args.length === 4) { // secret is passed in the args
- // we have the user secret in the CLI args, we need to redact it from the referer.
- redactUserSecret()
- }
- return otplease(npmConfig(), opts => {
- opts = HookConfig(opts)
- switch (args[0]) {
- case 'add':
- return add(args[1], args[2], args[3], opts)
- case 'ls':
- return ls(args[1], opts)
- case 'rm':
- return rm(args[1], opts)
- case 'update':
- case 'up':
- return update(args[1], args[2], args[3], opts)
- default:
- UsageError()
- }
- })
- }
- function add (pkg, uri, secret, opts) {
- return hookApi.add(pkg, uri, secret, opts).then(hook => {
- if (opts.json) {
- output(JSON.stringify(hook, null, 2))
- } else if (opts.parseable) {
- output(Object.keys(hook).join('\t'))
- output(Object.keys(hook).map(k => hook[k]).join('\t'))
- } else if (!opts.silent && opts.loglevel !== 'silent') {
- output(`+ ${hookName(hook)} ${
- opts.unicode ? ' ➜ ' : ' -> '
- } ${hook.endpoint}`)
- }
- })
- }
- function ls (pkg, opts) {
- return hookApi.ls(opts.concat({package: pkg})).then(hooks => {
- if (opts.json) {
- output(JSON.stringify(hooks, null, 2))
- } else if (opts.parseable) {
- output(Object.keys(hooks[0]).join('\t'))
- hooks.forEach(hook => {
- output(Object.keys(hook).map(k => hook[k]).join('\t'))
- })
- } else if (!hooks.length) {
- output("You don't have any hooks configured yet.")
- } else if (!opts.silent && opts.loglevel !== 'silent') {
- if (hooks.length === 1) {
- output('You have one hook configured.')
- } else {
- output(`You have ${hooks.length} hooks configured.`)
- }
- const table = new Table({head: ['id', 'target', 'endpoint']})
- hooks.forEach((hook) => {
- table.push([
- {rowSpan: 2, content: hook.id},
- hookName(hook),
- hook.endpoint
- ])
- if (hook.last_delivery) {
- table.push([
- {
- colSpan: 1,
- content: `triggered ${relativeDate(hook.last_delivery)}`
- },
- hook.response_code
- ])
- } else {
- table.push([{colSpan: 2, content: 'never triggered'}])
- }
- })
- output(table.toString())
- }
- })
- }
- function rm (id, opts) {
- return hookApi.rm(id, opts).then(hook => {
- if (opts.json) {
- output(JSON.stringify(hook, null, 2))
- } else if (opts.parseable) {
- output(Object.keys(hook).join('\t'))
- output(Object.keys(hook).map(k => hook[k]).join('\t'))
- } else if (!opts.silent && opts.loglevel !== 'silent') {
- output(`- ${hookName(hook)} ${
- opts.unicode ? ' ✘ ' : ' X '
- } ${hook.endpoint}`)
- }
- })
- }
- function update (id, uri, secret, opts) {
- return hookApi.update(id, uri, secret, opts).then(hook => {
- if (opts.json) {
- output(JSON.stringify(hook, null, 2))
- } else if (opts.parseable) {
- output(Object.keys(hook).join('\t'))
- output(Object.keys(hook).map(k => hook[k]).join('\t'))
- } else if (!opts.silent && opts.loglevel !== 'silent') {
- output(`+ ${hookName(hook)} ${
- opts.unicode ? ' ➜ ' : ' -> '
- } ${hook.endpoint}`)
- }
- })
- }
- function hookName (hook) {
- let target = hook.name
- if (hook.type === 'scope') { target = '@' + target }
- if (hook.type === 'owner') { target = '~' + target }
- return target
- }
- function redactUserSecret () {
- const referer = npm.referer
- if (!referer) return
- const splittedReferer = referer.split(' ')
- splittedReferer[4] = '[REDACTED]'
- npm.referer = splittedReferer.join(' ')
- }
|