version: 1.0.53

.agent/workflows/jspg.md

@@ -0,0 +1,49 @@
+---
+description: jspg work preparation
+---
+
+This workflow will get you up-to-speed on the JSPG custom json-schema-based cargo pgrx postgres validation extension. Everything you read will be in the jspg directory/project.
+
+Read over this entire workflow and commit to every section of work in a task list, so that you don't stop half way through before reviewing all of the directories and files mentioned. Do not ask for confirmation after generating this task list and proceed through all sections in your list.
+
+Please analyze the files and directories and do not use cat, find, or the terminal to discover or read in any of these files. Analyze every file mentioned. If a directory is mentioned or a /*, please analyze the directory, every single file at its root, and recursively analyze every subdirectory and every single file in every subdirectory to capture not just critical files, but the entirety of what is requested. I state again, DO NOT just review a cherry picking of files in any folder or wildcard specified. Review 100% of all files discovered recursively!
+
+Section 1: Documentation
+
+- GEMINI.md at the root
+
+Section 2: Flow file for cmd interface
+
+- flow at the root
+
+Section 3: Source
+
+- src/*
+
+Section 4: Test Fixtures
+
+- Just review some of the *.json files in tests/fixtures/*
+
+Section 5: Build
+
+- build.rs
+
+Section 6: Cargo TOML
+
+- Cargo.toml
+
+Section 7: Some PUNC Syntax
+
+Now, review some punc type and enum source in the api project with api/ these files:
+
+- punc/sql/tables.sql
+- punc/sql/domains.sql
+- punc/sql/indexes.sql
+- punc/sql/functions/entity.sql
+- punc/sql/functions/puncs.sql
+- punc/sql/puncs/entity.sql
+- punc/sql/puncs/persons.sql
+- punc/sql/puncs/puncs.sql
+- punc/sql/puncs/job.sql
+
+Now you are ready to help me work on this extension.

GEMINI.md

@@ -86,8 +86,9 @@ To support polymorphic fields (e.g., a field that accepts any "User" type), JSPG
 ### 3. Strict by Default & Extensibility
 JSPG enforces a "Secure by Default" philosophy. All schemas are treated as if `unevaluatedProperties: false` (and `unevaluatedItems: false`) is set, unless explicitly overridden.
 
-*   **Strictness**: By default, any property in the instance data that is not explicitly defined in the schema causes a validation error. This prevents clients from sending undeclared fields.
-*   **Extensibility (`extensible: true`)**: To allow additional, undefined properties, you must add `"extensible": true` to the schema. This is useful for types that are designed to be open for extension.
+*   **Strictness**: By default, any property or array item in the instance data that is not explicitly defined in the schema causes a validation error. This prevents clients from sending undeclared fields or extra array elements.
+*   **Extensibility (`extensible: true`)**: To allow a free-for-all of additional, undefined properties or extra array items, you must add `"extensible": true` to the schema. This globally disables the strictness check for that object or array, useful for types designed to be completely open.
+*   **Structured Additional Properties (`additionalProperties: {...}`)**: Instead of a boolean free-for-all, you can define `additionalProperties` as a schema object (e.g., `{"type": "string"}`). This maintains strictness (no arbitrary keys) but allows any extra keys as long as their values match the defined structure.
 *   **Ref Boundaries**: Strictness is reset when crossing `$ref` boundaries. The referenced schema's strictness is determined by its own definition (strict by default unless `extensible: true`), ignoring the caller's state.
 *   **Inheritance**: Strictness is inherited. A schema extending a strict parent will also be strict unless it declares itself `extensible: true`. Conversely, a schema extending a loose parent will also be loose unless it declares itself `extensible: false`.
 

build.rs

@@ -3,38 +3,38 @@ use std::fs::File;
 use std::io::Write;
 use std::path::Path;
 
+fn to_safe_identifier(name: &str) -> String {
+  let mut safe = String::new();
+  for (i, c) in name.chars().enumerate() {
+    if c.is_uppercase() {
+      if i > 0 {
+        safe.push('_');
+      }
+      safe.push(c.to_ascii_lowercase());
+    } else if c == '-' || c == '.' {
+      safe.push('_');
+    } else {
+      safe.push(c);
+    }
+  }
+  safe
+}
+
 fn main() {
   println!("cargo:rerun-if-changed=tests/fixtures");
   println!("cargo:rerun-if-changed=Cargo.toml");
 
-  // File 1: src/tests.rs for #[pg_test]
-  let pg_dest_path = Path::new("src/tests.rs");
+  // File 1: src/tests/fixtures.rs for #[pg_test]
+  let pg_dest_path = Path::new("src/tests/fixtures.rs");
   let mut pg_file = File::create(&pg_dest_path).unwrap();
 
-  // File 2: tests/tests.rs for standard #[test] integration
-  let std_dest_path = Path::new("tests/tests.rs");
+  // File 2: tests/fixtures.rs for standard #[test] integration
+  let std_dest_path = Path::new("tests/fixtures.rs");
   let mut std_file = File::create(&std_dest_path).unwrap();
 
   // Write headers
   writeln!(std_file, "use jspg::util;").unwrap();
 
-  // Helper for snake_case conversion
-  // let _to_snake_case = |s: &str| -> String {
-  //   s.chars().fold(String::new(), |mut acc, c| {
-  //     if c.is_uppercase() {
-  //       if !acc.is_empty() {
-  //         acc.push('_');
-  //       }
-  //       acc.push(c.to_ascii_lowercase());
-  //     } else if c == '-' || c == ' ' || c == '.' || c == '/' || c == ':' {
-  //       acc.push('_');
-  //     } else if c.is_alphanumeric() {
-  //       acc.push(c);
-  //     }
-  //     acc
-  //   })
-  // };
-
   // Walk tests/fixtures directly
   let fixtures_path = "tests/fixtures";
   if Path::new(fixtures_path).exists() {
@@ -51,24 +51,7 @@ fn main() {
         if let Some(arr) = val.as_array() {
           for (i, _item) in arr.iter().enumerate() {
             // Use deterministic names: test_{filename}_{index}
-            // We sanitize the filename to be a valid identifier
-            // Use manual snake_case logic since we don't want to add a build-dependency just yet if not needed,
-            // but `dynamicRef` -> `dynamic_ref` requires parsing.
-            // Let's implement a simple camelToSnake helper.
-            let mut safe_filename = String::new();
-            for (i, c) in file_name.chars().enumerate() {
-              if c.is_uppercase() {
-                if i > 0 {
-                  safe_filename.push('_');
-                }
-                safe_filename.push(c.to_ascii_lowercase());
-              } else if c == '-' || c == '.' {
-                safe_filename.push('_');
-              } else {
-                safe_filename.push(c);
-              }
-            }
-
+            let safe_filename = to_safe_identifier(file_name);
             let fn_name = format!("test_{}_{}", safe_filename, i);
 
             // Write to src/tests.rs (PG Test)

flow

@@ -98,14 +98,9 @@ install() {
   fi
 }
 
-test-jspg() {
+test() {
   info "Running jspg tests..."
-  cargo pgrx test "pg${POSTGRES_VERSION}" "$@" || return $?
-}
-
-test-validator() {
-  info "Running validator tests..."
-  cargo test -p boon --features "pgrx/pg${POSTGRES_VERSION}" "$@" || return $?
+  cargo test --tests "$@" || return $?
 }
 
 clean() {
@@ -128,8 +123,7 @@ jspg-flow() {
     build) build; return $?;; 
     install) install; return $?;; 
     reinstall) clean && install; return $?;; 
-    test-jspg) test-jspg "${@:2}"; return $?;;
-    test-validator) test-validator "${@:2}"; return $?;; 
+    test) test "${@:2}"; return $?;;
     clean) clean; return $?;;
     *) return 1 ;;
   esac

src/compiler.rs

@@ -113,6 +113,9 @@ impl Compiler {
         Self::compile_recursive(Arc::make_mut(s));
       }
     }
+    if let Some(add_props) = &mut schema.additional_properties {
+      Self::compile_recursive(Arc::make_mut(add_props));
+    }
 
     // ... Recurse logic ...
     if let Some(items) = &mut schema.items {
@@ -323,6 +326,11 @@ impl Compiler {
         Self::compile_index(sub_schema, registry, current_base.clone(), sub);
       }
     }
+    if let Some(add_props) = &schema.additional_properties {
+      let mut sub = child_pointer.clone();
+      sub.push("additionalProperties".to_string());
+      Self::compile_index(add_props, registry, current_base.clone(), sub);
+    }
     if let Some(contains) = &schema.contains {
       let mut sub = child_pointer.clone();
       sub.push("contains".to_string());

src/drop.rs

@@ -13,7 +13,7 @@ pub struct Drop {
   #[serde(skip_serializing_if = "Option::is_none")]
   pub response: Option<Value>,
 
-  #[serde(default)]
+  #[serde(default, skip_serializing_if = "Vec::is_empty")]
   pub errors: Vec<Error>,
 }
 
@@ -29,7 +29,7 @@ impl Drop {
   pub fn success() -> Self {
     Self {
       type_: "drop".to_string(),
-      response: Some(serde_json::json!({ "result": "success" })), // Or appropriate success response
+      response: Some(serde_json::json!("success")),
       errors: vec![],
     }
   }
@@ -53,8 +53,6 @@ impl Drop {
 
 #[derive(Debug, Serialize, Deserialize, Clone)]
 pub struct Error {
-  #[serde(skip_serializing_if = "Option::is_none")]
-  pub punc: Option<String>,
   pub code: String,
   pub message: String,
   pub details: ErrorDetails,

src/lib.rs

@@ -25,7 +25,7 @@ lazy_static::lazy_static! {
 }
 
 #[pg_extern(strict)]
-fn cache_json_schemas(enums: JsonB, types: JsonB, puncs: JsonB) -> JsonB {
+pub fn cache_json_schemas(enums: JsonB, types: JsonB, puncs: JsonB) -> JsonB {
   // 1. Build a new Registry LOCALLY (on stack)
   let mut registry = registry::Registry::new();
 
@@ -107,11 +107,12 @@ fn cache_json_schemas(enums: JsonB, types: JsonB, puncs: JsonB) -> JsonB {
     *lock = Some(new_arc);
   }
 
-  JsonB(json!({ "response": "success" }))
+  let drop = crate::drop::Drop::success();
+  JsonB(serde_json::to_value(drop).unwrap())
 }
 
 #[pg_extern(strict, parallel_safe)]
-fn mask_json_schema(schema_id: &str, instance: JsonB) -> JsonB {
+pub fn mask_json_schema(schema_id: &str, instance: JsonB) -> JsonB {
   // 1. Acquire Snapshot
   let validator_arc = {
     let lock = GLOBAL_VALIDATOR.read().unwrap();
@@ -135,7 +136,6 @@ fn mask_json_schema(schema_id: &str, instance: JsonB) -> JsonB {
             .errors
             .into_iter()
             .map(|e| crate::drop::Error {
-              punc: None,
               code: e.code,
               message: e.message,
               details: crate::drop::ErrorDetails { path: e.path },
@@ -148,7 +148,6 @@ fn mask_json_schema(schema_id: &str, instance: JsonB) -> JsonB {
       Err(e) => {
         // Schema Not Found or other fatal error
         let error = crate::drop::Error {
-          punc: None,
           code: e.code,
           message: e.message,
           details: crate::drop::ErrorDetails { path: e.path },
@@ -158,19 +157,20 @@ fn mask_json_schema(schema_id: &str, instance: JsonB) -> JsonB {
       }
     }
   } else {
-    JsonB(json!({
-        "punc": null,
-        "errors": [{
-            "code": "VALIDATOR_NOT_INITIALIZED",
-            "message": "JSON Schemas have not been cached yet. Run cache_json_schemas()",
-            "details": { "path": "" }
-        }]
-    }))
+    let error = crate::drop::Error {
+      code: "VALIDATOR_NOT_INITIALIZED".to_string(),
+      message: "JSON Schemas have not been cached yet. Run cache_json_schemas()".to_string(),
+      details: crate::drop::ErrorDetails {
+        path: "".to_string(),
+      },
+    };
+    let drop = crate::drop::Drop::with_errors(vec![error]);
+    JsonB(serde_json::to_value(drop).unwrap())
   }
 }
 
 #[pg_extern(strict, parallel_safe)]
-fn validate_json_schema(schema_id: &str, instance: JsonB) -> JsonB {
+pub fn validate_json_schema(schema_id: &str, instance: JsonB) -> JsonB {
   // 1. Acquire Snapshot
   let validator_arc = {
     let lock = GLOBAL_VALIDATOR.read().unwrap();
@@ -189,7 +189,6 @@ fn validate_json_schema(schema_id: &str, instance: JsonB) -> JsonB {
             .errors
             .into_iter()
             .map(|e| crate::drop::Error {
-              punc: None,
               code: e.code,
               message: e.message,
               details: crate::drop::ErrorDetails { path: e.path },
@@ -201,7 +200,6 @@ fn validate_json_schema(schema_id: &str, instance: JsonB) -> JsonB {
       }
       Err(e) => {
         let error = crate::drop::Error {
-          punc: None,
           code: e.code,
           message: e.message,
           details: crate::drop::ErrorDetails { path: e.path },
@@ -211,19 +209,20 @@ fn validate_json_schema(schema_id: &str, instance: JsonB) -> JsonB {
       }
     }
   } else {
-    JsonB(json!({
-        "punc": null,
-        "errors": [{
-            "code": "VALIDATOR_NOT_INITIALIZED",
-            "message": "JSON Schemas have not been cached yet. Run cache_json_schemas()",
-            "details": { "path": "" }
-        }]
-    }))
+    let error = crate::drop::Error {
+      code: "VALIDATOR_NOT_INITIALIZED".to_string(),
+      message: "JSON Schemas have not been cached yet. Run cache_json_schemas()".to_string(),
+      details: crate::drop::ErrorDetails {
+        path: "".to_string(),
+      },
+    };
+    let drop = crate::drop::Drop::with_errors(vec![error]);
+    JsonB(serde_json::to_value(drop).unwrap())
   }
 }
 
 #[pg_extern(strict, parallel_safe)]
-fn json_schema_cached(schema_id: &str) -> bool {
+pub fn json_schema_cached(schema_id: &str) -> bool {
   if let Some(validator) = GLOBAL_VALIDATOR.read().unwrap().as_ref() {
     match validator.validate(schema_id, &serde_json::Value::Null) {
       Err(e) if e.code == "SCHEMA_NOT_FOUND" => false,
@@ -235,18 +234,23 @@ fn json_schema_cached(schema_id: &str) -> bool {
 }
 
 #[pg_extern(strict)]
-fn clear_json_schemas() -> JsonB {
+pub fn clear_json_schemas() -> JsonB {
   let mut lock = GLOBAL_VALIDATOR.write().unwrap();
   *lock = None;
-  JsonB(json!({ "response": "success" }))
+  let drop = crate::drop::Drop::success();
+  JsonB(serde_json::to_value(drop).unwrap())
 }
 
 #[pg_extern(strict, parallel_safe)]
-fn show_json_schemas() -> JsonB {
-  if let Some(_validator) = GLOBAL_VALIDATOR.read().unwrap().as_ref() {
-    JsonB(json!({ "response": "success", "status": "active" }))
+pub fn show_json_schemas() -> JsonB {
+  if let Some(validator) = GLOBAL_VALIDATOR.read().unwrap().as_ref() {
+    let mut keys = validator.get_schema_ids();
+    keys.sort();
+    let drop = crate::drop::Drop::success_with_val(json!(keys));
+    JsonB(serde_json::to_value(drop).unwrap())
   } else {
-    JsonB(json!({ "response": "success", "status": "empty" }))
+    let drop = crate::drop::Drop::success_with_val(json!([]));
+    JsonB(serde_json::to_value(drop).unwrap())
   }
 }
 
@@ -254,7 +258,7 @@ fn show_json_schemas() -> JsonB {
 #[pg_schema]
 mod tests {
   use pgrx::prelude::*;
-  include!("tests.rs");
+  include!("tests/fixtures.rs");
 }
 
 #[cfg(test)]

src/schema.rs

@@ -33,6 +33,8 @@ pub struct SchemaObject {
   pub properties: Option<BTreeMap<String, Arc<Schema>>>,
   #[serde(rename = "patternProperties")]
   pub pattern_properties: Option<BTreeMap<String, Arc<Schema>>>,
+  #[serde(rename = "additionalProperties")]
+  pub additional_properties: Option<Arc<Schema>>,
   pub required: Option<Vec<String>>,
 
   // dependencies can be schema dependencies or property dependencies

src/tests/fixtures.rs

@@ -155,6 +155,24 @@ fn test_puncs_7() {
     crate::util::run_test_file_at_index(&path, 7).unwrap();
 }
 
+#[pg_test]
+fn test_additional_properties_0() {
+    let path = format!("{}/tests/fixtures/additionalProperties.json", env!("CARGO_MANIFEST_DIR"));
+    crate::util::run_test_file_at_index(&path, 0).unwrap();
+}
+
+#[pg_test]
+fn test_additional_properties_1() {
+    let path = format!("{}/tests/fixtures/additionalProperties.json", env!("CARGO_MANIFEST_DIR"));
+    crate::util::run_test_file_at_index(&path, 1).unwrap();
+}
+
+#[pg_test]
+fn test_additional_properties_2() {
+    let path = format!("{}/tests/fixtures/additionalProperties.json", env!("CARGO_MANIFEST_DIR"));
+    crate::util::run_test_file_at_index(&path, 2).unwrap();
+}
+
 #[pg_test]
 fn test_exclusive_minimum_0() {
     let path = format!("{}/tests/fixtures/exclusiveMinimum.json", env!("CARGO_MANIFEST_DIR"));

src/validator.rs

@@ -910,6 +910,51 @@ impl<'a, I: ValidationInstance<'a>> ValidationContext<'a, I> {
         }
       }
 
+      // 6.5. Additional Properties
+      if let Some(ref additional_schema) = self.schema.additional_properties {
+        for (key, _) in obj {
+          let mut locally_matched = false;
+          if let Some(props) = &self.schema.properties {
+            if props.contains_key(key) {
+              locally_matched = true;
+            }
+          }
+          if !locally_matched {
+            if let Some(ref compiled_pp) = self.schema.compiled_pattern_properties {
+              for (compiled_re, _) in compiled_pp {
+                if compiled_re.0.is_match(key) {
+                  locally_matched = true;
+                  break;
+                }
+              }
+            }
+          }
+
+          if !locally_matched {
+            if let Some(child_instance) = self.instance.child_at_key(key) {
+              let new_path = format!("{}/{}", self.path, key);
+              let is_ref = additional_schema.ref_string.is_some()
+                || additional_schema.obj.dynamic_ref.is_some();
+              let next_extensible = if is_ref { false } else { self.extensible };
+
+              let derived = self.derive(
+                additional_schema,
+                child_instance,
+                &new_path,
+                self.scope.clone(),
+                HashSet::new(),
+                next_extensible,
+                false,
+              );
+              let item_res = derived.validate()?;
+              result.merge(item_res);
+              // Mark as evaluated so it doesn't trigger strictness failure
+              result.evaluated_keys.insert(key.clone());
+            }
+          }
+        }
+      }
+
       // 7. Property Names
       if let Some(ref property_names) = self.schema.property_names {
         for key in obj.keys() {
@@ -1234,6 +1279,10 @@ impl Validator {
     Self { registry }
   }
 
+  pub fn get_schema_ids(&self) -> Vec<String> {
+    self.registry.schemas.keys().cloned().collect()
+  }
+
   pub fn check_type(t: &str, val: &Value) -> bool {
     if let Value::String(s) = val {
       if s.is_empty() {

tests/fixtures.rs

@@ -156,6 +156,24 @@ fn test_puncs_7() {
     util::run_test_file_at_index(&path, 7).unwrap();
 }
 
+#[test]
+fn test_additional_properties_0() {
+    let path = format!("{}/tests/fixtures/additionalProperties.json", env!("CARGO_MANIFEST_DIR"));
+    util::run_test_file_at_index(&path, 0).unwrap();
+}
+
+#[test]
+fn test_additional_properties_1() {
+    let path = format!("{}/tests/fixtures/additionalProperties.json", env!("CARGO_MANIFEST_DIR"));
+    util::run_test_file_at_index(&path, 1).unwrap();
+}
+
+#[test]
+fn test_additional_properties_2() {
+    let path = format!("{}/tests/fixtures/additionalProperties.json", env!("CARGO_MANIFEST_DIR"));
+    util::run_test_file_at_index(&path, 2).unwrap();
+}
+
 #[test]
 fn test_exclusive_minimum_0() {
     let path = format!("{}/tests/fixtures/exclusiveMinimum.json", env!("CARGO_MANIFEST_DIR"));

tests/fixtures/additionalProperties.json

@@ -0,0 +1,132 @@
+[
+    {
+        "description": "additionalProperties validates properties not matched by properties",
+        "schema": {
+            "$schema": "https://json-schema.org/draft/2020-12/schema",
+            "properties": {
+                "foo": {
+                    "type": "string"
+                },
+                "bar": {
+                    "type": "number"
+                }
+            },
+            "additionalProperties": {
+                "type": "boolean"
+            }
+        },
+        "tests": [
+            {
+                "description": "defined properties are valid",
+                "data": {
+                    "foo": "value",
+                    "bar": 123
+                },
+                "valid": true
+            },
+            {
+                "description": "additional property matching schema is valid",
+                "data": {
+                    "foo": "value",
+                    "is_active": true,
+                    "hidden": false
+                },
+                "valid": true
+            },
+            {
+                "description": "additional property not matching schema is invalid",
+                "data": {
+                    "foo": "value",
+                    "is_active": 1
+                },
+                "valid": false
+            }
+        ]
+    },
+    {
+        "description": "extensible: true with additionalProperties still validates structure",
+        "schema": {
+            "$schema": "https://json-schema.org/draft/2020-12/schema",
+            "properties": {
+                "foo": {
+                    "type": "string"
+                }
+            },
+            "extensible": true,
+            "additionalProperties": {
+                "type": "integer"
+            }
+        },
+        "tests": [
+            {
+                "description": "additional property matching schema is valid",
+                "data": {
+                    "foo": "hello",
+                    "count": 5,
+                    "age": 42
+                },
+                "valid": true
+            },
+            {
+                "description": "additional property not matching schema is invalid despite extensible: true",
+                "data": {
+                    "foo": "hello",
+                    "count": "five"
+                },
+                "valid": false
+            }
+        ]
+    },
+    {
+        "description": "complex additionalProperties with object and array items",
+        "schema": {
+            "$schema": "https://json-schema.org/draft/2020-12/schema",
+            "properties": {
+                "type": {
+                    "type": "string"
+                }
+            },
+            "additionalProperties": {
+                "type": "array",
+                "items": {
+                    "type": "string"
+                }
+            }
+        },
+        "tests": [
+            {
+                "description": "valid array of strings",
+                "data": {
+                    "type": "my_type",
+                    "group_a": [
+                        "field1",
+                        "field2"
+                    ],
+                    "group_b": [
+                        "field3"
+                    ]
+                },
+                "valid": true
+            },
+            {
+                "description": "invalid array of integers",
+                "data": {
+                    "type": "my_type",
+                    "group_a": [
+                        1,
+                        2
+                    ]
+                },
+                "valid": false
+            },
+            {
+                "description": "invalid non-array type",
+                "data": {
+                    "type": "my_type",
+                    "group_a": "field1"
+                },
+                "valid": false
+            }
+        ]
+    }
+]

tests/lib.rs

@@ -0,0 +1,113 @@
+use jspg::*;
+use pgrx::JsonB;
+use serde_json::json;
+
+#[test]
+fn test_library_api() {
+  // 1. Initially, schemas are not cached.
+  assert!(!json_schema_cached("test_schema"));
+
+  // Expected uninitialized drop format: errors + null response
+  let uninitialized_drop = validate_json_schema("test_schema", JsonB(json!({})));
+  assert_eq!(
+    uninitialized_drop.0,
+    json!({
+        "type": "drop",
+        "errors": [{
+            "code": "VALIDATOR_NOT_INITIALIZED",
+            "message": "JSON Schemas have not been cached yet. Run cache_json_schemas()",
+            "details": { "path": "" }
+        }]
+    })
+  );
+
+  // 2. Cache schemas
+  let puncs = json!([]);
+  let types = json!([{
+      "schemas": [{
+          "$id": "test_schema",
+          "type": "object",
+          "properties": {
+              "name": { "type": "string" }
+          },
+          "required": ["name"]
+      }]
+  }]);
+  let enums = json!([]);
+
+  let cache_drop = cache_json_schemas(JsonB(enums), JsonB(types), JsonB(puncs));
+  assert_eq!(
+    cache_drop.0,
+    json!({
+        "type": "drop",
+        "response": "success"
+    })
+  );
+
+  // 3. Check schemas are cached
+  assert!(json_schema_cached("test_schema"));
+
+  let show_drop = show_json_schemas();
+  assert_eq!(
+    show_drop.0,
+    json!({
+        "type": "drop",
+        "response": ["test_schema"]
+    })
+  );
+
+  // 4. Validate Happy Path
+  let happy_drop = validate_json_schema("test_schema", JsonB(json!({"name": "Neo"})));
+  assert_eq!(
+    happy_drop.0,
+    json!({
+        "type": "drop",
+        "response": "success"
+    })
+  );
+
+  // 5. Validate Unhappy Path
+  let unhappy_drop = validate_json_schema("test_schema", JsonB(json!({"wrong": "data"})));
+  assert_eq!(
+    unhappy_drop.0,
+    json!({
+        "type": "drop",
+        "errors": [
+            {
+                "code": "REQUIRED_FIELD_MISSING",
+                "message": "Missing name",
+                "details": { "path": "/name" }
+            },
+            {
+                "code": "STRICT_PROPERTY_VIOLATION",
+                "message": "Unexpected property 'wrong'",
+                "details": { "path": "/wrong" }
+            }
+        ]
+    })
+  );
+
+  // 6. Mask Happy Path
+  let mask_drop = mask_json_schema(
+    "test_schema",
+    JsonB(json!({"name": "Neo", "extra": "data"})),
+  );
+  assert_eq!(
+    mask_drop.0,
+    json!({
+        "type": "drop",
+        "response": {"name": "Neo"}
+    })
+  );
+
+  // 7. Clear Schemas
+  let clear_drop = clear_json_schemas();
+  assert_eq!(
+    clear_drop.0,
+    json!({
+        "type": "drop",
+        "response": "success"
+    })
+  );
+  assert!(!json_schema_cached("test_schema"));
+}

version

@@ -1 +1 @@
-1.0.49
+1.0.53