Compare commits

..

No commits in common. "323dd43c5b57a7892c2ad2cf3a61a8f7730877b0" and "13ea0619cdf554e58217bb178f19230e082e7189" have entirely different histories.

7 changed files with 2 additions and 16 deletions

2
Cargo.lock generated
View File

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

View File

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

View File

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

View File

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

View File

@ -24,13 +24,6 @@ impl Service {
Ok(tickers) 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 /// 🐎 » retrieves a ticker from the database, given its id
pub async fn get(&self, id: String) -> Result<Option<TickerModel>, DbErr> { pub async fn get(&self, id: String) -> Result<Option<TickerModel>, DbErr> {
let ticker = Ticker::find_by_id(id).one(&self.conn).await?; let ticker = Ticker::find_by_id(id).one(&self.conn).await?;

View File

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

View File

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