Feat/graphql api

Cargo.toml

@@ -1,6 +1,6 @@
 [workspace]
 resolver = "2"
-members = [
-    "cli", "codegen", "core", "ipfs", "node", "sink", "web3-utils",
+members = [ "api",
+    "cli", "codegen", "sdk", "ipfs", "sink", "substreams-utils", "web3-utils",
 ]
 

README.md

@@ -21,15 +21,21 @@ docker run \
 ```
 
 ### 2. Compile and run the indexer
-In a separate terminal, run the following command:
+In a separate terminal, run the following commands:
 ```bash
-cargo run --bin kg-node -- \
-    --rollup \
+cargo run --bin sink -- \
     --reset-db \
     --neo4j-uri neo4j://localhost:7687 \
     --neo4j-user neo4j \
     --neo4j-pass neo4j
 ```
 
+```bash
+cargo run --bin api -- \
+    --neo4j-uri neo4j://localhost:7687 \
+    --neo4j-user neo4j \
+    --neo4j-pass neo4j
+```
+
 ## GRC20 CLI
 Coming soon™️

api/Cargo.toml

@@ -0,0 +1,25 @@
+[package]
+name = "api"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+anyhow = "1.0.94"
+axum = "0.7.9"
+clap = { version = "4.5.23", features = ["derive"] }
+futures = "0.3.31"
+juniper = "0.16.1"
+juniper_axum = "0.1.1"
+juniper_graphql_ws = "0.4.0"
+serde = "1.0.216"
+serde_json = "1.0.133"
+tokio = { version = "1.42.0", features = ["macros", "rt-multi-thread"] }
+tracing = "0.1.41"
+tracing-subscriber = "0.3.19"
+
+sdk = { version = "0.1.0", path = "../sdk" }
+sink = { version = "0.1.0", path = "../sink" }
+chrono = "0.4.39"
+
+[dev-dependencies]
+serde_path_to_error = "0.1.16"

api/schema.graphql

@@ -0,0 +1,133 @@
+input AttributeFilter {
+  valueType: ValueType
+}
+
+"""Entity object"""
+type Entity {
+  """Entity ID"""
+  id: String!
+
+  """Entity name (if available)"""
+  name: 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!
+
+  """Types of the entity (which are entities themselves)"""
+  types: [Entity!]!
+
+  """Attributes of the entity"""
+  attributes(filter: AttributeFilter): [Triple!]!
+
+  """Relations outgoing from the entity"""
+  relations: [Relation!]!
+}
+
+input EntityAttributeFilter {
+  attribute: String!
+  value: String
+  valueType: ValueType
+}
+
+input EntityWhereFilter {
+  spaceId: String
+  typesContain: [String!]
+  attributesContain: [EntityAttributeFilter!]
+}
+
+type Options {
+  format: String
+  unit: String
+  language: String
+}
+
+type Query {
+  """Returns a single entity identified by its ID and space ID"""
+  entity(id: String!, spaceId: String!): Entity
+
+  """
+  Returns multiple entities according to the provided space ID and filter
+  """
+  entities(where: EntityWhereFilter): [Entity!]!
+
+  """Returns a single relation identified by its ID and space ID"""
+  relation(id: String!, spaceId: String!): Relation
+
+  """
+  Returns multiple relations according to the provided space ID and filter
+  """
+  relations(spaceId: String!, filter: RelationFilter): [Relation!]!
+}
+
+"""
+Relation object
+
+Note: Relations are also entities, but they have a different structure in the database.
+In other words, the Relation object is a "view" on a relation entity. All relations
+can also be queried as entities.
+"""
+type Relation {
+  """Relation ID"""
+  id: String!
+
+  """Relation name (if available)"""
+  name: String
+  createdAt: String!
+  createdAtBlock: String!
+  updatedAt: String!
+  updatedAtBlock: String!
+
+  """Attributes of the relation"""
+  attributes: [Triple!]!
+
+  """Relation types of the relation"""
+  relationTypes: [Entity!]!
+
+  """Entity from which the relation originates"""
+  from: Entity!
+
+  """Entity to which the relation points"""
+  to: Entity!
+
+  """Relations outgoing from the relation"""
+  relations: [Relation!]!
+}
+
+"""Relation filter input object"""
+input RelationFilter {
+  """Filter by relation types"""
+  relationTypes: [String!]
+}
+
+type Triple {
+  """Attribute ID of the triple"""
+  attribute: String!
+
+  """Value of the triple"""
+  value: String!
+
+  """Value type of the triple"""
+  valueType: ValueType!
+
+  """Options of the triple (if any)"""
+  options: Options!
+
+  """Name of the attribute (if available)"""
+  name: String
+}
+
+enum ValueType {
+  TEXT
+  NUMBER
+  CHECKBOX
+  URL
+  TIME
+  POINT
+}
+

api/src/lib.rs

@@ -0,0 +1 @@
+pub mod query_mapping;