# Stubs for rdfdb.service (Python 3)
#
# NOTE: This dynamically typed stub was automatically generated by stubgen.

import cyclone.websocket
from typing import Any, Optional, Set

log: Any

class WebsocketDisconnect(ValueError): ...

def sendGraphToClient(graph: Any, client: Any) -> None: ...

class Client:
    label: Any = ...
    updateUri: Any = ...
    def __init__(self, updateUri: bytes, label: Any) -> Any: ...
    def sendPatch(self, p: Any): ...

class WsClient:
    updateUri: Any = ...
    sendMessage: Any = ...
    def __init__(self, connectionId: Any, sendMessage: Any) -> None: ...
    def sendPatch(self, p: Any): ...

class WatchedFiles:
    dirUriMap: Any = ...
    addlPrefixes: Any = ...
    graphFiles: Any = ...
    notifier: Any = ...
    def __init__(self, dirUriMap: Any, patch: Any, getSubgraph: Any, addlPrefixes: Any) -> None: ...
    initialLoad: bool = ...
    def findAndLoadFiles(self) -> None: ...
    def dirChange(self, watch: Any, path: Any, mask: Any) -> None: ...
    def watchFile(self, inFile: Any) -> None: ...
    def aboutToPatch(self, ctx: Any) -> None: ...
    def dirtyFiles(self, ctxs: Any) -> None: ...

class Db:
    clients: Any = ...
    graph: Any = ...
    watchedFiles: Any = ...
    def __init__(self, dirUriMap: Any, addlPrefixes: Any) -> None: ...
    def patch(self, p: Any, dueToFileChange: bool = ...) -> None: ...
    def clientErrored(self, err: Any, c: Any) -> None: ...
    def summarizeToLog(self) -> None: ...
    def getSubgraph(self, uri: Any): ...
    def addClient(self, newClient: Any) -> None: ...
    def sendClientsToAllLivePages(self) -> None: ...

class GraphResource(cyclone.web.RequestHandler):
    def get(self) -> None: ...

class Patches(cyclone.web.RequestHandler):
    put: Any = ...
    def __init__(self, *args: Any, **kw: Any) -> None: ...
    def get(self) -> None: ...

class GraphClients(cyclone.web.RequestHandler):
    def get(self) -> None: ...
    def post(self) -> None: ...

class Prefixes(cyclone.web.RequestHandler):
    def post(self) -> None: ...

class WebsocketClient(cyclone.websocket.WebSocketHandler):
    wsClient: Any = ...
    def connectionMade(self, *args: Any, **kwargs: Any) -> None: ...
    def connectionLost(self, reason: Any) -> None: ...
    def messageReceived(self, message: Any) -> None: ...

class Live(cyclone.websocket.WebSocketHandler):
    def connectionMade(self, *args: Any, **kwargs: Any) -> None: ...
    def connectionLost(self, reason: Any) -> None: ...
    def messageReceived(self, message: Any) -> None: ...

liveClients: Set[Live]

def sendToLiveClients(d: Optional[Any] = ..., asJson: Optional[Any] = ...) -> None: ...

class NoExts(cyclone.web.StaticFileHandler):
    def get(self, path: Any, *args: Any, **kw: Any) -> None: ...

def main(dirUriMap: Optional[Any] = ..., prefixes: Optional[Any] = ..., port: int = ...) -> None: ...