alpaca-data 0.25.1

use std::collections::BTreeMap;

use rust_decimal::Decimal;
use serde::{Deserialize, Serialize};

pub type UnknownCorporateAction = BTreeMap<String, serde_json::Value>;

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct CorporateActions {
    #[serde(default)]
    pub forward_splits: Vec<ForwardSplit>,
    #[serde(default)]
    pub reverse_splits: Vec<ReverseSplit>,
    #[serde(default)]
    pub unit_splits: Vec<UnitSplit>,
    #[serde(default)]
    pub stock_dividends: Vec<StockDividend>,
    #[serde(default)]
    pub cash_dividends: Vec<CashDividend>,
    #[serde(default)]
    pub spin_offs: Vec<SpinOff>,
    #[serde(default)]
    pub cash_mergers: Vec<CashMerger>,
    #[serde(default)]
    pub stock_mergers: Vec<StockMerger>,
    #[serde(default)]
    pub stock_and_cash_mergers: Vec<StockAndCashMerger>,
    #[serde(default)]
    pub redemptions: Vec<Redemption>,
    #[serde(default)]
    pub name_changes: Vec<NameChange>,
    #[serde(default)]
    pub worthless_removals: Vec<WorthlessRemoval>,
    #[serde(default)]
    pub rights_distributions: Vec<RightsDistribution>,
    #[serde(default)]
    pub contract_adjustments: Vec<UnknownCorporateAction>,
    #[serde(default)]
    pub partial_calls: Vec<UnknownCorporateAction>,
    #[serde(flatten)]
    pub other: BTreeMap<String, Vec<UnknownCorporateAction>>,
}

impl CorporateActions {
    pub(crate) fn merge(&mut self, mut next: Self) {
        self.forward_splits.append(&mut next.forward_splits);
        self.reverse_splits.append(&mut next.reverse_splits);
        self.unit_splits.append(&mut next.unit_splits);
        self.stock_dividends.append(&mut next.stock_dividends);
        self.cash_dividends.append(&mut next.cash_dividends);
        self.spin_offs.append(&mut next.spin_offs);
        self.cash_mergers.append(&mut next.cash_mergers);
        self.stock_mergers.append(&mut next.stock_mergers);
        self.stock_and_cash_mergers
            .append(&mut next.stock_and_cash_mergers);
        self.redemptions.append(&mut next.redemptions);
        self.name_changes.append(&mut next.name_changes);
        self.worthless_removals.append(&mut next.worthless_removals);
        self.rights_distributions
            .append(&mut next.rights_distributions);
        self.contract_adjustments
            .append(&mut next.contract_adjustments);
        self.partial_calls.append(&mut next.partial_calls);

        for (key, mut values) in next.other {
            self.other.entry(key).or_default().append(&mut values);
        }
    }
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct ForwardSplit {
    pub id: String,
    pub symbol: String,
    pub cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub new_rate: Decimal,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub old_rate: Decimal,
    pub process_date: String,
    pub ex_date: String,
    pub record_date: Option<String>,
    pub payable_date: Option<String>,
    pub due_bill_redemption_date: Option<String>,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct ReverseSplit {
    pub id: String,
    pub symbol: String,
    pub old_cusip: String,
    pub new_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub new_rate: Decimal,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub old_rate: Decimal,
    pub process_date: String,
    pub ex_date: String,
    pub record_date: Option<String>,
    pub payable_date: Option<String>,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct UnitSplit {
    pub id: String,
    pub old_symbol: String,
    pub old_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub old_rate: Decimal,
    pub new_symbol: String,
    pub new_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub new_rate: Decimal,
    pub alternate_symbol: String,
    pub alternate_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub alternate_rate: Decimal,
    pub process_date: String,
    pub effective_date: String,
    pub payable_date: Option<String>,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct StockDividend {
    pub id: String,
    pub symbol: String,
    pub cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub rate: Decimal,
    pub process_date: String,
    pub ex_date: String,
    pub record_date: Option<String>,
    pub payable_date: Option<String>,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct CashDividend {
    pub id: String,
    pub symbol: String,
    pub cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub rate: Decimal,
    pub special: bool,
    pub foreign: bool,
    pub process_date: String,
    pub ex_date: String,
    pub record_date: Option<String>,
    pub payable_date: Option<String>,
    pub due_bill_on_date: Option<String>,
    pub due_bill_off_date: Option<String>,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct SpinOff {
    pub id: String,
    pub source_symbol: String,
    pub source_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub source_rate: Decimal,
    pub new_symbol: String,
    pub new_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub new_rate: Decimal,
    pub process_date: String,
    pub ex_date: String,
    pub record_date: Option<String>,
    pub payable_date: Option<String>,
    pub due_bill_redemption_date: Option<String>,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct CashMerger {
    pub id: String,
    pub acquirer_symbol: Option<String>,
    pub acquirer_cusip: Option<String>,
    pub acquiree_symbol: String,
    pub acquiree_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub rate: Decimal,
    pub process_date: String,
    pub effective_date: String,
    pub payable_date: Option<String>,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct StockMerger {
    pub id: String,
    pub acquirer_symbol: String,
    pub acquirer_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub acquirer_rate: Decimal,
    pub acquiree_symbol: String,
    pub acquiree_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub acquiree_rate: Decimal,
    pub process_date: String,
    pub effective_date: String,
    pub payable_date: Option<String>,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct StockAndCashMerger {
    pub id: String,
    pub acquirer_symbol: String,
    pub acquirer_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub acquirer_rate: Decimal,
    pub acquiree_symbol: String,
    pub acquiree_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub acquiree_rate: Decimal,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub cash_rate: Decimal,
    pub process_date: String,
    pub effective_date: String,
    pub payable_date: Option<String>,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct Redemption {
    pub id: String,
    pub symbol: String,
    pub cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub rate: Decimal,
    pub process_date: String,
    pub payable_date: Option<String>,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct NameChange {
    pub id: String,
    pub old_symbol: String,
    pub old_cusip: String,
    pub new_symbol: String,
    pub new_cusip: String,
    pub process_date: String,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct WorthlessRemoval {
    pub id: String,
    pub symbol: String,
    pub cusip: String,
    pub process_date: String,
}

#[derive(Clone, Debug, Default, PartialEq, Serialize, Deserialize)]
pub struct RightsDistribution {
    pub id: String,
    pub source_symbol: String,
    pub source_cusip: String,
    pub new_symbol: String,
    pub new_cusip: String,
    #[serde(deserialize_with = "alpaca_core::decimal::deserialize_decimal_from_string_or_number")]
    pub rate: Decimal,
    pub process_date: String,
    pub ex_date: String,
    pub record_date: Option<String>,
    pub payable_date: String,
    pub expiration_date: Option<String>,
}