diff options
| author | Xe Iaso <me@xeiaso.net> | 2024-10-18 11:47:55 -0400 |
|---|---|---|
| committer | Xe Iaso <me@xeiaso.net> | 2024-10-18 11:47:55 -0400 |
| commit | e461eabd42c09a221b2b2cdc26e759053edb04db (patch) | |
| tree | db8ba0cd2d67d10e047ee22425d798bd5b70d6ae /cmd/mi | |
| parent | 88d8a45b4be34f4b412fb83d147606bb1fbdeb87 (diff) | |
| download | x-e461eabd42c09a221b2b2cdc26e759053edb04db.tar.xz x-e461eabd42c09a221b2b2cdc26e759053edb04db.zip | |
oops
Signed-off-by: Xe Iaso <me@xeiaso.net>
Diffstat (limited to 'cmd/mi')
| -rw-r--r-- | cmd/mi/services/twitchevents/twitchevents.go | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/cmd/mi/services/twitchevents/twitchevents.go b/cmd/mi/services/twitchevents/twitchevents.go index 1b87504..3ff6563 100644 --- a/cmd/mi/services/twitchevents/twitchevents.go +++ b/cmd/mi/services/twitchevents/twitchevents.go @@ -28,16 +28,11 @@ var ( Help: "Number of twitch events ever processed", }, []string{"messageType"}) - twitchEventsErrors = promauto.NewGaugeVec(prometheus.GaugeOpts{ - Name: "mi_twitch_events_errors", - Help: "Number of twitch events that caused errors", - }, []string{"messageType"}) - twitchClientID = flag.String("twitch-client-id", "", "twitch.tv client ID") twitchClientSecret = flag.String("twitch-client-secret", "", "twitch.tv client secret") twitchUserID = flag.Int("twitch-user-id", 105794391, "twitch.tv user ID") twitchWebhookSecret = flag.String("twitch-webhook-secret", "", "twitch.tv webhook secret") - twitchWebhookURL = flag.String("twitch-events-webhook-url", "https://shiroko-wsl.shark-harmonic.ts.net/twitch", "URL for Twitch events to be pushed to") + twitchWebhookURL = flag.String("twitch-webhook-url", "", "URL for Twitch events to be pushed to") ) type Config struct { @@ -223,7 +218,7 @@ func (s *Server) handleNotification(ctx context.Context, lg *slog.Logger, w http if err := json.Unmarshal(data.Event, &ev); err != nil { return fmt.Errorf("can't unmarshal event: %w", err) } - err = s.handleStreamUp(ctx, lg, w, &ev) + err = s.handleStreamUp(ctx, lg, &ev) default: lg.Error("unknown event", "event", data.Subscription.Type, "data", data.Event) } @@ -237,7 +232,7 @@ func (s *Server) handleNotification(ctx context.Context, lg *slog.Logger, w http return nil } -func (s *Server) handleStreamUp(ctx context.Context, lg *slog.Logger, w http.ResponseWriter, ev *helix.EventSubStreamOnlineEvent) error { +func (s *Server) handleStreamUp(ctx context.Context, lg *slog.Logger, ev *helix.EventSubStreamOnlineEvent) error { lg.Info("broadcaster went online!", "username", ev.BroadcasterUserLogin) bs, err := s.cfg.BlueskyAgent(ctx) |