11 Commits

Author SHA1 Message Date
bel
b89ed62036 dont ?say if hotword is a gm command 2023-04-19 18:49:34 -06:00
bel
67c93a9048 pageup, pagedown instead 2023-04-19 18:37:27 -06:00
bel
8eae7ae9a6 Merge branch 'master' of https://gogs.inhome.blapointe.com/bel/mayhem-party 2023-04-19 18:29:02 -06:00
bel
ce32620940 add <=F24, >=F23 2023-04-19 18:28:39 -06:00
Bel LaPointe
24f4b6b8f5 v01 config has gm.hotwords.[].{call,args} and impl tap to link /gm/rpc/someoneSaidAlias to button pushes 2023-04-19 18:04:10 -06:00
zach-m
440191de0f Merge branch 'master' of https://gogs.inhome.blapointe.com/bel/mayhem-party 2023-04-10 18:55:35 -06:00
zach-m
d5adc596ac adding "labels" 2023-04-10 18:55:26 -06:00
bel
41a39c40d0 oops debug logs 2023-04-10 18:40:43 -06:00
bel
9a38033b65 RAW_WS serves all static files 2023-04-10 18:38:38 -06:00
zach-m
6a4ad5ec36 adding labels 2023-04-10 18:26:47 -06:00
zach-m
c2b8ab67f2 adding labels 2023-04-10 18:09:59 -06:00
11 changed files with 206 additions and 40 deletions

View File

