いまさらGASでLineBotを作る【Drive画像保存・キュー処理】

// LINE developersのメッセージ送受信設定に記載のアクセストークン
const LINE_TOKEN = PropertiesService.getScriptProperties().getProperty("LINE_TOKEN"); // Messaging API設定の一番下で発行できるLINE Botのアクセストークン
const FOLDER_ID = PropertiesService.getScriptProperties().getProperty("FOLDER_ID");
const LINE_URL = '<https://api.line.me/v2/bot/message/reply>';

//ユーザーがメッセージを送信した時に下記を実行する
function doPost(e) {

  const json = JSON.parse(e.postData.contents);

  //replyToken…イベントへの応答に使用するトークン(Messaging APIリファレンス)
  // <https://developers.line.biz/ja/reference/messaging-api/#message-event>
  const reply_token = json.events[0].replyToken;
  const messageId = json.events[0].message.id;
  const messageType = json.events[0].message.type;
  const messageText = json.events[0].message.text;

  // 検証で200を返すための取り組み
  if (typeof reply_token === 'underfined') {
    return;
  }

  switch (messageType) {
    case "text":
      return;
    case "image":
      // 受け取った情報がimageの場合は、保存用にジョブを保存しておく
      const job = {
        "reply_token": reply_token,
        "messageId": messageId
      }
      setJobData(job)
      return
    case "sticker":
			// 一分後にstartJobを実行するTriggerの作成
      const triggers = ScriptApp.getProjectTriggers()
      let jobTriggerFlag = true;
      triggers.forEach((trigger) => {
        if (trigger.getHandlerFunction() == "startJob") jobTriggerFlag = false
      })
      if (jobTriggerFlag) ScriptApp.newTrigger("startJob").timeBased().after(1000).create();
      return
    default:
      // 受け取った情報がimage以外の場合、通知を行う
      const message = "今回のBOTは写真を保存するためだけです。別のBOTはまた用意します。";
      // request fetch all 要のプロパティ
      const request = createRequestForTextMessage(message, reply_token)
      UrlFetchApp.fetchAll([request])
      return;
  }

}
const createRequestForTextMessage = (message, reply_token) => {
  return {
    "url": LINE_URL,
    'headers': {
      'Content-Type': 'application/json; charset=UTF-8',
      'Authorization': 'Bearer ' + LINE_TOKEN,
    },
    'method': 'post',
    'payload': JSON.stringify({
      'replyToken': reply_token,
      'messages': [{
        'type': 'text',
        'text': message,
      }],
    }),
  }
}

// キュー処理の保存
const setJobData = (job) => {
  const cache = CacheService.getScriptCache();
  const uid = getUuid()
  const jobList = JSON.parse(cache.get("jobList"))
  const newJobList = jobList ? [...jobList, uid] : [uid]
  cache.put("jobList", JSON.stringify(newJobList))
  cache.put(uid, JSON.stringify(job))
}

const getUuid = () => {
  return Utilities.getUuid()
}

const startJob = () => {
	// キャッシュを取得する
  const cache = CacheService.getScriptCache();
  const triggers = ScriptApp.getProjectTriggers()
  for (const trigger of triggers) {
    if (trigger.getHandlerFunction() == "startJob") {
      ScriptApp.deleteTrigger(trigger)
    }
  }
  const jobList = JSON.parse(cache.get("jobList"))
  if (jobList) {
    const replyTokenList = []
		// 画像取得用request生成
    const requests = jobList.map((value) => {
      const job = JSON.parse(cache.get(value));
      const messageId = job.messageId;
      replyTokenList.push(job.reply_token)
      return {
        "url": "<https://api-data.line.me/v2/bot/message/>" + messageId + "/content",
        'headers': {
          'Content-Type': 'application/json; charset=UTF-8',
          'Authorization': 'Bearer ' + LINE_TOKEN,
        },
        'method': 'get',
      }
    })
		// 画像取得
    const imageList = UrlFetchApp.fetchAll(requests)
    const imageBlobs = imageList.map((value) => value.getBlob().getAs("image/png").setName("LINE画像_" + getUuid() + ".png"))

		// 画像保存
    try {
      const folder = DriveApp.getFolderById(FOLDER_ID)
      const replayRequests = imageBlobs.map((value) => {
        folder.createFile(value);
        const replyToken = replyTokenList[0]
        replyTokenList.shift()
        return createRequestForTextMessage(`${value.getName()}で保存しました`, replyToken)
      })
      UrlFetchApp.fetchAll(replayRequests)
    } catch (e) {
      UrlFetchApp.fetchAll([createRequestForTextMessage("何かしらの問題が発生しました。頑張ってデバックしてくれ" + JSON.stringify(e), replyTokenList[0])])
      Logger.log(e)
    }
		// キャッシュの開放
    cache.removeAll(jobList)
    cache.remove("jobList")
  }