22
22
"""
23
23
24
24
ACL_NEW_RULES = """key_prefix "" {
25
- policy = "read
25
+ policy = "read"
26
26
}
27
27
key "foo/" {
28
28
policy = "write"
46
46
dict (Name = "policylink_update_sample" )
47
47
]
48
48
49
- SERVICE_IDENTITIES_SAMPLE = [dict (ServiceName = "db" , Datacenters = ["dc1" ])]
50
-
51
- ROLELINKS_SAMPLE = [dict (Name = "role_sample" )]
49
+ SERVICE_IDENTITIES_SAMPLE = [dict (ServiceName = "db" , Datacenters = list ("dc1" ))]
52
50
53
51
54
52
class TestCase (base .TestCase ):
@@ -58,15 +56,16 @@ def uuidv4():
58
56
59
57
@staticmethod
60
58
def random ():
61
- return str (random .random ( ))
59
+ return str (random .randint ( 0 , 999999 ))
62
60
63
61
def _generate_policies (self ):
64
62
sample = self .consul .acl .create_policy (self .random ())
65
63
sample_update = self .consul .acl .create_policy (self .random ())
66
64
return [dict (ID = sample ["ID" ]), dict (ID = sample_update ["ID" ])]
67
65
68
66
def _generate_roles (self ):
69
- return [dict (ID = self .consul .acl .create_role (self .random ()))]
67
+ role = self .consul .acl .create_role (self .random ())
68
+ return [dict (ID = role ["ID" ])]
70
69
71
70
def test_bootstrap_request_exception (self ):
72
71
@httmock .all_requests
@@ -178,27 +177,27 @@ def test_update_forbidden(self):
178
177
# NOTE: Everything above here is deprecated post consul-1.4.0
179
178
180
179
def test_create_policy (self ):
181
- result = self .consul . acl . create_policy ( "unittest_create_policy" ,
182
- rules = ACL_NEW_RULES )
180
+ name = self .random ()
181
+ result = self . consul . acl . create_policy ( name = name , rules = ACL_NEW_RULES )
183
182
self .assertEqual (result ['Rules' ], ACL_NEW_RULES )
184
183
185
184
def test_create_and_read_policy (self ):
186
- value = self .consul . acl . create_policy ( "unittest_read_policy" ,
187
- rules = ACL_NEW_RULES )
185
+ name = self .random ()
186
+ value = self . consul . acl . create_policy ( name = name , rules = ACL_NEW_RULES )
188
187
result = self .consul .acl .read_policy (value ["ID" ])
189
188
self .assertEqual (result ['Rules' ], ACL_NEW_RULES )
190
189
191
190
def test_create_and_update_policy (self ):
192
- value = self .consul . acl . create_policy ( "unittest_update_policy" ,
193
- rules = ACL_NEW_RULES )
191
+ name = self .random ()
192
+ value = self . consul . acl . create_policy ( name = name , rules = ACL_NEW_RULES )
194
193
result = self .consul .acl .update_policy (value ["ID" ],
195
- value ["Name" ],
194
+ str ( value ["Name" ]) ,
196
195
rules = ACL_NEW_UPDATE_RULES )
197
196
self .assertGreater (result ["ModifyIndex" ], result ["CreateIndex" ])
198
197
199
198
def test_create_and_delete_policy (self ):
200
- value = self .consul . acl . create_policy ( "unittest_delete_policy" ,
201
- rules = ACL_NEW_RULES )
199
+ name = self .random ()
200
+ value = self . consul . acl . create_policy ( name = name , rules = ACL_NEW_RULES )
202
201
result = self .consul .acl .delete_policy (value ["ID" ])
203
202
self .assertTrue (result )
204
203
@@ -208,34 +207,38 @@ def test_list_policy_exception(self):
208
207
self .consul .acl .list_policies ()
209
208
210
209
def test_create_role (self ):
210
+ name = self .random ()
211
211
result = self .consul .acl .create_role (
212
- "unittest_create_role" ,
212
+ name = name ,
213
213
policies = self ._generate_policies (),
214
- service_identities = SERVICE_IDENTITIES_SAMPLE ,
215
- self .assertEqual (result ['ServiceIdentities' ][ 0 ][ 'ID' ], SERVICE_IDENTITIES_SAMPLE [ 0 ][ 'ID' ] )
214
+ service_identities = SERVICE_IDENTITIES_SAMPLE )
215
+ self .assertEqual (result ['Name' ], name )
216
216
217
217
def test_create_and_read_role (self ):
218
+ name = self .random ()
218
219
value = self .consul .acl .create_role (
219
- "unittest_read_role" ,
220
+ name = name ,
220
221
policies = self ._generate_policies (),
221
222
service_identities = SERVICE_IDENTITIES_SAMPLE )
222
223
result = self .consul .acl .read_role (value ["ID" ])
223
224
self .assertEqual (result ['ID' ], value ['ID' ])
224
225
225
226
def test_create_and_update_role (self ):
227
+ name = self .random ()
226
228
value = self .consul .acl .create_role (
227
- "unittest_update_role" ,
229
+ name = name ,
228
230
policies = self ._generate_policies (),
229
231
service_identities = SERVICE_IDENTITIES_SAMPLE )
230
232
result = self .consul .acl .update_role (
231
233
value ["ID" ],
232
- "unittest_update_role" ,
233
- policies = POLICYLINKS_UPDATE_SAMPLE )
234
+ str ( value [ "Name" ]) ,
235
+ policies = self . _generate_policies () )
234
236
self .assertGreater (result ["ModifyIndex" ], result ["CreateIndex" ])
235
237
236
238
def test_create_and_delete_role (self ):
239
+ name = self .random ()
237
240
value = self .consul .acl .create_role (
238
- "unittest_delete_role" ,
241
+ name = name ,
239
242
policies = self ._generate_policies (),
240
243
service_identities = SERVICE_IDENTITIES_SAMPLE )
241
244
result = self .consul .acl .delete_role (value ["ID" ])
@@ -280,7 +283,7 @@ def test_create_and_update_token(self):
280
283
policies = self ._generate_policies (),
281
284
service_identities = SERVICE_IDENTITIES_SAMPLE )
282
285
result = self .consul .acl .update_token (
283
- value ["AccessorID" ], policies = self ._generate_policies ())
286
+ str ( value ["AccessorID" ]) , policies = self ._generate_policies ())
284
287
self .assertGreater (result ["ModifyIndex" ], result ["CreateIndex" ])
285
288
286
289
def test_create_and_clone_token (self ):
@@ -290,11 +293,11 @@ def test_create_and_clone_token(self):
290
293
value = self .consul .acl .create_token (
291
294
accessor_id = accessor_id ,
292
295
secret_id = secret_id ,
293
- roles = ROLELINKS_SAMPLE ,
294
- policies = POLICYLINKS_SAMPLE ,
296
+ roles = self . _generate_roles () ,
297
+ policies = self . _generate_policies () ,
295
298
service_identities = SERVICE_IDENTITIES_SAMPLE )
296
299
result = self .consul .acl .clone_token (value ["AccessorID" ],
297
- description = "clone" )
300
+ description = clone_description )
298
301
self .assertEqual (result ["Description" ], clone_description )
299
302
300
303
def test_create_and_delete_token (self ):
@@ -303,8 +306,8 @@ def test_create_and_delete_token(self):
303
306
value = self .consul .acl .create_token (
304
307
accessor_id = accessor_id ,
305
308
secret_id = secret_id ,
306
- roles = ROLELINKS_SAMPLE ,
307
- policies = POLICYLINKS_SAMPLE ,
309
+ roles = self . _generate_roles () ,
310
+ policies = self . _generate_policies () ,
308
311
service_identities = SERVICE_IDENTITIES_SAMPLE )
309
312
result = self .consul .acl .delete_token (value ["AccessorID" ])
310
313
self .assertTrue (result )
0 commit comments