import 'dart:async'; import 'package:flutter/foundation.dart'; import 'package:flutter/material.dart'; import 'package:flutter_hbb/desktop/widgets/scroll_wrapper.dart'; import 'package:get/get.dart'; import 'package:provider/provider.dart'; import 'package:visibility_detector/visibility_detector.dart'; import 'package:window_manager/window_manager.dart'; import '../../common.dart'; import '../../models/peer_model.dart'; import '../../models/platform_model.dart'; import 'peercard_widget.dart'; typedef OffstageFunc = bool Function(Peer peer); typedef PeerCardWidgetFunc = Widget Function(Peer peer); /// for peer search text, global obs value final peerSearchText = "".obs; final peerSearchTextController = TextEditingController(text: peerSearchText.value); class _PeerWidget extends StatefulWidget { final Peers peers; final OffstageFunc offstageFunc; final PeerCardWidgetFunc peerCardWidgetFunc; const _PeerWidget( {required this.peers, required this.offstageFunc, required this.peerCardWidgetFunc, Key? key}) : super(key: key); @override _PeerWidgetState createState() => _PeerWidgetState(); } /// State for the peer widget. class _PeerWidgetState extends State<_PeerWidget> with WindowListener { static const int _maxQueryCount = 3; final space = isDesktop ? 12.0 : 8.0; final _curPeers = {}; final _scrollController = ScrollController(); var _lastChangeTime = DateTime.now(); var _lastQueryPeers = {}; var _lastQueryTime = DateTime.now().subtract(const Duration(hours: 1)); var _queryCoun = 0; var _exit = false; late final mobileWidth = () { const minWidth = 320.0; final windowWidth = MediaQuery.of(context).size.width; var width = windowWidth - 2 * space; if (windowWidth > minWidth + 2 * space) { final n = (windowWidth / (minWidth + 2 * space)).floor(); width = windowWidth / n - 2 * space; } return width; }(); _PeerWidgetState() { _startCheckOnlines(); } @override void initState() { windowManager.addListener(this); super.initState(); } @override void dispose() { windowManager.removeListener(this); _exit = true; super.dispose(); } @override void onWindowFocus() { _queryCoun = 0; } @override void onWindowMinimize() { _queryCoun = _maxQueryCount; } @override Widget build(BuildContext context) { return ChangeNotifierProvider( create: (context) => widget.peers, child: Consumer( builder: (context, peers, child) => peers.peers.isEmpty ? Center( child: Text(translate("Empty")), ) : _buildPeersView(peers)), ); } Widget _buildPeersView(Peers peers) { final body = ObxValue((searchText) { return FutureBuilder>( builder: (context, snapshot) { if (snapshot.hasData) { final peers = snapshot.data!; final cards = []; for (final peer in peers) { final visibilityChild = VisibilityDetector( key: ValueKey(peer.id), onVisibilityChanged: (info) { final peerId = (info.key as ValueKey).value; if (info.visibleFraction > 0.00001) { _curPeers.add(peerId); } else { _curPeers.remove(peerId); } _lastChangeTime = DateTime.now(); }, child: widget.peerCardWidgetFunc(peer), ); cards.add(Offstage( key: ValueKey("off${peer.id}"), offstage: widget.offstageFunc(peer), child: isDesktop ? Obx( () => SizedBox( width: 220, height: peerCardUiType.value == PeerUiType.grid ? 140 : 42, child: visibilityChild, ), ) : SizedBox(width: mobileWidth, child: visibilityChild))); } return Wrap(spacing: space, runSpacing: space, children: cards); } else { return const Center( child: CircularProgressIndicator(), ); } }, future: matchPeers(searchText.value, peers.peers), ); }, peerSearchText); if (isDesktop) { return DesktopScrollWrapper( scrollController: _scrollController, child: SingleChildScrollView( physics: NeverScrollableScrollPhysics(), controller: _scrollController, child: body), ); } else { return SingleChildScrollView( physics: BouncingScrollPhysics(), controller: _scrollController, child: body, ); } } // ignore: todo // TODO: variables walk through async tasks? void _startCheckOnlines() { () async { while (!_exit) { final now = DateTime.now(); if (!setEquals(_curPeers, _lastQueryPeers)) { if (now.difference(_lastChangeTime) > const Duration(seconds: 1)) { if (_curPeers.isNotEmpty) { platformFFI.ffiBind .queryOnlines(ids: _curPeers.toList(growable: false)); _lastQueryPeers = {..._curPeers}; _lastQueryTime = DateTime.now(); _queryCoun = 0; } } } else { if (_queryCoun < _maxQueryCount) { if (now.difference(_lastQueryTime) > const Duration(seconds: 20)) { if (_curPeers.isNotEmpty) { platformFFI.ffiBind .queryOnlines(ids: _curPeers.toList(growable: false)); _lastQueryTime = DateTime.now(); _queryCoun += 1; } } } } await Future.delayed(const Duration(milliseconds: 300)); } }(); } } abstract class BasePeerWidget extends StatelessWidget { final String name; final String loadEvent; final OffstageFunc offstageFunc; final PeerCardWidgetFunc peerCardWidgetFunc; final List initPeers; const BasePeerWidget({ Key? key, required this.name, required this.loadEvent, required this.offstageFunc, required this.peerCardWidgetFunc, required this.initPeers, }) : super(key: key); @override Widget build(BuildContext context) { return _PeerWidget( peers: Peers(name: name, loadEvent: loadEvent, peers: initPeers), offstageFunc: offstageFunc, peerCardWidgetFunc: peerCardWidgetFunc); } } class RecentPeerWidget extends BasePeerWidget { RecentPeerWidget({Key? key}) : super( key: key, name: 'recent peer', loadEvent: 'load_recent_peers', offstageFunc: (Peer peer) => false, peerCardWidgetFunc: (Peer peer) => RecentPeerCard( peer: peer, ), initPeers: [], ); @override Widget build(BuildContext context) { final widget = super.build(context); bind.mainLoadRecentPeers(); return widget; } } class FavoritePeerWidget extends BasePeerWidget { FavoritePeerWidget({Key? key}) : super( key: key, name: 'favorite peer', loadEvent: 'load_fav_peers', offstageFunc: (Peer peer) => false, peerCardWidgetFunc: (Peer peer) => FavoritePeerCard( peer: peer, ), initPeers: [], ); @override Widget build(BuildContext context) { final widget = super.build(context); bind.mainLoadFavPeers(); return widget; } } class DiscoveredPeerWidget extends BasePeerWidget { DiscoveredPeerWidget({Key? key}) : super( key: key, name: 'discovered peer', loadEvent: 'load_lan_peers', offstageFunc: (Peer peer) => false, peerCardWidgetFunc: (Peer peer) => DiscoveredPeerCard( peer: peer, ), initPeers: [], ); @override Widget build(BuildContext context) { final widget = super.build(context); bind.mainLoadLanPeers(); return widget; } } class AddressBookPeerWidget extends BasePeerWidget { AddressBookPeerWidget({Key? key}) : super( key: key, name: 'address book peer', loadEvent: 'load_address_book_peers', offstageFunc: (Peer peer) => !_hitTag(gFFI.abModel.selectedTags, peer.tags), peerCardWidgetFunc: (Peer peer) => AddressBookPeerCard( peer: peer, ), initPeers: _loadPeers(), ); static List _loadPeers() { debugPrint("_loadPeers : ${gFFI.abModel.peers.toString()}"); return gFFI.abModel.peers.map((e) { return Peer.fromJson(e['id'], e); }).toList(); } static bool _hitTag(List selectedTags, List idents) { if (selectedTags.isEmpty) { return true; } if (idents.isEmpty) { return false; } for (final tag in selectedTags) { if (!idents.contains(tag)) { return false; } } return true; } @override Widget build(BuildContext context) { final widget = super.build(context); // gFFI.abModel.updateAb(); return widget; } }