LINE公式アカウントの応答モードをチャットモードで行ったトーク履歴を、kintoneへ登録したい

Question

普段は見る専門だったのですが、この度初めてteratailへ質問させていただきます。
不足分等ありましたらご指摘いただけたら幸いです。
何卒よろしくお願いいたします。

前提・実現したいこと

LINE公式アカウントと友達ユーザーとのトーク履歴をFirebaseで取得し、
kintoneに保存するプログラムを作っています。

＜システムフロー＞
0. 企業のLINE公式アカウントで友達とトークのやり取り
0. LINEMessagingAPIのWebhookを使用してトークをトリガーとしてFirebaseにデータを渡す
0. FirebaseのfunctionでLINEのJSONデータを取得
0. kintoneに登録するためのJSONデータを生成し、kintoneへPOST

発生している問題

LINEの仕様で、2の際、応答モードがbotモードでないとWebhookを使用できない仕様ということが
わかりました。。
そのため、企業アカウントとユーザーとの直接やり取り（応答モード：チャットモード）でのやり取りが
Firebaseで取得できません。

Webhookイベントは、ユーザーがボットとやり取りするとトリガーされます。

https://developers.line.biz/ja/glossary/#webhook-url

（※取り急ぎbotモードでは取得に成功したため既存ソースとして展開いたします。）

知りたいこと

今回は上記のようなフローで実装しておりましたが、先述の問題が発生したことにより、回避策を考えております。
何か別の方法を経由、もしくは抜本的に別の方法を用いて実装などによってLINEのトーク履歴を取得する方法を探しているのですが、
どうしても分からないため質問させていただきます。

試したこと

まずbotモードで正常にkintoneへPOSTできるか実装致しました。（下記のソースになります）
こちらの方法は成功しております。
kintone側への登録画面も添付いたします。

既存のソースコード

'use strict';

const functions = require('firebase-functions');
const express = require('express');
const line = require('@line/bot-sdk');
const kintoneRec = require('request');
const moment = require('moment');

const app = express();

/************************************************************
 * LINE設定情報
 ***********************************************************/
const lineToken = '{xxxxxxxxxxxxxxx}';
const config = {
  channelSecret: '{xxxxxxxxxxxxxxx}',
  channelAccessToken: lineToken,
};

/************************************************************
 * kintone共通設定情報
 ***********************************************************/
const subDomain = 'ss-kintone-dev';
const oneRecordUrl = 'https://' + subDomain + '.cybozu.com/k/v1/record.json';
const someRecordsUrl = 'https://' + subDomain + '.cybozu.com/k/v1/records.json';
const kintoneAPPid = '{xxxxxxxxxxxxxxx}';
const kintoneAPPToken = '{xxxxxxxxxxxxxxx}';

/************************************************************
 * ここから処理スタート
 ***********************************************************/
app.post('/webhook', line.middleware(config), (req, res) => {

  //req.body.eventsのJSONデータは配列形式で返ってくる仕様になっている→[{・・・}]
  //LINEから取得したJSONデータ
  let contents = req.body.events[0];

  const LineNowDate = getNowDate();
  const LinelastUpdate = convIsoDate();
  const LineUserId = contents.source.userId;
  const LineMessageId = contents.message.id;
  const LineMessageText = LineNowDate + '\n' + contents.message.text + '\n-----------\n';

  /************************************************************
   * 現在時刻を取得（※LINEのtimestampを使用しようとすると変な文字列を取得してしまうため現在時刻で対応）
   ************************************************************/
  function getNowDate() {
    const mom = moment();
    let jpDate = mom.add(+9, 'h'); //海外時間となるため9時間加算
    return jpDate.format('YYYY年MM月DD日 HH:mm');
  }
  /************************************************************ 
   * 現時刻日時をkintone登録用にISO8601形式へ変換
   ************************************************************/
  function convIsoDate() {
    let now = new Date();
    return now.toISOString();
  }

  /************************************************************
   * ここからkintone側への処理
   * 
   ************************************************************/

  //POST用：kintoneのJSON形式に当てはめる
  var bodyPost = {
    'app': kintoneAPPid,
    'record': {
      'userID': {
        'value': LineUserId,
      },
      'lastUpdate': {
        'value': LinelastUpdate,
      },
      'talkHistory': {
        'value': LineMessageText,
      },
    },
  };

  // GET送信のクエリ設定
  // （query設定の書式 => url + '?app=' + アプリID + '&query（条件）=' + ('{fieldCode} in ("' +  {value} + '") ）
  let query = ('userID in ("' + LineUserId + '")');

  // URL設定
  let url = someRecordsUrl + '?app=' + kintoneAPPid + '&query=' + query;

  // GETリクエスト送信
  let LinePromise = sendGetKintone(url, kintoneAPPToken);
  console.log('GET成功');

  //dataはGETリクエスト送信して返ってきた値
  LinePromise.then(function (data) {
    // 返ってきた値のrecordsの数を取得
    let count = data['records'].length;

    // パラメータ指定して取得できたrecordの数が1以上の場合=>更新となる=>PUST送信
    if (count > 0) {
      /************************************************************
       * PUT用JSON生成：kintoneのJSON形式に当てはめる

       ************************************************************/

      // ※PUT送信した後のレスポンスデータのうち、LINEメッセージのみ抽出
      let oldLineMessage = data['records'][0]['talkHistory']['value'];

      var bodyPut = {
        'app': kintoneAPPid,
        'updateKey': {
          'field': 'userID',
          'value': LineUserId,
        },
        'record': {
          'lastUpdate': {
            'value': LinelastUpdate,
          },
          'talkHistory': {
            'value': LineMessageText + oldLineMessage,
          },
        },
      };

      console.log('PUT処理始めます');
      var kintonePutResponse = sendPutKintone(bodyPut, kintoneAPPToken);

      // パラメータ指定して取得できたrecordの数が0の場合=>データが無い=>新規登録=>POST送信
    } else {
      // POST送信した後のレスポンスデータ格納
      console.log('POST処理始めます');
      let kintoneResponse = sendPostKintone(bodyPost, kintoneAPPToken);
    }
  });
});

