Mercurial > libervia-web
annotate libervia/server/tasks/task.py @ 1257:1ec41ac1e7cf
server: seperation between production build dir and dev build dir:
LiberviaRootResource instances's `build_path` is the path where generated files are put
and served by the HTTP server, while `dev_buid_path` is used for temporary files/libraries
needed for the generation/compilation of files.
author | Goffi <goffi@goffi.org> |
---|---|
date | Sun, 03 May 2020 18:25:11 +0200 |
parents | 079e8eb6e327 |
children | 6161076193e0 |
rev | line source |
---|---|
1239 | 1 #!/usr/bin/env python3 |
2 | |
1146 | 3 # Libervia: a Salut à Toi frontend |
1237 | 4 # Copyright (C) 2011-2020 Jérôme Poisson <goffi@goffi.org> |
1146 | 5 |
6 # This program is free software: you can redistribute it and/or modify | |
7 # it under the terms of the GNU Affero General Public License as published by | |
8 # the Free Software Foundation, either version 3 of the License, or | |
9 # (at your option) any later version. | |
10 | |
11 # This program is distributed in the hope that it will be useful, | |
12 # but WITHOUT ANY WARRANTY; without even the implied warranty of | |
13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
14 # GNU Affero General Public License for more details. | |
15 | |
16 # You should have received a copy of the GNU Affero General Public License | |
17 # along with this program. If not, see <http://www.gnu.org/licenses/>. | |
18 from twisted.python.procutils import which | |
1245 | 19 from sat.core.log import getLogger |
20 from sat.tools.common import async_process | |
1146 | 21 from sat.core import exceptions |
22 from sat.core.i18n import _ | |
1245 | 23 from typing import Optional |
1146 | 24 |
25 log = getLogger(__name__) | |
26 | |
27 | |
1245 | 28 class Task: |
1146 | 29 """Handle tasks of a Libervia site""" |
1245 | 30 # can be "stop" or "continue" |
31 ON_ERROR: str = "stop" | |
32 LOG_OUTPUT: bool = True | |
33 # list of directories to check for restarting this task | |
34 WATCH_DIRS: Optional[list] = None | |
1146 | 35 |
1245 | 36 def __init__(self, manager): |
37 self.manager = manager | |
38 | |
39 @property | |
40 def host(self): | |
41 return self.manager.host | |
42 | |
43 @property | |
44 def resource(self): | |
45 return self.manager.resource | |
1146 | 46 |
47 @property | |
48 def site_path(self): | |
1245 | 49 return self.manager.site_path |
1146 | 50 |
51 @property | |
52 def build_path(self): | |
53 """path where generated files will be build for this site""" | |
1245 | 54 return self.manager.build_path |
1146 | 55 |
56 def getConfig(self, key, default=None, value_type=None): | |
1147
02afab1b15c5
server, pages, tasks: moved getConfig to backend, and added shorcut version in LiberviaPage and TasksManager
Goffi <goffi@goffi.org>
parents:
1146
diff
changeset
|
57 return self.host.getConfig(self.resource, key=key, default=default, |
02afab1b15c5
server, pages, tasks: moved getConfig to backend, and added shorcut version in LiberviaPage and TasksManager
Goffi <goffi@goffi.org>
parents:
1146
diff
changeset
|
58 value_type=value_type) |
1146 | 59 |
60 @property | |
61 def site_name(self): | |
62 return self.resource.site_name | |
63 | |
64 def findCommand(self, name, *args): | |
65 """Find full path of a shell command | |
66 | |
67 @param name(unicode): name of the command to find | |
68 @param *args(unicode): extra names the command may have | |
69 @return (unicode): full path of the command | |
70 @raise exceptions.NotFound: can't find this command | |
71 """ | |
72 names = (name,) + args | |
73 for n in names: | |
74 try: | |
1216 | 75 cmd_path = which(n)[0] |
1146 | 76 except IndexError: |
77 pass | |
1189
170802865156
server (tasks): fixed findCommand when first name can't be found
Goffi <goffi@goffi.org>
parents:
1166
diff
changeset
|
78 else: |
170802865156
server (tasks): fixed findCommand when first name can't be found
Goffi <goffi@goffi.org>
parents:
1166
diff
changeset
|
79 return cmd_path |
1146 | 80 raise exceptions.NotFound(_( |
1216 | 81 "Can't find {name} command, did you install it?").format(name=name)) |
1146 | 82 |
83 def runCommand(self, command, *args, **kwargs): | |
1245 | 84 kwargs['verbose'] = self.LOG_OUTPUT |
1146 | 85 return async_process.CommandProtocol.run(command, *args, **kwargs) |