diff --git a/server.js b/server.js index 1837365..26d239b 100644 --- a/server.js +++ b/server.js @@ -34,16 +34,19 @@ if (!DATABASE_URL || !JWT_SECRET) { // ========================= const pool = new Pool({ connectionString: DATABASE_URL, - ssl: false // Correcto para Coolify interno + ssl: false }); // ========================================== -// šŸ› ļø RUTA DE INSTALACIƓN (ACTUALIZADA) +// 🧠 CEREBRO DE AUTO-ACTUALIZACIƓN (NUEVO) // ========================================== -app.get("/setup-db", async (req, res) => { +// Esta función se ejecuta sola al arrancar y repara la DB +async function autoUpdateDB() { const client = await pool.connect(); try { - // 1. TABLAS ORIGINALES + console.log("šŸ”„ Verificando salud de la base de datos..."); + + // 1. Crear tablas base si no existen await client.query(` CREATE TABLE IF NOT EXISTS users ( id SERIAL PRIMARY KEY, @@ -56,6 +59,7 @@ app.get("/setup-db", async (req, res) => { is_verified BOOLEAN DEFAULT FALSE, created_at TIMESTAMP DEFAULT NOW() ); + CREATE TABLE IF NOT EXISTS login_codes ( id SERIAL PRIMARY KEY, user_id INT REFERENCES users(id) ON DELETE CASCADE, @@ -66,6 +70,7 @@ app.get("/setup-db", async (req, res) => { expires_at TIMESTAMP NOT NULL, created_at TIMESTAMP DEFAULT NOW() ); + CREATE TABLE IF NOT EXISTS services ( id SERIAL PRIMARY KEY, user_id INT REFERENCES users(id) ON DELETE CASCADE, @@ -76,10 +81,7 @@ app.get("/setup-db", async (req, res) => { notes TEXT, created_at TIMESTAMP DEFAULT NOW() ); - `); - // 2. NUEVAS TABLAS (Gremios y Roles) - await client.query(` CREATE TABLE IF NOT EXISTS guilds ( id SERIAL PRIMARY KEY, name TEXT UNIQUE NOT NULL, @@ -93,28 +95,25 @@ app.get("/setup-db", async (req, res) => { ); `); - // 3. ACTUALIZAR USUARIOS (AƱadir columna role si no existe) - try { - await client.query(`ALTER TABLE users ADD COLUMN role TEXT DEFAULT 'operario'`); - } catch (e) { - // Ignoramos error si la columna ya existe - } + // 2. PARCHE INTELIGENTE: AƱadir columna 'role' si falta + // Este bloque es la CLAVE: comprueba si existe 'role', si no, la crea. + await client.query(` + DO $$ + BEGIN + IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='users' AND column_name='role') THEN + ALTER TABLE users ADD COLUMN role TEXT DEFAULT 'operario'; + RAISE NOTICE 'āœ… Columna ROLE aƱadida automĆ”ticamente'; + END IF; + END $$; + `); - res.send("āœ… Ā”Base de datos actualizada! Tablas y Roles listos."); + console.log("āœ… Base de datos Sincronizada y Lista."); } catch (e) { - console.error(e); - res.status(500).send("āŒ Error configurando DB: " + e.message); + console.error("āŒ Error en auto-actualización:", e); } finally { client.release(); } -}); - -// ========================= -// RUTA DE "ESTOY VIVO" -// ========================= -app.get("/", (req, res) => { - res.status(200).send("šŸš€ IntegraRepara API v1.0 - Online"); -}); +} // ========================= // HELPERS @@ -133,7 +132,6 @@ function genCode6() { } function signToken(user) { - // AƑADIDO: Incluimos el 'role' en el token return jwt.sign( { sub: user.id, phone: user.phone, email: user.email, role: user.role || 'operario' }, JWT_SECRET, @@ -190,7 +188,7 @@ async function sendWhatsAppCode(phone, code) { } // ========================= -// RUTAS ORIGINALES +// RUTAS // ========================= // 1. REGISTRO @@ -277,7 +275,6 @@ app.post("/auth/verify", async (req, res) => { await pool.query("UPDATE login_codes SET consumed_at=NOW() WHERE id=$1", [row.id]); await pool.query("UPDATE users SET is_verified=TRUE WHERE id=$1", [row.uid]); - // Incluimos role en el token const token = signToken({ id: row.uid, email: row.email, phone: p, role: row.role }); res.json({ ok: true, token }); } catch (e) { @@ -317,10 +314,6 @@ app.get("/services", authMiddleware, async (req, res) => { } }); -// ========================= -// NUEVAS RUTAS: CONFIGURACIƓN -// ========================= - // 5. GESTIƓN DE GREMIOS app.get("/guilds", authMiddleware, async (req, res) => { try { @@ -351,18 +344,13 @@ app.post("/admin/users", authMiddleware, async (req, res) => { try { const { fullName, email, password, role, guilds } = req.body; - // Validación - if (!email || !password || !fullName) { - return res.status(400).json({ ok: false, error: "Faltan datos obligatorios" }); - } + if (!email || !password || !fullName) return res.status(400).json({ ok: false, error: "Faltan datos" }); const passwordHash = await bcrypt.hash(password, 10); - // Generamos un telĆ©fono dummy porque la base de datos lo exige (UNIQUE) const dummyPhone = `manual_${Date.now()}`; await client.query('BEGIN'); - // Insertar usuario const insert = await client.query( `INSERT INTO users (full_name, email, password_hash, role, phone, is_verified) VALUES ($1, $2, $3, $4, $5, TRUE) RETURNING id`, @@ -370,7 +358,6 @@ app.post("/admin/users", authMiddleware, async (req, res) => { ); const userId = insert.rows[0].id; - // Asignar Gremios if (guilds && Array.isArray(guilds)) { for (const guildId of guilds) { await client.query("INSERT INTO user_guilds (user_id, guild_id) VALUES ($1, $2)", [userId, guildId]); @@ -378,17 +365,24 @@ app.post("/admin/users", authMiddleware, async (req, res) => { } await client.query('COMMIT'); - res.json({ ok: true, msg: "Usuario creado correctamente" }); - + res.json({ ok: true, msg: "Usuario creado" }); } catch (e) { await client.query('ROLLBACK'); console.error(e); - res.status(500).json({ ok: false, error: "Error creando usuario (Email duplicado?)" }); + res.status(500).json({ ok: false, error: "Error creando usuario" }); } finally { client.release(); } }); -// ARRANCAR +// ========================= +// ARRANCAR SERVIDOR Y AUTO-UPDATE +// ========================= const port = process.env.PORT || 3000; -app.listen(port, "0.0.0.0", () => console.log(`šŸš€ Server OK en puerto ${port}`)); \ No newline at end of file + +// Primero ejecutamos la actualización, y SOLO CUANDO TERMINE, arrancamos el server +autoUpdateDB().then(() => { + app.listen(port, "0.0.0.0", () => { + console.log(`šŸš€ Server OK en puerto ${port} (DB Sincronizada)`); + }); +}); \ No newline at end of file