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

minor improvements

Browse source
This commit is contained in:
Clinton Hall 2013-03-03 21:02:23 -08:00
commit 8be53264c8
1 changed files with 15 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

29
autoProcessMovie.py
View file

@ -76,7 +76,7 @@ def get_movie_info(myOpener, baseURL, imdbid):
for index in range(len(movieid)): for index in range(len(movieid)):
if library[index] == imdbid: if library[index] == imdbid:
movie_id = str(movieid[index]) movie_id = str(movieid[index])
Logger.info("found movie id %s in CPS database for movie %s", movie_id, imdbid) Logger.info("Found movie id %s in CPS database for movie %s", movie_id, imdbid)
break break
return movie_id return movie_id
@ -96,6 +96,7 @@ def get_status(myOpener, baseURL, movie_id):
result = json.load(urlObj) result = json.load(urlObj)
try: try:
movie_status = result["movie"]["status"]["identifier"] movie_status = result["movie"]["status"]["identifier"]
Logger.debug("This movie is marked as status %s in CouchPotatoServer", movie_status)
return movie_status return movie_status
except: except:
return "" return ""
@ -149,11 +150,8 @@ def process(dirName, nzbName=None, status=0):
baseURL = protocol + host + ":" + port + web_root + "/api/" + apikey + "/" baseURL = protocol + host + ":" + port + web_root + "/api/" + apikey + "/"
movie_id = get_movie_info(myOpener, baseURL, imdbid) # get the CPS database movie id this movie. movie_id = get_movie_info(myOpener, baseURL, imdbid) # get the CPS database movie id this movie.
if not movie_id:
initial_status = "" initial_status = get_status(myOpener, baseURL, movie_id)
else:
initial_status = get_status(myOpener, baseURL, movie_id)
Logger.debug("This movie is marked as status %s in CouchPotatoServer", initial_status)
process_all_exceptions(nzbName.lower(), dirName) process_all_exceptions(nzbName.lower(), dirName)
@ -165,7 +163,7 @@ def process(dirName, nzbName=None, status=0):
url = baseURL + command url = baseURL + command
Logger.info("waiting for %s seconds to allow CPS to process newly extracted files", str(delay)) Logger.info("Waiting for %s seconds to allow CPS to process newly extracted files", str(delay))
time.sleep(delay) time.sleep(delay)
@ -186,13 +184,13 @@ def process(dirName, nzbName=None, status=0):
return 1 # failure return 1 # failure
else: else:
Logger.info("download of %s has failed.", nzbName1) Logger.info("Download of %s has failed.", nzbName1)
Logger.info("trying to re-cue the next highest ranked release") Logger.info("Trying to re-cue the next highest ranked release")
if not movie_id: if not movie_id:
Logger.warning("cound not find a movie in the database for release %s", nzbName1) Logger.warning("Cound not find a movie in the database for release %s", nzbName1)
Logger.warning("please manually ignore this release and refresh the wanted movie") Logger.warning("Please manually ignore this release and refresh the wanted movie")
Logger.error("exiting postprocessing script") Logger.error("Exiting autoProcessMovie script")
return 1 # failure return 1 # failure
url = baseURL + "searcher.try_next/?id=" + movie_id url = baseURL + "searcher.try_next/?id=" + movie_id
@ -209,10 +207,13 @@ def process(dirName, nzbName=None, status=0):
for line in result: for line in result:
Logger.info("%s", line) Logger.info("%s", line)
Logger.info("movie %s set to try the next best release on CouchPotatoServer", movie_id) Logger.info("Movie %s set to try the next best release on CouchPotatoServer", movie_id)
if delete_failed: if delete_failed:
Logger.info("Deleting failed files and folder %s", dirName) Logger.info("Deleting failed files and folder %s", dirName)
shutil.rmtree(dirName) try:
shutil.rmtree(dirName)
except e:
Logger.error("Unable to delete folder %s due to: %s", dirName, str(e))
return 0 # success return 0 # success
if nzbName == "Manual Run": if nzbName == "Manual Run":