From e5a296deef2458ddc8d09054808038f249c50dea Mon Sep 17 00:00:00 2001 From: Philipp Spitzer Date: Thu, 9 Jul 2020 22:17:33 +0200 Subject: [PATCH] Exit when room closed. --- lagarde.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/lagarde.py b/lagarde.py index 28cff73..487b88c 100755 --- a/lagarde.py +++ b/lagarde.py @@ -183,22 +183,24 @@ class Lagarde: msg_json = json.loads(msg) msg_type = msg_json['Type'] msg_value = msg_json['Value'] - self.session_id = msg_json['SessionID'] log.info(f"receive for session {self.session_id} type {msg_type}") if msg_type == 'newSession': - pass + self.session_id = msg_json['SessionID'] elif msg_type == 'gotOffer': + assert self.session_id == msg_json['SessionID'] value_json = json.loads(msg_value) sdp = value_json['sdp'] log.info(f'SDP: {sdp}') self.sdp_offer = sdp elif msg_type == 'addCallerIceCandidate': + assert self.session_id == msg_json['SessionID'] value_json = json.loads(msg_value) log.info(f'ICE: {value_json}') self.received_ice_candidates.append(value_json) elif msg_type == 'roomClosed': log.info('Oh noes, the room went away!') - # and here we should clean up + self.session_id = None + return else: log.error(f'Unknown message type {msg_type}') -- 2.39.5