Skip to content

Commit 0154283

Browse files
FIX: Add missing publishers
1 parent 34e30bb commit 0154283

1 file changed

Lines changed: 17 additions & 1 deletion

File tree

rust/dbn/src/publishers.rs

Lines changed: 17 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -592,6 +592,8 @@ impl Dataset {
592592
Publisher::EqusSipFiny,
593593
Publisher::EqusSipFinc,
594594
Publisher::EqusSipXadf,
595+
Publisher::EqusSipCta,
596+
Publisher::EqusSipUtp,
595597
],
596598
}
597599
}
@@ -937,10 +939,14 @@ pub enum Publisher {
937939
EqusSipFinc = 132,
938940
/// US Equities SIP - FINRA Alternative Display Facility
939941
EqusSipXadf = 133,
942+
/// US Equities SIP - CTA
943+
EqusSipCta = 134,
944+
/// US Equities SIP - UTP
945+
EqusSipUtp = 135,
940946
}
941947

942948
/// The number of [`Publisher`] variants.
943-
pub const PUBLISHER_COUNT: usize = 133;
949+
pub const PUBLISHER_COUNT: usize = 135;
944950

945951
impl Publisher {
946952
/// Converts the publisher to its `str` representation.
@@ -1079,6 +1085,8 @@ impl Publisher {
10791085
Self::EqusSipFiny => "EQUS.SIP.FINY",
10801086
Self::EqusSipFinc => "EQUS.SIP.FINC",
10811087
Self::EqusSipXadf => "EQUS.SIP.XADF",
1088+
Self::EqusSipCta => "EQUS.SIP.CTA",
1089+
Self::EqusSipUtp => "EQUS.SIP.UTP",
10821090
}
10831091
}
10841092

@@ -1218,6 +1226,8 @@ impl Publisher {
12181226
Self::EqusSipFiny => Venue::Finy,
12191227
Self::EqusSipFinc => Venue::Finc,
12201228
Self::EqusSipXadf => Venue::Xadf,
1229+
Self::EqusSipCta => Venue::Cta,
1230+
Self::EqusSipUtp => Venue::Utp,
12211231
}
12221232
}
12231233

@@ -1357,6 +1367,8 @@ impl Publisher {
13571367
Self::EqusSipFiny => Dataset::EqusSip,
13581368
Self::EqusSipFinc => Dataset::EqusSip,
13591369
Self::EqusSipXadf => Dataset::EqusSip,
1370+
Self::EqusSipCta => Dataset::EqusSip,
1371+
Self::EqusSipUtp => Dataset::EqusSip,
13601372
}
13611373
}
13621374

@@ -1499,6 +1511,8 @@ impl Publisher {
14991511
(Dataset::EqusSip, Venue::Finy) => Ok(Self::EqusSipFiny),
15001512
(Dataset::EqusSip, Venue::Finc) => Ok(Self::EqusSipFinc),
15011513
(Dataset::EqusSip, Venue::Xadf) => Ok(Self::EqusSipXadf),
1514+
(Dataset::EqusSip, Venue::Cta) => Ok(Self::EqusSipCta),
1515+
(Dataset::EqusSip, Venue::Utp) => Ok(Self::EqusSipUtp),
15021516
_ => Err(Error::conversion::<Self>(format!("({dataset}, {venue})"))),
15031517
}
15041518
}
@@ -1654,6 +1668,8 @@ impl std::str::FromStr for Publisher {
16541668
"EQUS.SIP.FINY" => Ok(Self::EqusSipFiny),
16551669
"EQUS.SIP.FINC" => Ok(Self::EqusSipFinc),
16561670
"EQUS.SIP.XADF" => Ok(Self::EqusSipXadf),
1671+
"EQUS.SIP.CTA" => Ok(Self::EqusSipCta),
1672+
"EQUS.SIP.UTP" => Ok(Self::EqusSipUtp),
16571673
_ => Err(Error::conversion::<Self>(s)),
16581674
}
16591675
}

0 commit comments

Comments
 (0)