const path = require('path');
const fs = require('fs');
const express = require('express');
const bodyParser = require('body-parser');

const config = JSON.parse(fs.readFileSync('config.json', 'utf-8'));

const pg = require('postgresupdater')(
  config.database.host,
  config.database.port,
  config.database.user,
  config.database.password,
  config.database.database
);

const app = express();

app.use(bodyParser.text({ type: '*/*' }));

app.post('/', (req, res, next) => {
  console.log('post');
  if (req.query.json) {
    // json mod requests
  } else {
    try {
      const json = JSON.parse(req.body);
      pg.query(
        `INSERT INTO "Log" ("App", "Type", "Client", "Message", "Misc", "Stack") Values($1, $2, $3, $4, $5, $6)`,
        [json.app, json.type, json.client, json.message, json.misc, json.stack]
      );
    } catch {
      console.log('invalid json', req.body);
    }
  }
  res.status(201).end();
  next();
});

app.get('/', async (req, res, next) => {
  if (typeof req.query.json != 'undefined') {
    const data = await pg.query(
      `SELECT "Timestamp", "Type", "App", "Client", "Message", "Misc", "Stack" FROM "LogView"`
    );
    const rows = [];
    for (let row of data.rows) {
      rows.push(Object.values(row));
    }
    res
      .status(200)
      .type('application/json')
      .end(JSON.stringify(rows));
  } else {
    next();
  }
});

app.use(express.static('html'));

app.listen(config.port);
console.log('server listening on', config.port);