Comunic/comunicmobile
1
0
Fork 0
mirror of https://gitlab.com/comunic/comunicmobile synced 2024-11-26 14:59:22 +00:00
Code Issues Projects Releases Wiki Activity

Notify when we stop streaming

Browse Source
This commit is contained in:
Pierre HUBERT 2020-04-22 18:35:19 +02:00
parent b9a329c8f0
commit 565f351d1e
2 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
lib/helpers/calls_helper.dart
View File

@ -66,4 +66,15 @@ class CallsHelper {
/// Mark ourselves as ready to stream to other peers /// Mark ourselves as ready to stream to other peers
static Future<void> markPeerReady(int callID) async => static Future<void> markPeerReady(int callID) async =>
await ws("calls/mark_ready", {"callID": callID}); await ws("calls/mark_ready", {"callID": callID});
/// Notify other peers that we stopped streaming
///
/// This method never throw
static Future<void> notifyStoppedStreaming(int callID) async {
try {
await ws("calls/stop_streaming", {"callID": callID});
} catch (e, stack) {
print("$e\n$stack");
}
}
} }

6
lib/ui/screens/call_screen.dart
View File

@ -226,7 +226,7 @@ class _CallScreenState extends SafeState<CallScreen> {
final offer = await peerConnection.createOffer({ final offer = await peerConnection.createOffer({
"mandatory": { "mandatory": {
"OfferToReceiveAudio": true, "OfferToReceiveAudio": true,
"OfferToReceiveVideo": true, "OfferToReceiveVideo": includeVideo,
}, },
"optional": [], "optional": [],
}); });
@ -245,6 +245,8 @@ class _CallScreenState extends SafeState<CallScreen> {
if (_peersConnections.containsKey(userID())) { if (_peersConnections.containsKey(userID())) {
_peersConnections[userID()].close(); _peersConnections[userID()].close();
_peersConnections.remove(userID()); _peersConnections.remove(userID());
await CallsHelper.notifyStoppedStreaming(convID);
} }
// Stop local stream // Stop local stream
@ -313,6 +315,8 @@ class _CallScreenState extends SafeState<CallScreen> {
// Request an offer to establish a peer connection // Request an offer to establish a peer connection
await CallsHelper.requestOffer(convID, memberID); await CallsHelper.requestOffer(convID, memberID);
setState(() {});
} catch (e, stack) { } catch (e, stack) {
print("Could not connect to remote peer $e\n$stack!"); print("Could not connect to remote peer $e\n$stack!");
showSimpleSnack(context, tr("Could not connect to a remote peer!")); showSimpleSnack(context, tr("Could not connect to a remote peer!"));