test: Update Dekaf tests

estuary · Sep 30, 2024 · 6009e38 · 6009e38
1 parent 41e60b8
commit 6009e38
Show file tree

Hide file tree

Showing 5 changed files with 126 additions and 1,591 deletions.
diff --git a/crates/validation/tests/scenario_tests.rs b/crates/validation/tests/scenario_tests.rs
@@ -12,22 +12,20 @@ fn test_golden_all_visits() {
 fn test_dekaf_materialization_inline_config() {
  let fixture = r##"
 test://example/catalog.yaml:
- collections:
- testing/schema_with_properties:
- schema:
- type: object
- properties:
- id: { type: string }
- required: [id]
- key: [/id]
  materializations:
- testing/test_dekaf:
+ good:
  endpoint:
- dekaf: {}
- bindings:
- - source: testing/schema_with_properties
- resource: {}
+ dekaf: &config
+ variant: foo
+ config:
+ strict_topic_names: false
+ bindings: []
 driver:
+ materializations:
+ good: &connector
+ connectorType: DEKAF
+ config: *config
+ bindings: []
  dataPlanes:
  "1d:1d:1d:1d:1d:1d:1d:1d":
  default: true
@@ -41,24 +39,22 @@ driver:
 #[test]
 fn test_dekaf_materialization_indirect_config() {
  let fixture = r##"
-test://example/dekaf.yaml: {}
 test://example/catalog.yaml:
- collections:
- testing/schema_with_properties:
- schema:
- type: object
- properties:
- id: { type: string }
- required: [id]
- key: [/id]
  materializations:
- testing/test_dekaf:
+ good:
  endpoint:
- dekaf: example/dekaf.yaml
- bindings:
- - source: testing/schema_with_properties
- resource: {}
+ dekaf: &config
+ variant: foo
+ config: test://example/dekaf
+ bindings: []
+test://example/dekaf:
+ strict_topic_names: false
 driver:
+ materializations:
+ good: &connector
+ connectorType: DEKAF
+ config: *config
+ bindings: []
  dataPlanes:
  "1d:1d:1d:1d:1d:1d:1d:1d":
  default: true
@@ -72,7 +68,6 @@ driver:
 #[test]
 fn test_dekaf_materialization_invalid() {
  let fixture = r##"
-test://example/dekaf.yaml: {}
 test://example/catalog.yaml:
  collections:
  testing/schema_with_properties:
@@ -83,13 +78,16 @@ test://example/catalog.yaml:
  required: [id]
  key: [/id]
  materializations:
- testing/test_dekaf:
- endpoint:
+ bad:
+ endpoint: &config
  dekaf: false
- bindings:
- - source: testing/schema_with_properties
- resource: {}
+ bindings: []
 driver:
+ materializations:
+ bad: &connector
+ connectorType: DEKAF
+ config: *config
+ bindings: []
  dataPlanes:
  "1d:1d:1d:1d:1d:1d:1d:1d":
  default: true
@@ -103,24 +101,20 @@ driver:
 #[test]
 fn test_dekaf_materialization_nonexistent() {
  let fixture = r##"
-test://example/dekaf.yaml: {}
 test://example/catalog.yaml:
- collections:
- testing/schema_with_properties:
- schema:
- type: object
- properties:
- id: { type: string }
- required: [id]
- key: [/id]
  materializations:
- testing/test_dekaf:
+ bad:
  endpoint:
- dekaf: foo/bar
- bindings:
- - source: testing/schema_with_properties
-  resource: {}
+ dekaf: &config
+  variant: bar
+  config: foo/bar
+ bindings: []
 driver:
+ materializations:
+ good: &connector
+ connectorType: DEKAF
+ config: *config
+ bindings: []
  dataPlanes:
  "1d:1d:1d:1d:1d:1d:1d:1d":
  default: true