Sik/tradingbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Change code to use all trade-pairs

Browse Source
This commit is contained in:
Sik Yoon 2023-10-15 15:25:37 +09:00
parent f0f3384be4
commit 2df8f5ae10
1 changed files with 105 additions and 103 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

208
src/coin_health_check_team/monitors.rs
View File

@ -28,119 +28,121 @@ pub async fn collect_valid_usde_trade(
symbol: String,
}
// if RUNNING_MODE == SIMUL { // || RUNNING_MODE == REAL {
// let mut usdt_trades = UsdtTrades { symbol: String::new() };
let mut usdt_trades = UsdtTrades { symbol: String::new() };
// let fetch_table_name = String::from("all_24h_change");
// let column_name = String::from("symbol");
// let mut condition_build = String::from("WHERE symbol LIKE '%BUSD' AND symbol NOT LIKE '%DOWNUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE '%UPUSDT' AND firstId >= 0 AND lastId >= 0");
// condition_build.push_str(" AND symbol NOT IN (SELECT symbol FROM stop_usdt_trades)");
// // add unnessesary coins
// condition_build.push_str(" AND symbol NOT LIKE 'BUSDUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'TUSDUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'USDPUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'SUSDUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'AUDUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'EURUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'GBPUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'USDCUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'BZRXUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'USTUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'NBTUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'VGXUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'RAMPUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'TORNUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'BTTCUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'BTCSTUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'ACAUSDT'");
// condition_build.push_str(" AND symbol NOT LIKE 'ANCUSDT'");
// let condition = Some(condition_build);
let fetch_table_name = String::from("all_24h_change");
let column_name = String::from("symbol");
let mut condition_build = String::from("WHERE symbol LIKE '%USDT' AND symbol NOT LIKE '%DOWNUSDT'");
condition_build.push_str(" AND symbol NOT LIKE '%UPUSDT' AND firstId >= 0 AND lastId >= 0");
condition_build.push_str(" AND symbol NOT IN (SELECT symbol FROM stop_usdt_trades)");
// add unnessesary coins
condition_build.push_str(" AND symbol NOT LIKE 'BUSDUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'USTCUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'FDUSDUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'TUSDUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'USDPUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'SUSDUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'AUDUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'EURUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'GBPUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'USDCUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'BZRXUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'USTUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'NBTUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'VGXUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'RAMPUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'TORNUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'BTTCUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'BTCSTUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'ACAUSDT'");
condition_build.push_str(" AND symbol NOT LIKE 'ANCUSDT'");
let condition = Some(condition_build);
// let select_result = select_record(&fetch_table_name, &column_name, &condition, &usdt_trades).await?;
let select_result = select_record(&fetch_table_name, &column_name, &condition, &usdt_trades).await?;
let table_name = String::from("valid_usdt_trades");
let columns = vec!["symbol"];
let mut symbol_vec: Vec<String> = Vec::new();
let mut value_wrapper: Vec<Vec<String>> = Vec::new();
for element in select_result {
let mut inner_vec: Vec<String> = Vec::new();
inner_vec.push(element.symbol.clone());
value_wrapper.push(inner_vec);
symbol_vec.push(element.symbol);
}
*valid_usdt_trade_vec = symbol_vec;
delete_all_rows(&table_name).await?;
insert_records(&table_name, &columns, &value_wrapper).await?;
// major trades
// if RUNNING_MODE == TEST || RUNNING_MODE == REAL || RUNNING_MODE == SIMUL {
// let table_name = String::from("valid_usdt_trades");
// let columns = vec!["symbol"];
// let mut symbol_vec: Vec<String> = Vec::new();
// let mut value_wrapper: Vec<Vec<String>> = Vec::new();
// for element in select_result {
// let mut inner_vec: Vec<String> = Vec::new();
// inner_vec.push(element.symbol.clone());
// value_wrapper.push(inner_vec);
// symbol_vec.push(element.symbol);
// }
// value_wrapper.push(vec![String::from("BTCUSDT")]);
// value_wrapper.push(vec![String::from("ETHUSDT")]);
// value_wrapper.push(vec![String::from("XRPUSDT")]);
// value_wrapper.push(vec![String::from("DOGEUSDT")]);
// value_wrapper.push(vec![String::from("LTCUSDT")]);
// value_wrapper.push(vec![String::from("TRXUSDT")]);
// value_wrapper.push(vec![String::from("DOTUSDT")]);
// value_wrapper.push(vec![String::from("LINKUSDT")]);
// value_wrapper.push(vec![String::from("AVAXUSDT")]);
// value_wrapper.push(vec![String::from("BCHUSDT")]);
// value_wrapper.push(vec![String::from("SHIBUSDT")]);
// value_wrapper.push(vec![String::from("APTUSDT")]);
// value_wrapper.push(vec![String::from("ARBUSDT")]);
// value_wrapper.push(vec![String::from("ETCUSDT")]);
// value_wrapper.push(vec![String::from("XMRUSDT")]);
// value_wrapper.push(vec![String::from("HBARUSDT")]);
// value_wrapper.push(vec![String::from("UNIUSDT")]);
// value_wrapper.push(vec![String::from("XLMUSDT")]);
// value_wrapper.push(vec![String::from("VETUSDT")]);
// value_wrapper.push(vec![String::from("QNTUSDT")]);
// value_wrapper.push(vec![String::from("GRTUSDT")]);
// value_wrapper.push(vec![String::from("AAVEUSDT")]);
// value_wrapper.push(vec![String::from("EGLDUSDT")]);
// value_wrapper.push(vec![String::from("LDOUSDT")]);
// value_wrapper.push(vec![String::from("STXUSDT")]);
// value_wrapper.push(vec![String::from("MKRUSDT")]);
// value_wrapper.push(vec![String::from("OPUSDT")]);
// symbol_vec.push(String::from("BTCUSDT"));
// symbol_vec.push(String::from("ETHUSDT"));
// symbol_vec.push(String::from("XRPUSDT"));
// symbol_vec.push(String::from("DOGEUSDT"));
// symbol_vec.push(String::from("LTCUSDT"));
// symbol_vec.push(String::from("TRXUSDT"));
// symbol_vec.push(String::from("DOTUSDT"));
// symbol_vec.push(String::from("LINKUSDT"));
// symbol_vec.push(String::from("AVAXUSDT"));
// symbol_vec.push(String::from("BCHUSDT"));
// symbol_vec.push(String::from("SHIBUSDT"));
// symbol_vec.push(String::from("APTUSDT"));
// symbol_vec.push(String::from("ARBUSDT"));
// symbol_vec.push(String::from("ETCUSDT"));
// symbol_vec.push(String::from("XMRUSDT"));
// symbol_vec.push(String::from("HBARUSDT"));
// symbol_vec.push(String::from("UNIUSDT"));
// symbol_vec.push(String::from("XLMUSDT"));
// symbol_vec.push(String::from("VETUSDT"));
// symbol_vec.push(String::from("QNTUSDT"));
// symbol_vec.push(String::from("GRTUSDT"));
// symbol_vec.push(String::from("AAVEUSDT"));
// symbol_vec.push(String::from("EGLDUSDT"));
// symbol_vec.push(String::from("LDOUSDT"));
// symbol_vec.push(String::from("STXUSDT"));
// symbol_vec.push(String::from("MKRUSDT"));
// symbol_vec.push(String::from("OPUSDT"));
// *valid_usdt_trade_vec = symbol_vec;
// delete_all_rows(&table_name).await?;
// insert_records(&table_name, &columns, &value_wrapper).await?;
// } else
if RUNNING_MODE == TEST || RUNNING_MODE == REAL || RUNNING_MODE == SIMUL {
let table_name = String::from("valid_usdt_trades");
let columns = vec!["symbol"];
let mut symbol_vec: Vec<String> = Vec::new();
let mut value_wrapper: Vec<Vec<String>> = Vec::new();
value_wrapper.push(vec![String::from("BTCUSDT")]);
value_wrapper.push(vec![String::from("ETHUSDT")]);
value_wrapper.push(vec![String::from("XRPUSDT")]);
value_wrapper.push(vec![String::from("DOGEUSDT")]);
value_wrapper.push(vec![String::from("LTCUSDT")]);
value_wrapper.push(vec![String::from("TRXUSDT")]);
value_wrapper.push(vec![String::from("DOTUSDT")]);
value_wrapper.push(vec![String::from("LINKUSDT")]);
value_wrapper.push(vec![String::from("AVAXUSDT")]);
value_wrapper.push(vec![String::from("BCHUSDT")]);
value_wrapper.push(vec![String::from("SHIBUSDT")]);
value_wrapper.push(vec![String::from("APTUSDT")]);
value_wrapper.push(vec![String::from("ARBUSDT")]);
value_wrapper.push(vec![String::from("ETCUSDT")]);
value_wrapper.push(vec![String::from("XMRUSDT")]);
value_wrapper.push(vec![String::from("HBARUSDT")]);
value_wrapper.push(vec![String::from("UNIUSDT")]);
value_wrapper.push(vec![String::from("XLMUSDT")]);
value_wrapper.push(vec![String::from("VETUSDT")]);
value_wrapper.push(vec![String::from("QNTUSDT")]);
value_wrapper.push(vec![String::from("GRTUSDT")]);
value_wrapper.push(vec![String::from("AAVEUSDT")]);
value_wrapper.push(vec![String::from("EGLDUSDT")]);
value_wrapper.push(vec![String::from("LDOUSDT")]);
value_wrapper.push(vec![String::from("STXUSDT")]);
value_wrapper.push(vec![String::from("MKRUSDT")]);
value_wrapper.push(vec![String::from("OPUSDT")]);
symbol_vec.push(String::from("BTCUSDT"));
symbol_vec.push(String::from("ETHUSDT"));
symbol_vec.push(String::from("XRPUSDT"));
symbol_vec.push(String::from("DOGEUSDT"));
symbol_vec.push(String::from("LTCUSDT"));
symbol_vec.push(String::from("TRXUSDT"));
symbol_vec.push(String::from("DOTUSDT"));
symbol_vec.push(String::from("LINKUSDT"));
symbol_vec.push(String::from("AVAXUSDT"));
symbol_vec.push(String::from("BCHUSDT"));
symbol_vec.push(String::from("SHIBUSDT"));
symbol_vec.push(String::from("APTUSDT"));
symbol_vec.push(String::from("ARBUSDT"));
symbol_vec.push(String::from("ETCUSDT"));
symbol_vec.push(String::from("XMRUSDT"));
symbol_vec.push(String::from("HBARUSDT"));
symbol_vec.push(String::from("UNIUSDT"));
symbol_vec.push(String::from("XLMUSDT"));
symbol_vec.push(String::from("VETUSDT"));
symbol_vec.push(String::from("QNTUSDT"));
symbol_vec.push(String::from("GRTUSDT"));
symbol_vec.push(String::from("AAVEUSDT"));
symbol_vec.push(String::from("EGLDUSDT"));
symbol_vec.push(String::from("LDOUSDT"));
symbol_vec.push(String::from("STXUSDT"));
symbol_vec.push(String::from("MKRUSDT"));
symbol_vec.push(String::from("OPUSDT"));
*valid_usdt_trade_vec = symbol_vec;
delete_all_rows(&table_name).await?;
insert_records(&table_name, &columns, &value_wrapper).await?;
}
// println!("valid USDT trades 완료");
// }
Ok(())
}