feat: exportable members

Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "monitoring"
+name = "pragma-monitoring"
 version = "0.1.0"
 edition = "2021"
 

src/lib.rs

@@ -0,0 +1,5 @@
+pub(crate) mod config;
+pub(crate) mod constants;
+pub mod models;
+pub mod schema;
+pub mod types;

src/models.rs

@@ -1,9 +1,13 @@
-extern crate bigdecimal;
-extern crate chrono;
+// Generated by diesel_ext
+
+#![allow(unused)]
+#![allow(clippy::all)]
 
 use bigdecimal::BigDecimal;
 use chrono::NaiveDateTime;
 use diesel::{Queryable, QueryableByName, Selectable};
+use num_bigint::BigInt;
+use std::ops::Bound;
 
 #[derive(Debug, Queryable, Selectable, QueryableByName)]
 #[diesel(table_name = crate::schema::spot_entry)]
@@ -43,3 +47,45 @@ pub struct FutureEntry {
     pub expiration_timestamp: Option<chrono::NaiveDateTime>,
     pub _cursor: i64,
 }
+
+#[derive(Queryable, Debug, QueryableByName, Selectable)]
+#[diesel(primary_key(data_id))]
+#[diesel(check_for_backend(diesel::pg::Pg))]
+#[diesel(table_name = crate::schema::spot_checkpoints)]
+pub struct SpotCheckpoint {
+    pub network: String,
+    pub pair_id: String,
+    pub data_id: String,
+    pub block_hash: String,
+    pub block_number: i64,
+    pub block_timestamp: NaiveDateTime,
+    pub transaction_hash: String,
+    pub price: BigDecimal,
+    pub sender_address: String,
+    pub aggregation_mode: BigDecimal,
+    pub _cursor: i64,
+    pub timestamp: NaiveDateTime,
+    pub nb_sources_aggregated: BigDecimal,
+}
+
+#[derive(Queryable, Debug, QueryableByName, Selectable)]
+#[diesel(primary_key(data_id))]
+#[diesel(check_for_backend(diesel::pg::Pg))]
+#[diesel(table_name = crate::schema::vrf_requests)]
+pub struct VrfRequest {
+    pub network: String,
+    pub request_id: BigDecimal,
+    pub seed: BigDecimal,
+    pub created_at: NaiveDateTime,
+    pub created_at_tx: String,
+    pub callback_address: String,
+    pub callback_fee_limit: BigDecimal,
+    pub num_words: BigDecimal,
+    pub requestor_address: String,
+    pub updated_at: NaiveDateTime,
+    pub updated_at_tx: String,
+    pub status: BigDecimal,
+    pub minimum_block_number: BigDecimal,
+    pub _cursor: (Bound<i64>, Bound<i64>),
+    pub data_id: String,
+}

src/schema.rs

@@ -78,7 +78,7 @@ diesel::table! {
 }
 
 diesel::table! {
-    spot_entry (timestamp) {
+    spot_entry (data_id) {
         #[max_length = 255]
         network -> Varchar,
         #[max_length = 255]
@@ -102,6 +102,54 @@ diesel::table! {
     }
 }
 
+diesel::table! {
+    mainnet_spot_checkpoints (pair_id) {
+        #[max_length = 255]
+        network -> Varchar,
+        #[max_length = 255]
+        pair_id -> Varchar,
+        #[max_length = 255]
+        data_id -> Varchar,
+        #[max_length = 255]
+        block_hash -> Varchar,
+        block_number -> Int8,
+        block_timestamp -> Timestamp,
+        #[max_length = 255]
+        transaction_hash -> Varchar,
+        price -> Numeric,
+        #[max_length = 255]
+        sender_address -> Varchar,
+        aggregation_mode -> Numeric,
+        _cursor -> Int8,
+        timestamp -> Timestamp,
+        nb_sources_aggregated -> Numeric,
+    }
+}
+
+diesel::table! {
+    spot_checkpoints (data_id) {
+        #[max_length = 255]
+        network -> Varchar,
+        #[max_length = 255]
+        pair_id -> Varchar,
+        #[max_length = 255]
+        data_id -> Varchar,
+        #[max_length = 255]
+        block_hash -> Varchar,
+        block_number -> Int8,
+        block_timestamp -> Timestamp,
+        #[max_length = 255]
+        transaction_hash -> Varchar,
+        price -> Numeric,
+        #[max_length = 255]
+        sender_address -> Varchar,
+        aggregation_mode -> Numeric,
+        _cursor -> Int8,
+        timestamp -> Timestamp,
+        nb_sources_aggregated -> Numeric,
+    }
+}
+
 diesel::table! {
     vrf_requests (data_id) {
         #[max_length = 255]
@@ -127,7 +175,9 @@ diesel::table! {
 diesel::allow_tables_to_appear_in_same_query!(
     future_entry,
     mainnet_future_entry,
+    mainnet_spot_checkpoints,
     mainnet_spot_entry,
+    spot_checkpoints,
     spot_entry,
     vrf_requests,
 );