Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,114 @@ | ||
| #![doc(alias = "channel.shared_chat.end")] | ||
| //! A channel leaves a shared chat session or the session ends. | ||
|
|
||
| use super::*; | ||
|
|
||
| /// [`channel.shared_chat.end`](https://dev.twitch.tv/docs/eventsub/eventsub-subscription-types/#channelshared_chatend): a channel leaves a shared chat session or the session ends. | ||
| #[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)] | ||
| #[cfg_attr(feature = "typed-builder", derive(typed_builder::TypedBuilder))] | ||
| #[cfg_attr(feature = "deny_unknown_fields", serde(deny_unknown_fields))] | ||
| #[non_exhaustive] | ||
| pub struct ChannelSharedChatEndV1 { | ||
| /// The User ID of the channel to receive shared chat session end events for. | ||
| #[cfg_attr(feature = "typed-builder", builder(setter(into)))] | ||
| pub broadcaster_user_id: types::UserId, | ||
| } | ||
|
|
||
| impl ChannelSharedChatEndV1 { | ||
| /// The User ID of the channel to receive shared chat session end events for. | ||
| pub fn broadcaster_user_id(broadcaster_user_id: impl Into<types::UserId>) -> Self { | ||
| Self { | ||
| broadcaster_user_id: broadcaster_user_id.into(), | ||
| } | ||
| } | ||
| } | ||
|
|
||
| impl EventSubscription for ChannelSharedChatEndV1 { | ||
| type Payload = ChannelSharedChatEndV1Payload; | ||
|
|
||
| const EVENT_TYPE: EventType = EventType::ChannelSharedChatEnd; | ||
| #[cfg(feature = "twitch_oauth2")] | ||
| const SCOPE: twitch_oauth2::Validator = twitch_oauth2::validator![]; | ||
| const VERSION: &'static str = "1"; | ||
| } | ||
|
|
||
| /// [`channel.shared_chat.end`](ChannelSharedChatEndV1) response payload. | ||
| #[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize)] | ||
| #[cfg_attr(feature = "deny_unknown_fields", serde(deny_unknown_fields))] | ||
| #[non_exhaustive] | ||
| pub struct ChannelSharedChatEndV1Payload { | ||
| /// The unique identifier for the shared chat session. | ||
| pub session_id: types::SharedChatSessionId, | ||
| /// The User ID of the channel in the subscription condition which is no longer active in the shared chat session. | ||
| pub broadcaster_user_id: types::UserId, | ||
| /// The display name of the channel in the subscription condition which is no longer active in the shared chat session. | ||
| pub broadcaster_user_name: types::DisplayName, | ||
| /// The user login of the channel in the subscription condition which is no longer active in the shared chat session. | ||
| pub broadcaster_user_login: types::UserName, | ||
| /// The User ID of the host channel. | ||
| pub host_broadcaster_user_id: types::UserId, | ||
| /// The display name of the host channel. | ||
| pub host_broadcaster_user_name: types::DisplayName, | ||
| /// The user login of the host channel. | ||
| pub host_broadcaster_user_login: types::UserName, | ||
| } | ||
|
|
||
| #[cfg(test)] | ||
| #[test] | ||
| fn parse_payload() { | ||
| use crate::eventsub::{Event, Message}; | ||
|
|
||
| let payload = r##" | ||
| { | ||
| "subscription": { | ||
| "id": "84a875f1-1dc0-43b2-8ed3-d7db4d650c37", | ||
| "status": "enabled", | ||
| "type": "channel.shared_chat.end", | ||
| "version": "1", | ||
| "condition": { | ||
| "broadcaster_user_id": "112233" | ||
| }, | ||
| "transport": { | ||
| "method": "websocket", | ||
| "session_id": "AgoQOtgGkFvXRlSkij343CndhIGY2VsbC1h" | ||
| }, | ||
| "created_at": "2023-10-06T18:04:38.807682738Z", | ||
| "cost": 0 | ||
| }, | ||
| "event": { | ||
| "session_id": "2b64a92a-dbb8-424e-b1c3-304423ba1b6f", | ||
| "broadcaster_user_id": "1971641", | ||
| "broadcaster_user_login": "streamer", | ||
| "broadcaster_user_name": "streamer", | ||
| "host_broadcaster_user_id": "1971641", | ||
| "host_broadcaster_user_login": "streamer", | ||
| "host_broadcaster_user_name": "streamer" | ||
| } | ||
| } | ||
| "##; | ||
|
|
||
| let val = Event::parse(payload).unwrap(); | ||
| crate::tests::roundtrip(&val); | ||
|
|
||
| let Event::ChannelSharedChatEndV1(val) = val else { | ||
| panic!("invalid event type"); | ||
| }; | ||
| let Message::Notification(notif) = val.message else { | ||
| panic!("invalid message type"); | ||
| }; | ||
|
|
||
| assert_eq!(notif.broadcaster_user_id.as_str(), "1971641"); | ||
| assert_eq!(notif.broadcaster_user_id, notif.host_broadcaster_user_id); | ||
| assert_eq!( | ||
| notif.broadcaster_user_login, | ||
| notif.host_broadcaster_user_login | ||
| ); | ||
| assert_eq!( | ||
| notif.broadcaster_user_name, | ||
| notif.host_broadcaster_user_name | ||
| ); | ||
| assert_eq!( | ||
| notif.session_id.as_str(), | ||
| "2b64a92a-dbb8-424e-b1c3-304423ba1b6f" | ||
| ); | ||
| } | ||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters