DifyのチャットボットのAPIの活用の検討

ローカル環境のDifyのチャットボットのAPIに接続テストで、簡易WEBアプリケーション環境を試しに構築しました。
以下はUbuntuでの構築手順です。

### 構築手順

#### 1. プロジェクトディレクトリの作成
まず、新しいディレクトリを作成して、プロジェクトのための作業ディレクトリに移動します。

```bash
mkdir chatbot-web
cd chatbot-web
```

#### 2. Node.jsプロジェクトの初期化
Node.jsのプロジェクトを初期化します。

```bash
npm init -y
```

#### 3. 必要なパッケージのインストール
`express`と`axios`をインストールします。

```bash
npm install express axios
```

#### 4. サーバーの設定
次に、`server.js`ファイルを作成して、サーバーを設定します。以下のコードは、Dify環境のAPIに接続するための例です。

```javascript
// server.js
const express = require('express');
const axios = require('axios');
const app = express();
const port = 3000; // 使用するポート番号

app.use(express.json());

app.post('/api/chat', async (req, res) => {
    try {
        const response = await axios.post('http://localhost/v1/chat-messages', req.body, {
            headers: {
                'Authorization': `Bearer app-xxxxxxxxxxxxxxxxxxxxxxx`,
                'Content-Type': 'application/json'
            },
            responseType: 'stream'
        });

        response.data.on('data', chunk => {
            res.write(chunk);
        });

        response.data.on('end', () => {
            res.end();
        });

    } catch (error) {
        res.status(error.response?.status || 500).json({ error: error.message });
    }
});

app.listen(port, () => {
    console.log(`Server is running on http://localhost:${port}`);
});
```

#### 5. クライアントの設定
publicフォルダの下に、`index.html`ファイルを作成して、クライアント側のHTMLとJavaScriptを設定します。

```html
<!-- index.html -->
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>Chat App</title>
    <link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/markdown-it/12.3.2/markdown-it.min.css">
    <style>
        body {
            font-family: 'Arial', sans-serif;
            background-color: #f4f4f9;
            margin: 0;
            padding: 0;
            display: flex;
            justify-content: center;
            align-items: center;
            height: 100vh;
        }
        .container {
            background-color: #fff;
            padding: 20px;
            border-radius: 8px;
            box-shadow: 0 2px 10px rgba(0, 0, 0, 0.1);
            width: 800px;
            height: 600px;
            display: flex;
            flex-direction: column;
        }
        h1 {
            font-size: 24px;
            margin-bottom: 20px;
            color: #333;
            text-align: center;
        }
        form {
            display: flex;
            margin-bottom: 20px;
        }
        input[type="text"] {
            flex: 1;
            padding: 10px;
            border: 1px solid #ddd;
            border-radius: 4px;
            margin-right: 10px;
            font-size: 16px;
        }
        button {
            padding: 10px 20px;
            background-color: #007bff;
            border: none;
            border-radius: 4px;
            color: white;
            font-size: 16px;
            cursor: pointer;
        }
        button:hover {
            background-color: #0056b3;
        }
        #chatOutput {
            flex: 1;
            border: 1px solid #ddd;
            padding: 10px;
            border-radius: 4px;
            background-color: #f9f9f9;
            overflow-y: auto;
            position: relative;
        }
        .spinner {
            width: 40px;
            height: 40px;
            border: 4px solid rgba(0, 0, 0, 0.1);
            border-top: 4px solid #007bff;
            border-radius: 50%;
            animation: spin 1s linear infinite;
            position: absolute;
            top: 50%;
            left: 50%;
            transform: translate(-50%, -50%);
        }
        @keyframes spin {
            0% { transform: translate(-50%, -50%) rotate(0deg); }
            100% { transform: translate(-50%, -50%) rotate(360deg); }
        }
    </style>
</head>
<body>
    <div class="container">
        <h1>Chat with Bot</h1>
        <form id="chatForm">
            <input type="text" id="query" placeholder="Ask something..." required>
            <button type="submit">Send</button>
        </form>
        <div id="chatOutput"></div>
    </div>

    <script src="https://cdnjs.cloudflare.com/ajax/libs/markdown-it/12.3.2/markdown-it.min.js"></script>
    <script>
        const md = window.markdownit();

        document.getElementById('chatForm').addEventListener('submit', async (event) => {
            event.preventDefault();
            const query = document.getElementById('query').value;
            const responseMode = 'streaming';
            const user = 'unique-user-id';
            const conversationId = ''; // 初回は空文字、続きは以前のIDを使用

            const payload = JSON.stringify({
                query,
                response_mode: responseMode,
                user,
                conversation_id: conversationId,
                inputs: {}
            });

            const chatOutput = document.getElementById('chatOutput');
            const spinner = document.createElement('div');
            spinner.className = 'spinner';
            chatOutput.appendChild(spinner);

            try {
                const response = await fetch('/api/chat', {
                    method: 'POST',
                    headers: {
                        'Content-Type': 'application/json'
                    },
                    body: payload
                });

                if (response.ok) {
                    const reader = response.body.getReader();
                    const decoder = new TextDecoder();
                    let messageBuffer = '';

                    while (true) {
                        const { done, value } = await reader.read();
                        if (done) break;

                        const chunk = decoder.decode(value, { stream: true });
                        const events = chunk.split('\n\n').filter(Boolean);

                        events.forEach(eventStr => {
                            if (eventStr.startsWith('data:')) {
                                const event = JSON.parse(eventStr.slice(5));
                                if (event.event === 'message') {
                                    messageBuffer += event.answer;
                                } else if (event.event === 'message_end') {
                                    const htmlOutput = md.render(messageBuffer);
                                    chatOutput.innerHTML += `<div>${htmlOutput}</div>`;
                                    messageBuffer = '';
                                    // スピナーを削除
                                    if (spinner.parentNode) {
                                        spinner.parentNode.removeChild(spinner);
                                    }
                                }
                            }
                        });
                    }
                } else {
                    console.error('Failed to send message:', response.statusText);
                }
            } catch (error) {
                console.error('Error:', error);
            } finally {
                // 確実にスピナーを削除
                if (spinner.parentNode) {
                    spinner.parentNode.removeChild(spinner);
                }
            }
        });
    </script>
</body>
</html>
```

#### 6. サーバーの起動
`server.js`を実行してサーバーを起動します。

```bash
node server.js
```

### 動作確認
ブラウザで`http://localhost:3000`にアクセスし、チャットフォームに質問を入力してSENDボタンを押します。