Fix ForeachDocs function of pkg/couchdb (#4378)

The bug was introduced in #4377.

Author: nono

pkg/couchdb/bulk.go

@@ -206,7 +206,7 @@ func ForeachDocsWithCustomPagination(db prefixer.Prefixer, doctype string, limit
 			skip = 1
 		}
 		req := &AllDocsRequest{
-			StartKey: startKey,
+			StartKey: `"` + startKey + `"`,
 			Skip:     skip,
 			Limit:    limit,
 		}

pkg/couchdb/couchdb_test.go

@@ -3,6 +3,7 @@ package couchdb
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 	"reflect"
 	"strings"
 	"sync"
@@ -262,6 +263,34 @@ func TestCouchdb(t *testing.T) {
 		}
 	})
 
+	t.Run("ForeachDocs", func(t *testing.T) {
+		for i := 0; i < 5; i++ {
+			doc := &testDoc{Test: fmt.Sprintf("foreach_%d", i)}
+			require.NoError(t, CreateDoc(TestPrefix, doc))
+		}
+
+		var results []*testDoc
+		err := GetAllDocs(TestPrefix, TestDoctype, &AllDocsRequest{}, &results)
+		require.NoError(t, err)
+		var expected []string
+		for _, result := range results {
+			expected = append(expected, result.Test)
+		}
+
+		var keys []string
+		ForeachDocsWithCustomPagination(TestPrefix, TestDoctype, 2, func(id string, raw json.RawMessage) error {
+			var doc testDoc
+			err := json.Unmarshal(raw, &doc)
+			if err != nil {
+				return err
+			}
+			keys = append(keys, doc.Test)
+			return nil
+		})
+
+		assert.Equal(t, expected, keys)
+	})
+
 	t.Run("ChangesSuccess", func(t *testing.T) {
 		err := ResetDB(TestPrefix, TestDoctype)
 		assert.NoError(t, err)