feat: add denormalized player online status, add to friends

Author: ZakShearman

services/player-service/api/v2/intnl/openapi.yaml

@@ -1443,10 +1443,12 @@ components:
 
     PlayerFriend:
       type: object
-      required: [ playerId, username, friendsSince ]
+      required: [ playerId, username, online, lastOnline, friendsSince ]
       properties:
         playerId: { type: string }
         username: { type: string }
+        online: { type: boolean }
+        lastOnline: { type: string, format: date-time }
         friendsSince:
           type: string
           format: date-time

services/player-service/api/v2/intnl/server.gen.go

@@ -129,6 +129,8 @@ func (s *server) GetPlayerFriends(ctx context.Context, request GetPlayerFriendsR
 			FriendsSince: row.CreatedAt,
 			PlayerId:     row.TargetID,
 			Username:     row.Username,
+			Online:       row.Online,
+			LastOnline:   row.LastOnline,
 		}
 	}
 

services/player-service/api/v2/intnl/server_relationships.go

@@ -9,6 +9,7 @@ import (
 	"github.com/go-chi/chi/v5"
 	"github.com/hollow-cube/hc-services/libraries/common/pkg/kafkafx"
 	"github.com/hollow-cube/hc-services/services/player-service/api/auth"
+	"github.com/hollow-cube/hc-services/services/player-service/internal/consumers"
 	"github.com/hollow-cube/hc-services/services/player-service/internal/db"
 	"github.com/hollow-cube/hc-services/services/player-service/internal/pkg/model"
 	"github.com/hollow-cube/tebex-go"
@@ -80,6 +81,9 @@ func main() {
 		),
 		httpfx.Module,
 
+		// Generic consumer (e.g., denormalized data from other services)
+		fx.Invoke(consumers.NewConsumerSet),
+
 		// GRPC server (for Envoy)
 		fx.Provide(auth.NewServer),
 		fx.Invoke(newGrpcServer),

services/player-service/cmd/player-service/main.go

@@ -0,0 +1,41 @@
+package consumers
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+
+	"github.com/hollow-cube/hc-services/libraries/common/pkg/kafkafx"
+	"github.com/hollow-cube/hc-services/services/player-service/internal/db"
+	"github.com/hollow-cube/hc-services/services/session-service/pkg/kafkaModel"
+	"github.com/segmentio/kafka-go"
+)
+
+const consumerGroup = "player-service"
+
+func NewConsumerSet(consumer kafkafx.Consumer, store *db.Store) {
+
+	// if you add more, separate into multiple files :)
+	consumer.Subscribe(kafkafx.TopicSessionUpdates, consumerGroup, func(ctx context.Context, rawMsg kafka.Message) error {
+		var msg kafkaModel.SessionUpdateMessage
+		if err := json.Unmarshal(rawMsg.Value, &msg); err != nil {
+			return err
+		}
+
+		var newOnline bool
+		switch msg.Action {
+		case kafkaModel.Session_Create:
+			newOnline = true
+		case kafkaModel.Session_Delete:
+			newOnline = false
+		default:
+			return nil // do nothing
+		}
+
+		if err := store.UpdatePlayerData(ctx, db.UpdatePlayerDataParams{ID: msg.PlayerId, Online: &newOnline}); err != nil {
+			return fmt.Errorf("failed to update player data: %w", err)
+		}
+
+		return nil
+	})
+}

services/player-service/internal/consumers/public.go

@@ -0,0 +1,4 @@
+alter table player_data add column online boolean not null default false;
+alter table player_data alter column online drop default;
+
+comment on column player_data.online is 'Updated by observing session status messages from the session-service'