diff --git a/entities/src/market/svc.rs b/entities/src/market/svc.rs index d0a74a2..cbe464d 100644 --- a/entities/src/market/svc.rs +++ b/entities/src/market/svc.rs @@ -23,44 +23,7 @@ impl Service { Ok(markets) } - pub async fn create( - &self, - id: &str, - short_name: &str, - full_name: &str, - opens_from: i32, - opens_till: i32, - open_time: &str, - close_time: &str, - pre_market_offset: i32, - post_market_offset: i32, - time_zone_offset: i32, - ) -> Result { - let mut start = Instant::now(); - - let market = MarketModel { - id: id.to_string(), - short_name: short_name.to_string(), - full_name: full_name.to_string(), - opens_from, - opens_till, - open_time: open_time.to_string(), - close_time: close_time.to_string(), - pre_market_offset, - post_market_offset, - time_zone_offset, - }; - - println!("create market model took {:?}", start.elapsed()); - start = Instant::now(); - - MarketEntity::insert(market.clone().into_active_model()).exec(&*self.conn).await?; - - println!("insert market model took {:?}", start.elapsed()); - Ok(market) - } - - pub async fn create_from_model(&self, market: MarketModel) -> Result { + pub async fn create(&self, market: MarketModel) -> Result { let start = Instant::now(); MarketEntity::insert(market.clone().into_active_model()).exec(&*self.conn).await?; println!("insert market model took {:?}", start.elapsed()); diff --git a/grpc/src/server.rs b/grpc/src/server.rs index a2f2d29..9153c2a 100644 --- a/grpc/src/server.rs +++ b/grpc/src/server.rs @@ -72,7 +72,7 @@ impl MarketApi for GrpcServer { let start = Instant::now(); let mkt = market.into_inner().into_model(); - if let Some(m) = self.svc.create_from_model(mkt).await.ok() { + if let Some(m) = self.svc.create(mkt).await.ok() { println!("create took {:?}", start.elapsed()); Ok(Response::new(Market::from_model(m))) } else {