Changes into Rating Bar
parent
8bdcfcb764
commit
b4bc99369f
@ -1,82 +1,82 @@
|
||||
import 'dart:async';
|
||||
import 'dart:core';
|
||||
|
||||
import 'package:diplomaticquarterapp/pages/conference/widgets/noise_box.dart';
|
||||
import 'package:flutter/material.dart';
|
||||
import 'package:flutter_webrtc/flutter_webrtc.dart';
|
||||
|
||||
import 'draggable_cam.dart';
|
||||
|
||||
class CamViewWidget extends StatefulWidget {
|
||||
RTCVideoRenderer? localRenderer;
|
||||
RTCVideoRenderer? remoteRenderer;
|
||||
MediaStream? localStream;
|
||||
BoxConstraints? constraints;
|
||||
StreamController<bool>? onButtonBarVisibleStreamController;
|
||||
StreamController<double>? onButtonBarHeightStreamController;
|
||||
|
||||
CamViewWidget({this.localRenderer, this.remoteRenderer, this.constraints, this.onButtonBarVisibleStreamController, this.onButtonBarHeightStreamController});
|
||||
|
||||
@override
|
||||
_CamViewWidgetState createState() => _CamViewWidgetState();
|
||||
}
|
||||
|
||||
class _CamViewWidgetState extends State<CamViewWidget> {
|
||||
@override
|
||||
void initState() {
|
||||
super.initState();
|
||||
}
|
||||
|
||||
@override
|
||||
Widget build(BuildContext context) {
|
||||
return Container(
|
||||
width: double.infinity,
|
||||
height: double.infinity,
|
||||
child: Stack(
|
||||
children: [
|
||||
FractionallySizedBox(
|
||||
heightFactor: 1, widthFactor: 1,
|
||||
child: Container(
|
||||
color: Colors.black87,
|
||||
child: RTCVideoView(widget.remoteRenderer!, mirror: true,filterQuality: FilterQuality.medium,),
|
||||
),
|
||||
),
|
||||
|
||||
if(widget.remoteRenderer!.srcObject == null)
|
||||
Positioned.fill(child: _buildNoiseBox()),
|
||||
|
||||
Positioned.fill(
|
||||
child: RTCVideoView(widget.remoteRenderer!)
|
||||
),
|
||||
|
||||
DraggableCam(
|
||||
key: Key('publisher'),
|
||||
onButtonBarHeight: widget.onButtonBarHeightStreamController!.stream,
|
||||
onButtonBarVisible: widget.onButtonBarVisibleStreamController!.stream,
|
||||
availableScreenSize: widget.constraints!.biggest,
|
||||
child: RTCVideoView(widget.localRenderer!)
|
||||
),
|
||||
|
||||
if(widget.remoteRenderer!.srcObject == null)
|
||||
Container(
|
||||
margin: EdgeInsets.all(MediaQuery.of(context).size.width/8),
|
||||
child: Text(
|
||||
'Waiting for another participant to connect to the call...',
|
||||
key: Key('text-wait'),
|
||||
textAlign: TextAlign.center,
|
||||
style: TextStyle(color: Colors.white),
|
||||
)
|
||||
),
|
||||
],
|
||||
),
|
||||
);
|
||||
}
|
||||
|
||||
|
||||
Widget _buildNoiseBox() {
|
||||
return NoiseBox(
|
||||
density: NoiseBoxDensity.xHigh,
|
||||
backgroundColor: Colors.grey.shade900,
|
||||
);
|
||||
}
|
||||
}
|
||||
// import 'dart:async';
|
||||
// import 'dart:core';
|
||||
//
|
||||
// import 'package:diplomaticquarterapp/pages/conference/widgets/noise_box.dart';
|
||||
// import 'package:flutter/material.dart';
|
||||
// import 'package:flutter_webrtc/flutter_webrtc.dart';
|
||||
//
|
||||
// import 'draggable_cam.dart';
|
||||
//
|
||||
// class CamViewWidget extends StatefulWidget {
|
||||
// RTCVideoRenderer? localRenderer;
|
||||
// RTCVideoRenderer? remoteRenderer;
|
||||
// MediaStream? localStream;
|
||||
// BoxConstraints? constraints;
|
||||
// StreamController<bool>? onButtonBarVisibleStreamController;
|
||||
// StreamController<double>? onButtonBarHeightStreamController;
|
||||
//
|
||||
// CamViewWidget({this.localRenderer, this.remoteRenderer, this.constraints, this.onButtonBarVisibleStreamController, this.onButtonBarHeightStreamController});
|
||||
//
|
||||
// @override
|
||||
// _CamViewWidgetState createState() => _CamViewWidgetState();
|
||||
// }
|
||||
//
|
||||
// class _CamViewWidgetState extends State<CamViewWidget> {
|
||||
// @override
|
||||
// void initState() {
|
||||
// super.initState();
|
||||
// }
|
||||
//
|
||||
// @override
|
||||
// Widget build(BuildContext context) {
|
||||
// return Container(
|
||||
// width: double.infinity,
|
||||
// height: double.infinity,
|
||||
// child: Stack(
|
||||
// children: [
|
||||
// FractionallySizedBox(
|
||||
// heightFactor: 1, widthFactor: 1,
|
||||
// child: Container(
|
||||
// color: Colors.black87,
|
||||
// // child: RTCVideoView(widget.remoteRenderer!, mirror: true,filterQuality: FilterQuality.medium,),
|
||||
// ),
|
||||
// ),
|
||||
//
|
||||
// if(widget.remoteRenderer!.srcObject == null)
|
||||
// Positioned.fill(child: _buildNoiseBox()),
|
||||
//
|
||||
// // Positioned.fill(
|
||||
// // child: RTCVideoView(widget.remoteRenderer!)
|
||||
// // ),
|
||||
//
|
||||
// // DraggableCam(
|
||||
// // key: Key('publisher'),
|
||||
// // onButtonBarHeight: widget.onButtonBarHeightStreamController!.stream,
|
||||
// // onButtonBarVisible: widget.onButtonBarVisibleStreamController!.stream,
|
||||
// // availableScreenSize: widget.constraints!.biggest,
|
||||
// // child: RTCVideoView(widget.localRenderer!)
|
||||
// // ),
|
||||
//
|
||||
// if(widget.remoteRenderer!.srcObject == null)
|
||||
// Container(
|
||||
// margin: EdgeInsets.all(MediaQuery.of(context).size.width/8),
|
||||
// child: Text(
|
||||
// 'Waiting for another participant to connect to the call...',
|
||||
// key: Key('text-wait'),
|
||||
// textAlign: TextAlign.center,
|
||||
// style: TextStyle(color: Colors.white),
|
||||
// )
|
||||
// ),
|
||||
// ],
|
||||
// ),
|
||||
// );
|
||||
// }
|
||||
//
|
||||
//
|
||||
// Widget _buildNoiseBox() {
|
||||
// return NoiseBox(
|
||||
// density: NoiseBoxDensity.xHigh,
|
||||
// backgroundColor: Colors.grey.shade900,
|
||||
// );
|
||||
// }
|
||||
// }
|
||||
|
||||
File diff suppressed because it is too large
Load Diff
@ -1,241 +1,241 @@
|
||||
import 'dart:async';
|
||||
|
||||
import 'package:diplomaticquarterapp/pages/conference/conference_button_bar.dart';
|
||||
import 'package:diplomaticquarterapp/pages/conference/web_rtc/widgets/cam_view_widget.dart';
|
||||
import 'package:diplomaticquarterapp/pages/videocall-webrtc-rnd/utils/device_info.dart';
|
||||
import 'package:firebase_messaging/firebase_messaging.dart';
|
||||
import 'package:flutter/material.dart';
|
||||
import 'package:flutter/services.dart';
|
||||
import 'dart:core';
|
||||
import 'signaling.dart';
|
||||
import 'package:flutter_webrtc/flutter_webrtc.dart';
|
||||
|
||||
class StartVideoCall extends StatefulWidget {
|
||||
static String tag = 'webrtc';
|
||||
final String host;
|
||||
|
||||
String caller;
|
||||
String receiver;
|
||||
bool iAmCaller;
|
||||
StartVideoCall({required this.caller, required this.receiver, this.iAmCaller = false, required this.host});
|
||||
|
||||
@override
|
||||
StartVideoCallState createState() => StartVideoCallState(receiverId: receiver, callerId: caller, iAmCaller: iAmCaller);
|
||||
}
|
||||
|
||||
class StartVideoCallState extends State<StartVideoCall> {
|
||||
late Signaling _signaling;
|
||||
late SessionOneToOne? _session;
|
||||
|
||||
StartVideoCallState({required String callerId, required String receiverId, required bool iAmCaller}){
|
||||
|
||||
final self_role = iAmCaller ? "Caller" : "Receiver";
|
||||
final self_id = iAmCaller ? callerId : receiverId;
|
||||
final self_user = SocketUser(id: self_id, name: "$self_role-$self_id", userAgent: DeviceInfo.userAgent, moreInfo: {});
|
||||
|
||||
final remote_role = !iAmCaller ? "Caller" : "Receiver";
|
||||
final remote_id = !iAmCaller ? callerId : receiverId;
|
||||
final remote_user = SocketUser(id: remote_id, name: "$remote_role-$remote_id", userAgent: DeviceInfo.userAgent, moreInfo: {});
|
||||
|
||||
final session_id = "$callerId-$receiverId";
|
||||
_session = SessionOneToOne(id: session_id, local_user: self_user, remote_user: remote_user);
|
||||
}
|
||||
|
||||
bool showNoise = true;
|
||||
final StreamController<bool> _audioButton = StreamController<bool>.broadcast();
|
||||
final StreamController<bool> _videoButton = StreamController<bool>.broadcast();
|
||||
final StreamController<bool> _onButtonBarVisibleStreamController = StreamController<bool>.broadcast();
|
||||
final StreamController<double> _onButtonBarHeightStreamController = StreamController<double>.broadcast();
|
||||
|
||||
final RTCVideoRenderer _localRenderer = RTCVideoRenderer();
|
||||
final RTCVideoRenderer _remoteRenderer = RTCVideoRenderer();
|
||||
|
||||
MediaStream get localMediaStream => _signaling.localStream!;
|
||||
MediaStream get remoteMediaStream => _signaling.remoteStreams.first;
|
||||
|
||||
@override
|
||||
initState() {
|
||||
super.initState();
|
||||
initRenderers();
|
||||
_connect();
|
||||
}
|
||||
|
||||
initRenderers() async {
|
||||
await _localRenderer.initialize();
|
||||
await _remoteRenderer.initialize();
|
||||
}
|
||||
|
||||
@override
|
||||
deactivate() {
|
||||
super.deactivate();
|
||||
_signaling?.close();
|
||||
_localRenderer.dispose();
|
||||
_remoteRenderer.dispose();
|
||||
}
|
||||
|
||||
@override
|
||||
Widget build(BuildContext context) {
|
||||
return Scaffold(
|
||||
// appBar: AppBar(
|
||||
// title: Text('P2P Call Sample' + (_session?.local_user != null ? ' [Your ID (${_session?.local_user?.id})] ' : '')),
|
||||
// actions: <Widget>[
|
||||
// IconButton(
|
||||
// icon: const Icon(Icons.settings),
|
||||
// onPressed: (){
|
||||
// setState(() {
|
||||
// });
|
||||
// },
|
||||
// tooltip: 'setup',
|
||||
// ),
|
||||
// ],
|
||||
// ),
|
||||
body: videoCanvasWidgets(),
|
||||
);
|
||||
}
|
||||
|
||||
LayoutBuilder videoCanvasWidgets() {
|
||||
return LayoutBuilder(
|
||||
builder: (BuildContext context, BoxConstraints constraints) {
|
||||
return Stack(
|
||||
children: [
|
||||
CamViewWidget(
|
||||
localRenderer: _localRenderer,
|
||||
remoteRenderer: _remoteRenderer,
|
||||
constraints: constraints,
|
||||
onButtonBarVisibleStreamController: _onButtonBarVisibleStreamController,
|
||||
onButtonBarHeightStreamController: _onButtonBarHeightStreamController,
|
||||
),
|
||||
ConferenceButtonBar(
|
||||
audioEnabled: _audioButton.stream,
|
||||
videoEnabled: _videoButton.stream,
|
||||
onAudioEnabled: _onAudioEnable,
|
||||
onVideoEnabled: _onVideoEnabled,
|
||||
onSwitchCamera: _onSwitchCamera,
|
||||
onHangup: _onHangup,
|
||||
onPersonAdd: () {},
|
||||
onPersonRemove: () {},
|
||||
onHeight: _onHeightBar,
|
||||
onShow: _onShowBar,
|
||||
onHide: _onHideBar,
|
||||
),
|
||||
],
|
||||
);
|
||||
},
|
||||
);
|
||||
}
|
||||
|
||||
|
||||
void _connect() async {
|
||||
if(_session == null)
|
||||
return;
|
||||
|
||||
_signaling ??= Signaling(widget.host, session: _session!)..connect();
|
||||
|
||||
_signaling?.onSignalingStateChange = (SignalingState state) {
|
||||
switch (state) {
|
||||
case SignalingState.Closed:
|
||||
case SignalingState.Error:
|
||||
case SignalingState.Open:
|
||||
break;
|
||||
}
|
||||
};
|
||||
|
||||
_signaling?.onCallStateChange = (SessionOneToOne session, CallState state) {
|
||||
switch (state) {
|
||||
case CallState.Calling:
|
||||
setState(() {});
|
||||
break;
|
||||
case CallState.Bye:
|
||||
setState(() {
|
||||
_localRenderer.srcObject = null;
|
||||
_remoteRenderer.srcObject = null;
|
||||
_session = null;
|
||||
});
|
||||
break;
|
||||
case CallState.Invite:
|
||||
case CallState.Connected:
|
||||
case CallState.Ringing:
|
||||
}
|
||||
};
|
||||
|
||||
_signaling?.onConnected = ((event) {
|
||||
_signaling?.callAccepted(_session!);
|
||||
});
|
||||
|
||||
_signaling?.onRemoteConnected = ((event) {
|
||||
|
||||
});
|
||||
|
||||
_signaling?.onLocalStream = ((stream) {
|
||||
_localRenderer.srcObject = stream;
|
||||
setState(() {
|
||||
});
|
||||
});
|
||||
|
||||
_signaling?.onAddRemoteStream = ((_, stream) {
|
||||
_remoteRenderer.srcObject = stream;
|
||||
setState(() {});
|
||||
});
|
||||
|
||||
_signaling?.onRemoveRemoteStream = ((_, stream) {
|
||||
setState(() {
|
||||
_remoteRenderer.srcObject = null;
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
_hangUp() async{
|
||||
if (_session != null) {
|
||||
_signaling?.bye(_session!);
|
||||
}
|
||||
}
|
||||
|
||||
_switchCamera() {
|
||||
_signaling?.switchCamera();
|
||||
}
|
||||
|
||||
_muteMic() {
|
||||
_signaling?.muteMic();
|
||||
}
|
||||
|
||||
Function? _onAudioEnable() {
|
||||
final audioTrack = localMediaStream.getAudioTracks()[0];
|
||||
final mute = audioTrack.muted;
|
||||
Helper.setMicrophoneMute(!mute!, audioTrack);
|
||||
_audioButton.add(mute);
|
||||
}
|
||||
|
||||
Function? _onVideoEnabled() {
|
||||
final videoTrack = localMediaStream.getVideoTracks()[0];
|
||||
bool videoEnabled = videoTrack.enabled;
|
||||
localMediaStream.getVideoTracks()[0].enabled = !videoEnabled;
|
||||
_videoButton.add(!videoEnabled);
|
||||
}
|
||||
|
||||
Function? _onSwitchCamera() {
|
||||
Helper.switchCamera(localMediaStream.getVideoTracks()[0]);
|
||||
}
|
||||
|
||||
void _onShowBar() {
|
||||
setState(() {
|
||||
});
|
||||
_onButtonBarVisibleStreamController.add(true);
|
||||
}
|
||||
|
||||
void _onHeightBar(double height) {
|
||||
_onButtonBarHeightStreamController.add(height);
|
||||
}
|
||||
|
||||
void _onHideBar() {
|
||||
setState(() {
|
||||
SystemChrome.setEnabledSystemUIMode(SystemUiMode.manual, overlays: [SystemUiOverlay.bottom]);
|
||||
});
|
||||
_onButtonBarVisibleStreamController.add(false);
|
||||
}
|
||||
|
||||
Future<void> _onHangup() async {
|
||||
_signaling?.finishSessions();
|
||||
print('onHangup');
|
||||
Navigator.of(context).pop();
|
||||
}
|
||||
}
|
||||
// import 'dart:async';
|
||||
//
|
||||
// import 'package:diplomaticquarterapp/pages/conference/conference_button_bar.dart';
|
||||
// import 'package:diplomaticquarterapp/pages/conference/web_rtc/widgets/cam_view_widget.dart';
|
||||
// import 'package:diplomaticquarterapp/pages/videocall-webrtc-rnd/utils/device_info.dart';
|
||||
// import 'package:firebase_messaging/firebase_messaging.dart';
|
||||
// import 'package:flutter/material.dart';
|
||||
// import 'package:flutter/services.dart';
|
||||
// import 'dart:core';
|
||||
// import 'signaling.dart';
|
||||
// import 'package:flutter_webrtc/flutter_webrtc.dart';
|
||||
//
|
||||
// class StartVideoCall extends StatefulWidget {
|
||||
// static String tag = 'webrtc';
|
||||
// final String host;
|
||||
//
|
||||
// String caller;
|
||||
// String receiver;
|
||||
// bool iAmCaller;
|
||||
// StartVideoCall({required this.caller, required this.receiver, this.iAmCaller = false, required this.host});
|
||||
//
|
||||
// @override
|
||||
// StartVideoCallState createState() => StartVideoCallState(receiverId: receiver, callerId: caller, iAmCaller: iAmCaller);
|
||||
// }
|
||||
//
|
||||
// class StartVideoCallState extends State<StartVideoCall> {
|
||||
// late Signaling _signaling;
|
||||
// late SessionOneToOne? _session;
|
||||
//
|
||||
// StartVideoCallState({required String callerId, required String receiverId, required bool iAmCaller}){
|
||||
//
|
||||
// final self_role = iAmCaller ? "Caller" : "Receiver";
|
||||
// final self_id = iAmCaller ? callerId : receiverId;
|
||||
// final self_user = SocketUser(id: self_id, name: "$self_role-$self_id", userAgent: DeviceInfo.userAgent, moreInfo: {});
|
||||
//
|
||||
// final remote_role = !iAmCaller ? "Caller" : "Receiver";
|
||||
// final remote_id = !iAmCaller ? callerId : receiverId;
|
||||
// final remote_user = SocketUser(id: remote_id, name: "$remote_role-$remote_id", userAgent: DeviceInfo.userAgent, moreInfo: {});
|
||||
//
|
||||
// final session_id = "$callerId-$receiverId";
|
||||
// _session = SessionOneToOne(id: session_id, local_user: self_user, remote_user: remote_user);
|
||||
// }
|
||||
//
|
||||
// bool showNoise = true;
|
||||
// final StreamController<bool> _audioButton = StreamController<bool>.broadcast();
|
||||
// final StreamController<bool> _videoButton = StreamController<bool>.broadcast();
|
||||
// final StreamController<bool> _onButtonBarVisibleStreamController = StreamController<bool>.broadcast();
|
||||
// final StreamController<double> _onButtonBarHeightStreamController = StreamController<double>.broadcast();
|
||||
//
|
||||
// final RTCVideoRenderer _localRenderer = RTCVideoRenderer();
|
||||
// final RTCVideoRenderer _remoteRenderer = RTCVideoRenderer();
|
||||
//
|
||||
// MediaStream get localMediaStream => _signaling.localStream!;
|
||||
// MediaStream get remoteMediaStream => _signaling.remoteStreams.first;
|
||||
//
|
||||
// @override
|
||||
// initState() {
|
||||
// super.initState();
|
||||
// initRenderers();
|
||||
// _connect();
|
||||
// }
|
||||
//
|
||||
// initRenderers() async {
|
||||
// await _localRenderer.initialize();
|
||||
// await _remoteRenderer.initialize();
|
||||
// }
|
||||
//
|
||||
// @override
|
||||
// deactivate() {
|
||||
// super.deactivate();
|
||||
// _signaling?.close();
|
||||
// _localRenderer.dispose();
|
||||
// _remoteRenderer.dispose();
|
||||
// }
|
||||
//
|
||||
// @override
|
||||
// Widget build(BuildContext context) {
|
||||
// return Scaffold(
|
||||
// // appBar: AppBar(
|
||||
// // title: Text('P2P Call Sample' + (_session?.local_user != null ? ' [Your ID (${_session?.local_user?.id})] ' : '')),
|
||||
// // actions: <Widget>[
|
||||
// // IconButton(
|
||||
// // icon: const Icon(Icons.settings),
|
||||
// // onPressed: (){
|
||||
// // setState(() {
|
||||
// // });
|
||||
// // },
|
||||
// // tooltip: 'setup',
|
||||
// // ),
|
||||
// // ],
|
||||
// // ),
|
||||
// body: videoCanvasWidgets(),
|
||||
// );
|
||||
// }
|
||||
//
|
||||
// LayoutBuilder videoCanvasWidgets() {
|
||||
// return LayoutBuilder(
|
||||
// builder: (BuildContext context, BoxConstraints constraints) {
|
||||
// return Stack(
|
||||
// children: [
|
||||
// CamViewWidget(
|
||||
// localRenderer: _localRenderer,
|
||||
// remoteRenderer: _remoteRenderer,
|
||||
// constraints: constraints,
|
||||
// onButtonBarVisibleStreamController: _onButtonBarVisibleStreamController,
|
||||
// onButtonBarHeightStreamController: _onButtonBarHeightStreamController,
|
||||
// ),
|
||||
// ConferenceButtonBar(
|
||||
// audioEnabled: _audioButton.stream,
|
||||
// videoEnabled: _videoButton.stream,
|
||||
// onAudioEnabled: _onAudioEnable,
|
||||
// onVideoEnabled: _onVideoEnabled,
|
||||
// onSwitchCamera: _onSwitchCamera,
|
||||
// onHangup: _onHangup,
|
||||
// onPersonAdd: () {},
|
||||
// onPersonRemove: () {},
|
||||
// onHeight: _onHeightBar,
|
||||
// onShow: _onShowBar,
|
||||
// onHide: _onHideBar,
|
||||
// ),
|
||||
// ],
|
||||
// );
|
||||
// },
|
||||
// );
|
||||
// }
|
||||
//
|
||||
//
|
||||
// void _connect() async {
|
||||
// if(_session == null)
|
||||
// return;
|
||||
//
|
||||
// _signaling ??= Signaling(widget.host, session: _session!)..connect();
|
||||
//
|
||||
// _signaling?.onSignalingStateChange = (SignalingState state) {
|
||||
// switch (state) {
|
||||
// case SignalingState.Closed:
|
||||
// case SignalingState.Error:
|
||||
// case SignalingState.Open:
|
||||
// break;
|
||||
// }
|
||||
// };
|
||||
//
|
||||
// _signaling?.onCallStateChange = (SessionOneToOne session, CallState state) {
|
||||
// switch (state) {
|
||||
// case CallState.Calling:
|
||||
// setState(() {});
|
||||
// break;
|
||||
// case CallState.Bye:
|
||||
// setState(() {
|
||||
// _localRenderer.srcObject = null;
|
||||
// _remoteRenderer.srcObject = null;
|
||||
// _session = null;
|
||||
// });
|
||||
// break;
|
||||
// case CallState.Invite:
|
||||
// case CallState.Connected:
|
||||
// case CallState.Ringing:
|
||||
// }
|
||||
// };
|
||||
//
|
||||
// _signaling?.onConnected = ((event) {
|
||||
// _signaling?.callAccepted(_session!);
|
||||
// });
|
||||
//
|
||||
// _signaling?.onRemoteConnected = ((event) {
|
||||
//
|
||||
// });
|
||||
//
|
||||
// _signaling?.onLocalStream = ((stream) {
|
||||
// _localRenderer.srcObject = stream;
|
||||
// setState(() {
|
||||
// });
|
||||
// });
|
||||
//
|
||||
// _signaling?.onAddRemoteStream = ((_, stream) {
|
||||
// _remoteRenderer.srcObject = stream;
|
||||
// setState(() {});
|
||||
// });
|
||||
//
|
||||
// _signaling?.onRemoveRemoteStream = ((_, stream) {
|
||||
// setState(() {
|
||||
// _remoteRenderer.srcObject = null;
|
||||
// });
|
||||
// });
|
||||
// }
|
||||
//
|
||||
// _hangUp() async{
|
||||
// if (_session != null) {
|
||||
// _signaling?.bye(_session!);
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// _switchCamera() {
|
||||
// _signaling?.switchCamera();
|
||||
// }
|
||||
//
|
||||
// _muteMic() {
|
||||
// _signaling?.muteMic();
|
||||
// }
|
||||
//
|
||||
// Function? _onAudioEnable() {
|
||||
// final audioTrack = localMediaStream.getAudioTracks()[0];
|
||||
// final mute = audioTrack.muted;
|
||||
// Helper.setMicrophoneMute(!mute!, audioTrack);
|
||||
// _audioButton.add(mute);
|
||||
// }
|
||||
//
|
||||
// Function? _onVideoEnabled() {
|
||||
// final videoTrack = localMediaStream.getVideoTracks()[0];
|
||||
// bool videoEnabled = videoTrack.enabled;
|
||||
// localMediaStream.getVideoTracks()[0].enabled = !videoEnabled;
|
||||
// _videoButton.add(!videoEnabled);
|
||||
// }
|
||||
//
|
||||
// Function? _onSwitchCamera() {
|
||||
// Helper.switchCamera(localMediaStream.getVideoTracks()[0]);
|
||||
// }
|
||||
//
|
||||
// void _onShowBar() {
|
||||
// setState(() {
|
||||
// });
|
||||
// _onButtonBarVisibleStreamController.add(true);
|
||||
// }
|
||||
//
|
||||
// void _onHeightBar(double height) {
|
||||
// _onButtonBarHeightStreamController.add(height);
|
||||
// }
|
||||
//
|
||||
// void _onHideBar() {
|
||||
// setState(() {
|
||||
// SystemChrome.setEnabledSystemUIMode(SystemUiMode.manual, overlays: [SystemUiOverlay.bottom]);
|
||||
// });
|
||||
// _onButtonBarVisibleStreamController.add(false);
|
||||
// }
|
||||
//
|
||||
// Future<void> _onHangup() async {
|
||||
// _signaling?.finishSessions();
|
||||
// print('onHangup');
|
||||
// Navigator.of(context).pop();
|
||||
// }
|
||||
// }
|
||||
@ -1,242 +1,242 @@
|
||||
import 'dart:convert';
|
||||
|
||||
// import 'package:cloud_firestore/cloud_firestore.dart';
|
||||
import 'package:flutter_webrtc/flutter_webrtc.dart';
|
||||
|
||||
typedef void StreamStateCallback(MediaStream stream);
|
||||
|
||||
class Signaling {
|
||||
Map<String, dynamic> configuration = {
|
||||
'iceServers': [
|
||||
{
|
||||
'urls': ['stun:stun1.l.google.com:19302', 'stun:stun2.l.google.com:19302']
|
||||
}
|
||||
]
|
||||
};
|
||||
|
||||
late RTCPeerConnection peerConnection;
|
||||
late MediaStream localStream;
|
||||
late MediaStream remoteStream;
|
||||
late String roomId;
|
||||
late String currentRoomText;
|
||||
late StreamStateCallback onAddRemoteStream;
|
||||
|
||||
Future<String> createRoom(RTCVideoRenderer remoteRenderer) async {
|
||||
// FirebaseFirestore db = FirebaseFirestore.instance;
|
||||
// DocumentReference roomRef = db.collection('rooms').doc();
|
||||
|
||||
print('Create PeerConnection with configuration: $configuration');
|
||||
|
||||
peerConnection = await createPeerConnection(configuration);
|
||||
|
||||
registerPeerConnectionListeners();
|
||||
|
||||
localStream.getTracks().forEach((track) {
|
||||
peerConnection?.addTrack(track, localStream);
|
||||
});
|
||||
|
||||
// Code for collecting ICE candidates below
|
||||
// var callerCandidatesCollection = roomRef.collection('callerCandidates');
|
||||
|
||||
peerConnection?.onIceCandidate = (RTCIceCandidate candidate) {
|
||||
print('Got candidate: ${candidate.toMap()}');
|
||||
// callerCandidatesCollection.add(candidate.toMap());
|
||||
};
|
||||
// Finish Code for collecting ICE candidate
|
||||
|
||||
// Add code for creating a room
|
||||
RTCSessionDescription offer = await peerConnection.createOffer();
|
||||
await peerConnection.setLocalDescription(offer);
|
||||
print('Created offer: $offer');
|
||||
|
||||
Map<String, dynamic> roomWithOffer = {'offer': offer.toMap()};
|
||||
|
||||
// await roomRef.set(roomWithOffer);
|
||||
// var roomId = roomRef.id;
|
||||
print('New room created with SDK offer. Room ID: $roomId');
|
||||
currentRoomText = 'Current room is $roomId - You are the caller!';
|
||||
// Created a Room
|
||||
|
||||
peerConnection?.onTrack = (RTCTrackEvent event) {
|
||||
print('Got remote track: ${event.streams[0]}');
|
||||
|
||||
event.streams[0].getTracks().forEach((track) {
|
||||
print('Add a track to the remoteStream $track');
|
||||
remoteStream?.addTrack(track);
|
||||
});
|
||||
};
|
||||
|
||||
// Listening for remote session description below
|
||||
// roomRef.snapshots().listen((snapshot) async {
|
||||
// print('Got updated room: ${snapshot.data()}');
|
||||
//
|
||||
// Map<String, dynamic> data = snapshot.data() as Map<String, dynamic>;
|
||||
// if (peerConnection?.getRemoteDescription() != null && data['answer'] != null) {
|
||||
// var answer = RTCSessionDescription(
|
||||
// data['answer']['sdp'],
|
||||
// data['answer']['type'],
|
||||
// );
|
||||
//
|
||||
// print("Someone tried to connect");
|
||||
// await peerConnection?.setRemoteDescription(answer);
|
||||
// }
|
||||
// });
|
||||
// // Listening for remote session description above
|
||||
//
|
||||
// // Listen for remote Ice candidates below
|
||||
// roomRef.collection('calleeCandidates').snapshots().listen((snapshot) {
|
||||
// snapshot.docChanges.forEach((change) {
|
||||
// if (change.type == DocumentChangeType.added) {
|
||||
// Map<String, dynamic> data = change.doc.data() as Map<String, dynamic>;
|
||||
// print('Got new remote ICE candidate: ${jsonEncode(data)}');
|
||||
// peerConnection.addCandidate(
|
||||
// RTCIceCandidate(
|
||||
// data['candidate'],
|
||||
// data['sdpMid'],
|
||||
// data['sdpMLineIndex'],
|
||||
// ),
|
||||
// );
|
||||
// }
|
||||
// });
|
||||
// });
|
||||
// Listen for remote ICE candidates above
|
||||
|
||||
return roomId;
|
||||
}
|
||||
|
||||
Future<void> joinRoom(String roomId, RTCVideoRenderer remoteVideo) async {
|
||||
// FirebaseFirestore db = FirebaseFirestore.instance;
|
||||
// DocumentReference roomRef = db.collection('rooms').doc('$roomId');
|
||||
// var roomSnapshot = await roomRef.get();
|
||||
// print('Got room ${roomSnapshot.exists}');
|
||||
|
||||
// if (roomSnapshot.exists) {
|
||||
// print('Create PeerConnection with configuration: $configuration');
|
||||
// peerConnection = await createPeerConnection(configuration);
|
||||
//
|
||||
// registerPeerConnectionListeners();
|
||||
//
|
||||
// localStream.getTracks().forEach((track) {
|
||||
// peerConnection?.addTrack(track, localStream);
|
||||
// });
|
||||
//
|
||||
// // Code for collecting ICE candidates below
|
||||
// // var calleeCandidatesCollection = roomRef.collection('calleeCandidates');
|
||||
// peerConnection.onIceCandidate = (RTCIceCandidate candidate) {
|
||||
// if (candidate == null) {
|
||||
// print('onIceCandidate: complete!');
|
||||
// return;
|
||||
// }
|
||||
// print('onIceCandidate: ${candidate.toMap()}');
|
||||
// // calleeCandidatesCollection.add(candidate.toMap());
|
||||
// };
|
||||
// // Code for collecting ICE candidate above
|
||||
//
|
||||
// peerConnection?.onTrack = (RTCTrackEvent event) {
|
||||
// print('Got remote track: ${event.streams[0]}');
|
||||
// event.streams[0].getTracks().forEach((track) {
|
||||
// print('Add a track to the remoteStream: $track');
|
||||
// remoteStream?.addTrack(track);
|
||||
// });
|
||||
// };
|
||||
//
|
||||
// // Code for creating SDP answer below
|
||||
// var data = roomSnapshot.data() as Map<String, dynamic>;
|
||||
// print('Got offer $data');
|
||||
// var offer = data['offer'];
|
||||
// await peerConnection?.setRemoteDescription(
|
||||
// RTCSessionDescription(offer['sdp'], offer['type']),
|
||||
// );
|
||||
// var answer = await peerConnection.createAnswer();
|
||||
// print('Created Answer $answer');
|
||||
//
|
||||
// await peerConnection.setLocalDescription(answer);
|
||||
//
|
||||
// Map<String, dynamic> roomWithAnswer = {
|
||||
// 'answer': {'type': answer.type, 'sdp': answer.sdp}
|
||||
// };
|
||||
//
|
||||
// await roomRef.update(roomWithAnswer);
|
||||
// // Finished creating SDP answer
|
||||
//
|
||||
// // Listening for remote ICE candidates below
|
||||
// // roomRef.collection('callerCandidates').snapshots().listen((snapshot) {
|
||||
// // snapshot.docChanges.forEach((document) {
|
||||
// // var data = document.doc.data() as Map<String, dynamic>;
|
||||
// // print(data);
|
||||
// // print('Got new remote ICE candidate: $data');
|
||||
// // peerConnection.addCandidate(
|
||||
// // RTCIceCandidate(
|
||||
// // data['candidate'],
|
||||
// // data['sdpMid'],
|
||||
// // data['sdpMLineIndex'],
|
||||
// // ),
|
||||
// // );
|
||||
// // });
|
||||
// // });
|
||||
// }
|
||||
}
|
||||
|
||||
Future<void> openUserMedia(
|
||||
RTCVideoRenderer localVideo,
|
||||
RTCVideoRenderer remoteVideo,
|
||||
) async {
|
||||
var stream = await navigator.mediaDevices.getUserMedia({'video': true, 'audio': false});
|
||||
|
||||
localVideo.srcObject = stream;
|
||||
localStream = stream;
|
||||
|
||||
remoteVideo.srcObject = await createLocalMediaStream('key');
|
||||
}
|
||||
|
||||
Future<void> hangUp(RTCVideoRenderer localVideo) async {
|
||||
List<MediaStreamTrack> tracks = localVideo.srcObject!.getTracks();
|
||||
tracks.forEach((track) {
|
||||
track.stop();
|
||||
});
|
||||
|
||||
if (remoteStream != null) {
|
||||
remoteStream.getTracks().forEach((track) => track.stop());
|
||||
}
|
||||
if (peerConnection != null) peerConnection.close();
|
||||
|
||||
if (roomId != null) {
|
||||
// var db = FirebaseFirestore.instance;
|
||||
// var roomRef = db.collection('rooms').doc(roomId);
|
||||
// var calleeCandidates = await roomRef.collection('calleeCandidates').get();
|
||||
// calleeCandidates.docs.forEach((document) => document.reference.delete());
|
||||
|
||||
// var callerCandidates = await roomRef.collection('callerCandidates').get();
|
||||
// callerCandidates.docs.forEach((document) => document.reference.delete());
|
||||
|
||||
// await roomRef.delete();
|
||||
}
|
||||
|
||||
localStream.dispose();
|
||||
remoteStream?.dispose();
|
||||
}
|
||||
|
||||
void registerPeerConnectionListeners() {
|
||||
peerConnection?.onIceGatheringState = (RTCIceGatheringState state) {
|
||||
print('ICE gathering state changed: $state');
|
||||
};
|
||||
|
||||
peerConnection?.onConnectionState = (RTCPeerConnectionState state) {
|
||||
print('Connection state change: $state');
|
||||
};
|
||||
|
||||
peerConnection?.onSignalingState = (RTCSignalingState state) {
|
||||
print('Signaling state change: $state');
|
||||
};
|
||||
|
||||
peerConnection?.onIceGatheringState = (RTCIceGatheringState state) {
|
||||
print('ICE connection state change: $state');
|
||||
};
|
||||
|
||||
peerConnection?.onAddStream = (MediaStream stream) {
|
||||
print("Add remote stream");
|
||||
onAddRemoteStream?.call(stream);
|
||||
remoteStream = stream;
|
||||
};
|
||||
}
|
||||
}
|
||||
// import 'dart:convert';
|
||||
//
|
||||
// // import 'package:cloud_firestore/cloud_firestore.dart';
|
||||
// import 'package:flutter_webrtc/flutter_webrtc.dart';
|
||||
//
|
||||
// typedef void StreamStateCallback(MediaStream stream);
|
||||
//
|
||||
// class Signaling {
|
||||
// Map<String, dynamic> configuration = {
|
||||
// 'iceServers': [
|
||||
// {
|
||||
// 'urls': ['stun:stun1.l.google.com:19302', 'stun:stun2.l.google.com:19302']
|
||||
// }
|
||||
// ]
|
||||
// };
|
||||
//
|
||||
// late RTCPeerConnection peerConnection;
|
||||
// late MediaStream localStream;
|
||||
// late MediaStream remoteStream;
|
||||
// late String roomId;
|
||||
// late String currentRoomText;
|
||||
// late StreamStateCallback onAddRemoteStream;
|
||||
//
|
||||
// Future<String> createRoom(RTCVideoRenderer remoteRenderer) async {
|
||||
// // FirebaseFirestore db = FirebaseFirestore.instance;
|
||||
// // DocumentReference roomRef = db.collection('rooms').doc();
|
||||
//
|
||||
// print('Create PeerConnection with configuration: $configuration');
|
||||
//
|
||||
// peerConnection = await createPeerConnection(configuration);
|
||||
//
|
||||
// registerPeerConnectionListeners();
|
||||
//
|
||||
// localStream.getTracks().forEach((track) {
|
||||
// peerConnection?.addTrack(track, localStream);
|
||||
// });
|
||||
//
|
||||
// // Code for collecting ICE candidates below
|
||||
// // var callerCandidatesCollection = roomRef.collection('callerCandidates');
|
||||
//
|
||||
// peerConnection?.onIceCandidate = (RTCIceCandidate candidate) {
|
||||
// print('Got candidate: ${candidate.toMap()}');
|
||||
// // callerCandidatesCollection.add(candidate.toMap());
|
||||
// };
|
||||
// // Finish Code for collecting ICE candidate
|
||||
//
|
||||
// // Add code for creating a room
|
||||
// RTCSessionDescription offer = await peerConnection.createOffer();
|
||||
// await peerConnection.setLocalDescription(offer);
|
||||
// print('Created offer: $offer');
|
||||
//
|
||||
// Map<String, dynamic> roomWithOffer = {'offer': offer.toMap()};
|
||||
//
|
||||
// // await roomRef.set(roomWithOffer);
|
||||
// // var roomId = roomRef.id;
|
||||
// print('New room created with SDK offer. Room ID: $roomId');
|
||||
// currentRoomText = 'Current room is $roomId - You are the caller!';
|
||||
// // Created a Room
|
||||
//
|
||||
// peerConnection?.onTrack = (RTCTrackEvent event) {
|
||||
// print('Got remote track: ${event.streams[0]}');
|
||||
//
|
||||
// event.streams[0].getTracks().forEach((track) {
|
||||
// print('Add a track to the remoteStream $track');
|
||||
// remoteStream?.addTrack(track);
|
||||
// });
|
||||
// };
|
||||
//
|
||||
// // Listening for remote session description below
|
||||
// // roomRef.snapshots().listen((snapshot) async {
|
||||
// // print('Got updated room: ${snapshot.data()}');
|
||||
// //
|
||||
// // Map<String, dynamic> data = snapshot.data() as Map<String, dynamic>;
|
||||
// // if (peerConnection?.getRemoteDescription() != null && data['answer'] != null) {
|
||||
// // var answer = RTCSessionDescription(
|
||||
// // data['answer']['sdp'],
|
||||
// // data['answer']['type'],
|
||||
// // );
|
||||
// //
|
||||
// // print("Someone tried to connect");
|
||||
// // await peerConnection?.setRemoteDescription(answer);
|
||||
// // }
|
||||
// // });
|
||||
// // // Listening for remote session description above
|
||||
// //
|
||||
// // // Listen for remote Ice candidates below
|
||||
// // roomRef.collection('calleeCandidates').snapshots().listen((snapshot) {
|
||||
// // snapshot.docChanges.forEach((change) {
|
||||
// // if (change.type == DocumentChangeType.added) {
|
||||
// // Map<String, dynamic> data = change.doc.data() as Map<String, dynamic>;
|
||||
// // print('Got new remote ICE candidate: ${jsonEncode(data)}');
|
||||
// // peerConnection.addCandidate(
|
||||
// // RTCIceCandidate(
|
||||
// // data['candidate'],
|
||||
// // data['sdpMid'],
|
||||
// // data['sdpMLineIndex'],
|
||||
// // ),
|
||||
// // );
|
||||
// // }
|
||||
// // });
|
||||
// // });
|
||||
// // Listen for remote ICE candidates above
|
||||
//
|
||||
// return roomId;
|
||||
// }
|
||||
//
|
||||
// Future<void> joinRoom(String roomId, RTCVideoRenderer remoteVideo) async {
|
||||
// // FirebaseFirestore db = FirebaseFirestore.instance;
|
||||
// // DocumentReference roomRef = db.collection('rooms').doc('$roomId');
|
||||
// // var roomSnapshot = await roomRef.get();
|
||||
// // print('Got room ${roomSnapshot.exists}');
|
||||
//
|
||||
// // if (roomSnapshot.exists) {
|
||||
// // print('Create PeerConnection with configuration: $configuration');
|
||||
// // peerConnection = await createPeerConnection(configuration);
|
||||
// //
|
||||
// // registerPeerConnectionListeners();
|
||||
// //
|
||||
// // localStream.getTracks().forEach((track) {
|
||||
// // peerConnection?.addTrack(track, localStream);
|
||||
// // });
|
||||
// //
|
||||
// // // Code for collecting ICE candidates below
|
||||
// // // var calleeCandidatesCollection = roomRef.collection('calleeCandidates');
|
||||
// // peerConnection.onIceCandidate = (RTCIceCandidate candidate) {
|
||||
// // if (candidate == null) {
|
||||
// // print('onIceCandidate: complete!');
|
||||
// // return;
|
||||
// // }
|
||||
// // print('onIceCandidate: ${candidate.toMap()}');
|
||||
// // // calleeCandidatesCollection.add(candidate.toMap());
|
||||
// // };
|
||||
// // // Code for collecting ICE candidate above
|
||||
// //
|
||||
// // peerConnection?.onTrack = (RTCTrackEvent event) {
|
||||
// // print('Got remote track: ${event.streams[0]}');
|
||||
// // event.streams[0].getTracks().forEach((track) {
|
||||
// // print('Add a track to the remoteStream: $track');
|
||||
// // remoteStream?.addTrack(track);
|
||||
// // });
|
||||
// // };
|
||||
// //
|
||||
// // // Code for creating SDP answer below
|
||||
// // var data = roomSnapshot.data() as Map<String, dynamic>;
|
||||
// // print('Got offer $data');
|
||||
// // var offer = data['offer'];
|
||||
// // await peerConnection?.setRemoteDescription(
|
||||
// // RTCSessionDescription(offer['sdp'], offer['type']),
|
||||
// // );
|
||||
// // var answer = await peerConnection.createAnswer();
|
||||
// // print('Created Answer $answer');
|
||||
// //
|
||||
// // await peerConnection.setLocalDescription(answer);
|
||||
// //
|
||||
// // Map<String, dynamic> roomWithAnswer = {
|
||||
// // 'answer': {'type': answer.type, 'sdp': answer.sdp}
|
||||
// // };
|
||||
// //
|
||||
// // await roomRef.update(roomWithAnswer);
|
||||
// // // Finished creating SDP answer
|
||||
// //
|
||||
// // // Listening for remote ICE candidates below
|
||||
// // // roomRef.collection('callerCandidates').snapshots().listen((snapshot) {
|
||||
// // // snapshot.docChanges.forEach((document) {
|
||||
// // // var data = document.doc.data() as Map<String, dynamic>;
|
||||
// // // print(data);
|
||||
// // // print('Got new remote ICE candidate: $data');
|
||||
// // // peerConnection.addCandidate(
|
||||
// // // RTCIceCandidate(
|
||||
// // // data['candidate'],
|
||||
// // // data['sdpMid'],
|
||||
// // // data['sdpMLineIndex'],
|
||||
// // // ),
|
||||
// // // );
|
||||
// // // });
|
||||
// // // });
|
||||
// // }
|
||||
// }
|
||||
//
|
||||
// Future<void> openUserMedia(
|
||||
// RTCVideoRenderer localVideo,
|
||||
// RTCVideoRenderer remoteVideo,
|
||||
// ) async {
|
||||
// var stream = await navigator.mediaDevices.getUserMedia({'video': true, 'audio': false});
|
||||
//
|
||||
// localVideo.srcObject = stream;
|
||||
// localStream = stream;
|
||||
//
|
||||
// remoteVideo.srcObject = await createLocalMediaStream('key');
|
||||
// }
|
||||
//
|
||||
// Future<void> hangUp(RTCVideoRenderer localVideo) async {
|
||||
// List<MediaStreamTrack> tracks = localVideo.srcObject!.getTracks();
|
||||
// tracks.forEach((track) {
|
||||
// track.stop();
|
||||
// });
|
||||
//
|
||||
// if (remoteStream != null) {
|
||||
// remoteStream.getTracks().forEach((track) => track.stop());
|
||||
// }
|
||||
// if (peerConnection != null) peerConnection.close();
|
||||
//
|
||||
// if (roomId != null) {
|
||||
// // var db = FirebaseFirestore.instance;
|
||||
// // var roomRef = db.collection('rooms').doc(roomId);
|
||||
// // var calleeCandidates = await roomRef.collection('calleeCandidates').get();
|
||||
// // calleeCandidates.docs.forEach((document) => document.reference.delete());
|
||||
//
|
||||
// // var callerCandidates = await roomRef.collection('callerCandidates').get();
|
||||
// // callerCandidates.docs.forEach((document) => document.reference.delete());
|
||||
//
|
||||
// // await roomRef.delete();
|
||||
// }
|
||||
//
|
||||
// localStream.dispose();
|
||||
// remoteStream?.dispose();
|
||||
// }
|
||||
//
|
||||
// void registerPeerConnectionListeners() {
|
||||
// peerConnection?.onIceGatheringState = (RTCIceGatheringState state) {
|
||||
// print('ICE gathering state changed: $state');
|
||||
// };
|
||||
//
|
||||
// peerConnection?.onConnectionState = (RTCPeerConnectionState state) {
|
||||
// print('Connection state change: $state');
|
||||
// };
|
||||
//
|
||||
// peerConnection?.onSignalingState = (RTCSignalingState state) {
|
||||
// print('Signaling state change: $state');
|
||||
// };
|
||||
//
|
||||
// peerConnection?.onIceGatheringState = (RTCIceGatheringState state) {
|
||||
// print('ICE connection state change: $state');
|
||||
// };
|
||||
//
|
||||
// peerConnection?.onAddStream = (MediaStream stream) {
|
||||
// print("Add remote stream");
|
||||
// onAddRemoteStream?.call(stream);
|
||||
// remoteStream = stream;
|
||||
// };
|
||||
// }
|
||||
// }
|
||||
|
||||
Loading…
Reference in New Issue