add opencdc.collection metadata key for snapshots (#241)

maha-mstfa · web-flow · commit bd9aa4ed4cff · 2025-01-15T13:41:21.000-08:00
* add opencdc.collection metadata key for snapshots

* update test
diff --git a/source/snapshot/iterator.go b/source/snapshot/iterator.go
@@ -120,7 +120,7 @@ func (i *Iterator) buildRecord(d FetchData) opencdc.Record {
 
 	pos := i.lastPosition.ToSDKPosition()
 	metadata := make(opencdc.Metadata)
-	metadata["postgres.table"] = d.Table
+	metadata[opencdc.MetadataCollection] = d.Table
 
 	rec := sdk.Util.Source.NewRecordSnapshot(pos, metadata, d.Key, d.Payload)
 	if i.conf.WithAvroSchema {
diff --git a/source/snapshot/iterator_test.go b/source/snapshot/iterator_test.go
@@ -52,6 +52,7 @@ func Test_Iterator_Next(t *testing.T) {
 			r, err := i.Next(ctx)
 			is.NoErr(err)
 			is.Equal(r.Operation, opencdc.OperationSnapshot)
+			is.Equal(r.Metadata[opencdc.MetadataCollection], table)
 		}
 
 		for j := 1; j <= 4; j++ {

Original file line number	Diff line number	Diff line change
`@@ -52,6 +52,7 @@ func Test_Iterator_Next(t *testing.T) {`
`52`	`52`	`r, err := i.Next(ctx)`
`53`	`53`	`is.NoErr(err)`
`54`	`54`	`is.Equal(r.Operation, opencdc.OperationSnapshot)`
	`55`	`+ is.Equal(r.Metadata[opencdc.MetadataCollection], table)`
`55`	`56`	`}`
`56`	`57`
`57`	`58`	`for j := 1; j <= 4; j++ {`