#!/usr/bin/node
/* jshint esnext:true */
"use strict";

const Commando = require("discord.js-commando"),
    Discord = require("discord.js"),
    Promise = require("bluebird"),
    ua = require("universal-analytics"),
    emoji = require("discord-emoji"),
    oneLine = require("common-tags").oneLine,
    Channel = require("async-csp").Channel,
    api = require("./api");

const PREVIEW = process.env.PREVIEW != "false",
    MATCH_HISTORY_LEN = parseInt(process.env.MATCH_HISTORY_LEN) || 3,
    IGN_ROTATE_TIMEOUT = parseInt(process.env.IGN_ROTATE_TIMEOUT) || 300,
    REACTION_TIMEOUT = parseInt(process.env.REACTION_TIMEOUT) || 60,  // s
    GOOGLEANALYTICS_ID = process.env.GOOGLEANALYTICS_ID,
    ROOTURL = (PREVIEW? "https://preview.vainsocial.com/":"https://vainsocial.com/");

const reactionsPipe = new Channel();

// embed template
function vainsocialEmbed(title, link, command) {
    return new Discord.RichEmbed()
        .setTitle(title)
        .setColor("#55ADD3")
        .setURL(ROOTURL + link + track(command))
        .setAuthor("VainSocial" + (PREVIEW? " preview":""), ROOTURL + "images/brands/logo-blue.png",
            ROOTURL + track(command))
        .setFooter("VainSocial" + (PREVIEW? " preview":""), ROOTURL + "images/brands/logo-blue.png")
}

// analytics url
function track(command) {
    return "?utm_source=discordbot&utm_medium=discord&utm_campaign=" + command;
}

// direct analytics
function trackAction(msg, action, ign="") {
    if (GOOGLEANALYTICS_ID == undefined) return;
    const user = ua(GOOGLEANALYTICS_ID, msg.author.id,
        { strictCidFormat: false });
    user.pageview({
        documentPath: action,
        documentTitle: ign,
        campaignSource: msg.guild.id,
        campaignMedium: msg.guild.name
    }).send();
}

// return the shortest version of the usage help
// just '?vm'
function usg(msg, cmd) {
    return msg.anyUsage(cmd, undefined, null);
}

// based on impact score float, return an Emoji
function emojifyScore(score) {
    if (score > 0.7) return emoji.people.heart_eyes;
    if (score > 0.6) return emoji.people.blush;
    if (score > 0.5) return emoji.people.yum;
    if (score > 0.3) return emoji.people.relieved;
    return emoji.people.upside_down;
}

// return a match overview string
async function formatMatch(participant) {
    let winstr = "Won",
        hero = await api.mapActor(participant.actor),
        game_mode = await api.mapGameMode(participant.game_mode_id);
    if (!participant.winner) winstr = "Lost";
    return `
${winstr} ${game_mode} with \`${hero}\`
KDA, CS | \`${participant.stats.kills}/${participant.stats.deaths}/${participant.stats.assists}\`, \`${Math.round(participant.stats.farm)}\`
Kill Participation | \`${Math.floor(100 * participant.stats.kill_participation)}%\`
Score | ${emojifyScore(participant.stats.impact_score)} \`${Math.floor(100 * participant.stats.impact_score)}%\`
`;
}

// return [[title, text], …] for rosters
async function formatMatchDetail(match) {
    let strings = [];
    for(let roster of match.rosters) {
        let winstr = "Won";
        if (!roster.winner) winstr = "Lost";
        let rosterstr = `${roster.side} - \`${roster.hero_kills}\` Kills - ${winstr}`;
        let teamstr = "";
        for(let participant of roster.participants) {
            const hero = await api.mapActor(participant.actor);
            teamstr += `
\`${hero}\`, [${participant.player.name}](${ROOTURL}player/${participant.player.name}${track("match-detail")}) \`T${Math.floor(participant.skill_tier/3+1)}\` | \`${participant.stats.kills}/${participant.stats.deaths}/${participant.stats.assists}\`, \`${Math.floor(participant.stats.farm)}\`, Score ${emojifyScore(participant.stats.impact_score)} \`${Math.floor(100 * participant.stats.impact_score)}%\``;
        }
        strings.push([rosterstr, teamstr]);
    }
    return strings;
}

// return a profile string
async function formatPlayer(player) {
    const stats = oneLine`
            Win Rate | \`${Math.round(100 *
            player.currentSeries.reduce((t, s) => t + s.wins, 0) /
            player.currentSeries.reduce((t, s) => t + s.played, 0)
        )}%\`
        `,
        total_kda = oneLine`
            Total KDA | \`${player.stats.kills}\` / \`${player.stats.deaths}\` / \`${player.stats.assists}\`
        `;
    let best_hero = "",
        picks = "";
    if (player.best_hero.length > 0)
        best_hero = oneLine`
            Best | \`${player.best_hero[0].name}\`
        `;
    if (player.picks.length > 0) {
        const hero = await api.mapActor(player.picks[0].actor);
        picks = oneLine`
            Favorite | \`${hero}\`, \`${player.picks[0].hero_pick} picks\`
        `;
    }
    return `
${stats}
${total_kda}
${best_hero}
${picks}
    `;
}

