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
|
// +build acceptance db rackspace
package v1
import (
"github.com/rackspace/gophercloud/acceptance/tools"
db "github.com/rackspace/gophercloud/openstack/db/v1/databases"
os "github.com/rackspace/gophercloud/openstack/db/v1/users"
"github.com/rackspace/gophercloud/pagination"
"github.com/rackspace/gophercloud/rackspace/db/v1/users"
)
func (c *context) createUsers() {
c.users = []string{
tools.RandomString("user_", 5),
tools.RandomString("user_", 5),
tools.RandomString("user_", 5),
}
db1 := db.CreateOpts{Name: c.DBIDs[0]}
db2 := db.CreateOpts{Name: c.DBIDs[1]}
db3 := db.CreateOpts{Name: c.DBIDs[2]}
opts := os.BatchCreateOpts{
os.CreateOpts{
Name: c.users[0],
Password: tools.RandomString("db_", 5),
Databases: db.BatchCreateOpts{db1, db2, db3},
},
os.CreateOpts{
Name: c.users[1],
Password: tools.RandomString("db_", 5),
Databases: db.BatchCreateOpts{db1, db2},
},
os.CreateOpts{
Name: c.users[2],
Password: tools.RandomString("db_", 5),
Databases: db.BatchCreateOpts{db3},
},
}
err := users.Create(c.client, c.instanceID, opts).ExtractErr()
c.Logf("Created three users on instance %s: %s, %s, %s", c.instanceID, c.users[0], c.users[1], c.users[2])
c.AssertNoErr(err)
}
func (c *context) listUsers() {
c.Logf("Listing users on instance %s", c.instanceID)
err := os.List(c.client, c.instanceID).EachPage(func(page pagination.Page) (bool, error) {
uList, err := os.ExtractUsers(page)
c.AssertNoErr(err)
for _, u := range uList {
c.Logf("User: %#v", u)
}
return true, nil
})
c.AssertNoErr(err)
}
func (c *context) deleteUsers() {
for _, id := range c.users {
err := users.Delete(c.client, c.instanceID, id).ExtractErr()
c.AssertNoErr(err)
c.Logf("Deleted user %s", id)
}
}
func (c *context) changeUserPwd() {
opts := os.BatchCreateOpts{}
for _, name := range c.users[:1] {
opts = append(opts, os.CreateOpts{Name: name, Password: tools.RandomString("", 5)})
}
err := users.ChangePassword(c.client, c.instanceID, opts).ExtractErr()
c.Logf("Updated 2 users' passwords")
c.AssertNoErr(err)
}
func (c *context) getUser() {
user, err := users.Get(c.client, c.instanceID, c.users[0]).Extract()
c.Logf("Getting user %s", user)
c.AssertNoErr(err)
}
func (c *context) updateUser() {
opts := users.UpdateOpts{Name: tools.RandomString("new_name_", 5)}
err := users.Update(c.client, c.instanceID, c.users[0], opts).ExtractErr()
c.Logf("Updated user %s", c.users[0])
c.AssertNoErr(err)
c.users[0] = opts.Name
}
func (c *context) listUserAccess() {
err := users.ListAccess(c.client, c.instanceID, c.users[0]).EachPage(func(page pagination.Page) (bool, error) {
dbList, err := users.ExtractDBs(page)
c.AssertNoErr(err)
for _, db := range dbList {
c.Logf("User %s has access to DB: %#v", db)
}
return true, nil
})
c.AssertNoErr(err)
}
func (c *context) grantUserAccess() {
opts := db.BatchCreateOpts{db.CreateOpts{Name: c.DBIDs[0]}}
err := users.GrantAccess(c.client, c.instanceID, c.users[0], opts).ExtractErr()
c.Logf("Granted access for user %s to DB %s", c.users[0], c.DBIDs[0])
c.AssertNoErr(err)
}
func (c *context) revokeUserAccess() {
dbName, userName := c.DBIDs[0], c.users[0]
err := users.RevokeAccess(c.client, c.instanceID, userName, dbName).ExtractErr()
c.Logf("Revoked access for user %s to DB %s", userName, dbName)
c.AssertNoErr(err)
}
|
