import 'dart:io'; import 'dart:typed_data'; import 'package:dartssh2/dartssh2.dart'; import 'package:flutter/material.dart'; import 'package:flutter_gen/gen_l10n/l10n.dart'; import 'package:toolbox/core/extension/navigator.dart'; import 'package:toolbox/core/extension/sftpfile.dart'; import 'package:toolbox/data/res/misc.dart'; import 'package:toolbox/view/page/editor.dart'; import '../../../core/extension/numx.dart'; import '../../../core/extension/stringx.dart'; import '../../../core/route.dart'; import '../../../core/utils/misc.dart'; import '../../../core/utils/ui.dart'; import '../../../data/model/server/server.dart'; import '../../../data/model/server/server_private_info.dart'; import '../../../data/model/sftp/absolute_path.dart'; import '../../../data/model/sftp/browser_status.dart'; import '../../../data/model/sftp/req.dart'; import '../../../data/provider/server.dart'; import '../../../data/provider/sftp.dart'; import '../../../data/res/path.dart'; import '../../../data/res/ui.dart'; import '../../../data/store/private_key.dart'; import '../../../locator.dart'; import '../../widget/fade_in.dart'; import '../../widget/input_field.dart'; import '../../widget/two_line_text.dart'; import 'downloading.dart'; class SFTPPage extends StatefulWidget { final ServerPrivateInfo spi; final String? initPath; const SFTPPage(this.spi, {Key? key, this.initPath}) : super(key: key); @override _SFTPPageState createState() => _SFTPPageState(); } class _SFTPPageState extends State { final SftpBrowserStatus _status = SftpBrowserStatus(); final ScrollController _scrollController = ScrollController(); late S _s; ServerState? _state; SSHClient? _client; @override void didChangeDependencies() { super.didChangeDependencies(); _s = S.of(context)!; } @override void initState() { super.initState(); final serverProvider = locator(); _client = serverProvider.servers[widget.spi.id]?.client; _state = serverProvider.servers[widget.spi.id]?.state; } @override Widget build(BuildContext context) { return Scaffold( appBar: AppBar( centerTitle: true, title: TwoLineText(up: 'SFTP', down: widget.spi.name), actions: [ IconButton( icon: const Icon(Icons.downloading), onPressed: () => AppRoute( const SFTPDownloadingPage(), 'sftp downloading', ).go(context), ), ], ), body: _buildFileView(), bottomNavigationBar: _buildBottom(), ); } Widget _buildBottom() { return SafeArea( child: Container( padding: const EdgeInsets.fromLTRB(11, 7, 11, 11), child: Column( mainAxisSize: MainAxisSize.min, children: [ const Divider(), (_status.path?.path ?? _s.loadingFiles).omitStartStr(), Row( mainAxisAlignment: MainAxisAlignment.spaceAround, children: [ IconButton( padding: const EdgeInsets.all(0), onPressed: () async { await _backward(); }, icon: const Icon(Icons.arrow_back), ), _buildAddBtn(), _buildGotoBtn(), ], ) ], ), ), ); } Widget _buildAddBtn() { return IconButton( onPressed: (() => showRoundDialog( context: context, child: Column( mainAxisSize: MainAxisSize.min, children: [ ListTile( leading: const Icon(Icons.folder), title: Text(_s.createFolder), onTap: () => _mkdir(context)), ListTile( leading: const Icon(Icons.insert_drive_file), title: Text(_s.createFile), onTap: () => _newFile(context)), ], ), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.close), ) ], )), icon: const Icon(Icons.add), ); } Widget _buildGotoBtn() { return IconButton( padding: const EdgeInsets.all(0), onPressed: () async { final p = await showRoundDialog( context: context, title: Text(_s.goto), child: Column( mainAxisSize: MainAxisSize.min, children: [ Input( label: _s.path, onSubmitted: (value) => context.pop(value), ), ], ), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.close), ) ], ); // p == null || p.isEmpty if (p?.isEmpty ?? true) { return; } _status.path?.update(p!); _listDir(path: p); }, icon: const Icon(Icons.gps_fixed), ); } Widget _buildFileView() { if (_client == null || _state != ServerState.connected) { return centerLoading; } if (_status.isBusy) { return centerLoading; } if (_status.files == null) { final p_ = widget.initPath ?? '/'; _status.path = AbsolutePath(p_); _listDir(path: p_, client: _client); return centerLoading; } else { return RefreshIndicator( child: FadeIn( key: Key(widget.spi.name + _status.path!.path), child: ListView.builder( itemCount: _status.files!.length, controller: _scrollController, itemBuilder: (context, index) { final file = _status.files![index]; final isDir = file.attr.isDirectory; return ListTile( leading: Icon(isDir ? Icons.folder : Icons.insert_drive_file), title: Text(file.filename), trailing: Text( '${getTime(file.attr.modifyTime)}\n${file.attr.mode?.str ?? ''}', style: const TextStyle(color: Colors.grey), textAlign: TextAlign.right, ), subtitle: isDir ? null : Text((file.attr.size ?? 0).convertBytes), onTap: () { if (isDir) { _status.path?.update(file.filename); _listDir(path: _status.path?.path); } else { _onItemPress(context, file, true); } }, onLongPress: () => _onItemPress(context, file, !isDir), ); }, ), ), onRefresh: () => _listDir(path: _status.path?.path), ); } } void _onItemPress(BuildContext context, SftpName file, bool notDir) { showRoundDialog( context: context, child: Column( mainAxisSize: MainAxisSize.min, children: [ notDir ? ListTile( leading: const Icon(Icons.edit), title: Text(_s.edit), onTap: () => _edit(context, file), ) : placeholder, ListTile( leading: const Icon(Icons.delete), title: Text(_s.delete), onTap: () => _delete(context, file), ), ListTile( leading: const Icon(Icons.abc), title: Text(_s.rename), onTap: () => _rename(context, file), ), notDir ? ListTile( leading: const Icon(Icons.download), title: Text(_s.download), onTap: () => _download(context, file), ) : placeholder, ], ), ); } Future _edit(BuildContext context, SftpName name) async { final size = name.attr.size; if (size == null || size > editorMaxSize) { showSnackBar( context, Text(_s.fileTooLarge( name.filename, size ?? 0, editorMaxSize, ))); return; } final file = await _status.client!.open( _getRemotePath(name), mode: SftpFileOpenMode.read | SftpFileOpenMode.write, ); final localPath = '${(await sftpDir).path}${_getRemotePath(name)}'; await Directory(localPath.substring(0, localPath.lastIndexOf('/'))) .create(recursive: true); final local = File(localPath); if (await local.exists()) { await local.delete(); } final localFile = local.openWrite(mode: FileMode.append); const defaultChunkSize = 1024 * 1024; final chunkSize = size > defaultChunkSize ? defaultChunkSize : size; for (var i = 0; i < size; i += chunkSize) { final fileData = file.read(length: chunkSize); await for (var form in fileData) { localFile.add(form); } } await localFile.close(); context.pop(); final result = await AppRoute( EditorPage(path: localPath), 'SFTP edit', ).go(context); if (result != null) { await local.writeAsString(result); await file.writeBytes(result.uint8List); showSnackBar(context, Text(_s.saved)); } await file.close(); } void _download(BuildContext context, SftpName name) { showRoundDialog( context: context, title: Text(_s.attention), child: Text('${_s.dl2Local(name.filename)}\n${_s.keepForeground}'), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.cancel), ), TextButton( onPressed: () async { context.pop(); final remotePath = _getRemotePath(name); final local = '${(await sftpDir).path}$remotePath'; final pubKeyId = widget.spi.pubKeyId; final key = locator().get(pubKeyId)?.privateKey; locator().add( SftpReqItem( widget.spi, remotePath, local, ), SftpReqType.download, key: key, ); context.pop(); }, child: Text(_s.download), ) ], ); } void _delete(BuildContext context, SftpName file) { context.pop(); final isDir = file.attr.isDirectory; final dirText = isDir ? '\n${_s.sureDirEmpty}' : ''; final text = '${_s.sureDelete(file.filename)}$dirText'; final child = Text(text); showRoundDialog( context: context, child: child, title: Text(_s.attention), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.cancel), ), TextButton( onPressed: () async { context.pop(); showRoundDialog( context: context, child: centerSizedLoading, barrierDismiss: false, ); final remotePath = _getRemotePath(file); try { if (file.attr.isDirectory) { await _status.client!.rmdir(remotePath); } else { await _status.client!.remove(remotePath); } context.pop(); } catch (e) { context.pop(); showRoundDialog( context: context, title: Text(_s.error), child: Text(e.toString()), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.ok), ) ], ); return; } _listDir(); }, child: Text( _s.delete, style: const TextStyle(color: Colors.red), ), ), ], ); } void _mkdir(BuildContext context) { context.pop(); final textController = TextEditingController(); showRoundDialog( context: context, title: Text(_s.createFolder), child: Input( controller: textController, label: _s.name, ), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.cancel), ), TextButton( onPressed: () { if (textController.text == '') { showRoundDialog( context: context, child: Text(_s.fieldMustNotEmpty), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.ok), ), ], ); return; } _status.client! .mkdir('${_status.path!.path}/${textController.text}'); context.pop(); _listDir(); }, child: Text( _s.ok, style: const TextStyle(color: Colors.red), ), ), ], ); } void _newFile(BuildContext context) { context.pop(); final textController = TextEditingController(); showRoundDialog( context: context, title: Text(_s.createFile), child: Input( controller: textController, label: _s.name, ), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.cancel), ), TextButton( onPressed: () async { if (textController.text == '') { showRoundDialog( context: context, child: Text(_s.fieldMustNotEmpty), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.ok), ), ], ); return; } (await _status.client! .open('${_status.path!.path}/${textController.text}')) .writeBytes(Uint8List(0)); context.pop(); _listDir(); }, child: Text( _s.ok, style: const TextStyle(color: Colors.red), ), ), ], ); } void _rename(BuildContext context, SftpName file) { context.pop(); final textController = TextEditingController(); showRoundDialog( context: context, title: Text(_s.rename), child: Input( controller: textController, label: _s.name, ), actions: [ TextButton(onPressed: () => context.pop(), child: Text(_s.cancel)), TextButton( onPressed: () async { if (textController.text == '') { showRoundDialog( context: context, child: Text(_s.fieldMustNotEmpty), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.ok), ), ], ); return; } await _status.client!.rename(file.filename, textController.text); context.pop(); _listDir(); }, child: Text( _s.rename, style: const TextStyle(color: Colors.red), ), ), ], ); } String _getRemotePath(SftpName name) { final prePath = _status.path!.path; return prePath + (prePath.endsWith('/') ? '' : '/') + name.filename; } Future _listDir({String? path, SSHClient? client}) async { if (_status.isBusy) { return; } _status.isBusy = true; if (client != null) { final sftpc = await client.sftp(); _status.client = sftpc; } try { final fs = await _status.client!.listdir(path ?? _status.path?.path ?? '/'); fs.sort((a, b) => a.filename.compareTo(b.filename)); fs.removeAt(0); if (mounted) { setState(() { _status.files = fs; _status.isBusy = false; }); } } catch (e) { await showRoundDialog( context: context, title: Text(_s.error), child: Text(e.toString()), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.ok), ) ], ); await _backward(); } } Future _backward() async { if (_status.path!.undo()) { await _listDir(); } } }