NexVeridian/ark-invest-api-rust-data
1
0
Fork 0
mirror of https://github.com/NexVeridian/ark-invest-api-rust-data.git synced 2025-09-02 09:59:12 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

0.3.1

Browse source
This commit is contained in:
Elijah McMorris 2023-06-08 21:24:17 +00:00
parent 26047c418b
commit 9107445cae
Signed by: NexVeridian
SSH key fingerprint: SHA256:bsA1SKZxuEcEVHAy3gY1HUeM5ykRJl0U0kQHQn0hMg8
2 changed files with 32 additions and 31 deletions
Download patch file Download diff file Expand all files Collapse all files

4
NOTES.md Normal file
View file

@ -0,0 +1,4 @@
https://ark-funds.com/ark-trade-notifications/
https://etfs.ark-funds.com/hubfs/idt/trades/ARK_Trade_06072023_0800PM_EST_6480efd1294b5.xls

59
src/util.rs
View file

@ -36,13 +36,6 @@ impl Ticker {
} }
} }
#[derive(Clone, Copy)]
pub enum Source {
Ark,
ApiIncremental,
ApiFull,
}
pub fn merge_csv_to_parquet(ticker: Ticker) -> Result<(), Box<dyn Error>> { pub fn merge_csv_to_parquet(ticker: Ticker) -> Result<(), Box<dyn Error>> {
let mut dfs = vec![]; let mut dfs = vec![];
for x in glob(&format!("data/csv/{}/*", ticker))?.filter_map(Result::ok) { for x in glob(&format!("data/csv/{}/*", ticker))?.filter_map(Result::ok) {
@ -61,6 +54,12 @@ pub fn merge_csv_to_parquet(ticker: Ticker) -> Result<(), Box<dyn Error>> {
Ok(()) Ok(())
} }
pub enum Source {
Ark,
ApiIncremental,
ApiFull,
}
pub fn update_parquet(ticker: Ticker, source: Source) -> Result<(), Box<dyn Error>> { pub fn update_parquet(ticker: Ticker, source: Source) -> Result<(), Box<dyn Error>> {
let mut df = read_parquet(ticker)?; let mut df = read_parquet(ticker)?;
let last_day = df.clone().collect()?.column("date").unwrap().max(); let last_day = df.clone().collect()?.column("date").unwrap().max();
@ -249,26 +248,7 @@ pub fn get_api(ticker: Ticker, last_day: Option<i32>) -> Result<LazyFrame, Box<d
format!("https://api.nexveridian.com/ark_holdings?ticker={}", ticker) format!("https://api.nexveridian.com/ark_holdings?ticker={}", ticker)
} }
}; };
let response = Client::builder() get_data_url(url, Reader::Json)
.user_agent("Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.3")
.build()?.get(url).send()?;
if !response.status().is_success() {
return Err(format!(
"HTTP request failed with status code: {:?}",
response.status()
)
.into());
}
let data = response.text()?.into_bytes();
let json_string = String::from_utf8(data)?;
let json: Value = serde_json::from_str(&json_string)?;
let df = JsonReader::new(Cursor::new(json.to_string()))
.finish()?
.lazy();
Ok(df)
} }
pub fn get_csv_ark(ticker: Ticker) -> Result<LazyFrame, Box<dyn Error>> { pub fn get_csv_ark(ticker: Ticker) -> Result<LazyFrame, Box<dyn Error>> {
@ -276,7 +256,15 @@ pub fn get_csv_ark(ticker: Ticker) -> Result<LazyFrame, Box<dyn Error>> {
Ticker::ARKVC => "https://ark-ventures.com/wp-content/uploads/funds-etf-csv/ARK_VENTURE_FUND_HOLDINGS.csv".to_owned(), Ticker::ARKVC => "https://ark-ventures.com/wp-content/uploads/funds-etf-csv/ARK_VENTURE_FUND_HOLDINGS.csv".to_owned(),
_ => format!("https://ark-funds.com/wp-content/uploads/funds-etf-csv/ARK_{}_ETF_{}_HOLDINGS.csv", ticker.value(), ticker), _ => format!("https://ark-funds.com/wp-content/uploads/funds-etf-csv/ARK_{}_ETF_{}_HOLDINGS.csv", ticker.value(), ticker),
}; };
get_data_url(url, Reader::Csv)
}
pub enum Reader {
Csv,
Json,
}
pub fn get_data_url(url: String, reader: Reader) -> Result<LazyFrame, Box<dyn Error>> {
let response = Client::builder() let response = Client::builder()
.user_agent("Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.3") .user_agent("Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.3")
.build()?.get(url).send()?; .build()?.get(url).send()?;
@ -291,10 +279,19 @@ pub fn get_csv_ark(ticker: Ticker) -> Result<LazyFrame, Box<dyn Error>> {
let data = response.text()?.into_bytes(); let data = response.text()?.into_bytes();
let df = CsvReader::new(Cursor::new(data)) let df = match reader {
.has_header(true) Reader::Csv => CsvReader::new(Cursor::new(data))
.finish()? .has_header(true)
.lazy(); .finish()?
.lazy(),
Reader::Json => {
let json_string = String::from_utf8(data)?;
let json: Value = serde_json::from_str(&json_string)?;
JsonReader::new(Cursor::new(json.to_string()))
.finish()?
.lazy()
}
};
Ok(df) Ok(df)
} }