refactor(cmd): separate commands by functionality

commands/fediverse/beg.js

@@ -0,0 +1,21 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, registrar) {
+  axios({
+    method: 'POST',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+    data: { status: `@10grans@fedi.cc beg` },
+  }).then((response) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+      '',
+      `<b>
+      <blockquote><i>You have begged for 10grans.<br>
+      (id: ${response.data.id}</a>)
+      </blockquote><br>`);
+  })
+    .catch((e) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '', `${e}`);
+    });
+};

commands/fediverse/boo.js

@@ -0,0 +1,18 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, userInput, registrar) {
+  axios({
+    method: 'POST',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses/${userInput}/unfavourite`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+  }).then((response) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+      '',
+      `You have boo'd: <a href="${response.data.url}">${response.data.account.acct}</a>
+      <blockquote>${response.data.content}`);
+  })
+    .catch((e) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '', `${e}`);
+    });
+};

commands/fediverse/clap.js

@@ -0,0 +1,18 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, userInput, registrar) {
+  axios({
+    method: 'POST',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses/${userInput}/favourite`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+  }).then((response) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+      '',
+      `You have clapped: <a href="${response.data.url}">${response.data.account.acct}</a>:
+      <blockquote>${response.data.content}`);
+  })
+    .catch((e) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '', `${e}`);
+    });
+};

commands/fediverse/copy.js

