mirror of
https://github.com/clinton-hall/nzbToMedia.git
synced 2025-08-19 21:03:14 -07:00
Fixing imports
This commit is contained in:
parent
3fdc575865
commit
b6ac6ca16b
2 changed files with 45 additions and 43 deletions
|
@ -8,14 +8,6 @@ import nzbtomedia
|
||||||
import platform
|
import platform
|
||||||
|
|
||||||
from subprocess import Popen
|
from subprocess import Popen
|
||||||
from nzbtomedia.autoProcess.autoProcessComics import autoProcessComics
|
|
||||||
from nzbtomedia.autoProcess.autoProcessGames import autoProcessGames
|
|
||||||
from nzbtomedia.autoProcess.autoProcessMovie import autoProcessMovie
|
|
||||||
from nzbtomedia.autoProcess.autoProcessMusic import autoProcessMusic
|
|
||||||
from nzbtomedia.autoProcess.autoProcessTV import autoProcessTV
|
|
||||||
from nzbtomedia.nzbToMediaUtil import category_search, sanitizeFileName, copy_link, parse_args, flatten, get_dirnames, \
|
|
||||||
remove_read_only, pause_torrent, resume_torrent, listMediaFiles, joinPath, \
|
|
||||||
extractFiles, cleanProcDirs, update_downloadInfoStatus, get_downloadInfo
|
|
||||||
from nzbtomedia import logger, nzbToMediaDB
|
from nzbtomedia import logger, nzbToMediaDB
|
||||||
|
|
||||||
def processTorrent(inputDirectory, inputName, inputCategory, inputHash, inputID, clientAgent):
|
def processTorrent(inputDirectory, inputName, inputCategory, inputHash, inputID, clientAgent):
|
||||||
|
@ -42,7 +34,7 @@ def processTorrent(inputDirectory, inputName, inputCategory, inputHash, inputID,
|
||||||
|
|
||||||
logger.debug("Received Directory: %s | Name: %s | Category: %s" % (inputDirectory, inputName, inputCategory))
|
logger.debug("Received Directory: %s | Name: %s | Category: %s" % (inputDirectory, inputName, inputCategory))
|
||||||
|
|
||||||
inputDirectory, inputName, inputCategory, root, single = category_search(inputDirectory, inputName, inputCategory, root, nzbtomedia.CATEGORIES) # Confirm the category by parsing directory structure
|
inputDirectory, inputName, inputCategory, root, single = nzbtomedia.category_search(inputDirectory, inputName, inputCategory, root, nzbtomedia.CATEGORIES) # Confirm the category by parsing directory structure
|
||||||
|
|
||||||
logger.debug("Determined Directory: %s | Name: %s | Category: %s" % (inputDirectory, inputName, inputCategory))
|
logger.debug("Determined Directory: %s | Name: %s | Category: %s" % (inputDirectory, inputName, inputCategory))
|
||||||
|
|
||||||
|
@ -57,13 +49,13 @@ def processTorrent(inputDirectory, inputName, inputCategory, inputHash, inputID,
|
||||||
except:Torrent_NoLink = 0
|
except:Torrent_NoLink = 0
|
||||||
|
|
||||||
if clientAgent != 'manual':
|
if clientAgent != 'manual':
|
||||||
pause_torrent(clientAgent, inputHash, inputID, inputName)
|
nzbtomedia.pause_torrent(clientAgent, inputHash, inputID, inputName)
|
||||||
|
|
||||||
processCategories = nzbtomedia.CFG[nzbtomedia.SECTIONS].sections
|
processCategories = nzbtomedia.CFG[nzbtomedia.SECTIONS].sections
|
||||||
|
|
||||||
if inputCategory == "":
|
if inputCategory == "":
|
||||||
inputCategory = "UNCAT"
|
inputCategory = "UNCAT"
|
||||||
outputDestination = os.path.normpath(joinPath(nzbtomedia.OUTPUTDIRECTORY, inputCategory, sanitizeFileName(inputName)))
|
outputDestination = os.path.normpath(nzbtomedia.joinPath(nzbtomedia. OUTPUTDIRECTORY, inputCategory, nzbtomedia.sanitizeFileName(inputName)))
|
||||||
|
|
||||||
logger.info("Output directory set to: %s" % (outputDestination))
|
logger.info("Output directory set to: %s" % (outputDestination))
|
||||||
|
|
||||||
|
@ -85,7 +77,7 @@ def processTorrent(inputDirectory, inputName, inputCategory, inputHash, inputID,
|
||||||
outputDestinationMaster = outputDestination # Save the original, so we can change this within the loop below, and reset afterwards.
|
outputDestinationMaster = outputDestination # Save the original, so we can change this within the loop below, and reset afterwards.
|
||||||
now = datetime.datetime.now()
|
now = datetime.datetime.now()
|
||||||
|
|
||||||
inputFiles = listMediaFiles(inputDirectory)
|
inputFiles = nzbtomedia.listMediaFiles(inputDirectory)
|
||||||
logger.debug("Found %s files in %s" % (str(len(inputFiles)), inputDirectory))
|
logger.debug("Found %s files in %s" % (str(len(inputFiles)), inputDirectory))
|
||||||
for inputFile in inputFiles:
|
for inputFile in inputFiles:
|
||||||
fileDirPath = os.path.dirname(inputFile)
|
fileDirPath = os.path.dirname(inputFile)
|
||||||
|
@ -94,15 +86,15 @@ def processTorrent(inputDirectory, inputName, inputCategory, inputHash, inputID,
|
||||||
|
|
||||||
if inputCategory in nzbtomedia.NOFLATTEN:
|
if inputCategory in nzbtomedia.NOFLATTEN:
|
||||||
if not fileDirPath == outputDestinationMaster:
|
if not fileDirPath == outputDestinationMaster:
|
||||||
outputDestination = joinPath(outputDestinationMaster, fileDirPath) # join this extra directory to output.
|
outputDestination = nzbtomedia.joinPath(outputDestinationMaster, fileDirPath) # join this extra directory to output.
|
||||||
logger.debug("Setting outputDestination to %s to preserve folder structure" % (outputDestination))
|
logger.debug("Setting outputDestination to %s to preserve folder structure" % (outputDestination))
|
||||||
|
|
||||||
targetDirectory = joinPath(outputDestination, fullFileName)
|
targetDirectory = nzbtomedia.joinPath(outputDestination, fullFileName)
|
||||||
|
|
||||||
if root == 1:
|
if root == 1:
|
||||||
if not foundFile:
|
if not foundFile:
|
||||||
logger.debug("Looking for %s in: %s" % (inputName, fullFileName))
|
logger.debug("Looking for %s in: %s" % (inputName, fullFileName))
|
||||||
if (sanitizeFileName(inputName) in sanitizeFileName(fullFileName)) or (sanitizeFileName(fileName) in sanitizeFileName(inputName)):
|
if (nzbtomedia.sanitizeFileName(inputName) in nzbtomedia.sanitizeFileName(fullFileName)) or (nzbtomedia.sanitizeFileName(fileName) in nzbtomedia.sanitizeFileName(inputName)):
|
||||||
foundFile = True
|
foundFile = True
|
||||||
logger.debug("Found file %s that matches Torrent Name %s" % (fullFileName, inputName))
|
logger.debug("Found file %s that matches Torrent Name %s" % (fullFileName, inputName))
|
||||||
else:
|
else:
|
||||||
|
@ -123,26 +115,26 @@ def processTorrent(inputDirectory, inputName, inputCategory, inputHash, inputID,
|
||||||
|
|
||||||
if Torrent_NoLink == 0:
|
if Torrent_NoLink == 0:
|
||||||
try:
|
try:
|
||||||
copy_link(inputFile, targetDirectory, nzbtomedia.USELINK, outputDestination)
|
nzbtomedia.copy_link(inputFile, targetDirectory, nzbtomedia.USELINK, outputDestination)
|
||||||
copy_list.append([inputFile, joinPath(outputDestination, fullFileName)])
|
copy_list.append([inputFile, nzbtomedia.joinPath(outputDestination, fullFileName)])
|
||||||
except:
|
except:
|
||||||
logger.error("Failed to link file: %s" % (fullFileName))
|
logger.error("Failed to link file: %s" % (fullFileName))
|
||||||
|
|
||||||
outputDestination = outputDestinationMaster # Reset here.
|
outputDestination = outputDestinationMaster # Reset here.
|
||||||
|
|
||||||
if not inputCategory in nzbtomedia.NOFLATTEN: #don't flatten hp in case multi cd albums, and we need to copy this back later.
|
if not inputCategory in nzbtomedia.NOFLATTEN: #don't flatten hp in case multi cd albums, and we need to copy this back later.
|
||||||
flatten(outputDestination)
|
nzbtomedia.flatten(outputDestination)
|
||||||
|
|
||||||
if platform.system() == 'Windows': # remove Read Only flag from files in Windows.
|
if platform.system() == 'Windows': # remove Read Only flag from files in Windows.
|
||||||
remove_read_only(outputDestination)
|
nzbtomedia.remove_read_only(outputDestination)
|
||||||
|
|
||||||
if nzbtomedia.CFG[section][inputCategory]['extract']:
|
if nzbtomedia.CFG[section][inputCategory]['extract']:
|
||||||
logger.debug('Checking for archives to extract in directory: %s' % (outputDestination))
|
logger.debug('Checking for archives to extract in directory: %s' % (outputDestination))
|
||||||
extractFiles(outputDestination)
|
nzbtomedia.extractFiles(outputDestination)
|
||||||
|
|
||||||
# Now check if video files exist in destination:
|
# Now check if video files exist in destination:
|
||||||
if nzbtomedia.CFG["SickBeard","NzbDrone", "CouchPotato"][inputCategory]:
|
if nzbtomedia.CFG["SickBeard","NzbDrone", "CouchPotato"][inputCategory]:
|
||||||
for outputFile in listMediaFiles(outputDestination):
|
for outputFile in nzbtomedia.listMediaFiles(outputDestination):
|
||||||
fullFileName = os.path.basename(outputFile)
|
fullFileName = os.path.basename(outputFile)
|
||||||
fileName, fileExt = os.path.splitext(fullFileName)
|
fileName, fileExt = os.path.splitext(fullFileName)
|
||||||
|
|
||||||
|
@ -172,35 +164,35 @@ def processTorrent(inputDirectory, inputName, inputCategory, inputHash, inputID,
|
||||||
|
|
||||||
if nzbtomedia.CFG['CouchPotato'][inputCategory]:
|
if nzbtomedia.CFG['CouchPotato'][inputCategory]:
|
||||||
logger.info("Calling CouchPotato:" + inputCategory + " to post-process: %s" % (inputName))
|
logger.info("Calling CouchPotato:" + inputCategory + " to post-process: %s" % (inputName))
|
||||||
result = autoProcessMovie().process(outputDestination, inputName, status, clientAgent, inputHash, inputCategory)
|
result = nzbtomedia.autoProcessMovie().process(outputDestination, inputName, status, clientAgent, inputHash, inputCategory)
|
||||||
elif nzbtomedia.CFG['SickBeard'][inputCategory]:
|
elif nzbtomedia.CFG['SickBeard'][inputCategory]:
|
||||||
logger.info("Calling Sick-Beard:" + inputCategory + " to post-process: %s" % (inputName))
|
logger.info("Calling Sick-Beard:" + inputCategory + " to post-process: %s" % (inputName))
|
||||||
result = autoProcessTV().processEpisode(outputDestination, inputName, status, clientAgent, inputCategory)
|
result = nzbtomedia.autoProcessTV().processEpisode(outputDestination, inputName, status, clientAgent, inputCategory)
|
||||||
elif nzbtomedia.CFG['NzbDrone'][inputCategory]:
|
elif nzbtomedia.CFG['NzbDrone'][inputCategory]:
|
||||||
logger.info("Calling NzbDrone:" + inputCategory + " to post-process: %s" % (inputName))
|
logger.info("Calling NzbDrone:" + inputCategory + " to post-process: %s" % (inputName))
|
||||||
result = autoProcessTV().processEpisode(outputDestination, inputName, status, clientAgent, inputCategory)
|
result = nzbtomedia.autoProcessTV().processEpisode(outputDestination, inputName, status, clientAgent, inputCategory)
|
||||||
elif nzbtomedia.CFG['HeadPhones'][inputCategory]:
|
elif nzbtomedia.CFG['HeadPhones'][inputCategory]:
|
||||||
status = 0 #Failed Handling Not Supported
|
status = 0 #Failed Handling Not Supported
|
||||||
logger.info("Calling HeadPhones:" + inputCategory + " to post-process: %s" % (inputName))
|
logger.info("Calling HeadPhones:" + inputCategory + " to post-process: %s" % (inputName))
|
||||||
result = autoProcessMusic().process(outputDestination, inputName, status, clientAgent, inputCategory)
|
result = nzbtomedia.autoProcessMusic().process(outputDestination, inputName, status, clientAgent, inputCategory)
|
||||||
elif nzbtomedia.CFG['Mylar'][inputCategory]:
|
elif nzbtomedia.CFG['Mylar'][inputCategory]:
|
||||||
status = 0 #Failed Handling Not Supported
|
status = 0 #Failed Handling Not Supported
|
||||||
logger.info("Calling Mylar:" + inputCategory + " to post-process: %s" % (inputName))
|
logger.info("Calling Mylar:" + inputCategory + " to post-process: %s" % (inputName))
|
||||||
result = autoProcessComics().processEpisode(outputDestination, inputName, status, clientAgent, inputCategory)
|
result = nzbtomedia.autoProcessComics().processEpisode(outputDestination, inputName, status, clientAgent, inputCategory)
|
||||||
elif nzbtomedia.CFG['Gamez'][inputCategory]:
|
elif nzbtomedia.CFG['Gamez'][inputCategory]:
|
||||||
status = 0 #Failed Handling Not Supported
|
status = 0 #Failed Handling Not Supported
|
||||||
logger.info("Calling Gamez:" + inputCategory + " to post-process: %s" % (inputName))
|
logger.info("Calling Gamez:" + inputCategory + " to post-process: %s" % (inputName))
|
||||||
result = autoProcessGames().process(outputDestination, inputName, status, clientAgent, inputCategory)
|
result = nzbtomedia.autoProcessGames().process(outputDestination, inputName, status, clientAgent, inputCategory)
|
||||||
|
|
||||||
if result != 0 and clientAgent != 'manual':
|
if result != 0 and clientAgent != 'manual':
|
||||||
logger.error("A problem was reported in the autoProcess* script. If torrent was paused we will resume seeding")
|
logger.error("A problem was reported in the autoProcess* script. If torrent was paused we will resume seeding")
|
||||||
resume_torrent(clientAgent, inputHash, inputID, result, inputName)
|
nzbtomedia.resume_torrent(clientAgent, inputHash, inputID, result, inputName)
|
||||||
else:
|
else:
|
||||||
# update download status in our DB
|
# update download status in our DB
|
||||||
update_downloadInfoStatus(inputName, 1)
|
nzbtomedia.update_downloadInfoStatus(inputName, 1)
|
||||||
|
|
||||||
# cleanup our processing folders of any misc unwanted files and empty directories
|
# cleanup our processing folders of any misc unwanted files and empty directories
|
||||||
cleanProcDirs()
|
nzbtomedia.cleanProcDirs()
|
||||||
|
|
||||||
return result
|
return result
|
||||||
|
|
||||||
|
@ -211,7 +203,7 @@ def external_script(outputDestination, torrentName, torrentLabel):
|
||||||
for dirpath, dirnames, filenames in os.walk(outputDestination):
|
for dirpath, dirnames, filenames in os.walk(outputDestination):
|
||||||
for file in filenames:
|
for file in filenames:
|
||||||
|
|
||||||
filePath = joinPath(dirpath, file)
|
filePath = nzbtomedia.joinPath(dirpath, file)
|
||||||
fileName, fileExtension = os.path.splitext(file)
|
fileName, fileExtension = os.path.splitext(file)
|
||||||
|
|
||||||
if fileExtension in nzbtomedia.USER_SCRIPT_MEDIAEXTENSIONS or "ALL" in nzbtomedia.USER_SCRIPT_MEDIAEXTENSIONS:
|
if fileExtension in nzbtomedia.USER_SCRIPT_MEDIAEXTENSIONS or "ALL" in nzbtomedia.USER_SCRIPT_MEDIAEXTENSIONS:
|
||||||
|
@ -264,7 +256,7 @@ def external_script(outputDestination, torrentName, torrentLabel):
|
||||||
num_files_new = 0
|
num_files_new = 0
|
||||||
for dirpath, dirnames, filenames in os.walk(outputDestination):
|
for dirpath, dirnames, filenames in os.walk(outputDestination):
|
||||||
for file in filenames:
|
for file in filenames:
|
||||||
filePath = joinPath(dirpath, file)
|
filePath = nzbtomedia.joinPath(dirpath, file)
|
||||||
fileName, fileExtension = os.path.splitext(file)
|
fileName, fileExtension = os.path.splitext(file)
|
||||||
|
|
||||||
if fileExtension in nzbtomedia.USER_SCRIPT_MEDIAEXTENSIONS or nzbtomedia.USER_SCRIPT_MEDIAEXTENSIONS == "ALL":
|
if fileExtension in nzbtomedia.USER_SCRIPT_MEDIAEXTENSIONS or nzbtomedia.USER_SCRIPT_MEDIAEXTENSIONS == "ALL":
|
||||||
|
@ -295,7 +287,7 @@ def main(args):
|
||||||
result = 0
|
result = 0
|
||||||
|
|
||||||
try:
|
try:
|
||||||
inputDirectory, inputName, inputCategory, inputHash, inputID = parse_args(clientAgent, args)
|
inputDirectory, inputName, inputCategory, inputHash, inputID = nzbtomedia.parse_args(clientAgent, args)
|
||||||
except:
|
except:
|
||||||
logger.error("There was a problem loading variables")
|
logger.error("There was a problem loading variables")
|
||||||
return -1
|
return -1
|
||||||
|
@ -309,14 +301,14 @@ def main(args):
|
||||||
for section, subsection in nzbtomedia.SUBSECTIONS.items():
|
for section, subsection in nzbtomedia.SUBSECTIONS.items():
|
||||||
for category in subsection:
|
for category in subsection:
|
||||||
if nzbtomedia.CFG[section][category].isenabled():
|
if nzbtomedia.CFG[section][category].isenabled():
|
||||||
dirNames = get_dirnames(section, category)
|
dirNames = nzbtomedia.get_dirnames(section, category)
|
||||||
for dirName in dirNames:
|
for dirName in dirNames:
|
||||||
clientAgent = 'manual'
|
clientAgent = 'manual'
|
||||||
inputHash = None
|
inputHash = None
|
||||||
inputID = None
|
inputID = None
|
||||||
|
|
||||||
logger.info("Checking database for download info for %s ..." % (os.path.basename(dirName)))
|
logger.info("Checking database for download info for %s ..." % (os.path.basename(dirName)))
|
||||||
downloadInfo = get_downloadInfo(os.path.basename(dirName), 0)[0]
|
downloadInfo = nzbtomedia.get_downloadInfo(os.path.basename(dirName), 0)[0]
|
||||||
if downloadInfo:
|
if downloadInfo:
|
||||||
clientAgent = str(downloadInfo['client_agent'])
|
clientAgent = str(downloadInfo['client_agent'])
|
||||||
inputHash = str(downloadInfo['input_hash'])
|
inputHash = str(downloadInfo['input_hash'])
|
||||||
|
|
|
@ -20,9 +20,17 @@ CONFIG_TV_FILE = os.path.join(PROGRAM_DIR, 'autoProcessTv.cfg')
|
||||||
# add our custom libs to the system path
|
# add our custom libs to the system path
|
||||||
sys.path.insert(0, LIBS_DIR)
|
sys.path.insert(0, LIBS_DIR)
|
||||||
|
|
||||||
|
from nzbtomedia.autoProcess.autoProcessComics import autoProcessComics
|
||||||
|
from nzbtomedia.autoProcess.autoProcessGames import autoProcessGames
|
||||||
|
from nzbtomedia.autoProcess.autoProcessMovie import autoProcessMovie
|
||||||
|
from nzbtomedia.autoProcess.autoProcessMusic import autoProcessMusic
|
||||||
|
from nzbtomedia.autoProcess.autoProcessTV import autoProcessTV
|
||||||
from nzbtomedia import logger, versionCheck, nzbToMediaDB
|
from nzbtomedia import logger, versionCheck, nzbToMediaDB
|
||||||
from nzbtomedia.nzbToMediaConfig import config
|
from nzbtomedia.nzbToMediaConfig import config
|
||||||
from nzbtomedia.nzbToMediaUtil import WakeUp, makeDir, joinPath, cleanProcDirs, create_torrent_class, listMediaFiles
|
from nzbtomedia.nzbToMediaUtil import category_search, sanitizeFileName, copy_link, parse_args, flatten, get_dirnames, \
|
||||||
|
remove_read_only, pause_torrent, resume_torrent, listMediaFiles, joinPath, \
|
||||||
|
extractFiles, cleanProcDirs, update_downloadInfoStatus, get_downloadInfo, WakeUp, makeDir, joinPath, cleanProcDirs, \
|
||||||
|
create_torrent_class, listMediaFiles
|
||||||
from nzbtomedia.transcoder import transcoder
|
from nzbtomedia.transcoder import transcoder
|
||||||
from nzbtomedia.databases import mainDB
|
from nzbtomedia.databases import mainDB
|
||||||
|
|
||||||
|
@ -128,9 +136,9 @@ USER_SCRIPT_CLEAN = None
|
||||||
USER_DELAY = None
|
USER_DELAY = None
|
||||||
USER_SCRIPT_RUNONCE = None
|
USER_SCRIPT_RUNONCE = None
|
||||||
|
|
||||||
|
|
||||||
__INITIALIZED__ = False
|
__INITIALIZED__ = False
|
||||||
|
|
||||||
|
|
||||||
def initialize(section=None):
|
def initialize(section=None):
|
||||||
global NZBGET_POSTPROCESS_ERROR, NZBGET_POSTPROCESS_NONE, NZBGET_POSTPROCESS_PARCHECK, NZBGET_POSTPROCESS_SUCCESS, \
|
global NZBGET_POSTPROCESS_ERROR, NZBGET_POSTPROCESS_NONE, NZBGET_POSTPROCESS_PARCHECK, NZBGET_POSTPROCESS_SUCCESS, \
|
||||||
NZBTOMEDIA_TIMEOUT, FORKS, FORK_DEFAULT, FORK_FAILED_TORRENT, FORK_FAILED, SICKBEARD_TORRENT, SICKBEARD_FAILED, \
|
NZBTOMEDIA_TIMEOUT, FORKS, FORK_DEFAULT, FORK_FAILED_TORRENT, FORK_FAILED, SICKBEARD_TORRENT, SICKBEARD_FAILED, \
|
||||||
|
@ -139,7 +147,7 @@ def initialize(section=None):
|
||||||
UTORRENTPWD, UTORRENTUSR, UTORRENTWEBUI, DELUGEHOST, DELUGEPORT, DELUGEUSR, DELUGEPWD, TRANSMISSIONHOST, TRANSMISSIONPORT, \
|
UTORRENTPWD, UTORRENTUSR, UTORRENTWEBUI, DELUGEHOST, DELUGEPORT, DELUGEUSR, DELUGEPWD, TRANSMISSIONHOST, TRANSMISSIONPORT, \
|
||||||
TRANSMISSIONPWD, TRANSMISSIONUSR, COMPRESSEDCONTAINER, MEDIACONTAINER, METACONTAINER, MINSAMPLESIZE, SAMPLEIDS, \
|
TRANSMISSIONPWD, TRANSMISSIONUSR, COMPRESSEDCONTAINER, MEDIACONTAINER, METACONTAINER, MINSAMPLESIZE, SAMPLEIDS, \
|
||||||
SECTIONS, SUBSECTIONS, USER_SCRIPT_CATEGORIES, __INITIALIZED__, AUTO_UPDATE, APP_FILENAME, USER_DELAY, USER_SCRIPT_RUNONCE, \
|
SECTIONS, SUBSECTIONS, USER_SCRIPT_CATEGORIES, __INITIALIZED__, AUTO_UPDATE, APP_FILENAME, USER_DELAY, USER_SCRIPT_RUNONCE, \
|
||||||
APP_NAME,USER_SCRIPT_MEDIAEXTENSIONS, USER_SCRIPT, USER_SCRIPT_PARAM, USER_SCRIPT_SUCCESSCODES, USER_SCRIPT_CLEAN, \
|
APP_NAME, USER_SCRIPT_MEDIAEXTENSIONS, USER_SCRIPT, USER_SCRIPT_PARAM, USER_SCRIPT_SUCCESSCODES, USER_SCRIPT_CLEAN, \
|
||||||
TRANSCODE, GIT_PATH, GIT_USER, GIT_BRANCH, GIT_REPO, SYS_ENCODING, NZB_CLIENTAGENT, SABNZBDHOST, SABNZBDPORT, SABNZBDAPIKEY, \
|
TRANSCODE, GIT_PATH, GIT_USER, GIT_BRANCH, GIT_REPO, SYS_ENCODING, NZB_CLIENTAGENT, SABNZBDHOST, SABNZBDPORT, SABNZBDAPIKEY, \
|
||||||
DUPLICATE, IGNOREEXTENSIONS, OUTPUTVIDEOEXTENSION, OUTPUTVIDEOCODEC, OUTPUTVIDEOPRESET, OUTPUTVIDEOFRAMERATE, LOG_DB, \
|
DUPLICATE, IGNOREEXTENSIONS, OUTPUTVIDEOEXTENSION, OUTPUTVIDEOCODEC, OUTPUTVIDEOPRESET, OUTPUTVIDEOFRAMERATE, LOG_DB, \
|
||||||
OUTPUTVIDEOBITRATE, OUTPUTAUDIOCODEC, OUTPUTAUDIOBITRATE, OUTPUTSUBTITLECODEC, OUTPUTFASTSTART, OUTPUTQUALITYPERCENT, \
|
OUTPUTVIDEOBITRATE, OUTPUTAUDIOCODEC, OUTPUTAUDIOBITRATE, OUTPUTSUBTITLECODEC, OUTPUTFASTSTART, OUTPUTQUALITYPERCENT, \
|
||||||
|
@ -220,7 +228,8 @@ def initialize(section=None):
|
||||||
logger.error("Update wasn't successful, not restarting. Check your log for more information.")
|
logger.error("Update wasn't successful, not restarting. Check your log for more information.")
|
||||||
|
|
||||||
# Set Current Version
|
# Set Current Version
|
||||||
logger.info('nzbToMedia Version:' + NZBTOMEDIA_VERSION + ' Branch:' + GIT_BRANCH + ' (' + platform.system() + ' ' + platform.release() + ')')
|
logger.info(
|
||||||
|
'nzbToMedia Version:' + NZBTOMEDIA_VERSION + ' Branch:' + GIT_BRANCH + ' (' + platform.system() + ' ' + platform.release() + ')')
|
||||||
|
|
||||||
if int(CFG["WakeOnLan"]["wake"]) == 1:
|
if int(CFG["WakeOnLan"]["wake"]) == 1:
|
||||||
WakeUp()
|
WakeUp()
|
||||||
|
@ -254,7 +263,7 @@ def initialize(section=None):
|
||||||
MEDIACONTAINER = CFG["Extensions"]["mediaExtensions"]
|
MEDIACONTAINER = CFG["Extensions"]["mediaExtensions"]
|
||||||
AUDIOCONTAINER = CFG["Extensions"]["audioExtensions"]
|
AUDIOCONTAINER = CFG["Extensions"]["audioExtensions"]
|
||||||
METACONTAINER = CFG["Extensions"]["metaExtensions"] # .nfo,.sub,.srt
|
METACONTAINER = CFG["Extensions"]["metaExtensions"] # .nfo,.sub,.srt
|
||||||
if isinstance(COMPRESSEDCONTAINER, str):COMPRESSEDCONTAINER = COMPRESSEDCONTAINER.split(',')
|
if isinstance(COMPRESSEDCONTAINER, str): COMPRESSEDCONTAINER = COMPRESSEDCONTAINER.split(',')
|
||||||
if isinstance(MEDIACONTAINER, str): MEDIACONTAINER = MEDIACONTAINER.split(',')
|
if isinstance(MEDIACONTAINER, str): MEDIACONTAINER = MEDIACONTAINER.split(',')
|
||||||
if isinstance(AUDIOCONTAINER, str): AUDIOCONTAINER = AUDIOCONTAINER.split(',')
|
if isinstance(AUDIOCONTAINER, str): AUDIOCONTAINER = AUDIOCONTAINER.split(',')
|
||||||
if isinstance(METACONTAINER, str): METACONTAINER = METACONTAINER.split(',')
|
if isinstance(METACONTAINER, str): METACONTAINER = METACONTAINER.split(',')
|
||||||
|
@ -282,12 +291,12 @@ def initialize(section=None):
|
||||||
FFMPEG = joinPath(FFMPEG_PATH, 'ffmpeg.exe')
|
FFMPEG = joinPath(FFMPEG_PATH, 'ffmpeg.exe')
|
||||||
FFPROBE = joinPath(FFMPEG_PATH, 'ffprobe.exe')
|
FFPROBE = joinPath(FFMPEG_PATH, 'ffprobe.exe')
|
||||||
|
|
||||||
if not (os.path.isfile(FFMPEG)): # problem
|
if not (os.path.isfile(FFMPEG)): # problem
|
||||||
FFMPEG = None
|
FFMPEG = None
|
||||||
logger.warning("Failed to locate %s, transcoding disabled!" % (FFMPEG))
|
logger.warning("Failed to locate %s, transcoding disabled!" % (FFMPEG))
|
||||||
logger.warning("Install ffmpeg with x264 support to enable this feature ...")
|
logger.warning("Install ffmpeg with x264 support to enable this feature ...")
|
||||||
|
|
||||||
if not (os.path.isfile(FFPROBE)): # problem
|
if not (os.path.isfile(FFPROBE)): # problem
|
||||||
FFPROBE = None
|
FFPROBE = None
|
||||||
logger.warning("Failed to locate %s, video corruption detection disabled!" % (FFPROBE))
|
logger.warning("Failed to locate %s, video corruption detection disabled!" % (FFPROBE))
|
||||||
logger.warning("Install ffmpeg with x264 support to enable this feature ...")
|
logger.warning("Install ffmpeg with x264 support to enable this feature ...")
|
||||||
|
@ -318,7 +327,7 @@ def initialize(section=None):
|
||||||
|
|
||||||
# check for script-defied section and if None set to allow sections
|
# check for script-defied section and if None set to allow sections
|
||||||
SECTIONS = ("CouchPotato", "SickBeard", "NzbDrone", "HeadPhones", "Mylar", "Gamez")
|
SECTIONS = ("CouchPotato", "SickBeard", "NzbDrone", "HeadPhones", "Mylar", "Gamez")
|
||||||
if section:SECTIONS = (section,)
|
if section: SECTIONS = (section,)
|
||||||
|
|
||||||
SUBSECTIONS = CFG[SECTIONS]
|
SUBSECTIONS = CFG[SECTIONS]
|
||||||
CATEGORIES += SUBSECTIONS.sections
|
CATEGORIES += SUBSECTIONS.sections
|
||||||
|
@ -331,6 +340,7 @@ def initialize(section=None):
|
||||||
|
|
||||||
return True
|
return True
|
||||||
|
|
||||||
|
|
||||||
def restart():
|
def restart():
|
||||||
install_type = versionCheck.CheckVersion().install_type
|
install_type = versionCheck.CheckVersion().install_type
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue