Gemini × GAS × Slackの社内RAG構築術

const CONFIG = {


 FILE_SEARCH_STORE_ID: 'your_store_name', //CreateStore.gs実行時の戻りメッセージに記載されます
  // ストアの名前
 STORE_DISPLAY_NAME: 'your_display_name',
  // 使用するAIモデル
 MODEL: 'models/gemini-2.5-flash',
  // 最大待機時間（60回×5秒=5分）
 OPERATION_POLL_MAX: 60,
 OPERATION_POLL_INTERVAL_MS: 5000,


 CHARACTER_INSTRUCTION: `あなたは社内ドキュメント検索アシスタントです。ユーザーの質問に対する回答を作成してください。


 # 制約事項
 1. 回答は300文字以内に要約すること。
 2. 情報元から取得した情報以外は使用しないこと（推測で回答しない）。
 3. 制約事項の内容は回答に*絶対*に含めないこと。
 4. 「優しさ」や「落ち着き」のあるキャラクターとして回答してください。`,
  FOOTER_MESSAGE: "\n\nこの回答で解決しない場合は、問い合わせフォームからお問い合わせください。"
};

function storeCreate() {
 const apiKey = getApiKey_();


 try {
   Logger.log('=== Create Storeの処理を開始します ===');
  
   // 2. File Search ストアを作成
   const store = createStore_(apiKey);
   Logger.log('✅ ストアを作成しました: ' + store.name);
  
   Logger.log('\n=== すべての処理が正常に完了しました ===');
   Logger.log('作成されたストア名: ' + store.name);
   Logger.log('このストア名を回答生成用のスクリプトで使用してください。');


 } catch (error) {
   Logger.log('❌ 致命的なエラーが発生しました: ' + error.message);
   // 詳細なスタックトレースが必要な場合は以下を有効にしてください
   // Logger.log(error.stack);
   throw error;
 }
}


// APIキーを取得
function getApiKey_() {
 const key = PropertiesService.getScriptProperties().getProperty('GEMINI_API_KEY');
 if (!key) {
   throw new Error('APIキーが設定されていません。プロジェクト設定で GEMINI_API_KEY を設定してください。');
 }
 return key.trim();
}


// ストアを作成
function createStore_(apiKey) {
 const url = 'https://generativelanguage.googleapis.com/v1beta/fileSearchStores?key=' + encodeURIComponent(apiKey);
 const payload = { displayName: CONFIG.STORE_DISPLAY_NAME };
  const response = UrlFetchApp.fetch(url, {
   method: 'post',
   contentType: 'application/json',
   payload: JSON.stringify(payload),
   muteHttpExceptions: true,
 });
  const code = response.getResponseCode();
 if (code < 200 || code >= 300) {
   throw new Error('ストア作成に失敗: ' + response.getContentText());
 }
  return JSON.parse(response.getContentText());
}

function storeUpdate() {
 storeUpdateFromFile(['']) 


// Drive IDは、URLの/d/と/editの間にある長い文字列です。
// docs.google.com/~~~/d/{ここ}/edit
}


function storeUpdateFromFile(fileId) {
 try {
   // 1) APIキーを取得
   const apiKey = getApiKey_();


   // 2) ファイルを指定
   const file = DriveApp.getFileById(fileId);
  
   // 3) ファイルをアップロード   
   try {
     const blob = file.getBlob();
     const storeName = `fileSearchStores/${CONFIG.FILE_SEARCH_STORE_ID}`
     const op = uploadToStore(apiKey, storeName, blob, file.getName(), file.getUrl());
    
     // 4) アップロード完了を待つ
     waitOperations(apiKey, [op.name]);
    
   } catch (error) {
     // Browser.msgBox(`  ❌ エラー: ${error}`);
     throw error;
   }
   // Browser.msgBox("更新処理が完了しました。")
  
 } catch (error) {
   // Browser.msgBox('❌ エラーが発生しました: ' + error);
   throw error;
 }
}


function getApiKey_() {
 const key = PropertiesService.getScriptProperties().getProperty('GEMINI_API_KEY');
 if (!key) {
   throw new Error('APIキーが設定されていません。プロジェクト設定で GEMINI_API_KEY を設定してください。');
 }
 return key.trim();
}


