rustdesk/lib/models/file_model.dart

import 'dart:convert';
import 'dart:io';
import 'dart:typed_data';

import 'package:file_manager/enums/sort_by.dart';
import 'package:flutter/material.dart';

import 'model.dart';

//  BIG TODO  remove file manager !


// enum FileType {
//   Dir = 0,
//   DirLink = 2,
//   DirDrive = 3,
//   File = 4,
//   FileLink = 5,
// }

class FileDirectory {
  // List<Entry> entries = [];
  List<RemoteFileSystemEntity> entries = [];
  int id = 0;
  String path = "";

  FileDirectory();

  FileDirectory.fromJson(Map<String, dynamic> json,SortBy sort) {
    id = json['id'];
    path = json['path'];
    if (json['entries'] != null) {
      entries = <RemoteFileSystemEntity>[];
      json['entries'].forEach((v) {
        entries.add(new Entry.fromJson(v).toRemoteFileSystemEntity(path));
      });
      entries = _sortRemoteEntitiesList(entries, sort);
    }
  }

  changeSortStyle(SortBy sort){
    entries = _sortRemoteEntitiesList(entries, sort);
  }

  // Map<String, dynamic> toJson() {
  //   final Map<String, dynamic> data = new Map<String, dynamic>();
  //   data['entries'] = this.entries.map((v) => v.toJson()).toList();
  //   data['id'] = this.id;
  //   data['path'] = this.path;
  //   return data;
  // }

  clear() {
    entries = [];
    id = 0;
    path = "";
  }
}

class Entry {
  int entryType = 4;
  int modifiedTime = 0;
  String name = "";
  int size = 0;

  Entry();

  Entry.fromJson(Map<String, dynamic> json) {
    entryType = json['entry_type'];
    modifiedTime = json['modified_time'];
    name = json['name'];
    size = json['size'];
  }

  RemoteFileSystemEntity toRemoteFileSystemEntity(String parentPath) {
    return RemoteFileSystemEntity.from("$parentPath/$name", entryType, modifiedTime, size);
  }

  Map<String, dynamic> toJson() {
    final Map<String, dynamic> data = new Map<String, dynamic>();
    data['entry_type'] = this.entryType;
    data['modified_time'] = this.modifiedTime;
    data['name'] = this.name;
    data['size'] = this.size;
    return data;
  }
}

// TODO 使用工厂单例模式

class RemoteFileModel extends ChangeNotifier {

  SortBy _sortStyle = SortBy.name;
  SortBy get sortStyle => _sortStyle;

  FileDirectory _currentRemoteDir = FileDirectory();
  FileDirectory get currentRemoteDir => _currentRemoteDir;

  tryUpdateRemoteDir(String fd) {
    debugPrint("tryUpdateRemoteDir:$fd");
    try {
      final fileDir = FileDirectory.fromJson(jsonDecode(fd),_sortStyle);
      _currentRemoteDir = fileDir;
      debugPrint("_currentRemoteDir:${_currentRemoteDir.path}");
      notifyListeners();
    } catch (e) {
      debugPrint("tryUpdateRemoteDir fail:$fd");
    }
  }

  goToParentDirectory() {
    var parentPath = "";
    if (_currentRemoteDir.path == "") {
      parentPath = "";
    } else {
      parentPath = Directory(_currentRemoteDir.path).parent.path;
    }
    FFI.setByName("read_remote_dir", parentPath);
  }

  changeSortStyle(SortBy sort){
    _currentRemoteDir.changeSortStyle(sort);
    notifyListeners();
  }

  @override
  void dispose() {
    _currentRemoteDir.clear();
    super.dispose();
  }
}

// int entryType = 4;
// int modifiedTime = 0;
// String name = "";
// int size = 0;

class RemoteFileSystemEntity extends FileSystemEntity {
  int entryType;
  int modifiedTime;
  String path;
  int size;

  RemoteFileSystemEntity(this.path,
      this.entryType,
      this.modifiedTime,
      this.size);


  // 工厂模式 自动输出两个类型
  factory RemoteFileSystemEntity.from(
     String path,
     int entryType,
     int modifiedTime,
     int size
  ) {
    if (entryType > 3) {
      return RemoteFile(path,
          entryType,
          modifiedTime,
          size);
    } else {
      return RemoteFile(path,
          entryType,
          modifiedTime,
          size);
    }
  }

  DateTime lastModifiedSync() {
    return DateTime.fromMillisecondsSinceEpoch(modifiedTime * 1000);
  }

  int lengthSync() {
    return size;
  }

  bool isFile(){
    return entryType > 3;
  }

  @override
  // TODO: implement absolute
  FileSystemEntity get absolute => throw UnimplementedError();

  @override
  Future<bool> exists() {
    // TODO: implement exists
    throw UnimplementedError();
  }

