fix 400

src/main.rs

@@ -1,11 +1,12 @@
-use std::error::Error;
+use std::{collections::HashMap, error::Error, hash::Hash, process::exit};
 
-use reqwest::Client;
+use reqwest::{header::{HeaderMap, HeaderValue}, Client};
 use serde::{Deserialize, Serialize};
 
 use clap::Parser;
 
 const GREEN: &str = "\x1b[1;32m";
+const RED:   &str = "\x1b[1;31m";
 const RESET: &str = "\x1b[0m";
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
@@ -27,54 +28,58 @@ struct ChatChunk {
     pub created: u64,
     pub id: String,
     pub action: String,
-    pub model: String
+    pub model: String,
+}
+
+#[derive(Debug, Clone, Serialize, Deserialize)]
+struct ErrChatChunk {
+    pub action: String,
+    pub status: u64,
+    #[serde(rename = "type")]
+    pub err_type: String,
+}
+
+fn get_headers() -> HeaderMap {
+    let mut map = HeaderMap::new();
+    map.insert("Host", HeaderValue::from_static("duckduckgo.com"));
+    map.insert("Accept", HeaderValue::from_static("*/*"));
+    map.insert("Accept-Language", HeaderValue::from_static("en-US,en;q=0.5"));
+    map.insert("Accept-Encoding", HeaderValue::from_static("gzip, deflate, br"));
+    map.insert("Referer", HeaderValue::from_static("https://duckduckgo.com/"));
+    map.insert("User-Agent", HeaderValue::from_static("Mozilla/5.0 (X11; Linux x86_64; rv:124.0) Gecko/20100101 Firefox/124.0"));
+    map.insert("DNT", HeaderValue::from_static("1"));
+    map.insert("Sec-GPC", HeaderValue::from_static("1"));
+    map.insert("Connection", HeaderValue::from_static("keep-alive"));
+    map.insert("Cookie", HeaderValue::from_static("dcm=3"));
+    map.insert("Sec-Fetch-Dest", HeaderValue::from_static("empty"));
+    map.insert("Sec-Fetch-Mode", HeaderValue::from_static("cors"));
+    map.insert("Sec-Fetch-Site", HeaderValue::from_static("same-origin"));
+    map.insert("TE", HeaderValue::from_static("trailers"));
+
+    map
 }
 
 async fn simulate_browser_reqs(cli: &Client) -> Result<(), Box<dyn Error>> {
     let req = cli.get("https://duckduckgo.com/country.json")
-        .header("Host", "duckduckgo.com")
+        .headers(get_headers())
-        .header("Accept", "*/*")
-        .header("Accept-Language", "en-US,en;q=0.5")
-        .header("Accept-Encoding", "gzip, deflate, br")
-        .header("Referer", "https://duckduckgo.com/")
         .header("X-Requested-With", "XMLHttpRequest")
-        .header("User-Agent", "Mozilla/5.0 (X11; Linux x86_64; rv:124.0) Gecko/20100101 Firefox/124.0")
-        .header("DNT", "1")
-        .header("Sec-GPC", "1")
-        .header("Connection", "keep-alive")
-        .header("Cookie", "dcm=3")
-        .header("Sec-Fetch-Dest", "empty")
-        .header("Sec-Fetch-Mode", "cors")
-        .header("Sec-Fetch-Site", "same-origin")
         .build()?;
     cli.execute(req).await?;
     Ok(())
 }
 
 async fn get_vqd(cli: &Client) -> Result<String, Box<dyn Error>> {
+
+    let mut headers = get_headers();
+    headers.insert("Cache-Control", HeaderValue::from_static("no-store"));
+    headers.insert("x-vqd-accept", HeaderValue::from_static("1"));
+
     let req = cli.get("https://duckduckgo.com/duckchat/v1/status")
-        .header("Accept", "*/*")
+        .headers(headers)
-        .header("Accept-Language", "en-US,en;q=0.5")
-        .header("Accept-Encoding", "gzip, deflate, br")
-        .header("Host", "duckduckgo.com")
-        .header("Referer", "https://duckduckgo.com/")
-        .header("Cache-Control", "no-store")
-        .header("x-vqd-accept", "1")
-        .header("User-Agent", "Mozilla/5.0 (X11; Linux x86_64; rv:124.0) Gecko/20100101 Firefox/124.0")
-        .header("DNT", "1")
-        .header("Connection", "keep-alive")
-        .header("Cookie", "dcm=3")
-        .header("Sec-Fetch-Dest", "empty")
-        .header("Sec-Fetch-Mode", "cors")
-        .header("Sec-Fetch-Site", "same-origin")
-        .header("Sec-GPC", "1")
-        .header("TE", "trailers")
         .build()?;
 
     let res = cli.execute(req).await?;
 
-    // stdout().write(res.bytes().await.unwrap().to_vec().as_slice()).unwrap();
-
     let data = res.headers().iter().find(|x| x.0 == "x-vqd-4").map(|x| x.1.clone());
     if let Some(data) = data {
         Ok(data.to_str()?.to_string())
@@ -83,15 +88,17 @@ async fn get_vqd(cli: &Client) -> Result<String, Box<dyn Error>> {
     }
 }
 
-async fn get_res<T: Into<String>>(cli: &Client, query: T, vqd: String) {
+async fn get_res(cli: &Client, query: String, vqd: String) {
-    let query = query.into();
     let payload = ChatPayload {
         model: "claude-instant-1.2".into(),
         messages: vec![ ChatMessagePayload { role: "user".into(), content: query } ]
     };
     let payload = serde_json::to_string(&payload).unwrap();
 
+    // println!("{payload}\n\n{:#?}", headers);return;
+
     let req = cli.post("https://duckduckgo.com/duckchat/v1/chat")
+        // .headers(get_headers())
         .header("Content-Type", "application/json")
         .header("User-Agent", "Mozilla/5.0 (X11; Linux x86_64; rv:124.0) Gecko/20100101 Firefox/124.0")
         .header("x-vqd-4", vqd)
@@ -99,7 +106,16 @@ async fn get_res<T: Into<String>>(cli: &Client, query: T, vqd: String) {
         .build().unwrap();
 
     let mut res = cli.execute(req).await.unwrap();
+
     while let Some(chunk) = res.chunk().await.unwrap() {
+
+        if let Ok(obj) = serde_json::from_slice::<ErrChatChunk>(&chunk) {
+            if obj.action == "error" {
+                eprintln!("{RED}Error obtaining response: {} - {}{RESET}", obj.status, obj.err_type);
+                exit(1);
+            }
+        }
+
         let chunk = String::from_utf8(chunk.to_vec()).unwrap();
         let chunk = chunk.replace("data: ", "");
         for line in chunk.lines() {
@@ -129,7 +145,7 @@ async fn main() {
     let query = args.query.join(" ");
 
     let cli = Client::new();
-    simulate_browser_reqs(&cli).await.unwrap();
+    // simulate_browser_reqs(&cli).await.unwrap();
     let vqd = get_vqd(&cli).await.unwrap();
     get_res(&cli, query, vqd).await;