github/nzbToMedia
1
0
Fork 0
mirror of https://github.com/clinton-hall/nzbToMedia.git synced 2025-08-19 21:03:14 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

format and context fixes

Browse source
This commit is contained in:
clinton-hall 2014-04-09 12:38:56 +09:30
commit 4104aa91cd
1 changed files with 14 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

28
TorrentToMedia.py
View file

@ -257,7 +257,8 @@ def main(inputDirectory, inputName, inputCategory, inputHash, inputID):
cleanup_output(inputCategory, processCategories, result, outputDestination) cleanup_output(inputCategory, processCategories, result, outputDestination)
Logger.info("MAIN: All done.") Logger.info("MAIN: All done.")
def create_torrent_class(clientAgent, inputHash) # Hardlink solution for Torrents def create_torrent_class(clientAgent, inputHash):
# Hardlink solution for Torrents
TorrentClass = "" TorrentClass = ""
if clientAgent in ['utorrent', 'transmission', 'deluge'] and inputHash: if clientAgent in ['utorrent', 'transmission', 'deluge'] and inputHash:
if clientAgent == 'utorrent': if clientAgent == 'utorrent':
@ -284,19 +285,18 @@ def create_torrent_class(clientAgent, inputHash) # Hardlink solution for Torr
return TorrentClass return TorrentClass
def pause_torrent(clientAgent, TorrentClass, inputHash, inputID, inputName) def pause_torrent(clientAgent, TorrentClass, inputHash, inputID, inputName):
# if we are using links with Torrents it means we need to pause it in order to access the files # if we are using links with Torrents it means we need to pause it in order to access the files
Logger.debug("MAIN: Stoping torrent %s in %s while processing", inputName, clientAgent) Logger.debug("MAIN: Stoping torrent %s in %s while processing", inputName, clientAgent)
if clientAgent == 'utorrent' and TorrentClass != "": if clientAgent == 'utorrent' and TorrentClass != "":
TorrentClass.stop(inputHash) TorrentClass.stop(inputHash)
if clientAgent == 'transmission' and TorrentClass !="": if clientAgent == 'transmission' and TorrentClass !="":
TorrentClass.stop_torrent(inputID) TorrentClass.stop_torrent(inputID)
if clientAgent == 'deluge' and TorrentClass != "": if clientAgent == 'deluge' and TorrentClass != "":
TorrentClass.core.pause_torrent([inputID]) TorrentClass.core.pause_torrent([inputID])
time.sleep(5) # Give Torrent client some time to catch up with the change time.sleep(5) # Give Torrent client some time to catch up with the change
def resume_torrent(clientAgent, TorrentClass, inputHash, inputID, result, inputName)
def resume_torrent(clientAgent, TorrentClass, inputHash, inputID, result, inputName):
# Hardlink solution for uTorrent, need to implent support for deluge, transmission # Hardlink solution for uTorrent, need to implent support for deluge, transmission
if clientAgent in ['utorrent', 'transmission', 'deluge'] and inputHash: if clientAgent in ['utorrent', 'transmission', 'deluge'] and inputHash:
# Delete torrent and torrentdata from Torrent client if processing was successful. # Delete torrent and torrentdata from Torrent client if processing was successful.
@ -320,7 +320,7 @@ def resume_torrent(clientAgent, TorrentClass, inputHash, inputID, result, inputN
TorrentClass.core.resume_torrent([inputID]) TorrentClass.core.resume_torrent([inputID])
time.sleep(5) time.sleep(5)
def cleanup_output(inputCategory, processCategories, result, outputDestination) def cleanup_output(inputCategory, processCategories, result, outputDestination):
if inputCategory in processCategories and result == 0 and os.path.isdir(outputDestination): if inputCategory in processCategories and result == 0 and os.path.isdir(outputDestination):
num_files_new = int(0) num_files_new = int(0)
file_list = [] file_list = []