Add integration test for patch

examples/examples_nodejs_test.go

@@ -19,6 +19,22 @@ func TestAccEnvironmentTs(t *testing.T) {
 	integration.ProgramTest(t, &test)
 }
 
+// TestKafkaTopicPatch tests that upstream patches to add in the deprecated httpEndpoint field works as expected.
+func TestKafkaTopicPatch(t *testing.T) {
+	test := getJSBaseOptions(t).
+		With(integration.ProgramTestOptions{
+			Dir: path.Join(getCwd(t), "kafka-topic-patch", "ts", "step1"),
+			EditDirs: []integration.EditDir{
+				{
+					Dir:      path.Join(getCwd(t), "kafka-topic-patch", "ts", "step2"),
+					Additive: true,
+				},
+			},
+		})
+
+	integration.ProgramTest(t, &test)
+}
+
 func getJSBaseOptions(t *testing.T) integration.ProgramTestOptions {
 	base := getBaseOptions()
 	baseJS := base.With(integration.ProgramTestOptions{

examples/kafka-topic-patch/ts/step1/.gitignore

@@ -0,0 +1,2 @@
+/bin/
+/node_modules/

examples/kafka-topic-patch/ts/step1/Pulumi.yaml

@@ -0,0 +1,3 @@
+name: confluentcloud-ts-patch
+runtime: nodejs
+description: A minimal TypeScript Pulumi program

examples/kafka-topic-patch/ts/step1/index.ts

@@ -0,0 +1,22 @@
+import * as pulumi from "@pulumi/pulumi";
+import * as confluent from "@pulumi/confluentcloud";
+
+const env = new confluent.Environment("ts-env");
+
+const kfCluster = new confluent.KafkaCluster("kfCluster", {
+  cloud: "AWS",
+  region: "us-west-2",
+  availability: "SINGLE_ZONE",
+  environment: {
+    id: env.id,
+  },
+});
+
+const kfTopic = new confluent.KafkaTopic("kfTopic", {
+  topicName: "test-topic",
+  kafkaCluster: {
+    id: kfCluster.id,
+  },
+  // Deprecated field which we are still supporting.
+  httpEndpoint: kfCluster.restEndpoint,
+});

examples/kafka-topic-patch/ts/step1/package.json

@@ -0,0 +1,10 @@
+{
+    "name": "confluentcloud-ts-environment",
+    "devDependencies": {
+        "@types/node": "^14"
+    },
+    "dependencies": {
+        "@pulumi/pulumi": "^3.73.0",
+        "@pulumi/random": "^4.0.0"
+    }
+}

examples/kafka-topic-patch/ts/step1/tsconfig.json

@@ -0,0 +1,18 @@
+{
+    "compilerOptions": {
+        "strict": true,
+        "outDir": "bin",
+        "target": "es2016",
+        "module": "commonjs",
+        "moduleResolution": "node",
+        "sourceMap": true,
+        "experimentalDecorators": true,
+        "pretty": true,
+        "noFallthroughCasesInSwitch": true,
+        "noImplicitReturns": true,
+        "forceConsistentCasingInFileNames": true
+    },
+    "files": [
+        "index.ts"
+    ]
+}

examples/kafka-topic-patch/ts/step2/index.ts

@@ -0,0 +1,31 @@
+import * as pulumi from "@pulumi/pulumi";
+import * as confluent from "@pulumi/confluentcloud";
+
+const env = new confluent.Environment("ts-env");
+
+const kfCluster = new confluent.KafkaCluster("kfCluster", {
+  cloud: "AWS",
+  region: "us-west-2",
+  availability: "SINGLE_ZONE",
+  environment: {
+    id: env.id,
+  },
+});
+
+const kfTopic = new confluent.KafkaTopic("kfTopic", {
+  topicName: "test-topic",
+  kafkaCluster: {
+    id: kfCluster.id,
+  },
+  // Deprecated field which we are still supporting.
+  httpEndpoint: kfCluster.restEndpoint,
+});
+
+const res = kfCluster.restEndpoint.apply((endPt) => {
+  const res = confluent.getKafkaTopic({
+    topicName: "test-topic",
+    restEndpoint: endPt,
+  });
+
+  return res;
+});