discord-bot

name	discord-bot
description	Oceanic.jsを使用したDiscord Botの実装方法。Bot初期化、メッセージ送信、Embed作成、イベントハンドリングについて説明。Discord連携機能の実装時に参照。

Discord Bot 実装 (Oceanic.js)

Oceanic.js 概要

Oceanic.jsは、高速で型安全なDiscord APIライブラリです。

• 公式ドキュメント: https://docs.oceanic.ws/
• GitHub: https://github.com/oceanicjs/oceanic
• Node.js バージョン: 18.13.0 以上

インストール

pnpm add oceanic.js
pnpm add -D @types/node typescript

Bot の初期化

import { Client, Message, TextChannel } from 'oceanic.js';

export class DiscordBot {
    private client: Client;
    private channelId: string;

    constructor(token: string, channelId: string) {
        this.client = new Client({
            auth: `Bot ${token}`,
            gateway: {
                intents: ['GUILDS', 'GUILD_MESSAGES']
            }
        });
        this.channelId = channelId;

        this.setupEventHandlers();
    }

    private setupEventHandlers(): void {
        this.client.on('ready', () => {
            console.log(`Botがログインしました: ${this.client.user?.tag}`);
        });

        this.client.on('error', (error) => {
            console.error('Discord Clientエラー:', error);
        });
    }

    async connect(): Promise<void> {
        try {
            await this.client.connect();
        } catch (error) {
            console.error('Bot接続エラー:', error);
            throw error;
        }
    }

    async disconnect(): Promise<void> {
        await this.client.disconnect();
    }

    getClient(): Client {
        return this.client;
    }
}

メッセージ送信

基本的なメッセージ送信

async sendMessage(content: string): Promise<void> {
    try {
        const channel = await this.client.rest.channels.get(this.channelId);
        
        if (!channel || channel.type !== 0) { // 0 = GUILD_TEXT
            throw new Error('指定されたチャンネルがテキストチャンネルではありません');
        }

        await this.client.rest.channels.createMessage(this.channelId, {
            content: content
        });
    } catch (error) {
        console.error('メッセージ送信エラー:', error);
        throw error;
    }
}

Embed メッセージの送信

import { CreateMessageOptions, Embed } from 'oceanic.js';

async sendEmbed(embed: Embed): Promise<void> {
    try {
        await this.client.rest.channels.createMessage(this.channelId, {
            embeds: [embed]
        });
    } catch (error) {
        console.error('Embed送信エラー:', error);
        throw error;
    }
}

地震情報 Embed の作成

import { Embed, EmbedField } from 'oceanic.js';
import { EarthquakeInfo } from '../earthquake/types';

export class EarthquakeEmbedFormatter {
    static createEarthquakeEmbed(info: EarthquakeInfo): Embed {
        const intensity = this.convertIntensity(info.earthquake.maxScale || 0);
        const color = this.getColorByIntensity(info.earthquake.maxScale || 0);

        const fields: EmbedField[] = [];

        // 震源地情報
        if (info.earthquake.hypocenter) {
            fields.push({
                name: '📍 震源地',
                value: info.earthquake.hypocenter.name || '不明',
                inline: true
            });
        }

        // マグニチュード
        if (info.earthquake.hypocenter.magnitude) {
            fields.push({
                name: '📊 マグニチュード',
                value: `M${info.earthquake.hypocenter.magnitude}`,
                inline: true
            });
        }

        // 深さ
        if (info.earthquake.hypocenter.depth) {
            fields.push({
                name: '⬇️ 深さ',
                value: `約${info.earthquake.hypocenter.depth}km`,
                inline: true
            });
        }

        // 最大震度
        if (info.earthquake.maxScale) {
            fields.push({
                name: '⚠️ 最大震度',
                value: `震度${intensity}`,
                inline: false
            });
        }

        // 津波情報
        if (info.earthquake.domesticTsunami) {
            const tsunamiInfo = this.getTsunamiText(info.earthquake.domesticTsunami);
            fields.push({
                name: '🌊 津波の心配',
                value: tsunamiInfo,
                inline: false
            });
        }

        // 観測地点（上位10件）
        if (info.points && info.points.length > 0) {
            const topPoints = info.points
                .sort((a, b) => b.scale - a.scale)
                .slice(0, 10)
                .map(point => {
                    const scale = this.convertIntensity(point.scale);
                    return `\`震度${scale}\` ${point.pref} ${point.addr}`;
                })
                .join('\n');

            fields.push({
                name: '📌 主な観測地点',
                value: topPoints,
                inline: false
            });
        }

        const embed: Embed = {
            title: '🚨 地震情報',
            description: `**${info.earthquake.time}** 頃、地震がありました。`,
            color: color,
            fields: fields,
            timestamp: new Date(info.issue.time).toISOString(),
            footer: {
                text: `情報源: ${info.issue.source}`
            }
        };

        return embed;
    }

