package/storage
1
0
Fork 0
mirror of https://github.com/gofiber/storage.git synced 2025-10-06 17:17:18 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

chore: use testcontainers properly in dynamodb

Browse Source
This commit is contained in:
Manuel de la Peña
2025-03-28 13:05:30 +01:00
committed by Muhammed Efe Cetin
parent d7bbc22084
commit f3bdd2599c
1 changed files with 19 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
dynamodb/dynamodb_test.go
View File

@@ -69,7 +69,11 @@ func Test_DynamoDB_SetWithContext(t *testing.T) {
ctx, cancel := context.WithCancel(context.Background()) ctx, cancel := context.WithCancel(context.Background())
cancel() cancel()
err := testStore.SetWithContext(ctx, key, val, 0) testStore, err := newTestStore(t)
require.NoError(t, err)
defer testStore.Close()
err = testStore.SetWithContext(ctx, key, val, 0)
require.ErrorIs(t, err, context.Canceled) require.ErrorIs(t, err, context.Canceled)
} }
@@ -114,6 +118,10 @@ func Test_DynamoDB_GetWithContext(t *testing.T) {
ctx, cancel := context.WithCancel(context.Background()) ctx, cancel := context.WithCancel(context.Background())
cancel() cancel()
testStore, err := newTestStore(t)
require.NoError(t, err)
defer testStore.Close()
result, err := testStore.GetWithContext(ctx, key) result, err := testStore.GetWithContext(ctx, key)
require.ErrorIs(t, err, context.Canceled) require.ErrorIs(t, err, context.Canceled)
require.Zero(t, len(result)) require.Zero(t, len(result))
@@ -154,7 +162,11 @@ func Test_DynamoDB_DeleteWithContext(t *testing.T) {
val = []byte("doe") val = []byte("doe")
) )
err := testStore.Set(key, val, 0) testStore, err := newTestStore(t)
require.NoError(t, err)
defer testStore.Close()
err = testStore.Set(key, val, 0)
require.NoError(t, err) require.NoError(t, err)
ctx, cancel := context.WithCancel(context.Background()) ctx, cancel := context.WithCancel(context.Background())
@@ -195,7 +207,11 @@ func Test_DynamoDB_Reset(t *testing.T) {
func Test_DynamoDB_ResetWithContext(t *testing.T) { func Test_DynamoDB_ResetWithContext(t *testing.T) {
val := []byte("doe") val := []byte("doe")
err := testStore.Set("john1", val, 0) testStore, err := newTestStore(t)
require.NoError(t, err)
defer testStore.Close()
err = testStore.Set("john1", val, 0)
require.NoError(t, err) require.NoError(t, err)
err = testStore.Set("john2", val, 0) err = testStore.Set("john2", val, 0)