Support custom schema in Healthcare HL7 V2 stores

products/healthcare/api.yaml

@@ -333,18 +333,28 @@ objects:
             at_least_one_of:
               - parser_config.0.allow_null_header
               - parser_config.0.segment_terminator
+              - parser_config.0.schema
             description: |
               Determines whether messages with no header are allowed.
           - !ruby/object:Api::Type::String
             name: segmentTerminator
             at_least_one_of:
               - parser_config.0.allow_null_header
               - parser_config.0.segment_terminator
+              - parser_config.0.schema
             description: |
               Byte(s) to be used as the segment terminator. If this is unset, '\r' will be used as segment terminator.
 
               A base64-encoded string.
-
+          - !ruby/object:Api::Type::String
+            name: schema
+            at_least_one_of:
+              - parser_config.0.allow_null_header
+              - parser_config.0.segment_terminator
+              - parser_config.0.schema
+            description: |
+              JSON encoded string for schemas used to parse messages in this
+              store if schematized parsing is desired.
       - !ruby/object:Api::Type::KeyValuePairs
         name: labels
         required: false

products/healthcare/terraform.yaml

@@ -88,15 +88,28 @@ overrides: !ruby/object:Overrides::ResourceOverrides
     examples:
       - !ruby/object:Provider::Terraform::Examples
         name: "healthcare_hl7_v2_store_basic"
-        skip_test: true
-        primary_resource_id: "default"
+        min_version: beta
+        primary_resource_id: "store"
         vars:
           dataset_name: "example-dataset"
           hl7_v2_store_name: "example-hl7-v2-store"
           pubsub_topic: "hl7-v2-notifications"
+      - !ruby/object:Provider::Terraform::Examples
+        name: "healthcare_hl7_v2_store_parser_config"
+        min_version: beta
+        primary_resource_id: "store"
+        vars:
+          dataset_name: "example-dataset"
+          hl7_v2_store_name: "example-hl7-v2-store"
     properties:
       creationTime: !ruby/object:Overrides::Terraform::PropertyOverride
         exclude: true
+      parserConfig.schema: !ruby/object:Overrides::Terraform::PropertyOverride
+        custom_expand: 'templates/terraform/custom_expand/healthcare_hl7_v2_store_schema.erb'
+        custom_flatten: 'templates/terraform/custom_flatten/healthcare_hl7_v2_store_schema.erb'
+        state_func: 'func(v interface{}) string { s, _ := structure.NormalizeJsonString(v); return s }'
+        validation: !ruby/object:Provider::Terraform::Validation
+          function: 'validation.ValidateJsonString'
       selfLink: !ruby/object:Overrides::Terraform::PropertyOverride
         ignore_read: true
     custom_code: !ruby/object:Provider::Terraform::CustomCode

templates/terraform/custom_expand/healthcare_hl7_v2_store_schema.erb

@@ -0,0 +1,25 @@
+<%- # the license inside this block applies to this file
+	# Copyright 2020 Google Inc.
+	# Licensed under the Apache License, Version 2.0 (the "License");
+	# you may not use this file except in compliance with the License.
+	# You may obtain a copy of the License at
+	#
+	#     http://www.apache.org/licenses/LICENSE-2.0
+	#
+	# Unless required by applicable law or agreed to in writing, software
+	# distributed under the License is distributed on an "AS IS" BASIS,
+	# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+	# See the License for the specific language governing permissions and
+	# limitations under the License.
+-%>
+func expand<%= prefix -%><%= titlelize_property(property) -%>(v interface{}, d TerraformResourceData, config *Config) (interface{}, error) {
+	b := []byte(v.(string))
+	if len(b) == 0 {
+		return nil, nil
+	}
+	m := make(map[string]interface{})
+	if err := json.Unmarshal(b, &m); err != nil {
+		return nil, err
+	}
+	return m, nil
+}

templates/terraform/custom_flatten/healthcare_hl7_v2_store_schema.erb

@@ -0,0 +1,25 @@
+<%# The license inside this block applies to this file.
+	# Copyright 2020 Google Inc.
+	# Licensed under the Apache License, Version 2.0 (the "License");
+	# you may not use this file except in compliance with the License.
+	# You may obtain a copy of the License at
+	#
+	#     http://www.apache.org/licenses/LICENSE-2.0
+	#
+	# Unless required by applicable law or agreed to in writing, software
+	# distributed under the License is distributed on an "AS IS" BASIS,
+	# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+	# See the License for the specific language governing permissions and
+	# limitations under the License.
+-%>
+func flatten<%= prefix -%><%= titlelize_property(property) -%>(v interface{}, d *schema.ResourceData, config *Config) interface{} {
+	if v == nil {
+		return nil
+	}
+	b, err := json.Marshal(v)
+	if err != nil {
+        // TODO: return error once https://github.com/GoogleCloudPlatform/magic-modules/issues/3257 is fixed.
+		log.Printf("[ERROR] failed to marshal schema to JSON: %v", err)
+	}
+	return string(b)
+}

