Merge pull request #148 from Shopify/shopify-function-crate-ga

Propagate the Functions crate to (important) Rust templates and samples

Author: nickwesselman

.graphqlrc.cjs

@@ -0,0 +1,38 @@
+/**
+ * Configures the GraphQL language server for all the function schemas in this repo.
+ */
+const fs = require('node:fs');
+
+function getProjects(path) {
+    const projects = {}
+
+    const extensions = fs.readdirSync(`./${path}`);
+    for (const entry of extensions) {
+        const extensionPath = `./${path}/${entry}`;
+        const schema = `${extensionPath}/schema.graphql`;
+        if(!fs.existsSync(schema)) {
+            continue;
+        }
+
+        const projectName = extensionPath.substring(2).replaceAll('/', '-');
+        projects[projectName] = {
+            schema,
+            documents: `${extensionPath}/input.graphql`
+        }
+    }
+    
+    return projects;
+}
+
+const projects = {
+    ...getProjects("sample-apps/discounts-tutorial/extensions"),
+    ...getProjects("checkout/rust/delivery-customization"),
+    ...getProjects("checkout/rust/payment-customization"),
+    ...getProjects("discounts/rust/order-discounts"),
+    ...getProjects("discounts/rust/product-discounts"),
+    ...getProjects("discounts/rust/shipping-discounts"),
+}
+
+module.exports = {
+    projects
+};

.vscode/settings.json

@@ -0,0 +1,13 @@
+{
+    "rust-analyzer.linkedProjects": [
+      "checkout/rust/delivery-customization/default/Cargo.toml",
+      "checkout/rust/payment-customization/default/Cargo.toml",
+      "discounts/rust/order-discounts/default/Cargo.toml",
+      "discounts/rust/order-discounts/fixed-amount/Cargo.toml",
+      "discounts/rust/product-discounts/default/Cargo.toml",
+      "discounts/rust/product-discounts/fixed-amount/Cargo.toml",
+      "discounts/rust/shipping-discounts/default/Cargo.toml",
+      "discounts/rust/shipping-discounts/fixed-amount/Cargo.toml",
+      "sample-apps/discounts-tutorial/extensions/volume/Cargo.toml"
+    ]
+  }

checkout/rust/delivery-customization/default/.gitignore

@@ -1,2 +1,3 @@
 /target
+Cargo.lock
 .output.graphql

checkout/rust/delivery-customization/default/Cargo.toml.liquid

@@ -6,8 +6,8 @@ edition = "2021"
 [dependencies]
 serde = { version = "1.0.13", features = ["derive"] }
 serde_json = "1.0"
-shopify_function = { version = "0.2.3" }
-graphql_client = { git = "https://github.com/graphql-rust/graphql-client", rev = "0776197ad7cfde2c658490e7c7e627a21ed622cb" }
+shopify_function = { version = "0.2.4" }
+graphql_client = { version = "0.12.0" }
 
 [profile.release]
 lto = true

checkout/rust/payment-customization/default/.gitignore

@@ -1,2 +1,3 @@
 /target
+Cargo.lock
 .output.graphql

checkout/rust/payment-customization/default/Cargo.toml.liquid

@@ -6,8 +6,8 @@ edition = "2021"
 [dependencies]
 serde = { version = "1.0.13", features = ["derive"] }
 serde_json = "1.0"
-shopify_function = { version = "0.2.3" }
-graphql_client = { git = "https://github.com/graphql-rust/graphql-client", rev = "0776197ad7cfde2c658490e7c7e627a21ed622cb" }
+shopify_function = { version = "0.2.4" }
+graphql_client = { version = "0.12.0" }
 
 [profile.release]
 lto = true

discounts/rust/order-discounts/default/.gitignore

@@ -1,2 +1,3 @@
 /target
 Cargo.lock
+.output.graphql

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

@@ -5,8 +5,9 @@ edition = "2021"
 
 [dependencies]
 serde = { version = "1.0.13", features = ["derive"] }
