release: 🔖 v0.4.1

Cargo.lock

@@ -2168,7 +2168,7 @@ dependencies = [
 
 [[package]]
 name = "rustler-core"
-version = "0.4.0"
+version = "0.4.1"
 dependencies = [
  "async-stream",
  "async-trait",

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "rustler-core"
-version = "0.4.0"
+version = "0.4.1"
 edition = "2021"
 description = "🐎 » rustler-core market data extractor core functionality"
 authors = ["Lucas Colombo <lucas@lucode.ar>"]

lib/entities/migration/m20240325_200049_create_table_ticker.rs

@@ -16,6 +16,7 @@ impl MigrationTrait for Migration {
                     .col(ColumnDef::new(Ticker::Symbol).string().not_null())
                     .col(ColumnDef::new(Ticker::QuoteSymbol).string().null())
                     .col(ColumnDef::new(Ticker::MarketId).string().not_null())
+                    .col(ColumnDef::new(Ticker::Active).boolean().not_null().default(true))
                     .foreign_key(
                         ForeignKey::create()
                             .name("fk_ticker_market_id")
@@ -51,4 +52,6 @@ enum Ticker {
     QuoteSymbol,
     /// Market ID
     MarketId,
+    /// Active status of the ticker. This defines if quotes are generated for this ticker or not.
+    Active,
 }

lib/entities/orm/ticker.rs

@@ -11,6 +11,7 @@ pub struct Model {
     pub symbol: String,
     pub quote_symbol: Option<String>,
     pub market_id: String,
+    pub active: bool,
 }
 
 #[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]

lib/entities/services/ticker.rs

@@ -24,6 +24,13 @@ impl Service {
         Ok(tickers)
     }
 
+    /// 🐎 » get all active
+    pub async fn get_all_active(&self) -> Result<Vec<TickerModel>, DbErr> {
+        let tickers =
+            Ticker::find().filter(ticker::Column::Active.eq(true)).all(&self.conn).await?;
+        Ok(tickers)
+    }
+
     /// 🐎 » retrieves a ticker from the database, given its id
     pub async fn get(&self, id: String) -> Result<Option<TickerModel>, DbErr> {
         let ticker = Ticker::find_by_id(id).one(&self.conn).await?;

lib/grpc/proto/ticker.proto

@@ -23,6 +23,7 @@ message Ticker {
     string symbol = 2;
     optional string quote_symbol = 3;
     string market_id = 4;
+    bool active = 5;
 }
 
 message Tickers {

lib/grpc/services/ticker.rs

@@ -22,6 +22,7 @@ impl Ticker {
             symbol: self.symbol,
             quote_symbol: self.quote_symbol,
             market_id: self.market_id,
+            active: self.active,
         }
     }
 
@@ -32,6 +33,7 @@ impl Ticker {
             symbol: model.symbol,
             quote_symbol: model.quote_symbol,
             market_id: model.market_id,
+            active: model.active,
         }
     }
 }