Update config/db.js

config/db.js

@@ -22,13 +22,14 @@ const pool = mysql.createPool({
 async function initializeSchema() {
   console.log('Initializing database schema...');
   try {
-    // Create users table
+    // Create users table with role column
     await pool.query(`
       CREATE TABLE IF NOT EXISTS users (
         id INT AUTO_INCREMENT PRIMARY KEY,
         username VARCHAR(255) NOT NULL UNIQUE,
         email VARCHAR(255) NOT NULL UNIQUE,
         password VARCHAR(255) NOT NULL,
+        role ENUM('user', 'admin') NOT NULL DEFAULT 'user',
         full_name VARCHAR(255) NOT NULL,
         dob DATE NOT NULL,
         address TEXT NOT NULL,
@@ -41,17 +42,6 @@ async function initializeSchema() {
       )
     `);
 
-    // Create admins table
-    await pool.query(`
-      CREATE TABLE IF NOT EXISTS admins (
-        id INT AUTO_INCREMENT PRIMARY KEY,
-        username VARCHAR(255) NOT NULL UNIQUE,
-        email VARCHAR(255) NOT NULL UNIQUE,
-        password VARCHAR(255) NOT NULL,
-        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
-      )
-    `);
-
     // Create kyc_documents table
     await pool.query(`
       CREATE TABLE IF NOT EXISTS kyc_documents (
@@ -67,6 +57,49 @@ async function initializeSchema() {
       )
     `);
 
+    // Create crypto_addresses table
+    await pool.query(`
+      CREATE TABLE IF NOT EXISTS crypto_addresses (
+        id INT AUTO_INCREMENT PRIMARY KEY,
+        crypto_type VARCHAR(50) NOT NULL,
+        address VARCHAR(255) NOT NULL,
+        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
+      )
+    `);
+
+    // Create deposits table
+    await pool.query(`
+      CREATE TABLE IF NOT EXISTS deposits (
+        id INT AUTO_INCREMENT PRIMARY KEY,
+        user_id INT NOT NULL,
+        crypto_type VARCHAR(50) NOT NULL,
+        amount DECIMAL(10,2) NOT NULL,
+        status ENUM('pending', 'approved', 'rejected') DEFAULT 'pending',
+        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+        FOREIGN KEY (user_id) REFERENCES users(id)
+      )
+    `);
+
+    // Create profile_updates table
+    await pool.query(`
+      CREATE TABLE IF NOT EXISTS profile_updates (
+        id INT AUTO_INCREMENT PRIMARY KEY,
+        user_id INT NOT NULL,
+        username VARCHAR(255),
+        email VARCHAR(255),
+        full_name VARCHAR(255),
+        dob DATE,
+        address TEXT,
+        country VARCHAR(100),
+        zip_code VARCHAR(20),
+        phone_number VARCHAR(20),
+        status ENUM('pending', 'approved', 'rejected') DEFAULT 'pending',
+        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+        updated_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+        FOREIGN KEY (user_id) REFERENCES users(id)
+      )
+    `);
+
     // Create investment_plans table
     await pool.query(`
       CREATE TABLE IF NOT EXISTS investment_plans (
@@ -144,20 +177,44 @@ async function initializeSchema() {
     const [users] = await pool.query('SELECT COUNT(*) as count FROM users');
     if (users[0].count === 0) {
       await pool.query(`
-        INSERT INTO users (username, email, password, full_name, dob, address, country, zip_code, phone_number, kyc_status, balance)
+        INSERT INTO users (username, email, password, role, full_name, dob, address, country, zip_code, phone_number, kyc_status, balance)
         VALUES 
-          ('user1', 'user1@example.com', ?, 'User One', '1990-01-01', '123 Main St', 'USA', '12345', '1234567890', 'approved', 1000.00),
-          ('user2', 'user2@example.com', ?, 'User Two', '1985-02-02', '456 Elm St', 'Canada', '67890', '0987654321', 'pending', 500.00)
-      `, [user1Password, user2Password]);
+          ('user1', 'user1@example.com', ?, 'user', 'User One', '1990-01-01', '123 Main St', 'USA', '12345', '1234567890', 'approved', 1000.00),
+          ('user2', 'user2@example.com', ?, 'user', 'User Two', '1985-02-02', '456 Elm St', 'Canada', '67890', '0987654321', 'pending', 500.00),
+          ('admin1', 'admin1@example.com', ?, 'admin', 'Admin One', '1980-01-01', '789 Oak St', 'USA', '54321', '1112223333', 'approved', 0.00)
+      `, [user1Password, user2Password, admin1Password]);
     }
 
-    // Check if admins exist
-    const [admins] = await pool.query('SELECT COUNT(*) as count FROM admins');
-    if (admins[0].count === 0) {
+    // Check if crypto_addresses exist
+    const [cryptoAddresses] = await pool.query('SELECT COUNT(*) as count FROM crypto_addresses');
+    if (cryptoAddresses[0].count === 0) {
       await pool.query(`
-        INSERT INTO admins (username, email, password)
-        VALUES ('admin1', 'admin1@example.com', ?)
-      `, [admin1Password]);
+        INSERT INTO crypto_addresses (crypto_type, address)
+        VALUES 
+          ('BTC', '1A1zP1eP5QGefi2DMPTfTL5SLmv7DivfNa'),
+          ('ETH', '0x742d35Cc6634C0532925a3b844Bc454e4438f44e')
+      `);
+    }
+
+    // Check if deposits exist
+    const [deposits] = await pool.query('SELECT COUNT(*) as count FROM deposits');
+    if (deposits[0].count === 0) {
+      await pool.query(`
+        INSERT INTO deposits (user_id, crypto_type, amount, status)
+        VALUES 
+          (1, 'BTC', 200.00, 'pending'),
+          (2, 'ETH', 150.00, 'pending')
+      `);
+    }
+
+    // Check if profile_updates exist
+    const [profileUpdates] = await pool.query('SELECT COUNT(*) as count FROM profile_updates');
+    if (profileUpdates[0].count === 0) {
+      await pool.query(`
+        INSERT INTO profile_updates (user_id, username, email, full_name, dob, address, country, zip_code, phone_number, status)
+        VALUES 
+          (1, 'user1_updated', 'user1_updated@example.com', 'User One Updated', '1990-01-01', '123 Main St Updated', 'USA', '12345', '1234567890', 'pending')
+      `);
     }
 
     // Check if investment_plans exist
@@ -199,7 +256,7 @@ async function initializeSchema() {
         INSERT INTO withdrawals (user_id, amount, status)
         VALUES 
           (1, 200.00, 'approved'),
-          (2, 100.00, 'approved')
+          (2, 100.00, 'pending')
       `);
     }