Burtiraven2/session_redis_public
1
0
Fork 0
mirror of https://github.com/camptocamp/odoo-cloud-platform.git synced 2026-06-24 08:47:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge commit 'refs/pull/114/head' of github.com:camptocamp/odoo-cloud-platform into merge-branch-2660-dockerize-1fa840c3

Browse Source
This commit is contained in:
Patrick Tombez
2019-12-18 13:09:35 +01:00
parent af82b8fde3 18d33b4616
commit 5f931058ea
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
attachment_swift/models/ir_attachment.py
+8 -5
View File
@@ -83,9 +83,10 @@ class IrAttachment(osv.osv):
else: else:
return super(IrAttachment, self)._store_file_read(fname, bin_size) return super(IrAttachment, self)._store_file_read(fname, bin_size)
def _store_file_write(self, storage, key, bin_data): def _store_file_write(self, storage, key, bin_data, container=None):
if storage == 'swift': if storage == 'swift':
container = os.environ.get('SWIFT_WRITE_CONTAINER') if container is None:
container = os.environ.get('SWIFT_WRITE_CONTAINER')
conn = self._get_swift_connection() conn = self._get_swift_connection()
conn.put_container(container) conn.put_container(container)
filename = 'swift://{}/{}'.format(container, key) filename = 'swift://{}/{}'.format(container, key)
@@ -101,13 +102,15 @@ class IrAttachment(osv.osv):
filename = _super._store_file_write(key, bin_data) filename = _super._store_file_write(key, bin_data)
return filename return filename
def _store_file_delete(self, fname): def _store_file_delete(self, fname, container=None):
if fname.startswith('swift://'): if fname.startswith('swift://'):
swifturi = SwiftUri(fname) swifturi = SwiftUri(fname)
container = swifturi.container() uri_container = swifturi.container()
if container is None:
container = os.environ.get('SWIFT_WRITE_CONTAINER')
# delete the file only if it is on the current configured bucket # delete the file only if it is on the current configured bucket
# otherwise, we might delete files used on a different environment # otherwise, we might delete files used on a different environment
if container == os.environ.get('SWIFT_WRITE_CONTAINER'): if uri_container == container:
conn = self._get_swift_connection() conn = self._get_swift_connection()
try: try:
conn.delete_object(container, swifturi.item()) conn.delete_object(container, swifturi.item())