diff --git a/internal/events/types/authorization_revoke/authorization_revoke.go b/internal/events/types/authorization_revoke/authorization_revoke.go index 39444313..09b32f39 100644 --- a/internal/events/types/authorization_revoke/authorization_revoke.go +++ b/internal/events/types/authorization_revoke/authorization_revoke.go @@ -52,6 +52,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven Method: "webhook", Callback: "null", }, + Cost: 1, CreatedAt: util.GetTimestamp().Format(time.RFC3339Nano), }, Event: models.AuthorizationRevokeEvent{ diff --git a/internal/events/types/ban/ban.go b/internal/events/types/ban/ban.go index 83db53e7..fd9816f3 100644 --- a/internal/events/types/ban/ban.go +++ b/internal/events/types/ban/ban.go @@ -50,6 +50,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven Method: "webhook", Callback: "null", }, + Cost: 0, CreatedAt: util.GetTimestamp().Format(time.RFC3339Nano), }, Event: models.BanEventSubEvent{ diff --git a/internal/events/types/channel_points_redemption/redemption_event.go b/internal/events/types/channel_points_redemption/redemption_event.go index 491c2297..4a74b5cb 100644 --- a/internal/events/types/channel_points_redemption/redemption_event.go +++ b/internal/events/types/channel_points_redemption/redemption_event.go @@ -60,6 +60,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven Method: "webhook", Callback: "null", }, + Cost: 0, CreatedAt: tNow, }, Event: models.RedemptionEventSubEvent{ diff --git a/internal/events/types/channel_points_reward/reward_event.go b/internal/events/types/channel_points_reward/reward_event.go index 9d6d086a..ca9ec927 100644 --- a/internal/events/types/channel_points_reward/reward_event.go +++ b/internal/events/types/channel_points_reward/reward_event.go @@ -53,6 +53,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven Method: "webhook", Callback: "null", }, + Cost: 0, CreatedAt: tNow, }, Event: models.RewardEventSubEvent{ diff --git a/internal/events/types/cheer/cheer_event.go b/internal/events/types/cheer/cheer_event.go index b73dd7ca..4a3e1bd4 100644 --- a/internal/events/types/cheer/cheer_event.go +++ b/internal/events/types/cheer/cheer_event.go @@ -55,6 +55,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven Method: "webhook", Callback: "null", }, + Cost: 0, CreatedAt: util.GetTimestamp().Format(time.RFC3339Nano), }, Event: models.CheerEventSubEvent{ diff --git a/internal/events/types/follow/follow_event.go b/internal/events/types/follow/follow_event.go index f255a161..f1a19af2 100644 --- a/internal/events/types/follow/follow_event.go +++ b/internal/events/types/follow/follow_event.go @@ -47,6 +47,7 @@ func (e Event) GenerateEvent(p events.MockEventParameters) (events.MockEventResp Method: "webhook", Callback: "null", }, + Cost: 0, CreatedAt: util.GetTimestamp().Format(time.RFC3339Nano), }, Event: models.FollowEventSubEvent{ diff --git a/internal/events/types/moderator_change/moderator_change_event.go b/internal/events/types/moderator_change/moderator_change_event.go index 075e61ca..19ec2b96 100644 --- a/internal/events/types/moderator_change/moderator_change_event.go +++ b/internal/events/types/moderator_change/moderator_change_event.go @@ -43,7 +43,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven ID: params.ID, Status: "enabled", Type: triggerMapping[params.Transport][params.Trigger], - Version: "beta", + Version: "1", Condition: models.EventsubCondition{ BroadcasterUserID: params.ToUserID, }, diff --git a/internal/events/types/raid/raid.go b/internal/events/types/raid/raid.go index 1a1a4be3..98341fd5 100644 --- a/internal/events/types/raid/raid.go +++ b/internal/events/types/raid/raid.go @@ -38,7 +38,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven ID: params.ID, Status: "enabled", Type: triggerMapping[params.Transport][params.Trigger], - Version: "beta", + Version: "1", Condition: models.EventsubCondition{ ToBroadcasterUserID: params.ToUserID, }, diff --git a/internal/events/types/stream_change/stream_change_event.go b/internal/events/types/stream_change/stream_change_event.go index 5db8b58a..3e92e989 100644 --- a/internal/events/types/stream_change/stream_change_event.go +++ b/internal/events/types/stream_change/stream_change_event.go @@ -54,6 +54,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven Method: "webhook", Callback: "null", }, + Cost: 0, CreatedAt: util.GetTimestamp().Format(time.RFC3339Nano), }, Event: models.ChannelUpdateEventSubEvent{ diff --git a/internal/events/types/streamdown/streamdown.go b/internal/events/types/streamdown/streamdown.go index 3c28c9c0..0f286fb7 100644 --- a/internal/events/types/streamdown/streamdown.go +++ b/internal/events/types/streamdown/streamdown.go @@ -48,6 +48,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven Method: "webhook", Callback: "null", }, + Cost: 0, CreatedAt: util.GetTimestamp().Format(time.RFC3339Nano), }, Event: models.StreamDownEventSubEvent{ @@ -62,8 +63,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven } case models.TransportWebSub: body := *&models.StreamDownWebSubResponse{ - Data: []models.StreamDownWebSubResponseData{ - }} + Data: []models.StreamDownWebSubResponseData{}} event, err = json.Marshal(body) if err != nil { diff --git a/internal/events/types/streamup/streamup.go b/internal/events/types/streamup/streamup.go index 84d6a3ec..311ecf8e 100644 --- a/internal/events/types/streamup/streamup.go +++ b/internal/events/types/streamup/streamup.go @@ -52,6 +52,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven Method: "webhook", Callback: "null", }, + Cost: 0, CreatedAt: util.GetTimestamp().Format(time.RFC3339Nano), }, Event: models.StreamUpEventSubEvent{ @@ -71,20 +72,20 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven body := models.StreamUpWebSubResponse{ Data: []models.StreamUpWebSubResponseData{ { - ID: params.ID, - UserID: params.ToUserID, - UserLogin: params.ToUserName, - UserName: params.ToUserName, - GameID: "509658", - Type: "live", - Title: params.StreamTitle, - ViewerCount: 1337, - StartedAt: util.GetTimestamp().Format(time.RFC3339), - Language: "en", - ThumbnailURL: "https://static-cdn.jtvnw.net/ttv-static/404_preview-440x248.jpg", - TagIDs: make([]string, 0), + ID: params.ID, + UserID: params.ToUserID, + UserLogin: params.ToUserName, + UserName: params.ToUserName, + GameID: "509658", + Type: "live", + Title: params.StreamTitle, + ViewerCount: 1337, + StartedAt: util.GetTimestamp().Format(time.RFC3339), + Language: "en", + ThumbnailURL: "https://static-cdn.jtvnw.net/ttv-static/404_preview-440x248.jpg", + TagIDs: make([]string, 0), + }, }, - }, } event, err = json.Marshal(body) diff --git a/internal/events/types/subscribe/sub_event.go b/internal/events/types/subscribe/sub_event.go index faaef126..8f783f93 100644 --- a/internal/events/types/subscribe/sub_event.go +++ b/internal/events/types/subscribe/sub_event.go @@ -68,6 +68,7 @@ func (e Event) GenerateEvent(params events.MockEventParameters) (events.MockEven Method: "webhook", Callback: "null", }, + Cost: 0, CreatedAt: util.GetTimestamp().Format(time.RFC3339Nano), }, Event: models.SubEventSubEvent{ diff --git a/internal/models/eventsub.go b/internal/models/eventsub.go index ba378760..3f17b77a 100644 --- a/internal/models/eventsub.go +++ b/internal/models/eventsub.go @@ -10,6 +10,7 @@ type EventsubSubscription struct { Condition EventsubCondition `json:"condition"` Transport EventsubTransport `json:"transport"` CreatedAt string `json:"created_at"` + Cost int64 `json:"cost"` } type EventsubTransport struct {