refacotr picking unused word out of AssignmentRotation body

cmd/server/games.go

@@ -143,22 +143,27 @@ type (
 
 	EventPlayerJoin struct {
 		Type      EventType
+		Timestamp time.Time
 		ID        string
 	}
 	EventPlayerLeave struct {
 		Type      EventType
+		Timestamp time.Time
 		ID        string
 	}
 	EventGameComplete struct {
 		Type      EventType
+		Timestamp time.Time
 	}
 	EventAssignmentRotation struct {
 		Type         EventType
+		Timestamp    time.Time
 		Killer       string
 		Victim       string
 		KillWord     KillWord
-		KillWords map[string]KillWords
+		AllKillWords AllKillWords
 	}
+	AllKillWords map[string]KillWords
 )
 
 const (
@@ -168,57 +173,109 @@ const (
 	AssignmentRotation
 )
 
-func (games Games) GameState(ctx context.Context, id string) (GameState, error) {
-	result := GameState{Players: map[string]PlayerState{}}
+type Event interface{ event() }
 
-	err := games.db.Query(ctx, func(rows *sql.Rows) error {
-		var timestamp time.Time
-		var payload []byte
-		if err := rows.Scan(&timestamp, &payload); err != nil {
-			return err
+func (EventPlayerJoin) event()         {}
+func (EventPlayerLeave) event()        {}
+func (EventGameComplete) event()       {}
+func (EventAssignmentRotation) event() {}
+
+func EventWithTime(event Event, t time.Time) Event {
+	switch e := event.(type) {
+	case EventPlayerJoin:
+		e.Timestamp = t
+		event = e
+	case EventPlayerLeave:
+		e.Timestamp = t
+		event = e
+	case EventGameComplete:
+		e.Timestamp = t
+		event = e
+	case EventAssignmentRotation:
+		e.Timestamp = t
+		event = e
+	}
+	return event
 }
 
+func (games Games) GameEvents(ctx context.Context, id string, since time.Time) ([]Event, error) {
+	var results []Event
+	err := games.db.Query(ctx, func(rows *sql.Rows) error {
+		var timestamp time.Time
+		var b []byte
+		if err := rows.Scan(&timestamp, &b); err != nil {
+			return err
+		}
+		event, err := parseEvent(b, timestamp)
+		results = append(results, event)
+		return err
+	}, `
+		SELECT
+			timestamp,
+			payload
+		FROM events
+		WHERE game_uuid=? and timestamp>?
+		ORDER BY timestamp ASC
+	`, id, since)
+	return results, err
+}
+
+func parseEvent(b []byte, timestamp time.Time) (Event, error) {
 	var peek struct {
 		Type EventType
 	}
-		if err := json.Unmarshal(payload, &peek); err != nil {
-			return err
+	if err := json.Unmarshal(b, &peek); err != nil {
+		return nil, err
 	}
-
 	switch peek.Type {
 	case PlayerJoin:
-			var playerJoin EventPlayerJoin
-			if err := json.Unmarshal(payload, &playerJoin); err != nil {
-				return err
-			}
-			result.Players[playerJoin.ID] = PlayerState{}
-			return nil
+		var v EventPlayerJoin
+		err := json.Unmarshal(b, &v)
+		return EventWithTime(v, timestamp), err
 	case PlayerLeave:
-			var playerLeave EventPlayerLeave
-			if err := json.Unmarshal(payload, &playerLeave); err != nil {
-				return err
-			}
-			delete(result.Players, playerLeave.ID)
-			return nil
+		var v EventPlayerLeave
+		err := json.Unmarshal(b, &v)
+		return EventWithTime(v, timestamp), err
 	case GameComplete:
-			var gameComplete EventGameComplete
-			if err := json.Unmarshal(payload, &gameComplete); err != nil {
-				return err
-			}
-			result.Completed = timestamp
-			return nil
+		var v EventGameComplete
+		err := json.Unmarshal(b, &v)
+		return EventWithTime(v, timestamp), err
 	case AssignmentRotation:
-			result.Started = true
-			var assignmentRotation EventAssignmentRotation
-			if err := json.Unmarshal(payload, &assignmentRotation); err != nil {
-				return err
+		var v EventAssignmentRotation
+		err := json.Unmarshal(b, &v)
+		return EventWithTime(v, timestamp), err
 	}
+	return nil, fmt.Errorf("unknown event type %d: %s", peek.Type, b)
+}
+
+func (games Games) GameState(ctx context.Context, id string) (GameState, error) {
+	result := GameState{Players: map[string]PlayerState{}}
+
+	events, err := games.GameEvents(ctx, id, time.Time{})
+	if err != nil {
+		return result, err
+	}
+
+	for _, event := range events {
+		switch event.(type) {
+		case EventPlayerJoin:
+			playerJoin := event.(EventPlayerJoin)
+			result.Players[playerJoin.ID] = PlayerState{}
+		case EventPlayerLeave:
+			playerLeave := event.(EventPlayerLeave)
+			delete(result.Players, playerLeave.ID)
+		case EventGameComplete:
+			gameComplete := event.(EventGameComplete)
+			result.Completed = gameComplete.Timestamp
+		case EventAssignmentRotation:
+			result.Started = true
+			assignmentRotation := event.(EventAssignmentRotation)
 
 			if killer, ok := result.Players[assignmentRotation.Killer]; !ok {
 			} else if _, ok := result.Players[assignmentRotation.Victim]; !ok {
 			} else {
 				killer.Kills = append(killer.Kills, Kill{
-					Timestamp: timestamp,
+					Timestamp: assignmentRotation.Timestamp,
 					Victim:    assignmentRotation.Victim,
 					KillWord:  assignmentRotation.KillWord,
 				})
@@ -230,22 +287,15 @@ func (games Games) GameState(ctx context.Context, id string) (GameState, error)
 				result.Players[k] = v
 			}
 
-			for k, v := range assignmentRotation.KillWords {
+			for k, v := range assignmentRotation.AllKillWords {
 				player := result.Players[k]
 				player.KillWords = v
 				result.Players[k] = player
 			}
-			return nil
 		default:
-			return fmt.Errorf("unknown event type %d: %s", peek.Type, payload)
+			return GameState{}, fmt.Errorf("unknown event type %T", event)
+		}
 	}
-
-		return nil
-	}, `
-		SELECT timestamp, payload
-		FROM events
-		WHERE game_uuid=?
-	`, id)
 
 	return result, err
 }
@@ -301,9 +351,6 @@ func (games Games) CreateEventPlayerLeave(ctx context.Context, id string, player
 	return games.createEvent(ctx, id, EventPlayerLeave{Type: PlayerLeave, ID: player})
 }
 
-//go:embed holiday.txt
-var wordsHoliday string
-
 func (games Games) CreateEventAssignmentRotation(ctx context.Context, id string, killer, victim, word string, points int) error {
 	state, err := games.GameState(ctx, id)
 	if err != nil {
@@ -319,7 +366,7 @@ func (games Games) CreateEventAssignmentRotation(ctx context.Context, id string,
 			Word:   word,
 			Points: points,
 		},
-		KillWords: map[string]KillWords{},
+		AllKillWords: make(AllKillWords),
 	}
 
 	toAssign := []string{}
@@ -330,7 +377,7 @@ func (games Games) CreateEventAssignmentRotation(ctx context.Context, id string,
 		toAssign = append(toAssign, k)
 		doNotAssign[k] = v.Assignee
 
-		event.KillWords[k] = KillWords{
+		event.AllKillWords[k] = KillWords{
 			Global:     v.Global,
 			Assigned:   now,
 			Assignee:   "",
@@ -341,13 +388,13 @@ func (games Games) CreateEventAssignmentRotation(ctx context.Context, id string,
 	if killerState, ok := state.Players[killer]; !ok {
 	} else if victimState, ok := state.Players[victim]; !ok {
 	} else {
-		event.KillWords[killer] = KillWords{
+		event.AllKillWords[killer] = KillWords{
 			Global:     killerState.KillWords.Global,
 			Assigned:   now,
 			Assignee:   victimState.KillWords.Assignee,
 			Assignment: killerState.KillWords.Assignment,
 		}
-		toAssign = slices.DeleteFunc(toAssign, func(s string) bool { return s == event.KillWords[killer].Assignee })
+		toAssign = slices.DeleteFunc(toAssign, func(s string) bool { return s == event.AllKillWords[killer].Assignee })
 
 		if killerState.KillWords.Global.Word != word {
 			victimState.KillWords.Assignment = Assignment{}
@@ -358,17 +405,17 @@ func (games Games) CreateEventAssignmentRotation(ctx context.Context, id string,
 	for !func() bool {
 		toAssign := slices.Clone(toAssign)
 		doNotAssign := maps.Clone(doNotAssign)
-		eventKillWords := maps.Clone(event.KillWords)
+		allKillWords := maps.Clone(event.AllKillWords)
 
 		for i := range toAssign {
 			j := rand.Intn(i + 1)
 			toAssign[i], toAssign[j] = toAssign[j], toAssign[i]
 		}
-		for k, v := range eventKillWords {
+		for k, v := range allKillWords {
 			if k == toAssign[0] || doNotAssign[k] == toAssign[0] {
 				return false
 			}
-			eventKillWords[k] = KillWords{
+			allKillWords[k] = KillWords{
 				Global:     v.Global,
 				Assigned:   now,
 				Assignee:   toAssign[0],
@@ -377,66 +424,95 @@ func (games Games) CreateEventAssignmentRotation(ctx context.Context, id string,
 			toAssign = toAssign[1:]
 		}
 
-		event.KillWords = eventKillWords
+		event.AllKillWords = allKillWords
 		return true
 	}() {
 	}
 
-	globalsInUse := map[string]any{}
-	publicsInUse := map[string]any{}
-	privatesInUse := map[string]any{}
-	for _, v := range event.KillWords {
-		globalsInUse[v.Global.Word] = nil
-		for _, public := range v.Assignment.Public {
-			publicsInUse[public.Word] = nil
-		}
-		for _, private := range v.Assignment.Private {
-			privatesInUse[private.Word] = nil
-		}
-	}
-
-	randWord := func(words string, taken map[string]any) string {
-		wordsList := strings.Fields(words)
-		for {
-			got := wordsList[rand.Intn(len(wordsList))]
-			if _, ok := taken[got]; !ok {
-				taken[got] = nil
-				return got
-			}
-		}
-	}
-	randGlobal := func() string {
-		return randWord(wordsHoliday, globalsInUse)
-	}
-	randPublic := func() string {
-		return randWord(wordsHoliday, publicsInUse)
-	}
-	randPrivate := func() string {
-		return randWord(wordsHoliday, privatesInUse)
-	}
-
-	// TODO generate .Global=...us major cities?, .Assignments.Public=...?, .Assignments.Private=holiday
-	for k, v := range event.KillWords {
+	for k, v := range event.AllKillWords {
 		if v.Global.Word == "" {
-			v.Global = KillWord{Word: randGlobal(), Points: 1}
+			v.Global = KillWord{Word: event.AllKillWords.unusedGlobal(), Points: -1}
+			event.AllKillWords[k] = v
 		}
 		if len(v.Assignment.Public) == 0 {
-			v.Assignment.Public = []KillWord{
-				KillWord{Word: randPublic(), Points: 50},
-				KillWord{Word: randPublic(), Points: 50},
+			v.Assignment.Public = []KillWord{}
+			for i := 0; i < 2; i++ {
+				v.Assignment.Public = append(v.Assignment.Public, KillWord{Word: event.AllKillWords.unusedPublic(), Points: 50})
+				event.AllKillWords[k] = v
 			}
 		}
 		if len(v.Assignment.Private) == 0 {
-			v.Assignment.Private = []KillWord{
-				KillWord{Word: randPrivate(), Points: 100},
+			v.Assignment.Private = []KillWord{}
+			for i := 0; i < 2; i++ {
+				v.Assignment.Private = append(v.Assignment.Private, KillWord{Word: event.AllKillWords.unusedPrivate(), Points: 100})
+				event.AllKillWords[k] = v
 			}
 		}
-		event.KillWords[k] = v
 	}
 
 	return games.createEvent(ctx, id, event)
 }
 
+//go:embed holiday.txt
+var wordsHoliday string
+
+func (m AllKillWords) unusedGlobal() string {
+	pool := strings.Fields(wordsHoliday)
+	inUse := func() []string {
+		result := []string{}
+		for _, killWords := range m {
+			result = append(result, killWords.Global.Word)
+		}
+		return result
+	}
+	for {
+		picked := pool[rand.Intn(len(pool))]
+		if !slices.Contains(inUse(), picked) {
+			return picked
+		}
+	}
+}
+
+// TODO hard difficulty
+func (m AllKillWords) unusedPrivate() string {
+	pool := strings.Fields(wordsHoliday)
+	inUse := func() []string {
+		result := []string{}
+		for _, killWords := range m {
+			for _, killWord := range killWords.Assignment.Private {
+				result = append(result, killWord.Word)
+			}
+		}
+		return result
+	}
+	for {
+		picked := pool[rand.Intn(len(pool))]
+		if !slices.Contains(inUse(), picked) {
+			return picked
+		}
+	}
+}
+
+// TODO medium difficulty
+func (m AllKillWords) unusedPublic() string {
+	pool := strings.Fields(wordsHoliday)
+	inUse := func() []string {
+		result := []string{}
+		for _, killWords := range m {
+			for _, killWord := range killWords.Assignment.Public {
+				result = append(result, killWord.Word)
+			}
+		}
+		return result
+	}
+	for {
+		picked := pool[rand.Intn(len(pool))]
+		if !slices.Contains(inUse(), picked) {
+			return picked
+		}
+	}
+}
+
 func (games Games) CreateEventGameComplete(ctx context.Context, id string) error {
 	if err := games.db.Exec(ctx, `
 		UPDATE games

cmd/server/games_test.go

@@ -2,8 +2,10 @@ package main
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
 	"testing"
+	"time"
 )
 
 func newTestGames(t *testing.T) Games {
@@ -66,15 +68,41 @@ func TestGames(t *testing.T) {
 			}
 			if name, err := games.UserName(ctx, p); err != nil {
 				t.Fatal(p, "err getting user name", err)
-			} else if name == "" {
-				t.Fatal("name empty")
+			} else if name != "player "+p {
+				t.Fatal("name wrong", name)
+			}
+			if err := games.UpdateUserName(ctx, p, "player! "+p); err != nil {
+				t.Fatal(p, "failed to rename:", err)
+			} else if name, err := games.UserName(ctx, p); err != nil {
+				t.Fatal(p, "err getting user name", err)
+			} else if name != "player! "+p {
+				t.Fatal("updated name wrong", name)
 			}
 		}
 
+		if events, err := games.GameEvents(ctx, id, time.Time{}); err != nil {
+			t.Fatal("failed to get player join, leave events:", err)
+		} else if len(events) != 6 {
+			t.Error("wrong number of events:", len(events))
+		}
+
+		now := time.Now()
 		if err := games.CreateEventAssignmentRotation(ctx, id, "", "", "", 1); err != nil {
 			t.Fatal("err creating rotation:", err)
 		}
 
+		if events, err := games.GameEvents(ctx, id, time.Time{}); err != nil {
+			t.Fatal("failed to get player join, leave events:", err)
+		} else if len(events) != 7 {
+			t.Error("wrong number of events:", len(events))
+		} else if events, err = games.GameEvents(ctx, id, now); err != nil {
+			t.Fatal("failed to get assignment rotation event:", err)
+		} else if len(events) != 1 {
+			t.Error("wrong number of events:", len(events))
+		} else if _, ok := events[0].(EventAssignmentRotation); !ok {
+			t.Errorf("not an assignment rotation event: %T", events[0])
+		}
+
 		if v, err := games.GamesForUser(ctx, "p1"); err != nil {
 			t.Error("err getting games for user:", err)
 		} else if len(v) < 1 {
@@ -96,6 +124,9 @@ func TestGames(t *testing.T) {
 		} else {
 			for i := 0; i < 4; i++ {
 				p := fmt.Sprintf("p%d", i+1)
+				if v.Players[p].Points() != 0 {
+					t.Error("nonzero points after zero kills:", v.Players[p].Points())
+				}
 				if v.Players[p].KillWords.Global.Word == "" {
 					t.Error(p, "no killwords.global")
 				} else if v.Players[p].KillWords.Assigned.IsZero() {
@@ -119,3 +150,66 @@ func TestGames(t *testing.T) {
 		}
 	})
 }
+
+func TestParseEvent(t *testing.T) {
+	now := time.Now()
+
+	cases := map[string]Event{
+		"player join": EventPlayerJoin{
+			Type: PlayerJoin,
+			ID:   "x",
+		},
+		"player leave": EventPlayerLeave{
+			Type: PlayerLeave,
+			ID:   "x",
+		},
+		"game complete": EventGameComplete{
+			Type: GameComplete,
+		},
+		"assignment rotation": EventAssignmentRotation{
+			Type:   AssignmentRotation,
+			Killer: "x",
+			Victim: "y",
+			KillWord: KillWord{
+				Word:   "word",
+				Points: 1,
+			},
+			AllKillWords: map[string]KillWords{
+				"x": KillWords{
+					Global: KillWord{
+						Word:   "a",
+						Points: -1,
+					},
+					Assignee: "z",
+					Assigned: now,
+					Assignment: Assignment{
+						Public: []KillWord{{
+							Word:   "word2",
+							Points: 2,
+						}},
+						Private: []KillWord{{
+							Word:   "word3",
+							Points: 3,
+						}},
+					},
+				},
+			},
+		},
+	}
+
+	for name, d := range cases {
+		c := d
+		t.Run(name, func(t *testing.T) {
+			c := EventWithTime(c, now)
+			b, _ := json.Marshal(c)
+			got, err := parseEvent(b, now)
+			if err != nil {
+				t.Fatal(err)
+			}
+			gotb, _ := json.Marshal(got)
+			if string(b) != string(gotb) {
+				t.Errorf("expected (%T) %+v, but got (%T) %+v", c, c, got, got)
+			}
+		})
+	}
+}

cmd/server/ws.go

@@ -90,6 +90,7 @@ func (s *S) serveWS(w http.ResponseWriter, r *http.Request) error {
 		}
 	}()
 
+	var last time.Time
 	for {
 		select {
 		case <-ctx.Done():
@@ -97,6 +98,13 @@ func (s *S) serveWS(w http.ResponseWriter, r *http.Request) error {
 		case <-time.After(time.Second * 1):
 		}
 
+		if events, err := s.games.GameEvents(ctx, game, last); err != nil {
+			return err
+		} else if len(events) == 0 {
+			continue
+		}
+		last = time.Now()
+
 		gameState, err := s.games.GameState(ctx, game)
 		if err != nil {
 			return err