Googleミートの自動共有【Chatwork】

/**

* Google Meet録画＋GeminiメモをDriveへ保存し、保存済みファイルをChatworkへ通知。

*/

function saveMeetAttachmentsIncremental() {

 const CHATWORK_API_TOKEN = '*****'; // 修正① ChatworkのAPIトークンを入れてください

 const CHATWORK_ROOM_ID = '*****'; // 修正② Chatworkの通知先グループのIDを入れてください

 const DRIVE_FOLDER_ID = '*****'; // 修正③ データ保管先のGoogle DriveのIDを入れてください

 const THREAD_FETCH_LIMIT = 20; // 一度に取得するメールスレッドの最大件数

 const props = PropertiesService.getScriptProperties();

 const now = new Date();

 let success = false;

 try {

   const activeUser = Session.getActiveUser().getEmail();

   Logger.log(`Gmail受信トレイの確認を開始します。: ${activeUser}`);

   const query = buildQuery(props.getProperty('lastCheckTime'), now);

   Logger.log(`検索クエリ: ${query}`);

   const folder = DriveApp.getFolderById(DRIVE_FOLDER_ID);

   const threads = GmailApp.search(query, 0, THREAD_FETCH_LIMIT);

   Logger.log(`対象スレッド数: ${threads.length}`);

   threads.forEach(thread => {

  thread.getMessages().forEach(message => {

    Logger.log(`メール処理を開始します。: ${message.getSubject()} (ID: ${message.getId()})`);

    const savedFileNames = saveDriveFilesFromMessage(message, folder);

    if (savedFileNames.length > 0) {

      const folderUrl = `https://drive.google.com/drive/u/0/folders/${DRIVE_FOLDER_ID}`;

      notifyChatwork(CHATWORK_API_TOKEN, CHATWORK_ROOM_ID, savedFileNames, folderUrl);

    }

  });

   });

   success = true;

 } catch (e) {

   Logger.log(`処理中にエラー発生: ${e && e.stack || e}`);

 } finally {

   if (success) {

  props.setProperty('lastCheckTime', now.toISOString());

  Logger.log(`最終チェック時刻を保存: ${now.toISOString()}`);

   } else {

  Logger.log('処理中にエラーが発生したため、最終チェック時刻は保存されませんでした');

   }

   createDailyFixedTriggers();

   Logger.log('翌日分のトリガーを再作成しました。');

 }

}

/**

* スクリプトプロパティに保存している最終チェック時刻を削除し、次回実行を初回扱いに戻す。

* テスト時に使用します。

*/

function resetLastCheckTime() {

 PropertiesService.getScriptProperties().deleteProperty('lastCheckTime');

 Logger.log('lastCheckTime をリセットしました。次回実行時は初回扱いになります。');

}

/**

* 指定した時刻（9:00 / 12:00 / 15:00）のトリガーを作成し、毎日実行されるように設定。

* トリガー作成成功後、既存のトリガーがある場合は、既存を削除

*/

function createDailyFixedTriggers() {

 const functionName = 'saveMeetAttachmentsIncremental';

 const now = new Date();

 const times = [

   { hour: 9, minute: 0 },

   { hour: 12, minute: 0 },

   { hour: 15, minute: 0 }

 ];

 const created = [];

 try {

   // ① 新トリガーを全て作成

   times.forEach(({ hour, minute }) => {

  const triggerTime = nextTriggerTime(now, hour, minute);

  const trigger = ScriptApp.newTrigger(functionName)

    .timeBased()

    .at(triggerTime)

    .create();

  created.push(trigger);

  Logger.log(`新トリガー作成成功: JST ${hour}:${minute.toString().padStart(2, '0')}`);

   });

   // ② すべて成功したら既存トリガー削除

   ScriptApp.getProjectTriggers()

  .filter(trigger => trigger.getHandlerFunction() === functionName)

  .forEach(trigger => {

    const isNew = created.some(newTrigger => newTrigger.getUniqueId() === trigger.getUniqueId());

    if (isNew) return;

    try {

      ScriptApp.deleteTrigger(trigger);

      Logger.log(`既存トリガー削除成功: ${trigger.getUniqueId()}`);

    } catch (e) {

      Logger.log(`既存トリガー削除失敗: (${trigger.getUniqueId()}): ${e.message}`);

    }

  });

 } catch (e) {

   Logger.log(`トリガー作成中にエラー: ${e}`);

   // ③ 作成途中でエラー発生 → 新規作成分を削除（差し戻し）

   created.forEach(trigger => {

  try {

    ScriptApp.deleteTrigger(trigger);

    Logger.log(`差し戻し: 作成済みトリガーを削除 (${trigger.getUniqueId()})`);

  } catch (e) {

    Logger.log(`差し戻し失敗 (${trigger.getUniqueId()}): ${e.message}`);

  }

   });

   throw e;

 }

}

/**

* Chatwork APIを呼び出してメッセージを送信する。

*

* @param {string} apiToken ChatworkAPIトークン

* @param {string|number} roomId 通知先ルームID

* @param {string} message 通知内容

*/