function uploadToStore(apiKey, storeName, blob, fileName, filelink) {
 const base = 'https://generativelanguage.googleapis.com/upload/v1beta/';
 const path = `${storeName}:uploadToFileSearchStore`;
  // 1. uploadTypeをmultipartに変更
 const url = `${base}${path}?uploadType=multipart&key=${encodeURIComponent(apiKey)}`;
  console.log(filelink)
 const boundary = "-------boundary_string";
 // 2. メタデータの作成 (JSON部分は camelCase である点に注意: stringValue)
 const metadata = {
   "displayName": `<${filelink} | ${fileName}>`,
   "customMetadata": [
     { "key": "filename", "string_value": fileName },
     { "key": "filelink", "string_value": filelink }
   ]
 };


 // 以降、前回のマルチパート構築処理にこの metadata を渡す
 const requestBody = Utilities.newBlob("").getBytes()
     .concat(Utilities.newBlob("--" + boundary + "\r\n").getBytes())
     .concat(Utilities.newBlob("Content-Type: application/json; charset=UTF-8\r\n\r\n").getBytes())
     .concat(Utilities.newBlob(JSON.stringify(metadata) + "\r\n").getBytes()) // ここで変換
     .concat(Utilities.newBlob("--" + boundary + "\r\n").getBytes())
     .concat(Utilities.newBlob("Content-Type: " + blob.getContentType() + "\r\n\r\n").getBytes())
     .concat(blob.getBytes())
     .concat(Utilities.newBlob("\r\n--" + boundary + "--\r\n").getBytes());


   const options = {
     method: 'post',
     contentType: 'multipart/related; boundary=' + boundary, // boundaryの指定が必須
     payload: requestBody,
     muteHttpExceptions: true
   };


   const response = UrlFetchApp.fetch(url, options);
  
   const code = response.getResponseCode();
   if (code < 200 || code >= 300) {
     throw new Error('アップロード失敗: ' + response.getContentText());
   }
  
   return JSON.parse(response.getContentText());
}


function waitOperations(apiKey, operationNames) {
 const base = 'https://generativelanguage.googleapis.com/v1beta/';
  for (const opName of operationNames) {
   for (let i = 0; i < CONFIG.OPERATION_POLL_MAX; i++) {
     const url = `${base}${opName}?key=${encodeURIComponent(apiKey)}`;
     const response = UrlFetchApp.fetch(url, {
       method: 'get',
       muteHttpExceptions: true,
     });
    
     const op = JSON.parse(response.getContentText());
     if (op.done) {
       if (op.error) {
         throw new Error('Operation error: ' + JSON.stringify(op.error));
       }
       break;
     }
    
     Utilities.sleep(CONFIG.OPERATION_POLL_INTERVAL_MS);
   }
 }
}

// Slack用プロパティ
const SLACK_PROPS = {
 BOT_MEMBER_ID: PropertiesService.getScriptProperties().getProperty("BOT_MEMBER_ID"),
 BOT_CHANNEL_ID: PropertiesService.getScriptProperties().getProperty("BOT_CHANNEL_ID"),
 BOT_AUTH_TOKEN: PropertiesService.getScriptProperties().getProperty("BOT_AUTH_TOKEN")
};


function doPost(e) {
 if (!e || !e.postData) return ContentService.createTextOutput("No Content");
  let params;
 try {
   params = JSON.parse(e.postData.getDataAsString());
 } catch (err) {
   return ContentService.createTextOutput("Invalid JSON");
 }


 if (params.type === "url_verification") return ContentService.createTextOutput(params.challenge);


 if (params.type === "event_callback") {
   const event = params.event;
  
   // 重複防止
   const cache = CacheService.getScriptCache();
   if (cache.get(params.event_id)) return ContentService.createTextOutput("OK");
   cache.put(params.event_id, "processed", 300);


   // Bot自身の発言はスルー
   if (event.user === SLACK_PROPS.BOT_MEMBER_ID) return ContentService.createTextOutput("OK");


   // メッセージ判定
   const msgs = fetchSlackMsgsAskedToBot(event);
   if (msgs.length > 0) {
     try {
       const queryText = trimMentionText(msgs[msgs.length - 1].text);
       console.log(queryText);
      
       // --- 共通関数の呼び出し ---
       const aiResult = askGeminiCommon(queryText);
      
       // 回答の整形（フッターとソースを追加）
       let fullResponse = aiResult.answerText + CONFIG.FOOTER_MESSAGE;
       if (aiResult.sources.length > 0) {
         fullResponse += "\n\n【参考ドキュメント】\n" + aiResult.sources.map(s => `• ${s}`).join("\n");
       }


       slackPostMessage(event.channel, fullResponse, {
         thread_ts: event.thread_ts || event.ts
       });
       console.log(fullResponse);


     } catch (err) {
       console.error(err);
       slackPostMessage(event.channel, "申し訳ありません。エラーが発生しました: " + err.message, {
         thread_ts: event.thread_ts || event.ts
       });
     }
   }
 }
 return ContentService.createTextOutput("OK");
}


