hoangsonww
diff --git a/‎package.json‎
Lines changed: 4 additions & 0 deletions b/‎package.json‎
Lines changed: 4 additions & 0 deletions
diff --git a/‎server/database/connection.js‎
Lines changed: 71 additions & 0 deletions b/‎server/database/connection.js‎
Lines changed: 71 additions & 0 deletions
diff --git a/‎server/database/schema.sql‎
Lines changed: 266 additions & 0 deletions b/‎server/database/schema.sql‎
Lines changed: 266 additions & 0 deletions
@@ -78,6 +78,8 @@
     ]
   },
   "dependencies": {
+    "@sentry/node": "^7.99.0",
+    "@sentry/profiling-node": "^1.3.3",
     "bcryptjs": "^2.4.3",
     "compression": "^1.7.4",
     "cors": "^2.8.5",
@@ -89,6 +91,8 @@
     "jsonwebtoken": "^9.0.2",
     "morgan": "^1.10.0",
     "node": "^16.20.2",
+    "nodemailer": "^6.9.7",
+    "pg": "^8.11.3",
     "prettier": "^3.1.1",
     "socket.io": "^4.6.1",
     "winston": "^3.11.0"
 
@@ -0,0 +1,71 @@
+const { Pool } = require('pg');
+const logger = require('../utils/logger');
+
+// Database connection pool
+const pool = new Pool({
+  host: process.env.DB_HOST || 'localhost',
+  port: parseInt(process.env.DB_PORT) || 5432,
+  database: process.env.DB_NAME || 'maze_game',
+  user: process.env.DB_USER || 'postgres',
+  password: process.env.DB_PASSWORD || 'postgres',
+  max: 20,
+  idleTimeoutMillis: 30000,
+  connectionTimeoutMillis: 2000,
+});
+
+// Test connection
+pool.on('connect', () => {
+  logger.info('Database connected successfully');
+});
+
+pool.on('error', (err) => {
+  logger.error('Unexpected database error', err);
+  process.exit(-1);
+});
+
+// Query helper
+const query = async (text, params) => {
+  const start = Date.now();
+  try {
+    const res = await pool.query(text, params);
+    const duration = Date.now() - start;
+    logger.debug('Executed query', { text, duration, rows: res.rowCount });
+    return res;
+  } catch (error) {
+    logger.error('Query error', { text, error: error.message });
+    throw error;
+  }
+};
+
+// Transaction helper
+const transaction = async (callback) => {
+  const client = await pool.connect();
+  try {
+    await client.query('BEGIN');
+    const result = await callback(client);
+    await client.query('COMMIT');
+    return result;
+  } catch (error) {
+    await client.query('ROLLBACK');
+    throw error;
+  } finally {
+    client.release();
+  }
+};
+
+// Graceful shutdown
+const gracefulShutdown = async () => {
+  logger.info('Closing database connections...');
+  await pool.end();
+  logger.info('Database connections closed');
+};
+
+process.on('SIGTERM', gracefulShutdown);
+process.on('SIGINT', gracefulShutdown);
+
+module.exports = {
+  query,
+  transaction,
+  pool,
+  gracefulShutdown,
+};
@@ -0,0 +1,266 @@
+-- PostgreSQL Database Schema for Maze Game
+-- Version: 1.0.0
+
+-- Enable UUID extension
+CREATE EXTENSION IF NOT EXISTS "uuid-ossp";
+
+-- Users table
+CREATE TABLE users (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    username VARCHAR(50) UNIQUE NOT NULL,
+    email VARCHAR(255) UNIQUE NOT NULL,
+    password_hash VARCHAR(255) NOT NULL,
+    avatar_url VARCHAR(500),
+    role VARCHAR(20) DEFAULT 'user' CHECK (role IN ('user', 'admin', 'moderator')),
+    is_active BOOLEAN DEFAULT true,
+    is_verified BOOLEAN DEFAULT false,
+    verification_token VARCHAR(255),
+    reset_password_token VARCHAR(255),
+    reset_password_expires TIMESTAMP,
+    last_login TIMESTAMP,
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+
+-- User stats table
+CREATE TABLE user_stats (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    user_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    games_played INTEGER DEFAULT 0,
+    games_won INTEGER DEFAULT 0,
+    total_score INTEGER DEFAULT 0,
+    best_time INTEGER,
+    total_playtime INTEGER DEFAULT 0,
+    best_streak INTEGER DEFAULT 0,
+    current_streak INTEGER DEFAULT 0,
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    UNIQUE(user_id)
+);
+
+-- Game sessions table
+CREATE TABLE game_sessions (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    user_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    difficulty VARCHAR(20) NOT NULL CHECK (difficulty IN ('easy', 'medium', 'hard', 'expert')),
+    mode VARCHAR(20) DEFAULT 'single' CHECK (mode IN ('single', 'multiplayer', 'time_attack', 'challenge', 'custom')),
+    maze_seed VARCHAR(100),
+    status VARCHAR(20) DEFAULT 'in_progress' CHECK (status IN ('in_progress', 'completed', 'abandoned')),
+    start_time TIMESTAMP NOT NULL,
+    end_time TIMESTAMP,
+    completion_time INTEGER,
+    moves INTEGER DEFAULT 0,
+    hints_used INTEGER DEFAULT 0,
+    score INTEGER,
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+
+-- Leaderboard table
+CREATE TABLE leaderboard (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    user_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    session_id UUID REFERENCES game_sessions(id) ON DELETE CASCADE,
+    player_name VARCHAR(50) NOT NULL,
+    score INTEGER NOT NULL,
+    completion_time INTEGER NOT NULL,
+    difficulty VARCHAR(20) NOT NULL,
+    moves INTEGER,
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    INDEX idx_score (score DESC),
+    INDEX idx_created_at (created_at DESC),
+    INDEX idx_difficulty (difficulty)
+);
+
+-- Achievements table
+CREATE TABLE achievements (
+    id VARCHAR(50) PRIMARY KEY,
+    name VARCHAR(100) NOT NULL,
+    description TEXT NOT NULL,
+    icon VARCHAR(10),
+    points INTEGER NOT NULL,
+    category VARCHAR(50),
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+
+-- User achievements table
+CREATE TABLE user_achievements (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    user_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    achievement_id VARCHAR(50) REFERENCES achievements(id) ON DELETE CASCADE,
+    unlocked_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    UNIQUE(user_id, achievement_id)
+);
+
+-- Friends table
+CREATE TABLE friendships (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    user_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    friend_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    status VARCHAR(20) DEFAULT 'pending' CHECK (status IN ('pending', 'accepted', 'blocked')),
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    UNIQUE(user_id, friend_id),
+    CHECK (user_id != friend_id)
+);
+
+-- Custom mazes table
+CREATE TABLE custom_mazes (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    user_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    name VARCHAR(100) NOT NULL,
+    description TEXT,
+    maze_data JSONB NOT NULL,
+    difficulty VARCHAR(20),
+    rows INTEGER NOT NULL,
+    cols INTEGER NOT NULL,
+    is_public BOOLEAN DEFAULT false,
+    play_count INTEGER DEFAULT 0,
+    rating DECIMAL(3,2),
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+
+-- Maze ratings table
+CREATE TABLE maze_ratings (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    maze_id UUID REFERENCES custom_mazes(id) ON DELETE CASCADE,
+    user_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    rating INTEGER CHECK (rating >= 1 AND rating <= 5),
+    comment TEXT,
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    UNIQUE(maze_id, user_id)
+);
+
+-- Daily challenges table
+CREATE TABLE daily_challenges (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    date DATE UNIQUE NOT NULL,
+    maze_seed VARCHAR(100) NOT NULL,
+    difficulty VARCHAR(20) NOT NULL,
+    bonus_points INTEGER DEFAULT 0,
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+
+-- Challenge completions table
+CREATE TABLE challenge_completions (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    challenge_id UUID REFERENCES daily_challenges(id) ON DELETE CASCADE,
+    user_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    score INTEGER NOT NULL,
+    completion_time INTEGER NOT NULL,
+    moves INTEGER NOT NULL,
+    completed_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    UNIQUE(challenge_id, user_id)
+);
+
+-- Tournaments table
+CREATE TABLE tournaments (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    name VARCHAR(100) NOT NULL,
+    description TEXT,
+    start_time TIMESTAMP NOT NULL,
+    end_time TIMESTAMP NOT NULL,
+    difficulty VARCHAR(20) NOT NULL,
+    prize_pool INTEGER,
+    status VARCHAR(20) DEFAULT 'upcoming' CHECK (status IN ('upcoming', 'active', 'completed', 'cancelled')),
+    max_participants INTEGER,
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+
+-- Tournament participants table
+CREATE TABLE tournament_participants (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    tournament_id UUID REFERENCES tournaments(id) ON DELETE CASCADE,
+    user_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    best_score INTEGER,
+    best_time INTEGER,
+    rank INTEGER,
+    joined_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    UNIQUE(tournament_id, user_id)
+);
+
+-- Game replays table
+CREATE TABLE game_replays (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    session_id UUID REFERENCES game_sessions(id) ON DELETE CASCADE,
+    user_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    replay_data JSONB NOT NULL,
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+
+-- Notifications table
+CREATE TABLE notifications (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    user_id UUID REFERENCES users(id) ON DELETE CASCADE,
+    type VARCHAR(50) NOT NULL,
+    title VARCHAR(100) NOT NULL,
+    message TEXT NOT NULL,
+    data JSONB,
+    is_read BOOLEAN DEFAULT false,
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+);
+
+-- Analytics events table
+CREATE TABLE analytics_events (
+    id UUID PRIMARY KEY DEFAULT uuid_generate_v4(),
+    user_id UUID REFERENCES users(id) ON DELETE SET NULL,
+    event_type VARCHAR(50) NOT NULL,
+    event_data JSONB,
+    session_id VARCHAR(100),
+    ip_address INET,
+    user_agent TEXT,
+    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    INDEX idx_event_type (event_type),
+    INDEX idx_created_at (created_at)
+);
+
+-- Create indexes for performance
+CREATE INDEX idx_users_email ON users(email);
+CREATE INDEX idx_users_username ON users(username);
+CREATE INDEX idx_game_sessions_user_id ON game_sessions(user_id);
+CREATE INDEX idx_game_sessions_created_at ON game_sessions(created_at);
+CREATE INDEX idx_leaderboard_user_id ON leaderboard(user_id);
+CREATE INDEX idx_user_achievements_user_id ON user_achievements(user_id);
+CREATE INDEX idx_friendships_user_id ON friendships(user_id);
+CREATE INDEX idx_friendships_friend_id ON friendships(friend_id);
+CREATE INDEX idx_custom_mazes_user_id ON custom_mazes(user_id);
+CREATE INDEX idx_custom_mazes_is_public ON custom_mazes(is_public);
+CREATE INDEX idx_notifications_user_id ON notifications(user_id);
+CREATE INDEX idx_notifications_is_read ON notifications(is_read);
+
+-- Create updated_at trigger function
+CREATE OR REPLACE FUNCTION update_updated_at_column()
+RETURNS TRIGGER AS $$
+BEGIN
+    NEW.updated_at = CURRENT_TIMESTAMP;
+    RETURN NEW;
+END;
+$$ language 'plpgsql';
+
+-- Add triggers for updated_at
+CREATE TRIGGER update_users_updated_at BEFORE UPDATE ON users
+    FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
+
+CREATE TRIGGER update_user_stats_updated_at BEFORE UPDATE ON user_stats
+    FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
+
+CREATE TRIGGER update_friendships_updated_at BEFORE UPDATE ON friendships
+    FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
+
+CREATE TRIGGER update_custom_mazes_updated_at BEFORE UPDATE ON custom_mazes
+    FOR EACH ROW EXECUTE FUNCTION update_updated_at_column();
+
+-- Insert default achievements
+INSERT INTO achievements (id, name, description, icon, points, category) VALUES
+('first_win', 'First Victory', 'Complete your first maze', '🏆', 10, 'progression'),
+('speed_demon', 'Speed Demon', 'Complete a maze in under 30 seconds', '⚡', 25, 'skill'),
+('perfectionist', 'Perfectionist', 'Complete a maze without using any hints', '💎', 20, 'skill'),
+('efficient', 'Efficient Navigator', 'Complete a maze with minimal moves', '🎯', 30, 'skill'),
+('marathon', 'Marathon Runner', 'Complete 100 mazes', '🏃', 50, 'progression'),
+('expert_conqueror', 'Expert Conqueror', 'Complete an expert difficulty maze', '👑', 40, 'difficulty'),
+('streak_master', 'Streak Master', 'Win 10 games in a row', '🔥', 35, 'progression'),
+('night_owl', 'Night Owl', 'Play between midnight and 4 AM', '🦉', 15, 'special'),
+('social_butterfly', 'Social Butterfly', 'Add 10 friends', '🦋', 20, 'social'),
+('maze_creator', 'Maze Creator', 'Create your first custom maze', '🎨', 25, 'creation'),
+('daily_dedication', 'Daily Dedication', 'Complete 7 daily challenges', '📅', 30, 'challenge'),
+('tournament_champion', 'Tournament Champion', 'Win a tournament', '🥇', 100, 'competitive');