Rework schema

trustgraph-base/trustgraph/schema/library.py

@@ -6,16 +6,52 @@ from . types import Error
 from . metadata import Metadata
 from . documents import Document, TextDocument
 
-# add
+# add-document
-#   -> (id, document)
+#   -> (document_id, document_metadata, content)
 #   <- ()
 #   <- (error)
 
-# list
+# remove-document
-#   -> (user, collection?)
+#   -> (document_id)
-#   <- (info)
+#   <- ()
 #   <- (error)
 
+# update-document
+#   -> (document_id, document_metadata)
+#   <- ()
+#   <- (error)
+
+# get-document-metadata
+#   -> (document_id)
+#   <- (document_metadata)
+#   <- (error)
+
+# get-document-content
+#   -> (document_id)
+#   <- (content)
+#   <- (error)
+
+# add-processing
+#   -> (processing_id, processing_metadata)
+#   <- ()
+#   <- (error)
+
+# remove-processing
+#   -> (processing_id)
+#   <- ()
+#   <- (error)
+
+# list-documents
+#   -> (user, collection?)
+#   <- (document_metadata[])
+#   <- (error)
+
+# list-processing
+#   -> (user, collection?)
+#   <- (processing_metadata[])
+#   <- (error)
+
+# OLD:
 # add(Metadata, Bytes) : error?
 # copy(id, user, collection)
 # move(id, user, collection)
@@ -26,17 +62,21 @@ from . documents import Document, TextDocument
 # info(id[]) : DocumentInfo[]
 # search(<key,op,value>[]) : id[]
 
-class DocumentPackage(Record):
+class DocumentMetadata(Record):
     id = String()
-    flow = String()
+    time = Long()
-    document = Bytes()
     kind = String()
-    user = String()
-    collection = String()
     title = String()
     comments = String()
-    time = Long()
     metadata = Array(Triple())
+    tags = Array(String())
+
+class ProcessingMetadata(Record):
+    document_id = String()
+    time = Long()
+    flow = String()
+    user = String()
+    collection = String()
 
 class DocumentInfo(Record):
     id = String()
@@ -55,12 +95,35 @@ class Criteria(Record):
     operator = String()
 
 class LibrarianRequest(Record):
+
+    # add-document, remove-document, update-document, get-document-metadata,
+    # get-document-content, add-processing, remove-processing, list-documents,
+    # list-processing
     operation = String()
-    id = String()
+
-    flow = String()
+    # add-document, remove-document, update-document, get-document-metadata,
-    document = DocumentPackage()
+    # get-document-content
+    document_id = String()
+
+    # add-processing, remove-processing
+    processing_id = String()
+
+    # add-document, update-document
+    document_metadata = DocumentMetadata()
+
+    # add-processing
+    processing_metadata = ProcessingMetadata()
+
+    # add-document
+    content = Bytes()
+
+    # list-documents, list-processing
     user = String()
+
+    # list-documents?, list-processing?
     collection = String()
+
+    # 
     criteria = Array(Criteria())
 
 class LibrarianResponse(Record):