hmn
/
hmn
4
Fork 9
Code Issues 59 Pull Requests 1 Releases Activity

More twitch logs

This commit is contained in:
Asaf Gartner 2022-10-16 00:30:08 +03:00
parent 48451a49dd
commit d70f7d6b6d
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/twitch/twitch.go
View File

@ -877,6 +877,7 @@ func updateStreamHistory(ctx context.Context, dbConn db.ConnOrTx, status *models
) )
if err == db.NotFound { if err == db.NotFound {
twitchLog(ctx, dbConn, models.TwitchLogTypeOther, status.TwitchLogin, "updateStreamHistory", fmt.Sprintf("Creating new history\nstatus: %#v", status))
history = &models.TwitchStreamHistory{} history = &models.TwitchStreamHistory{}
history.StreamID = status.StreamID history.StreamID = status.StreamID
history.TwitchID = status.TwitchID history.TwitchID = status.TwitchID
@ -888,6 +889,7 @@ func updateStreamHistory(ctx context.Context, dbConn db.ConnOrTx, status *models
} }
if !status.Live && history.EndedAt.IsZero() { if !status.Live && history.EndedAt.IsZero() {
twitchLog(ctx, dbConn, models.TwitchLogTypeOther, status.TwitchLogin, "updateStreamHistory", fmt.Sprintf("Setting end time\nstatus: %#v", status))
history.EndedAt = time.Now() history.EndedAt = time.Now()
history.EndApproximated = true history.EndApproximated = true
history.DiscordNeedsUpdate = true history.DiscordNeedsUpdate = true
@ -904,22 +906,26 @@ func updateStreamHistory(ctx context.Context, dbConn db.ConnOrTx, status *models
_, err = tx.Exec(ctx, _, err = tx.Exec(ctx,
` `
INSERT INTO INSERT INTO
twitch_stream_history (stream_id, twitch_id, twitch_login, started_at, ended_at, title, category_id, tags) twitch_stream_history (stream_id, twitch_id, twitch_login, started_at, ended_at, end_approximated, title, category_id, tags, discord_needs_update)
VALUES ($1, $2, $3, $4, $5, $6, $7, $8) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)
ON CONFLICT (stream_id) DO UPDATE SET ON CONFLICT (stream_id) DO UPDATE SET
ended_at = EXCLUDED.ended_at, ended_at = EXCLUDED.ended_at,
end_approximated = EXCLUDED.end_approximated,
title = EXCLUDED.title, title = EXCLUDED.title,
category_id = EXCLUDED.category_id, category_id = EXCLUDED.category_id,
tags = EXCLUDED.tags tags = EXCLUDED.tags,
discord_needs_update = EXCLUDED.discord_needs_update
`, `,
history.StreamID, history.StreamID,
history.TwitchID, history.TwitchID,
history.TwitchLogin, history.TwitchLogin,
history.StartedAt, history.StartedAt,
history.EndedAt, history.EndedAt,
history.EndApproximated,
history.Title, history.Title,
history.CategoryID, history.CategoryID,
history.Tags, history.Tags,
history.DiscordNeedsUpdate,
) )
if err != nil { if err != nil {
return oops.New(err, "failed to insert/update twitch history") return oops.New(err, "failed to insert/update twitch history")
@ -930,6 +936,7 @@ func updateStreamHistory(ctx context.Context, dbConn db.ConnOrTx, status *models
} }
if !history.EndedAt.IsZero() { if !history.EndedAt.IsZero() {
twitchLog(ctx, dbConn, models.TwitchLogTypeOther, status.TwitchLogin, "updateStreamHistory", fmt.Sprintf("Checking VOD\nhistory: %#v", history))
err = findHistoryVOD(ctx, dbConn, history) err = findHistoryVOD(ctx, dbConn, history)
if err != nil { if err != nil {
return oops.New(err, "failed to look up twitch vod") return oops.New(err, "failed to look up twitch vod")
@ -940,6 +947,7 @@ func updateStreamHistory(ctx context.Context, dbConn db.ConnOrTx, status *models
func findHistoryVOD(ctx context.Context, dbConn db.ConnOrTx, history *models.TwitchStreamHistory) error { func findHistoryVOD(ctx context.Context, dbConn db.ConnOrTx, history *models.TwitchStreamHistory) error {
if history.StreamID == "" || (history.VODID != "" && !history.EndedAt.IsZero()) || history.VODGone { if history.StreamID == "" || (history.VODID != "" && !history.EndedAt.IsZero()) || history.VODGone {
twitchLog(ctx, dbConn, models.TwitchLogTypeOther, history.TwitchLogin, "findHistoryVOD", fmt.Sprintf("Skipping VOD check\nhistory: %#v", history))
return nil return nil
} }