MCPcopy Create free account
hub / github.com/Unpackerr/unpackerr / deleteAfterReached

Method deleteAfterReached

pkg/unpackerr/folder.go:596–618  ·  view source on GitHub ↗

nolint:wsl

(name string, now time.Time, folder *Folder)

Source from the content-addressed store, hash-verified

594
595//nolint:wsl
596func (u *Unpackerr) deleteAfterReached(name string, now time.Time, folder *Folder) {
597 var webhook bool
598 // Folder reached delete delay (after extraction), nuke it.
599 if folder.config.DeleteFiles && !folder.config.MoveBack {
600 u.delChan <- &fileDeleteReq{Paths: []string{strings.TrimRight(name, `/\`) + suffix}}
601 webhook = true
602 } else if folder.config.DeleteFiles && len(folder.files) > 0 {
603 u.delChan <- &fileDeleteReq{Paths: folder.files}
604 webhook = true
605 }
606
607 if folder.config.DeleteOrig && !folder.config.MoveBack {
608 u.delChan <- &fileDeleteReq{Paths: []string{name}}
609 webhook = true
610 } else if folder.config.DeleteOrig && len(folder.archives) > 0 {
611 u.delChan <- &fileDeleteReq{Paths: folder.archives.List()}
612 webhook = true
613 }
614
615 u.updateQueueStatus(&newStatus{Name: name, Status: DELETED, Resp: nil}, now, webhook)
616 // Folder reached delete delay (after extraction), nuke it.
617 delete(u.folders.Folders, name)
618}
619
620type newStatus struct {
621 Name string

Callers 1

checkFolderStatsMethod · 0.95

Calls 1

updateQueueStatusMethod · 0.95

Tested by

no test coverage detected