1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
|
package game
import (
"os"
"path/filepath"
"reflect"
"strings"
"testing"
"gopkg.in/yaml.v3"
"thehouseoficarus/internal/casino"
"thehouseoficarus/internal/persistence"
)
const uxTestRoom = "name: Cabinets\ncasino_tables:\n - id: ux_multi\n game: video_poker\n video_poker:\n cabinet: ultimate_x_multi\n"
func TestPokerBankAtomicSettlementAndRetry(t *testing.T) {
g, sess, _ := casinoCrapsGame(t, uxTestRoom)
g.DataDir = t.TempDir()
w := casinoWallet{g: g, p: sess.Player}
stake, err := w.Wager(10)
if err != nil {
t.Fatal(err)
}
banks := map[string][]int{"jacks_or_better/full/1/3": {2, 3, 4}}
// A failure before journal creation cannot apply either half.
if err := os.WriteFile(g.journalDir(), []byte("blocked"), 0600); err != nil {
t.Fatal(err)
}
if err := w.PayPoker(50, stake.ID, 1, "ux_multi", banks); err == nil {
t.Fatal("accepted failed persistence")
}
if sess.Player.Credits != 90 || len(sess.Player.PendingWagers) != 1 {
t.Fatal("failure mutated character")
}
loaded, err := w.LoadPokerBanks(1, "ux_multi")
if err != nil || len(loaded) != 0 {
t.Fatalf("bank changed: %v %v", loaded, err)
}
if err := os.Remove(g.journalDir()); err != nil {
t.Fatal(err)
}
if err := w.PayPoker(50, stake.ID, 1, "ux_multi", banks); err != nil {
t.Fatal(err)
}
disk, err := g.AccountStore.LoadCharacter("alice")
if err != nil {
t.Fatal(err)
}
loaded, err = w.LoadPokerBanks(1, "ux_multi")
if err != nil || disk.Credits != 140 || sess.Player.Credits != 140 || len(disk.PendingWagers) != 0 || !reflect.DeepEqual(loaded, banks) {
t.Fatalf("settlement: %v %+v", err, disk)
}
if err := w.PayPoker(50, stake.ID, 1, "ux_multi", banks); err == nil {
t.Fatal("duplicate stake paid")
}
}
func TestPokerSeatsPassMachineBankAcrossRestart(t *testing.T) {
g, sess, _ := casinoCrapsGame(t, uxTestRoom)
g.DataDir = t.TempDir()
w := casinoWallet{g: g, p: sess.Player}
stake, err := w.Wager(1)
if err != nil {
t.Fatal(err)
}
banks := map[string][]int{"jacks_or_better/full/1/3": {2, 3, 4}}
if err := w.PayPoker(0, stake.ID, 1, "ux_multi", banks); err != nil {
t.Fatal(err)
}
// Restart the casino manager: the bank comes from disk, not a player map.
g.Casino = casino.NewManager(2)
g.executePlay(sess, []string{"ux_multi"}, "play ux_multi")
table, ok := g.Casino.Participation("alice")
if !ok || table == nil {
t.Fatal("not seated")
}
g.Casino.Join(1, table.Config, "bob")
if _, playing := g.Casino.Participation("bob"); playing {
t.Fatal("second occupant admitted")
}
snap := table.Status("alice")[0].Snapshot.(*casino.VideoPokerSnapshot)
if !reflect.DeepEqual(snap.Next, []int{2, 3, 4}) {
t.Fatalf("bank not displayed on join: %v", snap.Next)
}
if !g.leaveCasinoGames(sess.Player) {
t.Fatal("could not leave")
}
g.Casino.Join(1, table.Config, "bob")
snap = table.Status("bob")[0].Snapshot.(*casino.VideoPokerSnapshot)
if !reflect.DeepEqual(snap.Next, []int{2, 3, 4}) {
t.Fatalf("next occupant did not inherit: %v", snap.Next)
}
// Settings keep separate banks; merely viewing them never consumes them.
g.Casino.Action(1, table.Config.ID, "bob", "denom 10")
if got := table.Status("bob")[0].Snapshot.(*casino.VideoPokerSnapshot).Next; len(got) != 0 {
t.Fatalf("wrong denomination bank: %v", got)
}
g.Casino.Action(1, table.Config.ID, "bob", "denom 1")
if got := table.Status("bob")[0].Snapshot.(*casino.VideoPokerSnapshot).Next; !reflect.DeepEqual(got, []int{2, 3, 4}) {
t.Fatal("bank lost on switch")
}
}
func TestPokerCorruptBankRefusesDeal(t *testing.T) {
g, sess, conn := casinoCrapsGame(t, uxTestRoom)
g.DataDir = t.TempDir()
path, _ := g.pokerBankPath(1, "ux_multi")
if err := os.MkdirAll(filepath.Dir(path), 0700); err != nil {
t.Fatal(err)
}
if err := os.WriteFile(path, []byte("banks: [broken"), 0600); err != nil {
t.Fatal(err)
}
g.executePlay(sess, []string{"ux_multi"}, "play ux_multi")
g.executeBet(sess, []string{"max"}, "bet max")
g.executeTableAction(sess, "deal")
if sess.Player.Credits != 100 || len(sess.Player.PendingWagers) != 0 || !strings.Contains(string(conn.data), "Machine bank unavailable") {
t.Fatal("corrupt bank did not block deal")
}
}
// TestVestaVideoPokerPayoutTiers pins the authored tiering: the parlor, high-limit
// and VIP rooms each hold the full cabinet set at one house-set payout, and no
// player command can change it.
func TestVestaVideoPokerPayoutTiers(t *testing.T) {
_, rooms, _ := loadVesta(t)
for id, tier := range map[int]string{6192: "low", 6193: "normal", 6194: "full"} {
r, ok := rooms[id]
if !ok {
t.Fatalf("missing video poker room %d", id)
}
if len(r.CasinoTables) != 5 {
t.Fatalf("room %d has %d cabinets, want the full set of 5", id, len(r.CasinoTables))
}
for _, cfg := range r.CasinoTables {
if cfg.Game != casino.GameVideoPoker || cfg.VideoPoker.Payout != tier {
t.Fatalf("room %d/%s = %s/%s, want video_poker/%s", id, cfg.ID, cfg.Game, cfg.VideoPoker.Payout, tier)
}
}
}
}
func TestPokerInterruptedTransactionRecovery(t *testing.T) {
g, sess, _ := casinoCrapsGame(t, uxTestRoom)
// Align the journal root with the account store's data root: Recover
// refuses op paths that escape the journal's parent directory, and the
// harness otherwise leaves g.DataDir (../../data) different from the
// temp dir the stores were built with.
g.DataDir = filepath.Dir(filepath.Dir(g.AccountStore.CharPath("alice")))
w := casinoWallet{g: g, p: sess.Player}
stake, err := w.Wager(10)
if err != nil {
t.Fatal(err)
}
path, _ := g.pokerBankPath(1, "ux_multi")
if err := os.MkdirAll(filepath.Dir(path), 0700); err != nil {
t.Fatal(err)
}
before, _ := yaml.Marshal(pokerBankFile{Banks: map[string][]int{"jacks_or_better/full/1/3": {2, 3, 4}}})
if err := os.WriteFile(path, before, 0600); err != nil {
t.Fatal(err)
}
next := *sess.Player
next.Credits += 50
next.PendingWagers = nil
charData, _ := g.AccountStore.MarshalCharacter(&next)
bankData, _ := yaml.Marshal(pokerBankFile{})
txn := g.newTxn()
if err := txn.Replace(g.AccountStore.CharPath("alice"), charData, 0600); err != nil {
t.Fatal(err)
}
if err := txn.Replace(path, bankData, 0600); err != nil {
t.Fatal(err)
}
journal, err := txn.MarshalJournal()
if err != nil {
t.Fatal(err)
}
if err := os.MkdirAll(g.journalDir(), 0700); err != nil {
t.Fatal(err)
}
if err := os.WriteFile(filepath.Join(g.journalDir(), "interrupted.json"), journal, 0600); err != nil {
t.Fatal(err)
}
// Process died after applying just the character replacement.
if err := persistence.WriteFile(g.AccountStore.CharPath("alice"), charData, 0600); err != nil {
t.Fatal(err)
}
g.recoverJournals()
restored, err := g.AccountStore.LoadCharacter("alice")
if err != nil {
t.Fatal(err)
}
if restored.Credits != 90 || len(restored.PendingWagers) != 1 || restored.PendingWagers[0].ID != stake.ID {
t.Fatal("character before-image not restored")
}
restoredBank, err := w.LoadPokerBanks(1, "ux_multi")
if err != nil || !reflect.DeepEqual(restoredBank["jacks_or_better/full/1/3"], []int{2, 3, 4}) {
t.Fatal("bank before-image not restored")
}
}
|