function sendChatworkNotification(apiToken, roomId, message) {

 const chatworkUrl = `https://api.chatwork.com/v2/rooms/${roomId}/messages`;

 const options = {

   method: 'post',

   headers: { 'X-ChatWorkToken': apiToken },

   payload: { body: message },

   muteHttpExceptions: true

 };

 try {

   const response = UrlFetchApp.fetch(chatworkUrl, options);

   const status = response.getResponseCode();

   if (status === 200 || status === 201) {

  Logger.log('Chatwork通知に成功しました。');

   } else {

  Logger.log(`Chatwork通知に失敗: ステータスコード ${status}`);

   }

 } catch (error) {

   Logger.log(`Chatwork通知中にエラー: ${error}`);

 }

}

/**

* 指定したGmailメッセージ内のDrive/Docsリンクからファイルを保存し、保存したファイル名一覧を返す。

*

* @param {GoogleAppsScript.Gmail.GmailMessage} message 処理対象のメールメッセージ

* @param {GoogleAppsScript.Drive.Folder} destinationFolder 保存先フォルダ

* @returns {string[]} 保存に成功したファイル名の配列。保存対象がなければ空配列を返す

*/

function saveDriveFilesFromMessage(message, destinationFolder) {

 const fileIds = extractDriveFileIds(message.getBody());

 if (fileIds.size === 0) {

   Logger.log('Drive/Docsリンクが見つかりません。');

   return [];

 }

 const savedFileNames = [];

 fileIds.forEach(fileId => {

   try {

  const file = DriveApp.getFileById(fileId);

  const name = file.getName();

  const existing = destinationFolder.getFilesByName(name);

  if (existing.hasNext()) {

    Logger.log(`同名ファイルが存在するためスキップ: ${name}`);

    return;

  }

  file.makeCopy(name, destinationFolder);

  savedFileNames.push(name);

  Logger.log(`ファイルを保存(コピー)しました: ${name}`);

   } catch (e) {

  Logger.log(`ファイルID処理エラー (${fileId}): ${e.message}`);

   }

 });

 return savedFileNames;

}

/**

* 保存ファイルがある場合に送信する、Chatworkメッセージを組み立てて通知。

*

* @param {string} token ChatworkAPIトークン

* @param {string|number} roomId 通知先ルームID

* @param {string[]} savedFileNames 保存済みファイル名の一覧

* @param {string} folderUrl 保存先フォルダのURL

*/

function notifyChatwork(token, roomId, savedFileNames, folderUrl) {

 const message = [

   '[info][title]顧客MTGデータ 保存完了[/title]顧客MTGの文字起こし、録画データを保存しました。',

   '',

   '保存データ：',

   savedFileNames.join('\n'),

   '',

   '保存先フォルダ：',

   folderUrl,

   '[/info]'

 ].join('\n');

 Logger.log(`Chatwork通知を送信します: Room ${roomId}`);

 sendChatworkNotification(token, roomId, message);

}

/**

* Gmail検索クエリを生成する。前回実行時刻が未保存であれば1日前以降を対象にする。

*

* @param {string|null} lastCheckTime 最終チェック日時。無ければ`null`

* @param {Date} now クエリ生成時の現在の日時

* @returns {string} Gmail検索APIに渡すクエリ文字列

*/

function buildQuery(lastCheckTime, now) {

 const base = 'subject:(【MTG】) from:(google.com) to:(me)';

 if (!lastCheckTime) {

   const oneDayAgo = Math.floor((now.getTime() - 24 * 60 * 60 * 1000) / 1000);

   return `${base} after:${oneDayAgo}`;

 }

 // overlapSec分引いて、処理中に受信したメールが次回実行時に対象となるようにする

 const lastTimestamp = Math.floor(new Date(lastCheckTime).getTime() / 1000);

 return `${base} after:${lastTimestamp}`;

}

/**

* メール本文からGoogle Drive/DocsリンクのファイルIDを抽出。

*

* @param {string} body Gmailメッセージ本文

* @returns {Set<string>} 抽出したファイルIDを格納したSet。メール本文内の重複は自動的に除外される。

*/

function extractDriveFileIds(body) {

 const driveRegex = /https:\/\/(?:drive\.google\.com\/file|docs\.google\.com\/document)\/d\/([a-zA-Z0-9_-]+)/g;

 const ids = new Set();

 let match;

 while ((match = driveRegex.exec(body)) !== null) {

   ids.add(match[1]);

 }

 return ids;

}

/**

* 指定の時刻が既に過ぎている場合は翌日に繰り上げたDateオブジェクトを返す。

*

* @param {Date} now 現在日時

* @param {number} hour 実行予定の時（24時間表記）

* @param {number} minute 実行予定の分

* @returns {Date} 次回の実行日時

*/

function nextTriggerTime(now, hour, minute) {

 const triggerTime = new Date(

   now.getFullYear(),

   now.getMonth(),

   now.getDate(),

   hour,

   minute

 );

 if (triggerTime < now) {

   triggerTime.setDate(triggerTime.getDate() + 1);

 }

 return triggerTime;

}