Mercurial > libervia-web
view libervia/pages/files/view/page_meta.py @ 1245:079e8eb6e327
server (tasks): refactoring:
- moved `TasksManager` to `server.tasks.manager`
- tasks modules now must have a `Task` class which will be instanciated by TasksManager
- `server.tasks.task` has a basis for `Task` class
- `Task.prepare` can now be asynchronous
- `importlib` is now used to import tasks, instead of exec
- tasks are now parsed/run after pages are imported
- `server.BackendReady` is now a coroutine
- type hinting for Task attributes
author | Goffi <goffi@goffi.org> |
---|---|
date | Sat, 25 Apr 2020 16:08:55 +0200 |
parents | f511f8fbbf8a |
children | e065c8886b81 |
line wrap: on
line source
#!/usr/bin/env python3 from libervia.server.constants import Const as C from sat.core.i18n import _ from twisted.internet import defer from twisted.web import static from libervia.server.utils import ProgressHandler import tempfile import os import os.path from sat.core.log import getLogger log = getLogger(__name__) """files handling pages""" name = "files_view" access = C.PAGES_ACCESS_PROFILE def parse_url(self, request): self.getPathArgs(request, ["service", "*path"], min_args=2, service="jid", path="") def cleanup(__, tmp_dir, dest_path): try: os.unlink(dest_path) except OSError: log.warning(_("Can't remove temporary file {path}").format(path=dest_path)) try: os.rmdir(tmp_dir) except OSError: log.warning(_("Can't remove temporary directory {path}").format(path=tmp_dir)) @defer.inlineCallbacks def render(self, request): data = self.getRData(request) profile = self.getProfile(request) service, path_elts = data["service"], data["path"] basename = path_elts[-1] dir_elts = path_elts[:-1] dir_path = "/".join(dir_elts) tmp_dir = tempfile.mkdtemp() dest_path = os.path.join(tmp_dir, basename) request.notifyFinish().addCallback(cleanup, tmp_dir, dest_path) progress_id = yield self.host.bridgeCall( "fileJingleRequest", service.full(), dest_path, basename, "", "", {"path": dir_path}, profile, ) log.debug("file requested") yield ProgressHandler(self.host, progress_id, profile).register() log.debug("file downloaded") self.delegateToResource(request, static.File(dest_path))