@@ -0,0 +1,18 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, userInput, registrar) {
+  axios({
+    method: 'POST',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses/${userInput}/reblog`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+  }).then((response) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+      '',
+      `You have repeated:
+      <blockquote>${response.data.content}`);
+  })
+    .catch((e) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '', `${e}`);
+    });
+};

commands/fediverse/flood.js

@@ -0,0 +1,41 @@
+const axios = require('axios');
+const fs = require('fs');
+
+exports.runQuery = function (matrixClient, room, registrar) {
+  setInterval(() => {
+    axios({
+      method: 'GET',
+      url: `${registrar.config.fediverse.domain}/api/v1/timelines/home`,
+      headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+    }).then((events) => {
+      const event = fs.readFileSync('timeline.json', 'utf8');
+      fs.writeFileSync('timeline.json', events.data[0].created_at, 'utf8');
+      if (event !== events.data[0].created_at) {
+        if (events.data[0].reblog === null) {
+          matrixClient.sendHtmlNotice(room.roomId,
+            '',
+            `<b><a href="${registrar.config.fediverse.domain}/notice/${events.data[0].id}">${events.data[0].account.acct}</a>
+              <blockquote><i>${events.data[0].content}</i><br>
+              ${events.data[0].media_attachments.map(media =>
+                `<a href="${media.remote_url}">`+`${media.description}`+'</a>'
+                ).join('<br>')}
+              (id: ${events.data[0].id}) ${registrar.media.visibilityEmoji(events.data[0].visibility)}
+              </blockquote>`);
+        } else {
+          matrixClient.sendHtmlNotice(room.roomId,
+            '',
+            `<b><a href="${registrar.config.fediverse.domain}/${events.data[0].account.id}">
+            ${events.data[0].account.acct}</a>
+            <font color="#7886D7">has <a href="${registrar.config.fediverse.domain}/notice/${events.data[0].id}">repeated</a>:
+            <blockquote><a href="${events.data[0].reblog.account.url}">${events.data[0].reblog.account.acct}</a></blockquote>
+            <blockquote>${events.data[0].content}<br>
+            ${events.data[0].media_attachments.map(media =>
+                `<a href="${media.remote_url}">`+`Proxied image, no description available.`+'</a>'
+                ).join('<br>')}
+            <br>(id: ${events.data[0].id}) ${registrar.media.visibilityEmoji(events.data[0].visibility)}
+            </blockquote>`);
+        }
+      }
+    });
+  }, 8000);
+};

commands/fediverse/follow.js

@@ -0,0 +1,20 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, userInput, registrar) {
+  axios.get(`${registrar.config.fediverse.domain}/api/v1/accounts/${userInput}`).then((findUID) => {
+    axios({
+      method: 'POST',
+      url: `${registrar.config.fediverse.domain}/api/v1/accounts/${findUID.data.id}/follow`,
+      headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+    })
+      .then((response) => {
+        matrixClient.sendHtmlNotice(room.roomId,
+          '',
+          `Subscribed:
+          <blockquote>${registrar.config.fediverse.domain}/${response.data.id}`);
+      });
+  }).catch((e) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+      '', `${e}`);
+  });
+};

commands/fediverse/media.js

@@ -0,0 +1,92 @@
+const qs = require('qs');
+const axios = require('axios');
+const FormData = require('form-data');
+
+const emojis = { public: '🌐', unlisted: '📝', private: '🔒️', direct: '✉️' };
+exports.visibilityEmoji = v => emojis[v] || v;
+
+const getFilename = header => {
+  if(typeof header !== 'string') return null;
+  try {
+    const m = header.match(/inline; filename(?:=(.+)|\*=utf-8''(.+))/);
+    return !m ? null : m[2] && decodeURIComponent(m[2]) || m[1];
+  } catch(e) {
+    return null;
+  }
+};
+
+const mediaDownload = async (url, { whitelist, blacklist }) => {
+  const media = await axios({ method: 'GET', url, responseType: 'arraybuffer' });
+  if (media.statusText !== 'OK' || blacklist.includes(media.headers['content-type'])) throw media;
+  if(whitelist.length && !whitelist.includes(media.headers['content-type'])) throw media;
+  return {
+    data: media.data,
+    filename: getFilename(media.headers['content-disposition']),
+    mimetype: media.headers['content-type']
+  };
+};
+
+const mediaUpload = async ({ domain, token }, { data, filename, mimetype }) => {
+  const form = new FormData();
+  form.append('file', data, {
+    filename: filename || 'upload',
+    contentType: mimetype,
+  });
+  const upload = await axios({
+    method: 'POST',
+    url: `${domain}/api/v1/media`,
+    headers: form.getHeaders({ Authorization: `Bearer ${token}` }),
+    data: form,
+  });
+  if(upload.statusText !== 'OK') throw upload;
+  return upload.data.id;
+};
+
+const run = async (matrixClient, { roomId }, content, replyId, mediaURL, subject, registrar) => {
+  let mediaId = null;
+  const fediverse = registrar.config.fediverse;
+  if(mediaURL) {
+    const media = await mediaDownload(mediaURL, registrar.config.matrix.mimetypes);
+    mediaId = await mediaUpload(fediverse, media);
+  }
+  const response = await axios({
+    method: 'POST',
+    url: `${fediverse.domain}/api/v1/statuses`,
+    headers: { Authorization: `Bearer ${fediverse.token}`, 'Content-Type': 'application/x-www-form-urlencoded' },
+    data : qs.stringify({
+      status: content,
+      content_type: `text/markdown`,
+      media_ids: mediaURL && [ mediaId ] || undefined,
+      in_reply_to_id: replyId || undefined,
+      spoiler_text: subject || undefined
+    }, { arrayFormat: 'brackets' })
+  });
+  return matrixClient.sendHtmlNotice(roomId, '', `<a href="${response.data.url}">${response.data.id}</a>`);
+}
+
+exports.runQuery = async (client, room, userInput, registrar, { isReply, hasMedia, hasSubject }) => {
+  try {
+    const chunks = userInput.trim().split(' ');
+    if(!chunks.length || chunks.length < !!isReply + !!hasMedia) throw '';
+    let replyId = null;
+    let mediaURL = null;
+    const subject = hasSubject ? registrar.config.matrix.subject : null;
+    if(isReply) {
+      replyId = chunks[0];
+      chunks.shift();
+    }
+    if(hasMedia) {
+      let url = new URL(chunks[0]);
+      chunks.shift();
+      if(url.protocol === 'mxc:' && url.hostname && url.pathname)
+        url = new URL(`${registrar.config.matrix.domain}/_matrix/media/r0/download/${url.hostname}${url.pathname}`);
+      if(url.protocol !== 'https:') throw '';
+      if(!registrar.config.matrix.domains.includes(url.hostname)) throw '';
+      if(!/^\/_matrix\/media\/r0\/download\/[^/]+\/[^/]+\/?$/.test(url.pathname)) throw '';
+      mediaURL = url.toString();
+    }
+    return await run(client, room, chunks.join(' '), replyId, mediaURL, subject, registrar);
+  } catch(e) {
+    return client.sendHtmlNotice(room.roomId, 'Sad!', `<strong>Sad!</strong>`).catch(()=>{});
+  }
+};

commands/fediverse/mordy.js

@@ -0,0 +1,26 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, userInput, registrar) {
+  axios({
+    method: 'POST',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+    data: { 
+      status: `@mordekai ${userInput}`, 
+      content_type: `text/markdown`,
+      visibility: 'unlisted',
+      expires_in: '7200'
+    },
+  }).then((response) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+      '',
+      `<b>
+      <blockquote><i>${response.data.content}<br>
+      (id: ${response.data.id}</a>)
+      </blockquote><br>`);
+  })
+    .catch((e) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '', `${e}`);
+    });
+};

commands/fediverse/notify.js

@@ -0,0 +1,51 @@
+const axios = require('axios');
+const fs = require('fs');
+
+exports.runQuery = function (matrixClient, room, registrar) {
+  setInterval(() => {
+    axios({
+      method: 'GET',
+      url: `${registrar.config.fediverse.domain}/api/v1/notifications`,
+      headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+    }).then((notifications) => {
+      const event = fs.readFileSync('notification.json', 'utf8');
+      fs.writeFileSync('notification.json', notifications.data[0].created_at, 'utf8');
+
+      if (event !== notifications.data[0].created_at) {
+        if (notifications.data[0].type === 'follow') {
+          matrixClient.sendHtmlNotice(room.roomId,
+            '',
+            `<b><a href="${registrar.config.fediverse.domain}/${notifications.data[0].account.id}">
+            ${notifications.data[0].account.acct}</a></b>
+          <font color="#03b381"><b>has followed you.</b></font>
+          <br><i>${notifications.data[0].account.note}</i>`);
+        } else if (notifications.data[0].type === 'favourite') {
+          matrixClient.sendHtmlNotice(room.roomId,
+            '',
+            `<b><a href="${registrar.config.fediverse.domain}/${notifications.data[0].account.id}">
+            ${notifications.data[0].account.acct}</a></b>
+          <font color="#03b381"><b>has <a href="${notifications.data[0].status.uri}">favorited</a>
+          your post:</b></font>
+          <br><blockquote><i><b>${notifications.data[0].status.content}</i></b></blockquote>`);
+        } else if (notifications.data[0].type === 'mention') {
+          matrixClient.sendHtmlNotice(room.roomId,
+            '',
+            `<b><a href="${registrar.config.fediverse.domain}/${notifications.data[0].account.id}">
+            ${notifications.data[0].account.acct}</a></b>
+          <font color="#03b381"><b>has <a href="${notifications.data[0].status.uri}">mentioned</a>
+          you:</b></font><br><blockquote><i><b>${notifications.data[0].status.content}
+          <br>(id: ${notifications.data[0].status.id}) ${registrar.media.visibilityEmoji(notifications.data[0].status.visibility)}</i></b>
+          </blockquote>`);
+        } else if (notifications.data[0].type === 'reblog') {
+          matrixClient.sendHtmlNotice(room.roomId,
+            '',
+            `<b><a href="${registrar.config.fediverse.domain}/${notifications.data[0].account.id}">
+            ${notifications.data[0].account.acct}</a></b>
+          <font color="#03b381"><b>has <a href="${notifications.data[0].status.uri}">repeated</a>
+          your post:</b></font><br>
+          <blockquote><i><b>${notifications.data[0].status.content}</i></b></blockquote>`);
+        }
+      }
+    });
+  }, 8000);
+};

commands/fediverse/pin.js

@@ -0,0 +1,20 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, userInput, registrar) {
+  axios({
+    method: 'POST',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses/${userInput}/pin`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+  }).then((response) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+          '',
+          `Pinned:
+          <blockquote><i><a href="${registrar.config.fediverse.domain}/notice/${response.data.id}">
+          ${response.data.content}</a></i>
+          </blockquote>`);
+  })
+    .catch((e) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '', `${e}`);
+    });
+};

