mirror of
https://github.com/NexVeridian/ark-invest-api-rust-data.git
synced 2025-09-02 09:59:12 +00:00
feat: CRCL
This commit is contained in:
parent
e297be713e
commit
86edeab90e
1 changed files with 31 additions and 0 deletions
|
@ -9,6 +9,7 @@ use crate::util::df::DF;
|
||||||
#[derive(Debug, strum_macros::Display, EnumIter, Clone, Copy, PartialEq, Eq)]
|
#[derive(Debug, strum_macros::Display, EnumIter, Clone, Copy, PartialEq, Eq)]
|
||||||
pub enum Ticker {
|
pub enum Ticker {
|
||||||
ARKW,
|
ARKW,
|
||||||
|
CRLC,
|
||||||
CRWV,
|
CRWV,
|
||||||
DKNG,
|
DKNG,
|
||||||
ETOR,
|
ETOR,
|
||||||
|
@ -31,6 +32,7 @@ impl Ticker {
|
||||||
pub fn format(&self, df: DF) -> Result<DF, Error> {
|
pub fn format(&self, df: DF) -> Result<DF, Error> {
|
||||||
match self {
|
match self {
|
||||||
Self::ARKW => Self::arkw(df),
|
Self::ARKW => Self::arkw(df),
|
||||||
|
Self::CRLC => Self::crlc(df),
|
||||||
Self::CRWV => Self::crwv(df),
|
Self::CRWV => Self::crwv(df),
|
||||||
Self::DKNG => Self::dkng(df),
|
Self::DKNG => Self::dkng(df),
|
||||||
Self::ETOR => Self::etor(df),
|
Self::ETOR => Self::etor(df),
|
||||||
|
@ -93,6 +95,24 @@ impl Ticker {
|
||||||
Ok(df.into())
|
Ok(df.into())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
fn crlc(df: DF) -> Result<DF, Error> {
|
||||||
|
let mut df = df.collect()?;
|
||||||
|
|
||||||
|
if let Ok(x) = df
|
||||||
|
.clone()
|
||||||
|
.lazy()
|
||||||
|
.with_columns(vec![when(col("company").eq(lit("CIRCLE INTERNET GROUP")))
|
||||||
|
.then(lit("CRLC"))
|
||||||
|
.otherwise(col("ticker"))
|
||||||
|
.alias("ticker")])
|
||||||
|
.collect()
|
||||||
|
{
|
||||||
|
df = x;
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(df.into())
|
||||||
|
}
|
||||||
|
|
||||||
fn crwv(df: DF) -> Result<DF, Error> {
|
fn crwv(df: DF) -> Result<DF, Error> {
|
||||||
let mut df = df.collect()?;
|
let mut df = df.collect()?;
|
||||||
|
|
||||||
|
@ -302,6 +322,17 @@ mod tests {
|
||||||
&[Some("ARKB"), Some("ARKB"), Some("ARKB"), Some("ARKB")],
|
&[Some("ARKB"), Some("ARKB"), Some("ARKB"), Some("ARKB")],
|
||||||
)?,
|
)?,
|
||||||
)]
|
)]
|
||||||
|
#[case::crlc(
|
||||||
|
Ticker::CRLC,
|
||||||
|
defualt_df(
|
||||||
|
&[Some("CRLC"), None::<&str>],
|
||||||
|
&[Some("CIRCLE INTERNET GROUP"), Some("CIRCLE INTERNET GROUP")],
|
||||||
|
)?,
|
||||||
|
defualt_df(
|
||||||
|
&[Some("CRLC"), Some("CRLC")],
|
||||||
|
&[Some("CIRCLE INTERNET GROUP"), Some("CIRCLE INTERNET GROUP")]
|
||||||
|
)?,
|
||||||
|
)]
|
||||||
#[case::crwv(
|
#[case::crwv(
|
||||||
Ticker::CRWV,
|
Ticker::CRWV,
|
||||||
defualt_df(
|
defualt_df(
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue