feat(sink): Add flags to disable versioning and governance event indexing

.gitignore

@@ -2,4 +2,5 @@
 **/ipfs-cache
 **/data
 *.json
-.env
+.env
+**/.fastembed_cache

README.md

@@ -23,8 +23,9 @@ docker run \
 ### 2. Compile and run the indexer
 In a separate terminal, run the following commands:
 ```bash
-CFLAGS='-std=gnu17' cargo run --bin sink -- \
-    --reset-db \
+CFLAGS='-std=gnu17' cargo run --release --bin sink -- \
+    --no-versioning \
+    --no-governance \
     --neo4j-uri neo4j://localhost:7687 \
     --neo4j-user neo4j \
     --neo4j-pass neo4j
@@ -36,6 +37,11 @@ CFLAGS='-std=gnu17' cargo run --bin api -- \
     --neo4j-user neo4j \
     --neo4j-pass neo4j
 ```
+Schema introspection
+
+```
+npx get-graphql-schema http://127.0.0.1:8080/graphql > api/schema.graphql
+```
 
 ## GRC20 CLI
 Coming soon™️

api/schema.graphql

@@ -32,6 +32,15 @@ type Entity {
   """Entity ID"""
   id: String!
 
+  """
+  The space ID of the entity (note: the same entity can exist in multiple spaces)
+  """
+  spaceId: String!
+  createdAt: String!
+  createdAtBlock: String!
+  updatedAt: String!
+  updatedAtBlock: String!
+
   """Entity name (if available)"""
   name: String
 
@@ -47,15 +56,6 @@ type Entity {
   """Types of the entity (which are entities themselves)"""
   types: [Entity!]!
 
-  """
-  The space ID of the entity (note: the same entity can exist in multiple spaces)
-  """
-  spaceId: String!
-  createdAt: String!
-  createdAtBlock: String!
-  updatedAt: String!
-  updatedAtBlock: String!
-
   """Attributes of the entity"""
   attributes(filter: AttributeFilter): [Triple!]!
 
@@ -143,6 +143,50 @@ enum OrderDirection {
   DESC
 }
 
+type Property {
+  """Entity ID"""
+  id: String!
+
+  """
+  The space ID of the entity (note: the same entity can exist in multiple spaces)
+  """
+  spaceId: String!
+  createdAt: String!
+  createdAtBlock: String!
+  updatedAt: String!
+  updatedAtBlock: String!
+
+  """Entity name (if available)"""
+  name(strict: Boolean! = true): String
+
+  """Entity description (if available)"""
+  description: String
+
+  """Entity cover (if available)"""
+  cover: String
+
+  """Entity blocks (if available)"""
+  blocks: [Entity!]!
+
+  """Types of the entity (which are entities themselves)"""
+  types: [Entity!]!
+
+  """Attributes of the entity"""
+  attributes(filter: AttributeFilter): [Triple!]!
+
+  """Relations outgoing from the entity"""
+  relations(where: EntityRelationFilter): [Relation!]!
+
+  """Versions of the entity, ordered chronologically"""
+  versions: [EntityVersion!]!
+
+  """Value type of the property"""
+  valueType: Entity
+
+  """Value type of the property"""
+  relationValueType: Entity
+}
+
 """Relation object"""
 type Relation {
   """Relation ID"""
@@ -187,10 +231,10 @@ input RelationFilter {
 
 type RootQuery {
   """Returns a single space by ID"""
-  space(id: String!): Space
+  space(id: String!, version: String): Space
 
   """Returns multiple spaces according to the provided filter"""
-  spaces(where: SpaceFilter, first: Int, skip: Int): [Space!]!
+  spaces(where: SpaceFilter, version: String, first: Int! = 100, skip: Int! = 0): [Space!]!
 
   """Returns a single account by ID"""
   account(id: String!): Account
@@ -199,23 +243,72 @@ type RootQuery {
   accountByAddress(address: String!): Account
 
   """Returns multiple accounts according to the provided filter"""
-  accounts(where: AccountFilter, first: Int, skip: Int): [Account!]!
+  accounts(where: AccountFilter, first: Int! = 100, skip: Int! = 0): [Account!]!
 
   """Returns a single entity identified by its ID and space ID"""
-  entity(id: String!, spaceId: String!, versionId: String): Entity
+  entity(id: String!, spaceId: String!, versionId: String, strict: Boolean! = true): Entity
 
   """
   Returns multiple entities according to the provided space ID and filter
   """
-  entities(spaceId: String!, orderBy: String, orderDirection: OrderDirection, where: EntityFilter, first: Int, skip: Int): [Entity!]!
+  entities(spaceId: String!, orderBy: String, orderDirection: OrderDirection, where: EntityFilter, first: Int! = 100, skip: Int! = 0, strict: Boolean! = true): [Entity!]!
 
   """Returns a single relation identified by its ID and space ID"""
-  relation(id: String!, spaceId: String!, versionId: String): Relation
+  relation(id: String!, spaceId: String!, versionId: String, strict: Boolean! = true): Relation
 
   """
   Returns multiple relations according to the provided space ID and filter
   """
-  relations(spaceId: String!, orderBy: String, orderDirection: OrderDirection, where: RelationFilter, first: Int, skip: Int): [Relation!]!
+  relations(spaceId: String!, orderBy: String, orderDirection: OrderDirection, where: RelationFilter, first: Int! = 100, skip: Int! = 0, strict: Boolean! = true): [Relation!]!
+
+  """
+  Returns a single triple identified by its entity ID, attribute ID, space ID and
+  optional version ID
+  """
+  triple(entityId: String!, attributeId: String!, spaceId: String!, versionId: String, strict: Boolean! = true): Triple
+  search(query: String!, first: Int! = 100): [Triple!]!
+}
+
+"""SchemaType object"""
+type SchemaType {
+  """Entity ID"""
+  id: String!
+
+  """
+  The space ID of the entity (note: the same entity can exist in multiple spaces)
+  """
+  spaceId: String!
+  createdAt: String!
+  createdAtBlock: String!
+  updatedAt: String!
+  updatedAtBlock: String!
+
+  """Entity name (if available)"""
+  name(strict: Boolean! = true): String
+
+  """Entity description (if available)"""
+  description: String
+
+  """Entity cover (if available)"""
+  cover: String
+
+  """Entity blocks (if available)"""
+  blocks: [Entity!]!
+
+  """Types of the entity (which are entities themselves)"""
+  types: [Entity!]!
+
+  """Attributes of the entity"""
+  attributes(filter: AttributeFilter): [Triple!]!
+
+  """Relations outgoing from the entity"""
+  relations(where: EntityRelationFilter): [Relation!]!
+
+  """Versions of the entity, ordered chronologically"""
+  versions: [EntityVersion!]!
+
+  """Properties of the Type"""
+  properties(first: Int! = 100, skip: Int! = 0): [Property!]!
 }
 
 type Space {
@@ -244,16 +337,19 @@ type Space {
   personalSpaceAdminPlugin: String
 
   """Members of the space"""
-  members(first: Int, skip: Int): [Account!]!
+  members(first: Int! = 100, skip: Int! = 0): [Account!]!
 
   """Editors of the space"""
-  editors(first: Int, skip: Int): [Account!]!
+  editors(first: Int! = 100, skip: Int! = 0): [Account!]!
 
   """Parent spaces of this space"""
-  parentSpaces(first: Int, skip: Int): [Space!]!
+  parentSpaces(first: Int! = 100, skip: Int! = 0): [Space!]!
 
   """Subspaces of this space"""
-  subspaces(first: Int, skip: Int): [Space!]!
+  subspaces(first: Int! = 100, skip: Int! = 0): [Space!]!
+  types(first: Int! = 100, skip: Int! = 0, strict: Boolean! = true): [SchemaType!]!
+  type(id: String!, strict: Boolean! = true): SchemaType
+  entities(orderBy: String, orderDirection: OrderDirection, where: EntityFilter, first: Int! = 100, skip: Int! = 0, strict: Boolean! = true): [Entity!]!
 }
 
 input SpaceFilter {
@@ -265,10 +361,10 @@ input SpaceFilter {
   networkNot: String
   networkIn: [String!]
   networkNotIn: [String!]
-  governanceType: String
-  governanceTypeNot: String
-  governanceTypeIn: [String!]
-  governanceTypeNotIn: [String!]
+  governanceType: SpaceGovernanceType
+  governanceTypeNot: SpaceGovernanceType
+  governanceTypeIn: [SpaceGovernanceType!]
+  governanceTypeNotIn: [SpaceGovernanceType!]
   daoContractAddress: String
   daoContractAddressNot: String
   daoContractAddressIn: [String!]
@@ -314,6 +410,7 @@ type Triple {
 
   """Name of the attribute (if available)"""
   name: String
+  entity: Entity
 }
 
 enum ValueType {

docker/Dockerfile

@@ -28,6 +28,8 @@ COPY --from=builder /kg-node/target/release/sink .
 COPY --from=builder /kg-node/geo-substream.spkg .
 
 CMD ./sink \
+    --no-versioning \
+    --no-governance \
     --neo4j-uri $neo4j_uri \
     --neo4j-user $neo4j_user \
     --neo4j-pass $neo4j_pass

sink/src/events/edit_published.rs

@@ -139,12 +139,19 @@ impl EventHandler {
             return Ok(());
         }
 
-        let version_index = mapping::new_version_index(block.block_number, index);
-        let edit_medatata =
-            models::Edit::new(edit.name, edit.content_uri, Some(version_index.clone()));
-        let proposal_id = Proposal::gen_id(&edit.space_plugin_address, &edit.proposal_id);
-        self.create_edit_relations(block, edit_medatata, &edit.space_id, &proposal_id)
-            .await?;
+        let version_index = if self.versioning {
+            mapping::new_version_index(block.block_number, index)
+        } else {
+            "0".to_string()
+        };
+
+        if self.governance {
+            let edit_medatata =
+                models::Edit::new(edit.name, edit.content_uri, Some(version_index.clone()));
+            let proposal_id = Proposal::gen_id(&edit.space_plugin_address, &edit.proposal_id);
+            self.create_edit_relations(block, edit_medatata, &edit.space_id, &proposal_id)
+                .await?;
+        }
 
         // Group ops by type
         let num_ops = edit.ops.len();