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

Change parameter data type

Browse Source
This commit is contained in:
Sik Yoon 2023-12-02 03:02:06 +09:00
parent 6a8cfa5c6f
commit f8e702a462
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/value_estimation_team/indicators/rsi.rs
View File

@ -3,6 +3,7 @@
use crate::database_control::*; use crate::database_control::*;
use crate::value_estimation_team::datapoints::price_data::RealtimePriceData; use crate::value_estimation_team::datapoints::price_data::RealtimePriceData;
use crate::strategy_team::FilteredData;
use csv::{DeserializeRecordsIter, StringRecord}; use csv::{DeserializeRecordsIter, StringRecord};
use futures::future::try_join_all; use futures::future::try_join_all;
use serde::Deserialize; use serde::Deserialize;
@ -30,7 +31,7 @@ impl RsiData {
pub async fn rsi( pub async fn rsi(
rsi_number: usize, rsi_number: usize,
input_rt_data: &Vec<(String, Vec<RealtimePriceData>)>, input_rt_data: &Vec<(String, Vec<RealtimePriceData>)>,
filtered_symbols: &Vec<(String, i64)>, filtered_symbols: &Vec<FilteredData>,
) -> Result<Vec<(String, Vec<RsiData>)>, Box<dyn std::error::Error + Send + Sync>> { ) -> Result<Vec<(String, Vec<RsiData>)>, Box<dyn std::error::Error + Send + Sync>> {
let instant = Instant::now(); let instant = Instant::now();
@ -41,7 +42,7 @@ pub async fn rsi(
for element in filtered_symbols { for element in filtered_symbols {
let element_c = element.clone(); let element_c = element.clone();
let rsi_data_wrapper_arc_c = Arc::clone(&rsi_data_wrapper_arc); let rsi_data_wrapper_arc_c = Arc::clone(&rsi_data_wrapper_arc);
let symbol_search_result = input_rt_data.iter().position(|x| x.0 == *element_c.0); let symbol_search_result = input_rt_data.iter().position(|x| x.0 == *element_c.symbol);
match symbol_search_result { match symbol_search_result {
Some(T) => { Some(T) => {
let input_rt_data_c = input_rt_data.clone(); let input_rt_data_c = input_rt_data.clone();
@ -144,7 +145,7 @@ pub async fn rsi(
rsi_data_vec.push(rsi_data.clone()); rsi_data_vec.push(rsi_data.clone());
} }
let mut rsi_data_wrapper_lock = rsi_data_wrapper_arc_c.lock().await; let mut rsi_data_wrapper_lock = rsi_data_wrapper_arc_c.lock().await;
rsi_data_wrapper_lock.push((element_c.0.clone(), rsi_data_vec.clone())); rsi_data_wrapper_lock.push((element_c.symbol.clone(), rsi_data_vec.clone()));
} }
})); }));
} }