broadcast isnt a user

main.go

@@ -11,6 +11,14 @@ import (
 func main() {
 	ctx, can := signal.NotifyContext(context.Background(), syscall.SIGINT)
 	defer can()
+
+	defer func() {
+		if err := recover(); err != nil {
+			log.Println("panic:", err)
+			panic(err)
+		}
+	}()
+
 	if err := src.Main(ctx); err != nil && ctx.Err() == nil {
 		panic(err)
 	}

src/device/input/parse/v01/config.go

@@ -9,11 +9,16 @@ import (
 
 type (
 	config struct {
-		lock     *sync.Mutex
-		Feedback configFeedback
-		Users    map[string]configUser
-		Players  []configPlayer
-		Quiet    bool
+		lock      *sync.Mutex
+		Feedback  configFeedback
+		Users     map[string]configUser
+		Players   []configPlayer
+		Quiet     bool
+		Broadcast configBroadcast
+	}
+
+	configBroadcast struct {
+		Message string
 	}
 
 	configFeedback struct {

src/device/input/parse/v01/server.go

@@ -79,7 +79,8 @@ func (v01 *V01) serveHTTP(w http.ResponseWriter, r *http.Request) {
 func (v01 *V01) getUserFeedback(w http.ResponseWriter, r *http.Request) {
 	user, ok := v01.cfg.Users[r.URL.Query().Get("user")]
 	if !ok {
-		user = v01.cfg.Users["broadcast"]
+		w.Write([]byte(v01.cfg.Broadcast.Message))
+		return
 	}
 	w.Write([]byte(user.State.Message))
 }
@@ -90,9 +91,7 @@ func (v01 *V01) servePutBroadcast(w http.ResponseWriter, r *http.Request) {
 }
 
 func (v01 *V01) servePutBroadcastValue(v string) {
-	u := v01.cfg.Users["broadcast"]
-	u.State.Message = v
-	v01.cfg.Users["broadcast"] = u
+	v01.cfg.Broadcast.Message = v
 }
 
 func (v01 *V01) serveConfig(w http.ResponseWriter, r *http.Request) {

src/device/input/parse/v01/server_test.go

@@ -183,10 +183,8 @@ func TestServeGM(t *testing.T) {
 				},
 				Message: "if someone else says 'driver', then you get to play",
 			}},
-			"broadcast": configUser{State: configUserState{
-				Message: ":)",
-			}},
 		}
+		v01.cfg.Broadcast.Message = ":)"
 		do(v01, "/gm/rpc/broadcastSomeoneSaidAlias", "")
 		if !v01.cfg.Quiet {
 			t.Error(v01.cfg.Quiet)
@@ -196,7 +194,7 @@ func TestServeGM(t *testing.T) {
 		} else if v.State.GM.LastAlias != "driver" {
 			t.Error(v.State.GM.LastAlias)
 		}
-		if bc := v01.cfg.Users["broadcast"]; bc.State.Message == ":)" {
+		if bc := v01.cfg.Broadcast.Message; bc == ":)" {
 			t.Error(bc)
 		}
 	})
@@ -342,8 +340,8 @@ func TestServeGM(t *testing.T) {
 			} else if v01.cfg.Users["zach"].State.Player != 1 {
 				t.Error(v01.cfg.Users["zach"].State.Player)
 			}
-			if v01.cfg.Users["broadcast"].State.Message != `bel is now player 0 and zach is now player 1` {
-				t.Error(v01.cfg.Users["broadcast"].State.Message)
+			if v01.cfg.Broadcast.Message != `bel is now player 0 and zach is now player 1` {
+				t.Error(v01.cfg.Broadcast)
 			}
 		})
 
@@ -367,8 +365,8 @@ func TestServeGM(t *testing.T) {
 			} else if result["zach"] != 1 {
 				t.Error(result)
 			}
-			if !strings.HasSuffix(v01.cfg.Users["broadcast"].State.Message, `is now player 1`) || strings.Contains(v01.cfg.Users["broadcast"].State.Message, ",") {
-				t.Error(v01.cfg.Users["broadcast"].State.Message)
+			if !strings.HasSuffix(v01.cfg.Broadcast.Message, `is now player 1`) || strings.Contains(v01.cfg.Broadcast.Message, ",") {
+				t.Error(v01.cfg.Broadcast.Message)
 			}
 			assignments := map[int]int{}
 			for _, v := range v01.cfg.Users {
@@ -376,7 +374,7 @@ func TestServeGM(t *testing.T) {
 			}
 			if len(assignments) != 2 {
 				t.Error(assignments)
-			} else if assignments[0] != 3 {
+			} else if assignments[0] != 2 {
 				t.Error(assignments[0])
 			} else if assignments[1] != 1 {
 				t.Error(assignments[1])
@@ -402,8 +400,8 @@ func TestServeGM(t *testing.T) {
 			} else if result["zach"] != 1 {
 				t.Error(result)
 			}
-			if !strings.HasSuffix(v01.cfg.Users["broadcast"].State.Message, `is now player 1`) || strings.Contains(v01.cfg.Users["broadcast"].State.Message, ",") {
-				t.Error(v01.cfg.Users["broadcast"].State.Message)
+			if bc := v01.cfg.Broadcast.Message; !strings.HasSuffix(bc, `is now player 1`) || strings.Contains(bc, ",") {
+				t.Error(bc)
 			}
 			assignments := map[int]int{}
 			for _, v := range v01.cfg.Users {
@@ -411,7 +409,7 @@ func TestServeGM(t *testing.T) {
 			}
 			if len(assignments) != 2 {
 				t.Error(assignments)
-			} else if assignments[0] != 2 {
+			} else if assignments[0] != 1 {
 				t.Error(assignments[0])
 			} else if assignments[1] != 1 {
 				t.Error(assignments[1])
@@ -433,7 +431,7 @@ func TestServeGM(t *testing.T) {
 				if v01.cfg.Quiet {
 					t.Error(v01.cfg.Quiet)
 				}
-				if len(v01.cfg.Users) != 3 {
+				if len(v01.cfg.Users) != 2 {
 					t.Error(v01.cfg.Users)
 				} else if len(v01.cfg.Players) != 2 {
 					t.Error(v01.cfg.Users)
@@ -482,7 +480,7 @@ func TestServeGM(t *testing.T) {
 					t.Error(v01.cfg.Quiet)
 				}
 
-				if len(v01.cfg.Users) != c.users+1 {
+				if len(v01.cfg.Users) != c.users {
 					t.Error(v01.cfg.Users)
 				} else if len(v01.cfg.Players) != c.players {
 					t.Error(v01.cfg.Users)

src/device/input/parse/v01/testdata/v01.yaml

@@ -1,6 +1,8 @@
 feedback:
   addr: :17071
   ttsurl: http://localhost:15002
+broadcast:
+  message: hi
 users:
   bel:
     state:

src/device/input/parse/v01/v01_exported_test.go

@@ -91,9 +91,8 @@ func TestV01Feedback(t *testing.T) {
           state:
             player: 2
             message: to bel
-        broadcast:
-          state:
-            message: to everyone
+      broadcast:
+        message: to everyone
       players:
       - transformation:
           w: t

src/main.go

@@ -17,9 +17,9 @@ func Main(ctx context.Context) error {
 	defer reader.Close()
 
 	interval := time.Millisecond * 50
-	if intervalS := os.Getenv("MAIN_INTERVAL_DURATION"); intervalS != "" {
+	if intervalS := os.Getenv("MAIN_INTERVAL_DURATION"); intervalS == "" {
 	} else if v, err := time.ParseDuration(intervalS); err != nil {
-		panic(err)
+		return err
 	} else {
 		interval = v
 	}

todo.yaml

@@ -1,104 +0,0 @@
-todo:
-- -venue needs to update for new env variables for GUI
-- -venue needs to udpate hits hotword path for new Users.[].State.GM.Alias
-- clients can vote
-- single docker image to run all
-- https via home.blapointe and rproxy
-- trigger dolphin pause via query param mapping to a button that is a pause hotkey
-- todo: rotation triggers
-  subtasks:
-  - ui for election start, election votes, election end stuff
-  - todo: stdin
-    subtasks:
-    - minigame end
-  - todo: voice recognition of hotwords to vote who dun it
-    subtasks:
-    - random word from cur wikipedia page
-    - each person has their own hotword
-    - only spectators have hotwords and must get a player to speak it
-    - tribunal to vote who said it
-scheduled: []
-done:
-- todo: sticky keyboard input mode for enable/disable explicitly
-  ts: Thu Mar 23 20:55:52 MDT 2023
-- todo: case-sensitive
-  ts: Fri Mar 24 13:39:26 MDT 2023
-- todo: rusty configs have "name" for each client so "if name == server_broadcasted_name
-    { debug_print_in_gui(server_broadcasted_message) }
-  ts: Fri Mar 24 16:40:09 MDT 2023
-- todo: change from 'a','b','c' from rust to just 10,11,12 so playerName is known
-    implicitly but then gotta translate back to char for keyboard things somewhere;
-    space delimited?
-  ts: Fri Mar 24 17:00:55 MDT 2023
-- todo: '"Button" to interface or strings'
-  ts: Fri Mar 24 17:01:01 MDT 2023
-- todo: input.UDP as a raw provider
-  ts: Fri Mar 24 19:58:59 MDT 2023
-- todo: input.MayhemParty as a logical wrapper
-  ts: Fri Mar 24 19:58:59 MDT 2023
-- todo: change from 'a','b','c' from rust to just 11,21,31,41 so playerName is known
-    implicitly from %10 but then gotta translate back to char for keyboard things
-    somewhere; space delimited?
-  ts: Fri Mar 24 19:58:59 MDT 2023
-- todo: input."Button" to interface or strings
-  ts: Fri Mar 24 21:16:39 MDT 2023
-- todo: input.MayhemParty as a logical wrapper from %10 but then gotta translate back
-    to char for keyboard things somewhere; space delimited?
-  ts: Fri Mar 24 21:16:39 MDT 2023
-- todo: change from 'a','b','c' from rust to just 11,21,31,41 so playerName is known
-    implicitly
-  ts: Sat Mar 25 00:06:21 MDT 2023
-- todo: lag via UDP formatted inputs as space-delimited TS PID buttonIdx buttonIdx
-    buttonIdx
-  ts: Sat Mar 25 00:13:19 MDT 2023
-- todo: map keys triggered by user to player idx and their keys
-  ts: Sat Mar 25 00:44:19 MDT 2023
-- todo: use button.V01Cfg; map keys triggered by user to player idx and their keys
-  ts: Sat Mar 25 09:12:43 MDT 2023
-- todo: v01cfg includes messages to send per client and exposes tcp server for it
-  ts: Sat Mar 25 10:09:06 MDT 2023
-- todo: v01cfg includes messages to send per client and exposes http server for it
-  ts: Sat Mar 25 11:28:29 MDT 2023
-- todo: send clients messages to display
-  ts: Sat Mar 25 11:28:29 MDT 2023
-- todo: input.MayhemParty as a logical wrapper from mod10 but then gotta translate
-    back to char for keyboard things somewhere; space delimited?
-  ts: Sat Mar 25 11:28:40 MDT 2023
-- todo: rusty configs have "name" for each client
-  details: |
-    'if name == server_broadcasted_name { debug_print_in_gui(server_broadcasted_message) }'
-  ts: Sat Mar 25 11:28:40 MDT 2023
-- todo: rotation triggers
-  subtasks:
-  - minigame end
-  - random word from cur wikipedia page
-  - each person has their own hotword
-  - only spectators have hotwords and must get a player to speak it
-  - tribunal to vote who said it
-  ts: Sat Mar 25 11:29:52 MDT 2023
-- todo: we have 7 players oooooof
-  ts: Sat Mar 25 11:29:52 MDT 2023
-- todo: endpoint for v01 to start read-only mode so when hotword spoken, players are
-    dcd without losing players
-  ts: Sat Mar 25 23:16:47 MDT 2023
-- todo: tts for when someone said the word via larynx docker + http.get + https://pkg.go.dev/github.com/faiface/beep@v1.1.0/wav
-  ts: Sun Mar 26 09:57:02 MDT 2023
-- todo: endpoint for v01 to start read-only mode so when hotword spoken, players are
-    dcd without losing players; press a hotkey that is bound to dolphin emulator pause
-  ts: Sun Mar 26 14:28:46 MDT 2023
-- todo: game master to coordinate config change
-  ts: Mon Mar 27 11:01:10 MDT 2023
-- todo: rotation triggers
-  subtasks:
-  - todo: stdin
-    subtasks:
-    - minigame end
-  - todo: voice recognition of hotwords to vote who dun it
-    subtasks:
-    - random word from cur wikipedia page
-    - each person has their own hotword
-    - only spectators have hotwords and must get a player to speak it
-    - tribunal to vote who said it
-  ts: Mon Mar 27 11:04:56 MDT 2023
-- todo: clients can send STT via box
-  ts: Mon Mar 27 17:55:41 MDT 2023