declare global {
  // eslint-disable-next-line no-var, no-unused-vars
  var cachedPrisma: PrismaClient
}

let prisma: PrismaClient
if (process.env.NODE_ENV === 'production') {
  prisma = new PrismaClient()
} else {
  if (!global.cachedPrisma) {
    global.cachedPrisma = new PrismaClient()
  }
  prisma = global.cachedPrisma
}

export const db = prisma

require("dotenv").config();
const { createClient } = require("redis");
const mysql = require("mysql2/promise");
const express = require("express");
const { Pool } = require("pg");

const app = express();
const port = process.env.PORT || 5600;

app.get("/", async (req, res) => {
  res.status(200).json({
    env: process.env,
  });
});

// Check for PostgreSQL env var
let pool = null;
if (process.env.PG_URL) {
  pool = new Pool({
    connectionString: process.env.PG_URL,
  });
} else {
  console.warn(
    "Warning: DATABASE_URL is not set. PostgreSQL endpoint will be disabled."
  );
}

// PostgreSQL endpoint
app.get("/pg", async (req, res) => {
  if (!pool) {
    return res
      .status(500)
      .json({ error: "PostgreSQL connection not configured" });
  }
  try {
    const result = await pool.query("SELECT NOW()");
    res.json({ status: "Postgres connected", time: result.rows[0].now });
  } catch (error) {
    console.error("PG error:", error);
    res.status(500).json({ status: "PG Error", message: error.message });
  }
});

// Check for Redis env var and initialize client
let redisClient = null;
if (process.env.REDIS_URL) {
  redisClient = createClient({
    url: process.env.REDIS_URL,
  });
  redisClient.on("error", (err) => console.error("Redis Client Error", err));
  (async () => {
    await redisClient.connect();
  })();
} else {
  console.warn(
    "Warning: REDIS_URL is not set. Redis endpoint will be disabled."
  );
}

// Redis endpoint
app.get("/redis", async (req, res) => {
  if (!redisClient) {
    return res.status(500).json({ error: "Redis connection not configured" });
  }
  try {
    await redisClient.set("ping", "PONG");
    const value = await redisClient.get("ping");
    res.json({ status: "Redis connected", message: value });
  } catch (error) {
    console.error("Redis error:", error);
    res.status(500).json({ status: "Redis Error", message: error.message });
  }
});

// MySQL setup
let mysqlPool = null;
if (process.env.MYSQL_URL) {
  mysqlPool = mysql.createPool({ uri: process.env.MYSQL_URL });
} else {
  console.warn(
    "Warning: MYSQL_URL is not set. MySQL endpoint will be disabled."
  );
}

// MySQL endpoint
app.get("/mysql", async (req, res) => {
  if (!mysqlPool) {
    return res.status(500).json({ error: "MySQL connection not configured" });
  }
  try {
    const [rows] = await mysqlPool.query("SELECT NOW() AS now");
    res.json({ status: "MySQL connected", time: rows[0].now });
  } catch (error) {
    console.error("MySQL error:", error);
    res.status(500).json({ status: "MySQL Error", message: error.message });
  }
});

app.listen(port, () => {
  console.log(`Server running on port ${port}`);
});