  @override
  bool existsSync() {
    // TODO: implement existsSync
    throw UnimplementedError();
  }

  @override
  Future<FileSystemEntity> rename(String newPath) {
    // TODO: implement rename
    throw UnimplementedError();
  }

  @override
  FileSystemEntity renameSync(String newPath) {
    // TODO: implement renameSync
    throw UnimplementedError();
  }
}

class RemoteDir extends RemoteFileSystemEntity implements Directory {
  RemoteDir(path, entryType, modifiedTime, size)
      : super(path, entryType, modifiedTime, size);

  @override
  // TODO: implement absolute
  Directory get absolute => throw UnimplementedError();

  @override
  Future<Directory> create({bool recursive = false}) {
    // TODO: implement create
    throw UnimplementedError();
  }

  @override
  void createSync({bool recursive = false}) {
    // TODO: implement createSync
  }

  @override
  Future<Directory> createTemp([String? prefix]) {
    // TODO: implement createTemp
    throw UnimplementedError();
  }

  @override
  Directory createTempSync([String? prefix]) {
    // TODO: implement createTempSync
    throw UnimplementedError();
  }

  @override
  Future<bool> exists() {
    // TODO: implement exists
    throw UnimplementedError();
  }

  @override
  bool existsSync() {
    // TODO: implement existsSync
    throw UnimplementedError();
  }

  @override
  Stream<FileSystemEntity> list(
      {bool recursive = false, bool followLinks = true}) {
    // TODO: implement list
    throw UnimplementedError();
  }

  @override
  List<FileSystemEntity> listSync(
      {bool recursive = false, bool followLinks = true}) {
    // TODO: implement listSync
    throw UnimplementedError();
  }

  @override
  Future<Directory> rename(String newPath) {
    // TODO: implement rename
    throw UnimplementedError();
  }

  @override
  Directory renameSync(String newPath) {
    // TODO: implement renameSync
    throw UnimplementedError();
  }
}

class RemoteFile extends RemoteFileSystemEntity implements File {

  RemoteFile(path, entryType, modifiedTime, size)
      : super(path, entryType, modifiedTime, size);

  // ***************************

  @override
  Future<int> length() {
    // TODO: implement length
    throw UnimplementedError();
  }

  @override
  Future<DateTime> lastModified() {
    // TODO: implement lastModified
    throw UnimplementedError();
  }

  @override
  Future<File> copy(String newPath) {
    // TODO: implement copy
    throw UnimplementedError();
  }

  @override
  File copySync(String newPath) {
    // TODO: implement copySync
    throw UnimplementedError();
  }

  @override
  Future<File> create({bool recursive = false}) {
    // TODO: implement create
    throw UnimplementedError();
  }

  @override
  void createSync({bool recursive = false}) {
    // TODO: implement createSync
  }

  @override
  Future<bool> exists() {
    // TODO: implement exists
    throw UnimplementedError();
  }

  @override
  bool existsSync() {
    // TODO: implement existsSync
    throw UnimplementedError();
  }

  @override
  Future<DateTime> lastAccessed() {
    // TODO: implement lastAccessed
    throw UnimplementedError();
  }

  @override
  DateTime lastAccessedSync() {
    // TODO: implement lastAccessedSync
    throw UnimplementedError();
  }

  @override
  Future<RandomAccessFile> open({FileMode mode = FileMode.read}) {
    // TODO: implement open
    throw UnimplementedError();
  }

  @override
  Stream<List<int>> openRead([int? start, int? end]) {
    // TODO: implement openRead
    throw UnimplementedError();
  }

  @override
  RandomAccessFile openSync({FileMode mode = FileMode.read}) {
    // TODO: implement openSync
    throw UnimplementedError();
  }

  @override
  IOSink openWrite({FileMode mode = FileMode.write, Encoding encoding = utf8}) {
    // TODO: implement openWrite
    throw UnimplementedError();
  }

  @override
  Future<Uint8List> readAsBytes() {
    // TODO: implement readAsBytes
    throw UnimplementedError();
  }

  @override
  Uint8List readAsBytesSync() {
    // TODO: implement readAsBytesSync
    throw UnimplementedError();
  }

  @override
  Future<List<String>> readAsLines({Encoding encoding = utf8}) {
    // TODO: implement readAsLines
    throw UnimplementedError();
  }

  @override
  List<String> readAsLinesSync({Encoding encoding = utf8}) {
    // TODO: implement readAsLinesSync
    throw UnimplementedError();
  }

  @override
  Future<String> readAsString({Encoding encoding = utf8}) {
    // TODO: implement readAsString
    throw UnimplementedError();
  }

  @override
  String readAsStringSync({Encoding encoding = utf8}) {
    // TODO: implement readAsStringSync
    throw UnimplementedError();
  }

