diff options
Diffstat (limited to 'src/leap/soledad/server/_blobs/__init__.py')
-rw-r--r-- | src/leap/soledad/server/_blobs/__init__.py | 41 |
1 files changed, 12 insertions, 29 deletions
diff --git a/src/leap/soledad/server/_blobs/__init__.py b/src/leap/soledad/server/_blobs/__init__.py index c415577d..b88c81a2 100644 --- a/src/leap/soledad/server/_blobs/__init__.py +++ b/src/leap/soledad/server/_blobs/__init__.py @@ -14,19 +14,25 @@ # # You should have received a copy of the GNU General Public License # along with this program. If not, see <http://www.gnu.org/licenses/>. - """ Blobs Server implementation. """ from .fs_backend import FilesystemBlobsBackend from .resource import BlobsResource - +from .state import BlobsServerState from .errors import BlobExists -from .errors import ImproperlyConfiguredException from .errors import QuotaExceeded +from .errors import ImproperlyConfiguredException -__all__ = ['BlobsResource', 'BlobExists', 'QuotaExceeded'] +__all__ = [ + 'FilesystemBlobsBackend', + 'BlobsResource', + 'BlobsServerState', + 'BlobExists', + 'QuotaExceeded', + 'ImproperlyConfiguredException', +] if __name__ == '__main__': @@ -40,39 +46,16 @@ if __name__ == '__main__': from twisted.web.server import Site from twisted.internet import reactor - # parse command line arguments import argparse + # parse command line parser = argparse.ArgumentParser() parser.add_argument('--port', default=9000, type=int) parser.add_argument('--path', default='/tmp/blobs/user') args = parser.parse_args() + # run the server root = BlobsResource("filesystem", args.path) - # I picture somethink like - # BlobsResource(backend="filesystem", backend_opts={'path': '/tmp/blobs'}) - factory = Site(root) reactor.listenTCP(args.port, factory) reactor.run() - - -class BlobsServerState(object): - """ - Given a backend name, it gives a instance of IBlobsBackend - """ - # Allowed backend classes are defined here - handlers = {"filesystem": FilesystemBlobsBackend} - - def __init__(self, backend, **backend_kwargs): - if backend not in self.handlers: - raise ImproperlyConfiguredException("No such backend: %s", backend) - self.backend = self.handlers[backend](**backend_kwargs) - - def open_database(self, user_id): - """ - That method is just for compatibility with CouchServerState, so - IncomingAPI can change backends. - """ - # TODO: deprecate/refactor it as it's here for compatibility. - return self.backend |