hpz937/zurg
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix api client

Browse Source
This commit is contained in:
Ben Sarmiento
2024-05-28 07:22:33 +02:00
parent 7470629486
commit d8b0bfc9f4
4 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
internal/app.go
View File

@@ -52,9 +52,9 @@ func MainApp(configPath string) {
apiClient := http.NewHTTPClient( apiClient := http.NewHTTPClient(
config.GetToken(), config.GetToken(),
config.GetRetriesUntilFailed()*2, // default retries = 2, so this is 4 config.GetRetriesUntilFailed(), // default retries = 2, so this is 4
config.GetApiTimeoutSecs(), // default api timeout = 60 config.GetApiTimeoutSecs(), // default api timeout = 60
false, // ipv6 support is not needed for api client false, // ipv6 support is not needed for api client
config, config,
log.Named("api_client"), log.Named("api_client"),
) )

2
internal/torrent/repair.go
View File

@@ -503,7 +503,7 @@ func (t *TorrentManager) canCapacityHandle() bool {
} }
func (t *TorrentManager) markAsUnplayable(torrent *Torrent, reason string) { func (t *TorrentManager) markAsUnplayable(torrent *Torrent, reason string) {
t.repairLog.Warnf("Torrent %s is unplayable (reason: %s), moving to unplayable directory", t.GetKey(torrent), reason) t.repairLog.Debugf("Torrent %s is unplayable (reason: %s), moving to unplayable directory", t.GetKey(torrent), reason)
// reassign to unplayable torrents directory // reassign to unplayable torrents directory
t.DirectoryMap.IterCb(func(directory string, torrents cmap.ConcurrentMap[string, *Torrent]) { t.DirectoryMap.IterCb(func(directory string, torrents cmap.ConcurrentMap[string, *Torrent]) {
if strings.HasPrefix(directory, "int__") { if strings.HasPrefix(directory, "int__") {

2
pkg/http/client.go
View File

@@ -60,7 +60,7 @@ func NewHTTPClient(
) *HTTPClient { ) *HTTPClient {
client := HTTPClient{ client := HTTPClient{
bearerToken: token, bearerToken: token,
client: http.DefaultClient, client: &http.Client{},
maxRetries: maxRetries, maxRetries: maxRetries,
timeoutSecs: timeoutSecs, timeoutSecs: timeoutSecs,
backoff: backoffFunc, backoff: backoffFunc,

4
pkg/realdebrid/api.go
View File

@@ -175,7 +175,7 @@ func (rd *RealDebrid) GetTorrents(onlyOne bool) ([]Torrent, int, error) {
// compute ceiling of totalCount / limit // compute ceiling of totalCount / limit
maxPages := (totalCount + rd.cfg.GetTorrentsCount() - 1) / rd.cfg.GetTorrentsCount() maxPages := (totalCount + rd.cfg.GetTorrentsCount() - 1) / rd.cfg.GetTorrentsCount()
rd.log.Debugf("Torrents total count is %d, max pages is %d", totalCount, maxPages) rd.log.Debugf("Torrents total count is %d, max pages is %d", totalCount, maxPages)
maxParallelThreads := 2 maxParallelThreads := 4
if maxPages < maxParallelThreads { if maxPages < maxParallelThreads {
maxParallelThreads = maxPages maxParallelThreads = maxPages
} }
@@ -194,7 +194,7 @@ func (rd *RealDebrid) GetTorrents(onlyOne bool) ([]Torrent, int, error) {
for i := 0; i < maxParallelThreads; i++ { for i := 0; i < maxParallelThreads; i++ {
res := <-allResults res := <-allResults
if res.err != nil { if res.err != nil {
return nil, 0, res.err continue
} }
allTorrents = append(allTorrents, res.torrents...) allTorrents = append(allTorrents, res.torrents...)
} }