Skip to content

Commit

Permalink
debug
Browse files Browse the repository at this point in the history
  • Loading branch information
tukeJonny committed Nov 1, 2023
1 parent 9a81afd commit ada757c
Showing 1 changed file with 10 additions and 0 deletions.
10 changes: 10 additions & 0 deletions webapp/go/stats_handler.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package main

import (
"log"
"net/http"
"sort"
"strconv"
Expand Down Expand Up @@ -202,21 +203,25 @@ func getLivestreamStatisticsHandler(c echo.Context) error {
}
defer tx.Rollback()

log.Println("checkpoint1")
var livestreams []*LivestreamModel
if err := tx.SelectContext(ctx, &livestreams, "SELECT * FROM livestreams"); err != nil {
return echo.NewHTTPError(http.StatusInternalServerError, err.Error())
}

// ランク算出
log.Println("checkpoint2")
var ranking LivestreamRanking
for _, livestream := range livestreams {
var reactions int64
if err := tx.GetContext(ctx, &reactions, "SELECT COUNT(*) FROM livestreams l INNER JOIN reactions r ON l.id = r.livestream_id WHERE l.id = ?", livestreamID); err != nil {
log.Println("failed to get reaction count for livestream stats")
return echo.NewHTTPError(http.StatusInternalServerError, err.Error())
}

var totalTips int64
if err := tx.GetContext(ctx, &totalTips, "SELECT SUM(l2.tip) FROM livestreams l INNER JOIN livecomments l2 ON l.id = l2.livestream_id WHERE l.id = ?", livestreamID); err != nil {
log.Println("failed to get total tips for livestream stats")
return echo.NewHTTPError(http.StatusInternalServerError, err.Error())
}

Expand All @@ -238,30 +243,35 @@ func getLivestreamStatisticsHandler(c echo.Context) error {
rank++
}

log.Println("checkpoint3")
var livestream *LivestreamModel
if err := tx.GetContext(ctx, &livestream, "SELECT * FROM livestreams WHERE id = ?", livestreamID); err != nil {
return echo.NewHTTPError(http.StatusInternalServerError, err.Error())
}

// 視聴者数算出
log.Println("checkpoint4")
var viewersCount int64
if err := tx.GetContext(ctx, &viewersCount, `SELECT COUNT(*) FROM livestreams l INNER JOIN livestream_viewers_history h ON h.livestream_id = l.id WHERE l.id = ?`, livestreamID); err != nil {
return echo.NewHTTPError(http.StatusInternalServerError, err.Error())
}

// 最大チップ額
log.Println("checkpoint5")
var maxTip int64
if err := tx.GetContext(ctx, &maxTip, `SELECT MAX(tip) FROM livestreams l INNER JOIN livecomments l2 ON l2.livestream_id = l.id WHERE l.id = ?`, livestreamID); err != nil {
return echo.NewHTTPError(http.StatusInternalServerError, err.Error())
}

// リアクション数
log.Println("checkpoint6")
var totalReactions int64
if err := tx.GetContext(ctx, &totalReactions, "SELECT COUNT(*) FROM livestreams l INNER JOIN reactions r ON r.livestream_id = l.id WHERE l.id = ?", livestreamID); err != nil {
return echo.NewHTTPError(http.StatusInternalServerError, err.Error())
}

// スパム報告数
log.Println("checkpoint7")
var totalReports int64
if err := tx.GetContext(ctx, &totalReports, `SELECT COUNT(*) FROM livestreams l INNER JOIN livecomment_reports r ON r.livestream_id = l.id WHERE l.id = ?`, livestreamID); err != nil {
return echo.NewHTTPError(http.StatusInternalServerError, err.Error())
Expand Down

0 comments on commit ada757c

Please sign in to comment.