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

Hotfix

Browse Source
This commit is contained in:
Mukhtar Akere
2024-12-18 17:01:26 +01:00
parent abc86a0460
commit 88a7196eaf
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/qbit/server/import.go
View File

@@ -72,6 +72,9 @@ func (i *ImportRequest) Process(s *Server) (err error) {
torrent := q.CreateTorrentFromMagnet(magnet, i.Arr.Name) torrent := q.CreateTorrentFromMagnet(magnet, i.Arr.Name)
debridTorrent, err := debrid.ProcessTorrent(q.Debrid, magnet, i.Arr, i.IsSymlink) debridTorrent, err := debrid.ProcessTorrent(q.Debrid, magnet, i.Arr, i.IsSymlink)
if err != nil || debridTorrent == nil { if err != nil || debridTorrent == nil {
if debridTorrent != nil {
go debridTorrent.Delete()
}
if err == nil { if err == nil {
err = fmt.Errorf("failed to process torrent") err = fmt.Errorf("failed to process torrent")
} }
@@ -95,8 +98,11 @@ func (i *ImportRequest) BetaProcess(s *Server) (err error) {
} }
debridTorrent, err := debrid.ProcessTorrent(q.Debrid, magnet, i.Arr, true) debridTorrent, err := debrid.ProcessTorrent(q.Debrid, magnet, i.Arr, true)
if err != nil || debridTorrent == nil { if err != nil || debridTorrent == nil {
if debridTorrent != nil {
go debridTorrent.Delete()
}
if err == nil { if err == nil {
err = errors.New("failed to process torrent") err = fmt.Errorf("failed to process torrent")
} }
return err return err
} }