From 949924dc8aa3c643171bf36ea1b73e3b1dd2641e Mon Sep 17 00:00:00 2001
From: Cyber MacGeddon <cybermaggedon@gmail.com>
Date: Sun, 4 May 2025 21:41:01 +0100
Subject: [PATCH] Processing schema

---
 .../trustgraph/librarian/librarian.py         | 15 ++++-----
 .../trustgraph/librarian/table_store.py       | 31 ++++++++++++++++++-
 2 files changed, 36 insertions(+), 10 deletions(-)

diff --git a/trustgraph-flow/trustgraph/librarian/librarian.py b/trustgraph-flow/trustgraph/librarian/librarian.py
index 5bf5a672..da716ae5 100644
--- a/trustgraph-flow/trustgraph/librarian/librarian.py
+++ b/trustgraph-flow/trustgraph/librarian/librarian.py
@@ -203,19 +203,16 @@ class Librarian:
         )
 
     async def list_processing(self, request):
-        raise RuntimeError("Not implemented")
 
-    async def list(self, user, collection):
+        procs = await self.table_store.list_processing(request.user)
 
-        raise RuntimeError("Not implemented")
-
-        info = self.table_store.list(user, collection)
-
-        print(">>", info)
+        print(procs)
 
         return LibrarianResponse(
             error = None,
-            document = None,
-            info = info,
+            document_metadata = None,
+            content = None,
+            document_metadatas = None,
+            processing_metadatas = procs,
         )
 
diff --git a/trustgraph-flow/trustgraph/librarian/table_store.py b/trustgraph-flow/trustgraph/librarian/table_store.py
index b80d62b8..73d39c79 100644
--- a/trustgraph-flow/trustgraph/librarian/table_store.py
+++ b/trustgraph-flow/trustgraph/librarian/table_store.py
@@ -211,7 +211,7 @@ class TableStore:
             WHERE user = ?
         """)
 
-        self.list_document_by_collection_stmt = self.cassandra.prepare("""
+        self.list_document_by_tag_stmt = self.cassandra.prepare("""
             SELECT
                 id, time, kind, title, comments, metadata, tags, object_id
             FROM document
@@ -219,6 +219,35 @@ class TableStore:
             ALLOW FILTERING
         """)
 
+        self.insert_processing_stmt = self.cassandra.prepare("""
+            INSERT INTO processing
+            (
+                id, document_id, time,
+                flow, user, collection,
+                tags,
+            )
+            VALUES (?, ?, ?, ?, ?, ?, ?)
+        """)
+
+        self.delete_processing_stmt = self.cassandra.prepare("""
+            DELETE FROM processing
+            WHERE user = ? AND id = ?
+        """)
+
+        self.test_processing_exists_stmt = self.cassandra.prepare("""
+            SELECT id
+            FROM processing
+            WHERE user = ? AND id = ?
+            LIMIT 1
+        """)
+
+        self.list_processing_stmt = self.cassandra.prepare("""
+            SELECT
+                id, document_id, time, flow, collection, tags
+            FROM processing
+            WHERE user = ?
+        """)
+
         return
 
         self.insert_triples_stmt = self.cassandra.prepare("""