import logger from "../log.mjs";
import { getLevel } from "../../inc/admin.mjs";
import { promises as fs } from "fs";
import cfg from "../config.mjs";
import db from "../sql.mjs";
import lib from "../lib.mjs";

export default async bot => {

  return [{
    name: "callback_query",
    listener: "callback_query",
    f: async e => {
      logger.info(`${e.network} -> ${e.channel} -> ${e.user.nick}: ${e.message}`);

      let [ cmd, id ] = e.opt.data.split(':');
      let f0ck;
      id = +id;

      switch(cmd) {
        case "b_tags":
          if(!id)
            return;

          const tags = [{
            tag: 'music',
            id: 115
          }, {
            tag: 'german',
            id: 329
          }, {
            tag: 'cat',
            id: 217
          }, {
            tag: 'doggo',
            id: 5
          }];
          const keyboard = await Promise.all(tags.map(async t => ({ text: `${await lib.hasTag(id, t.id) ? '✓ ' : ''}${t.tag}`, callback_data: `b_${t.tag}:${id}` })));

          await e.editMessageText(e.raw.chat.id, e.raw.message_id, e.message, {
            reply_markup: JSON.stringify({
              inline_keyboard: [[
                ...keyboard
              ], [
                { text: 'back', callback_data: `b_back:${id}` }
              ]]
            })
          });
        break;
        case "b_back":
          if(!id)
            return;

          await e.editMessageText(e.raw.chat.id, e.raw.message_id, e.message, {
            reply_markup: JSON.stringify({
              inline_keyboard: [[
                { text: (await lib.hasTag(id, 1) ? '✓ ' : '') + 'sfw', callback_data: `b_sfw:${id}` },
                { text: (await lib.hasTag(id, 2) ? '✓ ' : '') + 'nsfw', callback_data: `b_nsfw:${id}` },
                { text: 'tags', callback_data: `b_tags:${id}` },
                { text: '❌ delete', callback_data: `b_delete:${id}` }
              ], [
                { text: `open f0ck #${id}`, url: `${cfg.main.url.full}/${id}` }
              ]]
            })
          });
        break;
        case "b_sfw":
          
          if(!id)
            return;

          if(!(await lib.getTags(id)).filter(tag => [1,2].includes(tag.id)).length) {
            // insert
            await db`
              insert into "tags_assign" ${
                db({
                  item_id: id,
                  tag_id: 1, // sfw
                  user_id: 1
                })
              }
            `;
          }
          else {
            // update
            await db`
              update "tags_assign" set tag_id = 1
              where
                tag_id = 2 and
                item_id = ${id}
            `;
          }

          await e.editMessageText(e.raw.chat.id, e.raw.message_id, e.message, {
            reply_markup: JSON.stringify({
              inline_keyboard: [[
                { text: '✓ sfw', callback_data: `b_sfw:${id}` },
                { text: 'nsfw', callback_data: `b_nsfw:${id}` },
                { text: 'tags', callback_data: `b_tags:${id}` },
                { text: '❌ delete', callback_data: `b_delete:${id}` }
              ], [
                { text: `open f0ck #${id}`, url: `${cfg.main.url.full}/${id}` }
              ]]
            })
          });

        break;
        case "b_nsfw":
          if(!id)
            return;

          if(!(await lib.getTags(id)).filter(tag => [1,2].includes(tag.id)).length) {
            // insert
            await db`
              insert into "tags_assign" ${
                db({
                  item_id: id,
                  tag_id: 2, // nsfw
                  user_id: 1
                })
              }
            `;
          }
          else {
            // update
            await db`
              update "tags_assign" set tag_id = 2
              where
                tag_id = 1 and
                item_id = ${id}
            `;
          }

          await e.editMessageText(e.raw.chat.id, e.raw.message_id, e.message, {
            reply_markup: JSON.stringify({
              inline_keyboard: [[
                { text: 'sfw', callback_data: `b_sfw:${id}` },
                { text: '✓ nsfw', callback_data: `b_nsfw:${id}` },
                { text: 'tags', callback_data: `b_tags:${id}` },
                { text: '❌ delete', callback_data: `b_delete:${id}` }
              ], [
                { text: `open f0ck #${id}`, url: `${cfg.main.url.full}/${id}` }
              ]]
            })
          });
        break;
        case "b_delete":
          if(id <= 1)
            return;

          e.user = {
            prefix: `${e.raw.reply_to_message.from.username}!${e.raw.reply_to_message.from.id}@${e.network}`,
            nick: e.raw.reply_to_message.from.first_name,
            username: e.raw.reply_to_message.from.username,
            account: e.raw.reply_to_message.from.id.toString()
          };

          f0ck = await db`
            select dest, mime, username, userchannel, usernetwork
            from "items"
            where
              id = ${id} and
              active = 'true'
            limit 1
          `;
          const level = getLevel(e.user).level;

          if(f0ck.length === 0) {
            return await e.reply(`f0ck ${id}: f0ck not found`);
          }
          
          if(
            (f0ck[0].username !== (e.user.nick || e.user.username) ||
            f0ck[0].userchannel !== e.channel ||
            f0ck[0].usernetwork !== e.network) &&
            level < 100
          ) {
            return await e.reply(`f0ck ${id}: insufficient permissions`);
          }

          if(~~(new Date() / 1e3) >= (f0ck[0].stamp + 600) && level < 100) {
            return await e.reply(`f0ck ${id}: too late lol`);
          }

          await db`update "items" set active = 'false' where id = ${id}`;

          await fs.copyFile(`./public/b/${f0ck[0].dest}`, `./deleted/b/${f0ck[0].dest}`).catch(_=>{});
          await fs.copyFile(`./public/t/${id}.webp`, `./deleted/t/${id}.webp`).catch(_=>{});
          await fs.unlink(`./public/b/${f0ck[0].dest}`).catch(_=>{});
          await fs.unlink(`./public/t/${id}.webp`).catch(_=>{});

          if(f0ck[0].mime.startsWith('audio')) {
            await fs.copyFile(`./public/ca/${id}.webp`, `./deleted/ca/${id}.webp`).catch(_=>{});
            await fs.unlink(`./public/ca/${id}.webp`).catch(_=>{});
          }

          await e.editMessageText(e.raw.chat.id, e.raw.message_id, e.message, {
            reply_markup: JSON.stringify({
              inline_keyboard: [[
                { text: (await lib.hasTag(id, 1) ? '✓ ' : '') + 'sfw', callback_data: `b_sfw:${id}` },
                { text: (await lib.hasTag(id, 2) ? '✓ ' : '') + 'nsfw', callback_data: `b_nsfw:${id}` },
                { text: 'tags', callback_data: `b_tags:${id}` },
                { text: 'recover', callback_data: `b_recover:${id}` }
              ], [
                { text: `open f0ck #${id}`, url: `${cfg.main.url.full}/${id}` }
              ]]
            })
          });
        break;
        case "b_recover":
          if(id <= 1)
            return;

          e.user = {
            prefix: `${e.raw.reply_to_message.from.username}!${e.raw.reply_to_message.from.id}@${e.network}`,
            nick: e.raw.reply_to_message.from.first_name,
            username: e.raw.reply_to_message.from.username,
            account: e.raw.reply_to_message.from.id.toString()
          };
          
          f0ck = await db`
            select dest, mime
            from "items"
            where
              id = ${id} and
              active = 'false'
            limit 1
          `;
  
          if(f0ck.length === 0) {
            return await e.reply(`f0ck ${id}: f0ck not found`);
          }
  
          await fs.copyFile(`./deleted/b/${f0ck[0].dest}`, `./public/b/${f0ck[0].dest}`).catch(_=>{});
          await fs.copyFile(`./deleted/t/${id}.webp`, `./public/t/${id}.webp`).catch(_=>{});
          await fs.unlink(`./deleted/b/${f0ck[0].dest}`).catch(_=>{});
          await fs.unlink(`./deleted/t/${id}.webp`).catch(_=>{});
  
          if(f0ck[0].mime.startsWith('audio')) {
            await fs.copyFile(`./deleted/ca/${id}.webp`, `./public/ca/${id}.webp`).catch(_=>{});
            await fs.unlink(`./deleted/ca/${id}.webp`).catch(_=>{});
          }
  
          await db`update "items" set active = 'true' where id = ${id}`;
          
          await e.editMessageText(e.raw.chat.id, e.raw.message_id, e.message, {
            reply_markup: JSON.stringify({
              inline_keyboard: [[
                { text: (await lib.hasTag(id, 1) ? '✓ ' : '') + 'sfw', callback_data: `b_sfw:${id}` },
                { text: (await lib.hasTag(id, 2) ? '✓ ' : '') + 'nsfw', callback_data: `b_nsfw:${id}` },
                { text: 'tags', callback_data: `b_tags:${id}` },
                { text: '❌ delete', callback_data: `b_delete:${id}` }
              ], [
                { text: `open f0ck #${id}`, url: `${cfg.main.url.full}/${id}` }
              ]]
            })
          });
        break;
        default:
          await e.reply('lol');
      }
    }
  }];

};