feat(repo): Added blocks rest endpoint (#410)

Cargo.toml

@@ -50,6 +50,7 @@ serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 sha2 = "0.10"
 sqlx = { version = "0.8.3", default-features = false, features = [
+  "chrono",
   "macros",
   "postgres",
   "runtime-tokio",

crates/domains/Cargo.toml

@@ -12,6 +12,7 @@ version.workspace = true
 
 [dependencies]
 async-trait.workspace = true
+chrono.workspace = true
 fuel-core.workspace = true
 fuel-core-types.workspace = true
 fuel-streams-store.workspace = true
@@ -20,6 +21,7 @@ fuel-streams-types.workspace = true
 fuel-tx.workspace = true
 fuel-vm.workspace = true
 rayon.workspace = true
+sea-query = "0.32.2"
 serde.workspace = true
 serde_json.workspace = true
 sqlx.workspace = true
@@ -31,6 +33,8 @@ tokio.workspace = true
 netlink-proto = { version = "=0.11.3", optional = true }
 
 [dev-dependencies]
+pretty_assertions.workspace = true
+serde_urlencoded = "0.7.1"
 test-case.workspace = true
 
 [features]

crates/domains/src/blocks/db_item.rs

@@ -1,5 +1,6 @@
 use std::cmp::Ordering;
 
+use chrono::{DateTime, Utc};
 use fuel_streams_store::{
     db::{DbError, DbItem},
     record::{
@@ -23,6 +24,7 @@ pub struct BlockDbItem {
     pub value: Vec<u8>,
     pub block_height: i64,
     pub producer_address: String,
+    pub timestamp: DateTime<Utc>,
 }
 
 impl DataEncoder for BlockDbItem {
@@ -62,6 +64,7 @@ impl TryFrom<&RecordPacket> for BlockDbItem {
                 value: packet.value.to_owned(),
                 block_height: subject.height.unwrap().into(),
                 producer_address: subject.producer.unwrap().to_string(),
+                timestamp: Utc::now(),
             }),
             _ => Err(RecordPacketError::SubjectMismatch),
         }

crates/domains/src/blocks/mod.rs

@@ -1,5 +1,6 @@
 mod db_item;
 mod packets;
+pub mod queryable;
 mod record_impl;
 pub mod subjects;
 pub mod types;