Merge pull request #1 from streamdal/blinktag/ENG-1656_validjson

ENG-1656 - Fix valid_json module support

Author: blinktag

docs/resources/pipeline.md

@@ -84,13 +84,14 @@ Required:
 
 At lease one of the following step type blocks is required:
 
-- ``detective`` - (Block List, Max: 1) Detective Step (see [below for nested schema](#nestedblock--step--detective))
+- ``detective`` - (Block, Max: 1) Detective Step (see [below for nested schema](#nestedblock--step--detective))
 - ``dynamic`` - (Boolean) Should this step use the result from the previous step. This is valid **ONLY** for a transform step which immediately follows a detective step. Specifying `true` means
 any result from the detective step will be used as the path(s) for the transform step. (Default: `false`)
-- ``http_request`` - (Block List, Max: 1) HTTP Request Step (see [below for nested schema](#nestedblock--step--http_request))
+- ``http_request`` - (Block, Max: 1) HTTP Request Step (see [below for nested schema](#nestedblock--step--http_request))
 
-- ``schema_validation`` - (Block List, Max: 1) Schema Validation Step (see [below for nested schema](#nestedblock--step--schema_validation))
-- ``transform`` - (Block List, Max: 1) Transform Step (see [below for nested schema](#nestedblock--step--transform))
+- ``schema_validation`` - (Block, Max: 1) Schema Validation Step (see [below for nested schema](#nestedblock--step--schema_validation))
+- ``transform`` - (Block, Max: 1) Transform Step (see [below for nested schema](#nestedblock--step--transform))
+- ``valid_json`` - (Block, Max 1) Determine if the payload is valid JSON. Does not need any configuration.
 
 Optional parameters:
 

examples/valid_json/main.tf

@@ -0,0 +1,25 @@
+# This example shows how to create a step which simply validates a JSON payload
+terraform {
+  required_providers {
+    streamdal = {
+      version = "0.1.0"
+      source  = "streamdal.com/tf/streamdal"
+    }
+  }
+}
+
+provider "streamdal" {
+  token              = "1234"
+  address            = "localhost:8082"
+  connection_timeout = 10
+}
+
+resource "streamdal_pipeline" "validate_my_json" {
+  name = "Validate JSON Payload"
+  step {
+    name    = "Validate JSON Step"
+    dynamic = true
+    valid_json {
+    }
+  }
+}

internal/provider/resource_pipeline.go

@@ -283,13 +283,15 @@ func stepSchema() *schema.Resource {
 					},
 				},
 			},
-			//"valid_json": {
-			//	Description: "Valid JSON Step",
-			//	Type:        schema.TypeList,
-			//	Optional:    true,
-			//	MaxItems:    1,
-			//	Elem:        &schema.Resource{},
-			//},
+			"valid_json": {
+				Description: "Valid JSON Step",
+				Type:        schema.TypeList,
+				Optional:    true,
+				MaxItems:    1,
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{},
+				},
+			},
 			"schema_validation": {
 				Description: "Schema Validation Step",
 				Type:        schema.TypeList,