use crate::message::commands::IRCMessageParseExt;
use crate::message::twitch::{Badge, Emote, RGBColor, TwitchUserBasics};
use crate::message::{IRCMessage, ServerMessageParseError};
use chrono::{DateTime, Utc};
use std::convert::TryFrom;
#[derive(Debug, Clone, PartialEq)]
pub struct UserNoticeMessage {
pub channel_login: String,
pub channel_id: String,
pub sender: TwitchUserBasics,
pub message_text: Option<String>,
pub system_message: String,
pub event: UserNoticeEvent,
pub badge_info: Vec<Badge>,
pub badges: Vec<Badge>,
pub emotes: Vec<Emote>,
pub name_color: Option<RGBColor>,
pub message_id: String,
pub server_timestamp: DateTime<Utc>,
pub source: IRCMessage,
}
#[derive(Debug, Clone, PartialEq)]
pub struct SubGiftPromo {
pub total_gifts: u64,
pub promo_name: String,
}
impl SubGiftPromo {
fn parse_if_present(
source: &IRCMessage,
) -> Result<Option<SubGiftPromo>, ServerMessageParseError> {
if let (Some(total_gifts), Some(promo_name)) = (
source.try_get_optional_number("msg-param-promo-gift-total")?,
source
.try_get_optional_nonempty_tag_value("msg-param-promo-name")?
.map(|s| s.to_owned()),
) {
Ok(Some(SubGiftPromo {
total_gifts,
promo_name,
}))
} else {
Ok(None)
}
}
}
#[non_exhaustive]
#[derive(Debug, Clone, PartialEq)]
pub enum UserNoticeEvent {
SubOrResub {
is_resub: bool,
cumulative_months: u64,
streak_months: Option<u64>,
sub_plan: String,
sub_plan_name: String,
},
Raid {
viewer_count: u64,
profile_image_url: String,
},
SubGift {
is_sender_anonymous: bool,
cumulative_months: u64,
recipient: TwitchUserBasics,
sub_plan: String,
sub_plan_name: String,
num_gifted_months: u64,
},
SubMysteryGift {
mass_gift_count: u64,
sender_total_gifts: u64,
sub_plan: String,
},
AnonSubMysteryGift {
mass_gift_count: u64,
sub_plan: String,
},
GiftPaidUpgrade {
gifter_login: String,
gifter_name: String,
promotion: Option<SubGiftPromo>,
},
AnonGiftPaidUpgrade {
promotion: Option<SubGiftPromo>,
},
Ritual {
ritual_name: String,
},
BitsBadgeTier {
threshold: u64,
},
#[doc(hidden)]
Unknown,
}
impl TryFrom<IRCMessage> for UserNoticeMessage {
type Error = ServerMessageParseError;
fn try_from(source: IRCMessage) -> Result<UserNoticeMessage, ServerMessageParseError> {
if source.command != "USERNOTICE" {
return Err(ServerMessageParseError::MismatchedCommand(source));
}
let sender = TwitchUserBasics {
id: source.try_get_nonempty_tag_value("user-id")?.to_owned(),
login: source.try_get_nonempty_tag_value("login")?.to_owned(),
name: source
.try_get_nonempty_tag_value("display-name")?
.to_owned(),
};
let event_id = source.try_get_nonempty_tag_value("msg-id")?.to_owned();
let event = match event_id.as_str() {
"sub" | "resub" => UserNoticeEvent::SubOrResub {
is_resub: &event_id == "resub",
cumulative_months: source.try_get_number("msg-param-cumulative-months")?,
streak_months: if source.try_get_bool("msg-param-should-share-streak")? {
Some(source.try_get_number("msg-param-streak-months")?)
} else {
None
},
sub_plan: source
.try_get_nonempty_tag_value("msg-param-sub-plan")?
.to_owned(),
sub_plan_name: source
.try_get_nonempty_tag_value("msg-param-sub-plan-name")?
.to_owned(),
},
"raid" => UserNoticeEvent::Raid {
viewer_count: source.try_get_number::<u64>("msg-param-viewerCount")?,
profile_image_url: source
.try_get_nonempty_tag_value("msg-param-profileImageURL")?
.to_owned(),
},
"subgift" | "anonsubgift" => UserNoticeEvent::SubGift {
is_sender_anonymous: event_id == "anonsubgift" || sender.id == "274598607",
cumulative_months: source.try_get_number("msg-param-months")?,
recipient: TwitchUserBasics {
id: source
.try_get_nonempty_tag_value("msg-param-recipient-id")?
.to_owned(),
login: source
.try_get_nonempty_tag_value("msg-param-recipient-user-name")?
.to_owned(),
name: source
.try_get_nonempty_tag_value("msg-param-recipient-display-name")?
.to_owned(),
},
sub_plan: source
.try_get_nonempty_tag_value("msg-param-sub-plan")?
.to_owned(),
sub_plan_name: source
.try_get_nonempty_tag_value("msg-param-sub-plan-name")?
.to_owned(),
num_gifted_months: source.try_get_number("msg-param-gift-months")?,
},
_ if (sender.id == "274598607" && event_id == "submysterygift")
|| event_id == "anonsubmysterygift" =>
{
UserNoticeEvent::AnonSubMysteryGift {
mass_gift_count: source.try_get_number("msg-param-mass-gift-count")?,
sub_plan: source
.try_get_nonempty_tag_value("msg-param-sub-plan")?
.to_owned(),
}
}
"submysterygift" => UserNoticeEvent::SubMysteryGift {
mass_gift_count: source.try_get_number("msg-param-mass-gift-count")?,
sender_total_gifts: source.try_get_number("msg-param-sender-count")?,
sub_plan: source
.try_get_nonempty_tag_value("msg-param-sub-plan")?
.to_owned(),
},
"giftpaidupgrade" => UserNoticeEvent::GiftPaidUpgrade {
gifter_login: source
.try_get_nonempty_tag_value("msg-param-sender-login")?
.to_owned(),
gifter_name: source
.try_get_nonempty_tag_value("msg-param-sender-name")?
.to_owned(),
promotion: SubGiftPromo::parse_if_present(&source)?,
},
"anongiftpaidupgrade" => UserNoticeEvent::AnonGiftPaidUpgrade {
promotion: SubGiftPromo::parse_if_present(&source)?,
},
"ritual" => UserNoticeEvent::Ritual {
ritual_name: source
.try_get_nonempty_tag_value("msg-param-ritual-name")?
.to_owned(),
},
"bitsbadgetier" => UserNoticeEvent::BitsBadgeTier {
threshold: source
.try_get_number::<u64>("msg-param-threshold")?
.to_owned(),
},
_ => UserNoticeEvent::Unknown,
};
let message_text = source.params.get(1).cloned();
let emotes = if let Some(message_text) = &message_text {
source.try_get_emotes("emotes", message_text)?
} else {
vec![]
};
Ok(UserNoticeMessage {
channel_login: source.try_get_channel_login()?.to_owned(),
channel_id: source.try_get_nonempty_tag_value("room-id")?.to_owned(),
sender,
message_text,
system_message: source.try_get_nonempty_tag_value("system-msg")?.to_owned(),
event,
badge_info: source.try_get_badges("badge-info")?.to_owned(),
badges: source.try_get_badges("badges")?.to_owned(),
emotes,
name_color: source.try_get_color("color")?,
message_id: source.try_get_nonempty_tag_value("id")?.to_owned(),
server_timestamp: source.try_get_timestamp("tmi-sent-ts")?.to_owned(),
source,
})
}
}
impl From<UserNoticeMessage> for IRCMessage {
fn from(msg: UserNoticeMessage) -> IRCMessage {
msg.source
}
}
#[cfg(test)]
mod tests {
use crate::message::twitch::{Badge, Emote, RGBColor, TwitchUserBasics};
use crate::message::{IRCMessage, SubGiftPromo, UserNoticeEvent, UserNoticeMessage};
use chrono::{TimeZone, Utc};
use std::convert::TryFrom;
use std::ops::Range;
#[test]
pub fn test_sub() {
let src = "@badge-info=subscriber/0;badges=subscriber/0,premium/1;color=;display-name=fallenseraphhh;emotes=;flags=;id=2a9bea11-a80a-49a0-a498-1642d457f775;login=fallenseraphhh;mod=0;msg-id=sub;msg-param-cumulative-months=1;msg-param-months=0;msg-param-should-share-streak=0;msg-param-sub-plan-name=Channel\\sSubscription\\s(xqcow);msg-param-sub-plan=Prime;room-id=71092938;subscriber=1;system-msg=fallenseraphhh\\ssubscribed\\swith\\sTwitch\\sPrime.;tmi-sent-ts=1582685713242;user-id=224005980;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg,
UserNoticeMessage {
channel_login: "xqcow".to_owned(),
channel_id: "71092938".to_owned(),
sender: TwitchUserBasics {
id: "224005980".to_owned(),
login: "fallenseraphhh".to_owned(),
name: "fallenseraphhh".to_owned(),
},
message_text: None,
system_message: "fallenseraphhh subscribed with Twitch Prime.".to_owned(),
event: UserNoticeEvent::SubOrResub {
is_resub: false,
cumulative_months: 1,
streak_months: None,
sub_plan: "Prime".to_owned(),
sub_plan_name: "Channel Subscription (xqcow)".to_owned(),
},
badge_info: vec![Badge {
name: "subscriber".to_owned(),
version: "0".to_owned(),
}],
badges: vec![
Badge {
name: "subscriber".to_owned(),
version: "0".to_owned(),
},
Badge {
name: "premium".to_owned(),
version: "1".to_owned(),
}
],
emotes: vec![],
name_color: None,
message_id: "2a9bea11-a80a-49a0-a498-1642d457f775".to_owned(),
server_timestamp: Utc.timestamp_millis(1582685713242),
source: irc_message
}
)
}
#[test]
pub fn test_resub() {
let src = "@badge-info=subscriber/2;badges=subscriber/0,battlerite_1/1;color=#0000FF;display-name=Gutrin;emotes=1035663:0-3;flags=;id=e0975c76-054c-4954-8cb0-91b8867ec1ca;login=gutrin;mod=0;msg-id=resub;msg-param-cumulative-months=2;msg-param-months=0;msg-param-should-share-streak=1;msg-param-streak-months=2;msg-param-sub-plan-name=Channel\\sSubscription\\s(xqcow);msg-param-sub-plan=1000;room-id=71092938;subscriber=1;system-msg=Gutrin\\ssubscribed\\sat\\sTier\\s1.\\sThey've\\ssubscribed\\sfor\\s2\\smonths,\\scurrently\\son\\sa\\s2\\smonth\\sstreak!;tmi-sent-ts=1581713640019;user-id=21156217;user-type= :tmi.twitch.tv USERNOTICE #xqcow :xqcL";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg,
UserNoticeMessage {
channel_login: "xqcow".to_owned(),
channel_id: "71092938".to_owned(),
sender: TwitchUserBasics {
id: "21156217".to_owned(),
login: "gutrin".to_owned(),
name: "Gutrin".to_owned(),
},
message_text: Some("xqcL".to_owned()),
system_message: "Gutrin subscribed at Tier 1. They've subscribed for 2 months, currently on a 2 month streak!".to_owned(),
event: UserNoticeEvent::SubOrResub {
is_resub: true,
cumulative_months: 2,
streak_months: Some(2),
sub_plan: "1000".to_owned(),
sub_plan_name: "Channel Subscription (xqcow)".to_owned(),
},
badge_info: vec![Badge {
name: "subscriber".to_owned(),
version: "2".to_owned(),
}],
badges: vec![
Badge {
name: "subscriber".to_owned(),
version: "0".to_owned(),
},
Badge {
name: "battlerite_1".to_owned(),
version: "1".to_owned(),
}
],
emotes: vec![
Emote {
id: "1035663".to_owned(),
char_range: Range { start: 0, end: 4},
code: "xqcL".to_owned()
}
],
name_color: Some(RGBColor {
r: 0x00,
g: 0x00,
b: 0xFF,
}),
message_id: "e0975c76-054c-4954-8cb0-91b8867ec1ca".to_owned(),
server_timestamp: Utc.timestamp_millis(1581713640019),
source: irc_message
}
)
}
#[test]
pub fn test_resub_no_share_streak() {
let src = "@badge-info=;badges=premium/1;color=#8A2BE2;display-name=rene_rs;emotes=;flags=;id=ca1f02fb-77ec-487d-a9b3-bc4bfef2fe8b;login=rene_rs;mod=0;msg-id=resub;msg-param-cumulative-months=11;msg-param-months=0;msg-param-should-share-streak=0;msg-param-sub-plan-name=Channel\\sSubscription\\s(xqcow);msg-param-sub-plan=Prime;room-id=71092938;subscriber=0;system-msg=rene_rs\\ssubscribed\\swith\\sTwitch\\sPrime.\\sThey've\\ssubscribed\\sfor\\s11\\smonths!;tmi-sent-ts=1590628650446;user-id=171356987;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg,
UserNoticeMessage {
channel_login: "xqcow".to_owned(),
channel_id: "71092938".to_owned(),
sender: TwitchUserBasics {
id: "171356987".to_owned(),
login: "rene_rs".to_owned(),
name: "rene_rs".to_owned(),
},
message_text: None,
system_message:
"rene_rs subscribed with Twitch Prime. They've subscribed for 11 months!"
.to_owned(),
event: UserNoticeEvent::SubOrResub {
is_resub: true,
cumulative_months: 11,
streak_months: None,
sub_plan: "Prime".to_owned(),
sub_plan_name: "Channel Subscription (xqcow)".to_owned(),
},
badge_info: vec![],
badges: vec![Badge {
name: "premium".to_owned(),
version: "1".to_owned(),
},],
emotes: vec![],
name_color: Some(RGBColor {
r: 0x8A,
g: 0x2B,
b: 0xE2,
}),
message_id: "ca1f02fb-77ec-487d-a9b3-bc4bfef2fe8b".to_owned(),
server_timestamp: Utc.timestamp_millis(1590628650446),
source: irc_message
}
)
}
#[test]
pub fn test_raid() {
let src = "@badge-info=;badges=glhf-pledge/1;color=#FF69B4;display-name=iamelisabete;emotes=;flags=;id=bb99dda7-3736-4583-9114-52aa11b23d17;login=iamelisabete;mod=0;msg-id=raid;msg-param-displayName=iamelisabete;msg-param-login=iamelisabete;msg-param-profileImageURL=https://static-cdn.jtvnw.net/jtv_user_pictures/cae3ca63-510d-4715-b4ce-059dcf938978-profile_image-70x70.png;msg-param-viewerCount=430;room-id=71092938;subscriber=0;system-msg=430\\sraiders\\sfrom\\siamelisabete\\shave\\sjoined!;tmi-sent-ts=1594517796120;user-id=155874595;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.sender,
TwitchUserBasics {
id: "155874595".to_owned(),
login: "iamelisabete".to_owned(),
name: "iamelisabete".to_owned(),
}
);
assert_eq!(msg.event, UserNoticeEvent::Raid {
viewer_count: 430,
profile_image_url: "https://static-cdn.jtvnw.net/jtv_user_pictures/cae3ca63-510d-4715-b4ce-059dcf938978-profile_image-70x70.png".to_owned()
});
}
#[test]
pub fn test_subgift() {
let src = "@badge-info=;badges=sub-gifter/50;color=;display-name=AdamAtReflectStudios;emotes=;flags=;id=e21409b1-d25d-4a1a-b5cf-ef27d8b7030e;login=adamatreflectstudios;mod=0;msg-id=subgift;msg-param-gift-months=1;msg-param-months=2;msg-param-origin-id=da\\s39\\sa3\\see\\s5e\\s6b\\s4b\\s0d\\s32\\s55\\sbf\\sef\\s95\\s60\\s18\\s90\\saf\\sd8\\s07\\s09;msg-param-recipient-display-name=qatarking24xd;msg-param-recipient-id=236653628;msg-param-recipient-user-name=qatarking24xd;msg-param-sender-count=0;msg-param-sub-plan-name=Channel\\sSubscription\\s(xqcow);msg-param-sub-plan=1000;room-id=71092938;subscriber=0;system-msg=AdamAtReflectStudios\\sgifted\\sa\\sTier\\s1\\ssub\\sto\\sqatarking24xd!;tmi-sent-ts=1594583782376;user-id=211711554;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::SubGift {
is_sender_anonymous: false,
cumulative_months: 2,
recipient: TwitchUserBasics {
id: "236653628".to_owned(),
login: "qatarking24xd".to_owned(),
name: "qatarking24xd".to_owned()
},
sub_plan: "1000".to_owned(),
sub_plan_name: "Channel Subscription (xqcow)".to_owned(),
num_gifted_months: 1
}
)
}
#[test]
pub fn test_subgift_ananonymousgifter() {
let src = "@badge-info=;badges=;color=;display-name=AnAnonymousGifter;emotes=;flags=;id=62c3fd39-84cc-452a-9096-628a5306633a;login=ananonymousgifter;mod=0;msg-id=subgift;msg-param-fun-string=FunStringThree;msg-param-gift-months=1;msg-param-months=13;msg-param-origin-id=da\\s39\\sa3\\see\\s5e\\s6b\\s4b\\s0d\\s32\\s55\\sbf\\sef\\s95\\s60\\s18\\s90\\saf\\sd8\\s07\\s09;msg-param-recipient-display-name=Dot0422;msg-param-recipient-id=151784015;msg-param-recipient-user-name=dot0422;msg-param-sub-plan-name=Channel\\sSubscription\\s(xqcow);msg-param-sub-plan=1000;room-id=71092938;subscriber=0;system-msg=An\\sanonymous\\suser\\sgifted\\sa\\sTier\\s1\\ssub\\sto\\sDot0422!\\s;tmi-sent-ts=1594495108936;user-id=274598607;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::SubGift {
is_sender_anonymous: true,
cumulative_months: 13,
recipient: TwitchUserBasics {
id: "151784015".to_owned(),
login: "dot0422".to_owned(),
name: "Dot0422".to_owned()
},
sub_plan: "1000".to_owned(),
sub_plan_name: "Channel Subscription (xqcow)".to_owned(),
num_gifted_months: 1
}
)
}
#[test]
pub fn test_anonsubgift() {
let src = "@badge-info=;badges=;color=;display-name=xQcOW;emotes=;flags=;id=e21409b1-d25d-4a1a-b5cf-ef27d8b7030e;login=xqcow;mod=0;msg-id=anonsubgift;msg-param-gift-months=1;msg-param-months=2;msg-param-origin-id=da\\s39\\sa3\\see\\s5e\\s6b\\s4b\\s0d\\s32\\s55\\sbf\\sef\\s95\\s60\\s18\\s90\\saf\\sd8\\s07\\s09;msg-param-recipient-display-name=qatarking24xd;msg-param-recipient-id=236653628;msg-param-recipient-user-name=qatarking24xd;msg-param-sender-count=0;msg-param-sub-plan-name=Channel\\sSubscription\\s(xqcow);msg-param-sub-plan=1000;room-id=71092938;subscriber=0;system-msg=An\\sanonymous\\sgifter\\sgifted\\sa\\sTier\\s1\\ssub\\sto\\sqatarking24xd!;tmi-sent-ts=1594583782376;user-id=71092938;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::SubGift {
is_sender_anonymous: true,
cumulative_months: 2,
recipient: TwitchUserBasics {
id: "236653628".to_owned(),
login: "qatarking24xd".to_owned(),
name: "qatarking24xd".to_owned()
},
sub_plan: "1000".to_owned(),
sub_plan_name: "Channel Subscription (xqcow)".to_owned(),
num_gifted_months: 1
}
)
}
#[test]
pub fn test_submysterygift() {
let src = "@badge-info=;badges=sub-gifter/50;color=;display-name=AdamAtReflectStudios;emotes=;flags=;id=049e6371-7023-4fca-8605-7dec60e72e12;login=adamatreflectstudios;mod=0;msg-id=submysterygift;msg-param-mass-gift-count=20;msg-param-origin-id=1f\\sbe\\sbb\\s4a\\s81\\s9a\\s65\\sd1\\s4b\\s77\\sf5\\s23\\s16\\s4a\\sd3\\s13\\s09\\se7\\sbe\\s55;msg-param-sender-count=100;msg-param-sub-plan=1000;room-id=71092938;subscriber=0;system-msg=AdamAtReflectStudios\\sis\\sgifting\\s20\\sTier\\s1\\sSubs\\sto\\sxQcOW's\\scommunity!\\sThey've\\sgifted\\sa\\stotal\\sof\\s100\\sin\\sthe\\schannel!;tmi-sent-ts=1594583777669;user-id=211711554;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::SubMysteryGift {
mass_gift_count: 20,
sender_total_gifts: 100,
sub_plan: "1000".to_owned()
}
)
}
#[test]
pub fn test_submysterygift_ananonymousgifter() {
let src = "@badge-info=;badges=;color=;display-name=AnAnonymousGifter;emotes=;flags=;id=8db97752-3dee-460b-9001-e925d0e2ba5b;login=ananonymousgifter;mod=0;msg-id=submysterygift;msg-param-mass-gift-count=10;msg-param-origin-id=13\\s33\\sed\\sc0\\sef\\sa0\\s7b\\s9b\\s48\\s59\\scb\\scc\\se4\\s39\\s7b\\s90\\sf9\\s54\\s75\\s66;msg-param-sub-plan=1000;room-id=71092938;subscriber=0;system-msg=An\\sanonymous\\suser\\sis\\sgifting\\s10\\sTier\\s1\\sSubs\\sto\\sxQcOW's\\scommunity!;tmi-sent-ts=1585447099603;user-id=274598607;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::AnonSubMysteryGift {
mass_gift_count: 10,
sub_plan: "1000".to_owned()
}
)
}
#[test]
pub fn test_anonsubmysterygift() {
let src = "@badge-info=;badges=;color=;display-name=xQcOW;emotes=;flags=;id=8db97752-3dee-460b-9001-e925d0e2ba5b;login=xqcow;mod=0;msg-id=anonsubmysterygift;msg-param-mass-gift-count=15;msg-param-origin-id=13\\s33\\sed\\sc0\\sef\\sa0\\s7b\\s9b\\s48\\s59\\scb\\scc\\se4\\s39\\s7b\\s90\\sf9\\s54\\s75\\s66;msg-param-sub-plan=2000;room-id=71092938;subscriber=0;system-msg=An\\sanonymous\\suser\\sis\\sgifting\\s10\\sTier\\s1\\sSubs\\sto\\sxQcOW's\\scommunity!;tmi-sent-ts=1585447099603;user-id=71092938;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::AnonSubMysteryGift {
mass_gift_count: 15,
sub_plan: "2000".to_owned()
}
)
}
#[test]
pub fn test_giftpaidupgrade_no_promo() {
let src = "@badge-info=subscriber/2;badges=subscriber/2;color=#00FFF5;display-name=CrazyCrackAnimal;emotes=;flags=;id=7006f242-a45c-4e07-83b3-11f9c6d1ee28;login=crazycrackanimal;mod=0;msg-id=giftpaidupgrade;msg-param-sender-login=stridezgum;msg-param-sender-name=Stridezgum;room-id=71092938;subscriber=1;system-msg=CrazyCrackAnimal\\sis\\scontinuing\\sthe\\sGift\\sSub\\sthey\\sgot\\sfrom\\sStridezgum!;tmi-sent-ts=1594518849459;user-id=86082877;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::GiftPaidUpgrade {
gifter_login: "stridezgum".to_owned(),
gifter_name: "Stridezgum".to_owned(),
promotion: None
}
)
}
#[test]
pub fn test_giftpaidupgrade_with_promo() {
let src = "@badge-info=subscriber/2;badges=subscriber/2;color=#00FFF5;display-name=CrazyCrackAnimal;emotes=;flags=;id=7006f242-a45c-4e07-83b3-11f9c6d1ee28;login=crazycrackanimal;mod=0;msg-id=giftpaidupgrade;msg-param-sender-login=stridezgum;msg-param-sender-name=Stridezgum;msg-param-promo-name=TestSubtember2020;msg-param-promo-gift-total=4003;room-id=71092938;subscriber=1;system-msg=CrazyCrackAnimal\\sis\\scontinuing\\sthe\\sGift\\sSub\\sthey\\sgot\\sfrom\\sStridezgum!\\sbla\\sbla\\bla\\sstuff\\sabout\\spromo\\shere;tmi-sent-ts=1594518849459;user-id=86082877;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::GiftPaidUpgrade {
gifter_login: "stridezgum".to_owned(),
gifter_name: "Stridezgum".to_owned(),
promotion: Some(SubGiftPromo {
promo_name: "TestSubtember2020".to_owned(),
total_gifts: 4003
})
}
)
}
#[test]
pub fn test_anongiftpaidupgrade_no_promo() {
let src = "@badge-info=subscriber/1;badges=subscriber/0,premium/1;color=#8A2BE2;display-name=samura1jack_ttv;emotes=;flags=;id=144ee636-0c1d-404e-8b29-35449a045a7e;login=samura1jack_ttv;mod=0;msg-id=anongiftpaidupgrade;room-id=71092938;subscriber=1;system-msg=samura1jack_ttv\\sis\\scontinuing\\sthe\\sGift\\sSub\\sthey\\sgot\\sfrom\\san\\sanonymous\\suser!;tmi-sent-ts=1594327421732;user-id=102707709;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::AnonGiftPaidUpgrade { promotion: None }
)
}
#[test]
pub fn test_anongiftpaidupgrade_with_promo() {
let src = "@badge-info=subscriber/1;badges=subscriber/0,premium/1;color=#8A2BE2;display-name=samura1jack_ttv;emotes=;flags=;id=144ee636-0c1d-404e-8b29-35449a045a7e;msg-param-promo-name=TestSubtember2020;msg-param-promo-gift-total=4003;login=samura1jack_ttv;mod=0;msg-id=anongiftpaidupgrade;room-id=71092938;subscriber=1;system-msg=samura1jack_ttv\\sis\\scontinuing\\sthe\\sGift\\sSub\\sthey\\sgot\\sfrom\\san\\sanonymous\\suser!\\sbla\\sbla\\bla\\sstuff\\sabout\\spromo\\shere;tmi-sent-ts=1594327421732;user-id=102707709;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::AnonGiftPaidUpgrade {
promotion: Some(SubGiftPromo {
promo_name: "TestSubtember2020".to_owned(),
total_gifts: 4003
})
}
)
}
#[test]
pub fn test_ritual() {
let src = "@badge-info=;badges=;color=;display-name=SevenTest1;emotes=30259:0-6;id=37feed0f-b9c7-4c3a-b475-21c6c6d21c3d;login=seventest1;mod=0;msg-id=ritual;msg-param-ritual-name=new_chatter;room-id=6316121;subscriber=0;system-msg=Seventoes\\sis\\snew\\shere!;tmi-sent-ts=1508363903826;turbo=0;user-id=131260580;user-type= :tmi.twitch.tv USERNOTICE #seventoes :HeyGuys";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::Ritual {
ritual_name: "new_chatter".to_owned()
}
)
}
#[test]
pub fn test_bitsbadgetier() {
let src = "@badge-info=subscriber/2;badges=subscriber/2,bits/1000;color=#FF4500;display-name=whoopiix;emotes=;flags=;id=d2b32a02-3071-4c52-b2ce-bc3716acdc44;login=whoopiix;mod=0;msg-id=bitsbadgetier;msg-param-threshold=1000;room-id=71092938;subscriber=1;system-msg=bits\\sbadge\\stier\\snotification;tmi-sent-ts=1594520403813;user-id=104252055;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.event,
UserNoticeEvent::BitsBadgeTier { threshold: 1000 }
)
}
#[test]
pub fn test_unknown() {
let src = "@badge-info=;badges=sub-gifter/50;color=;display-name=AdamAtReflectStudios;emotes=;flags=;id=7f1336e4-f84a-4510-809d-e57bf50af0cc;login=adamatreflectstudios;mod=0;msg-id=rewardgift;msg-param-domain=pride_megacommerce_2020;msg-param-selected-count=100;msg-param-total-reward-count=100;msg-param-trigger-amount=20;msg-param-trigger-type=SUBGIFT;room-id=71092938;subscriber=0;system-msg=AdamAtReflectStudios's\\sGift\\sshared\\srewards\\sto\\s100\\sothers\\sin\\sChat!;tmi-sent-ts=1594583778756;user-id=211711554;user-type= :tmi.twitch.tv USERNOTICE #xqcow";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(msg.event, UserNoticeEvent::Unknown)
}
#[test]
pub fn test_sneaky_action_invalid_emote_tag() {
let src = r"@badge-info=subscriber/23;badges=moderator/1,subscriber/12;color=#19E6E6;display-name=randers;emotes=25:7-11,23-27/499:29-30;flags=;id=8c2918c2-adf4-4208-a554-8a72d016de70;login=randers;mod=1;msg-id=resub;msg-param-cumulative-months=23;msg-param-months=0;msg-param-should-share-streak=1;msg-param-streak-months=23;msg-param-sub-plan-name=look\sat\sthose\sshitty\semotes,\srip\s$5\sLUL;msg-param-sub-plan=1000;room-id=11148817;subscriber=1;system-msg=randers\ssubscribed\sat\sTier\s1.\sThey've\ssubscribed\sfor\s23\smonths,\scurrently\son\sa\s23\smonth\sstreak!;tmi-sent-ts=1595497450553;user-id=40286300;user-type=mod :tmi.twitch.tv USERNOTICE #pajlada :ACTION Kappa TEST TEST Kappa :)";
let irc_message = IRCMessage::parse(src).unwrap();
let msg = UserNoticeMessage::try_from(irc_message.clone()).unwrap();
assert_eq!(
msg.message_text,
Some("ACTION Kappa TEST TEST Kappa :)".to_owned())
);
assert_eq!(
msg.emotes,
vec![
Emote {
id: "25".to_owned(),
char_range: Range { start: 7, end: 12 },
code: " Kapp".to_owned()
},
Emote {
id: "25".to_owned(),
char_range: Range { start: 23, end: 28 },
code: " Kapp".to_owned()
},
Emote {
id: "499".to_owned(),
char_range: Range { start: 29, end: 31 },
code: " :".to_owned()
},
]
)
}
}