【LINE bot】記事にいいねをもらったら LINE に通知してささやかな喜びをつぶれるほど抱きしめる 🍒 #GoogleAppsScript

const QIITA_TOKEN =
  PropertiesService.getScriptProperties().getProperty("QIITA_TOKEN");
const QIITA_ARTICLES_SPREADSHEET_ID =
  PropertiesService.getScriptProperties().getProperty(
    "QIITA_ARTICLES_SPREADSHEET_ID"
  );
const LINE_CHANNEL_ACCESS_TOKEN =
  PropertiesService.getScriptProperties().getProperty(
    "LINE_CHANNEL_ACCESS_TOKEN"
  );
const LINE_USER_ID_SPREADSHEET_ID =
  PropertiesService.getScriptProperties().getProperty(
    "LINE_USER_ID_SPREADSHEET_ID"
  );

/**
 * Qiitaから記事一覧を取得する
 * @param {number} page 取得ページ番号
 * @param {number} perPage 1ページあたりの取得件数
 * @return {{ 'id': string, 'title': string, 'url': string, 'likes_count': number }[]} 記事一覧
 */
function getArticlesFromQiita(page, perPage) {
  // https://qiita.com/api/v2/docs#get-apiv2authenticated_useritems
  const response = UrlFetchApp.fetch(
    `https://qiita.com/api/v2/authenticated_user/items?page=${page}&per_page=${perPage}`,
    {
      method: "get",
      headers: {
        Authorization: `Bearer ${QIITA_TOKEN}`,
      },
    }
  );

  const body = JSON.parse(response.getContentText());
  const articles = body.map((item) => ({
    id: item["id"],
    title: item["title"],
    url: item["url"],
    likes_count: item["likes_count"],
  }));

  return articles;
}

/**
 * 記事IDから記事情報へのマッピングを取得する
 * @param {{ 'id': string, 'title': string, 'url': string, 'likes_count': number }[]} 記事一覧
 * @return {{ [articleId: string]: { 'title': string, 'url': string, 'likes_count': number }[] }} 記事IDから記事情報へのマッピング
 */
function getArticleId2Article(articles) {
  const articleId2Article = {};
  articles.forEach((article) => {
    const id = article["id"];
    articleId2Article[id] = {
      title: article["title"],
      url: article["url"],
      likes_count: article["likes_count"],
    };
  });

  return articleId2Article;
}

/**
 * スプレッドシートからデータを取得する
 * @param {Sheet} sheet スプレッドシート
 * @return {{ headers: string[], rows: (string | number)[][] }}
 */
function getDataFromSpreadsheet(sheet) {
  const startRow = 1;
  const startColumn = 1;
  const numRows = sheet.getLastRow();
  const numColumns = sheet.getLastColumn();
  // https://developers.google.com/apps-script/reference/spreadsheet/sheet?hl=ja#getRange(Integer,Integer,Integer,Integer)
  // https://developers.google.com/apps-script/reference/spreadsheet/range?hl=ja#getValues()
  const data = sheet
    .getRange(startRow, startColumn, numRows, numColumns)
    .getValues();

  const headers = data[0];
  const rows = data.length > 1 ? data.slice(1) : [];

  return { headers, rows };
}

/**
 * スプレッドシートのデータを更新する
 * @param {Sheet} sheet スプレッドシート
 * @param {(string | number)[][]} rows 行データ
 */
function updateDataToSpreadsheet(sheet, rows) {
  const startDataRow = 2;
  const startColumns = 1;
  const numDataRows = rows.length;
  const numColumns = sheet.getLastColumn();
  // https://developers.google.com/apps-script/reference/spreadsheet/range?hl=ja#setValues(Object)
  sheet
    .getRange(startDataRow, startColumns, numDataRows, numColumns)
    .setValues(rows);
}

/**
 * 記事IDからいいね件数へのマッピングを取得する
 * @param {(string | number)[][]} rows スプレッドシートの行データ
 * @return {{ [articleId: string]: number }} 記事IDからいいね件数へのマッピング
 */
