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.