import 'dart:async'; import 'dart:io'; import 'dart:ui' as ui; import 'package:desktop_multi_window/desktop_multi_window.dart'; import 'package:flutter/material.dart'; import 'package:flutter/services.dart'; import 'package:flutter_custom_cursor/cursor_manager.dart' as custom_cursor_manager; import 'package:get/get.dart'; import 'package:provider/provider.dart'; import 'package:wakelock/wakelock.dart'; import 'package:flutter_custom_cursor/flutter_custom_cursor.dart'; import 'package:flutter_improved_scrolling/flutter_improved_scrolling.dart'; import '../../consts.dart'; import '../../common/widgets/overlay.dart'; import '../../common/widgets/remote_input.dart'; import '../../common.dart'; import '../../common/widgets/dialog.dart'; import '../../models/model.dart'; import '../../models/platform_model.dart'; import '../../common/shared_state.dart'; import '../../utils/image.dart'; import '../widgets/remote_toolbar.dart'; import '../widgets/kb_layout_type_chooser.dart'; final SimpleWrapper _firstEnterImage = SimpleWrapper(false); class RemotePage extends StatefulWidget { RemotePage({ Key? key, required this.id, required this.password, required this.menubarState, this.switchUuid, this.forceRelay, }) : super(key: key); final String id; final String? password; final MenubarState menubarState; final String? switchUuid; final bool? forceRelay; final SimpleWrapper?> _lastState = SimpleWrapper(null); FFI get ffi => (_lastState.value! as _RemotePageState)._ffi; @override State createState() { final state = _RemotePageState(); _lastState.value = state; return state; } } class _RemotePageState extends State with AutomaticKeepAliveClientMixin, MultiWindowListener { Timer? _timer; String keyboardMode = "legacy"; bool _isWindowBlur = false; final _cursorOverImage = false.obs; late RxBool _showRemoteCursor; late RxBool _zoomCursor; late RxBool _remoteCursorMoved; late RxBool _keyboardEnabled; late RxInt _textureId; late int _textureKey; final useTextureRender = bind.mainUseTextureRender(); final _blockableOverlayState = BlockableOverlayState(); final FocusNode _rawKeyFocusNode = FocusNode(debugLabel: "rawkeyFocusNode"); Function(bool)? _onEnterOrLeaveImage4Menubar; late FFI _ffi; void _initStates(String id) { initSharedStates(id); _zoomCursor = PeerBoolOption.find(id, 'zoom-cursor'); _showRemoteCursor = ShowRemoteCursorState.find(id); _keyboardEnabled = KeyboardEnabledState.find(id); _remoteCursorMoved = RemoteCursorMovedState.find(id); _textureKey = newTextureId; _textureId = RxInt(-1); } @override void initState() { super.initState(); _initStates(widget.id); _ffi = FFI(); Get.put(_ffi, tag: widget.id); _ffi.imageModel.addCallbackOnFirstImage((String peerId) { showKBLayoutTypeChooserIfNeeded( _ffi.ffiModel.pi.platform, _ffi.dialogManager); }); _ffi.start( widget.id, password: widget.password, switchUuid: widget.switchUuid, forceRelay: widget.forceRelay, ); WidgetsBinding.instance.addPostFrameCallback((_) { SystemChrome.setEnabledSystemUIMode(SystemUiMode.manual, overlays: []); _ffi.dialogManager .showLoading(translate('Connecting...'), onCancel: closeConnection); }); if (!Platform.isLinux) { Wakelock.enable(); } // Register texture. _textureId.value = -1; if (useTextureRender) { textureRenderer.createTexture(_textureKey).then((id) async { debugPrint("id: $id, texture_key: $_textureKey"); if (id != -1) { final ptr = await textureRenderer.getTexturePtr(_textureKey); platformFFI.registerTexture(widget.id, ptr); _textureId.value = id; } }); } _ffi.ffiModel.updateEventListener(widget.id); bind.pluginSyncUi(syncTo: kAppTypeDesktopRemote); _ffi.qualityMonitorModel.checkShowQualityMonitor(widget.id); // Session option should be set after models.dart/FFI.start _showRemoteCursor.value = bind.sessionGetToggleOptionSync( id: widget.id, arg: 'show-remote-cursor'); _zoomCursor.value = bind.sessionGetToggleOptionSync(id: widget.id, arg: 'zoom-cursor'); DesktopMultiWindow.addListener(this); // if (!_isCustomCursorInited) { // customCursorController.registerNeedUpdateCursorCallback( // (String? lastKey, String? currentKey) async { // if (_firstEnterImage.value) { // _firstEnterImage.value = false; // return true; // } // return lastKey == null || lastKey != currentKey; // }); // _isCustomCursorInited = true; // } _blockableOverlayState.applyFfi(_ffi); } @override void onWindowBlur() { super.onWindowBlur(); // On windows, we use `focus` way to handle keyboard better. // Now on Linux, there's some rdev issues which will break the input. // We disable the `focus` way for non-Windows temporarily. if (Platform.isWindows) { _isWindowBlur = true; // unfocus the primary-focus when the whole window is lost focus, // and let OS to handle events instead. _rawKeyFocusNode.unfocus(); } } @override void onWindowFocus() { super.onWindowFocus(); // See [onWindowBlur]. if (Platform.isWindows) { _isWindowBlur = false; } } @override void onWindowRestore() { super.onWindowRestore(); // On windows, we use `onWindowRestore` way to handle window restore from // a minimized state. if (Platform.isWindows) { _isWindowBlur = false; } if (!Platform.isLinux) { Wakelock.enable(); } } // When the window is unminimized, onWindowMaximize or onWindowRestore can be called when the old state was maximized or not. @override void onWindowMaximize() { super.onWindowMaximize(); if (!Platform.isLinux) { Wakelock.enable(); } } @override void onWindowMinimize() { super.onWindowMinimize(); if (!Platform.isLinux) { Wakelock.disable(); } } @override void dispose() { debugPrint("REMOTE PAGE dispose ${widget.id}"); if (useTextureRender) { platformFFI.registerTexture(widget.id, 0); textureRenderer.closeTexture(_textureKey); } // ensure we leave this session, this is a double check bind.sessionEnterOrLeave(id: widget.id, enter: false); DesktopMultiWindow.removeListener(this); _ffi.dialogManager.hideMobileActionsOverlay(); _ffi.recordingModel.onClose(); _rawKeyFocusNode.dispose(); _ffi.close(); _timer?.cancel(); _ffi.dialogManager.dismissAll(); SystemChrome.setEnabledSystemUIMode(SystemUiMode.manual, overlays: SystemUiOverlay.values); if (!Platform.isLinux) { Wakelock.disable(); } Get.delete(tag: widget.id); super.dispose(); removeSharedStates(widget.id); } Widget buildBody(BuildContext context) { return Scaffold( backgroundColor: Theme.of(context).colorScheme.background, /// the Overlay key will be set with _blockableOverlayState in BlockableOverlay /// see override build() in [BlockableOverlay] body: BlockableOverlay( state: _blockableOverlayState, underlying: Container( color: Colors.black, child: RawKeyFocusScope( focusNode: _rawKeyFocusNode, onFocusChange: (bool imageFocused) { debugPrint( "onFocusChange(window active:${!_isWindowBlur}) $imageFocused"); // See [onWindowBlur]. if (Platform.isWindows) { if (_isWindowBlur) { imageFocused = false; Future.delayed(Duration.zero, () { _rawKeyFocusNode.unfocus(); }); } if (imageFocused) { _ffi.inputModel.enterOrLeave(true); } else { _ffi.inputModel.enterOrLeave(false); } } }, inputModel: _ffi.inputModel, child: getBodyForDesktop(context))), upperLayer: [ OverlayEntry( builder: (context) => RemoteMenubar( id: widget.id, ffi: _ffi, state: widget.menubarState, onEnterOrLeaveImageSetter: (func) => _onEnterOrLeaveImage4Menubar = func, onEnterOrLeaveImageCleaner: () => _onEnterOrLeaveImage4Menubar = null, )) ], ), ); } @override Widget build(BuildContext context) { super.build(context); return WillPopScope( onWillPop: () async { clientClose(widget.id, _ffi.dialogManager); return false; }, child: MultiProvider(providers: [ ChangeNotifierProvider.value(value: _ffi.ffiModel), ChangeNotifierProvider.value(value: _ffi.imageModel), ChangeNotifierProvider.value(value: _ffi.cursorModel), ChangeNotifierProvider.value(value: _ffi.canvasModel), ChangeNotifierProvider.value(value: _ffi.recordingModel), ], child: buildBody(context))); } void enterView(PointerEnterEvent evt) { _cursorOverImage.value = true; _firstEnterImage.value = true; if (_onEnterOrLeaveImage4Menubar != null) { try { _onEnterOrLeaveImage4Menubar!(true); } catch (e) { // } } // See [onWindowBlur]. if (!Platform.isWindows) { if (!_rawKeyFocusNode.hasFocus) { _rawKeyFocusNode.requestFocus(); } bind.sessionEnterOrLeave(id: widget.id, enter: true); } } void leaveView(PointerExitEvent evt) { if (_ffi.ffiModel.keyboard) { _ffi.inputModel.tryMoveEdgeOnExit(evt.position); } _cursorOverImage.value = false; _firstEnterImage.value = false; if (_onEnterOrLeaveImage4Menubar != null) { try { _onEnterOrLeaveImage4Menubar!(false); } catch (e) { // } } // See [onWindowBlur]. if (!Platform.isWindows) { bind.sessionEnterOrLeave(id: widget.id, enter: false); } } Widget _buildRawPointerMouseRegion( Widget child, PointerEnterEventListener? onEnter, PointerExitEventListener? onExit, ) { return RawPointerMouseRegion( onEnter: onEnter, onExit: onExit, onPointerDown: (event) { // A double check for blur status. // Note: If there's an `onPointerDown` event is triggered, `_isWindowBlur` is expected being false. // Sometimes the system does not send the necessary focus event to flutter. We should manually // handle this inconsistent status by setting `_isWindowBlur` to false. So we can // ensure the grab-key thread is running when our users are clicking the remote canvas. if (_isWindowBlur) { debugPrint( "Unexpected status: onPointerDown is triggered while the remote window is in blur status"); _isWindowBlur = false; } if (!_rawKeyFocusNode.hasFocus) { _rawKeyFocusNode.requestFocus(); } }, inputModel: _ffi.inputModel, child: child, ); } Widget getBodyForDesktop(BuildContext context) { var paints = [ MouseRegion(onEnter: (evt) { bind.hostStopSystemKeyPropagate(stopped: false); }, onExit: (evt) { bind.hostStopSystemKeyPropagate(stopped: true); }, child: LayoutBuilder(builder: (context, constraints) { Future.delayed(Duration.zero, () { Provider.of(context, listen: false).updateViewStyle(); }); return ImagePaint( id: widget.id, zoomCursor: _zoomCursor, cursorOverImage: _cursorOverImage, keyboardEnabled: _keyboardEnabled, remoteCursorMoved: _remoteCursorMoved, textureId: _textureId, useTextureRender: useTextureRender, listenerBuilder: (child) => _buildRawPointerMouseRegion(child, enterView, leaveView), ); })) ]; if (!_ffi.canvasModel.cursorEmbedded) { paints.add(Obx(() => Offstage( offstage: _showRemoteCursor.isFalse || _remoteCursorMoved.isFalse, child: CursorPaint( id: widget.id, zoomCursor: _zoomCursor, )))); } paints.add( Positioned( top: 10, right: 10, child: _buildRawPointerMouseRegion( QualityMonitor(_ffi.qualityMonitorModel), null, null), ), ); return Stack( children: paints, ); } @override bool get wantKeepAlive => true; } class ImagePaint extends StatefulWidget { final String id; final RxBool zoomCursor; final RxBool cursorOverImage; final RxBool keyboardEnabled; final RxBool remoteCursorMoved; final RxInt textureId; final bool useTextureRender; final Widget Function(Widget)? listenerBuilder; ImagePaint( {Key? key, required this.id, required this.zoomCursor, required this.cursorOverImage, required this.keyboardEnabled, required this.remoteCursorMoved, required this.textureId, required this.useTextureRender, this.listenerBuilder}) : super(key: key); @override State createState() => _ImagePaintState(); } class _ImagePaintState extends State { bool _lastRemoteCursorMoved = false; final ScrollController _horizontal = ScrollController(); final ScrollController _vertical = ScrollController(); String get id => widget.id; RxBool get zoomCursor => widget.zoomCursor; RxBool get cursorOverImage => widget.cursorOverImage; RxBool get keyboardEnabled => widget.keyboardEnabled; RxBool get remoteCursorMoved => widget.remoteCursorMoved; Widget Function(Widget)? get listenerBuilder => widget.listenerBuilder; @override Widget build(BuildContext context) { final m = Provider.of(context); var c = Provider.of(context); final s = c.scale; mouseRegion({child}) => Obx(() { double getCursorScale() { var c = Provider.of(context); var cursorScale = 1.0; if (Platform.isWindows) { // debug win10 final isViewAdaptive = c.viewStyle.style == kRemoteViewStyleAdaptive; if (zoomCursor.value && isViewAdaptive) { cursorScale = s * c.devicePixelRatio; } } else { final isViewOriginal = c.viewStyle.style == kRemoteViewStyleOriginal; if (zoomCursor.value || isViewOriginal) { cursorScale = s; } } return cursorScale; } return MouseRegion( cursor: cursorOverImage.isTrue ? c.cursorEmbedded ? SystemMouseCursors.none : keyboardEnabled.isTrue ? (() { if (remoteCursorMoved.isTrue) { _lastRemoteCursorMoved = true; return SystemMouseCursors.none; } else { if (_lastRemoteCursorMoved) { _lastRemoteCursorMoved = false; _firstEnterImage.value = true; } return _buildCustomCursor( context, getCursorScale()); } }()) : _buildDisabledCursor(context, getCursorScale()) : MouseCursor.defer, onHover: (evt) {}, child: child); }); if (c.imageOverflow.isTrue && c.scrollStyle == ScrollStyle.scrollbar) { final imageWidth = c.getDisplayWidth() * s; final imageHeight = c.getDisplayHeight() * s; final imageSize = Size(imageWidth, imageHeight); late final Widget imageWidget; if (widget.useTextureRender) { imageWidget = SizedBox( width: imageWidth, height: imageHeight, child: Obx(() => Texture(textureId: widget.textureId.value)), ); } else { imageWidget = CustomPaint( size: imageSize, painter: ImagePainter(image: m.image, x: 0, y: 0, scale: s), ); } return NotificationListener( onNotification: (notification) { final percentX = _horizontal.hasClients ? _horizontal.position.extentBefore / (_horizontal.position.extentBefore + _horizontal.position.extentInside + _horizontal.position.extentAfter) : 0.0; final percentY = _vertical.hasClients ? _vertical.position.extentBefore / (_vertical.position.extentBefore + _vertical.position.extentInside + _vertical.position.extentAfter) : 0.0; c.setScrollPercent(percentX, percentY); return false; }, child: mouseRegion( child: Obx(() => _buildCrossScrollbarFromLayout( context, _buildListener(imageWidget), c.size, imageSize)), )); } else { late final Widget imageWidget; if (c.size.width > 0 && c.size.height > 0) { if (widget.useTextureRender) { imageWidget = Stack( children: [ Positioned( left: c.x, top: c.y, width: c.getDisplayWidth() * s, height: c.getDisplayHeight() * s, child: Texture(textureId: widget.textureId.value), ) ], ); } else { imageWidget = CustomPaint( size: Size(c.size.width, c.size.height), painter: ImagePainter(image: m.image, x: c.x / s, y: c.y / s, scale: s), ); } return mouseRegion(child: _buildListener(imageWidget)); } else { return Container(); } } } MouseCursor _buildCursorOfCache( CursorModel cursor, double scale, CursorData? cache) { if (cache == null) { return MouseCursor.defer; } else { final key = cache.updateGetKey(scale); if (!cursor.cachedKeys.contains(key)) { debugPrint("Register custom cursor with key $key"); // [Safety] // It's ok to call async registerCursor in current synchronous context, // because activating the cursor is also an async call and will always // be executed after this. custom_cursor_manager.CursorManager.instance .registerCursor(custom_cursor_manager.CursorData() ..buffer = cache.data! ..height = (cache.height * cache.scale).toInt() ..width = (cache.width * cache.scale).toInt() ..hotX = cache.hotx ..hotY = cache.hoty ..name = key); cursor.addKey(key); } return FlutterCustomMemoryImageCursor(key: key); } } MouseCursor _buildCustomCursor(BuildContext context, double scale) { final cursor = Provider.of(context); final cache = cursor.cache ?? preDefaultCursor.cache; return _buildCursorOfCache(cursor, scale, cache); } MouseCursor _buildDisabledCursor(BuildContext context, double scale) { final cursor = Provider.of(context); final cache = preForbiddenCursor.cache; return _buildCursorOfCache(cursor, scale, cache); } Widget _buildCrossScrollbarFromLayout( BuildContext context, Widget child, Size layoutSize, Size size) { final scrollConfig = CustomMouseWheelScrollConfig( scrollDuration: kDefaultScrollDuration, scrollCurve: Curves.linearToEaseOut, mouseWheelTurnsThrottleTimeMs: kDefaultMouseWheelThrottleDuration.inMilliseconds, scrollAmountMultiplier: kDefaultScrollAmountMultiplier); var widget = child; if (layoutSize.width < size.width) { widget = ScrollConfiguration( behavior: ScrollConfiguration.of(context).copyWith(scrollbars: false), child: SingleChildScrollView( controller: _horizontal, scrollDirection: Axis.horizontal, physics: cursorOverImage.isTrue ? const NeverScrollableScrollPhysics() : null, child: widget, ), ); } else { widget = Row( children: [ Container( width: ((layoutSize.width - size.width) ~/ 2).toDouble(), ), widget, ], ); } if (layoutSize.height < size.height) { widget = ScrollConfiguration( behavior: ScrollConfiguration.of(context).copyWith(scrollbars: false), child: SingleChildScrollView( controller: _vertical, physics: cursorOverImage.isTrue ? const NeverScrollableScrollPhysics() : null, child: widget, ), ); } else { widget = Column( children: [ Container( height: ((layoutSize.height - size.height) ~/ 2).toDouble(), ), widget, ], ); } if (layoutSize.width < size.width) { widget = ImprovedScrolling( scrollController: _horizontal, enableCustomMouseWheelScrolling: cursorOverImage.isFalse, customMouseWheelScrollConfig: scrollConfig, child: RawScrollbar( thumbColor: Colors.grey, controller: _horizontal, thumbVisibility: false, trackVisibility: false, notificationPredicate: layoutSize.height < size.height ? (notification) => notification.depth == 1 : defaultScrollNotificationPredicate, child: widget, ), ); } if (layoutSize.height < size.height) { widget = ImprovedScrolling( scrollController: _vertical, enableCustomMouseWheelScrolling: cursorOverImage.isFalse, customMouseWheelScrollConfig: scrollConfig, child: RawScrollbar( thumbColor: Colors.grey, controller: _vertical, thumbVisibility: false, trackVisibility: false, child: widget, ), ); } return widget; } Widget _buildListener(Widget child) { if (listenerBuilder != null) { return listenerBuilder!(child); } else { return child; } } } class CursorPaint extends StatelessWidget { final String id; final RxBool zoomCursor; const CursorPaint({ Key? key, required this.id, required this.zoomCursor, }) : super(key: key); @override Widget build(BuildContext context) { final m = Provider.of(context); final c = Provider.of(context); double hotx = m.hotx; double hoty = m.hoty; if (m.image == null) { if (preDefaultCursor.image != null) { hotx = preDefaultCursor.image!.width / 2; hoty = preDefaultCursor.image!.height / 2; } } double cx = c.x; double cy = c.y; if (c.viewStyle.style == kRemoteViewStyleOriginal && c.scrollStyle == ScrollStyle.scrollbar) { final d = c.parent.target!.ffiModel.display; final imageWidth = d.width * c.scale; final imageHeight = d.height * c.scale; cx = -imageWidth * c.scrollX; cy = -imageHeight * c.scrollY; } double x = (m.x - hotx) * c.scale + cx; double y = (m.y - hoty) * c.scale + cy; double scale = 1.0; final isViewOriginal = c.viewStyle.style == kRemoteViewStyleOriginal; if (zoomCursor.value || isViewOriginal) { x = m.x - hotx + cx / c.scale; y = m.y - hoty + cy / c.scale; scale = c.scale; } return CustomPaint( painter: ImagePainter( image: m.image ?? preDefaultCursor.image, x: x, y: y, scale: scale, ), ); } }