From 0bade0bd4f827cda9aef36b9a3002923583490be Mon Sep 17 00:00:00 2001
From: bel <bel>
Date: Sat, 14 Dec 2024 23:25:08 -0700
Subject: [PATCH] todo last event is big one

---
 cmd/server/.games.go.swp | Bin 0 -> 16384 bytes
 cmd/server/games.go      | 154 ++++++++++++++++++++++++++++++++++++++-
 2 files changed, 150 insertions(+), 4 deletions(-)
 create mode 100644 cmd/server/.games.go.swp

diff --git a/cmd/server/.games.go.swp b/cmd/server/.games.go.swp
new file mode 100644
index 0000000000000000000000000000000000000000..67d8b636ae678ae4f5129351a963ed6e0791cf50
GIT binary patch
literal 16384
zcmeI2ZEO@p7{`ao+X*O<gz$+BHQ*I4cNAknN-C80s70XI9u$RY_jaep(!1SrcdxYa
z;wQzIL@_auXo3-6LV_rfXo!hl2oV#5(HO;;Xh<|cqb7*K4@SiQGy8Je_G$tBpk^-l
z-R;iHGxPlSnVH?$%P-yBv7RqaH!^%?Gq!l}{=x}9HSzRv#`2;_sS|#>bw~5`?Gu*U
z3xk<<JL5WfreJzP%h(k!qnC_~E1W^$WC~hIxaopDp(Ry7DWDX%b_Hf_x_w#WQmS`r
z{Q^GcmQB}gLe)?TC<T-PN&%&SQa~x76i^B%1^%-Nc;!0wFnV7Xc<^%YJ89JK4Z-=$
z;P;hL`N66BQ3@yplmbctrGQdEDWDWk3Md7X0!jg;fKuRJsDNfLMlS@vpbY@L{|}%4
zf4P~li{N|kHTVd;2i^h4z+vzjcojSYo&b-5ePA891Iz|>;QURDeF;7T$G{=54-A7|
zumv=N`Ctb4c@|?og7?93a1cBN9tV$r9bh{sfH~kYHYHAhx4;1~1O|WrYrzUIAIt@H
zfPpJB7&{7{2M54&U_aOm`avsL1y+IvFc&az`9{Wm2S0(c;1oCxj)6D93t%58gKeM<
zw18D$377|_fI2V<Tui`Ua29+BJ^)9-OW+{b4ekS3uoTP$2`~*z1%FIu>?`mwI0@bW
zuY)7tUa$agaDEzNXTS-t7nDH}41gYx1ubAY_-!g<zk*BP95@4xfB~=#^ngWR9+(Wy
zO=0Xsupc}LG|&z11oOb>lNmb=PJ%<=SuhOR!4+&QT>w9T)8H`J4VHm#5R(*_-vT<H
z3#Nk$IR6fu2cLpZfEW~(=R%r2Ea3>Rl1Lb$U#k?oCZx#}$Kw4ZFP(K9+v!i%Teio|
zQn}c~HP<x@RtfdFV|$us+Ex=^xMZ+C70c=havI27Cc|@`ZJpfFEW<9D4+)OuonhO;
zLD3c5wK<vhw&M_gX@MD@7yY&)c*}-1ndORNf83Ja2R>-(o>{uh<(}pg1T5Hmz$_Mp
z6E8~{qY945*3hoQ^@`(=OTJ|xNE;HTs)lf+S+k$xh&MI!9j<MqH(4dkakp#5WLX<7
z+M1E#i>eAmGOUo57Bq9qEb?7sc2IL_=*6>iVOk=ILj$OxYmjPePW*zwIGJ{Yiz}IK
zwQ;?KCk)=qA(L=DtyHG`>vW6$ZWP*VsO?a^i0?{!tWxMiJgr9e4MDw523~9|YQw^D
zQ@kt>)(LG;q&wPVU|pvpF-zn45i8-l;rBu|9(oZ=s^P@Q-f#5{uC+}IeecBu@oRTu
z{D@uBjlbm!8U9OGs6gBkIv?o>rH~))P7{Al<7FWR(z)TXK(r!N_KqeBObh-%xQcN=
zHpcc!nv#}ftkV%1py5E}x$8L<-J7^o$KL6tyLHV<E{cL1V=owmW1E!?_(PO$?adE+
zVXIMXIY`nuj1-m#hB(Eun>O<4dn%Z)lDapP;{6p%Pg3iAvHM^#-G!qD(!_RTr~M00
z^8<yse}Vmr?Kbg}R^AE+O{>s5A^`R<vdWXPJy{Vpqx#e?*KNxaLo}-8Z;G1+X$4aa
zJQ)>D`8{c%u3(6aoi12{%7(+3CH!s#f$g7EV?|!2W^Q6K=Sz4aLmym^C#7k+j8*e)
z+_h>l%G^y8vccuY?{Apsj7%J7=BoxoLY9bk-!~AHpkYLv>SzmeVSa^}hcR2@mz3_u
zqA-e5ZdxA30@d8;n1dL(2&BlRjg@@S)OjqaDnqqhzj`dEdI+=ri4gEBvKyq4f)uGi
zd?wn9c3vw=0m7oBbdT*A?&#*iu5q5XZCW8V%XO0~hjkMa_Hu!Uw?Y<28>_Yw9l;_U
zyRtW1d+9g~EE)f!P54)Yiq{?wuoniX5${eE<yC_o%}@wPT$EsTs>gkZX{WQDYsMQ>
ztA{sW2-F@_7IFenFsyua;$y1Xjz7+29!vDmaHJ)v=dNs5Hdw0MbOnFZeV|e?jpmgc
znQOW_*N1sH?ar>tw&ucwbOBAv!ibR+??ZtR^KCG%G;^(77M2k#k10;osO4bBicO1Q
z4$XXY9QbwplUs0OL33Le_!xBK%v|mo+t~#FYwH}Jyh2;Gb#6z`-Cah$i5q$7A{U=N
za=2jyz7oNF&vV%=IXbVD4Gc_!x3%Q5xsLVO6eW`PQd(Jzl3Kg6D8O?qtJh_D#~Qw&
zGsm-AI=XY+bZ?4VV+56KLdG<GjW%4{ZX&wmSJPD4zqc9FmLA=?g>F!5GB(N26dSi!
z(p`$Ut7)EOi5!hL@DJH1Eu{S*HnEOohlK7gqkVqhY!Ex;6|Nm7MxM8=4%Ro^0?JiZ
zu5B2HGLOj#Kw79y3bgXo(_~qXU(=><Jj&3IuyotNl9{1<cS=C8XnEXNXRwshd9cdX
zGd%0qj$G@?nm(Wv1m-H-GSTz@B|LMt;5nV1|LO6VKJVh3p7q}b^sIjfJPL+DAJ_tV
zKr5iStAP3_1(X6x0i}RaKq;UUPzopolmbctrGQf4f2%<44YX(n&EMGYchRC<o930+
z{*aqz{@x7Eg1s|($d|j8cs=Cr?T_9(qgP@mk7lF&wD@byiZx)_JMm6~Hhs9<Oju~(
Qb*775#OM`BWW0g>30wT<IRF3v

literal 0
HcmV?d00001

diff --git a/cmd/server/games.go b/cmd/server/games.go
index 9d8be41..3e0b66b 100644
--- a/cmd/server/games.go
+++ b/cmd/server/games.go
@@ -1,6 +1,13 @@
 package main
 
-import "context"
+import (
+	"context"
+	"database/sql"
+	"encoding/json"
+	"fmt"
+	"io"
+	"time"
+)
 
 type Games struct {
 	db DB
@@ -10,20 +17,159 @@ func NewGames(ctx context.Context, db DB) (Games, error) {
 	err := db.Exec(ctx, `
 		CREATE TABLE IF NOT EXISTS users (
 			uuid TEXT,
+         updated DATETIME,
 			name TEXT
 		);
 		CREATE TABLE IF NOT EXISTS games (
-			uuid TEXT
+			uuid TEXT,
+         updated DATETIME,
+			name TEXT,
+         completed DATETIME
 		);
 		CREATE TABLE IF NOT EXISTS players (
 			user_uuid TEXT,
-			game_uuid TEXT
+			game_uuid TEXT,
+         updated DATETIME
 		);
 		CREATE TABLE IF NOT EXISTS events (
 			game_uuid TEXT,
-			timestamp DATETIME,
+			updated DATETIME,
 			payload TEXT
 		);
 	`)
 	return Games{db: db}, err
 }
+
+func (games Games) GamesForUser(ctx context.Context, id string) ([]string, error) {
+	result := []string{}
+	err := games.db.Query(ctx, func(rows *sql.Rows) error {
+		var game string
+		err := rows.Scan(&game)
+		result = append(result, game)
+		return err
+	}, `
+		SELECT players.game_uuid
+		FROM players
+		WHERE players.user_uuid=? 
+	`, id)
+	return result, err
+}
+
+func (games Games) GameByName(ctx context.Context, name string) (string, error) {
+	return "", io.EOF
+}
+
+type (
+	GameState struct {
+		Completed time.Time
+		Players   map[string]PlayerState
+	}
+
+	PlayerState struct {
+		Kills     []Kill
+		KillWords KillWords
+	}
+
+	Kill struct {
+		Timestamp time.Time
+		Victim    string
+		Public    bool
+	}
+
+	KillWords struct {
+		Global     string
+		Assigned   time.Time
+		Assignee   string
+		Assignment Assignment
+	}
+
+	Assignment struct {
+		Public  []string
+		Private []string
+	}
+
+	EventType int
+
+	EventPlayerJoin struct {
+		ID string
+	}
+	EventPlayerLeave struct {
+		ID string
+	}
+	EventGameComplete       struct{}
+	EventAssignmentRotation struct {
+		Killer      string
+		Killed      string
+		Assignments map[string]Assignment
+	}
+)
+
+const (
+	PlayerJoin EventType = iota + 1
+	PlayerLeave
+	GameComplete
+	AssignmentRotation
+)
+
+func (games Games) GameState(ctx context.Context, id string) (GameState, error) {
+	result := GameState{Players: map[string]PlayerState{}}
+
+	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
+		}
+
+		var peek struct {
+			Type EventType
+		}
+		if err := json.Unmarshal(payload, &peek); err != nil {
+			return 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
+		case PlayerLeave:
+			var playerLeave EventPlayerLeave
+			if err := json.Unmarshal(payload, &playerLeave); err != nil {
+				return err
+			}
+			delete(result.Players, playerLeave.ID)
+			return nil
+		case GameComplete:
+			var gameComplete EventGameComplete
+			if err := json.Unmarshal(payload, &gameComplete); err != nil {
+				return err
+			}
+			result.Completed = timestamp
+			return nil
+		case AssignmentRotation:
+			var assignmentRotation EventAssignmentRotation
+			if err := json.Unmarshal(payload, &assignmentRotation); err != nil {
+				return err
+			}
+			// 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
+			return fmt.Errorf("not impl: assignment rotation: %+v", assignmentRotation)
+		default:
+			return fmt.Errorf("unknown event type %d: %s", peek.Type, payload)
+		}
+
+		return nil
+	}, `
+		SELECT timestamp, payload
+		FROM events
+      WHERE game_uuid=?
+	`, id)
+
+	return result, err
+}