ssh.dart 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129
  1. import 'dart:async';
  2. import 'dart:convert';
  3. import 'package:dartssh/client.dart';
  4. import 'package:flutter/material.dart';
  5. import 'package:xterm/flutter.dart';
  6. import 'package:xterm/xterm.dart';
  7. const host = 'ssh://localhost:22';
  8. const username = '<your username>';
  9. const password = '<your password>';
  10. void main() {
  11. runApp(MyApp());
  12. }
  13. class MyApp extends StatelessWidget {
  14. @override
  15. Widget build(BuildContext context) {
  16. return MaterialApp(
  17. title: 'xterm.dart demo',
  18. theme: ThemeData(
  19. primarySwatch: Colors.blue,
  20. visualDensity: VisualDensity.adaptivePlatformDensity,
  21. ),
  22. home: MyHomePage(),
  23. );
  24. }
  25. }
  26. class MyHomePage extends StatefulWidget {
  27. MyHomePage({Key key}) : super(key: key);
  28. @override
  29. _MyHomePageState createState() => _MyHomePageState();
  30. }
  31. class SSHTerminalBackend extends TerminalBackend {
  32. SSHClient client;
  33. String _host;
  34. String _username;
  35. String _password;
  36. Completer<int> _exitCodeCompleter;
  37. StreamController<String> _outStream;
  38. SSHTerminalBackend(this._host, this._username, this._password);
  39. void onWrite(String data) {
  40. _outStream.sink.add(data);
  41. }
  42. @override
  43. Future<int> get exitCode => _exitCodeCompleter.future;
  44. @override
  45. void init() {
  46. _exitCodeCompleter = Completer<int>();
  47. _outStream = StreamController<String>();
  48. onWrite('connecting $_host...');
  49. client = SSHClient(
  50. hostport: Uri.parse(_host),
  51. login: _username,
  52. print: print,
  53. termWidth: 80,
  54. termHeight: 25,
  55. termvar: 'xterm-256color',
  56. getPassword: () => utf8.encode(_password),
  57. response: (transport, data) {
  58. onWrite(utf8.decode(data, allowMalformed: true));
  59. },
  60. success: () {
  61. onWrite('connected.\n');
  62. },
  63. disconnected: () {
  64. onWrite('disconnected.');
  65. _outStream.close();
  66. },
  67. );
  68. }
  69. @override
  70. Stream<String> get out => _outStream.stream;
  71. @override
  72. void resize(int width, int height, int pixelWidth, int pixelHeight) {
  73. client.setTerminalWindowSize(width, height);
  74. }
  75. @override
  76. void write(String input) {
  77. client?.sendChannelData(utf8.encode(input));
  78. }
  79. @override
  80. void terminate() {
  81. client?.disconnect('terminate');
  82. }
  83. @override
  84. void ackProcessed() {
  85. // NOOP
  86. }
  87. }
  88. class _MyHomePageState extends State<MyHomePage> {
  89. Terminal terminal;
  90. SSHTerminalBackend backend;
  91. @override
  92. void initState() {
  93. super.initState();
  94. backend = SSHTerminalBackend(host, username, password);
  95. terminal = Terminal(backend: backend, maxLines: 10000);
  96. }
  97. @override
  98. Widget build(BuildContext context) {
  99. return Scaffold(
  100. body: SafeArea(
  101. child: TerminalView(
  102. terminal: terminal,
  103. ),
  104. ),
  105. );
  106. }
  107. }