feat(aliyundrive_open): support get fileobj by path

Author: hshpy

drivers/115_open/driver.go

@@ -131,7 +131,7 @@ func (d *Open115) Link(ctx context.Context, file model.Obj, args model.LinkArgs)
 	}, nil
 }
 
-func (d *Open115) GetObjInfo(ctx context.Context, path string) (model.Obj, error) {
+func (d *Open115) Get(ctx context.Context, path string) (model.Obj, error) {
 	if err := d.WaitLimit(ctx); err != nil {
 		return nil, err
 	}

drivers/aliyundrive_open/driver.go

@@ -83,6 +83,22 @@ func (d *AliyundriveOpen) GetRoot(ctx context.Context) (model.Obj, error) {
 	}, nil
 }
 
+func (d *AliyundriveOpen) Get(ctx context.Context, path string) (model.Obj, error) {
+	var resp File
+	_, err := d.request(ctx, limiterLink, "/adrive/v1.0/openFile/get_by_path", http.MethodPost, func(req *resty.Request) {
+		req.SetBody(base.Json{
+			"drive_id":  d.DriveId,
+			"file_path": path,
+		}).SetResult(&resp)
+	})
+	if err != nil {
+		return nil, err
+	}
+	obj := fileToObj(resp)
+	obj.Path = path
+	return obj, nil
+}
+
 func (d *AliyundriveOpen) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
 	files, err := d.getFiles(ctx, dir.GetID())
 	if err != nil {

internal/driver/driver.go

@@ -47,11 +47,6 @@ type Getter interface {
 	Get(ctx context.Context, path string) (model.Obj, error)
 }
 
-type GetObjInfo interface {
-	// GetObjInfo get file info by path
-	GetObjInfo(ctx context.Context, path string) (model.Obj, error)
-}
-
 //type Writer interface {
 //	Mkdir
 //	Move

internal/op/fs.go

@@ -5,7 +5,6 @@ import (
 	stderrors "errors"
 	stdpath "path"
 	"slices"
-	"strings"
 	"time"
 
 	"github.com/OpenListTeam/OpenList/v4/internal/driver"
@@ -258,32 +257,11 @@ func Link(ctx context.Context, storage driver.Driver, path string, args model.Li
 	if storage.Config().CheckStatus && storage.GetStorage().Status != WORK {
 		return nil, nil, errors.Errorf("storage not init: %s", storage.GetStorage().Status)
 	}
-	var (
-		file model.Obj
-		err  error
-	)
-	// use cache directly
-	dir, name := stdpath.Split(stdpath.Join(storage.GetStorage().MountPath, path))
-	if cacheFiles, ok := listCache.Get(strings.TrimSuffix(dir, "/")); ok {
-		for _, f := range cacheFiles {
-			if f.GetName() == name {
-				file = model.UnwrapObj(f)
-				break
-			}
-		}
-	} else {
-		if g, ok := storage.(driver.GetObjInfo); ok {
-			file, err = g.GetObjInfo(ctx, path)
-		} else {
-			file, err = GetUnwrap(ctx, storage, path)
-		}
-	}
-	if file == nil {
-		if err != nil {
-			return nil, nil, errors.WithMessage(err, "failed to get file")
-		}
-		return nil, nil, errors.WithStack(errs.ObjectNotFound)
+	file, err := GetUnwrap(ctx, storage, path)
+	if err != nil {
+		return nil, nil, errors.WithMessage(err, "failed to get file")
 	}
+
 	if file.IsDir() {
 		return nil, nil, errors.WithStack(errs.NotFile)
 	}