chore(kv): ensure kv store implementation return seek missing prefix …

…error in tests

bolt/kv.go

@@ -201,13 +201,18 @@ func (b *Bucket) ForwardCursor(seek []byte, opts ...kv.CursorOption) (kv.Forward
 	var (
 		cursor     = b.bucket.Cursor()
 		key, value = cursor.Seek(seek)
+		config     = kv.NewCursorConfig(opts...)
 	)
 
+	if config.Prefix != nil && !bytes.HasPrefix(seek, config.Prefix) {
+		return nil, fmt.Errorf("seek bytes %q not prefixed with %q: %w", string(seek), string(config.Prefix), kv.ErrSeekMissingPrefix)
+	}
+
 	return &Cursor{
 		cursor: cursor,
 		key:    key,
 		value:  value,
-		config: kv.NewCursorConfig(opts...),
+		config: config,
 	}, nil
 }
 

testing/kv.go

@@ -3,6 +3,7 @@ package testing
 import (
 	"bytes"
 	"context"
+	"errors"
 	"fmt"
 	"testing"
 	"time"
@@ -736,6 +737,24 @@ func KVForwardCursor(
 			},
 			exp: []string{"aaa/00", "aaa/01", "aaa/02", "aaa/03"},
 		},
+		{
+			name: "prefix - does not prefix seek",
+			fields: KVStoreFields{
+				Bucket: []byte("bucket"),
+				Pairs: pairs(
+					"aa/00", "aa/01",
+					"aaa/00", "aaa/01", "aaa/02", "aaa/03",
+					"bbb/00", "bbb/01", "bbb/02"),
+			},
+			args: args{
+				seek:  "aaa/00",
+				until: "bbb/02",
+				opts: []kv.CursorOption{
+					kv.WithCursorPrefix([]byte("aab")),
+				},
+			},
+			expErr: kv.ErrSeekMissingPrefix,
+		},
 		{
 			name: "prefix hint",
 			fields: KVStoreFields{
@@ -924,6 +943,11 @@ func KVForwardCursor(
 
 				cur, err := b.ForwardCursor([]byte(tt.args.seek), tt.args.opts...)
 				if err != nil {
+					if tt.expErr != nil && errors.Is(err, tt.expErr) {
+						// successfully returned expected error
+						return nil
+					}
+
 					t.Errorf("unexpected error: %v", err)
 					return err
 				}