mirror of
https://github.com/9001/copyparty.git
synced 2026-04-12 15:22:32 -06:00
c6965f0614
can check if the current version has a known vulnerability, with the option to panic and exit if so, and otherwise show a warning in the controlpanel for admins --------- Co-authored-by: ed <s@ocv.me>
75 lines
2 KiB
Python
75 lines
2 KiB
Python
# coding: utf-8
|
|
from __future__ import print_function, unicode_literals
|
|
|
|
import os
|
|
import threading
|
|
|
|
from .__init__ import TYPE_CHECKING
|
|
from .broker_util import BrokerCli, ExceptionalQueue, NotExQueue
|
|
from .httpsrv import HttpSrv
|
|
from .util import HMaccas
|
|
|
|
if TYPE_CHECKING:
|
|
from .svchub import SvcHub
|
|
|
|
if True: # pylint: disable=using-constant-test
|
|
from typing import Any, Union
|
|
|
|
|
|
class BrokerThr(BrokerCli):
|
|
"""external api; behaves like BrokerMP but using plain threads"""
|
|
|
|
def __init__(self, hub: "SvcHub") -> None:
|
|
super(BrokerThr, self).__init__()
|
|
|
|
self.hub = hub
|
|
self.log = hub.log
|
|
self.args = hub.args
|
|
self.asrv = hub.asrv
|
|
|
|
self.mutex = threading.Lock()
|
|
self.num_workers = 1
|
|
|
|
# instantiate all services here (TODO: inheritance?)
|
|
self.iphash = HMaccas(os.path.join(self.args.E.cfg, "iphash"), 8)
|
|
self.httpsrv = HttpSrv(self, None)
|
|
self.reload = self.noop
|
|
self.reload_sessions = self.noop
|
|
|
|
def shutdown(self) -> None:
|
|
# self.log("broker", "shutting down")
|
|
self.httpsrv.shutdown()
|
|
|
|
def noop(self) -> None:
|
|
pass
|
|
|
|
def ask(self, dest: str, *args: Any) -> Union[ExceptionalQueue, NotExQueue]:
|
|
|
|
# new ipc invoking managed service in hub
|
|
obj = self.hub
|
|
for node in dest.split("."):
|
|
obj = getattr(obj, node)
|
|
|
|
return NotExQueue(obj(*args)) # type: ignore
|
|
|
|
def say(self, dest: str, *args: Any) -> None:
|
|
if dest.startswith("httpsrv."):
|
|
if dest == "httpsrv.listen":
|
|
self.httpsrv.listen(args[0], 1)
|
|
return
|
|
|
|
if dest == "httpsrv.set_netdevs":
|
|
self.httpsrv.set_netdevs(args[0])
|
|
return
|
|
|
|
if dest == "httpsrv.set_bad_ver":
|
|
self.httpsrv.set_bad_ver()
|
|
return
|
|
|
|
# new ipc invoking managed service in hub
|
|
obj = self.hub
|
|
for node in dest.split("."):
|
|
obj = getattr(obj, node)
|
|
|
|
obj(*args) # type: ignore
|