cpet
/
freebsd-ports
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[NEW PORT] news/nzbhydra2: Usenet meta search 

NZBHydra 2 is a meta search for NZB indexers. It provides easy access to a
number of raw and newznab based indexers. You can search all your indexers
from one place and use it as an indexer source for tools like Sonarr,
Radarr or CouchPotato.

WWW: https://github.com/theotherp/nzbhydra2

PR:		234537
Submitted by:	Daniel Shafer <daniel shafer cc>
Differential_Revision:	https://reviews.freebsd.org/D18704
This commit is contained in:
Tobias C. Berner 2019-01-29 20:14:34 +00:00
parent 729efd5b4d
commit 8c06f3f158
Notes: svn2git 2021-03-31 03:12:20 +00:00 
svn path=/head/; revision=491596
8 changed files with 747 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
GIDs
View File

@ -295,7 +295,7 @@ sonarr:*:351:
radarr:*:352:
_iodined:*:353:
jackett:*:354:
# free: 355
nzbhydra2:*:355:
# free: 356
# free: 357
# free: 358

3
UIDs
View File

@ -300,8 +300,7 @@ sonarr:*:351:351::0:0:Sonarr PVR:/nonexistent:/usr/sbin/nologin
radarr:*:352:352::0:0:Radarr Daemon:/nonexistent:/usr/sbin/nologin
_iodined:*:353:353::0:0:Iodine Daemon:/nonexistent:/usr/sbin/nologin
jackett:*:354:354::0:0:Jackett Torznab Proxy Daemon:/nonexistent:/usr/sbin/nologin
# free: 354
# free: 355
nzbhydra2:*:355:355::0:0:NZBHydra 2 Daemon:/nonexistent:/usr/sbin/nologin
# free: 356
# free: 357
# free: 358

1
news/Makefile
View File

@ -46,6 +46,7 @@
SUBDIR += nntpcache
SUBDIR += noffle
SUBDIR += nzbget
SUBDIR += nzbhydra2
SUBDIR += nzbperl
SUBDIR += p5-NNTPClient
SUBDIR += p5-News-Article

52
news/nzbhydra2/Makefile Normal file
View File

@ -0,0 +1,52 @@
# $FreeBSD$
PORTNAME= nzbhydra2
DISTVERSION= 2.3.3
DISTVERSIONSUFFIX= -linux
CATEGORIES= news java
MASTER_SITES= https://github.com/theotherp/${PORTNAME}/releases/download/v${DISTVERSION}/
MAINTAINER= daniel@shafer.cc
COMMENT= Usenet meta search
LICENSE= APACHE20
LICENSE_FILE= ${WRKSRC}/LICENSE
ONLY_FOR_ARCHS= amd64
USES= python shebangfix zip
USE_JAVA= yes
USE_RC_SUBR= nzbhydra2
NO_BUILD= yes
NO_WRKSUBDIR= yes
SUB_FILES= nzbhydra2 nzbhydra2wrapper.py
SUB_LIST= PYTHON_CMD=${PYTHON_CMD} \
JAVA=${JAVA}
JAVA_VERSION= 1.8 1.9 1.10 1.11
JAVA_VENDOR= openjdk
JAVA_RUN= yes
USERS= nzbhydra2
GROUPS= nzbhydra2
PLIST_FILES= ${DATADIR}/lib/core-2.3.3-exec.jar \
${DATADIR}/nzbhydra2 \
${DATADIR}/nzbhydra2wrapper.py \
${DATADIR}/changelog.md \
${DATADIR}/readme.md \
${DATADIR}/LICENSE
post-extract:
# Cleanup unnecessary files
@${RM} -r ${WRKSRC}/systemd ${WRKSRC}/sysv ${WRKSRC}/rc.d ${WRKSRC}/upstart
do-install:
@${MKDIR} ${STAGEDIR}/${DATADIR}
${INSTALL} -d -m 755 ${STAGEDIR}/${DATADIR}
cd ${WRKSRC} && ${COPYTREE_SHARE} \* ${STAGEDIR}/${DATADIR}
${INSTALL_DATA} ${WRKDIR}/nzbhydra2wrapper.py ${STAGEDIR}/${DATADIR}
.include <bsd.port.mk>

