mirror of
https://github.com/clinton-hall/nzbToMedia.git
synced 2025-08-21 05:43:16 -07:00
Added working version 2.2
Previous work was done over at couchpota.to and QNAP forums. This commit includes previous history in the helpfile.
This commit is contained in:
parent
023a199269
commit
26ac4b5353
4 changed files with 338 additions and 0 deletions
143
autoProcessMovie.py
Normal file
143
autoProcessMovie.py
Normal file
|
@ -0,0 +1,143 @@
|
|||
import sys
|
||||
import urllib
|
||||
import os.path
|
||||
import ConfigParser
|
||||
import time
|
||||
import json
|
||||
from pprint import pprint
|
||||
|
||||
class AuthURLOpener(urllib.FancyURLopener):
|
||||
def __init__(self, user, pw):
|
||||
self.username = user
|
||||
self.password = pw
|
||||
self.numTries = 0
|
||||
urllib.FancyURLopener.__init__(self)
|
||||
|
||||
def prompt_user_passwd(self, host, realm):
|
||||
if self.numTries == 0:
|
||||
self.numTries = 1
|
||||
return (self.username, self.password)
|
||||
else:
|
||||
return ('', '')
|
||||
|
||||
def openit(self, url):
|
||||
self.numTries = 0
|
||||
return urllib.FancyURLopener.open(self, url)
|
||||
|
||||
|
||||
def process(dirName, nzbName=None, status=0):
|
||||
|
||||
config = ConfigParser.ConfigParser()
|
||||
configFilename = os.path.join(os.path.dirname(sys.argv[0]), "autoProcessMovie.cfg")
|
||||
print "autoProcessMovie v 2.2"
|
||||
print "Loading config from", configFilename
|
||||
|
||||
if not os.path.isfile(configFilename):
|
||||
print "ERROR: You need an autoProcessMovie.cfg file - did you rename and edit the .sample?"
|
||||
sys.exit(-1)
|
||||
|
||||
config.read(configFilename)
|
||||
|
||||
host = config.get("CouchPotato", "host")
|
||||
port = config.get("CouchPotato", "port")
|
||||
username = config.get("CouchPotato", "username")
|
||||
password = config.get("CouchPotato", "password")
|
||||
apikey = config.get("CouchPotato", "apikey")
|
||||
delay = float(config.get("CouchPotato", "delay"))
|
||||
method = config.get("CouchPotato", "method")
|
||||
|
||||
try:
|
||||
ssl = int(config.get("CouchPotato", "ssl"))
|
||||
except (ConfigParser.NoOptionError, ValueError):
|
||||
ssl = 0
|
||||
|
||||
try:
|
||||
web_root = config.get("CouchPotato", "web_root")
|
||||
except ConfigParser.NoOptionError:
|
||||
web_root = ""
|
||||
|
||||
myOpener = AuthURLOpener(username, password)
|
||||
|
||||
nzbName1 = str(nzbName)
|
||||
|
||||
if ssl:
|
||||
protocol = "https://"
|
||||
else:
|
||||
protocol = "http://"
|
||||
if status == 0:
|
||||
if method == "manage":
|
||||
command = "manage.update"
|
||||
else:
|
||||
command = "renamer.scan"
|
||||
|
||||
url = protocol + host + ":" + port + web_root + "/api/" + apikey + "/" + command
|
||||
|
||||
print "waiting for", str(delay), "seconds to allow CPS to process newly extracted files"
|
||||
|
||||
time.sleep(delay)
|
||||
|
||||
print "Opening URL:", url
|
||||
|
||||
try:
|
||||
urlObj = myOpener.openit(url)
|
||||
except IOError, e:
|
||||
print "Unable to open URL: ", str(e)
|
||||
sys.exit(1)
|
||||
|
||||
result = urlObj.readlines()
|
||||
for line in result:
|
||||
print line
|
||||
|
||||
print command, "started on CouchPotatoServer for", nzbName1
|
||||
|
||||
else:
|
||||
print "download of", nzbName1, "has failed."
|
||||
print "trying to re-cue the next highest ranked release"
|
||||
a=nzbName1.find('.cp')+4
|
||||
b=nzbName1.find('.nzb')-1
|
||||
imdbid=nzbName1[a:b]
|
||||
#print imdbid
|
||||
|
||||
url = protocol + host + ":" + port + web_root + "/api/" + apikey + "/movie.list"
|
||||
|
||||
print "Opening URL:", url
|
||||
|
||||
try:
|
||||
urlObj = myOpener.openit(url)
|
||||
except IOError, e:
|
||||
print "Unable to open URL: ", str(e)
|
||||
sys.exit(1)
|
||||
|
||||
n=0
|
||||
result = json.load(urlObj)
|
||||
movieid = [item["id"] for item in result["movies"]]
|
||||
library = [item["library"] for item in result["movies"]]
|
||||
identifier = [item["identifier"] for item in library]
|
||||
for index in range(len(movieid)):
|
||||
if identifier[index] == imdbid:
|
||||
movid = str(movieid[index])
|
||||
print "found movie id", movid, "in database for release", nzbName1
|
||||
n = n + 1
|
||||
break
|
||||
|
||||
if n == 0:
|
||||
print "cound not find a mvie in the database for release", nzbName1
|
||||
print "please manually ignore this release and refresh the wanted movie"
|
||||
print "exiting postprocessing script"
|
||||
sys.exit(1)
|
||||
|
||||
url = protocol + host + ":" + port + web_root + "/api/" + apikey + "/searcher.try_next/?id=" + movid
|
||||
|
||||
print "Opening URL:", url
|
||||
|
||||
try:
|
||||
urlObj = myOpener.openit(url)
|
||||
except IOError, e:
|
||||
print "Unable to open URL: ", str(e)
|
||||
sys.exit(1)
|
||||
|
||||
result = urlObj.readlines()
|
||||
for line in result:
|
||||
print line
|
||||
|
||||
print "movie", movid, "set to try the next best release on CouchPotatoServer"
|
Loading…
Add table
Add a link
Reference in a new issue