1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
| 'use strict'
|
| const fetch = require('npm-registry-fetch')
| const validate = require('aproba')
|
| const eu = encodeURIComponent
| const cmd = module.exports = {}
| cmd.add = (name, endpoint, secret, opts = {}) => {
| validate('SSSO', [name, endpoint, secret, opts])
| let type = 'package'
| if (name.match(/^@[^/]+$/)) {
| type = 'scope'
| }
| if (name[0] === '~') {
| type = 'owner'
| name = name.slice(1)
| }
| return fetch.json('/-/npm/v1/hooks/hook', {
| ...opts,
| method: 'POST',
| body: { type, name, endpoint, secret },
| })
| }
|
| cmd.rm = (id, opts = {}) => {
| validate('SO', [id, opts])
| return fetch.json(`/-/npm/v1/hooks/hook/${eu(id)}`, {
| ...opts,
| method: 'DELETE',
| }).catch(err => {
| if (err.code === 'E404') {
| return null
| } else {
| throw err
| }
| })
| }
|
| cmd.update = (id, endpoint, secret, opts = {}) => {
| validate('SSSO', [id, endpoint, secret, opts])
| return fetch.json(`/-/npm/v1/hooks/hook/${eu(id)}`, {
| ...opts,
| method: 'PUT',
| body: { endpoint, secret },
| })
| }
|
| cmd.find = (id, opts = {}) => {
| validate('SO', [id, opts])
| return fetch.json(`/-/npm/v1/hooks/hook/${eu(id)}`, opts)
| }
|
| cmd.ls = (opts = {}) => {
| return cmd.ls.stream(opts).collect()
| }
|
| cmd.ls.stream = (opts = {}) => {
| const { package: pkg, limit, offset } = opts
| validate('S|Z', [pkg])
| validate('N|Z', [limit])
| validate('N|Z', [offset])
| return fetch.json.stream('/-/npm/v1/hooks', 'objects.*', {
| ...opts,
| query: {
| package: pkg,
| limit,
| offset,
| },
| })
| }
|
|
