feat: 絵文字が作成されたら #無法地帯 にログを送信する機能の追加

src/adaptor/emoji-proxy.ts

@@ -0,0 +1,18 @@
+import type { Client } from 'discord.js';
+import type { EmojiData } from '../service/emoji-log';
+import type { EmojiEventProvider } from '../runner';
+
+export type EmojiHandler<E> = (emoji: E) => Promise<void>;
+
+export class EmojiProxy implements EmojiEventProvider<EmojiData> {
+  constructor(private readonly client: Client) {}
+
+  onEmojiCreate(handler: EmojiHandler<EmojiData>): void {
+    this.client.on('emojiCreate', (emoji) =>
+      handler({
+        emoji: emoji.toString(),
+        emojiAuthorId: emoji.author?.id ?? undefined
+      })
+    );
+  }
+}

src/runner/emoji.ts

@@ -0,0 +1,46 @@
+export type EmojiEvent = 'CREATE';
+
+export interface EmojiEventResponder<E> {
+  on(event: EmojiEvent, emoji: E): Promise<void>;
+}
+
+export const composeEmojiEventResponders = <E>(
+  ...responders: readonly EmojiEventResponder<E>[]
+): EmojiEventResponder<E> => ({
+  async on(event, emoji) {
+    await Promise.all(
+      responders.map((responder) => responder.on(event, emoji))
+    );
+  }
+});
+
+export interface EmojiEventProvider<E> {
+  onEmojiCreate(handler: (emoji: E) => Promise<void>): void;
+}
+
+export class EmojiResponseRunner<
+  E,
+  R extends EmojiEventResponder<E> = EmojiEventResponder<E>
+> {
+  constructor(provider: EmojiEventProvider<E>) {
+    provider.onEmojiCreate((emoji) => this.triggerEvent('CREATE', emoji));
+  }
+
+  private async triggerEvent(event: EmojiEvent, emoji: E): Promise<void> {
+    try {
+      await Promise.all(this.responders.map((res) => res.on(event, emoji)));
+    } catch (e) {
+      console.error(e);
+    }
+  }
+
+  private responders: R[] = [];
+
+  addResponder(responder: R) {
+    this.responders.push(responder);
+  }
+
+  getResponders(): readonly R[] {
+    return this.responders;
+  }
+}

src/runner/index.ts

@@ -2,3 +2,4 @@ export * from './message';
 export * from './schedule';
 export * from './voice-room';
 export * from './role';
+export * from './emoji';

src/server/index.ts

@@ -20,6 +20,7 @@ import type {
   CommandResponder
 } from '../service/command-message';
 import {
+  EmojiResponseRunner,
   MessageResponseRunner,
   MessageUpdateResponseRunner,
   RoleResponseRunner,
@@ -28,6 +29,7 @@ import {
 } from '../runner';
 import { type VoiceChannelParticipant, VoiceDiff } from '../service/voice-diff';
 import {
+  allEmojiResponder,
   allMessageEventResponder,
   allMessageUpdateEventResponder,
   allRoleResponder,
@@ -37,6 +39,7 @@ import type { AssetKey } from '../service/party';
 import { DiscordMemberStats } from '../adaptor/discord-member-stats';
 import { DiscordRoleManager } from '../adaptor/discord-role';
 import { DiscordSheriff } from '../adaptor/discord-sheriff';
+import { EmojiProxy } from '../adaptor/emoji-proxy';
 import type { KaereMusicKey } from '../service/kaere';
 import { Snowflake } from '../model/id';
 import dotenv from 'dotenv';
@@ -56,7 +59,8 @@ const intents = new Intents();
 intents.add(
   Intents.FLAGS.GUILDS, // GUILD_CREATE による初期化
   Intents.FLAGS.GUILD_MESSAGES, // ほとんどのメッセージに反応する機能
-  Intents.FLAGS.GUILD_VOICE_STATES // VoiceDiff 機能
+  Intents.FLAGS.GUILD_VOICE_STATES, // VoiceDiff 機能
+  Intents.FLAGS.GUILD_EMOJIS_AND_STICKERS // EmojiLog機能
 );
 
 const client = new Client({ intents });
@@ -141,6 +145,9 @@ roleRunner.addResponder(
 );
 roleProxy(client, roleRunner);
 
+const emojiRunner = new EmojiResponseRunner(new EmojiProxy(client));
+emojiRunner.addResponder(allEmojiResponder(output));
+
 client.once('ready', () => {
   readyLog(client);
 });

src/service/emoji-log.test.ts

@@ -0,0 +1,30 @@
+import { EmojiLog } from './emoji-log';
+
+test('create emoji', async () => {
+  const sendEmbed = jest.fn(() => Promise.resolve());
+  const responder = new EmojiLog({ sendEmbed });
+  await responder.on('CREATE', {
+    emoji: '<:kawaehand:903283802443501618>',
+    emojiAuthorId: '586824421470109716'
+  });
+
+  expect(sendEmbed).toHaveBeenCalledWith({
+    title: '絵文字警察',
+    description:
+      '<@586824421470109716> が <:kawaehand:903283802443501618> を作成しました'
+  });
+});
+
+test('create emoji(author undefined)', async () => {
+  const sendEmbed = jest.fn(() => Promise.resolve());
+  const responder = new EmojiLog({ sendEmbed });
+  await responder.on('CREATE', {
+    emoji: '<:kawaehand:903283802443501618>',
+    emojiAuthorId: undefined
+  });
+
+  expect(sendEmbed).toHaveBeenCalledWith({
+    title: '絵文字警察',
+    description: '誰かが <:kawaehand:903283802443501618> を作成しました'
+  });
+});

src/service/emoji-log.ts

@@ -0,0 +1,29 @@
+import type { EmojiEventResponder, RoleEvent } from '../runner';
+import type { StandardOutput } from './output';
+
+export interface EmojiData {
+  emoji: string;
+  emojiAuthorId: string | undefined;
+}
+
+export class EmojiLog implements EmojiEventResponder<EmojiData> {
+  constructor(private readonly output: StandardOutput) {}
+  async on(event: RoleEvent, role: EmojiData): Promise<void> {
+    if (event !== 'CREATE') {
+      return;
+    }
+
+    if (role.emojiAuthorId == undefined) {
+      await this.output.sendEmbed({
+        title: '絵文字警察',
+        description: `誰かが ${role.emoji} を作成しました`
+      });
+      return;
+    }
+
+    await this.output.sendEmbed({
+      title: '絵文字警察',
+      description: `<@${role.emojiAuthorId}> が ${role.emoji} を作成しました`
+    });
+  }
+}

src/service/index.ts

@@ -8,6 +8,7 @@ import {
   type Clock,
   type MessageResponseRunner,
   ScheduleRunner,
+  composeEmojiEventResponders,
   composeMessageEventResponders,
   composeMessageUpdateEventResponders,
   composeRoleEventResponders
@@ -31,6 +32,7 @@ import {
   type TypoRepository
 } from './typo-record';
 import { DifferenceDetector } from './difference-detector';
+import { EmojiLog } from './emoji-log';
 import { HelpCommand } from './help';
 import { Meme } from './meme';
 import type { Snowflake } from '../model/id';
@@ -90,3 +92,6 @@ export const allRoleResponder = (
   composeRoleEventResponders(
     new KawaemonHasAllRoles(kawaemonId, roleManager, output)
   );
+
+export const allEmojiResponder = (output: StandardOutput) =>
+  composeEmojiEventResponders(new EmojiLog(output));