Bump github.com/arangodb/go-driver from 1.2.1 to 1.3.0 in /arangodb (#340)

Bumps [github.com/arangodb/go-driver](https://github.com/arangodb/go-driver) from 1.2.1 to 1.3.0.
- [Release notes](https://github.com/arangodb/go-driver/releases)
- [Changelog](https://github.com/arangodb/go-driver/blob/master/CHANGELOG.md)
- [Commits](https://github.com/arangodb/go-driver/compare/v1.2.1...v1.3.0)

---
updated-dependencies:
- dependency-name: github.com/arangodb/go-driver
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

.github/dependabot.yml

@@ -112,6 +112,15 @@ updates:
                     dependency_name: "gofiber/fiber/*"
     -   package-ecosystem: "gomod"
         directory: "/s3/" # Location of package manifests
+        default_labels:
+            - "🤖 Dependencies"
+        schedule:
+            interval: "daily"
+        automerged_updates:
+            -   match:
+                    dependency_name: "gofiber/fiber/*"              
+    -   package-ecosystem: "gomod"
+        directory: "/bbolt/" # Location of package manifests
         default_labels:
             - "🤖 Dependencies"
         schedule:

.github/workflows/security.yml

@@ -16,7 +16,7 @@ jobs:
                     go get -u github.com/securego/gosec/v2/cmd/gosec
             -   name: Run Gosec (root)
                 working-directory: .
-                run: "`go env GOPATH`/bin/gosec -exclude-dir=internal -exclude-dir=arangodb -exclude-dir=badger -exclude-dir=dynamodb -exclude-dir=memcache -exclude-dir=memory -exclude-dir=mongodb -exclude-dir=mysql -exclude-dir=postgres -exclude-dir=redis -exclude-dir=ristretto -exclude-dir=sqlite3 -exclude-dir=s3 ./..."
+                run: "`go env GOPATH`/bin/gosec -exclude-dir=internal -exclude-dir=arangodb -exclude-dir=badger -exclude-dir=dynamodb -exclude-dir=memcache -exclude-dir=memory -exclude-dir=mongodb -exclude-dir=mysql -exclude-dir=postgres -exclude-dir=redis -exclude-dir=ristretto -exclude-dir=sqlite3 -exclude-dir=s3 -exclude-dir=bbolt ./..."
                 # -----
             -   name: Run Gosec (arangodb)
                 working-directory: ./arangodb
@@ -66,3 +66,7 @@ jobs:
                 working-directory: ./ristretto
                 run: "`go env GOPATH`/bin/gosec -exclude-dir=internal ./..."
                 # -----
+            -   name: Run Gosec (bbolt)
+                working-directory: ./bbolt
+                run: "`go env GOPATH`/bin/gosec -exclude-dir=internal ./..."
+                # -----

.github/workflows/test-bbolt.yml

@@ -0,0 +1,24 @@
+'on':
+  - push
+  - pull_request
+name: Bbolt
+jobs:
+  Tests:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        go-version:
+          - 1.16.x
+          - 1.17.x
+        platform:
+          - ubuntu-latest
+          - windows-latest
+    steps:
+      - name: Install Go
+        uses: actions/setup-go@v1
+        with:
+          go-version: '${{ matrix.go-version }}'
+      - name: Fetch Repository
+        uses: actions/checkout@v2
+      - name: Run Test
+        run: cd ./bbolt && go mod tidy && go test ./... -v -race

.github/workflows/test-dynamodb.yml

@@ -0,0 +1,31 @@
+'on':
+  - push
+  - pull_request
+name: DynamoDB
+jobs:
+  Tests:
+    runs-on: ubuntu-latest
+    services:
+      mongo:
+        image: 'amazon/dynamodb-local:latest'
+        ports:
+          - '8000:8000'
+    strategy:
+      matrix:
+        go-version:
+          - 1.14.x
+          - 1.15.x
+          - 1.16.x
+          - 1.17.x
+        platform:
+          - ubuntu-latest
+          - windows-latest
+    steps:
+      - name: Install Go
+        uses: actions/setup-go@v1
+        with:
+          go-version: '${{ matrix.go-version }}'
+      - name: Fetch Repository
+        uses: actions/checkout@v2
+      - name: Run Test
+        run: cd ./dynamodb && go test ./... -v -race

README.md

@@ -83,4 +83,7 @@ type Storage interface {
   </a>
 * [S3](/s3) <a href="https://github.com/gofiber/storage/actions?query=workflow%3A%22S3%22">
     <img src="https://img.shields.io/github/workflow/status/gofiber/storage/S3?label=%F0%9F%A7%AA%20&style=flat&color=75C46B">
+  </a>
+* [Bbolt](/bbolt) <a href="https://github.com/gofiber/storage/actions?query=workflow%3A%22Bbolt%22">
+    <img src="https://img.shields.io/github/workflow/status/gofiber/storage/Bbolt?label=%F0%9F%A7%AA%20&style=flat&color=75C46B">
   </a>

arangodb/go.mod

@@ -3,6 +3,6 @@ module github.com/gofiber/storage/arangodb
 go 1.14
 
 require (
-	github.com/arangodb/go-driver v1.2.1
+	github.com/arangodb/go-driver v1.3.0
 	github.com/gofiber/utils v0.1.2
 )

arangodb/go.sum

@@ -1,5 +1,5 @@
-github.com/arangodb/go-driver v1.2.1 h1:HREDHhDmzdIWxHmfkfTESbYUnRjESjPh4WUuXq7FZa8=
-github.com/arangodb/go-driver v1.2.1/go.mod h1:zdDkJJnCj8DAkfbtIjIXnsTrWIiy6VhP3Vy14p+uQeY=
+github.com/arangodb/go-driver v1.3.0 h1:gJiCX1TcQcM3tp1sR0Cn90i82tpU58B8sRTS251DfJA=
+github.com/arangodb/go-driver v1.3.0/go.mod h1:5GAx3XvK72DJPhJgyjZOtYAGc4SpY7rZDb3LyhCvLcQ=
 github.com/arangodb/go-velocypack v0.0.0-20200318135517-5af53c29c67e h1:Xg+hGrY2LcQBbxd0ZFdbGSyRKTYMZCfBbw/pMJFOk1g=
 github.com/arangodb/go-velocypack v0.0.0-20200318135517-5af53c29c67e/go.mod h1:mq7Shfa/CaixoDxiyAAc5jZ6CVBAyPaNQCGS7mkj4Ho=
 github.com/coreos/go-iptables v0.4.3/go.mod h1:/mVI274lEDI2ns62jHCDnCyBF9Iwsmekav8Dbxlm1MU=

bbolt/README.md

@@ -0,0 +1,92 @@
+# Bbolt
+A Bbolt storage driver using [etcd-io/bbolt](https://github.com/etcd-io/bbolt). Bolt is a pure Go key/value store inspired by [Howard Chu's](https://twitter.com/hyc_symas) [LMDB project](https://www.symas.com/symas-embedded-database-lmdb). The goal of the project is to provide a simple, fast, and reliable database for projects that don't require a full database server such as Postgres or MySQL.
+
+
+### Table of Contents
+- [Signatures](#signatures)
+- [Installation](#installation)
+- [Examples](#examples)
+- [Config](#config)
+- [Default Config](#default-config)
+
+### Signatures
+```go
+func New(config ...Config) Storage
+func (s *Storage) Get(key string) ([]byte, error)
+func (s *Storage) Set(key string, val []byte, exp time.Duration) error
+func (s *Storage) Delete(key string) error
+func (s *Storage) Reset() error
+func (s *Storage) Close() error
+```
+### Installation
+Bbolt is tested on the 2 last [Go versions](https://golang.org/dl/) with support for modules. So make sure to initialize one first if you didn't do that yet:
+```bash
+go mod init github.com/<user>/<repo>
+```
+And then install the s3 implementation:
+```bash
+go get github.com/gofiber/storage/bbolt
+```
+
+### Examples
+Import the storage package.
+```go
+import "github.com/gofiber/storage/bbolt"
+```
+
+You can use the following possibilities to create a storage:
+```go
+// Initialize default config
+store := bbolt.New()
+
+// Initialize custom config
+store := bbolt.New(bbolt.Config{
+	Database: "my_database.db",
+	Bucket:   "my-bucket",
+	Reset:    false,
+})
+```
+
+### Config
+```go
+// Config defines the config for storage.
+type Config struct {
+	// Database path
+	//
+	// Optional. Default is "fiber.db"
+	Database string
+
+	// Bbolt bucket name
+	//
+	// Optional. Default is "fiber_storage"
+	Bucket string
+
+	// Timeout is the amount of time to wait to obtain a file lock.
+	// Only available on Darwin and Linux.
+	//
+	// Optional. Default is 0 (no timeout)
+	Timeout time.Duration
+
+	// Open database in read-only mode.
+	//
+	// Optional. Default is false
+	ReadOnly bool
+
+	// Reset clears any existing keys in existing Bucket
+	//
+	// Optional. Default is false
+	Reset bool
+}
+```
+
+### Default Config
+```go
+// ConfigDefault is the default config
+var ConfigDefault = Config{
+	Database: "fiber.db",
+	Bucket:   "fiber_storage",
+	Timeout:  0,
+	ReadOnly: false,
+	Reset:    false,
+}
+```

bbolt/bbolt.go

@@ -0,0 +1,106 @@
+package bbolt
+
+import (
+	"time"
+
+	"github.com/gofiber/utils"
+	"go.etcd.io/bbolt"
+)
+
+// Storage interface that is implemented by storage providers
+type Storage struct {
+	conn   *bbolt.DB
+	bucket string
+}
+
+// New creates a new storage
+func New(config ...Config) *Storage {
+	// Set default config
+	cfg := configDefault(config...)
+
+	conn, err := bbolt.Open(cfg.Database, 0666, &bbolt.Options{
+		Timeout:  cfg.Timeout,
+		ReadOnly: cfg.ReadOnly,
+	})
+	if err != nil {
+		panic(err)
+	}
+
+	// Reset bucket if field selected
+	if cfg.Reset {
+		if err := removeBucket(cfg, conn); err != nil {
+			panic(err)
+		}
+	}
+
+	// Create bucket if not exists
+	if err := createBucket(cfg, conn); err != nil {
+		panic(err)
+	}
+
+	return &Storage{
+		conn:   conn,
+		bucket: cfg.Bucket,
+	}
+
+}
+
+// Get value by key
+func (s *Storage) Get(key string) ([]byte, error) {
+	if len(key) <= 0 {
+		return nil, nil
+	}
+
+	var value []byte
+
+	err := s.conn.View(func(tx *bbolt.Tx) error {
+		b := tx.Bucket(utils.UnsafeBytes(s.bucket))
+		value = b.Get(utils.UnsafeBytes(key))
+
+		return nil
+	})
+
+	return value, err
+}
+
+// Set key with value
+func (s *Storage) Set(key string, value []byte, exp time.Duration) error {
+	if len(key) <= 0 || len(value) <= 0 {
+		return nil
+	}
+
+	return s.conn.Update(func(tx *bbolt.Tx) error {
+		b := tx.Bucket(utils.UnsafeBytes(s.bucket))
+
+		return b.Put(utils.UnsafeBytes(key), value)
+	})
+}
+
+// Delete entry by key
+func (s *Storage) Delete(key string) error {
+	if len(key) <= 0 {
+		return nil
+	}
+
+	return s.conn.Update(func(tx *bbolt.Tx) error {
+		b := tx.Bucket(utils.UnsafeBytes(s.bucket))
+
+		return b.Delete(utils.UnsafeBytes(key))
+	})
+}
+
+// Reset all entries
+func (s *Storage) Reset() error {
+	return s.conn.Update(func(tx *bbolt.Tx) error {
+		b := tx.Bucket(utils.UnsafeBytes(s.bucket))
+
+		return b.ForEach(func(k, _ []byte) error {
+			return b.Delete(k)
+		})
+	})
+}
+
+// Close the database
+func (s *Storage) Close() error {
+	return s.conn.Close()
+}

bbolt/bbolt_test.go

@@ -0,0 +1,97 @@
+package bbolt
+
+import (
+	"testing"
+
+	"github.com/gofiber/utils"
+)
+
+var testStore = New()
+
+func Test_Bbolt_Set(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+}
+
+func Test_Bbolt_Set_Override(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+}
+
+func Test_Bbolt_Get(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get(key)
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, val, result)
+}
+
+func Test_Bbolt_Get_NotExist(t *testing.T) {
+
+	result, err := testStore.Get("notexist")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_Bbolt_Delete(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Delete(key)
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get(key)
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_Bbolt_Reset(t *testing.T) {
+	var (
+		val = []byte("doe")
+	)
+
+	err := testStore.Set("john1", val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Set("john2", val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Reset()
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get("john1")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+
+	result, err = testStore.Get("john2")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_Bbolt_Close(t *testing.T) {
+	utils.AssertEqual(t, nil, testStore.Close())
+}

bbolt/config.go

@@ -0,0 +1,63 @@
+package bbolt
+
+import "time"
+
+// Config defines the config for storage.
+type Config struct {
+	// Database path
+	//
+	// Optional. Default is "fiber.db"
+	Database string
+
+	// Bbolt bucket name
+	//
+	// Optional. Default is "fiber_storage"
+	Bucket string
+
+	// Timeout is the amount of time to wait to obtain a file lock.
+	// Only available on Darwin and Linux.
+	//
+	// Optional. Default is 0 (no timeout)
+	Timeout time.Duration
+
+	// Open database in read-only mode.
+	//
+	// Optional. Default is false
+	ReadOnly bool
+
+	// Reset clears any existing keys in existing Bucket
+	//
+	// Optional. Default is false
+	Reset bool
+}
+
+// ConfigDefault is the default config
+var ConfigDefault = Config{
+	Database: "fiber.db",
+	Bucket:   "fiber_storage",
+	Timeout:  0,
+	ReadOnly: false,
+	Reset:    false,
+}
+
+// Helper function to set default values
+func configDefault(config ...Config) Config {
+	// Return default config if nothing provided
+	if len(config) < 1 {
+		return ConfigDefault
+	}
+
+	// Override default config
+	cfg := config[0]
+
+	// Set default values
+	if cfg.Database == "" {
+		cfg.Database = ConfigDefault.Database
+	}
+
+	if cfg.Bucket == "" {
+		cfg.Bucket = ConfigDefault.Bucket
+	}
+
+	return cfg
+}

bbolt/go.mod

@@ -0,0 +1,10 @@
+module github.com/gofiber/storage/bbolt
+
+go 1.16
+
+require (
+	github.com/gofiber/utils v0.1.2
+	go.etcd.io/bbolt v1.3.6
+)
+
+require golang.org/x/sys v0.0.0-20220204135822-1c1b9b1eba6a // indirect

bbolt/go.sum

@@ -0,0 +1,7 @@
+github.com/gofiber/utils v0.1.2 h1:1SH2YEz4RlNS0tJlMJ0bGwO0JkqPqvq6TbHK9tXZKtk=
+github.com/gofiber/utils v0.1.2/go.mod h1:pacRFtghAE3UoknMOUiXh2Io/nLWSUHtQCi/3QASsOc=
+go.etcd.io/bbolt v1.3.6 h1:/ecaJf0sk1l4l6V4awd65v2C3ILy7MSj+s/x1ADCIMU=
+go.etcd.io/bbolt v1.3.6/go.mod h1:qXsaaIqmgQH0T+OPdb99Bf+PKfBBQVAdyD6TY9G8XM4=
+golang.org/x/sys v0.0.0-20200923182605-d9f96fdee20d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20220204135822-1c1b9b1eba6a h1:ppl5mZgokTT8uPkmYOyEUmPTr3ypaKkg5eFOGrAmxxE=
+golang.org/x/sys v0.0.0-20220204135822-1c1b9b1eba6a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

bbolt/utils.go

@@ -0,0 +1,20 @@
+package bbolt
+
+import (
+	"github.com/gofiber/utils"
+	"go.etcd.io/bbolt"
+)
+
+func createBucket(cfg Config, conn *bbolt.DB) error {
+	return conn.Update(func(tx *bbolt.Tx) error {
+		_, err := tx.CreateBucketIfNotExists(utils.UnsafeBytes(cfg.Bucket))
+
+		return err
+	})
+}
+
+func removeBucket(cfg Config, conn *bbolt.DB) error {
+	return conn.Update(func(tx *bbolt.Tx) error {
+		return tx.DeleteBucket(utils.UnsafeBytes(cfg.Bucket))
+	})
+}

dynamodb/README.md

@@ -1,4 +1,7 @@
-# ⚠ DynamoDB is still in development, do not use in production!
+# DynamoDB
+A DynamoDB storage driver using [aws/aws-sdk-go-v2](https://github.com/aws/aws-sdk-go-v2).
+
+**Note:** If config fields of credentials not given, credentials are using from the environment variables, ~/.aws/credentials, or EC2 instance role. If config fields of credentials given, credentials are using from config. Look at: [specifying credentials](https://aws.github.io/aws-sdk-go-v2/docs/configuring-sdk/#specifying-credentials)
 
 ....
 
@@ -60,28 +63,70 @@ type Config struct {
 	// Optional ("fiber_storage" by default).
 	Table string
 
-	// AWS access key ID (part of the credentials).
-	// Optional (read from shared credentials file or environment variable if not set).
-	// Environment variable: "AWS_ACCESS_KEY_ID".
-	AWSaccessKeyID string
-
-	// AWS secret access key (part of the credentials).
-	// Optional (read from shared credentials file or environment variable if not set).
-	// Environment variable: "AWS_SECRET_ACCESS_KEY".
-	AWSsecretAccessKey string
-
 	// CustomEndpoint allows you to set a custom DynamoDB service endpoint.
 	// This is especially useful if you're running a "DynamoDB local" Docker container for local testing.
 	// Typical value for the Docker container: "http://localhost:8000".
 	// See https://hub.docker.com/r/amazon/dynamodb-local/.
 	// Optional ("" by default)
-	CustomEndpoint string
+	Endpoint string
+
+	// Credentials overrides AWS access key and AWS secret access key. Not recommended.
+	//
+	// Optional. Default is Credentials{}
+	Credentials Credentials
+
+	// The maximum number of times requests that encounter retryable failures should be attempted.
+	//
+	// Optional. Default is 3
+	MaxAttempts int
+
+	// Reset clears any existing keys in existing Bucket
+	//
+	// Optional. Default is false
+	Reset bool
+
+	// ReadCapacityUnits of the table.
+	// Only required when the table doesn't exist yet and is created by gokv.
+	// Optional (5 by default, which is the same default value as when creating a table in the web console)
+	// 25 RCUs are included in the free tier (across all tables).
+	// For example calculations, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/HowItWorks.ProvisionedThroughput.
+	// For limits, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/Limits.md#capacity-units-and-provisioned-throughput.md#provisioned-throughput.
+	ReadCapacityUnits int64
+
+	// ReadCapacityUnits of the table.
+	// Only required when the table doesn't exist yet and is created by gokv.
+	// Optional (5 by default, which is the same default value as when creating a table in the web console)
+	// 25 RCUs are included in the free tier (across all tables).
+	// For example calculations, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/HowItWorks.ProvisionedThroughput.
+	// For limits, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/Limits.md#capacity-units-and-provisioned-throughput.md#provisioned-throughput.
+	WriteCapacityUnits int64
+
+	// If the table doesn't exist yet, gokv creates it.
+	// If WaitForTableCreation is true, gokv will block until the table is created, with a timeout of 15 seconds.
+	// If the table still doesn't exist after 15 seconds, an error is returned.
+	// If WaitForTableCreation is false, gokv returns the client immediately.
+	// In the latter case you need to make sure that you don't read from or write to the table before it's created,
+	// because otherwise you will get ResourceNotFoundException errors.
+	// Optional (true by default).
+	WaitForTableCreation *bool
 }
+
+type Credentials struct {
+	AccessKey       string
+	SecretAccessKey string
+}
+
 ```
 
 ### Default Config
 ```go
 var ConfigDefault = Config{
-	Table: "fiber_storage",
+	Table:                "fiber_storage",
+	Credentials:          Credentials{},
+	MaxAttempts:          3,
+	Reset:                false,
+	ReadCapacityUnits:    5,
+	WriteCapacityUnits:   5,
+	WaitForTableCreation: aws.Bool(true),
 }
 ```

dynamodb/config.go

@@ -1,6 +1,6 @@
 package dynamodb
 
-import "github.com/aws/aws-sdk-go/aws"
+import "github.com/aws/aws-sdk-go-v2/aws"
 
 // Config defines the config for storage.
 type Config struct {
@@ -15,22 +15,27 @@ type Config struct {
 	// Optional ("fiber_storage" by default).
 	Table string
 
-	// AWS access key ID (part of the credentials).
-	// Optional (read from shared credentials file or environment variable if not set).
-	// Environment variable: "AWS_ACCESS_KEY_ID".
-	AWSaccessKeyID string
-
-	// AWS secret access key (part of the credentials).
-	// Optional (read from shared credentials file or environment variable if not set).
-	// Environment variable: "AWS_SECRET_ACCESS_KEY".
-	AWSsecretAccessKey string
-
 	// CustomEndpoint allows you to set a custom DynamoDB service endpoint.
 	// This is especially useful if you're running a "DynamoDB local" Docker container for local testing.
 	// Typical value for the Docker container: "http://localhost:8000".
 	// See https://hub.docker.com/r/amazon/dynamodb-local/.
 	// Optional ("" by default)
-	CustomEndpoint string
+	Endpoint string
+
+	// Credentials overrides AWS access key and AWS secret access key. Not recommended.
+	//
+	// Optional. Default is Credentials{}
+	Credentials Credentials
+
+	// The maximum number of times requests that encounter retryable failures should be attempted.
+	//
+	// Optional. Default is 3
+	MaxAttempts int
+
+	// Reset clears any existing keys in existing Bucket
+	//
+	// Optional. Default is false
+	Reset bool
 
 	// ReadCapacityUnits of the table.
 	// Only required when the table doesn't exist yet and is created by gokv.
@@ -38,14 +43,16 @@ type Config struct {
 	// 25 RCUs are included in the free tier (across all tables).
 	// For example calculations, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/HowItWorks.ProvisionedThroughput.
 	// For limits, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/Limits.md#capacity-units-and-provisioned-throughput.md#provisioned-throughput.
-	readCapacityUnits int64
+	ReadCapacityUnits int64
+
 	// ReadCapacityUnits of the table.
 	// Only required when the table doesn't exist yet and is created by gokv.
 	// Optional (5 by default, which is the same default value as when creating a table in the web console)
 	// 25 RCUs are included in the free tier (across all tables).
 	// For example calculations, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/HowItWorks.ProvisionedThroughput.
 	// For limits, see https://github.com/awsdocs/amazon-dynamodb-developer-guide/blob/c420420a59040c5b3dd44a6e59f7c9e55fc922ef/doc_source/Limits.md#capacity-units-and-provisioned-throughput.md#provisioned-throughput.
-	writeCapacityUnits int64
+	WriteCapacityUnits int64
+
 	// If the table doesn't exist yet, gokv creates it.
 	// If WaitForTableCreation is true, gokv will block until the table is created, with a timeout of 15 seconds.
 	// If the table still doesn't exist after 15 seconds, an error is returned.
@@ -53,15 +60,23 @@ type Config struct {
 	// In the latter case you need to make sure that you don't read from or write to the table before it's created,
 	// because otherwise you will get ResourceNotFoundException errors.
 	// Optional (true by default).
-	waitForTableCreation *bool
+	WaitForTableCreation *bool
+}
+
+type Credentials struct {
+	AccessKey       string
+	SecretAccessKey string
 }
 
 // ConfigDefault is the default config
 var ConfigDefault = Config{
 	Table:                "fiber_storage",
-	readCapacityUnits:    5,
-	writeCapacityUnits:   5,
-	waitForTableCreation: aws.Bool(true),
+	Credentials:          Credentials{},
+	MaxAttempts:          3,
+	Reset:                false,
+	ReadCapacityUnits:    5,
+	WriteCapacityUnits:   5,
+	WaitForTableCreation: aws.Bool(true),
 }
 
 // configDefault is a helper function to set default values
@@ -78,5 +93,18 @@ func configDefault(config ...Config) Config {
 	if cfg.Table == "" {
 		cfg.Table = ConfigDefault.Table
 	}
+	if cfg.MaxAttempts == 0 {
+		cfg.MaxAttempts = ConfigDefault.MaxAttempts
+	}
+	if cfg.ReadCapacityUnits == 0 {
+		cfg.ReadCapacityUnits = ConfigDefault.ReadCapacityUnits
+	}
+	if cfg.WriteCapacityUnits == 0 {
+		cfg.WriteCapacityUnits = ConfigDefault.WriteCapacityUnits
+	}
+	if cfg.WaitForTableCreation == nil {
+		cfg.WaitForTableCreation = ConfigDefault.WaitForTableCreation
+	}
+
 	return cfg
 }

dynamodb/dynamodb.go

@@ -3,90 +3,23 @@ package dynamodb
 import (
 	"context"
 	"errors"
+	"fmt"
 	"time"
 
-	"github.com/aws/aws-sdk-go/aws"
-	"github.com/aws/aws-sdk-go/aws/awserr"
-	"github.com/aws/aws-sdk-go/aws/credentials"
-	"github.com/aws/aws-sdk-go/aws/session"
-	awsdynamodb "github.com/aws/aws-sdk-go/service/dynamodb"
+	"github.com/aws/aws-sdk-go-v2/aws"
+	"github.com/aws/aws-sdk-go-v2/aws/retry"
+	awsconfig "github.com/aws/aws-sdk-go-v2/config"
+	"github.com/aws/aws-sdk-go-v2/credentials"
+	"github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue"
+	awsdynamodb "github.com/aws/aws-sdk-go-v2/service/dynamodb"
+	"github.com/aws/aws-sdk-go-v2/service/dynamodb/types"
 )
 
 // Storage interface that is implemented by storage providers
 type Storage struct {
-	db    *awsdynamodb.DynamoDB
-	table string
-}
-
-// New creates a new storage
-func New(config Config) *Storage {
-	// Set default config
-	cfg := configDefault(config)
-
-	// Create db
-	var creds *credentials.Credentials
-	if (cfg.AWSaccessKeyID != "" && cfg.AWSsecretAccessKey == "") || (cfg.AWSaccessKeyID == "" && cfg.AWSsecretAccessKey != "") {
-		panic("[DynamoDB] You need to set BOTH AWSaccessKeyID AND AWSsecretAccessKey")
-	} else if cfg.AWSaccessKeyID != "" {
-		// Due to the previous check we can be sure that in this case AWSsecretAccessKey is not empty as well.
-		creds = credentials.NewStaticCredentials(cfg.AWSaccessKeyID, cfg.AWSsecretAccessKey, "")
-	}
-
-	// Set database options
-	opt := aws.NewConfig()
-	if cfg.Region != "" {
-		opt = opt.WithRegion(cfg.Region)
-	}
-	if creds != nil {
-		opt = opt.WithCredentials(creds)
-	}
-	if cfg.CustomEndpoint != "" {
-		opt = opt.WithEndpoint(cfg.CustomEndpoint)
-	}
-
-	sessionOpt := session.Options{
-		SharedConfigState: session.SharedConfigEnable,
-	}
-
-	// ...but allow overwrite of region and credentials if they are set in the options.
-	sessionOpt.Config.MergeIn(opt)
-	session, err := session.NewSessionWithOptions(sessionOpt)
-	if err != nil {
-		panic(err)
-	}
-	svc := awsdynamodb.New(session)
-
-	timeoutCtx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
-	defer cancel()
-	describeTableInput := awsdynamodb.DescribeTableInput{
-		TableName: &cfg.Table,
-	}
-
-	_, err = svc.DescribeTableWithContext(timeoutCtx, &describeTableInput)
-	if err != nil {
-		awsErr, ok := err.(awserr.Error)
-		if !ok {
-			panic(err)
-		} else if awsErr.Code() == awsdynamodb.ErrCodeResourceNotFoundException {
-			err = createTable(cfg.Table, cfg.readCapacityUnits, cfg.writeCapacityUnits, *cfg.waitForTableCreation, describeTableInput, svc)
-			if err != nil {
-				panic(err)
-			}
-		} else {
-			panic(err)
-		}
-	}
-
-	// Create storage
-	store := &Storage{
-		db:    svc,
-		table: cfg.Table,
-	}
-
-	// Start garbage collector
-	//go store.gc()
-
-	return store
+	db             *awsdynamodb.Client
+	table          string
+	requestTimeout time.Duration
 }
 
 // "k" is used as table column name for the key.
@@ -95,126 +28,182 @@ var keyAttrName = "k"
 // "v" is used as table column name for the value.
 var valAttrName = "v"
 
+type table struct {
+	K string
+	V []byte
+}
+
+// New creates a new storage
+func New(config Config) *Storage {
+	// Set default config
+	cfg := configDefault(config)
+
+	awscfg, err := returnAWSConfig(cfg)
+	if err != nil {
+		panic(fmt.Sprintf("unable to load SDK config, %v", err))
+	}
+
+	// Create db
+	sess := awsdynamodb.NewFromConfig(awscfg)
+
+	timeoutCtx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
+	defer cancel()
+	describeTableInput := awsdynamodb.DescribeTableInput{
+		TableName: &cfg.Table,
+	}
+
+	// Create storage
+	store := &Storage{
+		db:    sess,
+		table: cfg.Table,
+	}
+
+	// Create table
+	_, err = sess.DescribeTable(timeoutCtx, &describeTableInput)
+	if err != nil {
+		var rnfe *types.ResourceNotFoundException
+		if errors.As(err, &rnfe) {
+			err := store.createTable(cfg, describeTableInput)
+			if err != nil {
+				panic(err)
+			}
+		} else {
+			panic(err)
+		}
+	}
+
+	return store
+}
+
 // Get value by key
 func (s *Storage) Get(key string) ([]byte, error) {
-	k := make(map[string]*awsdynamodb.AttributeValue)
-	k[keyAttrName] = &awsdynamodb.AttributeValue{
-		S: &key,
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
+	k := make(map[string]types.AttributeValue)
+	k[keyAttrName] = &types.AttributeValueMemberS{
+		Value: key,
 	}
 	getItemInput := awsdynamodb.GetItemInput{
 		TableName: &s.table,
 		Key:       k,
 	}
-	getItemOutput, err := s.db.GetItem(&getItemInput)
+	getItemOutput, err := s.db.GetItem(ctx, &getItemInput)
 	if err != nil {
+		var rnfe *types.ResourceNotFoundException
+		if errors.As(err, &rnfe) {
+			return nil, nil
+		}
+
 		return nil, err
 	} else if getItemOutput.Item == nil {
 		return nil, nil
 	}
-	attributeVal := getItemOutput.Item[valAttrName]
-	if attributeVal == nil {
-		return nil, nil
-	}
-	return attributeVal.B, nil
+
+	item := &table{}
+	err = attributevalue.UnmarshalMap(getItemOutput.Item, &item)
+
+	return item.V, err
 }
 
-// Set key with value
 // Set key with value
 func (s *Storage) Set(key string, val []byte, exp time.Duration) error {
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
 	// Ain't Nobody Got Time For That
 	if len(key) <= 0 || len(val) <= 0 {
 		return nil
 	}
-	item := make(map[string]*awsdynamodb.AttributeValue)
-	item[keyAttrName] = &awsdynamodb.AttributeValue{
-		S: &key,
+
+	item := make(map[string]types.AttributeValue)
+	item[keyAttrName] = &types.AttributeValueMemberS{
+		Value: key,
 	}
-	item[valAttrName] = &awsdynamodb.AttributeValue{
-		B: val,
+	item[valAttrName] = &types.AttributeValueMemberB{
+		Value: val,
 	}
 	putItemInput := awsdynamodb.PutItemInput{
 		TableName: &s.table,
 		Item:      item,
 	}
-	_, err := s.db.PutItem(&putItemInput)
+
+	_, err := s.db.PutItem(ctx, &putItemInput)
 	return err
 }
 
 // Delete entry by key
 func (s *Storage) Delete(key string) error {
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
 	// Ain't Nobody Got Time For That
 	if len(key) <= 0 {
 		return nil
 	}
-	k := make(map[string]*awsdynamodb.AttributeValue)
-	k[keyAttrName] = &awsdynamodb.AttributeValue{
-		S: &key,
+
+	k := make(map[string]types.AttributeValue)
+	k[keyAttrName] = &types.AttributeValueMemberS{
+		Value: key,
 	}
 	deleteItemInput := awsdynamodb.DeleteItemInput{
 		TableName: &s.table,
 		Key:       k,
 	}
-	_, err := s.db.DeleteItem(&deleteItemInput)
+
+	_, err := s.db.DeleteItem(ctx, &deleteItemInput)
 	return err
 }
 
 // Reset all entries, including unexpired
 func (s *Storage) Reset() error {
+	ctx, cancel := s.requestContext()
+	defer cancel()
+
 	deleteTableInput := awsdynamodb.DeleteTableInput{
 		TableName: &s.table,
 	}
-	_, err := s.db.DeleteTable(&deleteTableInput)
+	_, err := s.db.DeleteTable(ctx, &deleteTableInput)
 	return err
 }
 
 // Close the database
 func (s *Storage) Close() error {
-	// In the DynamoDB implementation this doesn't have any effect.
 	return nil
 }
 
-// GC deletes all expired entries
-// func (s *Storage) gc() {
-// 	ticker := time.NewTicker(s.gcInterval)
-// 	defer ticker.Stop()
-// 	for {
-// 		select {
-// 		case <-s.done:
-// 			return
-// 		case t := <-ticker.C:
-// 			_, _ = s.db.Exec(s.sqlGC, t.Unix())
-// 		}
-// 	}
-// }
+func (s *Storage) createTable(cfg Config, describeTableInput awsdynamodb.DescribeTableInput) error {
+	ctx, cancel := s.requestContext()
+	defer cancel()
 
-func createTable(tableName string, readCapacityUnits, writeCapacityUnits int64, waitForTableCreation bool, describeTableInput awsdynamodb.DescribeTableInput, svc *awsdynamodb.DynamoDB) error {
 	keyAttrType := "S" // For "string"
 	keyType := "HASH"  // As opposed to "RANGE"
+
 	createTableInput := awsdynamodb.CreateTableInput{
-		TableName: &tableName,
-		AttributeDefinitions: []*awsdynamodb.AttributeDefinition{{
+		TableName: &s.table,
+		AttributeDefinitions: []types.AttributeDefinition{{
 			AttributeName: &keyAttrName,
-			AttributeType: &keyAttrType,
+			AttributeType: types.ScalarAttributeType(keyAttrType),
 		}},
-		KeySchema: []*awsdynamodb.KeySchemaElement{{
+		KeySchema: []types.KeySchemaElement{{
 			AttributeName: &keyAttrName,
-			KeyType:       &keyType,
+			KeyType:       types.KeyType(keyType),
 		}},
-		ProvisionedThroughput: &awsdynamodb.ProvisionedThroughput{
-			ReadCapacityUnits:  &readCapacityUnits,
-			WriteCapacityUnits: &writeCapacityUnits,
+		ProvisionedThroughput: &types.ProvisionedThroughput{
+			ReadCapacityUnits:  &cfg.ReadCapacityUnits,
+			WriteCapacityUnits: &cfg.WriteCapacityUnits,
 		},
 	}
-	_, err := svc.CreateTable(&createTableInput)
+	_, err := s.db.CreateTable(ctx, &createTableInput)
 	if err != nil {
 		return err
 	}
 	// If configured (true by default), block until the table is created.
 	// Typical table creation duration is 10 seconds.
-	if waitForTableCreation {
+	if *cfg.WaitForTableCreation {
 		for try := 1; try < 16; try++ {
-			describeTableOutput, err := svc.DescribeTable(&describeTableInput)
-			if err != nil || *describeTableOutput.Table.TableStatus == "CREATING" {
+			describeTableOutput, err := s.db.DescribeTable(ctx, &describeTableInput)
+			if err != nil || describeTableOutput.Table.TableStatus == "CREATING" {
 				time.Sleep(1 * time.Second)
 			} else {
 				break
@@ -222,14 +211,56 @@ func createTable(tableName string, readCapacityUnits, writeCapacityUnits int64,
 		}
 		// Last try (16th) after 15 seconds of waiting.
 		// Now handle error as such.
-		describeTableOutput, err := svc.DescribeTable(&describeTableInput)
+		describeTableOutput, err := s.db.DescribeTable(ctx, &describeTableInput)
 		if err != nil {
-			return errors.New("The DynamoDB table couldn't be created")
+			return errors.New("dynamodb: the table couldn't be created")
 		}
-		if *describeTableOutput.Table.TableStatus == "CREATING" {
-			return errors.New("The DynamoDB table took too long to be created")
+		if describeTableOutput.Table.TableStatus == "CREATING" {
+			return errors.New("dynamodb: the table took too long to be created")
 		}
 	}
 
 	return nil
 }
+
+// Context for making requests will timeout if a non-zero timeout is configured
+func (s *Storage) requestContext() (context.Context, context.CancelFunc) {
+	if s.requestTimeout > 0 {
+		return context.WithTimeout(context.Background(), s.requestTimeout)
+	}
+	return context.Background(), func() {}
+}
+
+func returnAWSConfig(cfg Config) (aws.Config, error) {
+	endpoint := aws.EndpointResolverWithOptionsFunc(func(service, region string, options ...interface{}) (aws.Endpoint, error) {
+		if cfg.Endpoint != "" {
+			return aws.Endpoint{
+				PartitionID:       "aws",
+				URL:               cfg.Endpoint,
+				SigningRegion:     cfg.Region,
+				HostnameImmutable: true,
+			}, nil
+		}
+		return aws.Endpoint{}, &aws.EndpointNotFoundError{}
+	})
+
+	if cfg.Credentials != (Credentials{}) {
+		credentials := credentials.NewStaticCredentialsProvider(cfg.Credentials.AccessKey, cfg.Credentials.SecretAccessKey, "")
+		return awsconfig.LoadDefaultConfig(context.TODO(),
+			awsconfig.WithRegion(cfg.Region),
+			awsconfig.WithEndpointResolverWithOptions(endpoint),
+			awsconfig.WithCredentialsProvider(credentials),
+			awsconfig.WithRetryer(func() aws.Retryer {
+				return retry.AddWithMaxAttempts(retry.NewStandard(), cfg.MaxAttempts)
+			}),
+		)
+	}
+
+	return awsconfig.LoadDefaultConfig(context.TODO(),
+		awsconfig.WithRegion(cfg.Region),
+		awsconfig.WithEndpointResolverWithOptions(endpoint),
+		awsconfig.WithRetryer(func() aws.Retryer {
+			return retry.AddWithMaxAttempts(retry.NewStandard(), cfg.MaxAttempts)
+		}),
+	)
+}

dynamodb/dynamodb_test.go

@@ -1 +1,107 @@
 package dynamodb
+
+import (
+	"testing"
+
+	"github.com/gofiber/utils"
+)
+
+var testStore = New(
+	Config{
+		Table:    "fiber_storage",
+		Endpoint: "http://localhost:8000/",
+		Region:   "us-east-1",
+		Credentials: Credentials{
+			AccessKey:       "dummy",
+			SecretAccessKey: "dummy",
+		},
+	},
+)
+
+func Test_DynamoDB_Set(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+}
+
+func Test_DynamoDB_Set_Override(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+}
+
+func Test_DynamoDB_Get(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get(key)
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, val, result)
+}
+
+func Test_DynamoDB_Get_NotExist(t *testing.T) {
+
+	result, err := testStore.Get("notexist")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_DynamoDB_Delete(t *testing.T) {
+	var (
+		key = "john"
+		val = []byte("doe")
+	)
+
+	err := testStore.Set(key, val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Delete(key)
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get(key)
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_DynamoDB_Reset(t *testing.T) {
+	var (
+		val = []byte("doe")
+	)
+
+	err := testStore.Set("john1", val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Set("john2", val, 0)
+	utils.AssertEqual(t, nil, err)
+
+	err = testStore.Reset()
+	utils.AssertEqual(t, nil, err)
+
+	result, err := testStore.Get("john1")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+
+	result, err = testStore.Get("john2")
+	utils.AssertEqual(t, nil, err)
+	utils.AssertEqual(t, true, len(result) == 0)
+}
+
+func Test_DynamoDB_Close(t *testing.T) {
+	utils.AssertEqual(t, nil, testStore.Close())
+}

dynamodb/go.mod

@@ -2,4 +2,11 @@ module github.com/gofiber/storage/dynamodb
 
 go 1.14
 
-require github.com/aws/aws-sdk-go v1.42.46
+require (
+	github.com/aws/aws-sdk-go-v2 v1.15.0
+	github.com/aws/aws-sdk-go-v2/config v1.15.0
+	github.com/aws/aws-sdk-go-v2/credentials v1.10.0
+	github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue v1.8.0
+	github.com/aws/aws-sdk-go-v2/service/dynamodb v1.15.0
+	github.com/gofiber/utils v0.1.2
+)

dynamodb/go.sum

@@ -1,23 +1,50 @@
-github.com/aws/aws-sdk-go v1.42.46 h1:Uehqm39VwQ+t0T7PeoFfsT1SjYRmazuTd9LMdN1JszE=
-github.com/aws/aws-sdk-go v1.42.46/go.mod h1:OGr6lGMAKGlG9CVrYnWYDKIyb829c6EVBRjxqjmPepc=
+github.com/aws/aws-sdk-go-v2 v1.15.0 h1:f9kWLNfyCzCB43eupDAk3/XgJ2EpgktiySD6leqs0js=
+github.com/aws/aws-sdk-go-v2 v1.15.0/go.mod h1:lJYcuZZEHWNIb6ugJjbQY1fykdoobWbOS7kJYb4APoI=
+github.com/aws/aws-sdk-go-v2/config v1.15.0 h1:cibCYF2c2uq0lsbu0Ggbg8RuGeiHCmXwUlTMS77CiK4=
+github.com/aws/aws-sdk-go-v2/config v1.15.0/go.mod h1:NccaLq2Z9doMmeQXHQRrt2rm+2FbkrcPvfdbCaQn5hY=
+github.com/aws/aws-sdk-go-v2/credentials v1.10.0 h1:M/FFpf2w31F7xqJqJLgiM0mFpLOtBvwZggORr6QCpo8=
+github.com/aws/aws-sdk-go-v2/credentials v1.10.0/go.mod h1:HWJMr4ut5X+Lt/7epc7I6Llg5QIcoFHKAeIzw32t6EE=
+github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue v1.8.0 h1:XxTy21xVUkoCZOSGwf+AW22v8aK3eEbYMaGGQ3MbKKk=
+github.com/aws/aws-sdk-go-v2/feature/dynamodb/attributevalue v1.8.0/go.mod h1:6WkjzWenkrj3IgLPIPBBz4Qh99jNDF8L4Wj03vfMhAA=
+github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.0 h1:gUlb+I7NwDtqJUIRcFYDiheYa97PdVHG/5Iz+SwdoHE=
+github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.12.0/go.mod h1:prX26x9rmLwkEE1VVCelQOQgRN9sOVIssgowIJ270SE=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.6 h1:xiGjGVQsem2cxoIX61uRGy+Jux2s9C/kKbTrWLdrU54=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.1.6/go.mod h1:SSPEdf9spsFgJyhjrXvawfpyzrXHBCUe+2eQ1CjC1Ak=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.0 h1:bt3zw79tm209glISdMRCIVRCwvSDXxgAxh5KWe2qHkY=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.4.0/go.mod h1:viTrxhAuejD+LszDahzAE2x40YjYWhMqzHxv2ZiWaME=
+github.com/aws/aws-sdk-go-v2/internal/ini v1.3.7 h1:QOMEP8jnO8sm0SX/4G7dbaIq2eEP2wcWEsF0jzrXLJc=
+github.com/aws/aws-sdk-go-v2/internal/ini v1.3.7/go.mod h1:P5sjYYf2nc5dE6cZIzEMsVtq6XeLD7c4rM+kQJPrByA=
+github.com/aws/aws-sdk-go-v2/service/dynamodb v1.15.0 h1:qnx+WyIH9/AD+wAxi05WCMNanO236ceqHg6hChCWs3M=
+github.com/aws/aws-sdk-go-v2/service/dynamodb v1.15.0/go.mod h1:+Kc1UmbE37ijaAsb3KogW6FR8z0myjX6VtdcCkQEK0k=
+github.com/aws/aws-sdk-go-v2/service/dynamodbstreams v1.13.0 h1:s71pGCiLqqGRoUWtdJ2j4PazwEpZVwQc16na/4FfXdk=
+github.com/aws/aws-sdk-go-v2/service/dynamodbstreams v1.13.0/go.mod h1:YGzTq/joAih4HRZZtMBWGP4bI8xVucOBQ9RvuanpclA=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.9.0 h1:uhb7moM7VjqIEpWzTpCvceLDSwrWpaleXm39OnVjuLE=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.9.0/go.mod h1:pA2St3Pu2Ldy6fBPY45Azoh1WBG4oS7eIKOd4XN7Meg=
+github.com/aws/aws-sdk-go-v2/service/internal/endpoint-discovery v1.7.0 h1:6Bc0KHhAyxGe15JUHrK+Udw7KhE5LN+5HKZjQGo4yDI=
+github.com/aws/aws-sdk-go-v2/service/internal/endpoint-discovery v1.7.0/go.mod h1:0nXuX9UrkN4r0PX9TSKfcueGRfsdEYIKG4rjTeJ61X8=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.0 h1:YQ3fTXACo7xeAqg0NiqcCmBOXJruUfh+4+O2qxF2EjQ=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.9.0/go.mod h1:R31ot6BgESRCIoxwfKtIHzZMo/vsZn2un81g9BJ4nmo=
+github.com/aws/aws-sdk-go-v2/service/sso v1.11.0 h1:gZLEXLH6NiU8Y52nRhK1jA+9oz7LZzBK242fi/ziXa4=
+github.com/aws/aws-sdk-go-v2/service/sso v1.11.0/go.mod h1:d1WcT0OjggjQCAdOkph8ijkr5sUwk1IH/VenOn7W1PU=
+github.com/aws/aws-sdk-go-v2/service/sts v1.16.0 h1:0+X/rJ2+DTBKWbUsn7WtF0JvNk/fRf928vkFsXkbbZs=
+github.com/aws/aws-sdk-go-v2/service/sts v1.16.0/go.mod h1:+8k4H2ASUZZXmjx/s3DFLo9tGBb44lkz3XcgfypJY7s=
+github.com/aws/smithy-go v1.11.1 h1:IQ+lPZVkSM3FRtyaDox41R8YS6iwPMYIreejOgPW49g=
+github.com/aws/smithy-go v1.11.1/go.mod h1:3xHYmszWVx2c0kIwQeEVf9uSm4fYZt67FBJnwub1bgM=
 github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/gofiber/utils v0.1.2 h1:1SH2YEz4RlNS0tJlMJ0bGwO0JkqPqvq6TbHK9tXZKtk=
+github.com/gofiber/utils v0.1.2/go.mod h1:pacRFtghAE3UoknMOUiXh2Io/nLWSUHtQCi/3QASsOc=
+github.com/google/go-cmp v0.5.7 h1:81/ik6ipDQS2aGcBfIN5dHDB36BwrStyeAQquSYCV4o=
+github.com/google/go-cmp v0.5.7/go.mod h1:n+brtR0CgQNWTVd5ZUFpTBC8YFBDLK/h/bpaJ8/DtOE=
 github.com/jmespath/go-jmespath v0.4.0 h1:BEgLn5cpjn8UN1mAw4NjwDrS35OdebyEtFe+9YPoQUg=
 github.com/jmespath/go-jmespath v0.4.0/go.mod h1:T8mJZnbsbmF+m6zOOFylbeCJqk5+pHWvzYPziyZiYoo=
 github.com/jmespath/go-jmespath/internal/testify v1.5.1 h1:shLQSRRSCCPj3f2gpwzGwWFoC7ycTf1rcQZHOlsJ6N8=
 github.com/jmespath/go-jmespath/internal/testify v1.5.1/go.mod h1:L3OGu8Wl2/fWfCI6z80xFu9LTZmf1ZRjMHUOPmWr69U=
-github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
-golang.org/x/net v0.0.0-20211216030914-fe4d6282115f h1:hEYJvxw1lSnWIl8X9ofsYMklzaDs90JI2az5YMd4fPM=
-golang.org/x/net v0.0.0-20211216030914-fe4d6282115f/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
-golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
-golang.org/x/text v0.3.6 h1:aRYxNxv6iGQlyVaZmk6ZgYEDa+Jg18DxebPSrd6bg1M=
-golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
-golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/yaml.v2 v2.2.8 h1:obN1ZagJSUGI0Ek/LBmuj4SNLPfIny3KsKFopxRdj10=

mongodb/go.mod

@@ -7,7 +7,7 @@ require (
 	github.com/gofiber/utils v0.1.2
 	github.com/golang/snappy v0.0.4 // indirect
 	github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a // indirect
-	go.mongodb.org/mongo-driver v1.8.3
+	go.mongodb.org/mongo-driver v1.8.4
 	golang.org/x/crypto v0.0.0-20211215153901-e495a2d5b3d3 // indirect
 	golang.org/x/sync v0.0.0-20210220032951-036812b2e83c // indirect
 	golang.org/x/text v0.3.7 // indirect

mongodb/go.sum

@@ -37,8 +37,8 @@ github.com/xdg-go/stringprep v1.0.2/go.mod h1:8F9zXuvzgwmyT5DUm4GUfZGDdT3W+LCvS6
 github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d/go.mod h1:rHwXgn7JulP+udvsHwJoVG1YGAP6VLg4y9I5dyZdqmA=
 github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a h1:fZHgsYlfvtyqToslyjUt3VOPF4J7aK/3MPcK7xp3PDk=
 github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a/go.mod h1:ul22v+Nro/R083muKhosV54bj5niojjWZvU8xrevuH4=
-go.mongodb.org/mongo-driver v1.8.3 h1:TDKlTkGDKm9kkJVUOAXDK5/fkqKHJVwYQSpoRfB43R4=
-go.mongodb.org/mongo-driver v1.8.3/go.mod h1:0sQWfOeY63QTntERDJJ/0SuKK0T1uVSgKCuAROlKEPY=
+go.mongodb.org/mongo-driver v1.8.4 h1:NruvZPPL0PBcRJKmbswoWSrmHeUvzdxA3GCPfD/NEOA=
+go.mongodb.org/mongo-driver v1.8.4/go.mod h1:0sQWfOeY63QTntERDJJ/0SuKK0T1uVSgKCuAROlKEPY=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
 golang.org/x/crypto v0.0.0-20200302210943-78000ba7a073/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
 golang.org/x/crypto v0.0.0-20201216223049-8b5274cf687f/go.mod h1:jdWPYTVW3xRLrWPugEBEK3UY2ZEsg3UU495nc5E+M+I=

redis/go.mod

@@ -3,6 +3,7 @@ module github.com/gofiber/storage/redis
 go 1.14
 
 require (
-	github.com/go-redis/redis/v8 v8.11.4
+	github.com/go-redis/redis/v8 v8.11.5
 	github.com/gofiber/utils v0.1.2
+	github.com/google/go-cmp v0.5.6 // indirect
 )

redis/go.sum

@@ -1,5 +1,8 @@
 github.com/cespare/xxhash/v2 v2.1.2 h1:YRXhKfTDauu4ajMg1TPgFO5jnlC2HCbmLXMcTG5cbYE=
 github.com/cespare/xxhash/v2 v2.1.2/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWRnGsAI=
+github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI=
+github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
@@ -7,8 +10,8 @@ github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cu
 github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
 github.com/fsnotify/fsnotify v1.4.9 h1:hsms1Qyu0jgnwNXIxa+/V/PDsU6CfLf6CNO8H7IWoS4=
 github.com/fsnotify/fsnotify v1.4.9/go.mod h1:znqG4EE+3YCdAaPaxE2ZRY/06pZUdp0tY4IgpuI1SZQ=
-github.com/go-redis/redis/v8 v8.11.4 h1:kHoYkfZP6+pe04aFTnhDH6GDROa5yJdHJVNxV3F46Tg=
-github.com/go-redis/redis/v8 v8.11.4/go.mod h1:2Z2wHZXdQpCDXEGzqMockDpNyYvi2l4Pxt6RJr792+w=
+github.com/go-redis/redis/v8 v8.11.5 h1:AcZZR7igkdvfVmQTPnu9WE37LRrO/YrBH5zWyjDC0oI=
+github.com/go-redis/redis/v8 v8.11.5/go.mod h1:gREzHqY1hg6oD9ngVRbLStwAWKhA0FEgq8Jd4h5lpwo=
 github.com/go-task/slim-sprig v0.0.0-20210107165309-348f09dbbbc0/go.mod h1:fyg7847qk6SyHyPtNmDHnmrv/HOrqktSC+C9fM+CJOE=
 github.com/gofiber/utils v0.1.2 h1:1SH2YEz4RlNS0tJlMJ0bGwO0JkqPqvq6TbHK9tXZKtk=
 github.com/gofiber/utils v0.1.2/go.mod h1:pacRFtghAE3UoknMOUiXh2Io/nLWSUHtQCi/3QASsOc=
@@ -28,18 +31,24 @@ github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/
 github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/go-cmp v0.5.6 h1:BKbKCqvP6I+rmFHt06ZmyQtvB8xAkWdhFyr0ZUNZcxQ=
 github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/pprof v0.0.0-20210407192527-94a9f03dee38/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
 github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
+github.com/ianlancetaylor/demangle v0.0.0-20200824232613-28f6c0f3b639/go.mod h1:aSSvb/t6k1mPoxDqO4vJh6VOCGPwU4O0C2/Eqndh1Sc=
 github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A=
 github.com/nxadm/tail v1.4.8 h1:nPr65rt6Y5JFSKQO7qToXr7pePgD6Gwiw05lkbyAQTE=
 github.com/nxadm/tail v1.4.8/go.mod h1:+ncqLTQzXmGhMZNUePPaPqPvBxHAIsmXswZKocGu+AU=
 github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
 github.com/onsi/ginkgo v1.12.1/go.mod h1:zj2OWP4+oCPe1qIXoGWkgMRwljMUYCdkwsT2108oapk=
-github.com/onsi/ginkgo v1.16.4 h1:29JGrr5oVBm5ulCWet69zQkzWipVXIol6ygQUe/EzNc=
 github.com/onsi/ginkgo v1.16.4/go.mod h1:dX+/inL/fNMqNlz0e9LfyB9TswhZpCVdJM/Z6Vvnwo0=
+github.com/onsi/ginkgo v1.16.5 h1:8xi0RTUf59SOSfEtZMvwTvXYMzG4gV23XVHOZiXNtnE=
+github.com/onsi/ginkgo v1.16.5/go.mod h1:+E8gABHa3K6zRBolWtd+ROzc/U5bkGt0FwiG042wbpU=
+github.com/onsi/ginkgo/v2 v2.0.0 h1:CcuG/HvWNkkaqCUpJifQY8z7qEMBJya6aLPx6ftGyjQ=
+github.com/onsi/ginkgo/v2 v2.0.0/go.mod h1:vw5CSIxN1JObi/U8gcbwft7ZxR2dgaR70JSE3/PpL4c=
 github.com/onsi/gomega v1.7.1/go.mod h1:XdKZgCCFLUoM/7CFJVPcG8C1xQ1AJ0vpAezJrB7JYyY=
 github.com/onsi/gomega v1.10.1/go.mod h1:iN09h71vgCQne3DLsj+A5owkum+a2tYe+TOCB1ybHNo=
-github.com/onsi/gomega v1.16.0 h1:6gjqkI8iiRHMvdccRJM8rVKjCWk6ZIm6FTm3ddIe4/c=
-github.com/onsi/gomega v1.16.0/go.mod h1:HnhC7FXeEQY45zxNK3PPoIUhzk/80Xly9PcubAlGdZY=
+github.com/onsi/gomega v1.17.0/go.mod h1:HnhC7FXeEQY45zxNK3PPoIUhzk/80Xly9PcubAlGdZY=
+github.com/onsi/gomega v1.18.1 h1:M1GfJqGRrBrrGGsbxzV5dqM2U2ApXefZCQpkukxYRLE=
+github.com/onsi/gomega v1.18.1/go.mod h1:0q+aL8jAiMXy9hbwj2mr5GziHiwhAIQpFmmtT5hitRs=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
@@ -64,12 +73,14 @@ golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7w
 golang.org/x/sys v0.0.0-20190904154756-749cb33beabd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20191005200804-aed5e4c7ecf9/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20191120155948-bd437916bb0e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20191204072324-ce4227a45e2e/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210112080510-489259a85091/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
-golang.org/x/sys v0.0.0-20210423082822-04245dca01da h1:b3NXsE2LusjYGGjL5bxEVZZORm/YEFFrWFjR8eFrw/c=
 golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e h1:fLOSk5Q00efkSvAm+4xcoXD+RRmLmmulPn5I3Y9F2EM=
+golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
 golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=

ristretto/ristretto_test.go

@@ -42,6 +42,9 @@ func Test_Ristretto_Get(t *testing.T) {
 	err := testStore.Set(key, val, 0)
 	utils.AssertEqual(t, nil, err)
 
+	// stabilize with some delay in between -> bug already communicated
+	time.Sleep(10000)
+
 	result, err := testStore.Get(key)
 	utils.AssertEqual(t, nil, err)
 	utils.AssertEqual(t, val, result)
@@ -86,6 +89,9 @@ func Test_Ristretto_Delete(t *testing.T) {
 	err := testStore.Set(key, val, 0)
 	utils.AssertEqual(t, nil, err)
 
+	// stabilize with some delay in between -> bug already communicated
+	time.Sleep(10000)
+
 	err = testStore.Delete(key)
 	utils.AssertEqual(t, nil, err)
 

sqlite3/go.mod

@@ -4,5 +4,5 @@ go 1.14
 
 require (
 	github.com/gofiber/utils v0.1.2
-	github.com/mattn/go-sqlite3 v1.14.11
+	github.com/mattn/go-sqlite3 v1.14.12
 )

sqlite3/go.sum

@@ -1,4 +1,4 @@
 github.com/gofiber/utils v0.1.2 h1:1SH2YEz4RlNS0tJlMJ0bGwO0JkqPqvq6TbHK9tXZKtk=
 github.com/gofiber/utils v0.1.2/go.mod h1:pacRFtghAE3UoknMOUiXh2Io/nLWSUHtQCi/3QASsOc=
-github.com/mattn/go-sqlite3 v1.14.11 h1:gt+cp9c0XGqe9S/wAHTL3n/7MqY+siPWgWJgqdsFrzQ=
-github.com/mattn/go-sqlite3 v1.14.11/go.mod h1:NyWgC/yNuGj7Q9rpYnZvas74GogHl5/Z4A/KQRfk6bU=
+github.com/mattn/go-sqlite3 v1.14.12 h1:TJ1bhYJPV44phC+IMu1u2K/i5RriLTPe+yc68XDJ1Z0=
+github.com/mattn/go-sqlite3 v1.14.12/go.mod h1:NyWgC/yNuGj7Q9rpYnZvas74GogHl5/Z4A/KQRfk6bU=