function getArticleId2LikesCountFromSheetData(rows) {
  const articleId2LikesCount = {};
  rows.forEach((row) => {
    const [id, likesCount] = row;
    articleId2LikesCount[id] = likesCount;
  });

  return articleId2LikesCount;
}

/**
 * 記事IDからスプレッドシート上のインデックスを取得する
 * @param {(string | number)[][]} rows スプレッドシートの行データ
 * @param {string} targetArticleId 記事ID
 * @return {number} スプレッドシート上のインデックス
 */
function findRowIndexByArticleId(rows, targetArticleId) {
  const foundIndex = rows.findIndex((row) => row[0] === targetArticleId);
  return foundIndex === -1 ? null : foundIndex;
}

/**
 * 記事に新しくいいねがついたか判定する
 * @param {{ 'id': string, 'title': string, 'url': string, 'likes_count': number }[]} 記事一覧
 * @return {{ [articleId: string]: number }} 新しくいいねがついた記事IDからいいね件数の差分へのマッピング
 */
function checkIfArticlesGotNewLikes(articlesFromQiita) {
  // https://developers.google.com/apps-script/reference/spreadsheet/spreadsheet-app?hl=ja#openById(String)
  // https://developers.google.com/apps-script/reference/spreadsheet/spreadsheet?hl=ja#getSheets()
  const qiitaArticlesSheet = SpreadsheetApp.openById(
    QIITA_ARTICLES_SPREADSHEET_ID
  ).getSheets()[0];
  const { rows } = getDataFromSpreadsheet(qiitaArticlesSheet);
  const articleId2PrevLikesCount = getArticleId2LikesCountFromSheetData(rows);

  const articleId2LikesDelta = {};
  articlesFromQiita.forEach((currArticle) => {
    const id = currArticle["id"];
    const currLikesCount = currArticle["likes_count"];

    const prevLikesCount = articleId2PrevLikesCount[id];
    // 新しく追加された記事の場合、レコードを追加する
    if (prevLikesCount == null) {
      rows.push([id, currLikesCount]);
      // いいねが1件以上あった場合、新しくいいねがついたと判定する
      if (currLikesCount > 0) {
        articleId2LikesDelta[id] = currLikesCount;
      }
      return;
    }

    // 前回の判定からいいねが増えた場合、いいね件数を更新する
    if (currLikesCount > prevLikesCount) {
      const rowIndex = findRowIndexByArticleId(rows, id);
      if (rowIndex != null) {
        rows[rowIndex][1] = currLikesCount;
        articleId2LikesDelta[id] = currLikesCount - prevLikesCount;
      }
    }
  });

  // スプレッドシートを一括更新する
  updateDataToSpreadsheet(qiitaArticlesSheet, rows);

  return articleId2LikesDelta;
}

/**
 * Qiitaから記事IDに紐づく新しくついたいいね一覧を取得する
 * @param {string} 記事ID
 * @param {number} あたらしくついたいいね件数
 * @return {{ 'created_at': string, 'user_id': string, 'article_id': string }[]} 指定した記事IDの新しくついたいいね一覧
 */
function getLikesFromQiitaByArticleId(articleId, delta) {
  // https://qiita.com/api/v2/docs#get-apiv2itemsitem_idlikes
  const response = UrlFetchApp.fetch(
    `https://qiita.com/api/v2/items/${articleId}/likes`,
    {
      method: "get",
      headers: {
        Authorization: `Bearer ${QIITA_TOKEN}`,
      },
    }
  );

  const body = JSON.parse(response.getContentText());
  const likes = body.map((item) => ({
    created_at: item["created_at"],
    user_id: item["user"]["id"],
    article_id: articleId,
  }));

  return likes.slice(0, delta);
}

/**
 * すべての新しくついたいいね一覧を取得する
 * @param {{ [articleId: string]: number }} 新しくいいねがついた記事IDからいいね件数の差分へのマッピング
 * @return {{ 'created_at': string, 'user_id': string, 'article_id': string }[]} すべての新しくついたいいね一覧
 */