templates/terraform/examples/healthcare_hl7_v2_store_basic.tf.erb

@@ -2,18 +2,14 @@ resource "google_healthcare_hl7_v2_store" "default" {
   name    = "<%= ctx[:vars]['hl7_v2_store_name'] %>"
   dataset = google_healthcare_dataset.dataset.id
 
-  parser_config {
-    allow_null_header  = false
-    segment_terminator = "Jw=="
-  }
-
   notification_config {
     pubsub_topic = google_pubsub_topic.topic.id
   }
 
   labels = {
     label1 = "labelvalue1"
   }
+
   provider = google-beta
 }
 

templates/terraform/examples/healthcare_hl7_v2_store_parser_config.tf.erb

@@ -0,0 +1,94 @@
+resource "google_healthcare_hl7_v2_store" "default" {
+  provider = google-beta
+  name    = "<%= ctx[:vars]['hl7_v2_store_name'] %>"
+  dataset = google_healthcare_dataset.dataset.id
+
+  parser_config {
+    allow_null_header  = false
+    segment_terminator = "Jw=="
+    schema = jsonencode({
+      "schemas": [{
+        "messageSchemaConfigs": {
+          "ADT_A01": {
+            "name": "ADT_A01",
+            "minOccurs": 1,
+            "maxOccurs": 1,
+            "members": [{
+                "segment": {
+                  "type": "MSH",
+                  "minOccurs": 1,
+                  "maxOccurs": 1
+                }
+              },
+              {
+                "segment": {
+                  "type": "EVN",
+                  "minOccurs": 1,
+                  "maxOccurs": 1
+                }
+              },
+              {
+                "segment": {
+                  "type": "PID",
+                  "minOccurs": 1,
+                  "maxOccurs": 1
+                }
+              },
+              {
+                "segment": {
+                  "type": "ZPD",
+                  "minOccurs": 1,
+                  "maxOccurs": 1
+                }
+              },
+              {
+                "segment": {
+                  "type": "OBX"
+                }
+              },
+              {
+                "group": {
+                  "name": "PROCEDURE",
+                  "members": [{
+                      "segment": {
+                        "type": "PR1",
+                        "minOccurs": 1,
+                        "maxOccurs": 1
+                      }
+                    },
+                    {
+                      "segment": {
+                        "type": "ROL"
+                      }
+                    }
+                  ]
+                }
+              },
+              {
+                "segment": {
+                  "type": "PDA",
+                  "maxOccurs": 1
+                }
+              }
+            ]
+          }
+        }
+      }],
+      "types": [{
+        "type": [{
+            "name": "ZPD",
+            "primitive": "VARIES"
+          }
+
+        ]
+      }],
+      "ignoreMinOccurs": true
+    })
+  }
+}
+
+resource "google_healthcare_dataset" "dataset" {
+  provider = google-beta
+  name     = "<%= ctx[:vars]['dataset_name'] %>"
+  location = "us-central1"
+}

third_party/terraform/tests/resource_healthcare_hl7_v2_store_test.go.erb

@@ -160,33 +160,6 @@ resource "google_pubsub_topic" "topic" {
 `, hl7_v2StoreName, datasetName, pubsubTopic)
 }
 
-func testAccCheckHealthcareHl7V2StoreDestroyProducer(t *testing.T) func(s *terraform.State) error {
-	return func(s *terraform.State) error {
-		for name, rs := range s.RootModule().Resources {
-			if rs.Type != "google_healthcare_hl7_v2_store" {
-				continue
-			}
-			if strings.HasPrefix(name, "data.") {
-				continue
-			}
-
-			config := googleProviderConfig(t)
-
-			url, err := replaceVarsForTest(config, rs, "{{HealthcareBasePath}}{{dataset}}/hl7V2Stores/{{name}}")
-			if err != nil {
-				return err
-			}
-
-			_, err = sendRequest(config, "GET", "", url, nil)
-			if err == nil {
-				return fmt.Errorf("HealthcareHl7V2Store still exists at %s", url)
-			}
-		}
-
-		return nil
-	}
-}
-
 func testAccCheckGoogleHealthcareHl7V2StoreUpdate(t *testing.T, pubsubTopic string) resource.TestCheckFunc {
 	return func(s *terraform.State) error {
 		var foundResource = false