From 223c8893dfa718e3bd5f48fbc9db061a5be94542 Mon Sep 17 00:00:00 2001
From: Flummi <flummi@f0ck.space>
Date: Wed, 3 May 2023 01:16:53 +0200
Subject: [PATCH] thumbnailer trigger

---
 src/inc/trigger/f0ck.mjs       |  4 ++--
 src/inc/trigger/thumbnails.mjs | 42 ++++++++++++++++++++++++++++++++++
 2 files changed, 44 insertions(+), 2 deletions(-)
 create mode 100644 src/inc/trigger/thumbnails.mjs

diff --git a/src/inc/trigger/f0ck.mjs b/src/inc/trigger/f0ck.mjs
index 1c5b69c..1cb40c5 100644
--- a/src/inc/trigger/f0ck.mjs
+++ b/src/inc/trigger/f0ck.mjs
@@ -60,7 +60,7 @@ export default async bot => {
           const tmpc = await lib.countf0cks();
           await e.reply(`tagged: ${tmpc.tagged}; untagged: ${tmpc.untagged}; sfw: ${tmpc.sfw}; nsfw: ${tmpc.nsfw}; total: ${tmpc.total}`);
         break;
-        case "autotagger":
+        /*case "autotagger":
           const body = { headers: { Authorization: `Basic ${cfg.tagger.btoa}` } };
           const res = await (await fetch(`${cfg.tagger.endpoint}/usage`, body)).json();
           if(res) {
@@ -69,7 +69,7 @@ export default async bot => {
             return await e.reply(`autotagger: usage/limit: ${processed}/${limit}`);
           }
           return;
-        break;
+        break;*/
         /*case "renameTag":
           const origTag = e.args.slice(1).join(' ');
 
diff --git a/src/inc/trigger/thumbnails.mjs b/src/inc/trigger/thumbnails.mjs
new file mode 100644
index 0000000..9267ccb
--- /dev/null
+++ b/src/inc/trigger/thumbnails.mjs
@@ -0,0 +1,42 @@
+import queue from '../queue.mjs';
+import db from '../sql.mjs';
+
+export default async bot => {
+
+  return [{
+    name: "thumbnailer",
+    call: /^\!thumb \d+/i,
+    active: true,
+    level: 100,
+    f: async e => {
+      let processed = [];
+
+      for(let id of e.args) {
+        id = +id;
+        if(id <= 1)
+          continue;
+
+        const f0ck = await db`
+          select dest, mime, username, userchannel, usernetwork
+          from "items"
+          where
+            id = ${id} and
+            active = 'true'
+          limit 1
+        `;
+
+        if(f0ck.length === 0) {
+          await e.reply(`f0ck ${id}: f0ck not found`);
+          continue;
+        }
+
+        // gen thumb
+        await queue.genThumbnail(f0ck[0].dest, f0ck[0].mime, f0ck[0].id, f0ck[0].src);
+
+        processed.push(id);
+      }
+
+      return await e.reply(`thumbnails: ${processed.length}/${e.args.length} (${processed.join(",")})`);
+    }
+  }];
+};