index.js

require("dotenv").config();
const {prompts,creepyGifs} = require("./data")
var async = require('async');
var pg = require('pg');
const { v1: uuidv1 } = require('uuid');

const Discord = require("discord.js");
const bot = new Discord.Client();

bot.login(process.env.DISCORD_TOKEN);



var config = {
    user: 'maxroach',
    host: '104.196.201.188',
    database: 'story',
    port: 26257
};

// Create a pool.
var pool = new pg.Pool(config);


bot.on("ready", () => {
  console.info(`Logged in as ${bot.user.tag}!`)
})

const PREFIX ="!boo "
const PREF ="!boo"

let story = []
let flag = false;
const constructStory = () => {
  let str = story.join(" ")
  return str;
}


(async () => {
  const client = await pool.connect();
  console.log("j1")
  var lol = await client.query('CREATE TABLE IF NOT EXISTS story_tb (id UUID PRIMARY KEY, server STRING, channel STRING, story STRING, endv BOOL, votes INT);');
  console.log(lol)
  var lol = await client.query('CREATE TABLE IF NOT EXISTS story_view (id UUID, server STRING, channel STRING PRIMARY KEY);');
  console.log(lol)
  client.release()
})();


async function clearCurrentStories(server, channel){
  const client = await pool.connect();
  console.log("clear")
  var tmp = await client.query(`UPDATE story_tb SET endv=true WHERE (server='${server}' AND channel='${channel}' AND endv=false);`);
  console.log(tmp);
  client.release()
};


bot.on("message", msg => {
  msgarr = msg.content.split(" ");

  if(msgarr[0] == `${PREF}` && msgarr[1] == `story`){
    let server = msg.guild.id, channel = msg.channel.id;
    if(msgarr[2] == `random`){
      clearCurrentStories(server, channel);
      (async () => {
        const client = await pool.connect();
        console.log("j10")
        var tmp = await client.query(`SELECT id, story FROM story_tb WHERE (endv=true AND story IS NOT NULL) ORDER BY random() LIMIT 1;`);
        console.log(tmp);
        msg.channel.send(tmp.rows[0]['story']);
        msg.channel.send("Vote by typing `!boo upvote` or `!boo downvote`");
        var id = tmp.rows[0]['id'];
        var tmp2 = await client.query(`UPSERT INTO story_view (id, server, channel) VALUES ('${id}','${server}','${channel}');`);
        client.release()
      })();
    }
    else if(msgarr[2] == `list`){
      clearCurrentStories(server, channel);
      (async () => {
        const client = await pool.connect();
        console.log("j10")
        var tmp = await client.query(`SELECT story,votes from story_tb WHERE (server='${server}' AND channel='${channel}' AND endv=true AND story IS NOT NULL);`);
        function iterate(item, index) {
          msg.channel.send(`**Story #${index+1}** Votes: ${item['votes']}\n ${item['story']}`);
        }
        tmp.rows.forEach(iterate);
        client.release()
      })();
    }

  }

  else if(msg.content == `${PREFIX}upvote`){
    let server = msg.guild.id, channel = msg.channel.id;
    (async () => {
      const client = await pool.connect();
      var tmp = await client.query(`SELECT id FROM story_view WHERE (server='${server}' AND channel='${channel}');`);
      if (tmp.rowCount!=0){
        var lol = await client.query(`UPDATE story_tb SET votes=votes+1 WHERE (id='${tmp.rows[0]['id']}');`);
        console.log(lol)
        msg.react('👍')
      }
      else {
        msg.reply("Read a story first with the command `!boo story random`");
      }
      client.release()
    })();
  }

  else if(msg.content == `${PREFIX}downvote`){
    let server = msg.guild.id, channel = msg.channel.id;
    (async () => {
      const client = await pool.connect();
      var tmp = await client.query(`SELECT id FROM story_view WHERE (server='${server}' AND channel='${channel}');`);
      if (tmp.rowCount!=0){
        var lol = await client.query(`UPDATE story_tb SET votes=votes-1 WHERE (id='${tmp.rows[0]['id']}');`);
        console.log(lol);
        msg.react('👎');
      }
      else {
        msg.reply("Read a story first!");
      }
      client.release()
    })();
  }

  else if(msg.content == `${PREFIX}start`){
    let server = msg.guild.id, channel = msg.channel.id;
    //Get all records from db and check if any unended story for the channel exists. If yes, end them
    clearCurrentStories(server, channel);

    story = []
    let index = Math.floor(Math.random() * 6);
    msg.channel.send(prompts[index].content);
    flag=1;
    id = uuidv1();

    (async () => {
      const client = await pool.connect();
      console.log("j2")
      var lol = await client.query(`INSERT INTO story_tb (id, server, channel, story, endv, votes) VALUES ('${id}', '${server}', '${channel}', '', false, 0);`);
      console.log(lol)
      client.release()
    })();

  }

  else if (msg.content == `${PREFIX}end`){
    let server = msg.guild.id, channel = msg.channel.id;
    (async () => {
      console.log("end");
      const client = await pool.connect();
      var tmp = await client.query(`SELECT story FROM story_tb WHERE (server='${server}' AND channel='${channel}' AND endv=false);`);
      let index = Math.floor(Math.random() * 3);
      msg.channel.send(`The end. Or is it?\n${creepyGifs[index]}`);
      msg.channel.send(`${tmp.rows[0]['story']}`);
      msg.channel.send('This story is: scary!');
      msg.channel.send('I predict you will get 4538 upvotes!');
      client.release()
      clearCurrentStories(server, channel);
    })();
    /*
    flag=0;
    setTimeout(()=>{
      msg.channel.send(constructStory())
    },2000)
    */
  }
  else if(msgarr[0] == `${PREF}`){
    msg.react('❓')
  }
  else{
    //If story is currently running
    //Get open story for that channel
    //Append
    let server = msg.guild.id, channel = msg.channel.id;

    (async () => {
      const client = await pool.connect();
      console.log("j3")
      var tmp = await client.query(`SELECT story FROM story_tb WHERE (server='${server}' AND channel='${channel}' AND endv=false);`);
      if (tmp.rowCount!=0){
        //console.log(tmp);
        if(tmp.rows[0]['story']){
          var ns = tmp.rows[0]['story']+'\n'+msg.content
        }
        else{
          var ns = msg.content
        }
        var lol = await client.query(`UPDATE story_tb SET story='${ns}' WHERE (server='${server}' AND channel='${channel}' AND endv=false);`);
        console.log(lol)
        msg.react('💀')
      }
      client.release()
      //story.push(msg.content);
    })();

  }


})