module.exports.rotateGameStatus = (client) => {
    (async function rotate() {
        /*
        const gamers = await api.getGamers(),
            idx = Math.floor(Math.random() * (gamers.length - 1)) + 1;
        if (PREVIEW) await client.user.setGame(
            `?v ${gamers[idx]} | preview.vainsocial.com`);
        else await client.user.setGame(
            `!v ${gamers[idx]} | vainsocial.com`);
        */
        setTimeout(rotate, IGN_ROTATE_TIMEOUT * 1000);
    })();
}

// reaction -> pipe ->>> consumers
// handle new reaction event
module.exports.onNewReaction = (reaction) => {
    if (reaction.users.array().length <= 1) return;  // was me TODO
    reactionsPipe.put(reaction);
}

// create an iterator that returns promises to await new reactions
// the Promise result is the reaction name
function awaitReactions(message, emoji, timeout=REACTION_TIMEOUT) {
    const pipeOut = new Channel();
    let reactions = [];
    // stop listening after timeout
    setTimeout(() => {
        pipeOut.close();
        Promise.map(reactions, async (r) => r.remove());
    }, timeout*1000);

    // async in background
    Promise.each(emoji, async (em) =>
        reactions.push(await message.react(em)));

    let reaction;
    reactionsPipe.pipe(pipeOut);
    return {
        next: async function() {
            do {
                reaction = await pipeOut.take();
                if (reaction == Channel.DONE)
                    return undefined;
            } while (reaction.message.id != message.id ||
                emoji.indexOf(reaction.emoji.name) == -1);
            return reaction.emoji.name;
        }
    }
}

// respond or say text or embed
async function respond(msg, data, response) {
    if (response == undefined) {
        if (typeof data === "string") {
            response = await msg.say(data);
        } else {
            response = await msg.embed(data);
        }
    } else {
        if (typeof data === "string") {
            if (data != response.content)
                await response.edit(data);
        } else {
            if (new Date(response.embeds[0].createdTimestamp).getTime()
                != data.timestamp.getTime())
                // TODO how2 edit embed properly?!
                await msg.editResponse(response, {
                    type: "plain",
                    content: "",
                    options: { embed: data }
                });
        }
    }
    return response;
}

// about
module.exports.showAbout = async (msg) => {
    trackAction(msg, "about");
    await msg.embed(vainsocialEmbed("About VainSocial", "", "about")
        .setDescription(
`Built by the VainSocial development team using the MadGlory API.
Currently running on ${msg.client.guilds.size} servers.`)
        .addField("Website",
            ROOTURL + track("about"), true)
        .addField("Bot invite link",
            "https://discordapp.com/oauth2/authorize?&client_id=287297889024213003&scope=bot&permissions=52288", true)
        .addField("Developer Discord invite",
            "https://discord.gg/txTchJY", true)
        .addField("Twitter",
            "https://twitter.com/vainsocial", true)
    );
}

// return the sqlite stored ign for this user
function nameByUser(msg) {
    return msg.guild.settings.get("remember+" + msg.author.id);
}

// tell the user that they need to store their name
function formatSorryUnknown(msg) {
    return `You're unknown to our service. Try ${usg(msg, "help vme")}.`;
}

module.exports.rememberUser = async (msg, args) => {
    const ign = args.name;
    trackAction(msg, "vainsocial-me", ign);
    await msg.guild.settings.set("remember+" + msg.author.id, ign);
    await msg.reply(
`You are now able to use ${usg(msg, "v")} to access your profile faster.`);
}

// show player profile and last match
module.exports.showUser = async (msg, args) => {
    let responded = false,
        response,
        ign = args.name,
        reactionsAdded = false;
    trackAction(msg, "vainsocial-user", ign);

    // shorthand
    // "?" is not accepted as user input, but the default for empty
    if (ign == "?") {
        ign = nameByUser(msg);
        if (ign == undefined) {
            await msg.reply(formatSorryUnknown(msg));
            return;
        }
    }

    const waiter = api.subscribeUpdates(ign);
    while (await waiter.next() != undefined) {
        const [player, data] = await Promise.all([
            api.getPlayer(ign),
            api.getMatches(ign)
        ]);
        if (player == undefined) {
            response = await respond(msg,
                "Loading your data…", response);
            continue;
        }
        if (data == undefined || data[0].data.length == 0) {
            response = await respond(msg,
                "No match history for you yet", response);
            continue;
        }
        const matches = data[0];

        const moreHelp = oneLine`
*${emoji.symbols.information_source} or ${usg(msg, "vm " + ign)} for detail,
${emoji.symbols["1234"]} or ${usg(msg, "vh " + ign)} for more*`

        const embed = vainsocialEmbed(`${ign} - ${player.shard_id}`, "player/" + ign, "vainsocial-user")
            .setThumbnail(ROOTURL + "images/game/skill_tiers/" +
                matches.data[0].skill_tier + ".png")
            .setDescription("")
            .addField("Profile", await formatPlayer(player), true)
            .addField("Last match", await formatMatch(matches.data[0]) + moreHelp, true)
            .setTimestamp(new Date(matches.data[0].created_at));
        response = await respond(msg, embed, response);

        if (!reactionsAdded) {
            reactionsAdded = true;
            let reactionWaiter = awaitReactions(response,
                [emoji.symbols.information_source, emoji.symbols["1234"]]);
            (async () => {
                while (true) {
                    let rmoji = await reactionWaiter.next();
                    if (rmoji == undefined) break;  // timeout
                    if (rmoji == emoji.symbols.information_source) {
                        trackAction(msg, "reaction-match", ign);
                        await respondMatch(msg, ign, matches.data[0].match_api_id);
                    }
                    if (rmoji == emoji.symbols["1234"]) {
                        trackAction(msg, "reaction-matches", ign);
                        await respondMatches(msg, ign);
                    }
                }
            })();  // async in background
        }
    }
    if (!reactionsAdded)
        await respond(msg, `Could not find \`${ign}\`.`, response);
}

