Matrix-Mirrors/anonymousland-synapse
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse.git synced 2025-12-10 10:20:32 -05:00
Code Issues Projects Releases Packages Wiki Activity

Add StorageProvider concept

Browse source
This commit is contained in:
Erik Johnston 2018-01-08 17:19:55 +00:00
parent 2442e9876c
commit 8f03aa9f61
3 changed files with 162 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

15
synapse/rest/media/v1/media_storage.py
View file

@ -32,9 +32,10 @@ class MediaStorage(object):
"""Responsible for storing/fetching files from local sources.
"""
def __init__(self, local_media_directory, filepaths):
def __init__(self, local_media_directory, filepaths, storage_providers):
self.local_media_directory = local_media_directory
self.filepaths = filepaths
self.storage_providers = storage_providers
@defer.inlineCallbacks
def store_file(self, source, file_info):
@ -90,11 +91,12 @@ class MediaStorage(object):
finished_called = [False]
@defer.inlineCallbacks
def finish():
# This will be used later when we want to hit out to other storage
# places
for provider in self.storage_providers:
yield provider.store_file(path, file_info)
finished_called[0] = True
return defer.succeed(None)
try:
with open(fname, "wb") as f:
@ -127,6 +129,11 @@ class MediaStorage(object):
if os.path.exists(local_path):
defer.returnValue(FileResponder(open(local_path, "rb")))
for provider in self.storage_providers:
res = yield provider.fetch(path, file_info)
if res:
defer.returnValue(res)
defer.returnValue(None)
def _file_info_to_path(self, file_info):