commands/fediverse/post.js

@@ -0,0 +1,21 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, userInput, registrar) {
+  axios({
+    method: 'POST',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+    data: { status: userInput, content_type: `text/markdown` },
+  }).then((response) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+      '',
+      `<b>
+      <blockquote><i>${response.data.content}<br>
+      (id: ${response.data.id}</a>)
+      </blockquote><br>`);
+  })
+    .catch((e) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '', `${e}`);
+    });
+};

commands/fediverse/redact.js

@@ -0,0 +1,17 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, userInput, registrar) {
+  axios({
+    method: 'DELETE',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses/${userInput}`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+  }).then((response) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+      '',
+      '<blockquote>Redacted.</blockquote');
+  })
+    .catch((e) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '', `${e}`);
+    });
+};

commands/fediverse/reply.js

@@ -0,0 +1,18 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, address, flaggedInput, registrar) {
+  axios({
+    method: 'POST',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+    data: { status: flaggedInput, in_reply_to_id: address, content_type: `text/markdown` },
+  }).then((response) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+      '',
+      `${response.data.content} ${response.data.url}`);
+  })
+    .catch((e) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '', `${e}`);
+    });
+};

commands/fediverse/status.js

@@ -0,0 +1,19 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, userInput, registrar) {
+  axios({
+    method: 'GET',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses/${userInput}`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+  }).then((response) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '',
+        `<b><a href="${registrar.config.fediverse.domain}/notice/${response.data.id}">${response.data.account.acct}</a>
+        <blockquote><i>${response.data.content}<br>
+        ${response.data.media_attachments.map(media =>
+          `<a href="${media.remote_url}"><b>${media.description}</b></a>`)
+        .join('<br>')}
+        (id: ${response.data.id}</a>)
+        </blockquote>`);
+    });
+};

