From 2343cb633118aaeaea26d0c7876299e2087a3baf Mon Sep 17 00:00:00 2001 From: "A.Unger" Date: Fri, 23 Oct 2020 10:38:23 +0200 Subject: [PATCH] interpret lower bounds correctly for the cs3 index --- accounts/pkg/indexer/index/cs3/autoincrement.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/accounts/pkg/indexer/index/cs3/autoincrement.go b/accounts/pkg/indexer/index/cs3/autoincrement.go index d65f45559..010499a4f 100644 --- a/accounts/pkg/indexer/index/cs3/autoincrement.go +++ b/accounts/pkg/indexer/index/cs3/autoincrement.go @@ -41,6 +41,7 @@ type Autoincrement struct { dataProvider dataProviderClient // Used to create and download data via http, bypassing reva upload protocol cs3conf *Config + bound *option.Bound } func init() { @@ -58,6 +59,7 @@ func NewAutoincrementIndex(o ...option.Option) index.Index { indexBy: opts.IndexBy, typeName: opts.TypeName, filesDir: opts.FilesDir, + bound: opts.Bound, indexBaseDir: path.Join(opts.DataDir, "index.cs3"), indexRootDir: path.Join(path.Join(opts.DataDir, "index.cs3"), strings.Join([]string{"autoincrement", opts.TypeName, opts.IndexBy}, ".")), cs3conf: &Config{ @@ -356,5 +358,10 @@ func (idx *Autoincrement) next() (int, error) { if err != nil { return -1, err } + + if int64(latest) < idx.bound.Lower { + return int(idx.bound.Lower), nil + } + return latest + 1, nil }