Function GetDirectUploadInfo

internal/op/fs.go:782–815

(ctx context.Context, tool string, storage driver.Driver, dstDirPath, dstName string, fileSize int64, overwrite bool)

}

func GetDirectUploadInfo(ctx context.Context, tool string, storage driver.Driver, dstDirPath, dstName string, fileSize int64, overwrite bool) (any, error) {
	du, ok := storage.(driver.DirectUploader)
	if !ok {
		return nil, errors.WithStack(errs.NotImplement)
	}
	if storage.Config().CheckStatus && storage.GetStorage().Status != WORK {
		return nil, errors.WithMessagef(errs.StorageNotInit, "storage status: %s", storage.GetStorage().Status)
	}
	dstDirPath = utils.FixAndCleanPath(dstDirPath)
	dstPath := stdpath.Join(dstDirPath, dstName)
	var err error
	if !overwrite {
		_, err = Get(ctx, storage, dstPath)
		if err == nil {
			return nil, errors.WithStack(errs.ObjectAlreadyExists)
		}
		if !errs.IsObjectNotFound(err) {
			return nil, errors.WithMessage(err, "failed to check if object exists")
		}
	}
	err = MakeDir(ctx, storage, dstDirPath)
	if err != nil {
		return nil, errors.WithMessagef(err, "failed to make dir [%s]", dstDirPath)
	}
	dstDir, err := GetUnwrap(ctx, storage, dstDirPath)
	if err != nil {
		return nil, errors.WithMessagef(err, "failed to get dir [%s]", dstDirPath)
	}
	info, err := du.GetDirectUploadInfo(ctx, tool, dstDir, dstName, fileSize)
	if err != nil {
		return nil, errors.WithStack(err)
	}
	return info, nil
}

func objsUpdateHook(ctx context.Context, storage driver.Driver, dirPath string, recursive bool) {
	files, err := List(ctx, storage, dirPath, model.ListArgs{SkipHook: true})