johno/decypharr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix Added bug in torrent

Browse Source
This commit is contained in:
Mukhtar Akere
2025-08-28 03:26:43 +01:00
parent d76ca032ab
commit aff12c2e4b
4 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/debrid/providers/alldebrid/alldebrid.go
View File

@@ -107,6 +107,7 @@ func (ad *AllDebrid) SubmitMagnet(torrent *types.Torrent) (*types.Torrent, error
magnet := magnets[0] magnet := magnets[0]
torrentId := strconv.Itoa(magnet.ID) torrentId := strconv.Itoa(magnet.ID)
torrent.Id = torrentId torrent.Id = torrentId
torrent.Added = time.Now().Format(time.RFC3339)
return torrent, nil return torrent, nil
} }

4
pkg/debrid/providers/realdebrid/realdebrid.go
View File

@@ -372,6 +372,7 @@ func (r *RealDebrid) addTorrent(t *types.Torrent) (*types.Torrent, error) {
t.Id = data.Id t.Id = data.Id
t.Debrid = r.name t.Debrid = r.name
t.MountPath = r.MountPath t.MountPath = r.MountPath
t.Added = time.Now().Format(time.RFC3339)
return t, nil return t, nil
} }
@@ -407,6 +408,7 @@ func (r *RealDebrid) addMagnet(t *types.Torrent) (*types.Torrent, error) {
t.Id = data.Id t.Id = data.Id
t.Debrid = r.name t.Debrid = r.name
t.MountPath = r.MountPath t.MountPath = r.MountPath
t.Added = time.Now().Format(time.RFC3339)
return t, nil return t, nil
} }
@@ -488,7 +490,6 @@ func (r *RealDebrid) UpdateTorrent(t *types.Torrent) error {
t.Links = data.Links t.Links = data.Links
t.MountPath = r.MountPath t.MountPath = r.MountPath
t.Debrid = r.name t.Debrid = r.name
t.Added = data.Added
t.Files, _ = r.getSelectedFiles(t, data) // Get selected files t.Files, _ = r.getSelectedFiles(t, data) // Get selected files
return nil return nil
@@ -520,6 +521,7 @@ func (r *RealDebrid) CheckStatus(t *types.Torrent) (*types.Torrent, error) {
t.Status = status t.Status = status
t.Debrid = r.name t.Debrid = r.name
t.MountPath = r.MountPath t.MountPath = r.MountPath
t.Added = data.Added
if status == "waiting_files_selection" { if status == "waiting_files_selection" {
t.Files = r.getTorrentFiles(t, data) t.Files = r.getTorrentFiles(t, data)
if len(t.Files) == 0 { if len(t.Files) == 0 {

1
pkg/debrid/providers/torbox/torbox.go
View File

@@ -161,6 +161,7 @@ func (tb *Torbox) SubmitMagnet(torrent *types.Torrent) (*types.Torrent, error) {
torrent.Id = torrentId torrent.Id = torrentId
torrent.MountPath = tb.MountPath torrent.MountPath = tb.MountPath
torrent.Debrid = tb.name torrent.Debrid = tb.name
torrent.Added = time.Now().Format(time.RFC3339)
return torrent, nil return torrent, nil
} }

4
pkg/debrid/store/repair.go
View File

@@ -262,7 +262,7 @@ func (c *Cache) reInsertTorrent(ct *CachedTorrent) (*CachedTorrent, error) {
_ = c.client.DeleteTorrent(newTorrent.Id) _ = c.client.DeleteTorrent(newTorrent.Id)
} }
c.markAsFailedToReinsert(oldID) c.markAsFailedToReinsert(oldID)
return ct, err return ct, fmt.Errorf("failed to check torrent: %w", err)
} }
// Update the torrent in the cache // Update the torrent in the cache
@@ -295,7 +295,7 @@ func (c *Cache) reInsertTorrent(ct *CachedTorrent) (*CachedTorrent, error) {
} }
} }
req.Complete(ct, err) req.Complete(ct, nil)
c.markAsSuccessfullyReinserted(oldID) c.markAsSuccessfullyReinserted(oldID)
c.logger.Debug().Str("torrentId", torrent.Id).Msg("Torrent successfully reinserted") c.logger.Debug().Str("torrentId", torrent.Id).Msg("Torrent successfully reinserted")