OLD | NEW |
1 # Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 # Copyright (c) 2012 The Chromium Authors. All rights reserved. |
2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
4 | 4 |
5 import blob_reference_store as datastore | 5 import blob_reference_store as datastore |
6 from blob_reference_store import BlobReferenceStore | 6 from blob_reference_store import BlobReferenceStore |
7 from appengine_wrappers import blobstore | 7 from appengine_wrappers import blobstore |
8 from appengine_wrappers import files | 8 from appengine_wrappers import files |
9 | 9 |
10 BLOBSTORE_GITHUB = 'BlobstoreGithub' | 10 BLOBSTORE_GITHUB = 'BlobstoreGithub' |
11 | 11 |
12 class AppEngineBlobstore(object): | 12 class AppEngineBlobstore(object): |
13 """A wrapper around the blobstore API, which stores the blob keys in | 13 """A wrapper around the blobstore API, which stores the blob keys in |
14 datastore. | 14 datastore. |
15 """ | 15 """ |
16 def __init__(self): | 16 def __init__(self): |
17 self._datastore = BlobReferenceStore('blobstore') | 17 self._datastore = BlobReferenceStore() |
18 | 18 |
19 def Set(self, key, blob, namespace): | 19 def Set(self, key, blob, namespace): |
20 """Add a blob to the blobstore. |version| is used as part of the key so | 20 """Add a blob to the blobstore. |version| is used as part of the key so |
21 multiple blobs with the same name can be differentiated. | 21 multiple blobs with the same name can be differentiated. |
22 """ | 22 """ |
23 key = namespace + '.' + key | 23 key = namespace + '.' + key |
24 filename = files.blobstore.create() | 24 filename = files.blobstore.create() |
25 with files.open(filename, 'a') as f: | 25 with files.open(filename, 'a') as f: |
26 f.write(blob) | 26 f.write(blob) |
27 files.finalize(filename) | 27 files.finalize(filename) |
(...skipping 11 matching lines...) Expand all Loading... |
39 return blob_reader.read() | 39 return blob_reader.read() |
40 | 40 |
41 def Delete(self, key, namespace): | 41 def Delete(self, key, namespace): |
42 """Delete the blob with version |version| if it is found. | 42 """Delete the blob with version |version| if it is found. |
43 """ | 43 """ |
44 key = namespace + '.' + key | 44 key = namespace + '.' + key |
45 blob_key = self._datastore.Delete(datastore.BLOB_REFERENCE_BLOBSTORE, key) | 45 blob_key = self._datastore.Delete(datastore.BLOB_REFERENCE_BLOBSTORE, key) |
46 if blob_key is None: | 46 if blob_key is None: |
47 return | 47 return |
48 blob_key.delete() | 48 blob_key.delete() |
OLD | NEW |