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