skong
/
synctv
mirror of https://github.com/synctv-org/synctv.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chore: vendor client

This commit is contained in:
zijiren233 2024-09-12 20:46:45 +08:00
parent f08c1360bd
commit b960454bc9
3 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
server/handlers/vendors/vendorAlist/alist.go vendored
View File

@ -39,6 +39,10 @@ func NewAlistVendorService(room *op.Room, movie *op.Movie) (*alistVendorService,
}, nil
}
func (s *alistVendorService) Client() alist.AlistHTTPServer {
return vendor.LoadAlistClient(s.movie.VendorInfo.Backend)
}
func (s *alistVendorService) ListDynamicMovie(ctx context.Context, reqUser *op.User, subPath string, page, max int) (*model.MoviesResp, error) {
if reqUser.ID != s.movie.CreatorID {
return nil, fmt.Errorf("list vendor dynamic folder error: %w", dbModel.ErrNoPermission)
@ -67,8 +71,7 @@ func (s *alistVendorService) ListDynamicMovie(ctx context.Context, reqUser *op.U
}
return nil, err
}
var cli = vendor.LoadAlistClient(s.movie.VendorInfo.Backend)
data, err := cli.FsList(ctx, &alist.FsListReq{
data, err := s.Client().FsList(ctx, &alist.FsListReq{
Token: aucd.Token,
Password: s.movie.VendorInfo.Alist.Password,
Path: truePath,
@ -261,7 +264,6 @@ func (s *alistVendorService) GenMovieInfo(ctx context.Context, user *op.User, us
}
func (s *alistVendorService) GenProxyMovieInfo(ctx context.Context, user *op.User, userAgent, userToken string) (*dbModel.Movie, error) {
movie := s.movie.Clone()
var err error

6
server/handlers/vendors/vendorBilibili/bilibili.go vendored
View File

@ -13,9 +13,11 @@ import (
"github.com/synctv-org/synctv/internal/cache"
dbModel "github.com/synctv-org/synctv/internal/model"
"github.com/synctv-org/synctv/internal/op"
"github.com/synctv-org/synctv/internal/vendor"
"github.com/synctv-org/synctv/server/model"
"github.com/synctv-org/synctv/utils"
"github.com/synctv-org/synctv/utils/proxy"
"github.com/synctv-org/vendors/api/bilibili"
"github.com/zijiren233/stream"
"golang.org/x/exp/maps"
)
@ -35,6 +37,10 @@ func NewBilibiliVendorService(room *op.Room, movie *op.Movie) (*bilibiliVendorSe
}, nil
}
func (s *bilibiliVendorService) Client() bilibili.BilibiliHTTPServer {
return vendor.LoadBilibiliClient(s.movie.VendorInfo.Backend)
}
func (s *bilibiliVendorService) ListDynamicMovie(ctx context.Context, reqUser *op.User, subPath string, page, max int) (*model.MoviesResp, error) {
return nil, fmt.Errorf("bilibili vendor not support list dynamic movie")
}

7
server/handlers/vendors/vendorEmby/emby.go vendored
View File

@ -37,6 +37,10 @@ func NewEmbyVendorService(room *op.Room, movie *op.Movie) (*embyVendorService, e
}, nil
}
func (s *embyVendorService) Client() emby.EmbyHTTPServer {
return vendor.LoadEmbyClient(s.movie.VendorInfo.Backend)
}
func (s *embyVendorService) ListDynamicMovie(ctx context.Context, reqUser *op.User, subPath string, page, max int) (*model.MoviesResp, error) {
if reqUser.ID != s.movie.CreatorID {
return nil, fmt.Errorf("list vendor dynamic folder error: %w", dbModel.ErrNoPermission)
@ -62,8 +66,7 @@ func (s *embyVendorService) ListDynamicMovie(ctx context.Context, reqUser *op.Us
}
return nil, err
}
var cli = vendor.LoadEmbyClient(s.movie.VendorInfo.Backend)
data, err := cli.FsList(ctx, &emby.FsListReq{
data, err := s.Client().FsList(ctx, &emby.FsListReq{
Host: aucd.Host,
Path: truePath,
Token: aucd.ApiKey,