found the type needed to pass closures with local variables

models/testme/Cargo.lock

@@ -0,0 +1,7 @@
+# This file is automatically @generated by Cargo.
+# It is not intended for manual editing.
+version = 3
+
+[[package]]
+name = "testme"
+version = "0.1.0"

models/testme/Cargo.toml

@@ -0,0 +1,8 @@
+[package]
+name = "testme"
+version = "0.1.0"
+edition = "2021"
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]

models/testme/src/main.rs

@@ -0,0 +1,4 @@
+fn main() {
+   let bytes = include_bytes!("./test.txt");
+   println!("{}", String::from_utf8_lossy(bytes));
+}

models/testme/src/test.txt

@@ -0,0 +1 @@
+../../ggml-tiny.en.bin

src/main.rs

@@ -5,27 +5,50 @@ use std::time::{Duration, Instant};
 use chrono;
 use clap::Parser;
 use std::thread;
+use std::fs::File;
+use std::io::Write;
 
 #[derive(Parser, Debug)]
 struct Flags {
-   #[arg(long, default_value = "../models/ggml-tiny.en.bin")]
+   #[arg(long, default_value = "./models/ggml-tiny.en.bin")]
    model: String,
 
    #[arg(long, default_value = "8")]
    threads: i32,
 
-   #[arg(long, default_value = "1.0")]
-   stream_retain: f32,
    #[arg(long, default_value = "5")]
    stream_step: u64,
+   #[arg(long, default_value = "0.6")]
+   stream_retain: f32,
+   #[arg(long, default_value = "0.3")]
+   stream_head: f32,
+   #[arg(long, default_value = "0.3")]
+   stream_tail: f32,
 
    wav: Option<String>,
+
+   #[arg(long, default_value = "false")]
+   debug: bool,
 }
 
 fn main() {
    let flags = Flags::parse();
 
-   let w = new_whisper(flags.model, flags.threads, Handler{}).unwrap();
+   let w = new_whisper_service(
+      flags.model,
+      flags.threads,
+      flags.stream_head,
+      flags.stream_tail,
+      |result: Result<Whispered, String>| {
+         match result {
+            Ok(whispered) => {
+               eprintln!("{}: {:?}", chrono::Local::now(), whispered);
+               println!("{}", whispered.to_string());
+            },
+            Err(msg) => { eprintln!("Error whispering: {}", msg); },
+         };
+      },
+   ).unwrap();
    let stream_retain = (flags.stream_retain * 16_000.0) as usize;
    let stream_step = Duration::new(flags.stream_step, 0);
    match flags.wav {
@@ -41,18 +64,33 @@ fn main() {
          w.transcribe(&audio_data);
       },
       None => {
+         match &flags.debug {
+            true => { File::create("/tmp/page.rawf32audio").unwrap(); },
+            false => {},
+         };
          let mut buffer = vec![];
          let mut last = Instant::now();
          new_listener().listen(move |data: Vec<f32>| {
             data.iter().for_each(|x| buffer.push(*x));
             if Instant::now() - last > stream_step {
-               match w.transcribe_async(&buffer) {
-                  Ok(_) => (),
-                  Err(msg) => eprintln!("{}", msg),
+               w.transcribe_async(&buffer).unwrap();
+
+               match &flags.debug {
+                  true => {
+                     let mut f = File::options().append(true).open("/tmp/page.rawf32audio").unwrap();
+                     let mut wav_data = vec![];
+                     for i in buffer.iter() {
+                        for j in i.to_le_bytes() {
+                           wav_data.push(j);
+                        }
+                     }
+                     f.write_all(wav_data.as_slice()).unwrap();
+                  },
+                  false => {},
                };
 
-               for i in stream_retain..buffer.len() {
-                  buffer[i - stream_retain] = buffer[i]
+               for i in 0..stream_retain {
+                  buffer[i] = buffer[buffer.len() - stream_retain + i];
                }
                buffer.truncate(stream_retain);
                last = Instant::now();
@@ -62,30 +100,25 @@ fn main() {
    };
 }
 
-struct Whisper {
+struct WhisperService {
    jobs: std::sync::mpsc::SyncSender<AWhisper>,
 }
 
-struct WhisperEngine {
-   ctx: WhisperContext,
-   threads: i32,
-   handler: Handler,
-}
-
-fn new_whisper(model_path: String, threads: i32, handler: Handler) -> Result<Whisper, String> {
-   match new_whisper_engine(model_path, threads, handler) {
+fn new_whisper_service<F>(model_path: String, threads: i32, stream_head: f32, stream_tail: f32, handler_fn: F) -> Result<WhisperService, String> where F: FnMut(Result<Whispered, String>) + Send + 'static {
+   match new_whisper_engine(model_path, threads) {
       Ok(engine) => {
+         let mut whisper = new_whisper_impl(engine, stream_head, stream_tail, handler_fn);
          let (send, recv) = std::sync::mpsc::sync_channel(100);
-         thread::spawn(move || { engine.transcribe_asyncs(recv); });
-         Ok(Whisper{jobs: send})
+         thread::spawn(move || { whisper.transcribe_asyncs(recv); });
+         Ok(WhisperService{jobs: send})
       },
       Err(msg) => Err(format!("failed to initialize engine: {}", msg)),
    }
 }
 
-impl Whisper {
+impl WhisperService {
    fn transcribe(&self, data: &Vec<f32>) {
-      let (send, recv) = std::sync::mpsc::sync_channel(1);
+      let (send, recv) = std::sync::mpsc::sync_channel(0);
       self._transcribe_async(data, Some(send)).unwrap();
       recv.recv().unwrap();
    }
@@ -105,41 +138,79 @@ impl Whisper {
    }
 }
 
-fn new_whisper_engine(model_path: String, threads: i32, handler: Handler) -> Result<WhisperEngine, String> {
-   match WhisperContext::new(&model_path) {
-      Ok(ctx) => Ok(WhisperEngine{ctx: ctx, threads: threads, handler: handler}),
-      Err(msg) => Err(format!("failed to load {}: {}", model_path, msg)),
+struct WhisperImpl {
+   engine: WhisperEngine,
+   stream_head: f32,
+   stream_tail: f32,
+   handler_fn: Option<Box<dyn FnMut(Result<Whispered, String>) + Send + 'static>>
+}
+
+fn new_whisper_impl<F>(engine: WhisperEngine, stream_head: f32, stream_tail: f32, handler_fn: F) -> WhisperImpl where F: FnMut(Result<Whispered, String>) + Send + 'static {
+   WhisperImpl {
+      engine: engine,
+      stream_head: stream_head,
+      stream_tail: stream_tail,
+      handler_fn: Some(Box::new(handler_fn)),
    }
 }
 
-impl WhisperEngine {
-   fn transcribe_asyncs(&self, recv: std::sync::mpsc::Receiver<AWhisper>) {
+impl WhisperImpl {
+   fn transcribe_asyncs(&mut self, recv: std::sync::mpsc::Receiver<AWhisper>) {
       loop {
          match recv.recv() {
             Ok(job) => {
-               match self.transcribe(&job.data) {
-                  Ok(result) => {
-                     self.handler.on_success(result);
+               let result = self.transcribe(&job).is_ok();
                match job.ack {
-                        Some(ack) => { let _ = ack.send(true); },
+                  Some(ack) => {
+                     ack.send(result).unwrap();
+                  },
                   None => (),
                };
-                  },
-                  Err(msg) => {
-                     self.handler.on_error(format!("failed to transcribe: {}", msg));
-                     match job.ack {
-                        Some(ack) => { let _ = ack.send(false); },
-                        None => (),
-                     };
-                  },
-               };
-            },
+            }
             Err(_) => return,
          };
       }
    }
 
-   fn transcribe(&self, data: &Vec<f32>) -> Result<String, WhisperError> {
+   fn transcribe(&mut self, a_whisper: &AWhisper) -> Result<(), ()> {
+      match self.engine.transcribe(&a_whisper.data) {
+         Ok(result) => {
+            self.on_success(&result);
+            Ok(())
+         },
+         Err(msg) => {
+            self.on_error(msg.to_string());
+            Err(())
+         },
+      }
+   }
+
+   fn on_success(&mut self, whispered: &Whispered) {
+      let result = whispered
+         .after(&(self.stream_head * 100.0))
+         .before(&(self.stream_tail * 100.0));
+      (self.handler_fn.as_mut().unwrap())(Ok(result));
+   }
+
+   fn on_error(&mut self, msg: String) {
+      (self.handler_fn.as_mut().unwrap())(Err(format!("failed to transcribe: {}", &msg)));
+   }
+}
+
+struct WhisperEngine {
+   ctx: WhisperContext,
+   threads: i32,
+}
+
+fn new_whisper_engine(model_path: String, threads: i32) -> Result<WhisperEngine, String> {
+   match WhisperContext::new(&model_path) {
+      Ok(ctx) => Ok(WhisperEngine{ctx: ctx, threads: threads}),
+      Err(msg) => Err(format!("failed to load {}: {}", model_path, msg)),
+   }
+}
+
+impl WhisperEngine {
+   fn transcribe(&self, data: &Vec<f32>) -> Result<Whispered, WhisperError> {
       let mut params = FullParams::new(SamplingStrategy::Greedy { best_of: 0 });
       params.set_no_context(true);
       params.set_n_threads(self.threads);
@@ -154,11 +225,13 @@ impl WhisperEngine {
       let mut state = self.ctx.create_state()?;
       state.full(params, &data[..])?;
 
+      let mut result = new_whispered();
       let num_segments = state.full_n_segments()?;
-      let mut result = "".to_string();
       for i in 0..num_segments {
-         let segment = state.full_get_segment_text(i)?;
-         result = format!("{} {}", result, segment);
+         let data = state.full_get_segment_text(i)?;
+         let start = state.full_get_segment_t0(i)?;
+         let stop = state.full_get_segment_t1(i)?;
+         result.push(data, start, stop);
       }
 
       Ok(result)
@@ -170,15 +243,70 @@ struct AWhisper {
    ack: Option<std::sync::mpsc::SyncSender<bool>>,
 }
 
-struct Handler {}
-
-impl Handler {
-   fn on_success(&self, result: String) {
-      eprintln!("{}", chrono::Local::now());
-      println!("{}", result);
+#[derive(Clone, Debug)]
+struct Whispered {
+   data: Vec<AWhispered>,
+}
+
+#[derive(Clone, Debug)]
+struct AWhispered {
+   data: String,
+   offset: i64,
+   length: i64,
+}
+
+fn new_whispered() -> Whispered {
+   Whispered{data: vec![]}
+}
+
+fn new_a_whispered(data: String, start: i64, stop: i64) -> AWhispered {
+   AWhispered{
+      data: data,
+      offset: start.clone(),
+      length: stop - start,
+   }
+}
+
+impl Whispered {
+   fn to_string(&self) -> String {
+      let mut result = "".to_string();
+      for i in 0..self.data.len() {
+         result = format!("{} {}", result, &self.data[i].data);
+      }
+      result
+   }
+
+   fn after(&self, t: &f32) -> Whispered {
+      let mut result = new_whispered();
+      self.data
+         .iter()
+         .filter(|x| x.offset as f32 >= *t)
+         .for_each(|x| result.data.push(x.clone()));
+      result
+   }
+
+   fn before(&self, t: &f32) -> Whispered {
+      let mut result = new_whispered();
+      let end = match self.data.iter().map(|x| x.offset + x.length).max() {
+         Some(x) => x,
+         None => 1,
+      };
+      let t = (end as f32) - *t;
+      self.data
+         .iter()
+         .filter(|x| ((x.offset) as f32) <= t)
+         .for_each(|x| result.data.push(x.clone()));
+      result
+   }
+
+   fn push(&mut self, data: String, start: i64, stop: i64) {
+      let words: Vec<_> = data.split_whitespace().collect();
+      let per_word = (stop - start) / (words.len() as i64);
+      for i in 0..words.len() {
+         let start = (i as i64) * per_word;
+         let stop = start.clone() + per_word;
+         self.data.push(new_a_whispered(words[i].to_string(), start, stop));
       }
-   fn on_error(&self, msg: String) {
-      eprintln!("error: {}", msg);
    }
 }
 
@@ -191,7 +319,7 @@ fn new_listener() -> Listener {
 
 impl Listener {
    fn listen(self, mut cb: impl FnMut(Vec<f32>)) {
-      let (send, recv) = std::sync::mpsc::sync_channel(5_000);
+      let (send, recv) = std::sync::mpsc::sync_channel(100);
       thread::spawn(move || { self._listen(send); });
       loop {
          match recv.recv() {