Rewrite apps/restate from TypeScript to Rust (restate-sdk 0.7.0, Soniox-only) (#3857)

Co-authored-by: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>
Co-authored-by: yujonglee <yujonglee.dev@gmail.com>

Author: devin-ai-integration[bot]

Cargo.lock

@@ -14,6 +14,7 @@ members = [
   "apps/desktop/src-tauri",
   "apps/eval-cli",
   "apps/granola",
+  "apps/restate",
   "apps/tools",
   "crates/*",
   "plugins/*",

Cargo.toml

@@ -0,0 +1,18 @@
+[package]
+name = "restate"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+restate-sdk = "0.7.0"
+
+chrono = { workspace = true, features = ["serde"] }
+dotenvy = { workspace = true }
+envy = { workspace = true }
+reqwest = { workspace = true, features = ["json"] }
+serde = { workspace = true, features = ["derive"] }
+serde_json = { workspace = true }
+tokio = { workspace = true, features = ["rt-multi-thread", "macros", "signal"] }
+tracing = { workspace = true }
+tracing-subscriber = { workspace = true, features = ["env-filter"] }
+urlencoding = { workspace = true }

apps/restate/.gitignore

@@ -0,0 +1,35 @@
+use std::path::Path;
+use std::sync::OnceLock;
+
+use serde::Deserialize;
+
+#[derive(Deserialize, Clone)]
+pub struct Env {
+    pub restate_identity_key: Option<String>,
+    pub restate_ingress_url: String,
+    pub soniox_api_key: String,
+    pub supabase_url: String,
+    pub supabase_service_role_key: String,
+    #[serde(default = "default_port")]
+    pub port: u16,
+}
+
+fn default_port() -> u16 {
+    9080
+}
+
+static ENV: OnceLock<Env> = OnceLock::new();
+
+pub fn env() -> &'static Env {
+    ENV.get_or_init(|| {
+        let manifest_dir = Path::new(env!("CARGO_MANIFEST_DIR"));
+        let repo_root = manifest_dir
+            .parent()
+            .and_then(|p| p.parent())
+            .unwrap_or(manifest_dir);
+        let _ = dotenvy::from_path(repo_root.join(".env.supabase"));
+        let _ = dotenvy::from_path(repo_root.join(".env.restate"));
+        let _ = dotenvy::from_path(manifest_dir.join(".env"));
+        envy::from_env().expect("Failed to load environment")
+    })
+}

apps/restate/Cargo.toml

@@ -0,0 +1,33 @@
+use restate_sdk::endpoint::Endpoint;
+use restate_sdk::http_server::HttpServer;
+
+mod env;
+mod services;
+mod soniox;
+mod supabase;
+
+use services::rate_limit::RateLimiter;
+use services::storage_cleanup::StorageCleanup;
+use services::stt_file::SttFile;
+
+#[tokio::main]
+async fn main() {
+    tracing_subscriber::fmt::init();
+    let env = env::env();
+
+    let mut builder = Endpoint::builder()
+        .bind(services::SttFileImpl::new(env).serve())
+        .bind(services::RateLimiterImpl.serve())
+        .bind(services::StorageCleanupImpl::new(env).serve());
+
+    if let Some(key) = &env.restate_identity_key {
+        builder = builder.identity_key(key).expect("invalid identity key");
+    }
+
+    let addr = format!("0.0.0.0:{}", env.port);
+    tracing::info!(addr = %addr, "server listening");
+
+    HttpServer::new(builder.build())
+        .listen_and_serve(addr.parse().unwrap())
+        .await;
+}