Mercurial > code > home > repos > rdfdb
changeset 107:19100db34354
s/Db/SharedGraph/
author | drewp@bigasterisk.com |
---|---|
date | Mon, 30 May 2022 22:44:10 -0700 |
parents | b0f922c8c728 |
children | a4a060241c73 |
files | rdfdb/service.py rdfdb/shared_graph.py |
diffstat | 2 files changed, 7 insertions(+), 7 deletions(-) [+] |
line wrap: on
line diff
--- a/rdfdb/service.py Mon May 30 22:43:07 2022 -0700 +++ b/rdfdb/service.py Mon May 30 22:44:10 2022 -0700 @@ -16,7 +16,7 @@ from rdfdb.file_vs_uri import DirUriMap from rdfdb.patch import Patch -from .shared_graph import Db +from rdfdb.shared_graph import SharedGraph log = logging.getLogger('rdfdb') @@ -40,7 +40,7 @@ """ encoding = "text" - def __init__(self, db: Db, *a, **kw): + def __init__(self, db: SharedGraph, *a, **kw): WebSocketEndpoint.__init__(self, *a, **kw) self.db = db self.connectionId = f'WS{next(_wsClientSerial)}' # unneeded? @@ -77,7 +77,7 @@ self.db.clientDisconnected(self.connectionId) -def get_graph(db: Db, request: Request) -> Response: +def get_graph(db: SharedGraph, request: Request) -> Response: accept = request.headers.get('accept', '') if accept == 'text/plain': format = 'nt' @@ -88,7 +88,7 @@ return PlainTextResponse(db.graph.serialize(format=format)) -async def post_prefixes(db: Db, request: Request) -> Response: +async def post_prefixes(db: SharedGraph, request: Request) -> Response: suggestion = await request.json() db.addPrefixes( ctx=URIRef(suggestion['ctx']), # @@ -111,7 +111,7 @@ log.setLevel(logging.DEBUG if 1 else logging.INFO) log.info('setup watches') - db = Db(dirUriMap=dirUriMap, prefixes=prefixes) + db = SharedGraph(dirUriMap=dirUriMap, prefixes=prefixes) app = Starlette( debug=True,
--- a/rdfdb/shared_graph.py Mon May 30 22:43:07 2022 -0700 +++ b/rdfdb/shared_graph.py Mon May 30 22:44:10 2022 -0700 @@ -14,7 +14,7 @@ from rdfdb.multigraph import Multigraph from rdfdb.patch import ALLSTMTS, EmptyPatch, Patch -from .watched_graphs import WatchedGraphs +from rdfdb.watched_graphs import WatchedGraphs log = logging.getLogger('shared') log.info('hello shared') @@ -25,7 +25,7 @@ STAT_MAPPED_GRAPH_FILES = Gauge('mapped_graph_files', 'mapped graph files') -class Db(object): +class SharedGraph(object): """ the master graph, all the connected clients, all the files we're watching. Handles the fan-out to other clients.