diff --git a/stubs/cyclone/httpserver.pyi b/stubs/cyclone/httpserver.pyi new file mode 100644 --- /dev/null +++ b/stubs/cyclone/httpserver.pyi @@ -0,0 +1,43 @@ +# Stubs for cyclone.httpserver (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from twisted.protocols import basic +from typing import Any, Dict, Optional + +class _BadRequestException(Exception): ... + +class HTTPConnection(basic.LineReceiver): + no_keep_alive: bool = ... + content_length: Any = ... + request_callback: Any = ... + xheaders: Any = ... + def connectionMade(self) -> None: ... + def connectionLost(self, reason: Any) -> None: ... + def notifyFinish(self): ... + def lineReceived(self, line: Any) -> None: ... + def rawDataReceived(self, data: Any) -> None: ... + def write(self, chunk: Any) -> None: ... + def finish(self) -> None: ... + +class HTTPRequest: + method: str = ... + uri: str = ... + version: str = ... + headers: Dict[str, str] = ... + body: bytes = ... + remote_ip: str = ... + protocol: str = ... + host: str = ... + files: Any = ... + connection: HTTPConnection = ... + arguments: Any = ... + def __init__(self, method: Any, uri: Any, version: str = ..., headers: Optional[Any] = ..., body: Optional[Any] = ..., remote_ip: Optional[Any] = ..., protocol: Optional[Any] = ..., host: Optional[Any] = ..., files: Optional[Any] = ..., connection: Optional[Any] = ...) -> None: ... + def supports_http_1_1(self): ... + @property + def cookies(self): ... + def write(self, chunk: Any) -> None: ... + def finish(self) -> None: ... + def full_url(self): ... + def request_time(self): ... + def notifyFinish(self): ... diff --git a/stubs/cyclone/web.pyi b/stubs/cyclone/web.pyi --- a/stubs/cyclone/web.pyi +++ b/stubs/cyclone/web.pyi @@ -3,7 +3,8 @@ # NOTE: This dynamically typed stub was automatically generated by stubgen. from twisted.internet import protocol -from typing import Any, Optional, List +from typing import Any, Optional +from .httpserver import HTTPRequest class RequestHandler: SUPPORTED_METHODS: Any = ... @@ -11,11 +12,11 @@ class RequestHandler: no_keep_alive: bool = ... xsrf_cookie_name: str = ... application: Any = ... - request: Any = ... + request: HTTPRequest = ... path_args: Any = ... path_kwargs: Any = ... ui: Any = ... - def __init__(self, application: Any, request: Any, **kwargs: Any) -> None: ... + def __init__(self, application: Any, request: HTTPRequest, **kwargs: Any) -> None: ... @property def settings(self): ... diff --git a/stubs/cyclone/websocket.pyi b/stubs/cyclone/websocket.pyi --- a/stubs/cyclone/websocket.pyi +++ b/stubs/cyclone/websocket.pyi @@ -4,7 +4,7 @@ import cyclone.escape import cyclone.web -from typing import Any +from typing import Any, Dict, Union class _NotEnoughFrame(Exception): ... @@ -17,8 +17,8 @@ class WebSocketHandler(cyclone.web.Reque def headersReceived(self) -> None: ... def connectionMade(self, *args: Any, **kwargs: Any) -> None: ... def connectionLost(self, reason: Any) -> None: ... - def messageReceived(self, message: Any) -> None: ... - def sendMessage(self, message: Any) -> None: ... + def messageReceived(self, message: bytes) -> None: ... + def sendMessage(self, message: Union[str, Dict]) -> None: ... def forbidConnection(self, message: Any): ... class WebSocketProtocol: @@ -28,20 +28,20 @@ class WebSocketProtocol: def __init__(self, handler: Any) -> None: ... def acceptConnection(self) -> None: ... def rawDataReceived(self, data: Any) -> None: ... - def sendMessage(self, message: Any) -> None: ... + def sendMessage(self, message: Union[str, Dict]) -> None: ... class WebSocketProtocol17(WebSocketProtocol): def __init__(self, handler: Any) -> None: ... def acceptConnection(self) -> None: ... def rawDataReceived(self, data: Any) -> None: ... - def sendMessage(self, message: Any, code: int = ...) -> None: ... + def sendMessage(self, message: Union[str, Dict], code: int = ...) -> None: ... class WebSocketProtocol76(WebSocketProtocol): def __init__(self, handler: Any) -> None: ... def acceptConnection(self) -> None: ... def rawDataReceived(self, data: Any) -> None: ... def close(self) -> None: ... - def sendMessage(self, message: Any) -> None: ... + def sendMessage(self, message: Union[str, Dict]) -> None: ... class FrameDecodeError(Exception): ... diff --git a/stubs/greplin/scales/__init__.pyi b/stubs/greplin/scales/__init__.pyi --- a/stubs/greplin/scales/__init__.pyi +++ b/stubs/greplin/scales/__init__.pyi @@ -126,6 +126,8 @@ class NamedPmfDict(UserDict): class NamedPmfDictStat(Stat): ... +class RecentFpsStat(Stat): ... + class StateTimeStatDict(UserDict): parent: Any = ... instance: Any = ... diff --git a/stubs/twisted/protocols/__init__.py b/stubs/twisted/protocols/__init__.py new file mode 100644 diff --git a/stubs/twisted/protocols/basic.pyi b/stubs/twisted/protocols/basic.pyi new file mode 100644 --- /dev/null +++ b/stubs/twisted/protocols/basic.pyi @@ -0,0 +1,87 @@ +# Stubs for twisted.protocols.basic (Python 3) +# +# NOTE: This dynamically typed stub was automatically generated by stubgen. + +from twisted.internet import protocol +from typing import Any, Optional + +DEBUG: int + +class NetstringParseError(ValueError): ... +class IncompleteNetstring(Exception): ... + +class NetstringReceiver(protocol.Protocol): + MAX_LENGTH: int = ... + brokenPeer: int = ... + def makeConnection(self, transport: Any) -> None: ... + def sendString(self, string: Any) -> None: ... + def dataReceived(self, data: Any) -> None: ... + def stringReceived(self, string: Any) -> None: ... + +class LineOnlyReceiver(protocol.Protocol): + delimiter: bytes = ... + MAX_LENGTH: int = ... + def dataReceived(self, data: Any): ... + def lineReceived(self, line: Any) -> None: ... + def sendLine(self, line: Any): ... + def lineLengthExceeded(self, line: Any): ... + +class _PauseableMixin: + paused: bool = ... + def pauseProducing(self) -> None: ... + def resumeProducing(self) -> None: ... + def stopProducing(self) -> None: ... + +class LineReceiver(protocol.Protocol, _PauseableMixin): + line_mode: int = ... + delimiter: bytes = ... + MAX_LENGTH: int = ... + def clearLineBuffer(self): ... + def dataReceived(self, data: Any): ... + def setLineMode(self, extra: bytes = ...): ... + def setRawMode(self) -> None: ... + def rawDataReceived(self, data: Any) -> None: ... + def lineReceived(self, line: Any) -> None: ... + def sendLine(self, line: Any): ... + def lineLengthExceeded(self, line: Any): ... + +class StringTooLongError(AssertionError): ... + +class _RecvdCompatHack: + def __get__(self, oself: Any, type: Optional[Any] = ...): ... + +class IntNStringReceiver(protocol.Protocol, _PauseableMixin): + MAX_LENGTH: int = ... + recvd: Any = ... + def stringReceived(self, string: Any) -> None: ... + def lengthLimitExceeded(self, length: Any) -> None: ... + def dataReceived(self, data: Any) -> None: ... + def sendString(self, string: Any) -> None: ... + +class Int32StringReceiver(IntNStringReceiver): + structFormat: str = ... + prefixLength: Any = ... + +class Int16StringReceiver(IntNStringReceiver): + structFormat: str = ... + prefixLength: Any = ... + +class Int8StringReceiver(IntNStringReceiver): + structFormat: str = ... + prefixLength: Any = ... + +class StatefulStringProtocol: + state: str = ... + def stringReceived(self, string: Any) -> None: ... + +class FileSender: + CHUNK_SIZE: Any = ... + lastSent: str = ... + deferred: Any = ... + file: Any = ... + consumer: Any = ... + transform: Any = ... + def beginFileTransfer(self, file: Any, consumer: Any, transform: Optional[Any] = ...): ... + def resumeProducing(self) -> None: ... + def pauseProducing(self) -> None: ... + def stopProducing(self) -> None: ...