[IMP] discuss: wip recording

see: odoo/sfu#27

task-3725174

Author: ThanhDodeurOdoo

addons/mail/controllers/discuss/rtc.py

@@ -145,3 +145,10 @@ def channel_ping(self, channel_id, rtc_session_id=None, check_rtc_session_ids=No
             fields_params={"added": rtc_updates[0], "removed": rtc_updates[1]},
         )
         return store.get_result()
+
+    @http.route("/mail/rtc/recording/routing/<channel_id>", methods=["POST"], type="jsonrpc", auth="public")
+    def route_recording(self, channel_id, recording: bool, transcription: bool):
+        # TODO: check auth JWT
+        # if transcription: provide callback upload address, expected format,...
+        # if recording: get cloud bucket, provide upload address
+        return

addons/mail/models/discuss/discuss_channel_member.py

@@ -442,10 +442,13 @@ def _rtc_join_call(self, store: Store = None, check_rtc_session_ids=None, camera
                 "_store_rtc_update_fields",
                 fields_params={"added": rtc_updates[0], "removed": rtc_updates[1]},
             )
+            has_sfu = bool(discuss.get_sfu_url(self.env))
             store.add_singleton_values(
                 "Rtc",
                 lambda res: (
                     res.attr("iceServers", ice_servers or False),
+                    res.attr("canRecord", has_sfu),
+                    res.attr("canTranscribe", has_sfu),
                     res.one("localSession", "_store_rtc_session_fields", value=rtc_session),
                     res.attr("serverInfo", self._get_rtc_server_info(rtc_session, ice_servers)),
                 ),
@@ -454,7 +457,10 @@ def _rtc_join_call(self, store: Store = None, check_rtc_session_ids=None, camera
             self._rtc_invite_members()
 
     def _join_sfu(self, ice_servers=None, force=False):
-        if len(self.channel_id.rtc_session_ids) < SFU_MODE_THRESHOLD and not force:
+        session_count = len(self.channel_id.rtc_session_ids)
+        if session_count < 2:
+            return # cant join a SFU when alone
+        if session_count < SFU_MODE_THRESHOLD and not force:
             if self.channel_id.sfu_channel_uuid:
                 self.channel_id.sfu_channel_uuid = None
                 self.channel_id.sfu_server_url = None
@@ -475,9 +481,13 @@ def _join_sfu(self, ice_servers=None, force=False):
             algorithm=jwt.Algorithm.HS256,
         )
         try:
+            recording_address = (
+                f"{self.get_base_url()}/mail/rtc/recording/routing/{self.channel_id.id}"
+            )
             response = requests.get(
                 sfu_server_url + "/v1/channel",
                 headers={"Authorization": "jwt " + json_web_token},
+                params={"recordingAddress": recording_address},
                 timeout=3,
             )
             response.raise_for_status()
@@ -500,9 +510,11 @@ def _get_rtc_server_info(self, rtc_session, ice_servers=None, key=None):
             return None
         if not key:
             key = self.env["ir.config_parameter"].sudo().get_str("mail.sfu_local_key")
+        is_partner = bool(rtc_session.partner_id)
         claims = {
             "session_id": rtc_session.id,
             "ice_servers": ice_servers,
+            "permissions": {"recording": is_partner, "transcription": is_partner}
         }
         json_web_token = jwt.sign(claims, key=key, ttl=60 * 60 * 8, algorithm=jwt.Algorithm.HS256)  # 8 hours
         return {"url": sfu_server_url, "channelUUID": sfu_channel_uuid, "jsonWebToken": json_web_token}