Mercurial > libervia-backend
annotate libervia/cli/cmd_call.py @ 4239:a38559e6d6e2
core: remove legacy VERSION file.
| author | Goffi <goffi@goffi.org> |
|---|---|
| date | Sat, 11 May 2024 13:25:45 +0200 |
| parents | d01b8d002619 |
| children | 79c8a70e1813 |
| rev | line source |
|---|---|
| 4143 | 1 #!/usr/bin/env python3 |
| 2 | |
| 3 | |
| 4 # Libervia CLI | |
| 5 # Copyright (C) 2009-2021 Jérôme Poisson (goffi@goffi.org) | |
| 6 | |
| 7 # This program is free software: you can redistribute it and/or modify | |
| 8 # it under the terms of the GNU Affero General Public License as published by | |
| 9 # the Free Software Foundation, either version 3 of the License, or | |
| 10 # (at your option) any later version. | |
| 11 | |
| 12 # This program is distributed in the hope that it will be useful, | |
| 13 # but WITHOUT ANY WARRANTY; without even the implied warranty of | |
| 14 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
| 15 # GNU Affero General Public License for more details. | |
| 16 | |
| 17 # You should have received a copy of the GNU Affero General Public License | |
| 18 # along with this program. If not, see <http://www.gnu.org/licenses/>. | |
| 19 | |
| 20 | |
| 21 from functools import partial | |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
22 import importlib |
| 4143 | 23 import logging |
|
4233
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
24 from typing import Any |
| 4143 | 25 |
| 26 | |
| 27 from libervia.backend.core.i18n import _ | |
| 28 from libervia.backend.tools.common import data_format | |
| 29 from libervia.cli.constants import Const as C | |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
30 from libervia.frontends.tools import jid |
|
4233
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
31 from libervia.frontends.tools.webrtc_models import CallData |
| 4143 | 32 |
| 33 from . import base | |
| 34 | |
| 35 __commands__ = ["Call"] | |
| 36 | |
| 37 | |
| 38 class Common(base.CommandBase): | |
| 39 | |
| 4206 | 40 |
| 41 def __init__(self, *args, **kwargs): | |
| 42 super().__init__( | |
| 43 *args, | |
| 44 use_output=C.OUTPUT_CUSTOM, | |
| 45 extra_outputs={ | |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
46 #: automatically select best output for current platform |
| 4206 | 47 "default": self.auto_output, |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
48 #: simple output with GStreamer ``autovideosink`` |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
49 "simple": partial(self.use_output, "simple"), |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
50 #: Qt GUI |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
51 "gui": partial(self.use_output, "gui"), |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
52 #: experimental TUI output |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
53 "tui": partial(self.use_output, "tui"), |
| 4206 | 54 }, |
| 55 **kwargs | |
| 56 ) | |
| 57 | |
| 4143 | 58 def add_parser_options(self): |
| 59 self.parser.add_argument( | |
| 60 "--no-ui", action="store_true", help=_("disable user interface") | |
| 61 ) | |
|
4233
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
62 sources_group = self.parser.add_mutually_exclusive_group() |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
63 sources_group.add_argument( |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
64 "-s", "--sources", choices=['auto', 'test'], default='auto', |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
65 help='Well-known sources to use (default: "auto").' |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
66 ) |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
67 |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
68 def get_call_data_kw(self) -> dict[str, Any]: |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
69 """Get relevant keyword arguments for CallData""" |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
70 kwargs: dict[str, Any] = {} |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
71 if self.args.sources == "test": |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
72 kwargs["sources"] = "test" |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
73 return kwargs |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
74 |
| 4143 | 75 |
| 76 async def start(self): | |
| 77 root_logger = logging.getLogger() | |
| 78 # we don't want any formatting for messages from webrtc | |
| 79 for handler in root_logger.handlers: | |
| 80 handler.setFormatter(None) | |
| 81 if self.verbosity == 0: | |
| 82 root_logger.setLevel(logging.ERROR) | |
| 83 if self.verbosity >= 1: | |
| 84 root_logger.setLevel(logging.WARNING) | |
| 85 if self.verbosity >= 2: | |
| 86 root_logger.setLevel(logging.DEBUG) | |
| 87 | |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
88 async def auto_output(self, call_data: CallData) -> None: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
89 """Make a guess on the best output to use on current platform""" |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
90 try: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
91 from .call_gui import AVCallUI |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
92 except ImportError: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
93 # we can't import GUI, we may have missing modules |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
94 await self.use_output("simple", call_data) |
| 4206 | 95 else: |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
96 if AVCallUI.can_run(): |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
97 await self.use_output("gui", call_data) |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
98 else: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
99 await self.use_output("simple", call_data) |
| 4206 | 100 |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
101 async def use_output(self, output_type, call_data: CallData): |
| 4206 | 102 try: |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
103 AVCall_module = importlib.import_module(f"libervia.cli.call_{output_type}") |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
104 AVCallUI = AVCall_module.AVCallUI |
| 4206 | 105 except Exception as e: |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
106 self.disp(f"Error starting {output_type.upper()} UI: {e}", error=True) |
| 4206 | 107 self.host.quit(C.EXIT_ERROR) |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
108 else: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
109 try: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
110 await AVCallUI.run(self, call_data) |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
111 except Exception as e: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
112 self.disp(f"Error running {output_type.upper()} UI: {e}", error=True) |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
113 self.host.quit(C.EXIT_ERROR) |
| 4206 | 114 |
| 4143 | 115 |
| 116 class Make(Common): | |
| 117 def __init__(self, host): | |
| 118 super().__init__( | |
| 119 host, | |
| 120 "make", | |
| 121 use_verbose=True, | |
| 122 help=_("start a call"), | |
| 123 ) | |
| 124 | |
| 125 def add_parser_options(self): | |
| 126 super().add_parser_options() | |
| 127 self.parser.add_argument( | |
| 128 "entity", | |
| 129 metavar="JID", | |
| 130 help=_("JIDs of entity to call"), | |
| 131 ) | |
| 132 | |
| 133 async def start(self): | |
| 134 await super().start() | |
| 4206 | 135 await super().output(CallData( |
| 136 callee=jid.JID(self.args.entity), | |
|
4233
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
137 kwargs=self.get_call_data_kw() |
| 4206 | 138 )) |
| 4143 | 139 |
| 140 | |
| 141 class Receive(Common): | |
| 142 def __init__(self, host): | |
| 143 super().__init__( | |
| 144 host, | |
| 145 "receive", | |
| 146 use_verbose=True, | |
| 147 help=_("wait for a call"), | |
| 148 ) | |
| 149 | |
| 150 def add_parser_options(self): | |
| 151 super().add_parser_options() | |
| 152 auto_accept_group = self.parser.add_mutually_exclusive_group() | |
| 153 auto_accept_group.add_argument( | |
| 154 "-a", | |
| 155 "--auto-accept", | |
| 156 action="append", | |
| 157 metavar="JID", | |
| 158 default=[], | |
| 159 help=_("automatically accept call from this jid (can be used multiple times)") | |
| 160 ) | |
| 161 auto_accept_group.add_argument( | |
| 162 "--auto-accept-all", | |
| 163 action="store_true", | |
| 164 help=_("automatically accept call from anybody") | |
| 165 ) | |
| 166 | |
| 167 async def on_action_new( | |
| 168 self, action_data_s: str, action_id: str, security_limit: int, profile: str | |
| 169 ) -> None: | |
| 170 if profile != self.profile: | |
| 171 return | |
| 172 action_data = data_format.deserialise(action_data_s) | |
| 173 if action_data.get("type") != C.META_TYPE_CALL: | |
| 174 return | |
| 175 peer_jid = jid.JID(action_data["from_jid"]).bare | |
| 176 caller = peer_jid.bare | |
| 177 if ( | |
| 178 not self.args.auto_accept_all | |
| 179 and caller not in self.args.auto_accept | |
| 180 and not await self.host.confirm( | |
| 181 _("📞 Incoming call from {caller}, do you accept?").format( | |
| 182 caller=caller | |
| 183 ) | |
| 184 ) | |
| 185 ): | |
| 186 await self.host.bridge.action_launch( | |
| 187 action_id, data_format.serialise({"cancelled": True}), profile | |
| 188 ) | |
| 189 return | |
| 190 | |
| 191 self.disp(_("✅ Incoming call from {caller} accepted.").format(caller=caller)) | |
| 192 | |
| 4206 | 193 await super().output(CallData( |
| 194 callee=peer_jid, | |
| 195 sid=action_data["session_id"], | |
|
4233
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
196 action_id=action_id, |
|
d01b8d002619
cli (call, file), frontends: implement webRTC data channel transfer:
Goffi <goffi@goffi.org>
parents:
4210
diff
changeset
|
197 kwargs=self.get_call_data_kw() |
| 4206 | 198 )) |
| 4143 | 199 |
| 200 async def start(self): | |
| 201 await super().start() | |
| 202 self.host.bridge.register_signal("action_new", self.on_action_new, "core") | |
| 203 | |
| 204 | |
| 205 class Call(base.CommandBase): | |
| 206 subcommands = (Make, Receive) | |
| 207 | |
| 208 def __init__(self, host): | |
| 209 super().__init__(host, "call", use_profile=False, help=_("A/V calls and related")) |