feat: プラグイン名をSourceAudioSinkからSpeechToTextに変更し、起動処理を追加

Author: sile

src/plugin.rs

@@ -1,26 +1,58 @@
 use std::path::PathBuf;
+use std::process::{Command, Stdio};
+
+use orfail::OrFail;
 
 use crate::json::JsonObject;
+use crate::media::MediaStreamId;
 
 #[derive(Debug, Clone)]
-pub struct SourceAudioSinkPluginSpec {
+pub struct SpeechToTextPluginSpec {
     pub command: PathBuf,
     pub args: Vec<String>,
+    pub output_file: PathBuf,
 }
 
-impl<'text, 'raw> TryFrom<nojson::RawJsonValue<'text, 'raw>> for SourceAudioSinkPluginSpec {
+impl<'text, 'raw> TryFrom<nojson::RawJsonValue<'text, 'raw>> for SpeechToTextPluginSpec {
     type Error = nojson::JsonParseError;
 
     fn try_from(value: nojson::RawJsonValue<'text, 'raw>) -> Result<Self, Self::Error> {
         let obj = JsonObject::new(value)?;
         Ok(Self {
             command: obj.get_required("command")?,
             args: obj.get("args")?.unwrap_or_default(),
+            output_file: obj.get_required("output_file")?,
         })
     }
 }
 
 #[derive(Debug)]
-pub struct SourceAudioSinkPlugin {
+pub struct SpeechToTextPlugin {
     pub process: std::process::Child,
+    pub input_stream_ids: Vec<MediaStreamId>,
+}
+
+impl SpeechToTextPlugin {
+    pub fn start(
+        input_stream_ids: Vec<MediaStreamId>,
+        spec: &SpeechToTextPluginSpec,
+    ) -> orfail::Result<Self> {
+        let process = Command::new(&spec.command)
+            .args(&spec.args)
+            .stdin(Stdio::piped())
+            .stdout(Stdio::piped())
+            .stderr(Stdio::inherit())
+            .spawn()
+            .or_fail_with(|e| {
+                format!(
+                    "failed to start speech-to-text plugin command '{}': {e}",
+                    spec.command.display()
+                )
+            })?;
+
+        Ok(Self {
+            process,
+            input_stream_ids,
+        })
+    }
 }