    private static convertIntensity(scale: number): string {
        const intensityMap: Record<number, string> = {
            10: '1',
            20: '2',
            30: '3',
            40: '4',
            45: '5弱',
            50: '5強',
            55: '6弱',
            60: '6強',
            70: '7'
        };
        return intensityMap[scale] || '不明';
    }

    private static getColorByIntensity(scale: number): number {
        // 震度に応じた色分け
        if (scale >= 60) return 0xFF0000; // 赤 (震度6弱以上)
        if (scale >= 50) return 0xFF6600; // オレンジ (震度5強以上)
        if (scale >= 45) return 0xFFCC00; // 黄色 (震度5弱以上)
        if (scale >= 40) return 0x00FF00; // 緑 (震度4以上)
        return 0x00BFFF; // 青 (震度3以下)
    }

    private static getTsunamiText(tsunamiType: string): string {
        const tsunamiMap: Record<string, string> = {
            'None': 'なし',
            'Unknown': '不明',
            'Checking': '調査中',
            'NonEffective': '若干の海面変動の可能性あり',
            'Watch': '津波注意報',
            'Warning': '津波警報'
        };
        return tsunamiMap[tsunamiType] || tsunamiType;
    }
}

使用例

// メインエントリーポイント
import { DiscordBot } from './bot/client';
import { EarthquakeWebSocket } from './earthquake/websocket';
import { EarthquakeEmbedFormatter } from './formatter/embed';

const bot = new DiscordBot(
    process.env.DISCORD_BOT_TOKEN!,
    process.env.DISCORD_CHANNEL_ID!
);

const earthquakeWs = new EarthquakeWebSocket();

// 地震情報受信時の処理
earthquakeWs.on('earthquake', async (data) => {
    const embed = EarthquakeEmbedFormatter.createEarthquakeEmbed(data);
    await bot.sendEmbed(embed);
});

// Bot起動
await bot.connect();
earthquakeWs.connect();

Intents (権限) の設定

Oceanic.jsでは、必要な権限を intents で指定します。

const client = new Client({
    auth: `Bot ${token}`,
    gateway: {
        intents: [
            'GUILDS',           // サーバー情報の取得
            'GUILD_MESSAGES'    // メッセージの送信
        ]
    }
});

エラーハンドリング

this.client.on('error', (error) => {
    console.error('Discord Client エラー:', error);
    // 必要に応じて通知やログ記録
});

this.client.on('disconnect', () => {
    console.warn('Discord Botが切断されました');
    // 再接続処理
});

ベストプラクティス

1. トークンの管理

   • Bot トークンは環境変数で管理する
   • .env ファイルを .gitignore に追加する

2. レート制限対策

   • Discord APIのレート制限に注意する
   • 頻繁な送信が必要な場合は、キューイング機構を実装する

3. エラー処理

   • すべての非同期処理に try-catch を実装する
   • エラーログを適切に記録する

4. Embedのデザイン

   • 色分けで情報の重要度を視覚化する
   • フィールドは適切に整理し、読みやすさを重視する
   • タイムスタンプを必ず含める

5. パフォーマンス

   • 不要なIntentsは指定しない
   • キャッシュの使用を検討する

Discord Bot の権限設定

Bot を Discord サーバーに追加する際、以下の権限が必要です:

• メッセージを送信 (Send Messages)
• 埋め込みリンク (Embed Links)
• チャンネルを見る (View Channel)

招待URLの生成例:

https://discord.com/api/oauth2/authorize?client_id=YOUR_CLIENT_ID&permissions=51200&scope=bot