/************************************************************
* GET送信共通処理
* 戻り値はpromise型のJson
***********************************************************/
function sendGetKintone(url, token) {
  // 全件取得
  var params = {
    url: url,
    method: 'GET',
    json: true,
    headers: {
      'X-Cybozu-API-Token': token,
    },
  };
  // kintone連携
  return commonToKintone(params);
}

/************************************************************
* POST送信共通処理
* 戻り値はpromise型のJson
***********************************************************/
function sendPostKintone(sendObj, token) {
  // パラメータ設定
  var params = {
    url: oneRecordUrl,
    method: 'POST',
    json: true,
    headers: {
      'X-Cybozu-API-Token': token,
      'Content-Type': 'application/json',
    },
    body: sendObj,
  };

  // kintone連携
  return commonToKintone(params);
}

function sendPutKintone(sendObj, token) {
  // パラメータ設定
  var params = {
    url: oneRecordUrl,
    method: 'PUT',
    json: true,
    headers: {
      'X-Cybozu-API-Token': token,
      'Content-Type': 'application/json',
    },
    body: sendObj,
  };

  // kintone連携
  return commonToKintone(params);
}

/************************************************************
*  kintoneリクエスト(GET,POST,PUT)共通処理:パラメータを送るだけの処理
*  戻り値はPromise型のJson
*  paramsの中にはGET, POST, PUTのそれぞれのパラメータが入っている
***********************************************************/
function commonToKintone(params) {
  //Promiseを返す。HTTPリクエストした値を保持するため
  return new Promise(function (resolve) {
    // kintone連携
    kintoneRec(params, function callBack(err, resp, body) { //kintoneからGETしてきたデータがbodyに入っている
      if (err) { //kintoneへの接続自体ができなかった場合の処理
        console.log(err);
        return;
      }
      console.log(JSON.stringify(body));

      // ファンクションの戻り値
      resolve(JSON.parse(JSON.stringify(body)));
    });
  });
}

exports.app = functions.https.onRequest(app);

![
※kintone側に登録された様子

###補足（自分が調べて得た情報）
0. チャンネルトークという有料サービス使用
https://channel.io/ja/blog/line_to_channeltalk
→上記を使用すれば可能そうなのですが、今後の運用のことを考えますと自社で開発できたら良いなと思っております。。

0. グループトークへLINEbotを招待し、ユーザー同士のトークからWebhookを走らせサーバーでデータを取得
https://taupe.site/entry/line-messaging-api/
→目指したゴールには非常に近いのですが、あくまで今回はLINE公式アカウントとユーザーとの1対1のやり取りを保存したいため、
泣く泣く採用できませんでした。

0. LINEWORKS上のトーク履歴を取得しkintoneへ登録
https://developer.cybozu.io/hc/ja/articles/360000783023

→仕様としては、まさに得たいゴールだったのですが、LINEWORKSというサービスのみ違い、
泣く泣く採用できませんでした。。

###利用環境
0. VScode
0. Node.js　6.14.7
0. Windows10

以上となります。
お分かりいただける方、お知恵を拝借できたら幸いです。
何卒よろしくお願いいたします。m(_ _)m

Answer 1

私も同様の問題のため、公式のチャット管理画面のような画面を自作して対応するようにいたしました。
他にも複数社、自前で管理画面を作っている会社を知っているので、面倒ですが管理画面を自作してしまうのが現実的な解になるかと思います。

ただ履歴を保存したいというだけなら、公式管理画面をスクレイピングしてしまうのもありかもしれません。

Comments

[okayuki1029]

＞Arahabica様

ご返事が遅くなり申し訳ありません。
また、ご回答ありがとうございました。
おっしゃる通り、専用の画面を作ることが現実的ですよね…。
当方も、あの後も様々な方法を試したのですが、やはりできませんでしたので、そのとおりかと思います。

>公式管理画面をスクレイピングしてしまうのもあり

なるほど…、おっしゃる通り、それも手ですね。ありがとうございます。
ただ、社内と当方自身がPythonのスキルがないことと納期の関係から少々難しいという判断に至ってしまいました。。
ご意見ありがとうございました。大変勉強になりました。