feat: add timeout parameter to Run command

Co-authored-by: aider (openrouter/x-ai/grok-code-fast-1) <[email protected]>

Author: rTreutlein

kernel/src/main.rs

@@ -2,6 +2,7 @@ use mork::{expr, prefix, sexpr};
 use mork::space::{transitions, unifications, writes, Space};
 use mork_frontend::bytestring_parser::Parser;
 use mork_expr::{item_byte, Tag};
+use std::time::{Duration, Instant};
 use pathmap::PathMap;
 use pathmap::zipper::{Zipper, ZipperAbsolutePath, ZipperIteration, ZipperMoving};
 use std::collections::{BTreeSet, HashSet};
@@ -2855,6 +2856,8 @@ enum Commands {
         query_pattern: Option<String>,
         #[arg(long, short = 't')]
         query_template: Option<String>,
+        #[arg(long, default_value_t = 0)]
+        timeout: u64,
     },
     #[command(arg_required_else_help = true)]
     Convert {
@@ -2947,7 +2950,7 @@ fn main() {
             parse_csv();
             parse_json();
         }
-        Commands::Run { input_paths, steps, instrumentation, output_path, query_pattern, query_template } => {
+        Commands::Run { input_paths, steps, instrumentation, output_path, query_pattern, query_template, timeout } => {
             #[cfg(debug_assertions)]
             println!("WARNING running in debug, if unintentional, build with --release");
             let mut s = Space::new();
@@ -2958,8 +2961,21 @@ fn main() {
             }
             if instrumentation > 0 { println!("loaded {} expressions", s.btm.val_count()) }
             println!("loaded {:?} ; running and outputing to {:?}", &input_paths, output_path.as_ref().or(Some(&"stdout".to_string())));
+            let timeout_duration = if timeout > 0 { Some(Duration::from_secs(timeout)) } else { None };
             let t0 = Instant::now();
-            let mut performed = s.metta_calculus(steps);
+            let mut performed = 0;
+            while performed < steps {
+                if let Some(td) = timeout_duration {
+                    if t0.elapsed() >= td {
+                        break;
+                    }
+                }
+                let p = s.metta_calculus(1);
+                performed += p;
+                if p == 0 {
+                    break;
+                }
+            }
             println!("executing {performed} steps took {} ms (unifications {}, writes {}, transitions {})", t0.elapsed().as_millis(), unsafe { unifications }, unsafe { writes }, unsafe { transitions });
             if instrumentation > 0 { println!("dumping {} expressions", s.btm.val_count()) }
             let query_pattern_expr = query_pattern.as_ref().map(|p| expr!(s, p));