Add CSV export to frontend API

ofdb-frontend-api/src/lib.rs

@@ -2,6 +2,8 @@ use gloo_net::http::Response;
 use serde::de::DeserializeOwned;
 use thiserror::Error;
 
+use ofdb_boundary::MapBbox;
+
 mod clearance;
 mod public;
 mod user;
@@ -48,3 +50,8 @@ where
         Err(response.json::<ofdb_boundary::Error>().await?.into())
     }
 }
+
+pub(crate) fn bbox_string(bbox: &MapBbox) -> String {
+    let MapBbox { sw, ne } = bbox;
+    format!("{},{},{},{}", sw.lat, sw.lng, ne.lat, ne.lng)
+}

ofdb-frontend-api/src/public.rs

@@ -7,7 +7,7 @@ use ofdb_boundary::{
     TagFrequency, UpdatePlace,
 };
 
-use crate::{into_json, Result, UserApi};
+use crate::{bbox_string, into_json, Result, UserApi};
 
 /// Public OpenFairDB API
 #[derive(Clone, Copy)]
@@ -212,8 +212,3 @@ impl PublicApi {
         into_json(response).await
     }
 }
-
-fn bbox_string(bbox: &MapBbox) -> String {
-    let MapBbox { sw, ne } = bbox;
-    format!("{},{},{},{}", sw.lat, sw.lng, ne.lat, ne.lng)
-}

ofdb-frontend-api/src/user.rs

@@ -1,10 +1,11 @@
 use gloo_net::http::{Request, RequestBuilder};
+use percent_encoding::{utf8_percent_encode, NON_ALPHANUMERIC};
 use serde::{de::DeserializeOwned, Serialize};
 use web_sys::RequestCredentials;
 
-use ofdb_boundary::{BboxSubscription, JwtToken, Review, User};
+use ofdb_boundary::{BboxSubscription, JwtToken, MapBbox, Review, User};
 
-use crate::{into_json, Result};
+use crate::{bbox_string, into_json, Result};
 
 /// Authorized OpenFairDB API
 #[derive(Clone)]
@@ -76,4 +77,20 @@ impl UserApi {
         let request = Request::post(&url);
         self.send_json(request, review).await
     }
+
+    // TODO: add other options like `limit`, `tags`, etc.
+    pub async fn export_csv(&self, bbox: &MapBbox, search_term: Option<&str>) -> Result<String> {
+        let bbox_string = bbox_string(bbox);
+        let search = search_term
+            .map(|term| {
+                let encoded_txt = utf8_percent_encode(term, NON_ALPHANUMERIC);
+                format!("&text={encoded_txt}")
+            })
+            .unwrap_or_default();
+        let url = format!("{}/export/entries.csv?bbox={bbox_string}{search}", self.url);
+        let request = self.add_auth_headers(Request::get(&url));
+        let response = request.send().await?;
+        let csv_string = response.text().await?;
+        Ok(csv_string)
+    }
 }

ofdb-frontend-api/src/util.rs

@@ -18,3 +18,4 @@ where
         Err(response.json::<ofdb_boundary::Error>().await?.into())
     }
 }
+