totole/services
1
0
Fork 0
mirror of https://github.com/kevin-DL/services.git synced 2026-01-11 19:04:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix reading

Browse Source
This commit is contained in:
Asim Aslam
2021-12-10 20:44:03 +00:00
parent 50e3377f32
commit 515f2f6caf
1 changed files with 17 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
file/handler/files.go
View File

@@ -83,30 +83,29 @@ func (e *File) Read(ctx context.Context, req *file.ReadRequest, rsp *file.ReadRe
path := filepath.Join("file", tenantId, req.Project, req.Path)
var opts []store.ReadOption
if strings.HasSuffix(req.Path, "/") {
opts = append(opts, store.ReadPrefix())
}
records, err := store.Read(path, opts...)
records, err := store.Read(path)
if err != nil {
return err
}
// filter the file
for _, rec := range records {
file := new(file.Record)
if err := rec.Decode(file); err != nil {
continue
}
// strip the tenant id
file.Project = strings.TrimPrefix(file.Project, tenantId+"/")
file.Path = strings.TrimPrefix(file.Path, filepath.Join(tenantId, req.Project))
if len(records) == 0 {
return errors.NotFound("file.read", "file not found")
}
// filter the file
rec := records[0]
file := new(file.Record)
if err := rec.Decode(file); err != nil {
return err
}
// strip the tenant id
file.Project = strings.TrimPrefix(file.Project, tenantId+"/")
file.Path = strings.TrimPrefix(file.Path, filepath.Join(tenantId, req.Project))
rsp.File = file
return nil
}