adminandClaude Opus 5
79843aa2ae
Erster Stand der Hintergrundprozesse, die auf der Synology unter /volume1/homes/wagner/SolarManager laufen: der Manager selbst, die Sammler je Geraet, die MQTT-Bruecke, der Wecker und - neu hinzugezogen - der AutoAction-Runner, der als Hintergrundprozess hierher gehoert und nicht ins Web-Verzeichnis. Zugangsdaten stehen nicht mehr im Quelltext, sondern in config.ini, die nicht mit eingecheckt wird. Vorlage ist config.ini.example, gelesen wird sie von konfig.py. Betroffen waren solarManager.py (Datenbank und Wattpilot), zeit.py, gatherWaterData.py, wecker.py und skoda_testdaten.py, das sich das Passwort bisher aus dem Quelltext eines anderen Moduls herausgesucht hat. Die Kia-Anbindung ist mit dem Fahrzeug entfallen: kiaTest.py, gatherCarData.py und hyundai_kia_connect_api sind nicht mehr dabei, ebenso gatherInverterData.py, auf das nur noch eine auskommentierte Zeile zeigte. Die mitgelieferten Bibliotheken bleiben im Repository - die NAS hat kein pip, sie muessen neben den Skripten liegen. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
510 lines
12 KiB
Python
510 lines
12 KiB
Python
import warnings
|
|
from http import HTTPStatus
|
|
from typing import Any, Iterable, Optional, Set, Tuple
|
|
|
|
from multidict import CIMultiDict
|
|
from yarl import URL
|
|
|
|
from . import hdrs
|
|
from .helpers import CookieMixin
|
|
from .typedefs import LooseHeaders, StrOrURL
|
|
|
|
__all__ = (
|
|
"HTTPException",
|
|
"HTTPError",
|
|
"HTTPRedirection",
|
|
"HTTPSuccessful",
|
|
"HTTPOk",
|
|
"HTTPCreated",
|
|
"HTTPAccepted",
|
|
"HTTPNonAuthoritativeInformation",
|
|
"HTTPNoContent",
|
|
"HTTPResetContent",
|
|
"HTTPPartialContent",
|
|
"HTTPMove",
|
|
"HTTPMultipleChoices",
|
|
"HTTPMovedPermanently",
|
|
"HTTPFound",
|
|
"HTTPSeeOther",
|
|
"HTTPNotModified",
|
|
"HTTPUseProxy",
|
|
"HTTPTemporaryRedirect",
|
|
"HTTPPermanentRedirect",
|
|
"HTTPClientError",
|
|
"HTTPBadRequest",
|
|
"HTTPUnauthorized",
|
|
"HTTPPaymentRequired",
|
|
"HTTPForbidden",
|
|
"HTTPNotFound",
|
|
"HTTPMethodNotAllowed",
|
|
"HTTPNotAcceptable",
|
|
"HTTPProxyAuthenticationRequired",
|
|
"HTTPRequestTimeout",
|
|
"HTTPConflict",
|
|
"HTTPGone",
|
|
"HTTPLengthRequired",
|
|
"HTTPPreconditionFailed",
|
|
"HTTPRequestEntityTooLarge",
|
|
"HTTPRequestURITooLong",
|
|
"HTTPUnsupportedMediaType",
|
|
"HTTPRequestRangeNotSatisfiable",
|
|
"HTTPExpectationFailed",
|
|
"HTTPMisdirectedRequest",
|
|
"HTTPUnprocessableEntity",
|
|
"HTTPFailedDependency",
|
|
"HTTPUpgradeRequired",
|
|
"HTTPPreconditionRequired",
|
|
"HTTPTooManyRequests",
|
|
"HTTPRequestHeaderFieldsTooLarge",
|
|
"HTTPUnavailableForLegalReasons",
|
|
"HTTPServerError",
|
|
"HTTPInternalServerError",
|
|
"HTTPNotImplemented",
|
|
"HTTPBadGateway",
|
|
"HTTPServiceUnavailable",
|
|
"HTTPGatewayTimeout",
|
|
"HTTPVersionNotSupported",
|
|
"HTTPVariantAlsoNegotiates",
|
|
"HTTPInsufficientStorage",
|
|
"HTTPNotExtended",
|
|
"HTTPNetworkAuthenticationRequired",
|
|
)
|
|
|
|
|
|
############################################################
|
|
# HTTP Exceptions
|
|
############################################################
|
|
|
|
|
|
class HTTPException(CookieMixin, Exception):
|
|
# You should set in subclasses:
|
|
# status = 200
|
|
|
|
status_code = -1
|
|
empty_body = False
|
|
default_reason = "" # Initialized at the end of the module
|
|
|
|
def __init__(
|
|
self,
|
|
*,
|
|
headers: Optional[LooseHeaders] = None,
|
|
reason: Optional[str] = None,
|
|
text: Optional[str] = None,
|
|
content_type: Optional[str] = None,
|
|
) -> None:
|
|
super().__init__()
|
|
if reason is None:
|
|
reason = self.default_reason
|
|
|
|
if text is None:
|
|
if not self.empty_body:
|
|
text = f"{self.status_code}: {reason}"
|
|
else:
|
|
if self.empty_body:
|
|
warnings.warn(
|
|
"text argument is deprecated for HTTP status {} "
|
|
"since 4.0 and scheduled for removal in 5.0 (#3462),"
|
|
"the response should be provided without a body".format(
|
|
self.status_code
|
|
),
|
|
DeprecationWarning,
|
|
stacklevel=2,
|
|
)
|
|
|
|
if headers is not None:
|
|
real_headers = CIMultiDict(headers)
|
|
else:
|
|
real_headers = CIMultiDict()
|
|
|
|
if content_type is not None:
|
|
if not text:
|
|
warnings.warn(
|
|
"content_type without text is deprecated "
|
|
"since 4.0 and scheduled for removal in 5.0 "
|
|
"(#3462)",
|
|
DeprecationWarning,
|
|
stacklevel=2,
|
|
)
|
|
real_headers[hdrs.CONTENT_TYPE] = content_type
|
|
elif hdrs.CONTENT_TYPE not in real_headers and text:
|
|
real_headers[hdrs.CONTENT_TYPE] = "text/plain"
|
|
|
|
self._reason = reason
|
|
self._text = text
|
|
self._headers = real_headers
|
|
self.args = ()
|
|
|
|
def __bool__(self) -> bool:
|
|
return True
|
|
|
|
@property
|
|
def status(self) -> int:
|
|
return self.status_code
|
|
|
|
@property
|
|
def reason(self) -> str:
|
|
return self._reason
|
|
|
|
@property
|
|
def text(self) -> Optional[str]:
|
|
return self._text
|
|
|
|
@property
|
|
def headers(self) -> "CIMultiDict[str]":
|
|
return self._headers
|
|
|
|
def __str__(self) -> str:
|
|
return self.reason
|
|
|
|
def __repr__(self) -> str:
|
|
return f"<{self.__class__.__name__}: {self.reason}>"
|
|
|
|
__reduce__ = object.__reduce__
|
|
|
|
def __getnewargs__(self) -> Tuple[Any, ...]:
|
|
return self.args
|
|
|
|
|
|
class HTTPError(HTTPException):
|
|
"""Base class for exceptions with status codes in the 400s and 500s."""
|
|
|
|
|
|
class HTTPRedirection(HTTPException):
|
|
"""Base class for exceptions with status codes in the 300s."""
|
|
|
|
|
|
class HTTPSuccessful(HTTPException):
|
|
"""Base class for exceptions with status codes in the 200s."""
|
|
|
|
|
|
class HTTPOk(HTTPSuccessful):
|
|
status_code = 200
|
|
|
|
|
|
class HTTPCreated(HTTPSuccessful):
|
|
status_code = 201
|
|
|
|
|
|
class HTTPAccepted(HTTPSuccessful):
|
|
status_code = 202
|
|
|
|
|
|
class HTTPNonAuthoritativeInformation(HTTPSuccessful):
|
|
status_code = 203
|
|
|
|
|
|
class HTTPNoContent(HTTPSuccessful):
|
|
status_code = 204
|
|
empty_body = True
|
|
|
|
|
|
class HTTPResetContent(HTTPSuccessful):
|
|
status_code = 205
|
|
empty_body = True
|
|
|
|
|
|
class HTTPPartialContent(HTTPSuccessful):
|
|
status_code = 206
|
|
|
|
|
|
############################################################
|
|
# 3xx redirection
|
|
############################################################
|
|
|
|
|
|
class HTTPMove(HTTPRedirection):
|
|
def __init__(
|
|
self,
|
|
location: StrOrURL,
|
|
*,
|
|
headers: Optional[LooseHeaders] = None,
|
|
reason: Optional[str] = None,
|
|
text: Optional[str] = None,
|
|
content_type: Optional[str] = None,
|
|
) -> None:
|
|
if not location:
|
|
raise ValueError("HTTP redirects need a location to redirect to.")
|
|
super().__init__(
|
|
headers=headers, reason=reason, text=text, content_type=content_type
|
|
)
|
|
self._location = URL(location)
|
|
self.headers["Location"] = str(self.location)
|
|
|
|
@property
|
|
def location(self) -> URL:
|
|
return self._location
|
|
|
|
|
|
class HTTPMultipleChoices(HTTPMove):
|
|
status_code = 300
|
|
|
|
|
|
class HTTPMovedPermanently(HTTPMove):
|
|
status_code = 301
|
|
|
|
|
|
class HTTPFound(HTTPMove):
|
|
status_code = 302
|
|
|
|
|
|
# This one is safe after a POST (the redirected location will be
|
|
# retrieved with GET):
|
|
class HTTPSeeOther(HTTPMove):
|
|
status_code = 303
|
|
|
|
|
|
class HTTPNotModified(HTTPRedirection):
|
|
# FIXME: this should include a date or etag header
|
|
status_code = 304
|
|
empty_body = True
|
|
|
|
|
|
class HTTPUseProxy(HTTPMove):
|
|
# Not a move, but looks a little like one
|
|
status_code = 305
|
|
|
|
|
|
class HTTPTemporaryRedirect(HTTPMove):
|
|
status_code = 307
|
|
|
|
|
|
class HTTPPermanentRedirect(HTTPMove):
|
|
status_code = 308
|
|
|
|
|
|
############################################################
|
|
# 4xx client error
|
|
############################################################
|
|
|
|
|
|
class HTTPClientError(HTTPError):
|
|
pass
|
|
|
|
|
|
class HTTPBadRequest(HTTPClientError):
|
|
status_code = 400
|
|
|
|
|
|
class HTTPUnauthorized(HTTPClientError):
|
|
status_code = 401
|
|
|
|
|
|
class HTTPPaymentRequired(HTTPClientError):
|
|
status_code = 402
|
|
|
|
|
|
class HTTPForbidden(HTTPClientError):
|
|
status_code = 403
|
|
|
|
|
|
class HTTPNotFound(HTTPClientError):
|
|
status_code = 404
|
|
|
|
|
|
class HTTPMethodNotAllowed(HTTPClientError):
|
|
status_code = 405
|
|
|
|
def __init__(
|
|
self,
|
|
method: str,
|
|
allowed_methods: Iterable[str],
|
|
*,
|
|
headers: Optional[LooseHeaders] = None,
|
|
reason: Optional[str] = None,
|
|
text: Optional[str] = None,
|
|
content_type: Optional[str] = None,
|
|
) -> None:
|
|
allow = ",".join(sorted(allowed_methods))
|
|
super().__init__(
|
|
headers=headers, reason=reason, text=text, content_type=content_type
|
|
)
|
|
self.headers["Allow"] = allow
|
|
self._allowed: Set[str] = set(allowed_methods)
|
|
self._method = method
|
|
|
|
@property
|
|
def allowed_methods(self) -> Set[str]:
|
|
return self._allowed
|
|
|
|
@property
|
|
def method(self) -> str:
|
|
return self._method
|
|
|
|
|
|
class HTTPNotAcceptable(HTTPClientError):
|
|
status_code = 406
|
|
|
|
|
|
class HTTPProxyAuthenticationRequired(HTTPClientError):
|
|
status_code = 407
|
|
|
|
|
|
class HTTPRequestTimeout(HTTPClientError):
|
|
status_code = 408
|
|
|
|
|
|
class HTTPConflict(HTTPClientError):
|
|
status_code = 409
|
|
|
|
|
|
class HTTPGone(HTTPClientError):
|
|
status_code = 410
|
|
|
|
|
|
class HTTPLengthRequired(HTTPClientError):
|
|
status_code = 411
|
|
|
|
|
|
class HTTPPreconditionFailed(HTTPClientError):
|
|
status_code = 412
|
|
|
|
|
|
class HTTPRequestEntityTooLarge(HTTPClientError):
|
|
status_code = 413
|
|
|
|
def __init__(self, max_size: int, actual_size: int, **kwargs: Any) -> None:
|
|
kwargs.setdefault(
|
|
"text",
|
|
"Maximum request body size {} exceeded, "
|
|
"actual body size {}".format(max_size, actual_size),
|
|
)
|
|
super().__init__(**kwargs)
|
|
|
|
|
|
class HTTPRequestURITooLong(HTTPClientError):
|
|
status_code = 414
|
|
|
|
|
|
class HTTPUnsupportedMediaType(HTTPClientError):
|
|
status_code = 415
|
|
|
|
|
|
class HTTPRequestRangeNotSatisfiable(HTTPClientError):
|
|
status_code = 416
|
|
|
|
|
|
class HTTPExpectationFailed(HTTPClientError):
|
|
status_code = 417
|
|
|
|
|
|
class HTTPMisdirectedRequest(HTTPClientError):
|
|
status_code = 421
|
|
|
|
|
|
class HTTPUnprocessableEntity(HTTPClientError):
|
|
status_code = 422
|
|
|
|
|
|
class HTTPFailedDependency(HTTPClientError):
|
|
status_code = 424
|
|
|
|
|
|
class HTTPUpgradeRequired(HTTPClientError):
|
|
status_code = 426
|
|
|
|
|
|
class HTTPPreconditionRequired(HTTPClientError):
|
|
status_code = 428
|
|
|
|
|
|
class HTTPTooManyRequests(HTTPClientError):
|
|
status_code = 429
|
|
|
|
|
|
class HTTPRequestHeaderFieldsTooLarge(HTTPClientError):
|
|
status_code = 431
|
|
|
|
|
|
class HTTPUnavailableForLegalReasons(HTTPClientError):
|
|
status_code = 451
|
|
|
|
def __init__(
|
|
self,
|
|
link: StrOrURL,
|
|
*,
|
|
headers: Optional[LooseHeaders] = None,
|
|
reason: Optional[str] = None,
|
|
text: Optional[str] = None,
|
|
content_type: Optional[str] = None,
|
|
) -> None:
|
|
super().__init__(
|
|
headers=headers, reason=reason, text=text, content_type=content_type
|
|
)
|
|
self.headers["Link"] = f'<{str(link)}>; rel="blocked-by"'
|
|
self._link = URL(link)
|
|
|
|
@property
|
|
def link(self) -> URL:
|
|
return self._link
|
|
|
|
|
|
############################################################
|
|
# 5xx Server Error
|
|
############################################################
|
|
# Response status codes beginning with the digit "5" indicate cases in
|
|
# which the server is aware that it has erred or is incapable of
|
|
# performing the request. Except when responding to a HEAD request, the
|
|
# server SHOULD include an entity containing an explanation of the error
|
|
# situation, and whether it is a temporary or permanent condition. User
|
|
# agents SHOULD display any included entity to the user. These response
|
|
# codes are applicable to any request method.
|
|
|
|
|
|
class HTTPServerError(HTTPError):
|
|
pass
|
|
|
|
|
|
class HTTPInternalServerError(HTTPServerError):
|
|
status_code = 500
|
|
|
|
|
|
class HTTPNotImplemented(HTTPServerError):
|
|
status_code = 501
|
|
|
|
|
|
class HTTPBadGateway(HTTPServerError):
|
|
status_code = 502
|
|
|
|
|
|
class HTTPServiceUnavailable(HTTPServerError):
|
|
status_code = 503
|
|
|
|
|
|
class HTTPGatewayTimeout(HTTPServerError):
|
|
status_code = 504
|
|
|
|
|
|
class HTTPVersionNotSupported(HTTPServerError):
|
|
status_code = 505
|
|
|
|
|
|
class HTTPVariantAlsoNegotiates(HTTPServerError):
|
|
status_code = 506
|
|
|
|
|
|
class HTTPInsufficientStorage(HTTPServerError):
|
|
status_code = 507
|
|
|
|
|
|
class HTTPNotExtended(HTTPServerError):
|
|
status_code = 510
|
|
|
|
|
|
class HTTPNetworkAuthenticationRequired(HTTPServerError):
|
|
status_code = 511
|
|
|
|
|
|
def _initialize_default_reason() -> None:
|
|
for obj in globals().values():
|
|
if isinstance(obj, type) and issubclass(obj, HTTPException):
|
|
if obj.status_code >= 0:
|
|
try:
|
|
status = HTTPStatus(obj.status_code)
|
|
obj.default_reason = status.phrase
|
|
except ValueError:
|
|
pass
|
|
|
|
|
|
_initialize_default_reason()
|
|
del _initialize_default_reason
|