mirror of
https://github.com/weyne85/rustdesk.git
synced 2025-10-29 17:00:05 +00:00
del file_manager pub;add send files
This commit is contained in:
csf
@@ -1,14 +1,9 @@
|
||||
import 'dart:convert';
|
||||
import 'dart:io';
|
||||
import 'dart:typed_data';
|
||||
|
||||
import 'package:file_manager/enums/sort_by.dart';
|
||||
import 'package:path/path.dart' as p;
|
||||
import 'package:flutter/material.dart';
|
||||
|
||||
import 'model.dart';
|
||||
|
||||
// BIG TODO remove file manager !
|
||||
|
||||
enum SortBy { name, type, date, size }
|
||||
|
||||
// enum FileType {
|
||||
// Dir = 0,
|
||||
@@ -19,37 +14,30 @@ import 'model.dart';
|
||||
// }
|
||||
|
||||
class FileDirectory {
|
||||
// List<Entry> entries = [];
|
||||
List<RemoteFileSystemEntity> entries = [];
|
||||
List<Entry> entries = [];
|
||||
int id = 0;
|
||||
String path = "";
|
||||
|
||||
String get parent => p.dirname(path);
|
||||
|
||||
FileDirectory();
|
||||
|
||||
FileDirectory.fromJson(Map<String, dynamic> json,SortBy sort) {
|
||||
FileDirectory.fromJson(Map<String, dynamic> json, SortBy sort) {
|
||||
id = json['id'];
|
||||
path = json['path'];
|
||||
if (json['entries'] != null) {
|
||||
entries = <RemoteFileSystemEntity>[];
|
||||
entries = <Entry>[];
|
||||
json['entries'].forEach((v) {
|
||||
entries.add(new Entry.fromJson(v).toRemoteFileSystemEntity(path));
|
||||
entries.add(new Entry.fromJson(v));
|
||||
});
|
||||
entries = _sortRemoteEntitiesList(entries, sort);
|
||||
entries = _sortList(entries, sort);
|
||||
}
|
||||
}
|
||||
|
||||
changeSortStyle(SortBy sort){
|
||||
entries = _sortRemoteEntitiesList(entries, sort);
|
||||
changeSortStyle(SortBy sort) {
|
||||
entries = _sortList(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;
|
||||
@@ -72,476 +60,157 @@ class Entry {
|
||||
size = json['size'];
|
||||
}
|
||||
|
||||
RemoteFileSystemEntity toRemoteFileSystemEntity(String parentPath) {
|
||||
return RemoteFileSystemEntity.from("$parentPath/$name", entryType, modifiedTime, size);
|
||||
}
|
||||
bool get isFile => entryType > 3;
|
||||
|
||||
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;
|
||||
bool get isDirectory => entryType <= 3;
|
||||
|
||||
DateTime lastModified() {
|
||||
return DateTime.fromMillisecondsSinceEpoch(modifiedTime * 1000);
|
||||
}
|
||||
}
|
||||
|
||||
// TODO 使用工厂单例模式
|
||||
|
||||
class RemoteFileModel extends ChangeNotifier {
|
||||
class FileModel extends ChangeNotifier {
|
||||
var _jobCount = 0;
|
||||
|
||||
SortBy _sortStyle = SortBy.name;
|
||||
|
||||
SortBy get sortStyle => _sortStyle;
|
||||
|
||||
FileDirectory _currentLocalDir = FileDirectory();
|
||||
|
||||
FileDirectory get currentLocalDir => _currentLocalDir;
|
||||
|
||||
FileDirectory _currentRemoteDir = FileDirectory();
|
||||
|
||||
FileDirectory get currentRemoteDir => _currentRemoteDir;
|
||||
|
||||
tryUpdateRemoteDir(String fd) {
|
||||
debugPrint("tryUpdateRemoteDir:$fd");
|
||||
tryUpdateDir(String fd, bool isLocal) {
|
||||
try {
|
||||
final fileDir = FileDirectory.fromJson(jsonDecode(fd),_sortStyle);
|
||||
_currentRemoteDir = fileDir;
|
||||
debugPrint("_currentRemoteDir:${_currentRemoteDir.path}");
|
||||
final fileDir = FileDirectory.fromJson(jsonDecode(fd), _sortStyle);
|
||||
if (isLocal) {
|
||||
_currentLocalDir = fileDir;
|
||||
} else {
|
||||
_currentRemoteDir = fileDir;
|
||||
}
|
||||
notifyListeners();
|
||||
} catch (e) {
|
||||
debugPrint("tryUpdateRemoteDir fail:$fd");
|
||||
debugPrint("tryUpdateDir fail:$fd");
|
||||
}
|
||||
}
|
||||
|
||||
goToParentDirectory() {
|
||||
var parentPath = "";
|
||||
if (_currentRemoteDir.path == "") {
|
||||
parentPath = "";
|
||||
refresh(bool isLocal){
|
||||
openDirectory(isLocal?_currentLocalDir.path:_currentRemoteDir.path,isLocal);
|
||||
}
|
||||
|
||||
openDirectory(String path, bool isLocal) {
|
||||
if (isLocal) {
|
||||
final res = FFI.getByName("read_dir", path);
|
||||
tryUpdateDir(res, true);
|
||||
} else {
|
||||
parentPath = Directory(_currentRemoteDir.path).parent.path;
|
||||
FFI.setByName("read_remote_dir", path);
|
||||
}
|
||||
FFI.setByName("read_remote_dir", parentPath);
|
||||
}
|
||||
|
||||
changeSortStyle(SortBy sort){
|
||||
goToParentDirectory(bool isLocal) {
|
||||
final fd = isLocal ? _currentLocalDir : _currentRemoteDir;
|
||||
openDirectory(fd.parent, isLocal);
|
||||
}
|
||||
|
||||
sendFiles(String path, String to, bool showHidden, bool isRemote) {
|
||||
_jobCount++;
|
||||
final msg = {
|
||||
"id": _jobCount.toString(),
|
||||
"path": path,
|
||||
"to": to,
|
||||
"show_hidden": showHidden.toString(),
|
||||
"is_remote": isRemote.toString() // isRemote 指path的位置而不是to的位置
|
||||
};
|
||||
FFI.setByName("send_files",jsonEncode(msg));
|
||||
}
|
||||
|
||||
changeSortStyle(SortBy sort) {
|
||||
_sortStyle = sort;
|
||||
_currentLocalDir.changeSortStyle(sort);
|
||||
_currentRemoteDir.changeSortStyle(sort);
|
||||
notifyListeners();
|
||||
}
|
||||
|
||||
@override
|
||||
void dispose() {
|
||||
void clear() {
|
||||
_currentLocalDir.clear();
|
||||
_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) {
|
||||
List<Entry> _sortList(List<Entry> list, SortBy sortType) {
|
||||
if (sortType == SortBy.name) {
|
||||
// making list of only folders.
|
||||
final dirs = list.where((element) => element is Directory).toList();
|
||||
final dirs = list.where((element) => element.isDirectory).toList();
|
||||
// sorting folder list by name.
|
||||
dirs.sort((a, b) => a.path.toLowerCase().compareTo(b.path.toLowerCase()));
|
||||
dirs.sort((a, b) => a.name.toLowerCase().compareTo(b.name.toLowerCase()));
|
||||
|
||||
// making list of only flies.
|
||||
final files = list.where((element) => element is File).toList();
|
||||
final files = list.where((element) => element.isFile).toList();
|
||||
// sorting files list by name.
|
||||
files.sort((a, b) => a.path.toLowerCase().compareTo(b.path.toLowerCase()));
|
||||
files.sort((a, b) => a.name.toLowerCase().compareTo(b.name.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()));
|
||||
for (Entry e in list) {
|
||||
_pathStat.add(_PathStat(e.name, e.lastModified()));
|
||||
}
|
||||
|
||||
// sort _pathStat according to date
|
||||
_pathStat.sort((b, a) => a.dateTime.compareTo(b.dateTime));
|
||||
|
||||
// sorting [list] accroding to [_pathStat]
|
||||
// sorting [list] according to [_pathStat]
|
||||
list.sort((a, b) => _pathStat
|
||||
.indexWhere((element) => element.path == a.path)
|
||||
.compareTo(_pathStat.indexWhere((element) => element.path == b.path)));
|
||||
.indexWhere((element) => element.path == a.name)
|
||||
.compareTo(_pathStat.indexWhere((element) => element.path == b.name)));
|
||||
return list;
|
||||
} else if (sortType == SortBy.type) {
|
||||
// making list of only folders.
|
||||
final dirs = list.where((element) => element is Directory).toList();
|
||||
final dirs = list.where((element) => element.isDirectory).toList();
|
||||
|
||||
// sorting folders by name.
|
||||
dirs.sort((a, b) => a.path.toLowerCase().compareTo(b.path.toLowerCase()));
|
||||
dirs.sort((a, b) => a.name.toLowerCase().compareTo(b.name.toLowerCase()));
|
||||
|
||||
// making the list of files
|
||||
final files = list.where((element) => element is File).toList();
|
||||
final files = list.where((element) => element.isFile).toList();
|
||||
|
||||
// sorting files list by extension.
|
||||
files.sort((a, b) => a.path
|
||||
files.sort((a, b) => a.name
|
||||
.toLowerCase()
|
||||
.split('.')
|
||||
.last
|
||||
.compareTo(b.path.toLowerCase().split('.').last));
|
||||
.compareTo(b.name.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();
|
||||
for (Entry e in list) {
|
||||
_sizeMap[e.name] = e.size;
|
||||
}
|
||||
|
||||
// making list of only folders.
|
||||
final dirs = list.where((element) => element is Directory).toList();
|
||||
final dirs = list.where((element) => element.isDirectory).toList();
|
||||
// sorting folder list by name.
|
||||
dirs.sort((a, b) => a.path.toLowerCase().compareTo(b.path.toLowerCase()));
|
||||
dirs.sort((a, b) => a.name.toLowerCase().compareTo(b.name.toLowerCase()));
|
||||
|
||||
// making list of only flies.
|
||||
final files = list.where((element) => element is File).toList();
|
||||
final files = list.where((element) => element.isFile).toList();
|
||||
|
||||
// creating sorted list of [_sizeMapList] by size.
|
||||
final List<MapEntry<String, int>> _sizeMapList = _sizeMap.entries.toList();
|
||||
@@ -549,9 +218,9 @@ List<RemoteFileSystemEntity> _sortRemoteEntitiesList(
|
||||
|
||||
// sort [list] according to [_sizeMapList]
|
||||
files.sort((a, b) => _sizeMapList
|
||||
.indexWhere((element) => element.key == a.path)
|
||||
.indexWhere((element) => element.key == a.name)
|
||||
.compareTo(
|
||||
_sizeMapList.indexWhere((element) => element.key == b.path)));
|
||||
_sizeMapList.indexWhere((element) => element.key == b.name)));
|
||||
return [...dirs, ...files];
|
||||
}
|
||||
return [];
|
||||
|
||||
@@ -135,7 +135,7 @@ class FfiModel with ChangeNotifier {
|
||||
} else if (name == 'chat') {
|
||||
FFI.chatModel.receive(evt['text'] ?? "");
|
||||
} else if (name == 'file_dir') {
|
||||
FFI.remoteFileModel.tryUpdateRemoteDir(evt['value'] ?? "");
|
||||
FFI.fileModel.tryUpdateDir(evt['value'] ?? "",false);
|
||||
}
|
||||
}
|
||||
if (pos != null) FFI.cursorModel.updateCursorPosition(pos);
|
||||
@@ -695,7 +695,7 @@ class FFI {
|
||||
static final canvasModel = CanvasModel();
|
||||
static final serverModel = ServerModel();
|
||||
static final chatModel = ChatModel();
|
||||
static final remoteFileModel = RemoteFileModel();
|
||||
static final fileModel = FileModel();
|
||||
|
||||
static String getId() {
|
||||
return getByName('remote_id');
|
||||
|
||||
Reference in New Issue
Block a user