-serde_with = "1.13.0"
 serde_json = "1.0"
+shopify_function = { version = "0.2.4" }
+graphql_client = { version = "0.12.0" }
 
 [profile.release]
 lto = true

discounts/rust/order-discounts/default/src/api.rs

@@ -1,90 +1,44 @@
+use shopify_function::prelude::*;
+use shopify_function::Result;
+
 use serde::{Deserialize, Serialize};
 
-mod api;
-use api::*;
+generate_types!(
+    query_path = "./input.graphql",
+    schema_path = "./schema.graphql"
+);
+
 
-#[derive(Clone, Debug, Serialize, Deserialize, Default)]
-#[serde(rename_all = "camelCase")]
-pub struct Configuration {}
+#[derive(Serialize, Deserialize, Default, PartialEq)]
+#[serde(rename_all(deserialize = "camelCase"))]
+struct Configuration {
+
+}
 
 impl Configuration {
     fn from_str(value: &str) -> Self {
         serde_json::from_str(value).expect("Unable to parse configuration value from metafield")
     }
 }
 
-impl input::Input {
-    pub fn configuration(&self) -> Configuration {
-        match &self.discount_node.metafield {
-            Some(input::Metafield { value }) => Configuration::from_str(value),
-            None => Configuration::default(),
-        }
-    }
-}
+#[shopify_function]
+fn function(input: input::ResponseData) -> Result<output::FunctionResult> {
+    let no_discount = output::FunctionResult {
+        discounts: vec![],
+        discount_application_strategy: output::DiscountApplicationStrategy::FIRST,
+    };
 
-fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let input: input::Input = serde_json::from_reader(std::io::BufReader::new(std::io::stdin()))?;
-    let mut out = std::io::stdout();
-    let mut serializer = serde_json::Serializer::new(&mut out);
-    function(input)?.serialize(&mut serializer)?;
-    Ok(())
-}
+    let _config = match input.discount_node.metafield {
+        Some(input::InputDiscountNodeMetafield { value }) => 
+            Configuration::from_str(&value),
+        None => return Ok(no_discount),
+    };
 
-fn function(input: input::Input) -> Result<FunctionResult, Box<dyn std::error::Error>> {
-    let _config = input.configuration();
-    Ok(FunctionResult {
+    Ok(output::FunctionResult {
         discounts: vec![],
-        discount_application_strategy: DiscountApplicationStrategy::First,
+        discount_application_strategy: output::DiscountApplicationStrategy::FIRST,
     })
 }
 
 #[cfg(test)]
-mod tests {
-    use super::*;
-
-    fn input(config: Option<Configuration>) -> input::Input {
-        input::Input {
-            discount_node: input::DiscountNode {
-                metafield: Some(input::Metafield {
-                    value: serde_json::to_string(&config.unwrap_or_default()).unwrap()
-                }),
-            },
-        }
-    }
-
-    #[test]
-    fn test_discount_with_no_configuration() {
-        let input = input(None);
-        let handle_result = serde_json::json!(function(input).unwrap());
-
-        let expected_handle_result = serde_json::json!({
-            "discounts": [],
-            "discountApplicationStrategy": "FIRST",
-        });
-        assert_eq!(handle_result, expected_handle_result);
-    }
-
-    #[test]
-    fn test_discount_with_configuration() {
-        let input = input(Some(Configuration {}));
-        let handle_result = serde_json::json!(function(input).unwrap());
-
-        let expected_handle_result = serde_json::json!({
-            "discounts": [],
-            "discountApplicationStrategy": "FIRST",
-        });
-        assert_eq!(handle_result, expected_handle_result);
-    }
-
-    #[test]
-    fn test_input_deserialization() {
-        let input_json = r#"
-        {
-            "discountNode": { "metafield": { "value": "{}" } }
-        }
-        "#;
-
-        let expected_input = input(Some(Configuration {}));
-        assert_eq!(expected_input, serde_json::from_str::<input::Input>(input_json).unwrap());
-    }
-}
+mod tests;