D3 Protototype Branch

.husky/pre-commit

@@ -1,4 +1,4 @@
 #!/bin/sh
 . "$(dirname "$0")/_/husky.sh"
 
-yarn lint-staged
+#yarn lint-staged

apps/hubble/src/addon/src/lib.rs

@@ -6,7 +6,7 @@ use db::RocksDB;
 use ed25519_dalek::{Signature, Signer, SigningKey, VerifyingKey, EXPANDED_SECRET_KEY_LENGTH};
 use neon::{prelude::*, types::buffer::TypedArray};
 use std::{convert::TryInto, sync::Mutex};
-use store::{LinkStore, ReactionStore, Store, UserDataStore};
+use store::{LinkStore, ReactionStore, TagStore, ObjectStore, RelationshipStore, Store, UserDataStore};
 use threadpool::ThreadPool;
 
 mod db;
@@ -171,6 +171,53 @@ fn main(mut cx: ModuleContext) -> NeonResult<()> {
         ReactionStore::js_get_reactions_by_target,
     )?;
 
+    // TagStore methods
+    cx.export_function("createTagStore", TagStore::create_tag_store)?;
+    // cx.export_function("getTagAdd", TagStore::js_get_tag_add)?;
+    // cx.export_function("getTagRemove", TagStore::js_get_tag_remove)?;
+    cx.export_function(
+        "getTagAddsByFid",
+        TagStore::js_get_tag_adds_by_fid,
+    )?;
+    cx.export_function(
+        "getTagRemovesByFid",
+        TagStore::js_get_tag_removes_by_fid,
+    )?;
+    cx.export_function(
+        "getTagsByTarget",
+        TagStore::js_get_tags_by_target,
+    )?;
+
+    // ObjectStore methods
+    cx.export_function("createObjectStore", ObjectStore::create_object_store)?;
+    cx.export_function("getObjectAdd", ObjectStore::js_get_object_add)?;
+    cx.export_function("getObjectRemove", ObjectStore::js_get_object_remove)?;
+    cx.export_function(
+        "getObjectAddsByFid",
+        ObjectStore::js_get_object_adds_by_fid,
+    )?;
+    cx.export_function(
+        "getObjectRemovesByFid",
+        ObjectStore::js_get_object_removes_by_fid,
+    )?;
+
+    // RelationshipStore methods
+    cx.export_function("createRelationshipStore", RelationshipStore::create_relationship_store)?;
+    cx.export_function("getRelationshipAdd", RelationshipStore::js_get_relationship_add)?;
+    cx.export_function("getRelationshipRemove", RelationshipStore::js_get_relationship_remove)?;
+    cx.export_function(
+        "getRelationshipAddsByFid",
+        RelationshipStore::js_get_relationship_adds_by_fid,
+    )?;
+    cx.export_function(
+        "getRelationshipRemovesByFid",
+        RelationshipStore::js_get_relationship_removes_by_fid,
+    )?;
+    cx.export_function(
+        "getRelationshipsByRelatedObjectRef",
+        RelationshipStore::js_get_relationships_by_related_object_ref,
+    )?;
+
     // CastStore methods
     cx.export_function("createCastStore", CastStore::js_create_cast_store)?;
     cx.export_function("getCastAdd", CastStore::js_get_cast_add)?;

apps/hubble/src/addon/src/store/message.rs

@@ -73,6 +73,13 @@ pub enum RootPrefix {
 
     /* Used to index fname username proofs by fid */
     FNameUserNameProofByFid = 27,
+
+    /* Used to index tags by target  */
+    TagsByTarget = 28,
+
+    /* Used to index relationships by source and target object refs  */
+    RelationshipsBySource = 29,
+    RelationshipsByTarget = 30,
 }
 
 /** Copied from the JS code */
@@ -89,6 +96,16 @@ pub enum UserPostfix {
     UsernameProofMessage = 7,
 
     // Add new message types here
+
+    /* Tag message */
+    TagMessage = 8,
+
+    /* Object message */
+    ObjectMessage = 9,
+
+    /* Relationship message */
+    RelationshipMessage = 10,
+
     // NOTE: If you add a new message type, make sure that it is only used to store Message protobufs.
     // If you need to store an index, use one of the UserPostfix values below (>86).
     /** Index records (must be 86-255) */
@@ -122,6 +139,18 @@ pub enum UserPostfix {
 
     /* Link Compact State set */
     LinkCompactStateMessage = 100,
+
+    /** TagStore add and remove sets */
+    TagAdds = 101,
+    TagRemoves = 102,
+
+    /** ObjectStore add and remove sets */
+    ObjectAdds = 103,
+    ObjectRemoves = 104,
+
+    /** RelationshipStore add and remove sets */
+    RelationshipAdds = 105,
+    RelationshipRemoves = 106,
 }
 
 impl UserPostfix {
@@ -183,6 +212,18 @@ pub fn type_to_set_postfix(message_type: MessageType) -> UserPostfix {
         return UserPostfix::UsernameProofMessage;
     }
 
+    if message_type == MessageType::TagAdd || message_type == MessageType::TagRemove {
+        return UserPostfix::TagMessage;
+    }
+
+    if message_type == MessageType::ObjectAdd || message_type == MessageType::ObjectRemove {
+        return UserPostfix::ObjectMessage;
+    }
+
+    if message_type == MessageType::RelationshipAdd || message_type == MessageType::RelationshipRemove {
+        return UserPostfix::RelationshipMessage;
+    }
+
     panic!("invalid type");
 }
 

apps/hubble/src/addon/src/store/mod.rs

@@ -8,6 +8,9 @@ pub use self::user_data_store::*;
 pub use self::username_proof_store::*;
 pub use self::utils::*;
 pub use self::verification_store::*;
+pub use self::tag_store::*;
+pub use self::object_store::*;
+pub use self::relationship_store::*;
 
 mod cast_store;
 mod link_store;
@@ -20,3 +23,9 @@ mod user_data_store;
 mod username_proof_store;
 mod utils;
 mod verification_store;
+mod tag_store;
+mod object_store;
+mod relationship_store;
+
+#[cfg(test)]
+mod store_tests;