pkg mgr support zypper pacman opkg

This commit is contained in:
lollipopkit
2023-01-27 19:19:11 +08:00
parent 092c3f522a
commit 7c84957230
5 changed files with 82 additions and 37 deletions

Binary file not shown.

Before

Width:  |  Height:  |  Size: 289 KiB

View File

@@ -0,0 +1 @@
enum PkgManager { apt, yum, zypper, pacman, opkg }

View File

@@ -1,30 +1,37 @@
import 'package:toolbox/data/model/server/dist.dart'; import 'package:toolbox/data/model/pkg/manager.dart';
class UpgradePkgInfo { class UpgradePkgInfo {
final String _raw; final PkgManager? _mgr;
final Dist _dist;
late String package; late String package;
late String nowVersion; late String nowVersion;
late String newVersion; late String newVersion;
late String arch; late String arch;
UpgradePkgInfo(this._raw, this._dist) { UpgradePkgInfo(String raw, this._mgr) {
switch (_dist) { switch (_mgr) {
case Dist.debian: case PkgManager.apt:
case Dist.ubuntu: _parseApt(raw);
_parseApt();
break; break;
case Dist.centos: case PkgManager.yum:
_parseYum(); _parseYum(raw);
break;
case PkgManager.zypper:
_parseZypper(raw);
break;
case PkgManager.pacman:
_parsePacman(raw);
break;
case PkgManager.opkg:
_parseOpkg(raw);
break; break;
default: default:
throw Exception('Unsupported dist: $_dist'); throw Exception('Unsupported pkg type: $_mgr');
} }
} }
void _parseApt() { void _parseApt(String raw) {
final split1 = _raw.split("/"); final split1 = raw.split("/");
package = split1[0]; package = split1[0];
final split2 = split1[1].split(" "); final split2 = split1[1].split(" ");
newVersion = split2[1]; newVersion = split2[1];
@@ -32,8 +39,8 @@ class UpgradePkgInfo {
nowVersion = split2[5].replaceFirst(']', ''); nowVersion = split2[5].replaceFirst(']', '');
} }
void _parseYum() { void _parseYum(String raw) {
final result = RegExp(r'\S+').allMatches(_raw); final result = RegExp(r'\S+').allMatches(raw);
final pkgAndArch = result.elementAt(0).group(0) ?? '.'; final pkgAndArch = result.elementAt(0).group(0) ?? '.';
final split1 = pkgAndArch.split('.'); final split1 = pkgAndArch.split('.');
package = split1[0]; package = split1[0];
@@ -41,4 +48,28 @@ class UpgradePkgInfo {
newVersion = result.elementAt(1).group(0) ?? 'Unknown'; newVersion = result.elementAt(1).group(0) ?? 'Unknown';
nowVersion = ''; nowVersion = '';
} }
void _parseZypper(String raw) {
final cols = raw.split("|");
package = cols[2].trim();
nowVersion = cols[3].trim();
newVersion = cols[4].trim();
arch = cols[5].trim();
}
void _parsePacman(String raw) {
final parts = raw.split(' ');
package = parts[0];
nowVersion = parts[1];
newVersion = parts[3];
arch = '';
}
void _parseOpkg(String raw) {
final parts = raw.split(' - ');
package = parts[0];
nowVersion = parts[1];
newVersion = parts[2];
arch = '';
}
} }

View File

@@ -8,7 +8,6 @@ enum Dist {
wrt, wrt,
armbian, armbian,
arch, arch,
freebsd,
/// Rocky Linux /// Rocky Linux
rocky; rocky;

View File

@@ -7,17 +7,16 @@ import 'package:toolbox/core/extension/ssh_client.dart';
import 'package:toolbox/core/extension/stringx.dart'; import 'package:toolbox/core/extension/stringx.dart';
import 'package:toolbox/core/extension/uint8list.dart'; import 'package:toolbox/core/extension/uint8list.dart';
import 'package:toolbox/core/provider_base.dart'; import 'package:toolbox/core/provider_base.dart';
import 'package:toolbox/data/model/pkg/manager.dart';
import 'package:toolbox/data/model/pkg/upgrade_info.dart'; import 'package:toolbox/data/model/pkg/upgrade_info.dart';
import 'package:toolbox/data/model/server/dist.dart'; import 'package:toolbox/data/model/server/dist.dart';
enum _Type { apt, yum, dnf, zypper, pkg, pacman, opkg }
class PkgProvider extends BusyProvider { class PkgProvider extends BusyProvider {
final logger = Logger('PKG'); final logger = Logger('PKG');
SSHClient? client; SSHClient? client;
Dist? dist; Dist? dist;
_Type? type; PkgManager? type;
Function()? onUpgrade; Function()? onUpgrade;
Function()? onUpdate; Function()? onUpdate;
PwdRequestFunc? onPasswordRequest; PwdRequestFunc? onPasswordRequest;
@@ -48,28 +47,23 @@ class PkgProvider extends BusyProvider {
switch (dist) { switch (dist) {
case Dist.centos: case Dist.centos:
case Dist.rocky: case Dist.rocky:
type = _Type.yum; case Dist.fedora:
type = PkgManager.yum;
break; break;
case Dist.debian: case Dist.debian:
case Dist.ubuntu: case Dist.ubuntu:
case Dist.kali: case Dist.kali:
case Dist.armbian: case Dist.armbian:
type = _Type.apt; type = PkgManager.apt;
break;
case Dist.fedora:
type = _Type.dnf;
break; break;
case Dist.opensuse: case Dist.opensuse:
type = _Type.zypper; type = PkgManager.zypper;
break;
case Dist.freebsd:
type = _Type.pkg;
break; break;
case Dist.wrt: case Dist.wrt:
type = _Type.opkg; type = PkgManager.opkg;
break; break;
case Dist.arch: case Dist.arch:
type = _Type.pacman; type = PkgManager.pacman;
break; break;
case null: case null:
error = 'Unsupported dist: $dist'; error = 'Unsupported dist: $dist';
@@ -100,14 +94,14 @@ class PkgProvider extends BusyProvider {
if (raw == null) return; if (raw == null) return;
var list = raw.split('\n'); var list = raw.split('\n');
switch (type) { switch (type) {
case _Type.yum: case PkgManager.yum:
list = list.sublist(2); list = list.sublist(2);
list.removeWhere((element) => element.isEmpty); list.removeWhere((element) => element.isEmpty);
final endLine = list.lastIndexWhere( final endLine = list.lastIndexWhere(
(element) => element.contains('Obsoleting Packages')); (element) => element.contains('Obsoleting Packages'));
list = list.sublist(0, endLine); list = list.sublist(0, endLine);
break; break;
case _Type.apt: case PkgManager.apt:
// avoid other outputs // avoid other outputs
// such as: [Could not chdir to home directory /home/test: No such file or directory, , WARNING: apt does not have a stable CLI interface. Use with caution in scripts., , Listing...] // such as: [Could not chdir to home directory /home/test: No such file or directory, , WARNING: apt does not have a stable CLI interface. Use with caution in scripts., , Listing...]
final idx = final idx =
@@ -119,17 +113,23 @@ class PkgProvider extends BusyProvider {
list = list.sublist(idx); list = list.sublist(idx);
list.removeWhere((element) => element.isEmpty); list.removeWhere((element) => element.isEmpty);
break; break;
case PkgManager.zypper:
list = list.sublist(4);
break;
case PkgManager.pacman:
case PkgManager.opkg:
break;
default: default:
return; return;
} }
upgradeable = list.map((e) => UpgradePkgInfo(e, dist!)).toList(); upgradeable = list.map((e) => UpgradePkgInfo(e, type)).toList();
} }
Future<String?> _update() async { Future<String?> _update() async {
switch (type) { switch (type) {
case _Type.yum: case PkgManager.yum:
return await client?.run(_wrap('yum check-update')).string; return await client?.run(_wrap('yum check-update')).string;
case _Type.apt: case PkgManager.apt:
await client!.exec( await client!.exec(
_wrap('apt update'), _wrap('apt update'),
onStderr: _onPwd, onStderr: _onPwd,
@@ -142,6 +142,14 @@ class PkgProvider extends BusyProvider {
return await client return await client
?.run('apt list --upgradeable'.withLangExport) ?.run('apt list --upgradeable'.withLangExport)
.string; .string;
case PkgManager.zypper:
return await client?.run(_wrap('zypper lu')).string;
case PkgManager.pacman:
await client?.run('pacman -Sy');
return await client?.run(_wrap('pacman -Qu')).string;
case PkgManager.opkg:
await client?.run('opkg update');
return await client?.run(_wrap('opkg list-upgradable')).string;
default: default:
error = 'Unsupported dist: $dist'; error = 'Unsupported dist: $dist';
return null; return null;
@@ -151,10 +159,16 @@ class PkgProvider extends BusyProvider {
Future<void> upgrade() async { Future<void> upgrade() async {
final upgradeCmd = () { final upgradeCmd = () {
switch (type) { switch (type) {
case _Type.yum: case PkgManager.yum:
return 'yum upgrade -y'; return 'yum upgrade -y';
case _Type.apt: case PkgManager.apt:
return 'apt upgrade -y'; return 'apt upgrade -y';
case PkgManager.zypper:
return 'zypper up -y';
case PkgManager.pacman:
return 'pacman -Syu --noconfirm';
case PkgManager.opkg:
return 'opkg upgrade ${upgradeable?.map((e) => e.package).join(" ")}';
default: default:
return null; return null;
} }