commands/fediverse/tip.js

@@ -0,0 +1,21 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, address, flaggedInput, registrar) {
+  axios({
+    method: 'POST',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+    data: { status: `@10grans@fedi.cc tip `+ flaggedInput + ` to `+address },
+  }).then((response) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+      '',
+      `<b>
+      <blockquote><i>Tipping ${response.data.content}<br>
+      (id: ${response.data.id}</a>)
+      </blockquote><br>`);
+  })
+    .catch((e) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '', `${e}`);
+    });
+};

commands/fediverse/unfollow.js

@@ -0,0 +1,20 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, userInput, registrar) {
+  axios.get(`${registrar.config.fediverse.domain}/api/v1/accounts/${userInput}`).then((findUID) => {
+    axios({
+      method: 'POST',
+      url: `${registrar.config.fediverse.domain}/api/v1/accounts/${findUID.data.id}/unfollow`,
+      headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+    })
+      .then((response) => {
+        matrixClient.sendHtmlNotice(room.roomId,
+          '',
+          `Unsubscribed:
+          <blockquote>${registrar.config.fediverse.domain}/${response.data.id}`);
+      });
+  }).catch((e) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+      '', `${e}`);
+  });
+};

commands/fediverse/unpin.js

@@ -0,0 +1,20 @@
+const axios = require('axios');
+
+exports.runQuery = function (matrixClient, room, userInput, registrar) {
+  axios({
+    method: 'POST',
+    url: `${registrar.config.fediverse.domain}/api/v1/statuses/${userInput}/unpin`,
+    headers: { Authorization: `Bearer ${registrar.config.fediverse.token}` },
+  }).then((response) => {
+    matrixClient.sendHtmlNotice(room.roomId,
+          '',
+          `Unpinned:
+          <blockquote><i><a href="${registrar.config.fediverse.domain}/notice/${response.data.id}">
+          ${response.data.content}</a></i>
+          </blockquote>`);
+  })
+    .catch((e) => {
+      matrixClient.sendHtmlNotice(room.roomId,
+        '', `${e}`);
+    });
+};