use enteredDiscountCode

Author: jonathanhamel4

discounts/rust/discounts/default/Cargo.toml.liquid

@@ -2,7 +2,7 @@
 name = "{{handle | replace: " ", "-" | downcase}}"
 version = "1.0.0"
 edition = "2021"
-rust-version = "1.62"
+rust-version = "1.84"
 
 [dependencies]
 serde = { version = "1.0.13", features = ["derive"] }

discounts/rust/discounts/default/src/fetch.graphql.liquid

@@ -1,7 +1,3 @@
 query Input {
-  cart {
-      buyerIdentity {
-        email
-      }
-  }
+  enteredDiscountCodes
 }

discounts/rust/discounts/default/src/fetch.rs

@@ -0,0 +1,139 @@
+use serde_json::json;
+use shopify_function::prelude::*;
+use shopify_function::Result;
+
+use cart_fetch::output::{
+    FunctionCartFetchResult, HttpRequest as CartHttpRequest,
+    HttpRequestMethod as CartHttpRequestMethod, HttpRequestPolicy as CartHttpRequestPolicy,
+};
+
+use delivery_fetch::output::FunctionDeliveryFetchResult;
+use delivery_fetch::output::{
+    HttpRequest as DeliveryHttpRequest, HttpRequestMethod as DeliveryHttpRequestMethod,
+    HttpRequestPolicy as DeliveryHttpRequestPolicy,
+};
+
+type CartFetchResponseData = cart_fetch::input::ResponseData;
+type DeliveryFetchResponseData = delivery_fetch::input::ResponseData;
+type CartHttpRequestHeader = cart_fetch::output::HttpRequestHeader;
+type DeliveryHttpRequestHeader = delivery_fetch::output::HttpRequestHeader;
+
+#[shopify_function_target(
+    target = "cart_fetch",
+    query_path = "src/fetch.graphql",
+    schema_path = "schema.graphql"
+)]
+fn cart_fetch(input: CartFetchResponseData) -> Result<FunctionCartFetchResult> {
+    let body = json!({
+        "enteredDiscountCodes": input.entered_discount_codes
+    });
+
+    Ok(FunctionCartFetchResult {
+        request: Some(CartHttpRequest {
+            body: Some(body.to_string()),
+            headers: vec![CartHttpRequestHeader {
+                name: "Accept".to_string(),
+                value: "application/json; charset=utf-8".to_string(),
+            }],
+            json_body: Some(body.clone()),
+            method: CartHttpRequestMethod::POST,
+            policy: CartHttpRequestPolicy {
+                read_timeout_ms: 2000,
+            },
+            url: "http://localhost:3000".to_string(),
+        }),
+    })
+}
+
+#[shopify_function_target(
+    target = "delivery_fetch",
+    query_path = "src/fetch.graphql",
+    schema_path = "schema.graphql"
+)]
+fn delivery_fetch(input: DeliveryFetchResponseData) -> Result<FunctionDeliveryFetchResult> {
+    let body = json!({
+        "enteredDiscountCodes": input.entered_discount_codes
+    });
+
+    Ok(FunctionDeliveryFetchResult {
+        request: Some(DeliveryHttpRequest {
+            body: Some(body.to_string()),
+            headers: vec![DeliveryHttpRequestHeader {
+                name: "Accept".to_string(),
+                value: "application/json; charset=utf-8".to_string(),
+            }],
+            json_body: Some(body.clone()),
+            method: DeliveryHttpRequestMethod::POST,
+            policy: DeliveryHttpRequestPolicy {
+                read_timeout_ms: 2000,
+            },
+            url: "http://localhost:3000".to_string(),
+        }),
+    })
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use shopify_function::{run_function_with_input, Result};
+
+    fn get_fetch_input_json() -> serde_json::Value {
+        json!({
+            "enteredDiscountCodes": ["WELCOME10"]
+        })
+    }
+
+    #[test]
+    fn test_cart_fetch() -> Result<()> {
+        let fetch_input = get_fetch_input_json();
+
+        let expected_fetch_result = FunctionCartFetchResult {
+            request: Some(CartHttpRequest {
+                body: Some(fetch_input.to_string()),
+                headers: vec![CartHttpRequestHeader {
+                    name: "Accept".to_string(),
+                    value: "application/json; charset=utf-8".to_string(),
+                }],
+                json_body: Some(fetch_input.clone()),
+                method: CartHttpRequestMethod::POST,
+                policy: CartHttpRequestPolicy {
+                    read_timeout_ms: 2000,
+                },
+                url: "http://localhost:3000".to_string(),
+            }),
+        };
+
+        assert_eq!(
+            run_function_with_input(cart_fetch, &fetch_input.to_string())?,
+            expected_fetch_result
+        );
+        Ok(())
+    }
+
+    #[test]
+    fn test_delivery_fetch() -> Result<()> {
+        let fetch_input = get_fetch_input_json();
+
+        let expected_fetch_result = FunctionDeliveryFetchResult {
+            request: Some(DeliveryHttpRequest {
+                body: Some(fetch_input.to_string()),
+                headers: vec![DeliveryHttpRequestHeader {
+                    name: "Accept".to_string(),
+                    value: "application/json; charset=utf-8".to_string(),
+                }],
+                json_body: Some(fetch_input.clone()),
+                method: DeliveryHttpRequestMethod::POST,
+                policy: DeliveryHttpRequestPolicy {
+                    read_timeout_ms: 2000,
+                },
+                url: "http://localhost:3000".to_string(),
+            }),
+        };
+
+        assert_eq!(
+            run_function_with_input(delivery_fetch, &fetch_input.to_string())?,
+            expected_fetch_result
+        );
+        Ok(())
+    }
+}

discounts/rust/discounts/default/src/main.rs

@@ -1,4 +1,5 @@
 use std::process;
+pub mod fetch;
 pub mod run;
 
 fn main() {