@@ -16,43 +16,46 @@ cmd.set = (org, user, role, opts = {}) => {
16
16
opts = role
17
17
role = undefined
18
18
}
19
- return new Promise ( ( resolve , reject ) => {
19
+ return Promise . resolve ( ) . then ( ( ) => {
20
20
validate ( 'SSSO|SSZO' , [ org , user , role , opts ] )
21
21
user = user . replace ( / ^ @ ? / , '' )
22
22
org = org . replace ( / ^ @ ? / , '' )
23
- fetch . json ( `/-/org/${ eu ( org ) } /user` , {
23
+ return fetch . json ( `/-/org/${ eu ( org ) } /user` , {
24
24
...opts ,
25
25
method : 'PUT' ,
26
26
body : { user, role }
27
- } ) . then ( resolve , reject )
28
- } ) . then ( ret => Object . assign ( new MembershipDetail ( ) , ret ) )
27
+ } ) . then ( ret => Object . assign ( new MembershipDetail ( ) , ret ) )
28
+ } )
29
29
}
30
30
31
31
cmd . rm = ( org , user , opts = { } ) => {
32
- return new Promise ( ( resolve , reject ) => {
32
+ return Promise . resolve ( ) . then ( ( ) => {
33
33
validate ( 'SSO' , [ org , user , opts ] )
34
34
user = user . replace ( / ^ @ ? / , '' )
35
35
org = org . replace ( / ^ @ ? / , '' )
36
- fetch ( `/-/org/${ eu ( org ) } /user` , {
36
+ return fetch ( `/-/org/${ eu ( org ) } /user` , {
37
37
...opts ,
38
38
method : 'DELETE' ,
39
39
body : { user } ,
40
40
ignoreBody : true
41
- } ) . then ( resolve , reject )
42
- } ) . then ( ( ) => null )
41
+ } ) . then ( ( ) => null )
42
+ } )
43
43
}
44
44
45
45
class Roster { }
46
46
cmd . ls = ( org , opts = { } ) => {
47
- return new Promise ( ( resolve , reject ) => {
48
- cmd . ls . stream ( org , opts ) . then ( entries => {
49
- const obj = { }
50
- for ( const [ key , val ] of entries ) {
51
- obj [ key ] = val
52
- }
53
- return obj
54
- } ) . then ( resolve , reject )
55
- } ) . then ( ret => Object . assign ( new Roster ( ) , ret ) )
47
+ return Promise . resolve ( ) . then ( ( ) => {
48
+ return cmd . ls . stream ( org , opts )
49
+ . collect ( )
50
+ . then ( data => data . reduce ( ( acc , [ key , val ] ) => {
51
+ if ( ! acc ) {
52
+ acc = { }
53
+ }
54
+ acc [ key ] = val
55
+ return acc
56
+ } , null ) )
57
+ . then ( ret => Object . assign ( new Roster ( ) , ret ) )
58
+ } )
56
59
}
57
60
58
61
cmd . ls . stream = ( org , opts = { } ) => {
0 commit comments