Chromium Code Reviews| OLD | NEW |
|---|---|
| (Empty) | |
| 1 import collections | |
| 2 import copy | |
| 3 import functools | |
| 4 | |
| 5 from .recipe_util import ModuleInjectionSite | |
| 6 | |
| 7 def combineify(name, dest, a, b): | |
| 8 """ | |
| 9 Combines dictionary members in two objects into a third one using addition. | |
| 10 | |
| 11 Args: | |
| 12 name - the name of the member | |
| 13 dest - the destination object | |
| 14 a - the first source object | |
| 15 b - the second source object | |
| 16 """ | |
| 17 dest_dict = getattr(dest, name) | |
| 18 dest_dict.update(getattr(a, name)) | |
| 19 for k, v in getattr(b, name).iteritems(): | |
| 20 if k in dest_dict: | |
| 21 dest_dict[k] += v | |
| 22 else: | |
| 23 dest_dict[k] = v | |
| 24 | |
| 25 | |
| 26 class BaseTestData(object): | |
| 27 def __init__(self, enabled=True): | |
| 28 super(BaseTestData, self).__init__() | |
| 29 self._enabled = enabled | |
| 30 | |
| 31 @property | |
| 32 def enabled(self): | |
| 33 return self._enabled | |
| 34 | |
| 35 | |
| 36 class PlaceholderTestData(BaseTestData): | |
| 37 def __init__(self, data=None): | |
| 38 super(PlaceholderTestData, self).__init__() | |
| 39 self.data = data | |
| 40 | |
| 41 def __repr__(self): | |
| 42 return "PlaceholderTestData(%s)" % self.data | |
| 43 | |
| 44 def __copy__(self): | |
| 45 ret = PlaceholderTestData() | |
| 46 ret.data = copy.deepcopy(self.data) | |
| 47 return ret | |
| 48 | |
| 49 | |
| 50 class StepTestData(BaseTestData): | |
| 51 """ | |
| 52 Mutable container for per-step test data. | |
| 53 | |
| 54 This data is consumed while running the recipe (during | |
| 55 annotated_run.run_steps). | |
| 56 """ | |
| 57 def __init__(self): | |
| 58 super(StepTestData, self).__init__() | |
| 59 # { (module, placeholder) -> [data] } | |
| 60 self.placeholder_data = collections.defaultdict(list) | |
| 61 self._retcode = None | |
| 62 | |
| 63 def __add__(self, other): | |
| 64 assert isinstance(other, StepTestData) | |
| 65 ret = StepTestData() | |
| 66 | |
| 67 # We don't use combineify to merge placeholder_data here because | |
| 68 # simply concatenating placeholder_data's list value is not meaningful to | |
| 69 # consumers of this object. | |
| 70 # Producers of this object should use the append() method. | |
| 71 ret.placeholder_data.update(copy.deepcopy(self.placeholder_data)) | |
| 72 for k, v in other.placeholder_data.iteritems(): | |
| 73 assert k not in ret.placeholder_data | |
| 74 ret.placeholder_data[k] = copy.deepcopy(v) | |
| 75 | |
| 76 # pylint: disable=W0212 | |
| 77 ret._retcode = self._retcode | |
| 78 if other._retcode is not None: | |
| 79 assert ret._retcode is None | |
| 80 ret._retcode = other._retcode | |
| 81 return ret | |
| 82 | |
| 83 def append(self, other): | |
| 84 self._retcode = self._retcode or other._retcode # pylint: disable=W0212 | |
| 85 combineify('placeholder_data', self, self, other) | |
| 86 return self | |
| 87 | |
| 88 def pop_placeholder(self, name_pieces): | |
| 89 l = self.placeholder_data[name_pieces] | |
| 90 if l: | |
| 91 return l.pop(0) | |
| 92 else: | |
| 93 return PlaceholderTestData() | |
| 94 | |
| 95 @property | |
| 96 def retcode(self): # pylint: disable=E0202 | |
| 97 return self._retcode or 0 | |
| 98 | |
| 99 @retcode.setter | |
| 100 def retcode(self, value): # pylint: disable=E0202 | |
| 101 self._retcode = value | |
| 102 | |
| 103 def __repr__(self): | |
| 104 return "StepTestData(%s)" % str({ | |
| 105 'placeholder_data': dict(self.placeholder_data.iteritems()), | |
| 106 'retcode': self._retcode, | |
| 107 }) | |
| 108 | |
| 109 | |
| 110 class ModuleTestData(BaseTestData, dict): | |
| 111 """ | |
| 112 Mutable container for test data for a specific module. | |
| 113 | |
| 114 This test data is consumed at module load time (i.e. when CreateRecipeApi | |
| 115 runs). | |
| 116 """ | |
| 117 def __add__(self, other): | |
| 118 assert isinstance(other, ModuleTestData) | |
| 119 ret = ModuleTestData() | |
| 120 ret.update(self) | |
| 121 ret.update(other) | |
| 122 return ret | |
| 123 | |
| 124 def __repr__(self): | |
| 125 return "ModuleTestData(%s)" % super(ModuleTestData, self).__repr__() | |
| 126 | |
| 127 | |
| 128 class TestData(BaseTestData): | |
| 129 def __init__(self, name=None): | |
| 130 super(TestData, self).__init__() | |
| 131 self.name = name | |
| 132 self.properties = {} # key -> val | |
| 133 self.mod_data = collections.defaultdict(ModuleTestData) | |
| 134 self.step_data = collections.defaultdict(StepTestData) | |
| 135 | |
| 136 def __add__(self, other): | |
| 137 assert isinstance(other, TestData) | |
| 138 ret = TestData(self.name or other.name) | |
| 139 | |
| 140 ret.properties.update(self.properties) | |
| 141 ret.properties.update(other.properties) | |
| 142 | |
| 143 combineify('mod_data', ret, self, other) | |
| 144 combineify('step_data', ret, self, other) | |
| 145 | |
| 146 return ret | |
| 147 | |
| 148 def empty(self): | |
| 149 return not self.step_data | |
| 150 | |
| 151 def __repr__(self): | |
| 152 return "TestData(%s)" % str({ | |
| 153 'name': self.name, | |
| 154 'properties': self.properties, | |
| 155 'mod_data': dict(self.mod_data.iteritems()), | |
| 156 'step_data': dict(self.step_data.iteritems()), | |
| 157 }) | |
| 158 | |
| 159 | |
| 160 class DisabledTestData(BaseTestData): | |
| 161 def __init__(self): | |
| 162 super(DisabledTestData, self).__init__(False) | |
| 163 | |
| 164 def __getattr__(self, name): | |
| 165 return self | |
| 166 | |
| 167 def pop_placeholder(self, _name_pieces): | |
| 168 return self | |
| 169 | |
| 170 | |
| 171 def static_wraps(func): | |
| 172 wrapped_fn = func | |
| 173 if isinstance(func, staticmethod): | |
| 174 wrapped_fn = func.__func__ | |
| 175 return functools.wraps(wrapped_fn) | |
| 176 | |
| 177 | |
| 178 def static_call(obj, func, *args, **kwargs): | |
| 179 if isinstance(func, staticmethod): | |
| 180 return func.__get__(obj)(*args, **kwargs) | |
| 181 else: | |
| 182 return func(obj, *args, **kwargs) | |
| 183 | |
| 184 | |
| 185 def mod_test_data(func): | |
| 186 @static_wraps(func) | |
| 187 def inner(self, *args, **kwargs): | |
| 188 assert isinstance(self, RecipeTestApi) | |
| 189 mod_name = self._module.NAME # pylint: disable=W0212 | |
| 190 ret = TestData(None) | |
| 191 data = static_call(self, func, *args, **kwargs) | |
| 192 ret.mod_data[mod_name][inner.__name__] = data | |
| 193 return ret | |
| 194 return inner | |
| 195 | |
| 196 | |
| 197 def placeholder_step_data(func): | |
| 198 @static_wraps(func) | |
| 199 def inner(self, *args, **kwargs): | |
| 200 assert isinstance(self, RecipeTestApi) | |
| 201 mod_name = self._module.NAME # pylint: disable=W0212 | |
| 202 ret = StepTestData() | |
| 203 placeholder_data, retcode = static_call(self, func, *args, **kwargs) | |
| 204 ret.placeholder_data[(mod_name, inner.__name__)].append( | |
| 205 PlaceholderTestData(placeholder_data)) | |
| 206 ret.retcode = retcode | |
| 207 return ret | |
| 208 return inner | |
| 209 | |
| 210 | |
| 211 class RecipeTestApi(object): | |
|
agable
2013/09/23 22:57:58
You're going to have to document this *really well
iannucci
2013/09/24 02:18:51
Well... with a data set of 1, all things are unexp
| |
| 212 def __init__(self, module=None, test_data=DisabledTestData()): | |
| 213 """Note: Injected dependencies are NOT available in __init__().""" | |
| 214 # If we're the 'root' api, inject directly into 'self'. | |
| 215 # Otherwise inject into 'self.m' | |
| 216 self.m = self if module is None else ModuleInjectionSite() | |
| 217 self._module = module | |
| 218 | |
| 219 assert isinstance(test_data, (ModuleTestData, DisabledTestData)) | |
| 220 self._test_data = test_data | |
| 221 | |
| 222 @staticmethod | |
| 223 def test(name): | |
| 224 return TestData(name) | |
| 225 | |
| 226 @staticmethod | |
| 227 def step_data(name, *data): | |
| 228 assert all(isinstance(d, StepTestData) for d in data) | |
| 229 ret = TestData(None) | |
| 230 ret.step_data[name] = reduce(sum, data) | |
| 231 return ret | |
| OLD | NEW |