aboutsummaryrefslogtreecommitdiff
path: root/weed/filer/arangodb
diff options
context:
space:
mode:
authorelee <eddy@gfxlabs.io>2022-03-17 05:07:40 -0500
committerelee <eddy@gfxlabs.io>2022-03-17 05:07:40 -0500
commit31571dd96e9c3b299dc72d0afac2859098248fc9 (patch)
tree5ea3213bbebf1eec420ed157de933adb03a2beb3 /weed/filer/arangodb
parentb25d03340b8fe7ca3c25ac20a9f14f85e1935f90 (diff)
downloadseaweedfs-31571dd96e9c3b299dc72d0afac2859098248fc9.tar.xz
seaweedfs-31571dd96e9c3b299dc72d0afac2859098248fc9.zip
fix file listing
Diffstat (limited to 'weed/filer/arangodb')
-rw-r--r--weed/filer/arangodb/arangodb_store.go19
1 files changed, 8 insertions, 11 deletions
diff --git a/weed/filer/arangodb/arangodb_store.go b/weed/filer/arangodb/arangodb_store.go
index 3cc9e14c9..dc4fbad84 100644
--- a/weed/filer/arangodb/arangodb_store.go
+++ b/weed/filer/arangodb/arangodb_store.go
@@ -268,22 +268,19 @@ func (store *ArangodbStore) ListDirectoryPrefixedEntries(ctx context.Context, di
}
func (store *ArangodbStore) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error) {
- dir, name := dirPath.DirAndName()
eq := ""
- if includeStartFile {
- eq = "="
+ if !includeStartFile {
+ eq = "filter d.name != \"" + startFileName + "\""
}
- _ = eq
- _ = name
-
- cur, err := store.database.Query(ctx, fmt.Sprintf(`
+ fmt.Println(dirPath, startFileName, includeStartFile)
+ query := fmt.Sprintf(`
for d in files
-filter d.directory == @dir
+filter d.directory == "%s"
sort d.name desc
+%s
limit %d
-return d`, limit), map[string]interface{}{
- "dir": dir,
- })
+return d`, string(dirPath), eq, limit)
+ cur, err := store.database.Query(ctx, query, nil)
if err != nil {
return lastFileName, fmt.Errorf("failed to list directory entries: find error: %w", err)
}