3
news/nzbhydra2/distinfo Normal file
View File

@ -0,0 +1,3 @@
TIMESTAMP = 1548790229
SHA256 (nzbhydra2-2.3.3-linux.zip) = 899981bccab23828bfc95590c22386261556271323f1810f73aecdeaf014a62f
SIZE (nzbhydra2-2.3.3-linux.zip) = 61623948

58
news/nzbhydra2/files/nzbhydra2.in Normal file
View File

@ -0,0 +1,58 @@
#!/bin/sh
#
# $FreeBSD$
#
# PROVIDE: nzbhydra2
# REQUIRE: LOGIN
# KEYWORD: shutdown
#
# Add the following lines to /etc/rc.conf.local or /etc/rc.conf
# to enable this service:
#
# nzbhydra2_enable (bool): Set to NO by default.
# Set it to YES to enable it.
# nzbhydra2_user: The user account nzbhydra daemon runs as what
# you want it to be. It uses '_sabnzbd' user by
# default. Do not sets it as empty or it will run
# as root.
# nzbhydra2_group: The group account nzbhydra daemon runs as what
# you want it to be. It uses 'nzbhydra2' group by
# default. Do not sets it as empty or it will run
# as wheel.
# nzbhydra2_dir: Directory where nzbhydra lives.
# Default: %%PREFIX%%/share/nzbhydra2
# nzbhydra2_datafolder: Data directory for nzbhydra (DB, Logs, config)
# Default: %%PREFIX%%/nzbhydra2
. /etc/rc.subr
name="nzbhydra2"
rcvar=${name}_enable
load_rc_config ${name}
: ${nzbhydra2_enable:="NO"}
: ${nzbhydra2_user:="nzbhydra2"}
: ${nzbhydra2_group:="nzbhydra2"}
: ${nzbhydra2_dir:="%%PREFIX%%/share/nzbhydra2"}
: ${nzbhydra2_datafolder:="%%PREFIX%%/nzbhydra2"}
pidfile="/var/run/nzbhydra2/nzbhydra2.pid"
command="%%PYTHON_CMD%%"
command_args="${nzbhydra2_dir}/nzbhydra2wrapper.py --datafolder ${nzbhydra2_datafolder} --pidfile ${pidfile} --daemon --nobrowser --java %%JAVA%%"
start_precmd="prestart"
prestart() {
if [ -f ${pidfile} ]; then
rm -f ${pidfile}
echo "Removing stale pidfile."
elif [ ! -d ${pidfile%/*} ]; then
install -d -o ${nzbhydra2_user} -g ${nzbhydra2_group} ${pidfile%/*}
fi
if [ ! -d ${nzbhydra2_datadir} ]; then
install -d -o ${nzbhydra2_user} -g ${nzbhydra2_group} ${nzbhydra2_datadir}
fi
}
run_rc_command "$1"

625
news/nzbhydra2/files/nzbhydra2wrapper.py.in Normal file
View File

@ -0,0 +1,625 @@
#!%%PYTHON_CMD%%
from __future__ import print_function
import sys
CURRENT_PYTHON = sys.version_info[:2]
REQUIRED_PYTHON = (2, 7)
# This check and everything above must remain compatible with Python 2.7 and above.
if CURRENT_PYTHON > REQUIRED_PYTHON:
sys.stderr.write("This script requires Python {}.{}, but you're trying to run it on Python {}.{}.".format(*(REQUIRED_PYTHON + CURRENT_PYTHON)))
sys.exit(1)
import argparse
import datetime
import logging
import os
import platform
import re
import shutil
import subprocess
import zipfile
from __builtin__ import file
from logging.handlers import RotatingFileHandler
jarFile = None
basepath = None
args = []
unknownArgs = []
terminatedByWrapper = False
LOGGER_DEFAULT_FORMAT = u'%(asctime)s %(levelname)s - %(message)s'
LOGGER_DEFAULT_LEVEL = 'INFO'
logger = logging.getLogger('root')
console_logger = logging.StreamHandler(sys.stdout)
console_logger.setFormatter(logging.Formatter(LOGGER_DEFAULT_FORMAT))
console_logger.setLevel(LOGGER_DEFAULT_LEVEL)
logger.addHandler(console_logger)
file_logger = None
logger.setLevel(LOGGER_DEFAULT_LEVEL)
consoleLines = []
def getBasePath():
global basepath
if basepath is not None:
return basepath
if "HYDRAWORKINGFOLDER" in os.environ.keys():
return os.environ["HYDRAWORKINGFOLDER"]
import sys
if sys.executable:
basepath = os.path.dirname(sys.executable)
if os.path.exists(os.path.join(basepath, "readme.md")) and os.path.exists(os.path.join(basepath, "changelog.md")):
return basepath
basepath = os.path.dirname(os.path.abspath(sys.argv[0]))
if os.path.exists(os.path.join(basepath, "readme.md")) and os.path.exists(os.path.join(basepath, "changelog.md")):
return basepath
try:
basepath = os.path.dirname(os.path.abspath(__file__))
except NameError: # We are the main py2exe script, not a module
import sys
basepath = os.path.dirname(os.path.abspath(sys.argv[0]))
return basepath
class GracefulKiller:
def __init__(self):
import signal
signal.signal(signal.SIGINT, terminated)
signal.signal(signal.SIGTERM, terminated)
def terminated(signum, frame):
logger.info("Terminated by signal %d" % signum)
killProcess()
def killProcess():
if process is not None and process.poll() is None:
global terminatedByWrapper
logger.info("NZBHydra2 wrapper shutdown request. Terminating main process gracefully")
terminatedByWrapper = True
process.terminate()
def daemonize(pidfile, nopidfile):
# Make a non-session-leader child process
try:
pid = os.fork() # @UndefinedVariable - only available in UNIX
if pid != 0:
os._exit(0)
except OSError as e:
sys.stderr.write("fork #1 failed: %d (%s)\n" % (e.errno, e.strerror))
sys.exit(1)
os.setsid() # @UndefinedVariable - only available in UNIX
# Make sure I can read my own files and shut out others
prev = os.umask(0)
os.umask(prev and int('077', 8))
# Make the child a session-leader by detaching from the terminal
try:
pid = os.fork() # @UndefinedVariable - only available in UNIX
if pid != 0:
os._exit(0)
except OSError as e:
sys.stderr.write("fork #2 failed: %d (%s)\n" % (e.errno, e.strerror))
sys.exit(1)
# Write pid
if not nopidfile:
pid = str(os.getpid())
try:
file(pidfile, 'w').write("%s\n" % pid)
except IOError as e:
sys.stderr.write(u"Unable to write PID file: " + pidfile + ". Error: " + str(e.strerror) + " [" + str(e.errno) + "]")
sys.exit(1)
else:
print("no pid file")
# Redirect all output
sys.stdout.flush()
sys.stderr.flush()
devnull = getattr(os, 'devnull', '/dev/null')
stdin = file(devnull, 'r')
stdout = file(devnull, 'a+')
stderr = file(devnull, 'a+')
os.dup2(stdin.fileno(), sys.stdin.fileno())
os.dup2(stdout.fileno(), sys.stdout.fileno())
os.dup2(stderr.fileno(), sys.stderr.fileno())
def setupLogger():
logsFolder = os.path.join(args.datafolder, "logs")
if not os.path.exists(logsFolder):
os.makedirs(logsFolder)
logfilename = os.path.join(logsFolder, "wrapper.log")
if not args.quiet:
print("Logging wrapper output to " + logfilename)
if not args.quiet:
console_logger.setLevel("INFO")
else:
console_logger.setLevel("CRITICAL")
global file_logger
file_logger = RotatingFileHandler(filename=logfilename, maxBytes=100000, backupCount=1)
file_logger.setFormatter(logging.Formatter(LOGGER_DEFAULT_FORMAT))
file_logger.setLevel("INFO")
logger.addHandler(file_logger)
logger.setLevel("INFO")
def update():
global jarFile
basePath = getBasePath()
updateFolder = os.path.join(args.datafolder, "update")
libFolder = os.path.join(basePath, "lib")
isWindows = any([x for x in os.listdir(basePath) if x.lower().endswith(".exe")])
logger.debug("Is Windows installation: %r", isWindows)
if not os.path.exists(updateFolder):
logger.critical("Error: Update folder %s does not exist", updateFolder)
sys.exit(-2)
onlyfiles = [f for f in os.listdir(updateFolder) if os.path.isfile(os.path.join(updateFolder, f))]
if len(onlyfiles) != 1 or not onlyfiles[0].lower().endswith("zip"):
logger.critical("Error: Unable to identify update ZIP")
sys.exit(-2)
updateZip = os.path.join(updateFolder, onlyfiles[0])
try:
with zipfile.ZipFile(updateZip, "r") as zf:
logger.info("Extracting updated files to %s", basePath)
for member in zf.namelist():
if not member.lower() == "nzbhydra2" and not member.lower().endswith(".exe"):
logger.debug("Extracting %s to %s", member, basePath)
try:
zf.extract(member, basePath)
except IOError as ex:
logger.critical("Unable to extract file %s to path %s: %s", member, basePath, ex)
sys.exit(-2)
logger.info("Removing update ZIP %s", updateZip)
os.remove(updateZip)
filesInLibFolder = [f for f in os.listdir(libFolder) if os.path.isfile(os.path.join(libFolder, f)) and f.endswith(".jar")]
logger.info("Found %d JAR files in lib folder", len(filesInLibFolder))
for file in filesInLibFolder:
logger.info("Found file: %s", file)
if len(filesInLibFolder) == 2:
logger.info("Deleting old JAR %s", jarFile)
os.remove(jarFile)
elif len(filesInLibFolder) == 1:
if filesInLibFolder[0] == os.path.basename(jarFile):
logger.warning("New JAR file in lib folder is the same as the old one. The update may not have found a newer version or failed for some reason")
else:
logger.warning("Expected the number of JAR files in folder %s to be 2 but it's %d. This will be fixed with the next start", libFolder, len(filesInLibFolder))
except zipfile.BadZipfile:
logger.critical("File is not a ZIP")
sys.exit(-2)
logger.info("Deleting folder " + updateFolder)
shutil.rmtree(updateFolder)
logger.info("Update successful, restarting Hydra main process")
def restore():
global args
dataFolder = args.datafolder
restoreFolder = os.path.join(args.datafolder, "restore")
if not os.path.exists(dataFolder):
logger.critical("Data folder %s does not exist", dataFolder)
sys.exit(-1)
if not os.path.exists(restoreFolder):
logger.critical("Restore folder %s does not exist", restoreFolder)
sys.exit(-1)
try:
oldSettingsFile = os.path.join(dataFolder, "nzbhydra.yml")
logger.info("Deleting old settings file " + oldSettingsFile)
os.remove(oldSettingsFile)
oldDatabaseFile = os.path.join(dataFolder, "database", "nzbhydra.mv.db")
logger.info("Deleting old database file " + oldDatabaseFile)
os.remove(oldDatabaseFile)
except Exception as e:
logger.critical("Error while deleting old data folder: %r", e)
sys.exit(-1)
for f in os.listdir(restoreFolder):
source = os.path.join(restoreFolder, f)
if source.endswith("db"):
dest = os.path.join(dataFolder, "database", f)
else:
dest = os.path.join(dataFolder, f)
logger.info("Moving " + source + " to " + dest)
shutil.move(source, dest)
logger.info("Deleting folder " + restoreFolder)
os.rmdir(restoreFolder)
logger.info("Moved all files from restore folder to data folder")
return True
# From https://github.com/pyinstaller/pyinstaller/wiki/Recipe-subprocess
def subprocess_args(include_stdout=True):
# The following is true only on Windows.
if hasattr(subprocess, 'STARTUPINFO'):
# On Windows, subprocess calls will pop up a command window by default
# when run from Pyinstaller with the ``--noconsole`` option. Avoid this
# distraction.
si = subprocess.STARTUPINFO()
try:
import _subprocess
si.dwFlags |= _subprocess.STARTF_USESHOWWINDOW
except:
si.dwFlags |= subprocess.STARTF_USESHOWWINDOW
# Windows doesn't search the path by default. Pass it an environment so
# it will.
env = os.environ.copy()
else:
si = None
env = None
# ``subprocess.check_output`` doesn't allow specifying ``stdout``::
#
# Traceback (most recent call last):
# File "test_subprocess.py", line 58, in <module>
# **subprocess_args(stdout=None))
# File "C:\Python27\lib\subprocess.py", line 567, in check_output
# raise ValueError('stdout argument not allowed, it will be overridden.')
# ValueError: stdout argument not allowed, it will be overridden.
#
# So, add it only if it's needed.
if include_stdout:
ret = {'stdout': subprocess.PIPE}
else:
ret = {}
# On Windows, running this from the binary produced by Pyinstaller
# with the ``--noconsole`` option requires redirecting everything
# (stdin, stdout, stderr) to avoid an OSError exception
# "[Error 6] the handle is invalid."
ret.update({'stdin': subprocess.PIPE,
'stderr': subprocess.STDOUT,
'startupinfo': si,
'env': env})
return ret
def startup():
global jarFile, process, args, unknownArgs, consoleLines
basePath = getBasePath()
readme = os.path.join(basePath, "readme.md")
if not os.path.exists(readme):
logger.critical("Unable to determine base path correctly. Please make sure to run NZBHydra in the folder where its binary is located. Current base path: " + basePath)
sys.exit(-1)
debugSwitchFile = os.path.join(args.datafolder, "DEBUG")
if os.path.exists(debugSwitchFile):
logger.setLevel("DEBUG")
global file_logger, console_logger
file_logger.setLevel("DEBUG")
console_logger.setLevel("DEBUG")
logger.info("Setting wrapper log level to DEBUG")
isWindows = platform.system().lower() == "windows"
libFolder = os.path.join(basePath, "lib")
if not os.path.exists(libFolder):
logger.critical("Error: Lib folder %s not found. An update might've failed or the installation folder is corrupt", libFolder)
sys.exit(-1)
jarFiles = [os.path.join(libFolder, f) for f in os.listdir(libFolder) if os.path.isfile(os.path.join(libFolder, f)) and f.endswith(".jar")]
if len(jarFiles) == 0:
logger.critical("Error: No JAR files found in folder %s. An update might've failed or the installation folder is corrupt", libFolder)
sys.exit(-1)
if len(jarFiles) == 1:
jarFile = jarFiles[0]
else:
latestFile = max(jarFiles, key=os.path.getmtime)
logger.warning("Expected the number of JAR files in folder %s to be 1 but it's %d. Will remove all JARs except the one last changed: %s", libFolder, len(jarFiles), latestFile)
for file in jarFiles:
if file is not latestFile:
logger.info("Deleting file %s", file)
os.remove(file)
jarFile = latestFile
logger.debug("Using JAR file " + jarFile)
if args.repairdb:
arguments = ["--repairdb", args.repairdb]
elif args.version:
arguments = ["--version"]
else:
arguments = unknownArgs # Those arguments not "caught" by this parser
# We need to set the ones which we "pass through" separately
if args.restarted and "restarted" not in arguments:
arguments.append("restarted")
if (args.daemon in arguments or args.nobrowser) and "--nobrowser" not in arguments:
arguments.append("--nobrowser")
if args.datafolder and "--datafolder" not in arguments:
arguments.append("--datafolder")
arguments.append(escape_parameter(isWindows, args.datafolder))
if args.host and "--host" not in arguments:
arguments.append("--host")
arguments.append(args.host)
if args.port and "--port" not in arguments:
arguments.append("--port")
arguments.append(args.port)
if args.baseurl and "--baseurl" not in arguments:
arguments.append("--baseurl")
arguments.append(args.baseurl)
yamlPath = os.path.join(args.datafolder, "nzbhydra.yml")
if args.xmx:
xmx = args.xmx
elif os.path.exists(yamlPath):
with open(yamlPath, "r") as f:
for line in f.readlines():
index = line.find("xmx:")
if index > -1:
xmx = line[index + 5:].rstrip("\n\r ")
break
else:
logger.warn("Didn't find XMX in YAML file, using default of 256")
xmx = 256
else:
logger.info("No file nzbhydra.yml found. Using 256M XMX")
xmx = 256
xmx = str(xmx)
if xmx.lower().endswith("m"):
logger.info("Removing superfluous M from XMX value " + xmx)
xmx = xmx[:-1]
javaVersion = getJavaVersion(args.java)
gcLogFilename = (os.path.join(args.datafolder, "logs") + "/gclog-" + datetime.datetime.now().strftime("%Y-%m-%d_%H-%M-%S") + ".log").replace("\\", "/")
gcLogFilename = os.path.relpath(gcLogFilename, basePath)
gcArguments = []
if javaVersion < 9:
gcArguments = ["-Xloggc:" + gcLogFilename,
"-XX:+PrintGCDetails",
"-XX:+PrintGCTimeStamps",
"-XX:+PrintTenuringDistribution",
"-XX:+PrintGCCause",
"-XX:+UseGCLogFileRotation",
"-XX:NumberOfGCLogFiles=10",
"-XX:GCLogFileSize=5M",
]
else:
gcArguments = [
"-Xlog:gc*:file=" + gcLogFilename + "::filecount=10,filesize=5000"]
java_arguments = ["-Xmx" + xmx + "M",
"-DfromWrapper",
"-XX:TieredStopAtLevel=1",
"-noverify",
"-XX:+HeapDumpOnOutOfMemoryError",
"-XX:HeapDumpPath=" + os.path.join(args.datafolder, "logs")
]
java_arguments.extend(gcArguments)
if args.debugport:
java_arguments.append("-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=*:" + args.debugport)
if not args.nocolors and not isWindows:
java_arguments.append("-Dspring.output.ansi.enabled=ALWAYS")
if args.debug:
java_arguments.append("-Ddebug=true")
arguments = [args.java] + java_arguments + ["-jar", escape_parameter(isWindows, jarFile)] + arguments
commandLine = " ".join(arguments)
logger.info("Starting NZBHydra main process with command line: %s in folder %s", commandLine, basePath)
if hasattr(subprocess, 'STARTUPINFO'):
si = subprocess.STARTUPINFO()
try:
import _subprocess
si.dwFlags |= _subprocess.STARTF_USESHOWWINDOW
except:
si.dwFlags |= subprocess.STARTF_USESHOWWINDOW
else:
si = None
# todo check shell=True/False for linux and windows
# shell=true: pass string, shell=false: pass arguments
try:
process = subprocess.Popen(arguments, shell=False, cwd=basePath, bufsize=-1, **subprocess_args())
# atexit.register(killProcess)
while True:
# Handle error first in case startup of main process returned only an error (on stderror)
nextline = process.stdout.readline()
if nextline == '' and process.poll() is not None:
break
if nextline != "":
consoleLines.append(nextline)
if len(consoleLines) > 100:
consoleLines = consoleLines[-100:]
if not args.quiet:
sys.stdout.write(nextline)
sys.stdout.flush()
process.wait()
return process
except Exception as e:
logger.error("Unable to start process; make sure Java is installed and callable. Error message: " + str(e))
def escape_parameter(is_windows, parameter):
return parameter # TODO FInd out when to actually escape with windows, I think when shell=True is used
# return '"' + parameter + '"' if is_windows else parameter
def list_files(startpath):
for root, dirs, files in os.walk(startpath):
level = root.replace(startpath, '').count(os.sep)
indent = ' ' * 4 * (level)
logger.info('{}{}/'.format(indent, os.path.basename(root)))
subindent = ' ' * 4 * (level + 1)
for f in files:
logger.info('{}{}'.format(subindent, f))
def handleUnexpectedExit():
global consoleLines
message = "Main process shut down unexpectedly. If the wrapper was started in daemon mode you might not see the error output. Start Hydra manually with the same parameters in the same environment to see it"
for x in consoleLines:
if "Unrecognized option: -Xlog" in x:
message = "You seem to be trying to run NZBHydra with a wrong Java version. Please make sure to use at least Java 9"
elif "java.lang.OutOfMemoryError" in x:
message = "The main process has exited because it didn't have enough memory. Please increase the XMX value in the main config"
logger.error(message)
sys.exit(-1)
def getJavaVersion(javaExecutable):
if hasattr(subprocess, 'STARTUPINFO'):
si = subprocess.STARTUPINFO()
try:
import _subprocess
si.dwFlags |= _subprocess.STARTF_USESHOWWINDOW
except:
si.dwFlags |= subprocess.STARTF_USESHOWWINDOW
else:
si = None
# todo check shell=True/False for linux and windows
# shell=true: pass string, shell=false: pass arguments
try:
lines = []
process = subprocess.Popen([javaExecutable, "-version"], shell=False, bufsize=-1, **subprocess_args())
# atexit.register(killProcess)
while True:
# Handle error first in case startup of main process returned only an error (on stderror)
nextline = process.stdout.readline()
if nextline == '' and process.poll() is not None:
break
if nextline != "":
lines.append(nextline)
process.wait()
if len(lines) == 0:
raise Exception("Unable to get output from call to java -version")
versionLine = lines[0].replace("\n", "").replace("\r", "")
match = re.match('(java|openjdk) version "(?P<major>\d+)(\.(?P<minor>\d+)\.(?P<patch>\d)+[\-_\w]*)?".*', versionLine)
if match is None:
raise Exception("Unable to determine java version from string " + lines[0])
javaMajor = int(match.group("major"))
javaMinor = int(match.group("minor")) if match.group("minor") is not None else 0
javaVersion = 0
if (javaMajor == 1 and javaMinor < 8) or (javaMajor > 1 and javaMajor < 8):
logger.error("Found incompatible java version '" + versionLine + "'")
sys.exit(-1)
if javaMajor == 1 and javaMinor == 8:
javaVersion = 8
else:
javaVersion = javaMajor
logger.info("Determined java version as '%d' from version string '%s'", javaVersion, versionLine)
return javaVersion
except Exception as e:
logger.error("Unable to determine java version; make sure Java is installed and callable. Error message: " + str(e))
sys.exit(-1)
if __name__ == '__main__':
GracefulKiller()
parser = argparse.ArgumentParser(description='NZBHydra 2')
parser.add_argument('--java', action='store', help='Full path to java executable', default="java")
parser.add_argument('--debugport', action='store', help='Set debug port to enable remote debugging', default=None)
parser.add_argument('--daemon', '-D', action='store_true', help='Run as daemon. *nix only', default=False)
parser.add_argument('--pidfile', action='store', help='Path to PID file. Only relevant with daemon argument', default="nzbhydra2.pid")
parser.add_argument('--nopidfile', action='store_true', help='Disable writing of PID file. Only relevant with daemon argument', default=False)
parser.add_argument('--nocolors', action='store_true', help='Disable color coded console output (disabled on Windows by default)', default=False)
parser.add_argument('--listfiles', action='store', help='Lists all files in given folder and quits. For debugging docker', default=None)
# Pass to main process
parser.add_argument('--datafolder', action='store', help='Set the main data folder containing config, database, etc using an absolute path', default=os.path.join(getBasePath(), "data"))
parser.add_argument('--xmx', action='store', help='Java Xmx setting in MB (e.g. 256)', default=None)
parser.add_argument('--quiet', action='store_true', help='Set to disable all console output', default=False)
parser.add_argument('--host', action='store', help='Set the host')
parser.add_argument('--port', action='store', help='Set the port')
parser.add_argument('--baseurl', action='store', help='Set the base URL (e.g. /nzbhydra)')
parser.add_argument('--nobrowser', action='store_true', help='Set to disable opening of browser at startup', default=False)
parser.add_argument('--debug', action='store_true', help='Start with more debugging output', default=False)
# Main process actions
parser.add_argument('--repairdb', action='store', help='Attempt to repair the database. Provide path to database file as parameter')
parser.add_argument('--version', action='store_true', help='Print version')
# Internal logic
parser.add_argument('--restarted', action='store_true', default=False, help=argparse.SUPPRESS)
args, unknownArgs = parser.parse_known_args()
setupLogger()
# Delete old files from last backup
oldFiles = [f for f in os.listdir(getBasePath()) if os.path.isfile(os.path.join(getBasePath(), f)) and f.endswith(".old")]
if len(oldFiles) > 0:
logger.info("Deleting .old files from last update")
for f in oldFiles:
logger.debug("Deleting file %s", f)
os.remove(f)
if not (os.path.isabs(args.datafolder)):
args.datafolder = os.path.join(os.getcwd(), args.datafolder)
logger.info("Data folder path is not absolute. Will assume " + args.datafolder + " was meant")
# Delete old control id file if it exists. Shouldn't ever exist or if it does it should be overwritten by main process, but who knows
controlIdFilePath = os.path.join(args.datafolder, "control.id")
if os.path.exists(controlIdFilePath):
os.remove(controlIdFilePath)
doStart = True
if "--version" in unknownArgs or "--help" in unknownArgs:
# no fancy shit, just start the file
startup()
elif args.listfiles is not None:
path = args.listfiles
curpath = os.path.dirname(os.path.realpath(__file__))
if not os.path.isabs(path):
path = os.path.join(curpath, path)
logger.info("Listing files in %s", path)
list_files(os.path.dirname(path))
else:
if args.daemon:
logger.info("Daemonizing...")
daemonize(args.pidfile, args.nopidfile)
while doStart:
process = startup()
if process is None:
logger.debug("No process found, exiting")
sys.exit(-1)
if terminatedByWrapper:
logger.debug("Shutting down because child process was terminated by us after getting signal")
sys.exit(0)
if process.returncode == 1:
handleUnexpectedExit()
args.restarted = True
# Try to read control code from file because under linux when started from the wrapper the return code is always 0
controlCode = 0
try:
with open(controlIdFilePath, "r") as f:
controlCode = int(f.readline())
logger.debug("Control code read from file %s: %d", controlIdFilePath, controlCode)
except Exception as e:
controlCode = process.returncode
if not (args.version or args.repairdb):
logger.warn("Unable to read control ID from %s: %s. Falling back to process return code %d", controlIdFilePath, e, controlCode)
if os.path.exists(controlIdFilePath):
try:
logger.debug("Deleting old control ID file %s", controlIdFilePath)
os.remove(controlIdFilePath)
except Exception as e:
logger.error("Unable to delete control ID file %s: %s", controlIdFilePath, e)
if controlCode == 11:
logger.info("NZBHydra main process has terminated for updating")
update()
doStart = True
elif controlCode == 22:
logger.info("NZBHydra main process has terminated for restart")
doStart = True
elif controlCode == 33:
logger.info("NZBHydra main process has terminated for restoration")
doStart = restore()
logger.info("Restoration successful")
doStart = True
elif args.version or args.repairdb:
# Just quit without further ado, help was printed by main process
doStart = False
else:
logger.info("NZBHydra main process has terminated for shutdown")
doStart = False

6
news/nzbhydra2/pkg-descr Normal file
View File

@ -0,0 +1,6 @@
NZBHydra 2 is a meta search for NZB indexers. It provides easy access to a
number of raw and newznab based indexers. You can search all your indexers
from one place and use it as an indexer source for tools like Sonarr,
Radarr or CouchPotato.
WWW: https://github.com/theotherp/nzbhydra2