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';
}