// show match in detail
async function respondMatch(msg, ign, id, response=undefined) {
    const match = await api.getMatch(id);

    let embed = vainsocialEmbed(`${match.game_mode}, ${match.duration} minutes`,
        "player/" + ign + "/match/" + id, "vainsocial-match")
        .setTimestamp(new Date(match.created_at));
    (await formatMatchDetail(match)).forEach(([title, text]) => {
        embed.addField(title, text, true);
    });
    return await respond(msg, embed, response);
}

module.exports.showMatch = async (msg, args) => {
    const index = args.number;
    let responded = false,
        ign = args.name,
        response;
    trackAction(msg, "vainsocial-match", ign);

    // shorthand
    if (ign == "?") {
        ign = nameByUser(msg);
        if (ign == undefined) {
            await msg.reply(formatSorryUnknown(msg));
            return;
        }
    }

    const waiter = api.subscribeUpdates(ign);
    while (await waiter.next() != undefined) {
        const data = await api.getMatches(ign);
        if (data == undefined || data[0].data.length == 0) {
            response = await respond(msg, "No matches for you yet",
                response);
            continue;
        }
        const matches = data[0];
        if (index - 1 > matches.data.length) {
            response = await respond(msg, "Not enough matches yet",
                response);
            continue;
        }
        let id = matches.data[index -1].match_api_id;
        response = await respondMatch(msg, ign, id, response);
        responded = true;
    }
    if (!responded)
        await respond(msg, `Could not find \`${ign}\`.`, response);
}

// show match history
async function respondMatches(msg, ign, response=undefined) {
    const count = [ emoji.symbols.one, emoji.symbols.two, emoji.symbols.three,
        emoji.symbols.four, emoji.symbols.five, emoji.symbols.six,
        emoji.symbols.seven, emoji.symbols.eight, emoji.symbols.nine,
        emoji.symbols.ten
    ];
    const data = await api.getMatches(ign),
        matches = data[0].data.slice(0, MATCH_HISTORY_LEN),  // TODO
        matches_num = matches.length;

    let embed = vainsocialEmbed(ign, "player/" + ign, "vainsocial-matches")
        .setDescription(`
Last ${matches_num} casual and ranked matches.
*${emoji.symbols["1234"]} or ${usg(msg, "vm " + ign + " number")} for details*
        `)
        .setTimestamp(new Date(matches[0].created_at));
    await Promise.each(matches, async (match, idx) =>
        embed.addField(`Match ${idx + 1}`, await formatMatch(match))
    );
    response = await respond(msg, embed, response);

    const reactionWaiter = awaitReactions(response,
        count.slice(0, matches_num));
    (async () => {
        while (true) {
            let rmoji = await reactionWaiter.next();
            if (rmoji == undefined) break;  // timeout
            let idx = count.indexOf(rmoji);
            await respondMatch(msg, ign, matches[idx].match_api_id);
            trackAction(msg, "reaction-match", ign);
        }
    })();  // async in background
    return response;
}

module.exports.showMatches = async (msg, args) => {
    let ign = args.name,
        responded = false,
        response;
    trackAction(msg, "vainsocial-matches", ign);

    // shorthand
    if (ign == "?") {
        ign = nameByUser(msg);
        if (ign == undefined) {
            await msg.reply(formatSorryUnknown(msg));
            return;
        }
    }

    const waiter = api.subscribeUpdates(ign);
    while (await waiter.next() != undefined) {
        const data = await api.getMatches(ign);
        if (data == undefined || data[0].data.length == 0) {
            response = await respond(msg, "No matches for you yet",
                response);
            continue;
        }
        const matches = data[0];
        response = await respondMatches(msg, ign, response);
        responded = true;
    }
    if (!responded)
        await respond(msg, `Could not find \`${ign}\`.`,
            response);
}