-
Notifications
You must be signed in to change notification settings - Fork 11
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
15 changed files
with
535 additions
and
575 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
306 changes: 153 additions & 153 deletions
306
commet/lib/client/matrix/components/voip/matrix_voip_component.dart
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,153 +1,153 @@ | ||
| // ignore_for_file: depend_on_referenced_packages, implementation_imports | ||
|
|
||
| import 'dart:async'; | ||
|
|
||
| import 'package:commet/client/components/component.dart'; | ||
| import 'package:commet/client/components/voip/voip_component.dart'; | ||
| import 'package:commet/client/components/voip/voip_session.dart'; | ||
| import 'package:commet/client/matrix/components/voip/matrix_voip_session.dart'; | ||
| import 'package:commet/client/matrix/matrix_client.dart'; | ||
| import 'package:commet/client/matrix/matrix_timeline_event.dart'; | ||
| import 'package:commet/client/timeline.dart'; | ||
| import 'package:commet/config/platform_utils.dart'; | ||
| import 'package:commet/ui/atoms/generic_room_event.dart'; | ||
| import 'package:flutter/material.dart'; | ||
| import 'package:matrix/matrix.dart' as mx; | ||
| import 'package:webrtc_interface/src/mediadevices.dart'; | ||
| import 'package:webrtc_interface/src/rtc_peerconnection.dart'; | ||
| import 'package:webrtc_interface/src/rtc_video_renderer.dart'; | ||
| import 'package:flutter_webrtc/flutter_webrtc.dart' as webrtc; | ||
|
|
||
| class MatrixVoipComponent | ||
| implements | ||
| VoipComponent<MatrixClient>, | ||
| EventHandlerComponent, | ||
| mx.WebRTCDelegate { | ||
| late mx.VoIP voip; | ||
|
|
||
| @override | ||
| MatrixClient client; | ||
|
|
||
| final StreamController<VoipSession> _onSessionStarted = StreamController(); | ||
| @override | ||
| Stream<VoipSession> get onSessionStarted => _onSessionStarted.stream; | ||
|
|
||
| final StreamController<VoipSession> _onSessionEnded = StreamController(); | ||
| @override | ||
| Stream<VoipSession> get onSessionEnded => _onSessionEnded.stream; | ||
|
|
||
| @override | ||
| bool get canHandleNewCall => true; | ||
|
|
||
| @override | ||
| bool get isWeb => PlatformUtils.isWeb; | ||
|
|
||
| @override | ||
| MediaDevices get mediaDevices => webrtc.navigator.mediaDevices; | ||
|
|
||
| MatrixVoipComponent(this.client) { | ||
| voip = mx.VoIP(client.getMatrixClient(), this); | ||
| } | ||
|
|
||
| @override | ||
| List<VoipSession> getSessionsInRoom(String roomId) { | ||
| return voip.calls.values | ||
| .where((element) => element.room.id == roomId) | ||
| .map((e) => MatrixVoipSession(e, client)) | ||
| .toList(); | ||
| } | ||
|
|
||
| @override | ||
| bool canHandleEvent(TimelineEvent event) { | ||
| if (event is! MatrixTimelineEvent) { | ||
| return false; | ||
| } | ||
|
|
||
| return [ | ||
| mx.EventTypes.CallHangup, | ||
| mx.EventTypes.CallAnswer, | ||
| mx.EventTypes.CallInvite, | ||
| mx.EventTypes.CallReject | ||
| ].contains(event.event.type); | ||
| } | ||
|
|
||
| @override | ||
| Widget? displayTimelineEvent(TimelineEvent event, | ||
| {required String senderName}) { | ||
| if (event is! MatrixTimelineEvent) { | ||
| return null; | ||
| } | ||
|
|
||
| switch (event.event.type) { | ||
| case mx.EventTypes.CallHangup: | ||
| return GenericRoomEvent( | ||
| "$senderName left the call", | ||
| icon: Icons.call_end, | ||
| ); | ||
| case mx.EventTypes.CallReject: | ||
| return GenericRoomEvent( | ||
| "$senderName rejected the call", | ||
| icon: Icons.call_end, | ||
| ); | ||
| case mx.EventTypes.CallInvite: | ||
| return GenericRoomEvent( | ||
| "$senderName started a call", | ||
| icon: Icons.call_end, | ||
| ); | ||
| case mx.EventTypes.CallAnswer: | ||
| return GenericRoomEvent( | ||
| "$senderName answered the call", | ||
| icon: Icons.call, | ||
| ); | ||
| } | ||
|
|
||
| return Text(event.event.type); | ||
| } | ||
|
|
||
| @override | ||
| Future<RTCPeerConnection> createPeerConnection( | ||
| Map<String, dynamic> configuration, | ||
| [Map<String, dynamic> constraints = const {}]) { | ||
| return webrtc.createPeerConnection(configuration, constraints); | ||
| } | ||
|
|
||
| @override | ||
| VideoRenderer createRenderer() { | ||
| return webrtc.RTCVideoRenderer(); | ||
| } | ||
|
|
||
| @override | ||
| Future<void> handleCallEnded(mx.CallSession session) async { | ||
| _onSessionEnded.add(MatrixVoipSession(session, client)); | ||
| } | ||
|
|
||
| @override | ||
| Future<void> handleGroupCallEnded(mx.GroupCall groupCall) async {} | ||
|
|
||
| @override | ||
| Future<void> handleMissedCall(mx.CallSession session) async {} | ||
|
|
||
| @override | ||
| Future<void> handleNewCall(mx.CallSession session) async { | ||
| _onSessionStarted.add(MatrixVoipSession(session, client)); | ||
| } | ||
|
|
||
| @override | ||
| Future<void> handleNewGroupCall(mx.GroupCall groupCall) async {} | ||
|
|
||
| @override | ||
| Future<void> playRingtone() async {} | ||
|
|
||
| @override | ||
| Future<void> stopRingtone() async {} | ||
|
|
||
| @override | ||
| Future<void> startCall(String roomId, CallType type) { | ||
| var callType = switch (type) { | ||
| CallType.voice => mx.CallType.kVoice, | ||
| CallType.video => mx.CallType.kVideo | ||
| }; | ||
|
|
||
| return voip.inviteToCall(roomId, callType); | ||
| } | ||
| } | ||
| // // ignore_for_file: depend_on_referenced_packages, implementation_imports | ||
|
|
||
| // import 'dart:async'; | ||
|
|
||
| // import 'package:commet/client/components/component.dart'; | ||
| // import 'package:commet/client/components/voip/voip_component.dart'; | ||
| // import 'package:commet/client/components/voip/voip_session.dart'; | ||
| // import 'package:commet/client/matrix/components/voip/matrix_voip_session.dart'; | ||
| // import 'package:commet/client/matrix/matrix_client.dart'; | ||
| // import 'package:commet/client/matrix/matrix_timeline_event.dart'; | ||
| // import 'package:commet/client/timeline.dart'; | ||
| // import 'package:commet/config/platform_utils.dart'; | ||
| // import 'package:commet/ui/atoms/generic_room_event.dart'; | ||
| // import 'package:flutter/material.dart'; | ||
| // import 'package:matrix/matrix.dart' as mx; | ||
| // import 'package:webrtc_interface/src/mediadevices.dart'; | ||
| // import 'package:webrtc_interface/src/rtc_peerconnection.dart'; | ||
| // import 'package:webrtc_interface/src/rtc_video_renderer.dart'; | ||
| // import 'package:flutter_webrtc/flutter_webrtc.dart' as webrtc; | ||
|
|
||
| // class MatrixVoipComponent | ||
| // implements | ||
| // VoipComponent<MatrixClient>, | ||
| // EventHandlerComponent, | ||
| // mx.WebRTCDelegate { | ||
| // late mx.VoIP voip; | ||
|
|
||
| // @override | ||
| // MatrixClient client; | ||
|
|
||
| // final StreamController<VoipSession> _onSessionStarted = StreamController(); | ||
| // @override | ||
| // Stream<VoipSession> get onSessionStarted => _onSessionStarted.stream; | ||
|
|
||
| // final StreamController<VoipSession> _onSessionEnded = StreamController(); | ||
| // @override | ||
| // Stream<VoipSession> get onSessionEnded => _onSessionEnded.stream; | ||
|
|
||
| // @override | ||
| // bool get canHandleNewCall => true; | ||
|
|
||
| // @override | ||
| // bool get isWeb => PlatformUtils.isWeb; | ||
|
|
||
| // @override | ||
| // MediaDevices get mediaDevices => webrtc.navigator.mediaDevices; | ||
|
|
||
| // MatrixVoipComponent(this.client) { | ||
| // voip = mx.VoIP(client.getMatrixClient(), this); | ||
| // } | ||
|
|
||
| // @override | ||
| // List<VoipSession> getSessionsInRoom(String roomId) { | ||
| // return voip.calls.values | ||
| // .where((element) => element.room.id == roomId) | ||
| // .map((e) => MatrixVoipSession(e, client)) | ||
| // .toList(); | ||
| // } | ||
|
|
||
| // @override | ||
| // bool canHandleEvent(TimelineEvent event) { | ||
| // if (event is! MatrixTimelineEvent) { | ||
| // return false; | ||
| // } | ||
|
|
||
| // return [ | ||
| // mx.EventTypes.CallHangup, | ||
| // mx.EventTypes.CallAnswer, | ||
| // mx.EventTypes.CallInvite, | ||
| // mx.EventTypes.CallReject | ||
| // ].contains(event.event.type); | ||
| // } | ||
|
|
||
| // @override | ||
| // Widget? displayTimelineEvent(TimelineEvent event, | ||
| // {required String senderName}) { | ||
| // if (event is! MatrixTimelineEvent) { | ||
| // return null; | ||
| // } | ||
|
|
||
| // switch (event.event.type) { | ||
| // case mx.EventTypes.CallHangup: | ||
| // return GenericRoomEvent( | ||
| // "$senderName left the call", | ||
| // icon: Icons.call_end, | ||
| // ); | ||
| // case mx.EventTypes.CallReject: | ||
| // return GenericRoomEvent( | ||
| // "$senderName rejected the call", | ||
| // icon: Icons.call_end, | ||
| // ); | ||
| // case mx.EventTypes.CallInvite: | ||
| // return GenericRoomEvent( | ||
| // "$senderName started a call", | ||
| // icon: Icons.call_end, | ||
| // ); | ||
| // case mx.EventTypes.CallAnswer: | ||
| // return GenericRoomEvent( | ||
| // "$senderName answered the call", | ||
| // icon: Icons.call, | ||
| // ); | ||
| // } | ||
|
|
||
| // return Text(event.event.type); | ||
| // } | ||
|
|
||
| // @override | ||
| // Future<RTCPeerConnection> createPeerConnection( | ||
| // Map<String, dynamic> configuration, | ||
| // [Map<String, dynamic> constraints = const {}]) { | ||
| // return webrtc.createPeerConnection(configuration, constraints); | ||
| // } | ||
|
|
||
| // @override | ||
| // VideoRenderer createRenderer() { | ||
| // return webrtc.RTCVideoRenderer(); | ||
| // } | ||
|
|
||
| // @override | ||
| // Future<void> handleCallEnded(mx.CallSession session) async { | ||
| // _onSessionEnded.add(MatrixVoipSession(session, client)); | ||
| // } | ||
|
|
||
| // @override | ||
| // Future<void> handleGroupCallEnded(mx.GroupCall groupCall) async {} | ||
|
|
||
| // @override | ||
| // Future<void> handleMissedCall(mx.CallSession session) async {} | ||
|
|
||
| // @override | ||
| // Future<void> handleNewCall(mx.CallSession session) async { | ||
| // _onSessionStarted.add(MatrixVoipSession(session, client)); | ||
| // } | ||
|
|
||
| // @override | ||
| // Future<void> handleNewGroupCall(mx.GroupCall groupCall) async {} | ||
|
|
||
| // @override | ||
| // Future<void> playRingtone() async {} | ||
|
|
||
| // @override | ||
| // Future<void> stopRingtone() async {} | ||
|
|
||
| // @override | ||
| // Future<void> startCall(String roomId, CallType type) { | ||
| // var callType = switch (type) { | ||
| // CallType.voice => mx.CallType.kVoice, | ||
| // CallType.video => mx.CallType.kVideo | ||
| // }; | ||
|
|
||
| // return voip.inviteToCall(roomId, callType); | ||
| // } | ||
| // } |
Oops, something went wrong.