function getNewLikes(articleId2LikesDelta) {
  const newLikes = Object.entries(articleId2LikesDelta).flatMap(([id, delta]) =>
    getLikesFromQiitaByArticleId(id, delta)
  );

  const compareByCreatedAtDesc = (a, b) =>
    new Date(b["created_at"]) - new Date(a["created_at"]);
  const sortedNewLikes = newLikes.sort(compareByCreatedAtDesc);

  return sortedNewLikes;
}

/**
 * いいねメッセージを作成する
 * @param {{ 'created_at': string, 'user_id': string, 'article_id': string }[]} いいね一覧
 * @param {{ 'id': string, 'title': string, 'url': string, 'likes_count': number }[]} 記事一覧
 * @return {string[]} いいねメッセージ一覧
 */
function createLikeMessages(newLikes, articlesFromQiita) {
  const articleId2Article = getArticleId2Article(articlesFromQiita);

  const likeMessages = newLikes.map((like) => {
    const userId = like["user_id"];
    const articleId = like["article_id"];

    const article = articleId2Article[articleId];
    const articleTitle = article["title"];
    const articleUrl = article["url"];

    const createdAt = like["created_at"];
    const createdAtDate = new Date(createdAt);
    const timeZone = "Asia/Tokyo";
    // http://developers.google.com/apps-script/reference/utilities/utilities?hl=ja#formatDate(Date,String,String)
    const formattedCreatedAt = Utilities.formatDate(
      createdAtDate,
      timeZone,
      "yyyy/MM/dd HH:mm"
    );

    return `@${userId}があなたの記事${articleTitle}にいいねしました。\n${articleUrl}\n${formattedCreatedAt}`;
  });

  return likeMessages;
}

/**
 * LINEユーザーにいいねメッセージをプッシュ通知する
 * @param {string[]} いいねメッセージ一覧
 * @return {TextOutput} TextOutputオブジェクト
 */
function pushLikeMessagesToLineUsers(likeMessages) {
  // 新しくいいねがない場合、通知しない
  if (likeMessages.length === 0) {
    return ContentService.createTextOutput("No new likes");
  }

  const lineUserIdSheet = SpreadsheetApp.openById(
    LINE_USER_ID_SPREADSHEET_ID
  ).getSheets()[0];
  const { rows } = getDataFromSpreadsheet(lineUserIdSheet);
  if (rows.length === 0) {
    return ContentService.createTextOutput("Failed to find user id");
  }
  const userId = rows[0][0];

  // 同時に送信できるメッセージは最大5件
  const MAX_MESSAGE_COUNT = 5;
  const messages = likeMessages.slice(0, MAX_MESSAGE_COUNT).map((message) => ({
    type: "text",
    text: message,
  }));

  // https://developers.line.biz/ja/docs/messaging-api/sending-messages/#send-messages-at-any-time
  // https://developers.line.biz/ja/reference/messaging-api/#send-push-message
  const url = "https://api.line.me/v2/bot/message/push";
  const payload = {
    to: userId,
    messages,
  };
  const options = {
    method: "post",
    contentType: "application/json",
    headers: {
      Authorization: `Bearer ${LINE_CHANNEL_ACCESS_TOKEN}`,
    },
    payload: JSON.stringify(payload),
  };
  UrlFetchApp.fetch(url, options);

  // https://developers.google.com/apps-script/reference/content/content-service?hl=ja#createtextoutput
  return ContentService.createTextOutput("OK");
}

function main() {
  const page = 1;
  const perPage = 20;
  const articlesFromQiita = getArticlesFromQiita(page, perPage);

  const articleId2LikesDelta = checkIfArticlesGotNewLikes(articlesFromQiita);
  const newLikes = getNewLikes(articleId2LikesDelta);

  const likeMessages = createLikeMessages(newLikes, articlesFromQiita);
  return pushLikeMessagesToLineUsers(likeMessages);
}