1 files changed, 59 insertions, 0 deletions
diff --git a/third_party/rust/warp/examples/query_string.rs b/third_party/rust/warp/examples/query_string.rs
new file mode 100644
index 0000000000..869468eb0d
--- /dev/null
+++ b/third_party/rust/warp/examples/query_string.rs
@@ -0,0 +1,59 @@
+use serde_derive::{Deserialize, Serialize};
+use std::collections::HashMap;
+use warp::{
+    http::{Response, StatusCode},
+    Filter,
+};
+
+#[derive(Deserialize, Serialize)]
+struct MyObject {
+    key1: String,
+    key2: u32,
+}
+
+#[tokio::main]
+async fn main() {
+    pretty_env_logger::init();
+
+    // get /example1?key=value
+    // demonstrates an optional parameter.
+    let example1 = warp::get()
+        .and(warp::path("example1"))
+        .and(warp::query::<HashMap<String, String>>())
+        .map(|p: HashMap<String, String>| match p.get("key") {
+            Some(key) => Response::builder().body(format!("key = {}", key)),
+            None => Response::builder().body(String::from("No \"key\" param in query.")),
+        });
+
+    // get /example2?key1=value&key2=42
+    // uses the query string to populate a custom object
+    let example2 = warp::get()
+        .and(warp::path("example2"))
+        .and(warp::query::<MyObject>())
+        .map(|p: MyObject| {
+            Response::builder().body(format!("key1 = {}, key2 = {}", p.key1, p.key2))
+        });
+
+    let opt_query = warp::query::<MyObject>()
+        .map(Some)
+        .or_else(|_| async { Ok::<(Option<MyObject>,), std::convert::Infallible>((None,)) });
+
+    // get /example3?key1=value&key2=42
+    // builds on example2 but adds custom error handling
+    let example3 =
+        warp::get()
+            .and(warp::path("example3"))
+            .and(opt_query)
+            .map(|p: Option<MyObject>| match p {
+                Some(obj) => {
+                    Response::builder().body(format!("key1 = {}, key2 = {}", obj.key1, obj.key2))
+                }
+                None => Response::builder()
+                    .status(StatusCode::BAD_REQUEST)
+                    .body(String::from("Failed to decode query param.")),
+            });
+
+    warp::serve(example1.or(example2).or(example3))
+        .run(([127, 0, 0, 1], 3030))
+        .await
+}