refactor(2671): Move retry logic from infer_type_name to wizard

Cargo.toml

@@ -169,6 +169,7 @@ indenter = "0.3.3"
 derive_more = { workspace = true }
 enum_dispatch = "0.3.13"
 strum = "0.26.2"
+tokio-retry = "0.3.0"
 
 [dev-dependencies]
 tailcall-prettier = { path = "tailcall-prettier" }

src/cli/llm/infer_type_name.rs

@@ -102,47 +102,37 @@
                     .collect(),
             };
 
-            let mut delay = 3;
-            loop {
-                let answer = wizard.ask(question.clone()).await;
-                match answer {
-                    Ok(answer) => {
-                        let name = &answer.suggestions.join(", ");
-                        for name in answer.suggestions {
-                            if config.types.contains_key(&name)
-                                || new_name_mappings.contains_key(&name)
-                            {
-                                continue;
-                            }
-                            new_name_mappings.insert(name, type_name.to_owned());
-                            break;
+            let answer = wizard.ask(question).await;
+            match answer {
+                Ok(answer) => {
+                    let name = &answer.suggestions.join(", ");
+                    for name in answer.suggestions {
+                        if config.types.contains_key(&name) || new_name_mappings.contains_key(&name)
+                        {
+                            continue;
                         }
-                        tracing::info!(
-                            "Suggestions for {}: [{}] - {}/{}",
-                            type_name,
-                            name,
-                            i + 1,
-                            total
-                        );
-
-                        // TODO: case where suggested names are already used, then extend the base
-                        // question with `suggest different names, we have already used following
-                        // names: [names list]`
+                        new_name_mappings.insert(name, type_name.to_owned());
                         break;
                     }
-                    Err(e) => {
-                        // TODO: log errors after certain number of retries.
-                        if let Error::GenAI(_) = e {
-                            // TODO: retry only when it's required.
-                            tracing::warn!(
-                                "Unable to retrieve a name for the type '{}'. Retrying in {}s",
-                                type_name,
-                                delay
-                            );
-                            tokio::time::sleep(tokio::time::Duration::from_secs(delay)).await;
-                            delay *= std::cmp::min(delay * 2, 60);
-                        }
-                    }
+                    tracing::info!(
+                        "Suggestions for {}: [{}] - {}/{}",
+                        type_name,
+                        name,
+                        i + 1,
+                        total
+                    );
+
+                    // TODO: case where suggested names are already used, then extend the base
+                    // question with `suggest different names, we have already used following
+                    // names: [names list]`
+                    break;
+                }
+                Err(e) => {
+                    tracing::warn!(
+                        "Unable to retrieve a name for the type '{}', skipping with error {}",
+                        type_name,
+                        e
+                    );
                 }
             }
         }

src/cli/llm/wizard.rs

@@ -1,8 +1,11 @@
+use std::time::Duration;
+
 use derive_setters::Setters;
 use genai::adapter::AdapterKind;
 use genai::chat::{ChatOptions, ChatRequest, ChatResponse};
 use genai::resolver::AuthResolver;
 use genai::Client;
+use tokio_retry::strategy::ExponentialBackoff;
 
 use super::Result;
 use crate::cli::llm::model::Model;
@@ -41,13 +44,22 @@
 
     pub async fn ask(&self, q: Q) -> Result<A>
     where
-        Q: TryInto<ChatRequest, Error = super::Error>,
+        Q: TryInto<ChatRequest, Error = super::Error> + Clone,
         A: TryFrom<ChatResponse, Error = super::Error>,
     {
-        let response = self
-            .client
-            .exec_chat(self.model.as_str(), q.try_into()?, None)
-            .await?;
-        A::try_from(response)
+        let retry = ExponentialBackoff::from_millis(1000)
+            .max_delay(Duration::from_secs(60))
+            .map(tokio_retry::strategy::jitter)
+            .take(10);
+
+        tokio_retry::Retry::spawn(retry, || async {
+            let response = self
+                .client
+                .exec_chat(self.model.as_str(), q.clone().try_into()?, None)
+                .await?;
+
+            A::try_from(response)
+        })
+        .await
     }
 }