Mercurial > libervia-backend
view libervia/backend/plugins/plugin_app_manager_docker/__init__.py @ 4294:a0ed5c976bf8
component conferences, plugin XEP-0167, XEP-0298: add stream user metadata:
A/V conference now adds user metadata about the stream it is forwarding through XEP-0298.
This is parsed and added to metadata during confirmation on client side.
rel 448
author | Goffi <goffi@goffi.org> |
---|---|
date | Tue, 06 Aug 2024 23:43:11 +0200 |
parents | 0d7bb4df2343 |
children |
line wrap: on
line source
#!/usr/bin/env python3 # SàT plugin to manage Docker # Copyright (C) 2009-2021 Jérôme Poisson (goffi@goffi.org) # This program is free software: you can redistribute it and/or modify # it under the terms of the GNU Affero General Public License as published by # the Free Software Foundation, either version 3 of the License, or # (at your option) any later version. # This program is distributed in the hope that it will be useful, # but WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the # GNU Affero General Public License for more details. # You should have received a copy of the GNU Affero General Public License # along with this program. If not, see <http://www.gnu.org/licenses/>. from pathlib import Path from twisted.python.procutils import which from libervia.backend.core.i18n import _ from libervia.backend.core.constants import Const as C from libervia.backend.core import exceptions from libervia.backend.core.log import getLogger from libervia.backend.plugins.plugin_misc_app_manager.models import AppManagerBackend from libervia.backend.tools.common import async_process log = getLogger(__name__) PLUGIN_INFO = { C.PI_NAME: "Docker Applications Manager", C.PI_IMPORT_NAME: "APP_MANAGER_DOCKER", C.PI_TYPE: C.PLUG_TYPE_MISC, C.PI_MODES: C.PLUG_MODE_BOTH, C.PI_DEPENDENCIES: ["APP_MANAGER"], C.PI_MAIN: "AppManagerDocker", C.PI_HANDLER: "no", C.PI_DESCRIPTION: _("""Applications Manager for Docker"""), } class AppManagerDocker(AppManagerBackend): name = "docker-compose" discover_path = Path(__file__).parent def __init__(self, host): log.info(_("Docker App Manager initialization")) try: self.docker_compose_path = which("docker-compose")[0] except IndexError: raise exceptions.NotFound( '"docker-compose" executable not found, Docker can\'t be used with ' "application manager" ) super().__init__(host) async def start(self, app_data: dict) -> None: await self._am.start_common(app_data) working_dir = app_data["_instance_dir_path"] try: override = app_data["override"] except KeyError: pass else: log.debug("writting override file") override_path = working_dir / "docker-compose.override.yml" with override_path.open("w") as f: self._am.dump(override, f) await async_process.run( self.docker_compose_path, "up", "--detach", path=str(working_dir), ) async def stop(self, app_data: dict) -> None: working_dir = app_data["_instance_dir_path"] await async_process.run( self.docker_compose_path, "down", path=str(working_dir), ) async def compute_expose(self, app_data: dict) -> None: working_dir = app_data["_instance_dir_path"] expose = app_data["expose"] ports = expose.get("ports", {}) for name, port_data in list(ports.items()): try: service = port_data["service"] private = port_data["private"] int(private) except (KeyError, ValueError): log.warning( f"invalid value found for {name!r} port in {app_data['_file_path']}" ) continue exposed_port = await async_process.run( self.docker_compose_path, "port", service, str(private), path=str(working_dir), ) exposed_port = exposed_port.decode().strip() try: addr, port = exposed_port.split(":") int(port) except ValueError: log.warning( f"invalid exposed port for {name}, ignoring: {exposed_port!r}" ) del ports[name] else: ports[name] = exposed_port