Method embed_sync

atomic-repository/src/ai/mod.rs:163–194

Synchronous embed using a throwaway tokio runtime (for use in non-async contexts). When called from within an existing Tokio runtime (e.g., from hook handlers that call `vault_store` → `vault_auto_index` → `embed_sync`), spawns a separate thread to avoid the "cannot start a runtime from within a runtime" panic.

(&self, texts: &[String])

    /// separate thread to avoid the "cannot start a runtime from within a runtime"
    /// panic.
    pub fn embed_sync(&self, texts: &[String]) -> Result<Vec<Vec<f32>>, AiError> {
        match self.provider {
            AiProvider::Local | AiProvider::None => Ok(texts
                .iter()
                .map(|t| crate::hash_embed(t, self.dimensions))
                .collect()),
            _ => {
                if tokio::runtime::Handle::try_current().is_ok() {
                    // Already inside an async runtime — run the API call on a
                    // separate thread with its own runtime to avoid nesting.
                    let provider = self.clone();
                    let texts = texts.to_vec();
                    std::thread::spawn(move || {
                        let rt = tokio::runtime::Builder::new_current_thread()
                            .enable_all()
                            .build()
                            .map_err(|e| AiError::Runtime(e.to_string()))?;
                        rt.block_on(provider.embed(&texts))
                    })
                    .join()
                    .unwrap_or_else(|_| Err(AiError::Runtime("Embedding thread panicked".into())))
                } else {
                    // Not inside a runtime — create a throwaway one directly.
                    let rt = tokio::runtime::Builder::new_current_thread()
                        .enable_all()
                        .build()
                        .map_err(|e| AiError::Runtime(e.to_string()))?;
                    rt.block_on(self.embed(texts))
                }
            }
        }
    }

    async fn embed_voyage(&self, texts: &[String]) -> Result<Vec<Vec<f32>>, AiError> {
        let api_key = self.api_key.as_ref().ok_or(AiError::NoApiKey)?;