opt.: use ssh term to upgrade pkg

lib/data/model/pkg/manager.dart

@@ -92,28 +92,28 @@ enum PkgManager {
     list.removeWhere((element) => element.isEmpty);
     return list;
   }
-}
 
-PkgManager? fromDist(Dist? dist) {
-  switch (dist) {
-    case Dist.centos:
-    case Dist.rocky:
-    case Dist.fedora:
-      return PkgManager.yum;
-    case Dist.debian:
-    case Dist.ubuntu:
-    case Dist.kali:
-    case Dist.armbian:
-      return PkgManager.apt;
-    case Dist.opensuse:
-      return PkgManager.zypper;
-    case Dist.wrt:
-      return PkgManager.opkg;
-    case Dist.arch:
-      return PkgManager.pacman;
-    case Dist.alpine:
-      return PkgManager.apk;
-    default:
-      return null;
+  static PkgManager? fromDist(Dist? dist) {
+    switch (dist) {
+      case Dist.centos:
+      case Dist.rocky:
+      case Dist.fedora:
+        return PkgManager.yum;
+      case Dist.debian:
+      case Dist.ubuntu:
+      case Dist.kali:
+      case Dist.armbian:
+        return PkgManager.apt;
+      case Dist.opensuse:
+        return PkgManager.zypper;
+      case Dist.wrt:
+        return PkgManager.opkg;
+      case Dist.arch:
+        return PkgManager.pacman;
+      case Dist.alpine:
+        return PkgManager.apk;
+      default:
+        return null;
+    }
   }
 }

lib/data/model/server/dist.dart

@@ -20,6 +20,17 @@ extension StringX on String {
         return dist;
       }
     }
+    for (final wrt in _wrts) {
+      if (lower.contains(wrt)) {
+        return Dist.wrt;
+      }
+    }
     return null;
   }
 }
+
+// Special rules
+
+const _wrts = [
+  'istoreos',
+];

lib/data/provider/pkg.dart

@@ -1,121 +0,0 @@
-import 'dart:async';
-
-import 'package:dartssh2/dartssh2.dart';
-import 'package:flutter/material.dart';
-import 'package:logging/logging.dart';
-import 'package:toolbox/core/extension/ssh_client.dart';
-import 'package:toolbox/core/extension/uint8list.dart';
-import 'package:toolbox/data/model/pkg/manager.dart';
-import 'package:toolbox/data/model/pkg/upgrade_info.dart';
-import 'package:toolbox/data/model/server/dist.dart';
-
-class PkgProvider extends ChangeNotifier {
-  final logger = Logger('PKG');
-
-  SSHClient? client;
-  Dist? dist;
-  PkgManager? type;
-  Function()? onUpgrade;
-  Function()? onUpdate;
-  BuildContext? context;
-
-  String? whoami;
-  List<UpgradePkgInfo>? upgradeable;
-  String? error;
-  String? upgradeLog;
-  String? updateLog;
-  String lastLog = '';
-
-  Future<void> init(
-    SSHClient client,
-    Dist? dist,
-    Function() onUpgrade,
-    Function() onUpdate,
-    String user,
-    BuildContext context,
-  ) async {
-    this.client = client;
-    this.dist = dist;
-    this.onUpgrade = onUpgrade;
-    whoami = user;
-
-    type = fromDist(dist);
-    if (type == null) {
-      error = 'Unsupported dist: $dist';
-    }
-  }
-
-  bool get isSU => whoami == 'root';
-
-  void clear() {
-    client = dist = updateLog = upgradeLog =
-        upgradeable = error = whoami = onUpdate = onUpgrade = context = null;
-  }
-
-  Future<void> refresh() async {
-    final result = await _update();
-    try {
-      _parse(result);
-    } catch (e) {
-      error = '[Server Raw]:\n$result\n[App Error]:\n$e';
-      rethrow;
-    } finally {
-      notifyListeners();
-    }
-  }
-
-  void _parse(String? raw) {
-    if (raw == null) return;
-    final list = type?.updateListRemoveUnused(raw.split('\n'));
-    upgradeable = list?.map((e) => UpgradePkgInfo(e, type)).toList();
-  }
-
-  Future<String?> _update() async {
-    final updateCmd = type?.update;
-    if (updateCmd != null) {
-      await client!.execWithPwd(
-        _wrap(updateCmd),
-        context: context,
-        onStdout: (data, sink) {
-          updateLog = (updateLog ?? '') + data;
-          if (onUpdate != null) onUpdate!();
-          notifyListeners();
-        },
-      );
-    }
-    final listCmd = type?.listUpdate;
-    if (listCmd == null) {
-      error = 'Unsupported dist: $dist';
-      return null;
-    }
-    return await client?.run(_wrap(listCmd)).string;
-  }
-
-  Future<void> upgrade() async {
-    final upgradeCmd =
-        type?.upgrade(upgradeable?.map((e) => e.package).join(" ") ?? '');
-
-    if (upgradeCmd == null) {
-      error = 'Unsupported dist: $dist';
-      return;
-    }
-
-    await client!.execWithPwd(
-      _wrap(upgradeCmd),
-      context: context,
-      onStdout: (log, sink) {
-        if (lastLog == log.trim()) return;
-        upgradeLog = (upgradeLog ?? '') + log;
-        lastLog = log.trim();
-        notifyListeners();
-        if (onUpgrade != null) onUpgrade!();
-      },
-    );
-
-    upgradeLog = null;
-    refresh();
-  }
-
-  String _wrap(String cmd) =>
-      'export LANG=en_US.utf-8 && ${isSU ? "" : "sudo -S "}$cmd';
-}