@@ -15,6 +15,16 @@ type (
Players []configPlayer Players []configPlayer
Quiet bool Quiet bool
Broadcast configBroadcast Broadcast configBroadcast
GM configGM
}
configGM struct {
Hotwords map[string]configGMHotword
}
configGMHotword struct {
Call string
Args []string
} }
configBroadcast struct { configBroadcast struct {

View File

@@ -7,6 +7,7 @@ import (
"io" "io"
"log" "log"
"math/rand" "math/rand"
"mayhem-party/src/device/input/button"
"mayhem-party/src/device/input/wrap" "mayhem-party/src/device/input/wrap"
"net/http" "net/http"
"os" "os"
@@ -178,7 +179,7 @@ func (v01 *V01) serveGM(w http.ResponseWriter, r *http.Request) {
case "/gm/rpc/status": case "/gm/rpc/status":
v01.serveGMStatus(w) v01.serveGMStatus(w)
case "/gm/rpc/broadcastSomeoneSaidAlias": case "/gm/rpc/broadcastSomeoneSaidAlias":
v01.serveGMSomeoneSaidAlias(w, r) v01.serveGMSomeoneSaid(w, r)
case "/gm/rpc/fillNonPlayerAliases": case "/gm/rpc/fillNonPlayerAliases":
v01.serveGMFillNonPlayerAliases(w, r) v01.serveGMFillNonPlayerAliases(w, r)
case "/gm/rpc/vote": case "/gm/rpc/vote":
@@ -223,6 +224,31 @@ func (v01 *V01) serveGMStatus(w io.Writer) {
w.Write(b) w.Write(b)
} }
func (v01 *V01) serveGMSomeoneSaid(w http.ResponseWriter, r *http.Request) {
if gmHotword, ok := v01.cfg.GM.Hotwords[r.URL.Query().Get("message")]; ok {
v01.serveGMSomeoneSaidGMHotword(w, r, gmHotword)
}
v01.serveGMSomeoneSaidAlias(w, r)
}
func (v01 *V01) serveGMSomeoneSaidGMHotword(w http.ResponseWriter, r *http.Request, gmHotword configGMHotword) {
switch gmHotword.Call {
case "tap":
args := append([]string{}, gmHotword.Args...)
if len(args) < 1 || len(args[0]) < 1 {
return
}
btn := args[0][0]
go func() {
v01.alt <- []button.Button{button.Button{Down: true, Char: btn}}
v01.alt <- []button.Button{button.Button{Down: false, Char: btn}}
}()
r.URL.RawQuery = ""
default:
http.NotFound(w, r)
}
}
func (v01 *V01) serveGMSomeoneSaidAlias(w http.ResponseWriter, r *http.Request) { func (v01 *V01) serveGMSomeoneSaidAlias(w http.ResponseWriter, r *http.Request) {
v01.cfg.Quiet = true v01.cfg.Quiet = true
for k, v := range v01.cfg.Users { for k, v := range v01.cfg.Users {

View File

@@ -96,12 +96,8 @@ func TestServeGM(t *testing.T) {
t.Run("status", func(t *testing.T) { t.Run("status", func(t *testing.T) {
v01 := NewV01(ctx, nil) v01 := NewV01(ctx, nil)
var result struct { var result struct {
Players int `yaml:"Players"` Players int `yaml:"Players"`
Users map[string]struct { Users map[string]string `yaml:"Users"`
Player int
Lag string
IdleFor string `yaml:"idle_for"`
} `yaml:"Users"`
} }
t.Run("empty", func(t *testing.T) { t.Run("empty", func(t *testing.T) {
@@ -157,22 +153,46 @@ func TestServeGM(t *testing.T) {
if len(result.Users) != 7 { if len(result.Users) != 7 {
t.Error(result.Users) t.Error(result.Users)
} }
if d, err := time.ParseDuration(result.Users["bel"].Lag); err != nil { if result.Users["bel"] == "" || result.Users["bel"] == "..." {
t.Error(err) t.Error(result.Users["bel"])
} else if d != time.Second {
t.Error(d)
}
if d, err := time.ParseDuration(result.Users["bel"].IdleFor); err != nil {
t.Error(err)
} else if d < time.Minute || d > 2*time.Minute {
t.Error(d)
}
if result.Users["bel"].Player != 3 {
t.Error(result.Users["bel"].Player)
} }
}) })
}) })
t.Run("broadcastSomeoneSaidAlias to hotword tap", func(t *testing.T) {
v01 := NewV01(ctx, nil)
v01.cfg.GM = configGM{
Hotwords: map[string]configGMHotword{
"hotword": configGMHotword{
Call: "tap",
Args: []string{"a"},
},
},
}
do(v01, "/gm/rpc/broadcastSomeoneSaidAlias?message=hotword", "")
for i := 0; i < 2; i++ {
select {
case btn := <-v01.alt:
if len(btn) != 1 {
t.Error(btn)
} else if btn[0].Down != (i == 0) {
t.Error(btn[0])
} else if btn[0].Char != 'a' {
t.Error(btn[0].Char)
}
case <-time.After(time.Second):
t.Fatal("nothing in alt")
}
}
do(v01, "/gm/rpc/broadcastSomeoneSaidAlias?message=hotword", "")
time.Sleep(time.Millisecond * 150)
if got := v01.Read(); len(got) != 1 || !got[0].Down || got[0].Char != 'a' {
t.Error(got)
} else if got := v01.Read(); len(got) != 1 || got[0].Down || got[0].Char != 'a' {
t.Error(got)
}
})
t.Run("broadcastSomeoneSaidAlias", func(t *testing.T) { t.Run("broadcastSomeoneSaidAlias", func(t *testing.T) {
v01 := NewV01(ctx, nil) v01 := NewV01(ctx, nil)
v01.cfg.Quiet = false v01.cfg.Quiet = false

View File

@@ -18,3 +18,11 @@ players:
quiet: false quiet: false
broadcast: broadcast:
message: hi message: hi
gm:
hotwords:
coin:
call: tap
args: ['!']
star:
call: tap
args: ['?']

View File

@@ -26,6 +26,7 @@ type (
src raw.Raw src raw.Raw
cfg config cfg config
telemetryc chan message telemetryc chan message
alt chan []button.Button
} }
) )
@@ -41,6 +42,7 @@ func NewV01(ctx context.Context, src raw.Raw) *V01 {
src: src, src: src,
cfg: cfg, cfg: cfg,
telemetryc: make(chan message), telemetryc: make(chan message),
alt: make(chan []button.Button, 2),
} }
go result.listen() go result.listen()
go result.dotelemetry() go result.dotelemetry()
@@ -58,6 +60,11 @@ func (v01 *V01) Close() {
} }
func (v01 *V01) Read() []button.Button { func (v01 *V01) Read() []button.Button {
select {
case alt := <-v01.alt:
return alt
default:
}
line := v01.src.Read() line := v01.src.Read()
var msg message var msg message
if err := json.Unmarshal(line, &msg); err != nil { if err := json.Unmarshal(line, &msg); err != nil {

View File

@@ -0,0 +1,45 @@
// a key map of allowed keys
var allowedKeys = {
37: 'left',
38: 'up',
39: 'right',
40: 'down',
65: 'a',
66: 'b'
};
// the 'official' Konami Code sequence
var konamiCode = ['up', 'up', 'down', 'down', 'left', 'right', 'left', 'right', 'b', 'a'];
// a variable to remember the 'position' the user has reached so far.
var konamiCodePosition = 0;
// add keydown event listener
document.addEventListener('keydown', function(e) {
// get the value of the key code from the key map
var key = allowedKeys[e.keyCode];
// get the value of the required key from the konami code
var requiredKey = konamiCode[konamiCodePosition];
// compare the key with the required key
if (key == requiredKey) {
// move to the next key in the konami code sequence
konamiCodePosition++;
// if the last key is reached, activate cheats
if (konamiCodePosition == konamiCode.length) {
showSecrets();
konamiCodePosition = 0;
}
} else {
konamiCodePosition = 0;
}
});
function showSecrets() {
var element = document.getElementById("konami")
element.style = "display:block"
var e = new Event("onKonami")
element.dispatchEvent(new Event("onKonami"))
}

View File

@@ -0,0 +1,26 @@
function onYouTubeIframeAPIReady() {
var player;
player = new YT.Player('konami', {
videoId: 'V4oJ62xrFZo', // 👈 video id.
width: 560,
height: 316,
playerVars: {
'autoplay': 1,
'controls': 1,
'showinfo': 0,
'modestbranding': 0,
'loop': 1,
'fs': 0,
'cc_load_policty': 0,
'iv_load_policy': 3
},
events: {
'onReady': function (e) {
e.target.setVolume(33); // For max value, set value to 100.
document.getElementById("konami").addEventListener("onKonami", () => {e.target.playVideo()})
}
}
});
}

View File

@@ -2,6 +2,9 @@
<html> <html>
<header> <header>
<link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/water.css@2/out/dark.css"> <link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/water.css@2/out/dark.css">
<script src="konami.js"></script>
<script src="lowerVolume.js"></script>
<script async src="https://www.youtube.com/iframe_api"></script>
<script> <script>
function formsay(message) { function formsay(message) {
console.log(`say '${message}'`) console.log(`say '${message}'`)
@@ -33,6 +36,8 @@
document.getElementById("ntfy").innerHTML = `<pre>${b}</pre>` document.getElementById("ntfy").innerHTML = `<pre>${b}</pre>`
}, null) }, null)
}, 1500) }, 1500)
</script> </script>
</header> </header>
<body> <body>
@@ -74,21 +79,32 @@
<form id="controls"> <form id="controls">
<div style="display: flex; flex-wrap: wrap;"> <div style="display: flex; flex-wrap: wrap;">
<div> <div>
<input type="text" maxLength=1 value="w" name="w" placeholder="up" onchange="recontrol()"> <label for="input-up">Up</label>
<input type="text" maxLength=1 value="s" name="s" placeholder="down" onchange="recontrol()"> <input id="input-up" type="text" maxLength=1 value="w" name="w" placeholder="up" onchange="recontrol()">
<input type="text" maxLength=1 value="a" name="a" placeholder="left" onchange="recontrol()"> <label for="input-down">Down</label>
<input type="text" maxLength=1 value="d" name="d" placeholder="right" onchange="recontrol()"> <input id="input-down" type="text" maxLength=1 value="s" name="s" placeholder="down" onchange="recontrol()">
<label for="input-left">Left</label>
<input id="input-left" type="text" maxLength=1 value="a" name="a" placeholder="left" onchange="recontrol()">
<label for="input-right">Right</label>
<input id="input-right" type="text" maxLength=1 value="d" name="d" placeholder="right" onchange="recontrol()">
</div> </div>
<div> <div>
<input type="text" maxLength=1 value="5" name="5" placeholder="start" onchange="recontrol()"> <label for="input-start">Start</label>
<input type="text" maxLength=1 value="q" name="q" placeholder="l" onchange="recontrol()"> <input id="input-start" type="text" maxLength=1 value="5" name="5" placeholder="start" onchange="recontrol()">
<input type="text" maxLength=1 value="e" name="e" placeholder="r" onchange="recontrol()"> <label for="input-left-bumper">Left Bumper</label>
<input id="input-left-bumper" type="text" maxLength=1 value="q" name="q" placeholder="l" onchange="recontrol()">
<label for="input-right-bumper">Right Bumper</label>
<input id="input-right-bumper" type="text" maxLength=1 value="e" name="e" placeholder="r" onchange="recontrol()">
</div> </div>
<div> <div>
<input type="text" maxLength=1 value="1" name="1" placeholder="a" onchange="recontrol()"> <label for="input-a">A</label>
<input type="text" maxLength=1 value="2" name="2" placeholder="b" onchange="recontrol()"> <input id="input-a" type="text" maxLength=1 value="1" name="1" placeholder="a" onchange="recontrol()">
<input type="text" maxLength=1 value="3" name="3" placeholder="x" onchange="recontrol()"> <label for="input-b">B</label>
<input type="text" maxLength=1 value="4" name="4" placeholder="y" onchange="recontrol()"> <input id="input-b" type="text" maxLength=1 value="2" name="2" placeholder="b" onchange="recontrol()">
<label for="input-x">X</label>
<input id="input-x" type="text" maxLength=1 value="3" name="3" placeholder="x" onchange="recontrol()">
<label for="input-y">Y</label>
<input id="input-y" type="text" maxLength=1 value="4" name="4" placeholder="y" onchange="recontrol()">
</div> </div>
</div> </div>
</form> </form>
@@ -96,6 +112,7 @@
</div> </div>
<div id="ntfy"></div> <div id="ntfy"></div>
<div id="ws"></div> <div id="ws"></div>
<div id="konami" style="display:none"></div>
</body> </body>
<footer> <footer>
<script> <script>

View File

@@ -2,6 +2,7 @@ package raw
import ( import (
"context" "context"
"embed"
_ "embed" _ "embed"
"fmt" "fmt"
"log" "log"
@@ -9,6 +10,7 @@ import (
"net/http/httputil" "net/http/httputil"
"net/url" "net/url"
"os" "os"
"path"
"strings" "strings"
"github.com/gorilla/websocket" "github.com/gorilla/websocket"
@@ -75,16 +77,13 @@ func (ws WS) ServeHTTP(w http.ResponseWriter, r *http.Request) {
func (ws WS) serveHTTP(w http.ResponseWriter, r *http.Request) error { func (ws WS) serveHTTP(w http.ResponseWriter, r *http.Request) error {
switch r.URL.Path { switch r.URL.Path {
case "/":
return ws.serveIndex(w, r)
case "/api/ws": case "/api/ws":
return ws.serveWS(w, r) return ws.serveWS(w, r)
} }
if strings.HasPrefix(r.URL.Path, "/proxy") { if strings.HasPrefix(r.URL.Path, "/proxy") {
return ws.serveProxy(w, r) return ws.serveProxy(w, r)
} }
http.NotFound(w, r) return ws.serveStaticFile(w, r)
return nil
} }
func (ws WS) serveProxy(w http.ResponseWriter, r *http.Request) error { func (ws WS) serveProxy(w http.ResponseWriter, r *http.Request) error {
@@ -101,16 +100,20 @@ func (ws WS) serveProxy(w http.ResponseWriter, r *http.Request) error {
return nil return nil
} }
//go:embed public/root.html //go:embed public/*
var rootHTML string var staticFiles embed.FS
func (ws WS) serveIndex(w http.ResponseWriter, r *http.Request) error { func (ws WS) serveStaticFile(w http.ResponseWriter, r *http.Request) error {
v := rootHTML
if FlagWSDebug { if FlagWSDebug {
b, _ := os.ReadFile("src/device/input/raw/public/root.html") b, _ := os.ReadFile("src/device/input/raw/public/root.html")
v = string(b) w.Write(b)
return nil
} }
w.Write([]byte(v)) if r.URL.Path == "/" {
r.URL.Path = "root.html"
}
r.URL.Path = path.Join("public", r.URL.Path)
http.FileServer(http.FS(staticFiles)).ServeHTTP(w, r)
return nil return nil
} }

View File

@@ -53,6 +53,8 @@ var (
';': PSemicolon, ';': PSemicolon,
'-': PMinus, '-': PMinus,
'=': PEqual, '=': PEqual,
'<': PageDown,
'>': PageUp,
} }
keyToChar = func() map[Key]byte { keyToChar = func() map[Key]byte {
result := map[Key]byte{} result := map[Key]byte{}

View File

@@ -57,4 +57,6 @@ const (
PSemicolon = Key(keybd_event.VK_SEMICOLON) PSemicolon = Key(keybd_event.VK_SEMICOLON)
PMinus = Key(keybd_event.VK_MINUS) PMinus = Key(keybd_event.VK_MINUS)
PEqual = Key(keybd_event.VK_EQUAL) PEqual = Key(keybd_event.VK_EQUAL)
PageUp = Key(keybd_event.VK_PAGEUP)
PageDown = Key(keybd_event.VK_PAGEDOWN)
) )