import 'package:flutter/material.dart'; import 'package:flutter_gen/gen_l10n/l10n.dart'; import 'package:provider/provider.dart'; import 'package:toolbox/core/extension/navigator.dart'; import 'package:toolbox/core/route.dart'; import 'package:toolbox/core/utils/misc.dart'; import 'package:toolbox/view/page/ssh.dart'; import 'package:toolbox/view/widget/input_field.dart'; import '../../core/utils/ui.dart'; import '../../data/model/docker/ps.dart'; import '../../data/model/server/server_private_info.dart'; import '../../data/provider/docker.dart'; import '../../data/provider/server.dart'; import '../../data/model/app/error.dart'; import '../../data/model/app/menu.dart'; import '../../data/res/ui.dart'; import '../../data/res/url.dart'; import '../../data/store/docker.dart'; import '../../locator.dart'; import '../widget/popup_menu.dart'; import '../widget/round_rect_card.dart'; import '../widget/two_line_text.dart'; import '../widget/url_text.dart'; class DockerManagePage extends StatefulWidget { final ServerPrivateInfo spi; const DockerManagePage(this.spi, {Key? key}) : super(key: key); @override State createState() => _DockerManagePageState(); } class _DockerManagePageState extends State { final _docker = locator(); final _textController = TextEditingController(); late S _s; @override void dispose() { super.dispose(); _docker.clear(); } @override void didChangeDependencies() { super.didChangeDependencies(); _s = S.of(context)!; } @override void initState() { super.initState(); final client = locator().servers[widget.spi.id]?.client; if (client == null) { showSnackBar(context, Text(_s.noClient)); context.pop(); return; } _docker.init(client, widget.spi.user, onPwdRequest, widget.spi.id); } @override Widget build(BuildContext context) { return Consumer(builder: (_, ___, __) { return Scaffold( appBar: AppBar( centerTitle: true, title: TwoLineText(up: 'Docker', down: widget.spi.name), actions: [ IconButton( onPressed: () => _docker.refresh(), icon: const Icon(Icons.refresh), ) ], ), body: _buildMain(), floatingActionButton: _buildFAB(), ); }); } Widget _buildFAB() { return FloatingActionButton( onPressed: () async => await _showAddFAB(), child: const Icon(Icons.add), ); } Future _showAddFAB() async { final imageCtrl = TextEditingController(); final nameCtrl = TextEditingController(); final argsCtrl = TextEditingController(); await showRoundDialog( context: context, title: Text(_s.newContainer), child: Column( mainAxisSize: MainAxisSize.min, children: [ Input( type: TextInputType.text, label: _s.image, hint: 'xxx:1.1', controller: imageCtrl, ), Input( type: TextInputType.text, controller: nameCtrl, label: _s.containerName, hint: 'xxx', ), Input( type: TextInputType.text, controller: argsCtrl, label: _s.extraArgs, hint: '-p 2222:22 -v ~/.xxx/:/xxx', ), ], ), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.cancel), ), TextButton( onPressed: () async { context.pop(); await _showAddCmdPreview( _buildAddCmd( imageCtrl.text.trim(), nameCtrl.text.trim(), argsCtrl.text.trim(), ), ); }, child: Text(_s.ok), ) ], ); } Future _showAddCmdPreview(String cmd) async { await showRoundDialog( context: context, title: Text(_s.preview), child: Text(cmd), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.cancel), ), TextButton( onPressed: () async { context.pop(); final result = await _docker.run(cmd); if (result != null) { showSnackBar(context, Text(getErrMsg(result) ?? _s.unknownError)); } }, child: Text(_s.run), ) ], ); } String _buildAddCmd(String image, String name, String args) { var suffix = ''; if (args.isEmpty) { suffix = image; } else { suffix = '$args $image'; } if (name.isEmpty) { return 'docker run -itd $suffix'; } return 'docker run -itd --name $name $suffix'; } String? getErrMsg(DockerErr err) { switch (err.type) { default: return err.message; } } void onSubmitted() { if (_textController.text == '') { showRoundDialog( context: context, child: Text(_s.fieldMustNotEmpty), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.ok), ), ], ); return; } context.pop(); } Future onPwdRequest() async { if (!mounted) return ''; await showRoundDialog( context: context, title: Text(widget.spi.user), child: Input( controller: _textController, type: TextInputType.visiblePassword, obscureText: true, onSubmitted: (_) => onSubmitted(), label: _s.pwd, ), actions: [ TextButton( onPressed: () { context.pop(); context.pop(); }, child: Text(_s.cancel), ), TextButton( onPressed: () => onSubmitted(), child: Text( _s.ok, style: const TextStyle(color: Colors.red), ), ), ], ); return _textController.text.trim(); } Widget _buildMain() { if (_docker.error != null && _docker.items == null) { return SizedBox.expand( child: Column( mainAxisAlignment: MainAxisAlignment.center, crossAxisAlignment: CrossAxisAlignment.center, children: [ const Icon( Icons.error, size: 37, ), const SizedBox(height: 27), _buildErr(_docker.error!), const SizedBox(height: 27), Padding( padding: const EdgeInsets.all(17), child: _buildSolution(_docker.error!), ) ], ), ); } if (_docker.items == null || _docker.images == null) { _docker.refresh(); return centerLoading; } final items = []; items.addAll([ _buildLoading(), _buildVersion( _docker.edition ?? _s.unknown, _docker.version ?? _s.unknown, ), _buildPsItems(), _buildImages(), _buildEditHost(), ].map((e) => RoundRectCard(e))); items.add(const SizedBox(height: 37)); return ListView( padding: const EdgeInsets.all(7), children: items, ); } Widget _buildImages() { if (_docker.images == null) { return placeholder; } final items = _docker.images! .map( (e) => ListTile( title: Text(e.repo), subtitle: Text('${e.tag} - ${e.size}', style: grey), trailing: IconButton( padding: EdgeInsets.zero, alignment: Alignment.centerRight, icon: const Icon(Icons.delete), onPressed: () async { showRoundDialog( context: context, child: Text(_s.sureDelete(e.repo)), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.cancel), ), TextButton( onPressed: () async { context.pop(); final result = await _docker.run( 'docker rmi ${e.id} -f', ); if (result != null) { showSnackBar( context, Text(getErrMsg(result) ?? _s.unknownError), ); } }, child: Text( _s.ok, style: const TextStyle(color: Colors.red), ), ), ], ); }, ), ), ) .toList(); items.insert( 0, ListTile( title: Text(_s.imagesList), subtitle: Text( _s.dockerImagesFmt(_docker.images!.length), style: grey, ), ), ); return Column(children: items); } Widget _buildLoading() { if (!_docker.isBusy) return placeholder; return Padding( padding: const EdgeInsets.all(17), child: Column( children: [ const Center( child: CircularProgressIndicator(), ), height13, Text(_docker.runLog ?? '...'), ], ), ); } Widget _buildEditHost() { if (_docker.items!.isNotEmpty || _docker.images!.isNotEmpty) { return placeholder; } return Padding( padding: const EdgeInsets.fromLTRB(17, 17, 17, 0), child: Column( children: [ Text( _s.dockerEmptyRunningItems, textAlign: TextAlign.center, ), TextButton( onPressed: () => _showEditHostDialog(), child: Text(_s.dockerEditHost), ) ], ), ); } Future _showEditHostDialog() async { await showRoundDialog( context: context, title: Text(_s.dockerEditHost), child: Input( maxLines: 1, controller: TextEditingController(text: 'unix:///run/user/1000/docker.sock'), onSubmitted: (value) { locator().setDockerHost(widget.spi.id, value.trim()); _docker.refresh(); context.pop(); }, ), actions: [ TextButton( onPressed: () => context.pop(), child: Text(_s.cancel), ), ], ); } Widget _buildErr(DockerErr err) { var errStr = ''; switch (err.type) { case DockerErrType.noClient: errStr = _s.noClient; break; case DockerErrType.notInstalled: errStr = _s.dockerNotInstalled; break; case DockerErrType.invalidVersion: errStr = _s.invalidVersion; break; default: errStr = err.message ?? _s.unknown; } return Text(errStr); } Widget _buildSolution(DockerErr err) { switch (err.type) { case DockerErrType.notInstalled: return UrlText( text: _s.installDockerWithUrl, replace: _s.install, ); case DockerErrType.noClient: return Text(_s.waitConnection); case DockerErrType.invalidVersion: return UrlText( text: _s.invalidVersionHelp(issueUrl), replace: 'Github', ); default: return Text(_s.unknownError); } } Widget _buildVersion(String edition, String version) { return Padding( padding: const EdgeInsets.all(17), child: Row( mainAxisAlignment: MainAxisAlignment.spaceBetween, children: [Text(edition), Text(version)], ), ); } Widget _buildPsItems() { final items = _docker.items!.map( (item) { return ListTile( title: Text(item.name), isThreeLine: true, subtitle: Text( '${item.image}\n${item.status}', style: textSize13Grey, ), trailing: _buildMoreBtn(item, _docker.isBusy), ); }, ).toList(); items.insert( 0, ListTile( title: Text(_s.containerStatus), subtitle: Text(_buildSubtitle(_docker.items!), style: grey), ), ); return Column( children: items, ); } Widget _buildMoreBtn(DockerPsItem dItem, bool busy) { return PopupMenu( items: DockerMenuType.items(dItem.running).map((e) => e.build(_s)).toList(), onSelected: (DockerMenuType item) async { if (busy) { showSnackBar(context, Text(_s.isBusy)); return; } switch (item) { case DockerMenuType.rm: showRoundDialog( context: context, child: Text(_s.sureDelete(dItem.name)), actions: [ TextButton( onPressed: () { context.pop(); _docker.delete(dItem.containerId); }, child: Text(_s.ok), ) ], ); break; case DockerMenuType.start: _docker.start(dItem.containerId); break; case DockerMenuType.stop: _docker.stop(dItem.containerId); break; case DockerMenuType.restart: _docker.restart(dItem.containerId); break; case DockerMenuType.logs: final logs = await _docker.logs(dItem.containerId); showRoundDialog( context: context, child: SingleChildScrollView( child: Text(logs), ), actions: [ TextButton( onPressed: () => copy2Clipboard(logs), child: Text(_s.copy), ) ], ); break; case DockerMenuType.terminal: AppRoute( SSHPage( spi: widget.spi, initCmd: 'docker exec -it ${dItem.containerId} /bin/sh', ), 'Docker terminal', ).go(context); } }, ); } String _buildSubtitle(List running) { final runningCount = running.where((element) => element.running).length; final stoped = running.length - runningCount; if (stoped == 0) { return _s.dockerStatusRunningFmt(runningCount); } return _s.dockerStatusRunningAndStoppedFmt(runningCount, stoped); } }