Mercurial > libervia-backend
annotate libervia/cli/cmd_call.py @ 4229:dd9bc7d791d7
core (constants): use `bool_type`:
Using `bool` for type hint in `Const.bool_const` if conflicting with `Const.bool` method.
To avoid this, `bool_type` is used as an alias to `bool`.
| author | Goffi <goffi@goffi.org> |
|---|---|
| date | Sat, 06 Apr 2024 12:14:10 +0200 |
| parents | 9218d4331bb2 |
| children | d01b8d002619 |
| 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 |
| 24 | |
| 25 | |
| 26 from libervia.backend.core.i18n import _ | |
| 27 from libervia.backend.tools.common import data_format | |
| 28 from libervia.cli.constants import Const as C | |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
29 from libervia.frontends.tools import jid |
| 4143 | 30 |
| 31 from . import base | |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
32 from .call_webrtc import CallData, WebRTCCall |
| 4143 | 33 |
| 34 __commands__ = ["Call"] | |
| 35 | |
| 36 | |
| 37 class Common(base.CommandBase): | |
| 38 | |
| 4206 | 39 |
| 40 def __init__(self, *args, **kwargs): | |
| 41 super().__init__( | |
| 42 *args, | |
| 43 use_output=C.OUTPUT_CUSTOM, | |
| 44 extra_outputs={ | |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
45 #: automatically select best output for current platform |
| 4206 | 46 "default": self.auto_output, |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
47 #: simple output with GStreamer ``autovideosink`` |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
48 "simple": partial(self.use_output, "simple"), |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
49 #: Qt GUI |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
50 "gui": partial(self.use_output, "gui"), |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
51 #: experimental TUI output |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
52 "tui": partial(self.use_output, "tui"), |
| 4206 | 53 }, |
| 54 **kwargs | |
| 55 ) | |
| 56 | |
| 4143 | 57 def add_parser_options(self): |
| 58 self.parser.add_argument( | |
| 59 "--no-ui", action="store_true", help=_("disable user interface") | |
| 60 ) | |
| 61 | |
| 62 async def start(self): | |
| 63 root_logger = logging.getLogger() | |
| 64 # we don't want any formatting for messages from webrtc | |
| 65 for handler in root_logger.handlers: | |
| 66 handler.setFormatter(None) | |
| 67 if self.verbosity == 0: | |
| 68 root_logger.setLevel(logging.ERROR) | |
| 69 if self.verbosity >= 1: | |
| 70 root_logger.setLevel(logging.WARNING) | |
| 71 if self.verbosity >= 2: | |
| 72 root_logger.setLevel(logging.DEBUG) | |
| 73 | |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
74 async def auto_output(self, call_data: CallData) -> None: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
75 """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
|
76 try: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
77 from .call_gui import AVCallUI |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
78 except ImportError: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
79 # we can't import GUI, we may have missing modules |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
80 await self.use_output("simple", call_data) |
| 4206 | 81 else: |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
82 if AVCallUI.can_run(): |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
83 await self.use_output("gui", call_data) |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
84 else: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
85 await self.use_output("simple", call_data) |
| 4206 | 86 |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
87 async def use_output(self, output_type, call_data: CallData): |
| 4206 | 88 try: |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
89 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
|
90 AVCallUI = AVCall_module.AVCallUI |
| 4206 | 91 except Exception as e: |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
92 self.disp(f"Error starting {output_type.upper()} UI: {e}", error=True) |
| 4206 | 93 self.host.quit(C.EXIT_ERROR) |
|
4210
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
94 else: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
95 try: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
96 await AVCallUI.run(self, call_data) |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
97 except Exception as e: |
|
9218d4331bb2
cli (call): `tui` output implementation:
Goffi <goffi@goffi.org>
parents:
4206
diff
changeset
|
98 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
|
99 self.host.quit(C.EXIT_ERROR) |
| 4206 | 100 |
| 4143 | 101 |
| 102 class Make(Common): | |
| 103 def __init__(self, host): | |
| 104 super().__init__( | |
| 105 host, | |
| 106 "make", | |
| 107 use_verbose=True, | |
| 108 help=_("start a call"), | |
| 109 ) | |
| 110 | |
| 111 def add_parser_options(self): | |
| 112 super().add_parser_options() | |
| 113 self.parser.add_argument( | |
| 114 "entity", | |
| 115 metavar="JID", | |
| 116 help=_("JIDs of entity to call"), | |
| 117 ) | |
| 118 | |
| 119 async def start(self): | |
| 120 await super().start() | |
| 4206 | 121 await super().output(CallData( |
| 122 callee=jid.JID(self.args.entity), | |
| 123 )) | |
| 4143 | 124 |
| 125 | |
| 126 class Receive(Common): | |
| 127 def __init__(self, host): | |
| 128 super().__init__( | |
| 129 host, | |
| 130 "receive", | |
| 131 use_verbose=True, | |
| 132 help=_("wait for a call"), | |
| 133 ) | |
| 134 | |
| 135 def add_parser_options(self): | |
| 136 super().add_parser_options() | |
| 137 auto_accept_group = self.parser.add_mutually_exclusive_group() | |
| 138 auto_accept_group.add_argument( | |
| 139 "-a", | |
| 140 "--auto-accept", | |
| 141 action="append", | |
| 142 metavar="JID", | |
| 143 default=[], | |
| 144 help=_("automatically accept call from this jid (can be used multiple times)") | |
| 145 ) | |
| 146 auto_accept_group.add_argument( | |
| 147 "--auto-accept-all", | |
| 148 action="store_true", | |
| 149 help=_("automatically accept call from anybody") | |
| 150 ) | |
| 151 | |
| 152 async def on_action_new( | |
| 153 self, action_data_s: str, action_id: str, security_limit: int, profile: str | |
| 154 ) -> None: | |
| 155 if profile != self.profile: | |
| 156 return | |
| 157 action_data = data_format.deserialise(action_data_s) | |
| 158 if action_data.get("type") != C.META_TYPE_CALL: | |
| 159 return | |
| 160 peer_jid = jid.JID(action_data["from_jid"]).bare | |
| 161 caller = peer_jid.bare | |
| 162 if ( | |
| 163 not self.args.auto_accept_all | |
| 164 and caller not in self.args.auto_accept | |
| 165 and not await self.host.confirm( | |
| 166 _("📞 Incoming call from {caller}, do you accept?").format( | |
| 167 caller=caller | |
| 168 ) | |
| 169 ) | |
| 170 ): | |
| 171 await self.host.bridge.action_launch( | |
| 172 action_id, data_format.serialise({"cancelled": True}), profile | |
| 173 ) | |
| 174 return | |
| 175 | |
| 176 self.disp(_("✅ Incoming call from {caller} accepted.").format(caller=caller)) | |
| 177 | |
| 4206 | 178 await super().output(CallData( |
| 179 callee=peer_jid, | |
| 180 sid=action_data["session_id"], | |
| 181 action_id=action_id | |
| 182 )) | |
| 4143 | 183 |
| 184 async def start(self): | |
| 185 await super().start() | |
| 186 self.host.bridge.register_signal("action_new", self.on_action_new, "core") | |
| 187 | |
| 188 | |
| 189 class Call(base.CommandBase): | |
| 190 subcommands = (Make, Receive) | |
| 191 | |
| 192 def __init__(self, host): | |
| 193 super().__init__(host, "call", use_profile=False, help=_("A/V calls and related")) |