{_obsidian_pattern_tag_public}

[ ] need asyncio mqtt layer with:
health task connection
logging abuot conn breaks
subscribe with error except on handnler funcs
good unsub, maybe with weakref handlers
str types, no bytes
also pkg mongo_required like this. video-files needs it
[ ] can't kill uvicorn- add /health check service to everything. And maybe /metrics on a separate port too so they don't serve to the public. see https://gist.github.com/tenuki/ff67f87cba5c4c04fd08d9c800437477 or https://github.com/encode/uvicorn/discussions/1103

A library for python and typescript.

Each of these steps should be a one-liner to set up.

server boilerplate with metrics and auto index page:
- svr = StarletteServer()
- svr.serve() # if caller hasn't routed '/', serve auto index

py

SSE -> graph
- graph = GraphSseClient(url1)
- await graph.finishFirstRead()
graph -> simple served text (StaticGraph)
- (part of addGraphRoutes)
graph -> SSE (GraphEvents)
- svr.addGraphRoutes('name1', graph1)
graph -> sparql -> table
k8s json -> graph
- graph = K8sRead(type='Deploy', ns='default', name='deploy1', watch=True)
- but break this into json-fetch and jsonld-convert
mqtt json/etc -> graph
csv -> graph
- graph = FromCsv(r: csvReader)
file -> graph -> file
- graph = WatchFile(file: Path)
- await graph.finishFirstRead()
- graph = WatchTree(top: Path)
- await graph.finishFirstRead()
multiple graphs -> readonlygraphaggregate (collector)
- graph = PatchableAggregate([graph])
http request -> statement(s) (rdf_over_http.py)
- def handler1(stmt, requests): ...
- svr.addRdfStatementRoute('/path1', handler1)
- def handler2(graph, requests): ...
- svr.addGraphInputRoute('/path2', handler2)

js