apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-07-22 19:51:02 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Reified triples support

Browse source
This commit is contained in:
Cyber MacGeddon 2026-03-05 21:24:04 +00:00
parent d6d74fb2ef
commit 78dba08ddc
1 changed files with 36 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

37
trustgraph-flow/trustgraph/storage/triples/cassandra/write.py
View file

@ -27,13 +27,39 @@ default_ident = "triples-write"
def serialize_triple(triple):
"""Serialize a Triple object to JSON for storage."""
"""
Serialize a Triple object or dict to JSON for storage.
Handles both Triple objects (with .s, .p, .o attributes) and
dict representations (with "s", "p", "o" keys) since message
deserialization may not fully reconstruct nested objects.
"""
if triple is None:
return None
def term_to_dict(term):
if term is None:
return None
# Handle dict representation (from message deserialization)
if isinstance(term, dict):
term_type = term.get("type", "")
result = {"type": term_type}
if term_type == IRI:
result["iri"] = term.get("iri", "")
elif term_type == LITERAL:
result["value"] = term.get("value", "")
if term.get("datatype"):
result["datatype"] = term.get("datatype")
if term.get("language"):
result["language"] = term.get("language")
elif term_type == BLANK:
result["id"] = term.get("id", "")
elif term_type == TRIPLE:
result["triple"] = serialize_triple(term.get("triple"))
return result
# Handle Term object
result = {"type": term.type}
if term.type == IRI:
result["iri"] = term.iri
@ -50,6 +76,15 @@ def serialize_triple(triple):
result["triple"] = serialize_triple(term.triple)
return result
# Handle dict representation
if isinstance(triple, dict):
return json.dumps({
"s": term_to_dict(triple.get("s")),
"p": term_to_dict(triple.get("p")),
"o": term_to_dict(triple.get("o")),
})
# Handle Triple object
return json.dumps({
"s": term_to_dict(triple.s),
"p": term_to_dict(triple.p),