feat: wire config into main, server, and lobby

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
2026-03-25 13:02:54 +09:00
parent 0f524779c0
commit ad1482ae03
5 changed files with 49 additions and 20 deletions

View File

@@ -4,6 +4,8 @@ import (
"fmt" "fmt"
"math/rand" "math/rand"
"sync" "sync"
"github.com/tolelom/catacombs/config"
) )
type RoomStatus int type RoomStatus int
@@ -36,13 +38,15 @@ type OnlinePlayer struct {
type Lobby struct { type Lobby struct {
mu sync.RWMutex mu sync.RWMutex
cfg *config.Config
rooms map[string]*LobbyRoom rooms map[string]*LobbyRoom
online map[string]*OnlinePlayer // fingerprint -> player online map[string]*OnlinePlayer // fingerprint -> player
activeSessions map[string]string // fingerprint -> room code (for reconnect) activeSessions map[string]string // fingerprint -> room code (for reconnect)
} }
func NewLobby() *Lobby { func NewLobby(cfg *config.Config) *Lobby {
return &Lobby{ return &Lobby{
cfg: cfg,
rooms: make(map[string]*LobbyRoom), rooms: make(map[string]*LobbyRoom),
online: make(map[string]*OnlinePlayer), online: make(map[string]*OnlinePlayer),
activeSessions: make(map[string]string), activeSessions: make(map[string]string),

View File

@@ -1,9 +1,19 @@
package game package game
import "testing" import (
"testing"
"github.com/tolelom/catacombs/config"
)
func testConfig(t *testing.T) *config.Config {
t.Helper()
cfg, _ := config.Load("")
return cfg
}
func TestCreateRoom(t *testing.T) { func TestCreateRoom(t *testing.T) {
lobby := NewLobby() lobby := NewLobby(testConfig(t))
code := lobby.CreateRoom("Test Room") code := lobby.CreateRoom("Test Room")
if len(code) != 4 { if len(code) != 4 {
t.Errorf("Room code length: got %d, want 4", len(code)) t.Errorf("Room code length: got %d, want 4", len(code))
@@ -15,7 +25,7 @@ func TestCreateRoom(t *testing.T) {
} }
func TestJoinRoom(t *testing.T) { func TestJoinRoom(t *testing.T) {
lobby := NewLobby() lobby := NewLobby(testConfig(t))
code := lobby.CreateRoom("Test Room") code := lobby.CreateRoom("Test Room")
err := lobby.JoinRoom(code, "player1", "fp-player1") err := lobby.JoinRoom(code, "player1", "fp-player1")
if err != nil { if err != nil {
@@ -28,7 +38,7 @@ func TestJoinRoom(t *testing.T) {
} }
func TestRoomStatusTransition(t *testing.T) { func TestRoomStatusTransition(t *testing.T) {
l := NewLobby() l := NewLobby(testConfig(t))
code := l.CreateRoom("Test") code := l.CreateRoom("Test")
l.JoinRoom(code, "Alice", "fp-alice") l.JoinRoom(code, "Alice", "fp-alice")
r := l.GetRoom(code) r := l.GetRoom(code)
@@ -47,7 +57,7 @@ func TestRoomStatusTransition(t *testing.T) {
} }
func TestJoinRoomFull(t *testing.T) { func TestJoinRoomFull(t *testing.T) {
lobby := NewLobby() lobby := NewLobby(testConfig(t))
code := lobby.CreateRoom("Test Room") code := lobby.CreateRoom("Test Room")
for i := 0; i < 4; i++ { for i := 0; i < 4; i++ {
lobby.JoinRoom(code, "player", "fp-player") lobby.JoinRoom(code, "player", "fp-player")
@@ -59,7 +69,7 @@ func TestJoinRoomFull(t *testing.T) {
} }
func TestSetPlayerClass(t *testing.T) { func TestSetPlayerClass(t *testing.T) {
l := NewLobby() l := NewLobby(testConfig(t))
code := l.CreateRoom("Test") code := l.CreateRoom("Test")
l.JoinRoom(code, "Alice", "fp-alice") l.JoinRoom(code, "Alice", "fp-alice")
l.SetPlayerClass(code, "fp-alice", "Warrior") l.SetPlayerClass(code, "fp-alice", "Warrior")
@@ -70,7 +80,7 @@ func TestSetPlayerClass(t *testing.T) {
} }
func TestAllReady(t *testing.T) { func TestAllReady(t *testing.T) {
l := NewLobby() l := NewLobby(testConfig(t))
code := l.CreateRoom("Test") code := l.CreateRoom("Test")
l.JoinRoom(code, "Alice", "fp-alice") l.JoinRoom(code, "Alice", "fp-alice")
l.JoinRoom(code, "Bob", "fp-bob") l.JoinRoom(code, "Bob", "fp-bob")
@@ -91,7 +101,7 @@ func TestAllReady(t *testing.T) {
} }
func TestAllReadyEmptyRoom(t *testing.T) { func TestAllReadyEmptyRoom(t *testing.T) {
l := NewLobby() l := NewLobby(testConfig(t))
code := l.CreateRoom("Test") code := l.CreateRoom("Test")
if l.AllReady(code) { if l.AllReady(code) {
t.Error("empty room should not be all ready") t.Error("empty room should not be all ready")

22
main.go
View File

@@ -1,9 +1,11 @@
package main package main
import ( import (
"fmt"
"log" "log"
"os" "os"
"github.com/tolelom/catacombs/config"
"github.com/tolelom/catacombs/game" "github.com/tolelom/catacombs/game"
"github.com/tolelom/catacombs/server" "github.com/tolelom/catacombs/server"
"github.com/tolelom/catacombs/store" "github.com/tolelom/catacombs/store"
@@ -13,23 +15,35 @@ import (
func main() { func main() {
os.MkdirAll("data", 0755) os.MkdirAll("data", 0755)
cfg, err := config.Load("config.yaml")
if err != nil {
if os.IsNotExist(err) {
cfg, _ = config.Load("")
} else {
log.Fatalf("Failed to load config: %v", err)
}
}
db, err := store.Open("data/catacombs.db") db, err := store.Open("data/catacombs.db")
if err != nil { if err != nil {
log.Fatalf("Failed to open database: %v", err) log.Fatalf("Failed to open database: %v", err)
} }
defer db.Close() defer db.Close()
lobby := game.NewLobby() lobby := game.NewLobby(cfg)
sshAddr := fmt.Sprintf("0.0.0.0:%d", cfg.Server.SSHPort)
webAddr := fmt.Sprintf(":%d", cfg.Server.HTTPPort)
// Start web terminal server in background // Start web terminal server in background
go func() { go func() {
if err := web.Start(":8080", 2222); err != nil { if err := web.Start(webAddr, cfg.Server.SSHPort); err != nil {
log.Printf("Web server error: %v", err) log.Printf("Web server error: %v", err)
} }
}() }()
log.Println("Catacombs server starting — SSH :2222, Web :8080") log.Printf("Catacombs server starting — SSH :%d, Web :%d", cfg.Server.SSHPort, cfg.Server.HTTPPort)
if err := server.Start("0.0.0.0", 2222, lobby, db); err != nil { if err := server.Start(sshAddr, lobby, db); err != nil {
log.Fatal(err) log.Fatal(err)
} }
} }

View File

@@ -14,9 +14,9 @@ import (
"github.com/tolelom/catacombs/ui" "github.com/tolelom/catacombs/ui"
) )
func Start(host string, port int, lobby *game.Lobby, db *store.DB) error { func Start(addr string, lobby *game.Lobby, db *store.DB) error {
s, err := wish.NewServer( s, err := wish.NewServer(
wish.WithAddress(fmt.Sprintf("%s:%d", host, port)), wish.WithAddress(addr),
wish.WithHostKeyPath(".ssh/catacombs_host_key"), wish.WithHostKeyPath(".ssh/catacombs_host_key"),
wish.WithPublicKeyAuth(func(_ ssh.Context, _ ssh.PublicKey) bool { wish.WithPublicKeyAuth(func(_ ssh.Context, _ ssh.PublicKey) bool {
return true // accept all keys return true // accept all keys
@@ -40,6 +40,6 @@ func Start(host string, port int, lobby *game.Lobby, db *store.DB) error {
return fmt.Errorf("could not create server: %w", err) return fmt.Errorf("could not create server: %w", err)
} }
log.Printf("Starting SSH server on %s:%d", host, port) log.Printf("Starting SSH server on %s", addr)
return s.ListenAndServe() return s.ListenAndServe()
} }

View File

@@ -1,12 +1,13 @@
package ui package ui
import ( import (
"os"
"testing" "testing"
tea "github.com/charmbracelet/bubbletea" tea "github.com/charmbracelet/bubbletea"
"github.com/tolelom/catacombs/config"
"github.com/tolelom/catacombs/game" "github.com/tolelom/catacombs/game"
"github.com/tolelom/catacombs/store" "github.com/tolelom/catacombs/store"
"os"
) )
func testDB(t *testing.T) *store.DB { func testDB(t *testing.T) *store.DB {
@@ -18,7 +19,7 @@ func testDB(t *testing.T) *store.DB {
} }
func TestTitleToLobby(t *testing.T) { func TestTitleToLobby(t *testing.T) {
lobby := game.NewLobby() lobby := game.NewLobby(func() *config.Config { c, _ := config.Load(""); return c }())
db := testDB(t) db := testDB(t)
defer func() { db.Close(); os.Remove("test_ui.db") }() defer func() { db.Close(); os.Remove("test_ui.db") }()
@@ -55,7 +56,7 @@ func TestTitleToLobby(t *testing.T) {
} }
func TestLobbyCreateRoom(t *testing.T) { func TestLobbyCreateRoom(t *testing.T) {
lobby := game.NewLobby() lobby := game.NewLobby(func() *config.Config { c, _ := config.Load(""); return c }())
db := testDB(t) db := testDB(t)
defer func() { db.Close(); os.Remove("test_ui.db") }() defer func() { db.Close(); os.Remove("test_ui.db") }()
@@ -86,7 +87,7 @@ func TestLobbyCreateRoom(t *testing.T) {
} }
func TestClassSelectToGame(t *testing.T) { func TestClassSelectToGame(t *testing.T) {
lobby := game.NewLobby() lobby := game.NewLobby(func() *config.Config { c, _ := config.Load(""); return c }())
db := testDB(t) db := testDB(t)
defer func() { db.Close(); os.Remove("test_ui.db") }() defer func() { db.Close(); os.Remove("test_ui.db") }()