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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
module.exports = adduser
var url = require('url')
var assert = require('assert')
function adduser (uri, params, cb) {
assert(typeof uri === 'string', 'must pass registry URI to adduser')
assert(
params && typeof params === 'object',
'must pass params to adduser'
)
assert(typeof cb === 'function', 'must pass callback to adduser')
assert(params.auth && typeof params.auth, 'must pass auth to adduser')
var auth = params.auth
assert(typeof auth.username === 'string', 'must include username in auth')
assert(typeof auth.password === 'string', 'must include password in auth')
assert(typeof auth.email === 'string', 'must include email in auth')
// normalize registry URL
if (uri.slice(-1) !== '/') uri += '/'
var username = auth.username.trim()
var password = auth.password.trim()
var email = auth.email.trim()
// validation
if (!username) return cb(new Error('No username supplied.'))
if (!password) return cb(new Error('No password supplied.'))
if (!email) return cb(new Error('No email address supplied.'))
if (!email.match(/^[^@]+@[^.]+\.[^.]+/)) {
return cb(new Error('Please use a real email address.'))
}
var userobj = {
_id: 'org.couchdb.user:' + username,
name: username,
password: password,
email: email,
type: 'user',
roles: [],
date: new Date().toISOString()
}
var token = this.config.couchToken
if (this.couchLogin) this.couchLogin.token = null
cb = done.call(this, token, cb)
var logObj = Object.keys(userobj).map(function (k) {
if (k === 'password') return [k, 'XXXXX']
return [k, userobj[k]]
}).reduce(function (s, kv) {
s[kv[0]] = kv[1]
return s
}, {})
this.log.verbose('adduser', 'before first PUT', logObj)
var client = this
uri = url.resolve(uri, '-/user/org.couchdb.user:' + encodeURIComponent(username))
var options = {
method: 'PUT',
body: userobj,
auth: auth
}
this.request(
uri,
Object.assign({}, options),
function (error, data, json, response) {
if (!error || !response || response.statusCode !== 409) {
return cb(error, data, json, response)
}
client.log.verbose('adduser', 'update existing user')
return client.request(
uri + '?write=true',
{ auth: auth },
function (er, data, json, response) {
if (er || data.error) {
return cb(er, data, json, response)
}
Object.keys(data).forEach(function (k) {
if (!userobj[k] || k === 'roles') {
userobj[k] = data[k]
}
})
client.log.verbose('adduser', 'userobj', logObj)
client.request(uri + '/-rev/' + userobj._rev, options, cb)
}
)
}
)
function done (token, cb) {
return function (error, data, json, response) {
if (!error && (!response || response.statusCode === 201)) {
return cb(error, data, json, response)
}
// there was some kind of error, reinstate previous auth/token/etc.
if (client.couchLogin) {
client.couchLogin.token = token
if (client.couchLogin.tokenSet) {
client.couchLogin.tokenSet(token)
}
}
client.log.verbose('adduser', 'back', [error, data, json])
if (!error) {
error = new Error(
((response && response.statusCode) || '') + ' ' +
'Could not create user\n' + JSON.stringify(data)
)
}
if (response && (response.statusCode === 401 || response.statusCode === 403)) {
client.log.warn('adduser', 'Incorrect username or password\n' +
'You can reset your account by visiting:\n' +
'\n' +
' https://npmjs.org/forgot\n')
}
return cb(error)
}
}
}
|