// 補助関数群 (Slack API関連)
function fetchSlackMsgsAskedToBot(event) {
 const isDm = event.channel.startsWith("D");
 const isMentioned = event.text.includes(SLACK_PROPS.BOT_MEMBER_ID);
 const isTargetChannel = (SLACK_PROPS.BOT_CHANNEL_ID && event.channel === SLACK_PROPS.BOT_CHANNEL_ID);


 if (!event.thread_ts) {
   if (isDm || (isTargetChannel && isMentioned)) return [event];
   return [];
 } else {
   // スレッド内の処理
   const msgs = fetchMsgsInThread(event.channel, event.thread_ts);
   const isBotInvolved = msgs.some(m => m.user === SLACK_PROPS.BOT_MEMBER_ID);
   if (isDm || isBotInvolved || isMentioned) return msgs;
   return [];
 }
}


function fetchMsgsInThread(channelId, ts) {
 const url = `https://slack.com/api/conversations.replies?channel=${channelId}&ts=${ts}`;
 const response = UrlFetchApp.fetch(url, {
   headers: { Authorization: "Bearer " + SLACK_PROPS.BOT_AUTH_TOKEN }
 });
 return JSON.parse(response.getContentText()).messages;
}


function trimMentionText(text) {
 return text.replace(/^<@.+?>\s*/, "").trim();
}


function slackPostMessage(channel, text, option) {
 UrlFetchApp.fetch("https://slack.com/api/chat.postMessage", {
   method: "POST",
   headers: {
     "Content-Type": "application/json",
     Authorization: "Bearer " + SLACK_PROPS.BOT_AUTH_TOKEN,
   },
   payload: JSON.stringify({ channel, text, ...option })
 });
}


function askGeminiCommon(userQuery) {
 const apiKey = PropertiesService.getScriptProperties().getProperty('GEMINI_API_KEY');


 const url = `https://generativelanguage.googleapis.com/v1beta/${CONFIG.MODEL}:generateContent?key=${encodeURIComponent(apiKey)}`;
  const payload = {
   contents: [
     {
       role: 'user',
       parts: [{ text: CONFIG.CHARACTER_INSTRUCTION + "\n\n" + userQuery }]
     }
   ],
   tools: [{ fileSearch: { fileSearchStoreNames: `fileSearchStores/${CONFIG.FILE_SEARCH_STORE_ID}` } }],
 };
  const response = UrlFetchApp.fetch(url, {
   method: 'post',
   contentType: 'application/json',
   payload: JSON.stringify(payload),
   muteHttpExceptions: true,
 });


 const code = response.getResponseCode();
 const result = JSON.parse(response.getContentText());


 if (code < 200 || code >= 300) {
   throw new Error(`Gemini API Error (${code}): ${response.getContentText()}`);
 }
  if (!result.candidates || result.candidates.length === 0) {
   return { answerText: "該当する情報が見つかりませんでした。", sources: [] };
 }
  const candidate = result.candidates[0];
 let mainText = candidate.content?.parts?.[0]?.text || "AIからのテキスト応答が空でした。";


 // 参照ドキュメントの抽出
 let sources = [];
 if (candidate.groundingMetadata?.groundingChunks) {
   candidate.groundingMetadata.groundingChunks.forEach(chunk => {
     if (chunk.retrievedContext?.title) {
       sources.push(chunk.retrievedContext.title);
     }
   });
 }
 sources = [...new Set(sources)];


 return {
   answerText: mainText,
   sources: sources
 };
}