feat: roblox likes route

.env.example

@@ -14,4 +14,7 @@ GITHUB_PROJECTS="trafficlunar/options-profiles,trafficlunar/blockmatic"
 GITHUB_TOKEN="API_KEY_GOES_HERE"
 
 # The password for the computer WebSocket
-WEBSOCKET_PASSWORD="PASSWORD_GOES_HERE"
+WEBSOCKET_PASSWORD="PASSWORD_GOES_HERE"
+
+# Roblox
+GROWAROBLOXIAN_UNIVERSE_ID=7778892933

internal/handler/roblox.go

@@ -0,0 +1,12 @@
+package handler
+
+import (
+	"api/internal/worker"
+	"encoding/json"
+	"net/http"
+)
+
+func HandleGetGrowARobloxianLikesCount(w http.ResponseWriter, r *http.Request) {
+	w.Header().Set("Content-Type", "application/json")
+	json.NewEncoder(w).Encode(worker.GrowARobloxianLikes)
+}

internal/model/roblox.go

@@ -0,0 +1,9 @@
+package model
+
+type RobloxGameVotesAPI struct {
+	Data []struct {
+		Id        int `json:"id"`
+		Upvotes   int `json:"upVotes"`
+		Downvotes int `json:"downVotes"`
+	} `json:"data"`
+}

internal/server/router.go

@@ -57,6 +57,7 @@ func NewRouter() {
 	r.Get("/projects", handler.HandleGetProjects)
 	r.Get("/computer", handler.HandleComputerGraphData)
 	r.Get("/computer/ws", handler.HandleComputerWebSocket)
+	r.Get("/roblox/grow-a-robloxian/likes", handler.HandleGetGrowARobloxianLikesCount)
 
 	port := os.Getenv("PORT")
 	if len(port) == 0 {

internal/service/roblox.go

@@ -0,0 +1,36 @@
+package service
+
+import (
+	"api/internal/model"
+	"encoding/json"
+	"fmt"
+	"io"
+	"log/slog"
+	"net/http"
+	"os"
+)
+
+func GetRobloxGrowARobloxianLikesCount() int {
+	url := fmt.Sprintf("https://games.roblox.com/v1/games/votes?universeIds=%s", os.Getenv("GROWAROBLOXIAN_UNIVERSE_ID"))
+	res, err := http.Get(url)
+	if err != nil {
+		slog.Error("Error requesting Roblox votes API", slog.Any("error", err))
+		return 0
+	}
+
+	body, err := io.ReadAll(res.Body)
+	if err != nil {
+		slog.Error("Error reading body", slog.Any("error", err))
+		return 0
+	}
+
+	var apiData model.RobloxGameVotesAPI
+
+	err = json.Unmarshal(body, &apiData)
+	if err != nil {
+		slog.Error("Error unmarshalling JSON", slog.Any("error", err))
+		return 0
+	}
+
+	return apiData.Data[0].Upvotes
+}

internal/worker/roblox.go

@@ -0,0 +1,18 @@
+package worker
+
+import (
+	"api/internal/service"
+	"log/slog"
+	"time"
+)
+
+var GrowARobloxianLikes int
+
+func StartRobloxWorker() {
+	slog.Info("Starting Roblox worker...")
+	GrowARobloxianLikes = service.GetRobloxGrowARobloxianLikesCount()
+
+	for range time.Tick(1 * time.Minute) {
+		GrowARobloxianLikes = service.GetRobloxGrowARobloxianLikesCount()
+	}
+}

internal/worker/worker.go

@@ -5,4 +5,5 @@ func StartWorkers() {
 	go StartLastFMWorker()
 	go StartGitHubWorker()
 	go StartComputerWorker()
+	go StartRobloxWorker()
 }