feat: snippet with term ctrl (#380 #382)

lib/data/model/server/snippet.dart

@@ -1,5 +1,9 @@
+import 'dart:async';
+
+import 'package:fl_lib/fl_lib.dart';
 import 'package:hive_flutter/hive_flutter.dart';
 import 'package:toolbox/data/model/server/server_private_info.dart';
+import 'package:xterm/core.dart';
 
 import '../app/tag_pickable.dart';
 
@@ -53,19 +57,114 @@ class Snippet implements TagPickable {
   @override
   String get tagName => name;
 
-  String fmtWith(ServerPrivateInfo spi) {
-    final fmted = script.replaceAllMapped(
-      RegExp(r'\${.+?}'),
+  static final fmtFinder = RegExp(r'\$\{[^{}]+\}');
+
+  String fmtWithSpi(ServerPrivateInfo spi) {
+    return script.replaceAllMapped(
+      fmtFinder,
       (match) {
         final key = match.group(0);
         final func = fmtArgs[key];
-        if (func == null) {
-          return key!;
-        }
-        return func(spi);
+        if (func != null) return func(spi);
+        // If not found, return the original content for further processing
+        return key ?? '';
       },
     );
-    return fmted;
+  }
+
+  Future<void> runInTerm(
+    Terminal terminal,
+    ServerPrivateInfo spi, {
+    bool autoEnter = false,
+  }) async {
+    final argsFmted = fmtWithSpi(spi);
+    final matches = fmtFinder.allMatches(argsFmted);
+
+    /// There is no [TerminalKey] in the script
+    if (matches.isEmpty) {
+      terminal.textInput(argsFmted);
+      if (autoEnter) terminal.keyInput(TerminalKey.enter);
+      return;
+    }
+
+    // Records all start and end indexes of the matches
+    final (starts, ends) = matches.fold((<int>[], <int>[]), (pre, e) {
+      pre.$1.add(e.start);
+      pre.$2.add(e.end);
+      return pre;
+    });
+
+    // Check all indexes, `(idx + 1).start` must >= `idx.end`
+    for (var i = 0; i < starts.length - 1; i++) {
+      final lastEnd = ends[i];
+      final nextStart = starts[i + 1];
+      if (nextStart < lastEnd) {
+        throw 'Invalid format: $nextStart < $lastEnd';
+      }
+    }
+
+    // Start term input
+    if (starts.first > 0) {
+      terminal.textInput(argsFmted.substring(0, starts.first));
+    }
+
+    // Process matched
+    for (var idx = 0; idx < starts.length; idx++) {
+      final start = starts[idx];
+      final end = ends[idx];
+      final key = argsFmted.substring(start, end).toLowerCase();
+
+      // Special funcs
+      final special = _find(specialCtrl, key);
+      if (special != null) {
+        final raw = key.substring(special.key.length + 1, key.length - 1);
+        await special.value(raw);
+      }
+
+      // Term keys
+      final termKey = _find(fmtTermKeys, key);
+      if (termKey != null) await _doTermKeys(terminal, termKey, key);
+    }
+
+    // End term input
+    if (ends.last < argsFmted.length) {
+      terminal.textInput(argsFmted.substring(ends.last));
+    }
+
+    if (autoEnter) terminal.keyInput(TerminalKey.enter);
+  }
+
+  Future<void> _doTermKeys(
+    Terminal terminal,
+    MapEntry<String, TerminalKey> termKey,
+    String key,
+  ) async {
+    if (termKey.value == TerminalKey.enter) {
+      terminal.keyInput(TerminalKey.enter);
+      return;
+    }
+
+    final ctrlAlt = switch (termKey.value) {
+      TerminalKey.control => (ctrl: true, alt: false),
+      TerminalKey.alt => (ctrl: false, alt: true),
+      _ => (ctrl: false, alt: false),
+    };
+
+    // `${ctrl+ad}` -> `ctrla + d`
+    final chars = key.substring(termKey.key.length + 1, key.length - 1);
+    terminal.charInput(
+      chars.codeUnitAt(0),
+      ctrl: ctrlAlt.ctrl,
+      alt: ctrlAlt.alt,
+    );
+    
+    for (final char in chars.codeUnits.skip(1)) {
+      terminal.charInput(char, ctrl: false, alt: false);
+    }
+  }
+
+  MapEntry<String, T>? _find<T>(Map<String, T> map, String key) {
+    return map.entries.firstWhereOrNull((e) => key.startsWith(e.key));
   }
 
   static final fmtArgs = {
@@ -76,6 +175,18 @@ class Snippet implements TagPickable {
     r'${id}': (ServerPrivateInfo spi) => spi.id,
     r'${name}': (ServerPrivateInfo spi) => spi.name,
   };
+
+  /// r'${ctrl+ad}' -> TerminalKey.control, a, d
+  static final fmtTermKeys = {
+    r'${ctrl': TerminalKey.control,
+    r'${alt': TerminalKey.alt,
+    r'${enter': TerminalKey.enter,
+  };
+
+  static final specialCtrl = {
+    // `${sleep 3}` -> sleep 3 seconds
+    r'${sleep': SnippetFuncs.sleep,
+  };
 }
 
 class SnippetResult {
@@ -89,3 +200,12 @@ class SnippetResult {
     required this.time,
   });
 }
+
+abstract final class SnippetFuncs {
+  static FutureOr<void> sleep(String raw) async {
+    final seconds = int.tryParse(raw);
+    if (seconds == null) return;
+    final duration = Duration(seconds: seconds);
+    await Future.delayed(duration);
+  }
+}

lib/data/provider/server.dart

@@ -18,7 +18,6 @@ import '../../core/utils/server.dart';
 import '../model/server/server.dart';
 import '../model/server/server_private_info.dart';
 import '../model/server/server_status_update_req.dart';
-import '../model/server/snippet.dart';
 import '../model/server/try_limiter.dart';
 import '../res/status.dart';
 
@@ -460,20 +459,20 @@ class ServerProvider extends ChangeNotifier {
     TryLimiter.reset(sid);
   }
 
-  Future<SnippetResult?> runSnippet(String id, Snippet snippet) async {
-    final server = _servers[id];
-    if (server == null) return null;
-    final watch = Stopwatch()..start();
-    final result = await server.client?.run(snippet.fmtWith(server.spi)).string;
-    final time = watch.elapsed;
-    watch.stop();
-    if (result == null) return null;
-    return SnippetResult(
-      dest: _servers[id]?.spi.name,
-      result: result,
-      time: time,
-    );
-  }
+  // Future<SnippetResult?> runSnippet(String id, Snippet snippet) async {
+  //   final server = _servers[id];
+  //   if (server == null) return null;
+  //   final watch = Stopwatch()..start();
+  //   final result = await server.client?.run(snippet.fmtWithArgs(server.spi)).string;
+  //   final time = watch.elapsed;
+  //   watch.stop();
+  //   if (result == null) return null;
+  //   return SnippetResult(
+  //     dest: _servers[id]?.spi.name,
+  //     result: result,
+  //     time: time,
+  //   );
+  // }
 
   // Future<List<SnippetResult?>> runSnippetsMulti(
   //   List<String> ids,