OLD | NEW |
| (Empty) |
1 # -*- coding: utf-8 -*- | |
2 # Copyright 2014 Google Inc. All Rights Reserved. | |
3 # | |
4 # Licensed under the Apache License, Version 2.0 (the "License"); | |
5 # you may not use this file except in compliance with the License. | |
6 # You may obtain a copy of the License at | |
7 # | |
8 # http://www.apache.org/licenses/LICENSE-2.0 | |
9 # | |
10 # Unless required by applicable law or agreed to in writing, software | |
11 # distributed under the License is distributed on an "AS IS" BASIS, | |
12 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | |
13 # See the License for the specific language governing permissions and | |
14 # limitations under the License. | |
15 """Integration tests for multiple bucket configuration commands.""" | |
16 | |
17 import json | |
18 import gslib.tests.testcase as testcase | |
19 from gslib.tests.testcase.integration_testcase import SkipForS3 | |
20 from gslib.tests.util import ObjectToURI as suri | |
21 | |
22 | |
23 class TestBucketConfig(testcase.GsUtilIntegrationTestCase): | |
24 """Integration tests for multiple bucket configuration commands.""" | |
25 | |
26 _set_cors_command = ['cors', 'set'] | |
27 _get_cors_command = ['cors', 'get'] | |
28 | |
29 empty_cors = '[]' | |
30 | |
31 cors_doc = ( | |
32 '[{"origin": ["http://origin1.example.com", ' | |
33 '"http://origin2.example.com"], ' | |
34 '"responseHeader": ["foo", "bar"], "method": ["GET", "PUT", "POST"], ' | |
35 '"maxAgeSeconds": 3600},' | |
36 '{"origin": ["http://origin3.example.com"], ' | |
37 '"responseHeader": ["foo2", "bar2"], "method": ["GET", "DELETE"]}]\n') | |
38 cors_json_obj = json.loads(cors_doc) | |
39 | |
40 _set_lifecycle_command = ['lifecycle', 'set'] | |
41 _get_lifecycle_command = ['lifecycle', 'get'] | |
42 | |
43 empty_lifecycle = '{}' | |
44 | |
45 lifecycle_doc = ( | |
46 '{"rule": [{"action": {"type": "Delete"}, "condition": {"age": 365}}]}\n') | |
47 lifecycle_json_obj = json.loads(lifecycle_doc) | |
48 | |
49 _set_acl_command = ['acl', 'set'] | |
50 _get_acl_command = ['acl', 'get'] | |
51 _set_defacl_command = ['defacl', 'set'] | |
52 _get_defacl_command = ['defacl', 'get'] | |
53 | |
54 @SkipForS3('A number of configs in this test are not supported by S3') | |
55 def test_set_multi_config(self): | |
56 """Tests that bucket config patching affects only the desired config.""" | |
57 bucket_uri = self.CreateBucket() | |
58 lifecycle_path = self.CreateTempFile(contents=self.lifecycle_doc) | |
59 cors_path = self.CreateTempFile(contents=self.cors_doc) | |
60 | |
61 self.RunGsUtil(self._set_cors_command + [cors_path, suri(bucket_uri)]) | |
62 cors_out = self.RunGsUtil(self._get_cors_command + [suri(bucket_uri)], | |
63 return_stdout=True) | |
64 self.assertEqual(json.loads(cors_out), self.cors_json_obj) | |
65 | |
66 self.RunGsUtil(self._set_lifecycle_command + [lifecycle_path, | |
67 suri(bucket_uri)]) | |
68 cors_out = self.RunGsUtil(self._get_cors_command + [suri(bucket_uri)], | |
69 return_stdout=True) | |
70 lifecycle_out = self.RunGsUtil(self._get_lifecycle_command + | |
71 [suri(bucket_uri)], return_stdout=True) | |
72 self.assertEqual(json.loads(cors_out), self.cors_json_obj) | |
73 self.assertEqual(json.loads(lifecycle_out), self.lifecycle_json_obj) | |
74 | |
75 self.RunGsUtil( | |
76 self._set_acl_command + ['authenticated-read', suri(bucket_uri)]) | |
77 | |
78 cors_out = self.RunGsUtil(self._get_cors_command + [suri(bucket_uri)], | |
79 return_stdout=True) | |
80 lifecycle_out = self.RunGsUtil(self._get_lifecycle_command + | |
81 [suri(bucket_uri)], return_stdout=True) | |
82 acl_out = self.RunGsUtil(self._get_acl_command + [suri(bucket_uri)], | |
83 return_stdout=True) | |
84 self.assertEqual(json.loads(cors_out), self.cors_json_obj) | |
85 self.assertEqual(json.loads(lifecycle_out), self.lifecycle_json_obj) | |
86 self.assertIn('allAuthenticatedUsers', acl_out) | |
87 | |
88 self.RunGsUtil( | |
89 self._set_defacl_command + ['public-read', suri(bucket_uri)]) | |
90 | |
91 cors_out = self.RunGsUtil(self._get_cors_command + [suri(bucket_uri)], | |
92 return_stdout=True) | |
93 lifecycle_out = self.RunGsUtil(self._get_lifecycle_command + | |
94 [suri(bucket_uri)], return_stdout=True) | |
95 acl_out = self.RunGsUtil(self._get_acl_command + [suri(bucket_uri)], | |
96 return_stdout=True) | |
97 def_acl_out = self.RunGsUtil(self._get_defacl_command + [suri(bucket_uri)], | |
98 return_stdout=True) | |
99 self.assertEqual(json.loads(cors_out), self.cors_json_obj) | |
100 self.assertEqual(json.loads(lifecycle_out), self.lifecycle_json_obj) | |
101 self.assertIn('allAuthenticatedUsers', acl_out) | |
102 self.assertIn('allUsers', def_acl_out) | |
OLD | NEW |