import 'dart:async'; import 'package:logging/logging.dart'; import 'package:flutter_riverpod/flutter_riverpod.dart'; import 'package:window_manager/window_manager.dart'; import '../core/state.dart'; import '../app/models.dart'; import 'models.dart'; import 'rpc.dart'; // This must be initialized before use in initialize.dart. final rpcProvider = Provider((ref) { throw UnimplementedError(); }); final rpcStateProvider = StateNotifierProvider<_RpcStateNotifier, RpcState>( (ref) { final rpc = ref.watch(rpcProvider); ref.listen(logLevelProvider, (_, level) { rpc.setLogLevel(level); }, fireImmediately: true); return _RpcStateNotifier(rpc); }, ); class _RpcStateNotifier extends StateNotifier { final RpcSession rpc; _RpcStateNotifier(this.rpc) : super(const RpcState('unknown')) { _init(); } _init() async { final response = await rpc.command('get', []); if (mounted) { state = state.copyWith(version: response['data']['version']); } } } final _windowStateProvider = StateNotifierProvider<_WindowStateNotifier, WindowState>( (ref) => _WindowStateNotifier()); final desktopWindowStateProvider = Provider( (ref) => ref.watch(_windowStateProvider), ); class _WindowStateNotifier extends StateNotifier with WindowListener { Timer? _idleTimer; _WindowStateNotifier() : super(WindowState(focused: true, visible: true, active: true)) { _init(); } void _init() async { windowManager.addListener(this); if (!await windowManager.isVisible() && mounted) { state = WindowState(focused: false, visible: false, active: true); _idleTimer = Timer(const Duration(seconds: 5), () { if (mounted) { state = state.copyWith(active: false); } }); } } @override void dispose() { windowManager.removeListener(this); super.dispose(); } @override set state(WindowState value) { log.config('Window state changed: $value'); super.state = value; } @override void onWindowEvent(String eventName) { if (mounted) { switch (eventName) { case 'blur': state = state.copyWith(focused: false); _idleTimer?.cancel(); _idleTimer = Timer(const Duration(seconds: 5), () { if (mounted) { state = state.copyWith(active: false); } }); break; case 'focus': state = state.copyWith(focused: true, active: true); _idleTimer?.cancel(); break; case 'minimize': state = state.copyWith(visible: false, active: false); _idleTimer?.cancel(); break; case 'restore': state = state.copyWith(visible: true, active: true); break; default: log.fine('Window event ignored: $eventName'); } } } }