create event assignment rotation TODO

.gitignore

@@ -0,0 +1 @@
+/cmd/server/server

cmd/server/games.go

@@ -6,6 +6,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"io"
+	"slices"
 	"time"
 )
 
@@ -17,23 +18,23 @@ func NewGames(ctx context.Context, db DB) (Games, error) {
 	err := db.Exec(ctx, `
 		CREATE TABLE IF NOT EXISTS users (
 			uuid TEXT,
-         updated DATETIME,
+			updated DATETIME,
 			name TEXT
 		);
 		CREATE TABLE IF NOT EXISTS games (
 			uuid TEXT,
-         updated DATETIME,
+			updated DATETIME,
 			name TEXT,
-         completed DATETIME
+			completed DATETIME
 		);
 		CREATE TABLE IF NOT EXISTS players (
 			user_uuid TEXT,
 			game_uuid TEXT,
-         updated DATETIME
+			updated DATETIME
 		);
 		CREATE TABLE IF NOT EXISTS events (
 			game_uuid TEXT,
-			updated DATETIME,
+			timestamp DATETIME,
 			payload TEXT
 		);
 	`)
@@ -77,9 +78,11 @@ type (
 	}
 
 	KillWords struct {
-		Global     string
+		Global string
-		Assigned   time.Time
+
-		Assignee   string
+		Assigned time.Time
+		Assignee string
+
 		Assignment Assignment
 	}
 
@@ -98,9 +101,10 @@ type (
 	}
 	EventGameComplete       struct{}
 	EventAssignmentRotation struct {
-		Killer      string
+		Killer    string
-		Killed      string
+		Killed    string
-		Assignments map[string]Assignment
+		KillWord  string
+		KillWords map[string]KillWords
 	}
 )
 
@@ -155,11 +159,29 @@ func (games Games) GameState(ctx context.Context, id string) (GameState, error)
 			if err := json.Unmarshal(payload, &assignmentRotation); err != nil {
 				return err
 			}
-			// TODO gather current assignees
+
-			// TODO get victim's target
+			if killer, ok := result.Players[assignmentRotation.Killer]; !ok {
-			// TODO assign victim's target to killer
+			} else if victim, ok := result.Players[assignmentRotation.Killed]; !ok {
-			// TODO randomize everyone else so not the same as before
+			} else {
-			return fmt.Errorf("not impl: assignment rotation: %+v", assignmentRotation)
+				killer.Kills = append(killer.Kills, Kill{
+					Timestamp: timestamp,
+					Victim:    assignmentRotation.Killed,
+					Public:    slices.Contains(victim.KillWords.Assignment.Public, assignmentRotation.KillWord),
+				})
+				result.Players[assignmentRotation.Killer] = killer
+			}
+
+			for k, v := range result.Players {
+				v.KillWords = KillWords{}
+				result.Players[k] = v
+			}
+
+			for k, v := range assignmentRotation.KillWords {
+				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)
 		}
@@ -168,8 +190,44 @@ func (games Games) GameState(ctx context.Context, id string) (GameState, error)
 	}, `
 		SELECT timestamp, payload
 		FROM events
-      WHERE game_uuid=?
+		WHERE game_uuid=?
 	`, id)
 
 	return result, err
 }
+
+func (games Games) CreateEventPlayerJoin(ctx context.Context, id string, player string) error {
+	return games.createEvent(ctx, id, EventPlayerJoin{ID: player})
+}
+
+func (games Games) CreateEventPlayerLeave(ctx context.Context, id string, player string) error {
+	return games.createEvent(ctx, id, EventPlayerLeave{ID: player})
+}
+
+func (games Games) CreateEventGameComplete(ctx context.Context, id string) error {
+	return games.createEvent(ctx, id, EventGameComplete{})
+}
+
+func (games Games) CreateEventAssignmentRotation(ctx context.Context, id string, killer, killed, killWord string) error {
+	// TODO gather current assignees
+	// TODO get victim's target
+	// TODO assign victim's target to killer
+	// TODO randomize everyone else so not the same as before AND not self
+	return io.EOF
+	return games.createEvent(ctx, id, v)
+}
+
+func (games Games) createEvent(ctx context.Context, id string, v any) error {
+	payload, err := json.Marshal(any)
+	if err != nil {
+		panic(err)
+	}
+
+	return games.db.Exec(ctx, `
+		INSERT INTO events (
+			game_uuid, 
+			timestamp,
+			payload
+		) VALUES (?, ?, ?)
+	`, id, time.Now(), payload)
+}