pedro/rating-orama
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change gin web framework to ron

Browse Source
This commit is contained in:
Pedro Pérez
2024-11-23 12:40:59 +01:00
parent fdee50b574
commit 490e610e4e
12 changed files with 3467 additions and 261 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/internal/handlers/handlers.go
+16 -63
View File
@@ -1,91 +1,44 @@
package handlers
import (
"context"
"gopher-toolbox/app"
"log/slog"
"net/http"
"strings"
"ron"
"gopher-toolbox/config"
"github.com/gin-gonic/gin"
"github.com/zepyrshut/rating-orama/internal/repository"
)
// TODO: Extract to toolbox
const (
InvalidRequest string = "invalid_request"
InternalError string = "internal_error"
RequestID string = "request_id"
NotFound string = "not_found"
Created string = "created"
Updated string = "updated"
Deleted string = "deleted"
Enabled string = "enabled"
Disabled string = "disabled"
Retrieved string = "retrieved"
ErrorCreating string = "error_creating"
ErrorUpdating string = "error_updating"
ErrorEnabling string = "error_enabling"
ErrorDisabling string = "error_disabling"
ErrorGetting string = "error_getting"
ErrorGettingAll string = "error_getting_all"
InvalidEntityID string = "invalid_entity_id"
NotImplemented string = "not_implemented"
UserUsernameKey string = "user_username_key"
UserEmailKey string = "user_email_key"
UsernameAlReadyExists string = "username_already_exists"
EmailAlreadyExists string = "email_already_exists"
IncorrectPassword string = "incorrect_password"
ErrorGeneratingToken string = "error_generating_token"
LoggedIn string = "logged_in"
CategoryNameKey string = "category_name_key"
CategoryAlreadyExists string = "category_already_exists"
ItemsNameKey string = "items_name_key"
NameAlreadyExists string = "name_already_exists"
)
type Handlers struct {
App *config.App
App *app.App
Queries repository.ExtendedQuerier
}
func New(q repository.ExtendedQuerier, app *config.App) *Handlers {
func New(q repository.ExtendedQuerier, app *app.App) *Handlers {
return &Handlers{
Queries: q,
App: app,
}
}
func (hq *Handlers) ToBeImplemented(c *gin.Context) {
c.JSON(http.StatusOK, gin.H{
func (hq *Handlers) ToBeImplemented(c *ron.CTX, ctx context.Context) {
c.JSON(http.StatusOK, ron.Data{
"message": "Not implemented yet",
})
}
func (hq *Handlers) Ping(c *gin.Context) {
slog.Info("ping", RequestID, c.Request.Context().Value(RequestID))
c.JSON(http.StatusOK, gin.H{
func (hq *Handlers) Ping(c *ron.CTX, ctx context.Context) {
slog.Info("ping", ron.RequestID, ctx.Value(ron.RequestID))
c.JSON(http.StatusOK, ron.Data{
"message": "pong",
})
}
// TODO: Extract to toolbox
func handleQueryError(c *gin.Context, err error, errorMap map[string]string, logMessage string, defaultErrorMessage string) bool {
if err != nil {
for key, message := range errorMap {
if strings.Contains(err.Error(), key) {
slog.Error(logMessage, "error", message, RequestID, c.Request.Context().Value(RequestID))
c.JSON(http.StatusConflict, gin.H{"error": message})
return true
}
}
slog.Error(logMessage, "error", err.Error(), RequestID, c.Request.Context().Value(RequestID))
c.JSON(http.StatusInternalServerError, gin.H{"error": defaultErrorMessage})
return true
}
return false
func (hq *Handlers) Error(c *ron.CTX, ctx context.Context) {
slog.Error("error", ron.RequestID, ctx.Value(ron.RequestID))
c.JSON(http.StatusInternalServerError, ron.Data{
"req": ctx.Value(ron.RequestID),
"message": "error",
})
}
core/internal/handlers/tvshow.go
+15 -13
View File
@@ -1,59 +1,61 @@
package handlers
import (
"context"
"gopher-toolbox/app"
"log/slog"
"net/http"
"ron"
"github.com/gin-gonic/gin"
"github.com/zepyrshut/rating-orama/internal/scraper"
"github.com/zepyrshut/rating-orama/internal/sqlc"
)
func (hq *Handlers) GetTVShow(c *gin.Context) {
func (hq *Handlers) GetTVShow(c *ron.CTX, ctx context.Context) {
ttShowID := c.Query("ttid")
slog.Info("", "ttid", ttShowID, RequestID, c.Request.Context().Value(RequestID))
slog.Info("", "ttid", ttShowID, ron.RequestID, ctx.Value(ron.RequestID))
var title string
var scraperEpisodes []scraper.Episode
var sqlcEpisodes []sqlc.Episode
tvShow, err := hq.Queries.CheckTVShowExists(c, ttShowID)
tvShow, err := hq.Queries.CheckTVShowExists(ctx, ttShowID)
if err != nil {
title, scraperEpisodes = scraper.ScrapeEpisodes(ttShowID)
sqlcEpisodes, err = hq.Queries.CreateTvShowWithEpisodes(c, sqlc.CreateTVShowParams{
sqlcEpisodes, err = hq.Queries.CreateTvShowWithEpisodes(ctx, sqlc.CreateTVShowParams{
TtImdb: ttShowID,
Name: title,
}, scraperEpisodes)
if err != nil {
slog.Error("failed to create tv show with episodes", "ttid", ttShowID, "error", err)
c.JSON(http.StatusInternalServerError, gin.H{"error": ErrorCreating})
c.JSON(http.StatusInternalServerError, ron.Data{"error": app.ErrorCreating})
return
}
slog.Info("scraped seasons", "ttid", ttShowID, "title", title)
} else {
title = tvShow.Name
sqlcEpisodes, err = hq.Queries.GetEpisodes(c, tvShow.ID)
sqlcEpisodes, err = hq.Queries.GetEpisodes(ctx, tvShow.ID)
if err != nil {
slog.Error("failed to get episodes", "ttid", ttShowID, "error", err)
c.JSON(http.StatusInternalServerError, gin.H{"error": ErrorGetting})
c.JSON(http.StatusInternalServerError, ron.Data{"error": app.ErrorGetting})
return
}
if err := hq.Queries.IncreasePopularity(c, ttShowID); err != nil {
if err := hq.Queries.IncreasePopularity(ctx, ttShowID); err != nil {
slog.Error("failed to increase popularity", "ttid", ttShowID, "error", err)
c.JSON(http.StatusInternalServerError, gin.H{"error": ErrorUpdating})
c.JSON(http.StatusInternalServerError, ron.Data{"error": app.ErrorUpdating})
return
}
slog.Info("tv show exists", "ttid", ttShowID, "title", tvShow.Name)
}
tvShowMedian, _ := hq.Queries.TvShowMedianRating(c, sqlcEpisodes[0].TvShowID)
tvShowAverage, _ := hq.Queries.TvShowAverageRating(c, sqlcEpisodes[0].TvShowID)
tvShowMedian, _ := hq.Queries.TvShowMedianRating(ctx, sqlcEpisodes[0].TvShowID)
tvShowAverage, _ := hq.Queries.TvShowAverageRating(ctx, sqlcEpisodes[0].TvShowID)
c.JSON(http.StatusOK, gin.H{
c.JSON(http.StatusOK, ron.Data{
"popularity": tvShow.Popularity,
"title": title,
"seasons": sqlcEpisodes,