【保存版】DifyとSlackを連携させてAIチャットボットを作ろう！

//----------
// 定数
//----------
const DIFY_API_ENDPOINT = 'https://api.dify.ai/v1/chat-messages';
const SLACK_API_BASE = 'https://slack.com/api';

//----------
// イベントの重複の対処
//----------
function isEventProcessed(eventId, eventTime) {
  const cache = CacheService.getScriptCache();
  const key = `processed_event_${eventId}`;

  // イベントが既に処理済みか確認
  if (cache.get(key)) {
    console.log(`重複イベント検出: ${eventId}`);
    return true;
  }

  // 古すぎるイベントはスキップ（3分以上前のイベント）
  const currentTime = Math.floor(Date.now() / 1000);
  if (currentTime - eventTime > 180) {
    console.log(`古いイベントをスキップ: ${eventId}`);
    return true;
  }

  // イベントを処理済みとしてマーク（10分間保持）
  cache.put(key, 'true', 600);
  return false;
}

//----------
// Difyの統合
//----------
function callDifyAPI(userMessage, slackUserId) {
  const apiKey = PropertiesService.getScriptProperties().getProperty('DIFY_API_KEY');
  if (!apiKey) {
    throw new Error('Dify APIキーがスクリプトプロパティに設定されていません');
  }

  const options = {
    method: 'post',
    headers: {
      Authorization: `Bearer ${apiKey}`,
      'Content-Type': 'application/json'
    },
    payload: JSON.stringify({
      inputs: {},
      query: userMessage,
      user: slackUserId,
      response_mode: 'blocking',
      conversation_id: null
    }),
    muteHttpExceptions: true
  };

  try {
    const response = UrlFetchApp.fetch(DIFY_API_ENDPOINT, options);
    const responseData = JSON.parse(response.getContentText());

    if (response.getResponseCode() !== 200) {
      console.error('Dify APIエラー:', responseData);
      throw new Error(`Dify APIからエラーが返されました: ${response.getResponseCode()}`);
    }

    return responseData.answer;
  } catch (error) {
    console.error('Dify API呼び出しエラー:', error);
    throw error;
  }
}

//----------
// イベントハンドラー
//----------
function doPost(e) {
  try {
    console.log('受信したイベント:', e.postData.contents);
    const data = JSON.parse(e.postData.contents);

    // URL検証リクエストへの対応
    if (data.type === 'url_verification') {
      return ContentService.createTextOutput(data.challenge);
    }

    // イベントの処理
    if (data.event && data.event_id) {
      if (isEventProcessed(data.event_id, data.event_time)) {
        return ContentService.createTextOutput('duplicate');
      }

      console.log('イベントタイプ:', data.event.type);

      switch (data.event.type) {
        case 'app_mention':
          handleMention(data.event);
          break;
        case 'message':
          if (data.event.channel_type === 'im') {
            handleDirectMessage(data.event);
          }
          break;
      }
    }

    return ContentService.createTextOutput('ok');
  } catch (error) {
    console.error('doPostでエラーが発生:', error);
    return ContentService.createTextOutput('error');
  }
}

function handleMention(event) {
  try {
    if (event.bot_id || event.subtype === 'bot_message') {
      return;
    }

    const userMessage = event.text.replace(/<@[A-Z0-9]+>/g, '').trim();
    const difyResponse = callDifyAPI(userMessage, event.user);

    const message = {
      channel: event.channel,
      text: difyResponse,
      thread_ts: event.thread_ts || event.ts
    };

    sendSlackMessage(message);
    console.log('メンションに応答しました (Dify統合)');
  } catch (error) {
    console.error('メンション処理でエラーが発生:', error);
    const errorMessage = {
      channel: event.channel,
      text: "申し訳ありません。現在応答に問題が発生しています。しばらく経ってから再度お試しください。",
      thread_ts: event.thread_ts || event.ts
    };
    sendSlackMessage(errorMessage);
  }
}

function handleDirectMessage(event) {
  try {
    if (event.bot_id || event.subtype === 'bot_message') {
      return;
    }

    const difyResponse = callDifyAPI(event.text, event.user);

    const message = {
      channel: event.channel,
      text: difyResponse,
      thread_ts: event.thread_ts || event.ts
    };

    sendSlackMessage(message);
    console.log('ダイレクトメッセージに応答しました (Dify統合)');
  } catch (error) {
    console.error('DM処理でエラーが発生:', error);
    const errorMessage = {
      channel: event.channel,
      text: "申し訳ありません。現在応答に問題が発生しています。しばらく経ってから再度お試しください。",
      thread_ts: event.thread_ts || event.ts
    };
    sendSlackMessage(errorMessage);
  }
}

function sendSlackMessage(message) {
  const token = PropertiesService.getScriptProperties().getProperty('SLACK_BOT_TOKEN');
  const options = {
    method: 'post',
    headers: {
      Authorization: `Bearer ${token}`,
      'Content-Type': 'application/json'
    },
    payload: JSON.stringify(message),
    muteHttpExceptions: true
  };

  try {
    const response = UrlFetchApp.fetch(`${SLACK_API_BASE}/chat.postMessage`, options);
    const responseData = JSON.parse(response.getContentText());
    console.log('メッセージ送信結果:', JSON.stringify(responseData));

    if (!responseData.ok) {
      throw new Error(`Slack APIエラー: ${responseData.error}`);
    }
  } catch (error) {
    console.error('メッセージ送信でエラーが発生:', error);
    throw error;
  }
}

{
“display_information”: {
“name”: “Slack App上で表示される名前”,
“description”: “Slack App上で表示される説明”,
“background_color”: “#000000”
},
“features”: {
“bot_user”: {
“display_name”: “Slackで表示されるアプリ名”,
“always_online”: true
},
“app_home”: {
“home_tab_enabled”: true,
“messages_tab_enabled”: true,
“messages_tab_read_only_enabled”: false
}
},
“oauth_config”: {
“scopes”: {
“bot”: [
“app_mentions:read”,
“channels:history”,
“channels:read”,
“chat:write”,
“im:history”,
“im:read”,
“im:write”,
“reactions:read”,
“reactions:write”,
“team:read”,
“users:read”,
“users:read.email”,
“channels:join”
]
}
},
“settings”: {
“event_subscriptions”: {
“request_url”: “YOUR_GAS_WEBAPP_URL”,
“bot_events”: [
“app_mention”,
“message.channels”,
“message.im”,
“reaction_added”,
“reaction_removed”
]
},
“interactivity”: {
“is_enabled”: true,
“request_url”: “YOUR_GAS_WEBAPP_URL”
},
“org_deploy_enabled”: false,
“socket_mode_enabled”: false,
“token_rotation_enabled”: false
}
}