Skip to content

Commit

Permalink
test: fix
Browse files Browse the repository at this point in the history
  • Loading branch information
davidebianchi committed Nov 25, 2024
1 parent 926cc50 commit deb505c
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions internal/sinks/mongo/integration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ func TestMongoOnlyInsert(t *testing.T) {
err = w.WriteData(ctx, e)
require.NoError(t, err)
findAllDocuments(t, coll, []map[string]any{
{"foo": "bar", "key": "123", "type": "created"},
{"foo": "bar", "key": "234", "type": "created"},
})
})

Expand All @@ -104,8 +104,8 @@ func TestMongoOnlyInsert(t *testing.T) {
err = w.WriteData(ctx, e)
require.NoError(t, err)
findAllDocuments(t, coll, []map[string]any{
{"foo": "bar", "key": "123", "type": "created"},
{"foo": "taz", "key": "123", "another": "field", "type": "updated"},
{"foo": "bar", "key": "234", "type": "created"},
{"foo": "taz", "key": "234", "another": "field", "type": "updated"},
})
})

Expand All @@ -114,9 +114,9 @@ func TestMongoOnlyInsert(t *testing.T) {
err = w.WriteData(ctx, e)
require.NoError(t, err)
findAllDocuments(t, coll, []map[string]any{
{"foo": "bar", "key": "123", "type": "created"},
{"foo": "taz", "key": "123", "another": "field", "type": "updated"},
{"foo": "taz", "key": "123", "another": "field", "type": "deleted"},
{"foo": "bar", "key": "234", "type": "created"},
{"foo": "taz", "key": "234", "another": "field", "type": "updated"},
{"foo": "taz", "key": "234", "another": "field", "type": "deleted"},
})
})
}
Expand Down

0 comments on commit deb505c

Please sign in to comment.