neet/minazuki

import { VoiceChannel } from 'discord.js';
import { isLeft } from 'fp-ts/lib/Either';
import * as t from 'io-ts';
import { filter } from 'rxjs/operators';
import yargsParser from 'yargs-parser';
import { Consumer } from '.';
import { filterNotBot, filterStartsWith } from '../operators';
import { validateVoiceChat } from '../utils/validate-voice-chat';

export const safeDisconnect: Consumer = async context =>
  context.voiceStateUpdate$
    .pipe(filter(([, newVoiceState]) => !newVoiceState.channel))
    .subscribe(([oldVoiceState]) => {
      if (!(oldVoiceState.channel instanceof VoiceChannel)) return;
      oldVoiceState.channel.leave();
    });

export const speakVoiceChat: Consumer = async context =>
  context.message$.subscribe(async message => {
    const { voiceText } = context;

    const connection = context.client.voice?.connections.find(
      c => c.channel.guild.id === message?.guild?.id,
    );

    if (!connection) return;

    try {
      const validatedContent = validateVoiceChat(message.content);
      const audioFilePath = await voiceText.speak(validatedContent);
      connection.play(audioFilePath);
    } catch (e) {
      console.warn(e);
    }
  });

const LeaveProps = t.type({
  _: t.tuple([t.literal('/leave')]),
  channel: t.union([t.string, t.undefined]),
});

export const leaveVoiceChat: Consumer = context =>
  context.message$
    .pipe(filterNotBot, filterStartsWith('/leave'))
    .subscribe(async message => {
      context.before(message);

      const args = LeaveProps.decode(yargsParser(message.content));
      if (isLeft(args)) {
        return context.after(message);
      }

      // VoiceConnection of same guild
      const guildsConnection = context.client.voice?.connections.find(
        c => c.channel.guild.id === message?.guild?.id,
      );
      const channel = args.right.channel ?? guildsConnection?.channel?.id;

      if (!channel) {
        await message.channel.send('参加中のボイスチャットはありません');
        return context.after(message);
      }

      const voiceChannel = context.client.channels.cache.get(channel);

      if (!(voiceChannel instanceof VoiceChannel)) {
        await message.channel.send('指定されたチャンネルは存在しません');
        return context.after(message);
      }

      voiceChannel.leave();
      await message.channel.send('ボイスチャットから退出しました');
      return context.after(message);
    });

const JoinProps = t.type({
  _: t.tuple([t.literal('/join')]),
  channel: t.union([t.string, t.undefined]),
});

export const joinVoiceChat: Consumer = async context =>
  context.message$
    .pipe(filterNotBot, filterStartsWith('/join'))
    .subscribe(async message => {
      context.before(message);

      const args = JoinProps.decode(yargsParser(message.content));
      if (isLeft(args)) {
        return context.after(message);
      }

      // Set default `channel` arg to the ID of the channel which sender currently join
      const senderVoiceChannel = message?.member?.voice?.channel?.id;
      const channel = args.right.channel ?? senderVoiceChannel;

      if (!channel) {
        await message.channel.send(
          '発言者がボイスチャットに参加している場合のみ参加可能です',
        );
        return context.after(message);
      }

      const voiceChannel = context.client.channels.cache.get(channel);

      if (!(voiceChannel instanceof VoiceChannel)) {
        await message.channel.send('指定されたチャンネルは存在しません');
        return context.after(message);
      }

      await voiceChannel.join();
      await message.channel.send('ボイスチャットに参加しました');
      return context.after(message);
    });