  @override
  Future<File> rename(String newPath) {
    // TODO: implement rename
    throw UnimplementedError();
  }

  @override
  File renameSync(String newPath) {
    // TODO: implement renameSync
    throw UnimplementedError();
  }

  @override
  Future setLastAccessed(DateTime time) {
    // TODO: implement setLastAccessed
    throw UnimplementedError();
  }

  @override
  void setLastAccessedSync(DateTime time) {
    // TODO: implement setLastAccessedSync
  }

  @override
  Future setLastModified(DateTime time) {
    // TODO: implement setLastModified
    throw UnimplementedError();
  }

  @override
  void setLastModifiedSync(DateTime time) {
    // TODO: implement setLastModifiedSync
  }

  @override
  Future<File> writeAsBytes(List<int> bytes,
      {FileMode mode = FileMode.write, bool flush = false}) {
    // TODO: implement writeAsBytes
    throw UnimplementedError();
  }

  @override
  void writeAsBytesSync(List<int> bytes,
      {FileMode mode = FileMode.write, bool flush = false}) {
    // TODO: implement writeAsBytesSync
  }

  @override
  Future<File> writeAsString(String contents,
      {FileMode mode = FileMode.write,
        Encoding encoding = utf8,
        bool flush = false}) {
    // TODO: implement writeAsString
    throw UnimplementedError();
  }

  @override
  void writeAsStringSync(String contents,
      {FileMode mode = FileMode.write,
        Encoding encoding = utf8,
        bool flush = false}) {
    // TODO: implement writeAsStringSync
  }

  @override
  // TODO: implement absolute
  File get absolute => throw UnimplementedError();
}


class _PathStat {
  final String path;
  final DateTime dateTime;
  _PathStat(this.path, this.dateTime);
}

// code from file_manager pkg after edit
List<RemoteFileSystemEntity> _sortRemoteEntitiesList(
    List<RemoteFileSystemEntity> list, SortBy sortType) {
  if (sortType == SortBy.name) {
    // making list of only folders.
    final dirs = list.where((element) => element is Directory).toList();
    // sorting folder list by name.
    dirs.sort((a, b) => a.path.toLowerCase().compareTo(b.path.toLowerCase()));

    // making list of only flies.
    final files = list.where((element) => element is File).toList();
    // sorting files list by name.
    files.sort((a, b) => a.path.toLowerCase().compareTo(b.path.toLowerCase()));

    // first folders will go to list (if available) then files will go to list.
    return [...dirs, ...files];
  } else if (sortType == SortBy.date) {
    // making the list of Path & DateTime
    List<_PathStat> _pathStat = [];
    for (RemoteFileSystemEntity e in list) {
      _pathStat.add(_PathStat(e.path, e.lastModifiedSync()));
    }

    // sort _pathStat according to date
    _pathStat.sort((b, a) => a.dateTime.compareTo(b.dateTime));

    // sorting [list] accroding to [_pathStat]
    list.sort((a, b) => _pathStat
        .indexWhere((element) => element.path == a.path)
        .compareTo(_pathStat.indexWhere((element) => element.path == b.path)));
    return list;
  } else if (sortType == SortBy.type) {
    // making list of only folders.
    final dirs = list.where((element) => element is Directory).toList();

    // sorting folders by name.
    dirs.sort((a, b) => a.path.toLowerCase().compareTo(b.path.toLowerCase()));

    // making the list of files
    final files = list.where((element) => element is File).toList();

    // sorting files list by extension.
    files.sort((a, b) => a.path
        .toLowerCase()
        .split('.')
        .last
        .compareTo(b.path.toLowerCase().split('.').last));
    return [...dirs, ...files];
  } else if (sortType == SortBy.size) {
    // create list of path and size
    Map<String, int> _sizeMap = {};
    for (RemoteFileSystemEntity e in list) {
      _sizeMap[e.path] = e.lengthSync();
    }

    // making list of only folders.
    final dirs = list.where((element) => element is Directory).toList();
    // sorting folder list by name.
    dirs.sort((a, b) => a.path.toLowerCase().compareTo(b.path.toLowerCase()));

    // making list of only flies.
    final files = list.where((element) => element is File).toList();

    // creating sorted list of [_sizeMapList] by size.
    final List<MapEntry<String, int>> _sizeMapList = _sizeMap.entries.toList();
    _sizeMapList.sort((b, a) => a.value.compareTo(b.value));

    // sort [list] according to [_sizeMapList]
    files.sort((a, b) => _sizeMapList
        .indexWhere((element) => element.key == a.path)
        .compareTo(
        _sizeMapList.indexWhere((element) => element.key == b.path)));
    return [...dirs, ...files];
  }
  return [];
}