Ground work for @Validate in operators module

src/blueprint/operators/mod.rs

@@ -5,6 +5,7 @@ mod grpc;
 mod http;
 mod modify;
 mod protected;
+// mod validate;
 
 pub use call::*;
 pub use expr::*;
@@ -13,3 +14,4 @@ pub use grpc::*;
 pub use http::*;
 pub use modify::*;
 pub use protected::*;
+// pub use validate::*;

src/blueprint/operators/validate.rs

@@ -0,0 +1,26 @@
+// use crate::blueprint::FieldDefinition;
+// use crate::config::{self, ConfigModule, Field};
+// use crate::lambda::{Expression, IO};
+// use crate::try_fold::TryFold;
+// use crate::valid::Valid;
+
+// pub fn update_validate<'a>(
+//     type_name: &'a str,
+// ) -> TryFold<'a, (&'a ConfigModule, &'a Field, &'a config::Type, &'a str), FieldDefinition, String>
+// {
+//     TryFold::<(&ConfigModule, &Field, &config::Type, &'a str), FieldDefinition, String>::new(
+//         |(config_module, field, _type, _), mut b_field| {
+//             if field.validate.is_some()
+//                 || _type.validate.is_some()
+//                 || config_module
+//                     .find_type(&field.type_of)
+//                     .and_then(|_type| _type.validate.as_ref())
+//                     .is_some()
+//             {
+//                 if !config_module.is_scalar(type_name) {
+//                     return Valid::fail("@validate can only be used on custom scalars".to_owned());
+//                 }
+//             }
+//         }
+//     )
+// }

src/config/config.rs

@@ -111,6 +111,10 @@ pub struct Type {
     ///
     /// Contains source information for the type.
     pub tag: Option<Tag>,
+    ///
+    /// Indicates if a custom scalar type is valid
+    /// for a given JS function
+    pub validate: Option<Validate>,
 }
 
 impl Type {
@@ -603,10 +607,10 @@ pub struct Expr {
     pub body: Value,
 }
 
-#[derive(Clone, Debug, PartialEq, Deserialize, Serialize, Eq, schemars::JsonSchema)]
+#[derive(Clone, Debug, PartialEq, Deserialize, Serialize, Eq, schemars::JsonSchema, MergeRight)]
 pub struct Validate {
     /// Name of the JS function
-    pub js: JS,
+    pub js: String,
 }
 
 #[derive(Serialize, Deserialize, Clone, Debug, PartialEq, Eq, schemars::JsonSchema)]

src/config/from_document.rs

@@ -243,11 +243,12 @@ where
         .fuse(to_fields(fields))
         .fuse(Protected::from_directives(directives.iter()))
         .fuse(Tag::from_directives(directives.iter()))
-        .map(|(cache, fields, protected, tag)| {
+        .fuse(Validate::from_directives(directives.iter()))
+        .map(|(cache, fields, protected, tag, validate)| {
             let doc = description.to_owned().map(|pos| pos.node);
             let implements = implements.iter().map(|pos| pos.node.to_string()).collect();
             let added_fields = to_add_fields_from_directives(directives);
-            config::Type { fields, added_fields, doc, implements, cache, protected, tag }
+            config::Type { fields, added_fields, doc, implements, cache, protected, tag, validate }
         })
 }
 fn to_input_object(

src/config/into_document.rs

@@ -266,6 +266,7 @@ fn get_directives(field: &crate::config::Field) -> Vec<Positioned<ConstDirective
         field.cache.as_ref().map(|d| pos(d.to_directive())),
         field.call.as_ref().map(|d| pos(d.to_directive())),
         field.protected.as_ref().map(|d| pos(d.to_directive())),
+        field.validate.as_ref().map(|d| pos(d.to_directive())),
     ];
 
     directives.into_iter().flatten().collect()