inventories.js

var gw2api = require('./api.js');
var sf = require('./sharedFunctions.js');
var debug = false;
module.exports = function() {
  var ret = {

    addResponses: function(controller) {

      ////wallet
      controller.hears(['^wallet(.*)', '^dungeonwallet(.*)', '^dw(.*)'], 'direct_message,direct_mention,mention,ambient', function(bot, message) {

        controller.storage.users.get(message.user, function(err, user) {
          if (err) {
            bot.reply(message, "I got an error loading your data (or you have no access token set up). Try again later");
            bot.botkit.log("Error: wallet no user data " + err);
            return;
          }
          //precheck - input scrub a bit
          var matches = sf.removePunctuationAndToLower(message.text).match(/(dw|dungeonwallet|wallet)([\s\w]*)$/i);
          if (!matches) {
            bot.reply(message, "I didn't quite get that. Maybe ask \'help wallet\'?");
            return;
          }
          //precheck: access token.
          if (!user || !user.access_token || !sf.userHasPermission(user, 'wallet')) {
            bot.botkit.log('ERROR: bank no access token: ' + JSON.stringify(user) + "err: " + JSON.stringify(err));
            bot.reply(message, "Sorry, I don't have your access token " + (user && user.access_token && !sf.userHasPermission(user, 'wallet') ? "with correct 'wallet' 'permissions' " : "") + "on file. Direct message me the phrase \'access token help\' for help.");
            return;
          }
          var searchTerm = (matches[2] ? matches[2].replace(/\s+/g, '') : null);
          var isDungeonOnly = (matches[1] == "dungeonwallet" || matches[1] == 'dw');
          if (searchTerm) bot.reply(message, "Okay, " + user.dfid + sf.randomHonoriffic(user.dfid, user.id) + ", rifling through your wallet for " + searchTerm + ".");
          else bot.reply(message, "Okay, " + user.dfid + sf.randomHonoriffic(user.dfid, user.id) + ", what's in YOUR wallet?");
          gw2api.accountWallet(function(walletList, headers) {
            var defaultIcon = 'https://render.guildwars2.com/file/0E011CD3AA34BB0C327D290830C7F10F0946307B/866837.png';
            if (isDungeonOnly) {
              //['Ascalonian Tear', 'Seal of Beetletun', 'Deadly Bloom', 'Manifesto of the Moletariate', 'Flame Legion Charr Carving', 'Symbol of Koda', 'Knowledge Crystal', 'Shard of Zhaitan', 'Fractal Relic', 'Pristine Fractal Relic'];
              //Hard coded ID instead of title, since both are subject to change, but id is probably more stable
              var dungeonCurrencyList = [5, 9, 11, 10, 13, 12, 14, 6, 7, 24];
              walletList = walletList.filter(function(value) {
                return (dungeonCurrencyList.indexOf(value.id) >= 0);
              });
              defaultIcon = 'https://render.guildwars2.com/file/943538394A94A491C8632FBEF6203C2013443555/102478.png';
            }
            walletList.sort(function(a, b) {
              return (gw2api.findInData('id', a.id, 'currencies').order - gw2api.findInData('id', b.id, 'currencies').order);
            });

            var text = [];
            var lastIcon;
            for (var i in walletList) {
              var currency = gw2api.findInData('id', walletList[i].id, 'currencies');
              if (currency &&
                (!searchTerm || (searchTerm && sf.removePunctuationAndToLower(currency.name).replace(/\s+/g, '').includes(searchTerm)))
              ) {
                if (currency.name == 'Coin') {
                  text.push("Coin: " + sf.coinToString(walletList[i].value));
                } else
                  text.push(currency.name + ": " + walletList[i].value);
                lastIcon = currency.icon;
              }
            }
            if (text.length > 0)
              bot.reply(message, {
                attachments: {
                  attachment: {
                    fallback: 'Too many items found in search.',
                    pretext: (searchTerm ? 'Looking for: ' + searchTerm : ''),
                    text: text.join("\n"),
                    thumb_url: ((lastIcon && text.length > 1) ? defaultIcon : lastIcon)
                  }
                }
              });
            else bot.reply(message, "You don't have any.");
          }, {
            access_token: user.access_token,
          });

        });
      });

      ////BANK
      controller.hears(['^bank (.*)'], 'direct_message,direct_mention,mention,ambient', function(bot, message) {

        controller.storage.users.get(message.user, function(err, user) {
          if (err) {
            bot.reply(message, "I got an error loading your data (or you have no access token set up). Try again later");
            bot.botkit.log("Error:bank no user data " + err);
            return;
          }
          //precheck - input scrub a bit
          var matches = sf.removePunctuationAndToLower(message.text).match(/(bank)\s?([\s\w]*)$/i);
          if (!matches || !matches[2]) {
            bot.reply(message, "I didn't quite get that. Maybe ask \'help bank\'?");
            return;
          }
          //precheck: access token.
          if (!user || !user.access_token || !sf.userHasPermission(user, 'inventories')) {
            bot.botkit.log('ERROR: bank no access token: ' + JSON.stringify(user) + "err: " + JSON.stringify(err));
            bot.reply(message, "Sorry, I don't have your access token " + (user && user.access_token && !sf.userHasPermission(user, 'inventories') ? "with correct 'inventories' permissions " : "") + "on file. Direct message me the phrase \'access token help\' for help.");
            return;
          }
          var searchTerm = matches[2].replace(/\s+/g, '');
          var bankAll = false;
          if (searchTerm == 'all')
            bankAll = true;
          bot.reply(message, "Okay, " + user.dfid + sf.randomHonoriffic(user.dfid, user.id) + ", rifling through your pockets" + (!bankAll ? " for spare " + matches[2] : '') + ".");

          //setup: fetch character list and callback

          ret.fetchAllCharacterData(user.access_token)
            .then(fetchAllItemAndSkinIds)
            .then(function(itemList) { //find items with our original search string
              if (debug) sf.log(itemList.length + " unique items in character inventories.");
              if (bankAll)
                tallyAndDisplay(itemList);
              else {
                var itemSearchResults = [];
                for (var i in itemList) {
                  if (sf.removePunctuationAndToLower(itemList[i].inventoryName).replace(/\s+/g, '').includes(searchTerm))
                    itemSearchResults.push(itemList[i]);
                }
                //And Display!
                if (itemSearchResults.length === 0) { //no match
                  bot.reply(message, "No item names on your account contain that exact text.");
                } else if (itemSearchResults.length == 1) { //exactly one. Ship it.
                  tallyAndDisplay([itemSearchResults[0]]);
                } else if (itemSearchResults.length > 10) { //too many matches in our 'contains' search, notify and give examples.
                  var itemNameList = [];
                  for (var n in itemSearchResults) {
                    itemNameList.push(itemSearchResults[n].inventoryName + sf.levelAndRarityForItem(itemSearchResults[n]));
                  }
                  bot.reply(message, {
                    attachments: {
                      attachment: {
                        fallback: 'Too many items found in search.',
                        text: "Bro. I found " + itemSearchResults.length + ' items. Get more specific.\n' + itemNameList.join("\n")
                      }
                    }
                  });
                } else { //10 items or less, allow user to choose
                  bot.startConversation(message, function(err, convo) {
                    var listofItems = '';
                    for (var i in itemSearchResults) {
                      listofItems += '\n' + [i] + ": " + itemSearchResults[i].inventoryName + sf.levelAndRarityForItem(itemSearchResults[i]) + (itemSearchResults[i].forged ? " (Mystic Forge)" : "");
                    }
                    convo.ask('I found multiple items with that name. Which number you mean? (say no to quit)' + listofItems, [{
                      //number, no, or repeat
                      pattern: new RegExp(/^(\d{1,2})/i),
                      callback: function(response, convo) {
                        //if it's a number, and that number is within our search results, print it
                        var matches = response.text.match(/^(\d{1,2})/i);
                        var selection = matches[0];
                        if (selection < itemSearchResults.length) {
                          tallyAndDisplay([itemSearchResults[selection]]);
                        } else convo.repeat(); //invalid number. repeat choices.
                        convo.next();
                      }
                    }, {
                      //negative response. Stop repeating the list.
                      pattern: bot.utterances.no,
                      callback: function(response, convo) {
                        convo.say('¯\\_(ツ)_/¯');
                        convo.next();
                      }
                    }, {
                      default: true,
                      callback: function(response, convo) {
                        // loop back, user needs to pick or say no.
                        convo.say("Nope. Next time choose a number of the item you'd like to see.");
                        convo.next();
                      }
                    }]);
                  });
                }
              }
            })
            .catch(function(error) {
              bot.reply(message, "I got an error on my way to promise land from the bank. Send help!\nTell them " + error);
              if (convo) convo.next();
            });

          var tallyAndDisplay = function(itemList) {
            var total = 0;
            var totalStrings = [];
            if (itemList.length == 1) { //find and count this item
              var itemToDisplay = itemList[0];
              for (var inv in inventories) {
                var sourceCount = 0;
                var ind = inventories[inv].ids.indexOf(itemToDisplay.id, 0);
                while (ind >= 0) {
                  sourceCount += inventories[inv].counts[ind];
                  total += inventories[inv].counts[ind];
                  ind = inventories[inv].ids.indexOf(itemToDisplay.id, (ind + 1));
                }
                if (sourceCount > 0)
                  totalStrings.push(inventories[inv].source + " has " + (sourceCount > 500 ? sourceCount + ' of the goddamn things' : sourceCount));
              }
              if (total > 0 && totalStrings.length > 0) {
                bot.reply(message, "*" + itemToDisplay.inventoryName + ": " + total + " owned*\n" + totalStrings.join('\n'));
              } else
                bot.reply(message, "You have none of that. None.");
            } else { //bank all command. List ALL items
              var tallyAllItemsArray = []; //index is id, object is like {total:total,sources:[{source: 'source', count:count}]}
              for (var i in inventories) {
                var uniqueIds = sf.arrayUnique(inventories[i].ids);
                for (var uid in uniqueIds) {
                  var foundIndex = inventories[i].ids.indexOf(uniqueIds[uid], 0);
                  var subCount = 0;
                  while (foundIndex >= 0) {
                    subCount += inventories[i].counts[foundIndex];
                    total += inventories[i].counts[foundIndex];
                    foundIndex = inventories[i].ids.indexOf(uniqueIds[uid], (foundIndex + 1));
                  }
                  if (subCount > 0) {
                    if (!tallyAllItemsArray[uniqueIds[uid]]) { //new item
                      tallyAllItemsArray[uniqueIds[uid]] = {
                        total: 0,
                        sources: []
                      };
                    }
                    tallyAllItemsArray[uniqueIds[uid]].total += subCount;
                    tallyAllItemsArray[uniqueIds[uid]].sources.push({
                      source: inventories[i].source,
                      count: subCount
                    });
                  }
                }
              }
              itemList.sort(function(a, b) {
                if (a.name < b.name) return -1;
                if (a.name > b.name) return 1;
                return 0;
              });
              for (var il in itemList) {
                if (tallyAllItemsArray[itemList[il].id]) {
                  var pushString = itemList[il].inventoryName + ": " + tallyAllItemsArray[itemList[il].id].total;
                  for (var n in tallyAllItemsArray[itemList[il].id].sources) {
                    pushString += ", " + tallyAllItemsArray[itemList[il].id].sources[n].source + " has " + tallyAllItemsArray[itemList[il].id].sources[n].count;
                  }
                  totalStrings.push(pushString);
                }

              }
              var attachments = [];
              var loopString = '';
              for (var ls in totalStrings) {
                if (loopString.length + totalStrings[ls].length > 7900) { //if we're about to go above the limit, peel off an attachment
                  attachments.push({
                    fallback: 'ALL THE ITEMS',
                    text: loopString
                  });
                  loopString = '';
                }
                loopString += totalStrings[ls] + '\n';
              }
              if (loopString.length > 0) //catch the last attachment.
                attachments.push({
                fallback: 'ALL THE ITEMS',
                text: loopString
              });

              attachments[0].title = "Everything Report: " + total + " total items";

              bot.reply(message, {
                attachments: attachments
              });
            }
          };
        });
      });
    },
    addHelp: function(helpFile) {
      helpFile.wallet = "List the contents of your wallet. Optionally add a search string to filter the list. Useage:wallet <name>";
      helpFile.dungeonWallet = "Lists only your dungeon currencies.";
      helpFile.dw = 'Alias for dungeon wallet: ' + JSON.stringify(helpFile.dungeonwallet);
      helpFile.bank = "Search your possessions for an item. Looks in character inventories, shared inventory, bank and material storage. Usage: bank <item name>";
    },
    fetchAllCharacterData: function(access_token) {
      //setup: promise fetch shared inventory, bank, and material storage.
      inventories = [];

      return gw2api.promise.characters(['all'], access_token)
        .then(ret.collateCharacterItems)
        .then(function() {
          return Promise.all([
              gw2api.promise.accountBank(['all'], access_token),
              gw2api.promise.accountInventory(['all'], access_token),
              gw2api.promise.accountMaterials(['all'], access_token)
            ])
            .then(ret.collateStorageItems);
        });
    },
    collateCharacterItems: function(characterList) {
      if (characterList.text || characterList.error) {
        bot.reply(message, "Oops. I got this error when asking about your character inventories: " + (characterList.text ? characterList.text : characterList.error) + '\n' + JSON.stringify(err));
        return;
      }
      //Build a list of all inventories. Character and account
      //setup:promise fetch items in each character inventory
      for (var ch in characterList) {
        var idList = [];
        var countList = [];
        var skinList = [];

        for (var bg in characterList[ch].bags) {
          if (characterList[ch].bags[bg] !== null) { //there can be no bag in the slot
            for (var it in characterList[ch].bags[bg].inventory) {
              if (characterList[ch].bags[bg].inventory[it] !== null) { //there can be no item in the bag
                idList.push(characterList[ch].bags[bg].inventory[it].id);
                countList.push(characterList[ch].bags[bg].inventory[it].count);
                skinList.push(characterList[ch].bags[bg].inventory[it].skin || 0);
              }
            }
          }
        }
        inventories.push({
          source: characterList[ch].name,
          ids: idList,
          counts: countList,
          skins: skinList
        });
        //Reset, add worn items
        idList = [];
        countList = [];
        skinList = [];
        for (var slot in characterList[ch].equipment) {
          if (characterList[ch].equipment[slot] !== null) {
            idList.push(characterList[ch].equipment[slot].id);
            countList.push(1);
            skinList.push(characterList[ch].equipment[slot].skin || 0);
          }
        }
        inventories.push({
          source: characterList[ch].name + " (worn)",
          ids: idList,
          counts: countList,
          skins: skinList
        });
      }
    },
    collateStorageItems: function(results) {
      return new Promise(function(resolve, reject) {
        var sourceNames = ['Your bank', 'Your shared inventory', 'Your materials storage'];
        if (debug) sf.log((results ? results.length : "0 (undefined)") + " owned item results returned, " + ((results[0] ? results[0].length : 0) + (results[1] ? results[1].length : 0) + (results[2] ? results[2].length : 0)) + " total items");
        for (var sourceList in results) {
          var idList = [];
          var countList = [];
          var skinsList = [];
          for (var item in results[sourceList]) {
            if (results[sourceList][item] !== null && (results[sourceList][item].count && results[sourceList][item].count !== 0)) {
              if (results[sourceList][item].id === null) console.log("null item " + JSON.stringify(results[sourceList][item]));
              idList.push(results[sourceList][item].id);
              countList.push(results[sourceList][item].count);
              skinsList.push(results[sourceList][item].skin || 0);
            }
          }
          inventories.push({
            source: sourceNames[sourceList],
            ids: idList,
            counts: countList,
            skins: skinsList
          });
        }
        if (debug)
          for (var ch in inventories)
            sf.log(inventories[ch].source + " has " + (inventories[ch].counts.length == inventories[ch].ids.length ? inventories[ch].counts.length + " items" : " an error"));
        resolve(inventories);
      });
    }
  };
  return ret;
}();

