-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathschema.sql
More file actions
491 lines (390 loc) · 15 KB
/
Copy pathschema.sql
File metadata and controls
491 lines (390 loc) · 15 KB
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
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
-- UnitedStats Database Schema v3.0
-- PostgreSQL 16+
-- Enable UUID extension
CREATE EXTENSION IF NOT EXISTS "uuid-ossp";
-- ============================================================================
-- PLAYERS & AUTHENTICATION
-- ============================================================================
CREATE TABLE players (
id BIGSERIAL PRIMARY KEY,
steam_id VARCHAR(32) UNIQUE NOT NULL,
name VARCHAR(64) NOT NULL,
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
last_seen TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
-- MMR & Rankings
mmr INTEGER DEFAULT 1000,
peak_mmr INTEGER DEFAULT 1000,
mmr_updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
-- Stats summary (updated via triggers)
total_kills INTEGER DEFAULT 0,
total_deaths INTEGER DEFAULT 0,
total_assists INTEGER DEFAULT 0,
total_airshots INTEGER DEFAULT 0,
total_headshots INTEGER DEFAULT 0,
total_backstabs INTEGER DEFAULT 0,
total_deflects INTEGER DEFAULT 0,
-- Profile
avatar_url VARCHAR(255),
country_code VARCHAR(2),
INDEX idx_steam_id (steam_id),
INDEX idx_mmr (mmr DESC),
INDEX idx_last_seen (last_seen DESC)
);
-- ============================================================================
-- MATCHES
-- ============================================================================
CREATE TABLE matches (
id BIGSERIAL PRIMARY KEY,
uuid UUID DEFAULT uuid_generate_v4() UNIQUE NOT NULL,
-- Match info
server_ip VARCHAR(45) NOT NULL,
map VARCHAR(64) NOT NULL,
gamemode VARCHAR(32) NOT NULL,
-- Timing
started_at TIMESTAMP WITH TIME ZONE NOT NULL,
ended_at TIMESTAMP WITH TIME ZONE,
duration_seconds INTEGER,
-- Results
winner_team INTEGER, -- 2=RED, 3=BLU, 0=tie
red_score INTEGER DEFAULT 0,
blu_score INTEGER DEFAULT 0,
-- Tournament link (nullable)
tournament_id BIGINT,
tournament_match_id BIGINT,
-- Metadata
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
INDEX idx_started_at (started_at DESC),
INDEX idx_server_ip (server_ip),
INDEX idx_tournament (tournament_id, tournament_match_id)
);
-- ============================================================================
-- PLAYER MATCH PARTICIPATION
-- ============================================================================
CREATE TABLE match_players (
id BIGSERIAL PRIMARY KEY,
match_id BIGINT NOT NULL REFERENCES matches(id) ON DELETE CASCADE,
player_id BIGINT NOT NULL REFERENCES players(id) ON DELETE CASCADE,
-- Team & Class
team INTEGER NOT NULL, -- 2=RED, 3=BLU
primary_class VARCHAR(32), -- Most played class
-- Stats
kills INTEGER DEFAULT 0,
deaths INTEGER DEFAULT 0,
assists INTEGER DEFAULT 0,
damage_dealt INTEGER DEFAULT 0,
healing_done INTEGER DEFAULT 0,
-- Special achievements
airshots INTEGER DEFAULT 0,
headshots INTEGER DEFAULT 0,
backstabs INTEGER DEFAULT 0,
deflects INTEGER DEFAULT 0,
-- MMR change (calculated at match end)
mmr_before INTEGER,
mmr_after INTEGER,
mmr_change INTEGER,
UNIQUE(match_id, player_id),
INDEX idx_match_id (match_id),
INDEX idx_player_id (player_id)
);
-- ============================================================================
-- EVENTS (Raw event log)
-- ============================================================================
CREATE TABLE events (
id BIGSERIAL PRIMARY KEY,
-- Event metadata
event_type VARCHAR(32) NOT NULL,
timestamp TIMESTAMP WITH TIME ZONE NOT NULL,
-- Match context
match_id BIGINT REFERENCES matches(id) ON DELETE SET NULL,
server_ip VARCHAR(45) NOT NULL,
gamemode VARCHAR(32) NOT NULL,
-- Raw JSON payload
payload JSONB NOT NULL,
-- Processed flag
processed BOOLEAN DEFAULT FALSE,
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
INDEX idx_event_type (event_type),
INDEX idx_timestamp (timestamp DESC),
INDEX idx_match_id (match_id),
INDEX idx_processed (processed) WHERE NOT processed,
INDEX idx_payload_gin (payload) USING GIN
);
-- ============================================================================
-- KILLS (Detailed kill log)
-- ============================================================================
CREATE TABLE kills (
id BIGSERIAL PRIMARY KEY,
event_id BIGINT REFERENCES events(id) ON DELETE CASCADE,
match_id BIGINT REFERENCES matches(id) ON DELETE CASCADE,
-- Players
killer_id BIGINT REFERENCES players(id) ON DELETE CASCADE,
victim_id BIGINT REFERENCES players(id) ON DELETE CASCADE,
assister_id BIGINT,
-- Weapon & properties
weapon VARCHAR(64) NOT NULL,
weapon_item_def_index INTEGER,
crit BOOLEAN DEFAULT FALSE,
airborne BOOLEAN DEFAULT FALSE,
headshot BOOLEAN DEFAULT FALSE,
backstab BOOLEAN DEFAULT FALSE,
first_blood BOOLEAN DEFAULT FALSE,
-- Position data
killer_pos_x REAL,
killer_pos_y REAL,
killer_pos_z REAL,
victim_pos_x REAL,
victim_pos_y REAL,
victim_pos_z REAL,
timestamp TIMESTAMP WITH TIME ZONE NOT NULL,
INDEX idx_killer_id (killer_id),
INDEX idx_victim_id (victim_id),
INDEX idx_match_id (match_id),
INDEX idx_timestamp (timestamp DESC),
INDEX idx_weapon (weapon),
INDEX idx_headshot (headshot) WHERE headshot = TRUE,
INDEX idx_backstab (backstab) WHERE backstab = TRUE
);
-- ============================================================================
-- AIRSHOTS
-- ============================================================================
CREATE TABLE airshots (
id BIGSERIAL PRIMARY KEY,
event_id BIGINT REFERENCES events(id) ON DELETE CASCADE,
match_id BIGINT REFERENCES matches(id) ON DELETE CASCADE,
player_id BIGINT NOT NULL REFERENCES players(id) ON DELETE CASCADE,
victim_id BIGINT NOT NULL REFERENCES players(id) ON DELETE CASCADE,
weapon_type VARCHAR(32) NOT NULL, -- rocket, sticky, pipebomb, arrow, flare, stun
air2air BOOLEAN DEFAULT FALSE,
timestamp TIMESTAMP WITH TIME ZONE NOT NULL,
INDEX idx_player_id (player_id),
INDEX idx_weapon_type (weapon_type),
INDEX idx_air2air (air2air) WHERE air2air = TRUE,
INDEX idx_timestamp (timestamp DESC)
);
-- ============================================================================
-- DEFLECTS
-- ============================================================================
CREATE TABLE deflects (
id BIGSERIAL PRIMARY KEY,
event_id BIGINT REFERENCES events(id) ON DELETE CASCADE,
match_id BIGINT REFERENCES matches(id) ON DELETE CASCADE,
player_id BIGINT NOT NULL REFERENCES players(id) ON DELETE CASCADE,
owner_id BIGINT, -- Original projectile owner
projectile_type VARCHAR(32) NOT NULL,
-- Dodgeball specific
rocket_speed REAL,
deflect_angle REAL,
timing_ms INTEGER,
distance REAL,
timestamp TIMESTAMP WITH TIME ZONE NOT NULL,
INDEX idx_player_id (player_id),
INDEX idx_projectile_type (projectile_type),
INDEX idx_timestamp (timestamp DESC)
);
-- ============================================================================
-- TOURNAMENTS
-- ============================================================================
CREATE TABLE tournaments (
id BIGSERIAL PRIMARY KEY,
uuid UUID DEFAULT uuid_generate_v4() UNIQUE NOT NULL,
name VARCHAR(128) NOT NULL,
format VARCHAR(32) NOT NULL, -- swiss, single_elimination, double_elimination
-- Dates
registration_start TIMESTAMP WITH TIME ZONE,
registration_end TIMESTAMP WITH TIME ZONE,
tournament_start TIMESTAMP WITH TIME ZONE,
tournament_end TIMESTAMP WITH TIME ZONE,
-- Settings
max_teams INTEGER,
match_format VARCHAR(32), -- bo1, bo3, bo5
map_pool TEXT[], -- Array of map names
-- Status
status VARCHAR(32) DEFAULT 'draft', -- draft, registration, active, completed, cancelled
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
updated_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
INDEX idx_status (status),
INDEX idx_tournament_start (tournament_start DESC)
);
CREATE TABLE tournament_teams (
id BIGSERIAL PRIMARY KEY,
tournament_id BIGINT NOT NULL REFERENCES tournaments(id) ON DELETE CASCADE,
team_name VARCHAR(64) NOT NULL,
seed INTEGER,
-- Swiss system
wins INTEGER DEFAULT 0,
losses INTEGER DEFAULT 0,
-- Bracket system
eliminated BOOLEAN DEFAULT FALSE,
current_bracket VARCHAR(16), -- upper, lower (for double elimination)
created_at TIMESTAMP WITH TIME ZONE DEFAULT NOW(),
UNIQUE(tournament_id, team_name),
INDEX idx_tournament_id (tournament_id),
INDEX idx_wins_losses (wins DESC, losses ASC)
);
CREATE TABLE tournament_matches (
id BIGSERIAL PRIMARY KEY,
tournament_id BIGINT NOT NULL REFERENCES tournaments(id) ON DELETE CASCADE,
round_number INTEGER NOT NULL,
match_number INTEGER NOT NULL,
team_a_id BIGINT REFERENCES tournament_teams(id),
team_b_id BIGINT REFERENCES tournament_teams(id),
-- Server assignment
assigned_server VARCHAR(64),
-- Results
winner_team_id BIGINT REFERENCES tournament_teams(id),
score_a INTEGER DEFAULT 0,
score_b INTEGER DEFAULT 0,
-- Link to actual match
match_id BIGINT REFERENCES matches(id),
-- Status
status VARCHAR(32) DEFAULT 'pending', -- pending, in_progress, completed, cancelled
scheduled_at TIMESTAMP WITH TIME ZONE,
completed_at TIMESTAMP WITH TIME ZONE,
UNIQUE(tournament_id, round_number, match_number),
INDEX idx_tournament_id (tournament_id),
INDEX idx_status (status)
);
-- ============================================================================
-- MATERIALIZED VIEWS (for performance)
-- ============================================================================
-- Global leaderboard (refreshed every 5 minutes)
CREATE MATERIALIZED VIEW leaderboard AS
SELECT
p.id,
p.steam_id,
p.name,
p.mmr,
p.peak_mmr,
p.total_kills,
p.total_deaths,
CASE
WHEN p.total_deaths > 0 THEN ROUND(p.total_kills::NUMERIC / p.total_deaths, 2)
ELSE p.total_kills::NUMERIC
END as kd_ratio,
p.total_airshots,
p.total_headshots,
p.total_backstabs,
p.total_deflects,
p.last_seen,
ROW_NUMBER() OVER (ORDER BY p.mmr DESC) as rank
FROM players p
WHERE p.last_seen > NOW() - INTERVAL '30 days'
ORDER BY p.mmr DESC
LIMIT 1000;
CREATE UNIQUE INDEX ON leaderboard (id);
CREATE INDEX ON leaderboard (mmr DESC);
CREATE INDEX ON leaderboard (rank);
-- Refresh function
CREATE OR REPLACE FUNCTION refresh_leaderboard()
RETURNS void AS $$
BEGIN
REFRESH MATERIALIZED VIEW CONCURRENTLY leaderboard;
END;
$$ LANGUAGE plpgsql;
-- ============================================================================
-- TRIGGERS & FUNCTIONS
-- ============================================================================
-- Update player stats on kill insert
CREATE OR REPLACE FUNCTION update_player_stats_on_kill()
RETURNS TRIGGER AS $$
BEGIN
-- Update killer stats
IF NEW.killer_id IS NOT NULL THEN
UPDATE players
SET total_kills = total_kills + 1,
total_headshots = total_headshots + CASE WHEN NEW.headshot THEN 1 ELSE 0 END,
total_backstabs = total_backstabs + CASE WHEN NEW.backstab THEN 1 ELSE 0 END,
updated_at = NOW()
WHERE id = NEW.killer_id;
END IF;
-- Update victim stats
IF NEW.victim_id IS NOT NULL THEN
UPDATE players
SET total_deaths = total_deaths + 1,
updated_at = NOW()
WHERE id = NEW.victim_id;
END IF;
-- Update assister stats
IF NEW.assister_id IS NOT NULL THEN
UPDATE players
SET total_assists = total_assists + 1,
updated_at = NOW()
WHERE id = NEW.assister_id;
END IF;
RETURN NEW;
END;
$$ LANGUAGE plpgsql;
CREATE TRIGGER trigger_update_player_stats_on_kill
AFTER INSERT ON kills
FOR EACH ROW
EXECUTE FUNCTION update_player_stats_on_kill();
-- Update player stats on airshot insert
CREATE OR REPLACE FUNCTION update_player_stats_on_airshot()
RETURNS TRIGGER AS $$
BEGIN
UPDATE players
SET total_airshots = total_airshots + 1,
updated_at = NOW()
WHERE id = NEW.player_id;
RETURN NEW;
END;
$$ LANGUAGE plpgsql;
CREATE TRIGGER trigger_update_player_stats_on_airshot
AFTER INSERT ON airshots
FOR EACH ROW
EXECUTE FUNCTION update_player_stats_on_airshot();
-- Update player stats on deflect insert
CREATE OR REPLACE FUNCTION update_player_stats_on_deflect()
RETURNS TRIGGER AS $$
BEGIN
UPDATE players
SET total_deflects = total_deflects + 1,
updated_at = NOW()
WHERE id = NEW.player_id;
RETURN NEW;
END;
$$ LANGUAGE plpgsql;
CREATE TRIGGER trigger_update_player_stats_on_deflect
AFTER INSERT ON deflects
FOR EACH ROW
EXECUTE FUNCTION update_player_stats_on_deflect();
-- Update updated_at timestamp
CREATE OR REPLACE FUNCTION update_updated_at_column()
RETURNS TRIGGER AS $$
BEGIN
NEW.updated_at = NOW();
RETURN NEW;
END;
$$ LANGUAGE plpgsql;
CREATE TRIGGER update_players_updated_at BEFORE UPDATE ON players
FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
CREATE TRIGGER update_tournaments_updated_at BEFORE UPDATE ON tournaments
FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
-- ============================================================================
-- INDEXES FOR COMMON QUERIES
-- ============================================================================
-- Player lookup by steam_id
CREATE INDEX idx_players_steam_id_lookup ON players(steam_id) INCLUDE (name, mmr, total_kills, total_deaths);
-- Recent matches
CREATE INDEX idx_matches_recent ON matches(started_at DESC) INCLUDE (map, gamemode, winner_team);
-- Player match history
CREATE INDEX idx_match_players_history ON match_players(player_id, match_id DESC);
-- Event processing queue
CREATE INDEX idx_events_unprocessed ON events(created_at) WHERE NOT processed;
-- ============================================================================
-- SAMPLE DATA (for testing)
-- ============================================================================
-- Insert a test player
INSERT INTO players (steam_id, name, mmr)
VALUES ('76561198012345678', 'TestPlayer', 1000)
ON CONFLICT (steam_id) DO NOTHING;
COMMENT ON TABLE players IS 'Player profiles and aggregate statistics';
COMMENT ON TABLE matches IS 'Match records with server and timing information';
COMMENT ON TABLE events IS 'Raw event log from game servers';
COMMENT ON TABLE kills IS 'Detailed kill records with weapon and position data';
COMMENT ON TABLE airshots IS 'Airshot achievements';
COMMENT ON TABLE deflects IS 'Deflect events (airblast and dodgeball)';
COMMENT ON TABLE tournaments IS 'Tournament definitions';
COMMENT ON TABLE tournament_teams IS 'Teams registered for tournaments';
COMMENT ON TABLE tournament_matches IS 'Tournament match pairings and results';