feat: keys, clicks, and totals in computer statistics

internal/handler/computer.go

@@ -3,6 +3,7 @@ package handler
 import (
 	"api/internal/model"
 	"api/internal/service"
+	"api/internal/storage"
 	"api/internal/worker"
 	"encoding/json"
 	"log/slog"
@@ -33,7 +34,7 @@ func HandleComputerWebSocket(w http.ResponseWriter, r *http.Request) {
 	}
 	defer conn.Close()
 
-	slog.Info("WebSocket connection established!")
+	slog.Info("WebSocket connection established")
 	service.ComputerData.Online = true
 
 	for {
@@ -52,6 +53,25 @@ func HandleComputerWebSocket(w http.ResponseWriter, r *http.Request) {
 
 		worker.QueuedClientMessage = clientMessage
 		slog.Info("Recieved message", slog.Any("message", clientMessage))
+
+		// Add to totals
+		keysData := storage.GlobalDataStore.Get("keys")
+		clicksData := storage.GlobalDataStore.Get("clicks")
+
+		var keys float64
+		var clicks float64
+
+		if keysData != nil {
+			keys = keysData.(float64)
+		}
+		if clicksData != nil {
+			clicks = clicksData.(float64)
+		}
+
+		storage.GlobalDataStore.Set("keys", keys+float64(clientMessage.Keys))
+		storage.GlobalDataStore.Set("clicks", clicks+float64(clientMessage.Clicks))
+
+		service.LoadComputerStatTotals()
 	}
 }
 

internal/model/computer.go

@@ -5,15 +5,25 @@ import "time"
 type ComputerWebSocketMessage struct {
 	Cpu    uint8  `json:"cpu"`
 	Ram    uint8  `json:"ram"`
+	Keys   uint16 `json:"keys"`
+	Clicks uint16 `json:"clicks"`
 }
 
 type ComputerData struct {
 	Online bool                `json:"online"`
+	Totals ComputerTotals      `json:"totals"`
 	Graph  []ComputerGraphData `json:"graph"`
 }
 
+type ComputerTotals struct {
+	Keys   float64 `json:"keys"`
+	Clicks float64 `json:"clicks"`
+}
+
 type ComputerGraphData struct {
 	Timestamp time.Time `json:"timestamp"`
 	Cpu       int       `json:"cpu"`
 	Ram       int       `json:"ram"`
+	Keys      int       `json:"keys"`
+	Clicks    int       `json:"clicks"`
 }

internal/service/computer.go

@@ -2,22 +2,49 @@ package service
 
 import (
 	"api/internal/model"
+	"api/internal/storage"
 	"time"
 )
 
 var ComputerData model.ComputerData = model.ComputerData{
 	Online: false,
+	Totals: model.ComputerTotals{
+		Keys:   0,
+		Clicks: 0,
+	},
 	Graph: initializeGraphData(),
 }
 
+func LoadComputerStatTotals() {
+	keysData := storage.GlobalDataStore.Get("keys")
+	clicksData := storage.GlobalDataStore.Get("clicks")
+
+	var keys float64
+	var clicks float64
+
+	if keysData != nil {
+		keys = keysData.(float64)
+	}
+	if clicksData != nil {
+		clicks = clicksData.(float64)
+	}
+
+	ComputerData.Totals = model.ComputerTotals{
+		Keys:   keys,
+		Clicks: clicks,
+	}
+}
+
 func initializeGraphData() []model.ComputerGraphData {
 	graphData := make([]model.ComputerGraphData, 60)
 
-	for i := 0; i < 60; i++ {
+	for i := range 60 {
 		graphData[i] = model.ComputerGraphData{
 			Timestamp: time.Now().Truncate(1 * time.Minute).Add(time.Duration(-60+i) * time.Minute),
 			Cpu:       0,
 			Ram:       0,
+			Keys:      0,
+			Clicks:    0,
 		}
 	}
 
@@ -29,6 +56,8 @@ func AddComputerData(clientMessage model.ComputerWebSocketMessage) {
 		Timestamp: time.Now().Truncate(time.Minute).Add(-time.Minute),
 		Cpu:       int(clientMessage.Cpu),
 		Ram:       int(clientMessage.Ram),
+		Keys:      int(clientMessage.Keys),
+		Clicks:    int(clientMessage.Clicks),
 	})
 
 	if len(ComputerData.Graph) > 60 {

internal/storage/datastore.go

@@ -12,7 +12,9 @@ type DataStore struct {
 	Mutex sync.Mutex
 }
 
-var GlobalDataStore *DataStore
+var GlobalDataStore = &DataStore{
+	Data: make(map[string]any),
+}
 
 func InitDataStore() *DataStore {
 	GlobalDataStore = &DataStore{
@@ -36,6 +38,7 @@ func InitDataStore() *DataStore {
 		return nil
 	}
 
+	slog.Info("Loaded data store")
 	return GlobalDataStore
 }
 

internal/worker/computer.go

@@ -20,6 +20,8 @@ func StartComputerWorker() {
 				service.AddComputerData(model.ComputerWebSocketMessage{
 					Cpu:    0,
 					Ram:    0,
+					Keys:   0,
+					Clicks: 0,
 				})
 			} else {
 				service.AddComputerData(QueuedClientMessage)

main.go

@@ -4,12 +4,14 @@ import (
 	"log/slog"
 	"os"
 	"os/signal"
+	"sync"
 	"syscall"
 
 	"github.com/joho/godotenv"
 	"github.com/lmittmann/tint"
 
 	"api/internal/server"
+	"api/internal/service"
 	"api/internal/storage"
 	"api/internal/worker"
 )
@@ -20,10 +22,19 @@ func main() {
 
 	err := godotenv.Load()
 	if err != nil {
-		slog.Warn("No .env file was found; using environment variables.", slog.Any("error", err))
+		slog.Warn("No .env file was found; using environment variables", slog.Any("error", err))
 	}
 
+	var wg sync.WaitGroup
+	wg.Add(1)
+
+	go func() {
+		defer wg.Done()
 		storage.InitDataStore()
+	}()
+
+	wg.Wait()
+	service.LoadComputerStatTotals()
 	go worker.StartWorkers()
 
 	// Shutdown-chan~~