flutter_server_box/lib/view/page/ping.dart

import 'dart:async';

import 'package:fl_lib/fl_lib.dart';
import 'package:flutter/material.dart';
import 'package:flutter_riverpod/flutter_riverpod.dart';
import 'package:server_box/core/extension/context/locale.dart';
import 'package:server_box/data/model/server/ping_result.dart';
import 'package:server_box/data/provider/server/all.dart';
import 'package:server_box/data/provider/server/single.dart';

/// Only permit ipv4 / ipv6 / domain chars
final targetReg = RegExp(r'[a-zA-Z0-9\.-_:]+');

class PingPage extends ConsumerStatefulWidget {
  const PingPage({super.key});

  @override
  ConsumerState<PingPage> createState() => _PingPageState();

  static const route = AppRouteNoArg(page: PingPage.new, path: '/ping');
}

class _PingPageState extends ConsumerState<PingPage> with AutomaticKeepAliveClientMixin {
  late TextEditingController _textEditingController;
  final _results = ValueNotifier(<PingResult>[]);
  bool get isInit => _results.value.isEmpty;

  @override
  void dispose() {
    super.dispose();
    _textEditingController.dispose();
    _results.dispose();
  }

  @override
  void initState() {
    super.initState();
    _textEditingController = TextEditingController(text: '');
  }

  @override
  Widget build(BuildContext context) {
    super.build(context);
    return Scaffold(body: _results.listenVal(_buildBody), floatingActionButton: _buildFAB());
  }

  Widget _buildFAB() {
    return FloatingActionButton(
      heroTag: 'ping',
      onPressed: () {
        context.showRoundDialog(
          title: libL10n.select,
          child: Input(
            autoFocus: true,
            controller: _textEditingController,
            hint: 'example.com',
            maxLines: 2,
            minLines: 1,
            onSubmitted: (_) => _doPing(),
          ),
          actions: Btn.ok(onTap: _doPing).toList,
        );
      },
      child: const Icon(Icons.search),
    );
  }

  Future<void> _doPing() async {
    context.pop();
    try {
      await doPing();
    } catch (e) {
      context.showRoundDialog(
        title: libL10n.error,
        child: Text(e.toString()),
        actions: [TextButton(onPressed: () => Pfs.copy(e.toString()), child: Text(libL10n.copy))],
      );
      rethrow;
    }
  }

  Widget _buildBody(List<PingResult> results) {
    if (isInit) {
      return Center(child: Text(libL10n.empty));
    }
    return ListView.builder(
      padding: const EdgeInsets.all(11),
      controller: ScrollController(),
      itemCount: results.length,
      itemBuilder: (_, index) => _buildResultItem(results[index]),
    );
  }

  Widget _buildResultItem(PingResult result) {
    final unknown = l10n.unknown;
    final ms = l10n.ms;
    return CardX(
      child: ListTile(
        contentPadding: const EdgeInsets.symmetric(vertical: 7, horizontal: 17),
        title: Text(
          result.serverName,
          style: TextStyle(fontSize: 18, fontWeight: FontWeight.bold, color: UIs.primaryColor),
        ),
        subtitle: Text(_buildPingSummary(result, unknown, ms), style: UIs.text11),
        trailing: Text(
          '${l10n.pingAvg}${result.statistic?.avg?.toStringAsFixed(2) ?? l10n.unknown} $ms',
          style: TextStyle(fontSize: 14, color: UIs.primaryColor),
        ),
      ),
    );
  }

  String _buildPingSummary(PingResult result, String unknown, String ms) {
    final ip = result.ip ?? unknown;
    if (result.results == null || result.results!.isEmpty) {
      return '$ip - ${libL10n.empty}';
    }
    final ttl = result.results?.firstOrNull?.ttl ?? unknown;
    final loss = result.statistic?.loss ?? unknown;
    final min = result.statistic?.min ?? unknown;
    final max = result.statistic?.max ?? unknown;
    return '$ip\n${l10n.ttl}: $ttl, ${l10n.loss}: $loss%\n${l10n.min}: $min $ms, ${l10n.max}: $max $ms';
  }

  Future<void> doPing() async {
    FocusScope.of(context).requestFocus(FocusNode());
    _results.value.clear();
    final target = _textEditingController.text.trim();
    if (target.isEmpty) {
      context.showSnackBar(l10n.pingInputIP);
      return;
    }

    if (ref.read(serversProvider).serverOrder.isEmpty) {
      context.showSnackBar(l10n.pingNoServer);
      return;
    }

    /// avoid ping command injection
    if (!targetReg.hasMatch(target)) {
      context.showSnackBar(l10n.pingInputIP);
      return;
    }

    await Future.wait(
      ref.read(serversProvider).servers.values.map((spi) async {
        final serverState = ref.read(serverProvider(spi.id));
        if (serverState.client == null) {
          return;
        }
        final result = await serverState.client!.run('ping -c 3 $target').string;
        _results.value.add(PingResult.parse(spi.name, result));
        // [ValueNotifier] only notify when value is changed
        // But we just add a element to list without changing the list itself
        // So we need to notify manually
        //
        // ignore: invalid_use_of_protected_member, invalid_use_of_visible_for_testing_member
        _results.notifyListeners();
      }),
    );
  }

  @override
  bool get wantKeepAlive => true;
}