| # Copyright 2013 The Chromium Authors. All rights reserved. |
| # Use of this source code is governed by a BSD-style license that can be |
| # found in the LICENSE file. |
| |
| from future import Future |
| from object_store import ObjectStore |
| |
| class TestObjectStore(ObjectStore): |
| '''An object store which records its namespace and behaves like a dict. |
| Specify |init| with an initial object for the object store. |
| Use CheckAndReset to assert how many times Get/Set/Del have been called. Get |
| is a special case; it is only incremented once the future has had Get called. |
| ''' |
| def __init__(self, namespace, start_empty=False, init=None): |
| self.namespace = namespace |
| self.start_empty = start_empty |
| self._store = {} if init is None else init |
| if start_empty: |
| assert not self._store |
| self._get_count = 0 |
| self._set_count = 0 |
| self._del_count = 0 |
| |
| # |
| # ObjectStore implementation. |
| # |
| |
| def GetMulti(self, keys): |
| class FutureImpl(object): |
| def Get(self2): |
| self._get_count += 1 |
| return dict((k, self._store.get(k)) for k in keys if k in self._store) |
| return Future(delegate=FutureImpl()) |
| |
| def SetMulti(self, mapping): |
| self._set_count += 1 |
| self._store.update(mapping) |
| |
| def DelMulti(self, keys): |
| self._del_count += 1 |
| for k in keys: |
| self._store.pop(k, None) |
| |
| # |
| # Testing methods. |
| # |
| |
| def CheckAndReset(self, get_count=0, set_count=0, del_count=0): |
| '''Returns a tuple (success, error). Use in tests like: |
| self.assertTrue(*object_store.CheckAndReset(...)) |
| ''' |
| errors = [] |
| for desc, expected, actual in (('get_count', get_count, self._get_count), |
| ('set_count', set_count, self._set_count), |
| ('del_count', del_count, self._del_count)): |
| if actual != expected: |
| errors.append('%s: expected %s got %s' % (desc, expected, actual)) |
| try: |
| return (len(errors) == 0, ', '.join(errors)) |
| finally: |
| self.Reset() |
| |
| def Reset(self): |
| self._get_count = 0 |
| self._set_count = 0 |
| self._del_count = 0 |
