Index: chrome/common/extensions/docs/server2/persistent_object_store.py |
diff --git a/chrome/common/extensions/docs/server2/persistent_object_store.py b/chrome/common/extensions/docs/server2/persistent_object_store.py |
deleted file mode 100644 |
index c0ae8734c01cdaeab51f7c1ada93c1b8b2f35dd5..0000000000000000000000000000000000000000 |
--- a/chrome/common/extensions/docs/server2/persistent_object_store.py |
+++ /dev/null |
@@ -1,47 +0,0 @@ |
-# 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 appengine_wrappers import db |
-from datastore_models import PersistentObjectStoreItem |
-from environment import IsDevServer |
-from future import All, Future |
-from object_store import ObjectStore |
- |
- |
-class PersistentObjectStore(ObjectStore): |
- '''Stores data persistently using the AppEngine Datastore API. |
- ''' |
- def __init__(self, namespace): |
- self._namespace = namespace |
- |
- def SetMulti(self, mapping): |
- rpcs = [db.put_async( |
- PersistentObjectStoreItem.CreateItem(self._namespace, key, value)) |
- for key, value in mapping.iteritems()] |
- # If running the dev server, the futures don't complete until the server is |
- # *quitting*. This is annoying. Flush now. |
- if IsDevServer(): |
- [rpc.wait() for rpc in rpcs] |
- return All(Future(callback=lambda: rpc.get_result()) for rpc in rpcs) |
- |
- def GetMulti(self, keys): |
- db_futures = dict( |
- (k, db.get_async( |
- PersistentObjectStoreItem.CreateKey(self._namespace, k))) |
- for k in keys) |
- def resolve(): |
- return dict((key, future.get_result().GetValue()) |
- for key, future in db_futures.iteritems() |
- if future.get_result() is not None) |
- return Future(callback=resolve) |
- |
- def DelMulti(self, keys): |
- futures = [] |
- for key in keys: |
- futures.append(db.delete_async( |
- PersistentObjectStoreItem.CreateKey(self._namespace, key))) |
- # If running the dev server, the futures don't complete until the server is |
- # *quitting*. This is annoying. Flush now. |
- if IsDevServer(): |
- [future.wait() for future in futures] |