part of '../../../main.dart'; class CameraStreamView extends StatefulWidget { final bool withControls; CameraStreamView({Key key, this.withControls: true}) : super(key: key); @override _CameraStreamViewState createState() => _CameraStreamViewState(); } class _CameraStreamViewState extends State { CameraEntity _entity; String _streamUrl = ""; VideoPlayerController _videoPlayerController; Timer _monitorTimer; bool _isLoaded = false; double _aspectRatio = 1.33; String _webViewHtml; String _jsMessageChannelName = 'unknown'; Completer _loading; @override void initState() { super.initState(); } Future _loadResources() { if (_loading != null && !_loading.isCompleted) { Logger.d("[Camera Player] Resources loading is not finished yet"); return _loading.future; } Logger.d("[Camera Player] Loading resources"); _loading = Completer(); _entity = EntityModel .of(context) .entityWrapper .entity; if (_entity.supportStream) { HomeAssistant().getCameraStream(_entity.entityId) .then((data) { if (_videoPlayerController != null) { _videoPlayerController.dispose().then((_) => createPlayer(data)); } else { createPlayer(data); } }) .catchError((e) { _loading.completeError(e); Logger.e("[Camera Player] $e"); }); } else { _streamUrl = '${ConnectionManager().httpWebHost}/api/camera_proxy_stream/${_entity .entityId}?token=${_entity.attributes['access_token']}'; _jsMessageChannelName = 'HA_${_entity.entityId.replaceAll('.', '_')}'; rootBundle.loadString('assets/html/cameraView.html').then((file) { _webViewHtml = Uri.dataFromString( file.replaceFirst('{{stream_url}}', _streamUrl).replaceFirst('{{message_channel}}', _jsMessageChannelName), mimeType: 'text/html', encoding: Encoding.getByName('utf-8') ).toString(); _loading.complete(); }); } return _loading.future; } void createPlayer(data) { _videoPlayerController = VideoPlayerController.network("${ConnectionManager().httpWebHost}${data["url"]}"); _videoPlayerController.initialize().then((_) { setState((){ _aspectRatio = _videoPlayerController.value.aspectRatio; }); _loading.complete(); autoPlay(); startMonitor(); }).catchError((e) { _loading.completeError(e); Logger.e("[Camera Player] Error player init. Retrying"); _loadResources(); }); } void autoPlay() { if (!_videoPlayerController.value.isPlaying) { _videoPlayerController.play(); } } void startMonitor() { _monitorTimer?.cancel(); _monitorTimer = Timer.periodic(Duration(milliseconds: 500), (timer) { if (_videoPlayerController.value.hasError) { timer.cancel(); setState(() { _isLoaded = false; }); } }); } Widget _buildScreen() { Widget screenWidget; if (!_isLoaded) { screenWidget = Center( child: EntityPicture() ); } else if (_entity.supportStream) { if (_videoPlayerController.value.initialized) { screenWidget = VideoPlayer(_videoPlayerController); } else { screenWidget = Center( child: EntityPicture() ); } } else { screenWidget = WebView( initialUrl: _webViewHtml, initialMediaPlaybackPolicy: AutoMediaPlaybackPolicy.always_allow, debuggingEnabled: Logger.isInDebugMode, gestureNavigationEnabled: false, javascriptMode: JavascriptMode.unrestricted, javascriptChannels: { JavascriptChannel( name: _jsMessageChannelName, onMessageReceived: ((message) { setState((){ _aspectRatio = double.tryParse(message.message) ?? 1.33; }); }) ) } ); } return AspectRatio( aspectRatio: _aspectRatio, child: screenWidget ); } Widget _buildControls() { Widget playControl; if (_entity.supportStream) { playControl = Center( child: IconButton( icon: Icon((_videoPlayerController != null && _videoPlayerController.value.isPlaying) ? Icons.pause_circle_outline : Icons.play_circle_outline), iconSize: 60, color: Colors.amberAccent, onPressed: (_videoPlayerController == null || _videoPlayerController.value.hasError || !_isLoaded) ? null : () { setState(() { if (_videoPlayerController != null && _videoPlayerController.value.isPlaying) { _videoPlayerController.pause(); } else { _videoPlayerController.play(); } }); }, ), ); } else { playControl = Container(); } return Row( mainAxisSize: MainAxisSize.max, crossAxisAlignment: CrossAxisAlignment.center, mainAxisAlignment: MainAxisAlignment.center, children: [ IconButton( icon: Icon(Icons.refresh), iconSize: 40, color: Colors.amberAccent, onPressed: _isLoaded ? () { setState(() { _isLoaded = false; }); } : null, ), Expanded( child: playControl, ), IconButton( icon: Icon(Icons.fullscreen), iconSize: 40, color: Colors.amberAccent, onPressed: _isLoaded ? () { _videoPlayerController?.pause(); eventBus.fire(ShowEntityPageEvent()); Navigator.of(context).push( MaterialPageRoute( builder: (conext) => FullScreenPage( child: EntityModel( child: CameraStreamView( withControls: false ), handleTap: false, entityWrapper: EntityWrapper( entity: _entity ), ), ), fullscreenDialog: true ) ).then((_) { eventBus.fire(ShowEntityPageEvent(entity: _entity)); }); } : null, ) ], ); } @override Widget build(BuildContext context) { if (!_isLoaded && (_loading == null || _loading.isCompleted)) { _loadResources().then((_) => setState((){ _isLoaded = true; })); } if (widget.withControls) { return Card( child: Column( mainAxisSize: MainAxisSize.min, children: [ _buildScreen(), _buildControls() ], ), ); } else { return _buildScreen(); } } @override void dispose() { _monitorTimer?.cancel(); _videoPlayerController?.dispose(); super.dispose(); } }