Added claimbot that uses chainquery instead of lbrycrd. Usage otherwise identical to old bot.

src/commands/lbry/claimbot.js

@@ -1,10 +1,12 @@
 // Claimbot is a work in progress, it will use chainquery when done.
-/* import { Command } from "discord.js-commando";
 import { RichEmbed } from "discord.js";
-import welcomeEvent from "../../helpers/welcomeEvent";
+import config from "config";
 
-let bootupTime = null;
-module.exports = class ClaimCommand extends Command {
+const Commando = require("discord.js-commando");
+
+let time = null;
+const channels = config.get("Wunderbot.claimbot");
+module.exports = class ClaimCommand extends Commando.Command {
     constructor(client) {
         super(client, {
             name: "claimbot",
@@ -24,12 +26,10 @@ module.exports = class ClaimCommand extends Command {
             guildOnly: true,
             guarded: true
         });
-        client.on("ready", () => {
-            bootupTime = new Date()
-                .toISOString()
-                .slice(0, 19)
-                .replace("T", " ");
-            this.checkGuilds();
+        client.on("ready", async () => {
+            setInterval(() => {
+                this.checkNewClaims();
+            }, 300000); // Check for new claims every 5 minutes
         });
     }
 
@@ -38,45 +38,89 @@ module.exports = class ClaimCommand extends Command {
     }
 
     async run(msg, { action }) {
-        if (action.toLowerCase() === "enable") {
-        }
-        if (action.toLowerCase() === "disable") {
-        }
         if (action.toLowerCase() === "test") {
-            console.log(
-                await this.getNewClaimsSince(
-                    new Date()
-                        .toISOString()
-                        .slice(0, 19)
-                        .replace("T", " ")
-                )
-            );
+            console.log(await this.getClaimsSince(bootupTime));
+        }
+    }
+    async checkNewClaims() {
+        if (time === null) {
+            time = new Date()
+                .toISOString()
+                .slice(0, 19)
+                .replace("T", " ");
+        } else {
+            const claims = await this.getClaimsSince(time);
+            // Output claims to channels
+            claims.data.forEach(c => {
+                const v = JSON.parse(c.value);
+                this.postToDiscord(c, v);
+            });
+            time = new Date()
+                .toISOString()
+                .slice(0, 19)
+                .replace("T", " ");
         }
     }
 
-    checkGuilds(){
+    postToDiscord(claim, value) {
+        const text = [];
+        if (value.author) {
+            text.push(`author: ${value.author}`);
+        }
+        if (value.description) {
+            text.push(value.description);
+        }
+        // if (value['content_type'])
+        // {
+        //   text.push("*Content Type:* " + value['content_type']);
+        // }
+        if (value.nsfw) {
+            text.push("*Warning: Adult Content*");
+        }
 
+        // "fee":{"currency":"LBC","amount":186,"version":"_0_0_1","address":"bTGoFCakvQXvBrJg1b7FJzombFUu6iRJsk"}
+        if (value.fee) {
+            const fees = [];
+            text.push(`Price: ${value.fee.amount} *${value.fee.currency}*`);
+        }
+
+        const claimEmbed = new RichEmbed();
+        claimEmbed
+            .setAuthor(value.author || "Anonymous", "http://barkpost-assets.s3.amazonaws.com/wp-content/uploads/2013/11/3dDoge.gif", `http://open.lbry.io/${claim.name}#${claim.claimId}`)
+            .setTitle(`lbry://${channelName ? `${channelName}/` : ""}${claim.name}`)
+            .setColor(1399626)
+            .setDescription(this.escapeSlackHtml(text.join("\n")))
+            .setFooter(`Block ${claimBlockHeight} • Claim ID ${claim.claimId}`)
+            .setImage(!value.nsfw ? value.thumbnail || "" : "")
+            .setURL(`http://open.lbry.io/${claim.name}#${claim.claimId}`);
+        channels.forEach(channel => {
+            this.bot.channels
+                .get(channel)
+                .send("", { embed: claimEmbed })
+                .catch(console.error);
+        });
     }
-    async getNewClaimsSince(date, guild_id) {
-        const query = `${`` +
-            `SELECT ` +
-            `name, ` +
-            `value_as_json as value, ` +
-            `bid_state, ` +
+    async getClaimsSince(time) {
+        const query = `${`${`` + `SELECT ` + `name, `}${`fee, ``value_as_json as value, `}bid_state, ` +
             `effective_amount, ` +
             `claim_id as claimId ` +
             // `,transaction_by_hash_id, ` + // txhash and vout needed to leverage old format for comparison.
             // `vout ` +
             `FROM claim ` +
-            `WHERE modified >='`}${date}'`;
-        const newClaims = await this.client.request({
+            `WHERE created >='`}${time}'`;
+        const claimList = await this.client.request({
             url: `https://chainquery.lbry.io/api/sql?query=${query}`,
             cacheKey: `https://chainquery.lbry.io/api/sql?query=${query}`,
-            cacheTTL: 1,
+            cacheTTL: 0,
             cacheLimit: 1,
             resolveWithFullResponse: false
         });
-        console.log(newClaims);
+        return JSON.parse(claimList);
+    }
+    escapeSlackHtml(txt) {
+        return txt
+            .replace("&", "&")
+            .replace("<", "&lt;")
+            .replace(">", "&gt;");
     }
 };
-*/