'use strict';

let fs = require('fs');
let mysql = require('mysql');
let querystring = require('querystring');

module.exports.reset = (event, context, callback) => {
  // Extract the Slack request body
  const requestBody = querystring.parse(event.body);
  const requestingUser = requestBody.user_name;

  // Setup the MySQL connection
  const connection = mysql.createConnection({
    host: "somedatabasehost.com",
    user: "someuser",
    password: "somepassword",
    multipleStatements: true
  });

  // Load in the reset script
  const resetScript = fs.readFileSync("resetdata.sql");

  // Drop the database, recreate it, and execute the reset script
  connection.connect();

  const query = `USE ${requestingUser}; ${resetScript}`;

  connection.query(query, function (error, results, fields) {
    connection.end();

    console.log(`Database reset for user ${requestingUser} via Slack.`)
    const response = {
      statusCode: 200,
      body: JSON.stringify({
        text: `Hi, ${requestingUser}.\nYour database has been reset!`
      })
    };
    callback(null, response);
  });
};