Function buildFSGetRawURL

server/mcp/fs_get.go:116–154

(ctx context.Context, c *gin.Context, reqPath string, obj model.Obj, meta *model.Meta)

}

func buildFSGetRawURL(ctx context.Context, c *gin.Context, reqPath string, obj model.Obj, meta *model.Meta) (string, string, error) {
	storage, storageErr := fs.GetStorage(reqPath, &fs.GetStoragesArgs{})
	provider, ok := model.GetProvider(obj)
	if !ok && storageErr == nil {
		provider = storage.Config().Name
	}
	if obj.IsDir() {
		return "", provider, nil
	}
	if storageErr != nil {
		return "", provider, storageErr
	}

	if storage.Config().MustProxy() || storage.GetStorage().WebProxy {
		rawURL := common.GenerateDownProxyURL(storage.GetStorage(), reqPath)
		if rawURL != "" {
			return rawURL, provider, nil
		}
		query := ""
		if isEncrypt(meta, reqPath) || setting.GetBool(conf.SignAll) {
			query = "?sign=" + sign.Sign(reqPath)
		}
		return fmt.Sprintf("%s/p%s%s", common.GetApiUrl(ctx), utils.EncodePath(reqPath, true), query), provider, nil
	}

	if url, ok := model.GetUrl(obj); ok {
		return url, provider, nil
	}
	link, _, err := fs.Link(ctx, reqPath, model.LinkArgs{
		IP:       c.ClientIP(),
		Header:   c.Request.Header,
		Redirect: true,
	})
	if err != nil {
		return "", provider, err
	}
	defer link.Close()
	return link.URL, provider, nil
}

func filterRelatedObjs(objs []model.Obj, obj model.Obj) []model.Obj {
	related := make([]model.Obj, 0)