3pp-mirror/pomerium
1
0
Fork 0
mirror of https://github.com/pomerium/pomerium.git synced 2025-08-06 10:21:05 +02:00
Code Issues Projects Releases Packages Wiki Activity

core/storage: fix nil data unmarshal (#4739)

Browse source 
core/storage: fix nil data unmarshal (#4734)

Co-authored-by: Caleb Doxsey <cdoxsey@pomerium.com>
This commit is contained in:
backport-actions-token[bot] 2023-11-10 13:22:34 -07:00 • committed by GitHub
parent b3d99857f9
commit 1a31a9492c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 23 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

22
pkg/storage/postgres/backend_test.go
View file

@ -51,18 +51,20 @@ func TestBackend(t *testing.T) {
})
t.Run("delete", func(t *testing.T) {
serverVersion, err := backend.Put(ctx, []*databroker.Record{
{
Type: "test-1",
Id: "r3",
Data: protoutil.NewAny(protoutil.NewStructMap(map[string]*structpb.Value{
"k1": protoutil.NewStructString("v1"),
})),
DeletedAt: timestamppb.Now(),
},
})
serverVersion, err := backend.Put(ctx, []*databroker.Record{{
Type: "test-1",
Id: "r3",
DeletedAt: timestamppb.Now(),
}})
assert.NotEqual(t, 0, serverVersion)
assert.NoError(t, err)
stream, err := backend.Sync(ctx, "test-1", serverVersion, 0)
require.NoError(t, err)
t.Cleanup(func() { _ = stream.Close() })
records, err := storage.RecordStreamToList(stream)
require.NoError(t, err)
assert.NotEmpty(t, records)
})
t.Run("capacity", func(t *testing.T) {