ayham
/
PaperTrader
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

remove unneeded server network commands
continuous-integration/drone/push Build is passing Details 

- remove get_asset_data.rs
- remove get_asset_info.rs
- remove purchase_asset.rs
This commit is contained in:
ayham 2021-08-01 17:49:07 +03:00
parent 1468aa9354
commit 499b38a17c
Signed by: ayham
GPG Key ID: EAB7F5A9DF503678
4 changed files with 0 additions and 176 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

82
src/libtrader/server/network/cmd/get_asset_data.rs
View File

@ -1,82 +0,0 @@
//use std::io::Write;
//
//use crate::common::message::message::Message;
//use crate::common::message::message_builder::message_builder;
//use crate::common::message::message_type::MessageType;
//use crate::common::misc::assert_msg::assert_msg;
//
//use crate::server::db::cmd::get_stock::get_stock_from_db_between_epochs;
//use crate::server::network::tls_connection::TlsConnection;
//
//pub fn get_asset_data(tls_connection: &mut TlsConnection, message: &Message) {
// /* assert recieved message */
// if !assert_msg(
// message,
// MessageType::DataTransfer,
// true,
// 3,
// false,
// 0,
// false,
// 0,
// false,
// 0,
// ) {
// tls_connection.closing = true;
// warn!("GET_ASSET_DATA_MSG_ASSERT_FAILED");
// return;
// }
//
// /*
// * Parse arguments
// * */
// /* get json data */
// let stringified_data = std::str::from_utf8(&message.data).unwrap();
// let data = json::parse(&stringified_data).unwrap();
// /* get symbol, start_epoch, and end_epoch */
// let symbol = data["symbol"].as_str().unwrap();
// let start_epoch = data["start_epoch"]
// .as_str()
// .unwrap()
// .to_string()
// .parse::<i64>()
// .unwrap();
// let end_epoch = data["end_epoch"]
// .as_str()
// .unwrap()
// .to_string()
// .parse::<i64>()
// .unwrap();
//
// /* call get_stock_from_db_between_epochs() */
// match get_stock_from_db_between_epochs(symbol, start_epoch, end_epoch) {
// Ok(vals) => {
// /* send the data */
// let mut counter = 0;
// for val in &vals {
// let message = message_builder(
// MessageType::DataTransfer,
// 1,
// counter,
// vals.len(),
// 0,
// bincode::serialize(&val).unwrap(),
// );
// let _ = tls_connection.write(&bincode::serialize(&message).unwrap());
// counter = counter + 1;
// }
// }
// Err(err) => {
// /* handle error */
// let message = message_builder(
// MessageType::ServerReturn,
// 0,
// 0,
// 0,
// 0,
// bincode::serialize(&err).unwrap(),
// );
// let _ = tls_connection.write(&bincode::serialize(&message).unwrap());
// }
// }
//}

56
src/libtrader/server/network/cmd/get_asset_info.rs
View File

@ -1,56 +0,0 @@
//use std::io::Write;
//
//use crate::common::message::inst::DataTransferInst;
//use crate::common::message::message::Message;
//use crate::common::message::message_builder::message_builder;
//use crate::common::message::message_type::MessageType;
//use crate::common::misc::assert_msg::assert_msg;
//
//use crate::server::db::cmd::get_company::get_company_from_db;
//use crate::server::network::tls_connection::TlsConnection;
//
//pub fn get_asset_info(tls_connection: &mut TlsConnection, message: &Message) {
// /* assert recieved message */
// if !assert_msg(
// message,
// MessageType::DataTransfer,
// true,
// 1,
// false,
// 0,
// false,
// 0,
// false,
// 0,
// ) {
// tls_connection.closing = true;
// warn!("GET_ASSET_INFO_INVALID_MESSAGE");
// return;
// }
//
// /* call get_company_from_db() */
// match get_company_from_db(bincode::deserialize(&message.data).unwrap()) {
// Ok(company) => {
// let message = message_builder(
// MessageType::ServerReturn,
// DataTransferInst::GetAssetInfo as i64,
// 0,
// 0,
// 1,
// bincode::serialize(&company).unwrap(),
// );
// let _ = tls_connection.write(&bincode::serialize(&message).unwrap());
// }
// Err(err) => {
// let message = message_builder(
// MessageType::ServerReturn,
// 0,
// 0,
// 0,
// 0,
// bincode::serialize(&err).unwrap(),
// );
// let _ = tls_connection.write(&bincode::serialize(&message).unwrap());
// }
// }
//}

3
src/libtrader/server/network/cmd/mod.rs
View File

@ -1,5 +1,2 @@
pub mod get_asset_data;
pub mod get_asset_info;
pub mod purchase_asset;
pub mod retrieve_portfolio;
pub mod retrieve_transactions;

35
src/libtrader/server/network/cmd/purchase_asset.rs
View File

@ -1,35 +0,0 @@
//use crate::common::message::message::Message;
//
//use crate::server::network::tls_connection::TlsConnection;
//
//pub fn purchase_asset(_tls_connection: &mut TlsConnection, _message: &Message) {
// /* assert recieved message */
// //if message.msgtype != MessageType::Command || message.argument_count != 4
// // || message.data_message_number != 0 || message.data_message_max != 0
// // || message.data.len() == 0 {
// // warn!("PURCHASE_ASSET_INVALID_MESSAGE");
// // tls_connection.closing = true;
// // return;
// // }
//
// //* parse request data */
// //let stringified_data = std::str::from_utf8(&message.data).unwrap();
// //let data = json::parse(&stringified_data).unwrap();
// //* get symbol, shares amount, price, buy or sell */
// //let symbol = data["symbol"].as_str().unwrap();
// //let shares_amount = data["shares_amount"].as_str().unwrap().to_string().parse::<i64>().unwrap();
// //let is_buy = data["is_buy"].as_bool().unwrap();
//
// //* connect to the data base */
// //let mut client = db_connect(DB_USER, DB_PASS).unwrap();
//
// //* check if the symbol exists */
// //let company = get_company_from_db(symbol);
// //if !company.is_ok() {
// // let msg = message_builder(MessageType::ServerReturn, 0, 1, 0, 0,
// // bincode::serialize("COULDNOT FIND COMPANY")).unwrap();
// // return;
// //}
//
// //* */
//}