function fetchAllItemAndSkinIds(inventories) { //collate the IDs of all items in all inventories, and fetch
  return new Promise(function(resolve, reject) {

    var itemPagePromises = [];
    var ownedItemIds = [];
    for (var inv in inventories)
      ownedItemIds = ownedItemIds.concat(inventories[inv].ids);
    ownedItemIds = sf.arrayUnique(ownedItemIds);
    if (debug) sf.log("Fetching " + ownedItemIds.length + " unique items");
    for (var i = 0; i < ownedItemIds.length; i += 200) {
      itemPagePromises.push(gw2api.promise.items(ownedItemIds.slice(i, i + 200)));
    }
    return Promise.all(itemPagePromises)
      .then(function(results) {
        var itemList = [];
        for (var list in results) {
          itemList = itemList.concat(results[list]);
        }
        if (debug) {
          sf.log("results has " + itemList.length + " items");
        }

        var skinPagePromises = [];
        var ownedSkinIds = [];
        for (var inv in inventories)
          ownedSkinIds = ownedSkinIds.concat(inventories[inv].skins);
        ownedSkinIds = sf.arrayUnique(ownedSkinIds);
        ownedSkinIds.splice(ownedSkinIds.indexOf(0), 1); //Remove 0 (inserted as a placeholder for blank skins)
        if (debug) sf.log("Fetching " + ownedSkinIds.length + " unique skins");
        for (var i = 0; i < ownedSkinIds.length; i += 200) {
          skinPagePromises.push(gw2api.promise.skins(ownedSkinIds.slice(i, i + 200)));
        }
        return Promise.all(skinPagePromises)
          .then(function(results) {
            var skinList = [];
            for (var list in results) {
              skinList = skinList.concat(results[list]);
            }
            if (debug) {
              sf.log("results has " + skinList.length + " skins");
            }

            //add skin data to items
            function getInventoryName(itemToDisplay) {
              var findSkinInInventories = function(skin) {
                return skin.id == inventories[source].skins[inSource];
              };

              for (var source in inventories) {
                var inSource = inventories[source].ids.indexOf(itemToDisplay.id);
                if (inSource >= 0 && inventories[source].skins[inSource] !== 0) {
                  var skinFound = skinList.find(findSkinInInventories);
                  if (skinFound)
                    return skinFound.name;
                }
              }
              return itemToDisplay.name;
            }

            for (var i in itemList)
              itemList[i].inventoryName = getInventoryName(itemList[i]);

            resolve(itemList);
          });
      });
  });
}