Make the payload object public (#85)

artie-labs · May 2, 2023 · f55aab3 · f55aab3
1 parent 14cf06a
commit f55aab3
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 7 deletions.
diff --git a/lib/cdc/util/relational_event.go b/lib/cdc/util/relational_event.go
@@ -16,10 +16,10 @@ import (
 // SchemaEventPayload is our struct for an event with schema enabled. For reference, this is an example payload https://gist.github.com/Tang8330/3b9989ed8c659771958fe481f248397a
 type SchemaEventPayload struct {
 	Schema  debezium.Schema `json:"schema"`
-	Payload payload         `json:"payload"`
+	Payload Payload         `json:"payload"`
 }
 
-type payload struct {
+type Payload struct {
 	Before    map[string]interface{} `json:"before"`
 	After     map[string]interface{} `json:"after"`
 	Source    Source                 `json:"source"`

diff --git a/lib/cdc/util/relational_event_test.go b/lib/cdc/util/relational_event_test.go
@@ -66,15 +66,14 @@ func TestSource_GetOptionalSchema(t *testing.T) {
 	assert.False(t, isOk)
 }
 
-
 func TestSource_GetExecutionTime(t *testing.T) {
 	source := Source{
 		Connector: "postgresql",
 		TsMs:      1665458364942, // Tue Oct 11 2022 03:19:24
 	}
 
 	schemaEventPayload := &SchemaEventPayload{
-		Payload: payload{Source: source},
+		Payload: Payload{Source: source},
 	}
 
 	assert.Equal(t, time.Date(2022, time.October,
@@ -91,7 +90,7 @@ func TestGetDataTestInsert(t *testing.T) {
 
 	var tc kafkalib.TopicConfig
 	schemaEventPayload := SchemaEventPayload{
-		Payload: payload{
+		Payload: Payload{
 			Before:    nil,
 			After:     after,
 			Operation: "c",
@@ -116,7 +115,7 @@ func TestGetDataTestDelete(t *testing.T) {
 
 	now := time.Now().UTC()
 	schemaEventPayload := SchemaEventPayload{
-		Payload: payload{
+		Payload: Payload{
 			Before:    nil,
 			After:     nil,
 			Operation: "c",
@@ -161,7 +160,7 @@ func TestGetDataTestUpdate(t *testing.T) {
 
 	var tc kafkalib.TopicConfig
 	schemaEventPayload := SchemaEventPayload{
-		Payload: payload{
+		Payload: Payload{
 			Before:    before,
 			After:     after,
 			Operation: "c",