libervia-desktop-kivy: libervia/desktop_kivy/plugins/plugin_wid

annotate libervia/desktop_kivy/plugins/plugin_wid_calls.py @ 517:f316c7f19909

install: update Kivy version to fix build issue.

author	Goffi <goffi@goffi.org>
date	Sat, 13 Jul 2024 13:08:13 +0200
parents	11851162dd4c
children

rev	line source
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	1 from dataclasses import dataclass
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	2 from pathlib import Path
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	3 from typing import Optional, Callable
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	4 from functools import partial
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	5
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	6 # from gi.repository import GLib
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	7 from gi.repository import GObject, Gst, GstWebRTC, GstSdp
510 97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	8 from kivy.metrics import dp
514 d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	9 from libervia.desktop_kivy.core.file_chooser import FileChooser
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	10
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	11 try:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	12 from gi.overrides import Gst as _
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	13 except ImportError:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	14 print(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	15 "no GStreamer python overrides available, please install relevant pacakges on "
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	16 "your system."
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	17 )
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	18 from kivy.clock import Clock
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	19 from kivy.core.audio import Sound, SoundLoader
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	20 from kivy.core.window import Window
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	21 from kivy.graphics.texture import Texture
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	22 from kivy.properties import (
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	23 BooleanProperty,
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	24 ColorProperty,
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	25 NumericProperty,
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	26 ObjectProperty,
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	27 ReferenceListProperty,
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	28 )
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	29 from kivy.support import install_gobject_iteration
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	30 from kivy.uix.button import Button
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	31 from kivy.uix.image import Image
510 97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	32 from kivy.uix.popup import Popup
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	33 from kivy.uix.screenmanager import Screen
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	34 from kivy.uix.widget import Widget
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	35 from libervia.backend.core.constants import Const as C
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	36 from libervia.backend.core import log as logging
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	37 from libervia.backend.core.i18n import _
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	38 from libervia.backend.core import exceptions
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	39 from libervia.backend.tools.common import data_format
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	40 from libervia.frontends.quick_frontend import quick_widgets
510 97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	41 from libervia.frontends.tools import aio, display_servers, jid, webrtc
514 d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	42 from libervia.frontends.tools.webrtc_file import WebRTCFileSender
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	43
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	44 from libervia.desktop_kivy import G
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	45
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	46 from ..core import cagou_widget
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	47 from ..core import common
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	48 from ..core.behaviors import FilterBehavior
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	49
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	50 log = logging.getLogger(__name__)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	51
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	52 install_gobject_iteration()
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	53
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	54 Gst.init(None)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	55
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	56
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	57 PLUGIN_INFO = {
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	58 "name": _("calls"),
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	59 "main": "Calls",
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	60 "description": _("Audio/Video calls"),
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	61 "icon_symbol": "phone",
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	62 }
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	63
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	64
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	65 @dataclass
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	66 class TextureData:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	67 texture: Optional[Texture] = None
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	68 size: Optional[tuple[int, int]] = None
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	69
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	70
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	71 class SearchScreen(Screen):
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	72 pass
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	73
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	74
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	75 class InCallScreen(Screen):
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	76 pass
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	77
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	78
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	79 class CallButton(Button):
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	80 parent_widget = ObjectProperty(None)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	81
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	82
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	83 class CallControlButton(common.SymbolButton):
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	84 active = BooleanProperty(True)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	85 background_color = ColorProperty()
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	86 margin_x = NumericProperty(0)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	87 margin_y = NumericProperty(0)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	88 margin = ReferenceListProperty(margin_x, margin_y)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	89
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	90
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	91 class VideoStreamWidget(Image):
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	92 pass
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	93
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	94
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	95 class WebRTC:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	96 """WebRTC implementation for audio and video communication.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	97
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	98 This class encapsulates the WebRTC functionalities required for initiating and
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	99 handling audio and video calls.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	100
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	101 @attribute test_mode: A flag to indicate whether the WebRTC instance is in test mode.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	102 If true, test video and audio sources will be used. Otherwise first webcam and
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	103 microphone available will be used.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	104 """
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	105
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	106 test_mode: bool = False
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	107
510 97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	108 PROXIED_PROPERTIES = {
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	109 'audio_muted', 'callee', 'desktop_sharing', 'sid', 'video_muted', 'desktop_sharing_data'
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	110 }
512 644a8d165e5a plugin calls: use the new binding feature of webrtc module: Goffi <goffi@goffi.org> parents: 510 diff changeset	111 PROXIED_METHODS = {'answer_call', 'bind', 'end_call', 'on_accepted_call', 'on_ice_candidates_new', 'setup_call', 'start_pipeline'}
509 f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	112
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	113 def __init__(self, parent_calls: "Calls", profile: str) -> None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	114 self.parent_calls = parent_calls
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	115 self.profile = profile
509 f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	116 self.webrtc = webrtc.WebRTC(
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	117 G.host.a_bridge,
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	118 profile,
516 11851162dd4c plugin calls: Change WebRTC call following change in class signature. Goffi <goffi@goffi.org> parents: 514 diff changeset	119 sinks_data=webrtc.SinksApp(
509 f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	120 local_video_cb=partial(
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	121 self.on_new_sample,
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	122 update_sample_method=self.update_sample,
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	123 video_widget=self.parent_calls.local_video
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	124 ),
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	125 remote_video_cb=partial(
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	126 self.on_new_sample,
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	127 update_sample_method=self.update_sample,
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	128 video_widget=self.parent_calls.remote_video
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	129 )
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	130 ),
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	131 reset_cb=self.on_reset
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	132
509 f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	133 )
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	134 self.pipeline = None
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	135
509 f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	136 def __getattr__(self, name):
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	137 if name in self.PROXIED_PROPERTIES or name in self.PROXIED_METHODS:
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	138 return getattr(self.webrtc, name)
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	139 raise AttributeError(f"'{type(self).__name__}' object has no attribute '{name}'")
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	140
509 f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	141 def __setattr__(self, name, value):
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	142 if name in self.PROXIED_PROPERTIES:
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	143 setattr(self.webrtc, name, value)
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	144 else:
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	145 super().__setattr__(name, value)
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	146
509 f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	147 def on_reset(self):
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	148 self.texture_map: dict[VideoStreamWidget, TextureData] = {}
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	149
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	150 def on_new_sample(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	151 self,
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	152 video_sink: Gst.Element,
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	153 update_sample_method: Callable,
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	154 video_widget: VideoStreamWidget,
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	155 ) -> bool:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	156 """Handles a new sample from the video sink.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	157
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	158 @param video_sink: The video sink to pull samples from.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	159 @param update_sample_method: The method to call for updating the sample.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	160 @param video_widget: The video widget (either local_video or remote_video).
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	161 @return: Always False
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	162 """
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	163 sample = video_sink.emit("pull-sample")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	164 if sample is None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	165 return False
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	166
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	167 try:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	168 texture_data = self.texture_map[video_widget]
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	169 except KeyError:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	170 texture_data = self.texture_map[video_widget] = TextureData()
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	171
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	172 # Get the current video size
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	173 video_pad = video_sink.get_static_pad("sink")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	174 assert video_pad is not None
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	175 s = video_pad.get_current_caps().get_structure(0)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	176 stream_size = (s.get_value("width"), s.get_value("height"))
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	177
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	178 # Compare with the texture size
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	179 texture_size = texture_data.size
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	180 if texture_size != stream_size:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	181 log.debug(f"sample size update: {texture_size} => {stream_size}")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	182 texture_data.size = stream_size
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	183 # texture needs to be recreated, so we reset the one in texture_data
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	184 texture_data.texture = None
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	185
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	186 Clock.schedule_once(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	187 partial(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	188 update_sample_method,
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	189 sample=sample,
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	190 video_widget=video_widget,
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	191 )
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	192 )
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	193 return False
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	194
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	195 def update_sample(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	196 self,
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	197 dt: float,
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	198 sample: Optional[Gst.Sample],
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	199 video_widget: VideoStreamWidget,
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	200 ) -> None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	201 """Updates the video sample.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	202
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	203 This method runs in the main thread.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	204
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	205 @param dt: Time delta since the last call. This is passed by Clock.schedule_once.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	206 @param sample: The video sample to update.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	207 @param texture_id: identifier of the texture data (e.g. "local" or "remote")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	208 @param texture: The texture object.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	209 @param texture_size: The texture size.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	210 @param video_widget: The video widget.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	211 """
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	212 if sample is None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	213 return
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	214 try:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	215 texture_data = self.texture_map[video_widget]
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	216 except KeyError:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	217 log.warning(f"no texture data found for {video_widget}")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	218 return
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	219
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	220 if texture_data.texture is None and texture_data.size is not None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	221 log.debug(f"===> creating texture for {video_widget}: {texture_data.size=}")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	222 texture = Texture.create(size=texture_data.size, colorfmt="rgb")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	223 assert texture is not None
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	224 texture_data.texture = texture
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	225 texture.flip_vertical()
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	226 video_widget.texture = texture
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	227
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	228 mapinfo = None
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	229 buf = None
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	230 try:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	231 buf = sample.get_buffer()
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	232 _, mapinfo = buf.map(Gst.MapFlags.READ)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	233
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	234 buffer = mapinfo.data.tobytes()
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	235
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	236 if texture_data.texture is None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	237 log.debug("can't copy the buffer, texture is None")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	238 return
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	239 texture_data.texture.blit_buffer(buffer, colorfmt="rgb")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	240 assert video_widget.canvas is not None
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	241 video_widget.canvas.ask_update()
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	242 buf.unmap(mapinfo)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	243 finally:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	244 if buf is not None and mapinfo is not None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	245 buf.unmap(mapinfo)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	246
512 644a8d165e5a plugin calls: use the new binding feature of webrtc module: Goffi <goffi@goffi.org> parents: 510 diff changeset	247
510 97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	248 class WindowSelectButton(Button):
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	249 pass
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	250
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	251
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	252 class DesktopScreenDialog(Popup):
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	253 windows_buttons = ObjectProperty()
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	254
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	255 def __init__(self, calls: "Calls", **kwargs):
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	256 super().__init__(**kwargs)
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	257 self.calls = calls
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	258 if display_servers.detect() == display_servers.X11:
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	259 windows_data = display_servers.x11_list_windows()
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	260 for window_data in windows_data:
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	261 log.debug(f"- X11 windows found: {window_data}")
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	262 button = WindowSelectButton(
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	263 text = window_data["title"],
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	264 on_press=partial(self.on_window_selected, xid=window_data["id"])
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	265 )
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	266 self.windows_buttons.add_widget(button)
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	267
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	268 def on_window_selected(self, instance, xid: str) -> None:
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	269 if xid is not None:
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	270 self.calls.webrtc.desktop_sharing_data = {"xid": xid}
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	271 else:
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	272 self.calls.webrtc.desktop_sharing_data = None
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	273 self.calls.desktop_sharing = True
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	274 self.dismiss()
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	275
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	276
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	277 class Calls(
510 97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	278 quick_widgets.QuickWidget,
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	279 cagou_widget.LiberviaDesktopKivyWidget,
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	280 FilterBehavior
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	281 ):
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	282 audio_muted = BooleanProperty(False)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	283 call_layout = ObjectProperty()
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	284 call_screen = ObjectProperty()
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	285 fullscreen = BooleanProperty(False)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	286 in_call = BooleanProperty(False)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	287 incoming_call_dialog: dict[str, Widget] = {}
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	288 jid_selector = ObjectProperty()
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	289 local_video = ObjectProperty()
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	290 remote_video = ObjectProperty()
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	291 ringtone: Sound \| None = None
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	292 screen_manager = ObjectProperty()
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	293 signals_registered = False
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	294 use_header_input = True
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	295 video_muted = BooleanProperty(False)
510 97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	296 desktop_sharing = BooleanProperty(False)
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	297
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	298 def __init__(self, host, target, profiles):
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	299 quick_widgets.QuickWidget.__init__(self, G.host, target, profiles)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	300 cagou_widget.LiberviaDesktopKivyWidget.__init__(self)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	301 call_btn = CallButton(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	302 parent_widget=self, on_press=lambda *__: aio.run_async(self.toggle_call())
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	303 )
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	304 self.header_input_add_extra(call_btn)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	305 self.webrtc = WebRTC(self, self.profile)
512 644a8d165e5a plugin calls: use the new binding feature of webrtc module: Goffi <goffi@goffi.org> parents: 510 diff changeset	306 self.webrtc.bind(
644a8d165e5a plugin calls: use the new binding feature of webrtc module: Goffi <goffi@goffi.org> parents: 510 diff changeset	307 desktop_sharing=partial(setattr, self, "desktop_sharing")
644a8d165e5a plugin calls: use the new binding feature of webrtc module: Goffi <goffi@goffi.org> parents: 510 diff changeset	308 )
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	309 self.previous_fullscreen = None
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	310 self.reset_instance()
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	311
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	312 @property
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	313 def sid(self):
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	314 return self.webrtc.sid
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	315
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	316 def hang_up(self):
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	317 if self.sid is not None:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	318 aio.run_async(self.toggle_call())
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	319
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	320 async def toggle_call(self):
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	321 """Toggle between making a call and hanging up.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	322
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	323 This function will initiate or terminate a call based on the call state.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	324 """
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	325 if self.sid is None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	326 # Initiate the call
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	327 log.info("initiating call")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	328 callee = jid.JID(self.header_input.text.strip())
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	329 if not callee:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	330 return
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	331 if not callee.is_valid():
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	332 G.host.add_note(
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	333 _("Calls"),
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	334 _("Can't make a call: invalid destinee {}").format(repr(callee)),
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	335 level=C.XMLUI_DATA_LVL_ERROR
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	336 )
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	337 return
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	338
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	339 self.webrtc.callee = callee
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	340 await self.webrtc.setup_call("initiator")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	341 self.webrtc.start_pipeline()
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	342 self.in_call = True
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	343 else:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	344 # Terminate the call
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	345 sid = self.sid
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	346 await self.end_call({"reason": "terminated"}, self.profile)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	347 await G.host.a_bridge.call_end(sid, "", self.profile)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	348 self.in_call = False
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	349
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	350 async def on_incoming_call(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	351 self, action_data: dict, action_id: str, profile: str
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	352 ) -> None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	353 """Handle incoming call notifications.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	354
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	355 @param action_data: A dictionary containing data related to the incoming call
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	356 @param action_id: The ID corresponding to the incoming call action.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	357 @param profile: The profile associated with the incoming call.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	358 """
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	359 if self.sid is not None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	360 # FIXME: show a double remote call notification
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	361 log.warning("Ignoring new remote call as we are already in a call.")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	362 return
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	363 sid = action_data["session_id"]
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	364 self.in_call = True
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	365 self.webrtc.sid = sid
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	366 # FIXME: we accept all remote calls for now, will be changed when proper UI/UX
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	367 # will be implemented
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	368 log.warning("auto-accepting remote call")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	369 await G.host.a_bridge.action_launch(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	370 action_id, data_format.serialise({"cancelled": False}), profile
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	371 )
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	372
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	373 async def on_call_setup(self, setup_data: dict, profile: str) -> None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	374 """Call has been accepted, connection can be established
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	375
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	376 @param session_id: Session identifier
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	377 @param setup_data: Data with following keys:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	378 role: initiator or responser
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	379 sdp: Session Description Protocol data
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	380 @param profile: Profile associated
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	381 """
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	382 try:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	383 role = setup_data["role"]
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	384 sdp = setup_data["sdp"]
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	385 except KeyError:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	386 log.error(f"Invalid setup data received: {setup_data}")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	387 return
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	388 if role == "initiator":
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	389 self.webrtc.on_accepted_call(sdp, profile)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	390 elif role == "responder":
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	391 await self.webrtc.answer_call(sdp, profile)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	392 else:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	393 log.error(f"Invalid role received during setup: {setup_data}")
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	394
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	395 def reset_instance(self) -> None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	396 self.in_call = False
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	397 self.local_video.texture = None
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	398 self.remote_video.texture = None
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	399
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	400 async def end_call(self, data: dict, profile: str) -> None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	401 """End current call if any and reset the instance
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	402
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	403 @param data: end call data, often includes the reason of the call ending.
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	404 """
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	405 await self.webrtc.end_call()
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	406 self.reset_instance()
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	407
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	408 def on_in_call(self, instance, in_call: bool) -> None:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	409 if in_call:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	410 self.screen_manager.transition.direction = "up"
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	411 self.screen_manager.current = "call"
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	412 else:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	413 self.fullscreen = False
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	414 self.screen_manager.transition.direction = "down"
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	415 self.screen_manager.current = "search"
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	416
509 f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	417 def on_audio_muted(self, instance, muted: bool) -> None:
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	418 self.webrtc.audio_muted = muted
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	419
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	420 def on_video_muted(self, instance, muted: bool) -> None:
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	421 self.webrtc.video_muted = muted
f0ce49b360c8 calls: move webrtc code to core: Goffi <goffi@goffi.org> parents: 506 diff changeset	422
510 97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	423 def on_desktop_btn_press(self) -> None:
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	424 if self.desktop_sharing:
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	425 self.desktop_sharing = False
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	426 else:
512 644a8d165e5a plugin calls: use the new binding feature of webrtc module: Goffi <goffi@goffi.org> parents: 510 diff changeset	427 if display_servers.detect() == display_servers.X11:
644a8d165e5a plugin calls: use the new binding feature of webrtc module: Goffi <goffi@goffi.org> parents: 510 diff changeset	428 DesktopScreenDialog(self).open()
644a8d165e5a plugin calls: use the new binding feature of webrtc module: Goffi <goffi@goffi.org> parents: 510 diff changeset	429 else:
644a8d165e5a plugin calls: use the new binding feature of webrtc module: Goffi <goffi@goffi.org> parents: 510 diff changeset	430 self.desktop_sharing = True
510 97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	431
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	432 def on_desktop_sharing(self, instance, active: bool) -> None:
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	433 self.webrtc.desktop_sharing = active
97ab236e8f20 plugin calls: implement desktop sharing: Goffi <goffi@goffi.org> parents: 509 diff changeset	434
514 d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	435 def on_file_btn_press(self) -> None:
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	436 aio.run_async(self.on_file_press())
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	437
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	438 async def on_file_press(self):
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	439 callee = self.webrtc.callee
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	440 if callee is None:
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	441 return
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	442 file_to_send = await FileChooser.a_open()
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	443 if file_to_send is None:
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	444 return
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	445 file_sender = WebRTCFileSender(
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	446 G.host.a_bridge,
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	447 self.profile
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	448 )
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	449 await file_sender.send_file_webrtc(file_to_send, self.webrtc.callee)
d78728d7fd6a plugin wid calls, core: implements WebRTC DataChannel file transfer: Goffi <goffi@goffi.org> parents: 512 diff changeset	450
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	451 def on_fullscreen(self, instance, fullscreen: bool) -> None:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	452 if fullscreen:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	453 G.host.app.show_head_widget(False, animation=False)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	454 self.call_layout.parent.remove_widget(self.call_layout)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	455 G.host.show_extra_ui(self.call_layout)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	456 self.previous_fullscreen = Window.fullscreen
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	457 Window.fullscreen = "auto"
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	458 else:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	459 G.host.app.show_head_widget(True, animation=False)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	460 G.host.close_ui()
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	461 self.call_screen.add_widget(self.call_layout)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	462 Window.fullscreen = self.previous_fullscreen or False
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	463
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	464 def on_header_wid_input(self):
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	465 aio.run_async(self.toggle_call())
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	466
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	467 def on_header_wid_input_complete(self, wid, text, **kwargs):
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	468 """we filter items when text is entered in input box"""
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	469 for layout in self.jid_selector.items_layouts:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	470 self.do_filter(
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	471 layout,
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	472 text,
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	473 # we append nick to jid to filter on both
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	474 lambda c: c.jid + c.data.get('nick', ''),
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	475 width_cb=lambda c: c.base_width,
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	476 height_cb=lambda c: c.minimum_height,
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	477 continue_tests=[lambda c: not isinstance(c, common.ContactButton)])
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	478
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	479 def on_jid_select(self, contact_button):
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	480 self.header_input.text = contact_button.jid
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	481 aio.run_async(self.toggle_call())
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	482
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	483 @classmethod
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	484 def ice_candidates_new_handler(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	485 cls, sid: str, candidates_s: str, profile: str
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	486 ) -> None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	487 for wid in G.host.get_visible_list(cls):
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	488 if profile not in wid.profiles or sid != wid.sid:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	489 continue
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	490 wid.webrtc.on_ice_candidates_new(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	491 data_format.deserialise(candidates_s),
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	492 )
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	493
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	494 @classmethod
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	495 def call_setup_handler(cls, sid: str, setup_data_s: str, profile: str) -> None:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	496 for wid in G.host.get_visible_list(cls):
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	497 if profile not in wid.profiles or sid != wid.sid:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	498 continue
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	499 aio.run_async(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	500 wid.on_call_setup(data_format.deserialise(setup_data_s), profile)
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	501 )
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	502
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	503 @classmethod
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	504 def call_ended_handler(cls, sid: str, data_s: str, profile: str) -> None:
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	505 if sid in cls.incoming_call_dialog:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	506 dialog_wid = cls.incoming_call_dialog.pop(sid)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	507 G.host.del_notif_widget(dialog_wid)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	508 G.host.add_note(_("Call cancelled"), _("The call has been cancelled."))
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	509
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	510
499 f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	511 for wid in G.host.get_visible_list(cls):
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	512 if profile not in wid.profiles or sid != wid.sid:
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	513 continue
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	514 aio.run_async(wid.end_call(data_format.deserialise(data_s), profile))
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	515
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	516 @classmethod
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	517 def action_new_handler(
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	518 cls, action_data: dict, action_id: str, security_limit: int, profile: str
f387992d8e37 plugins: new "call" plugin for A/V calls: Goffi <goffi@goffi.org> parents: diff changeset	519 ) -> None:
506 0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	520 if profile in G.host.profiles:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	521 if cls.ringtone is None:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	522 cls.ringtone = SoundLoader.load(
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	523 str(Path(G.host.media_dir) / "sounds/notifications/ring_1.mp3")
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	524 )
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	525 if cls.ringtone is not None:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	526 cls.ringtone.play()
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	527 peer_jid = jid.JID(action_data["from_jid"]).bare
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	528 sid = action_data["session_id"]
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	529 notif_body = f"{peer_jid} is calling you."
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	530 notif_title = "Incoming call"
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	531 G.host.desktop_notif(notif_body, title=notif_title, duration=10)
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	532
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	533 def on_call_answer(accepted, __):
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	534 del cls.incoming_call_dialog[sid]
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	535 if cls.ringtone is not None:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	536 cls.ringtone.stop()
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	537 if accepted:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	538 wid = G.host.do_action("calls", str(peer_jid), [profile])
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	539 aio.run_async(wid.on_incoming_call(action_data, action_id, profile))
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	540 else:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	541 aio.run_async(
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	542 G.host.a_bridge.action_launch(
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	543 action_id, data_format.serialise({"cancelled": True}), profile
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	544 )
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	545 )
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	546
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	547 dialog_wid = G.host.show_dialog(
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	548 notif_body, notif_title, type="yes/no", answer_cb=on_call_answer
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	549 )
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	550 cls.incoming_call_dialog[sid] = dialog_wid
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	551
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	552
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	553 if G.host is not None:
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	554 log.debug("registering signals")
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	555 G.host.register_signal(
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	556 "ice_candidates_new",
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	557 handler=Calls.ice_candidates_new_handler,
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	558 iface="plugin",
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	559 )
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	560 G.host.register_signal("call_setup", handler=Calls.call_setup_handler, iface="plugin")
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	561 G.host.register_signal("call_ended", handler=Calls.call_ended_handler, iface="plugin")
0480f883f0a6 plugin calls: update UI: Goffi <goffi@goffi.org> parents: 499 diff changeset	562 G.host.register_action_handler(C.META_TYPE_CALL, Calls.action_new_handler)

Mercurial > libervia-desktop-kivy

annotate libervia/desktop_kivy/plugins/plugin_wid_calls.py @ 517:f316c7f19909