const express = require('express');
const session = require('express-session');
const connectDb = require('../lib/db/connectDb');
const migrateDb = require('../lib/db/migrateDb');
const indexSync = require('../lib/db/indexSync');
const path = require('path');
const cors = require('cors');
const routes = require('./routes');
const errorController = require('./controllers/errorController');

const port = process.env.PORT || 3080;
const host = process.env.HOST || 'localhost';
const userSystemEnabled = process.env.ENABLE_USER_SYSTEM || false;
const projectPath = path.join(__dirname, '..', '..', 'client');

(async () => {
  await connectDb();
  console.log('Connected to MongoDB');
  await migrateDb();
  await indexSync();

  const app = express();
  app.use(errorController);
  app.use(cors());
  app.use(express.json());
  app.use(express.static(path.join(projectPath, 'dist')));
  app.set('trust proxy', 1); // trust first proxy
  app.use(
    session({
      secret: 'chatgpt-clone-random-secrect',
      resave: false,
      saveUninitialized: true,
      cookie: { maxAge: 7 * 24 * 60 * 60 * 1000 } // 7 days
    })
  );

  /* chore: potential redirect error here, can only comment out this block; 
    comment back in if using auth routes i guess */
  // app.get('/', routes.authenticatedOrRedirect, function (req, res) {
  //   console.log(path.join(projectPath, 'public', 'index.html'));
  //   res.sendFile(path.join(projectPath, 'public', 'index.html'));
  // });

  app.get('/api/me', function (req, res) {
    if (userSystemEnabled) {
      const user = req?.session?.user;

      if (user) res.send(JSON.stringify({ username: user?.username, display: user?.display }));
      else res.send(JSON.stringify(null));
    } else {
      res.send(JSON.stringify({ username: 'anonymous_user', display: 'Anonymous User' }));
    }
  });

  app.use('/api/search', routes.authenticatedOr401, routes.search);
  app.use('/api/ask', routes.authenticatedOr401, routes.ask);
  app.use('/api/messages', routes.authenticatedOr401, routes.messages);
  app.use('/api/convos', routes.authenticatedOr401, routes.convos);
  app.use('/api/customGpts', routes.authenticatedOr401, routes.customGpts);
  app.use('/api/presets', routes.authenticatedOr401, routes.presets);
  app.use('/api/prompts', routes.authenticatedOr401, routes.prompts);
  app.use('/auth', routes.auth);

  app.get('/api/endpoints', function (req, res) {
    const azureOpenAI = !!process.env.AZURE_OPENAI_KEY;
    const openAI = process.env.OPENAI_KEY
      ? { availableModels: ['gpt-4', 'text-davinci-003', 'gpt-3.5-turbo', 'gpt-3.5-turbo-0301'] }
      : false;
    const bingAI = !!process.env.BING_TOKEN;
    const chatGPTBrowser = process.env.OPENAI_KEY
      ? { availableModels: ['Default (GPT-3.5)', 'Legacy (GPT-3.5)', 'GPT-4'] }
      : false;

    res.send(JSON.stringify({ azureOpenAI, openAI, bingAI, chatGPTBrowser }));
  });

  app.get('/*', routes.authenticatedOrRedirect, function (req, res) {
    res.sendFile(path.join(projectPath, 'dist', 'index.html'));
  });

  app.listen(port, host, () => {
    if (host == '0.0.0.0')
      console.log(
        `Server listening on all interface at port ${port}. Use http://localhost:${port} to access it`
      );
    else console.log(`Server listening at http://${host == '0.0.0.0' ? 'localhost' : host}:${port}`);
  });
})();

let messageCount = 0;
process.on('uncaughtException', (err) => {
  if (!err.message.includes('fetch failed')) {
    console.error('There was an uncaught error:', err.message);
  }

  if (err.message.includes('fetch failed')) {
    if (messageCount === 0) {
      console.error('Meilisearch error, search will be disabled');
      messageCount++;
    }
  } else {
    process.exit(1);
  }
});