feat: Query Hasura Endpoint through Block Streamer

block-streamer/Cargo.toml

@@ -13,11 +13,14 @@ borsh = "0.10.2"
 cached = "0.49.3"
 chrono = "0.4.25"
 futures = "0.3.5"
+graphql_client = { version = "0.14.0", features = ["reqwest"] }
 lazy_static = "1.4.0"
 mockall = "0.11.4"
+near-lake-framework = "0.7.8"
 prometheus = "0.13.3"
 prost = "0.12.3"
 redis = { version = "0.21.5", features = ["tokio-comp", "connection-manager"] }
+reqwest = { version = "^0.11.0", features = ["json"] }
 serde = { version = "1", features = ["derive"] }
 serde_json = "1.0.55"
 tracing = "0.1.40"
@@ -31,8 +34,6 @@ wildmatch = "2.1.1"
 
 registry-types = { path = "../registry/types" }
 
-near-lake-framework = "0.7.8"
-
 [build-dependencies]
 tonic-build = "0.10"
 

block-streamer/README.md

@@ -0,0 +1,23 @@
+// TODO: Improve README further
+
+## GraphQL Code Generation
+Querying a GraphQL requires informing Rust of the correct types to deserialize the response data into. In order to do this, the schema of the GraphQL data needs to be introspected. Following that, the query intended to be called needs to be fully defined. With this information, code can be automatically generated using the macro provided in graphql-client. Below are the instructions on how to do so. 
+
+### Generating schema.graphql
+Follow the instructions in the [Hasura Documentation](https://hasura.io/docs/latest/schema/common-patterns/export-graphql-schema/) to introspect the schema and generate the graphql file. Keep in mind that a header for the role needs to be provided. Otherwise, the schemas remain hidden from the public/default user.
+
+For example: `gq https://my-graphql-engine.com/v1/graphql -H 'X-Hasura-Role: someaccount_near' --introspect > schema.graphql`
+
+### Generating Rust types from query
+After acquiring the graphql file for the schema, write the queries that need to be called in individual graphql files. Once written, add the following code template to a Rust file and the code will be auto generated using the macro. Assuming there are no problems generating the code, the code will be immediately usable. 
+
+```
+#[derive(GraphQLQuery)]
+#[graphql(
+    schema_path = "PATH/TO/schema.graphql",
+    query_path = "PATH/TO/query.graphql",
+    response_derives = "Debug",
+    normalization = "rust"
+)]
+struct QueryNameInPascalCase;
+```

block-streamer/graphql/darunrs_near/get_bitmaps_exact.graphql

@@ -0,0 +1,6 @@
+query GetBitmapsExact($block_date: date, $receiver_ids: [String!], $limit: Int, $offset: Int) {
+  darunrs_near_bitmap_v5_actions_index(limit: $limit, offset: $offset, where: {block_date: {_eq: $block_date}, receiver: {receiver: {_in: $receiver_ids}}}) {
+    bitmap
+    first_block_height
+  }
+}

block-streamer/graphql/darunrs_near/get_bitmaps_wildcard.graphql

@@ -0,0 +1,6 @@
+query GetBitmapsWildcard($block_date: date, $receiver_ids: String, $limit: Int, $offset: Int) {
+  darunrs_near_bitmap_v5_actions_index(limit: $limit, offset: $offset, where: {block_date: {_eq: $block_date}, receiver: {receiver: {_regex: $receiver_ids}}}) {
+    bitmap
+    first_block_height
+  }
+}