app.js

var express = require('express');
var app = express();
var bodyParser = require('body-parser');
var request = require('request');
var crypto = require("crypto");
var async = require('async');

var sendMessage = require('./lib/sendMessage.js');
var messageTemplate = require('./lib/messageTemplate.js');
// var gnavi = require('./lib/gnavi.js'); // ぐるなびAPIを使うときに必要
// var googleapi = require('./lib/googleMapAPI.js'); // GoogleMapAPIを使うときに必要
// var weather_api = require('./lib/openWeatherMap.js'); // 天気APIを使う時に必要

// utilモジュールを使います。
var util = require('util');

app.set('port', (process.env.PORT || 8000));
// JSONの送信を許可
app.use(bodyParser.urlencoded({
  extended: true
}));
// JSONパーサー
app.use(bodyParser.json());

// herokuのTOPページに表示されるコンテンツを指定する
app.get('/', function(req, res) {
  res.send('<h1>hello world</h1>');
});

// async.waterfall([function(){}], function(){})
app.post('/callback', function(req, res) {
  async.waterfall([
      function(callback) {

        // リクエストがLINE Platformから送られてきたか確認する
        if (!validate_signature(req.headers['x-line-signature'], req.body)) {
          return;
        }

        // テキストか画像が送られてきた場合のみ返事をする
        if (!isValidDataType(req)) {
          return;
        }

        // 特定の単語に反応させたい場合
        // var textData = req.body['events'][0]['message']['text'];
        //if (textData.indexOf('please input some word') == -1) {
        //    return;
        //}

        // ユーザIDを取得する
        var eventData = req.body['events'][0];
        var user_id = eventData['source']['userId'];
        var message_id = eventData['message']['id'];
        // 'text', 'image' ...
        var message_type = eventData['message']['type'];
        var message_text = eventData['message']['text'];
        if (eventData['source']['type'] == 'user') {
          // ユーザー情報取得
          request.get(getProfileOption(user_id), function(error, response, body) {
            if (!error && response.statusCode == 200) {
              callback(req, body['displayName'], message_id, message_type, message_text);
            }
          });
        }
      },
    ],

    function(req, displayName, message_id, message_type, message_text) {

      var message = "hello, " + displayName + "さん"; // helloと返事する
      //var message = message_text; // おうむ返しする
      //var message = message_text + "[" + message_text.length + "文字]";
      sendMessage.send(req, [messageTemplate.textMessage(message)]);

      ///////////////////
      // 画像で返事をする //
      ///////////////////
      /*
      var messages = ["左上を押した", "右上を押した", "左下を押した", "右下を押した"];
      if (message_text == "猫") {
         sendMessage.send(req, [ messageTemplate.imagemapMessage(messages, 'https://i.imgur.com/8cbL5dl.jpg') ]);
         return;
      } else if (message_text == "犬") {
         sendMessage.send(req, [ messageTemplate.imagemapMessage(messages, 'https://i.imgur.com/ph82KWH.jpg') ]);
         return;
      } else if (message_text == "鹿") {
         sendMessage.send(req, [ messageTemplate.imagemapMessage(messages, 'https://i.imgur.com/Z6ilhSI.jpg') ]);
         return;
      }
      */
      ///////////////////
      // 画像で返事をする //
      ///////////////////

      //////////////////
      // 天気APIパート //
      /////////////////
      /*
      // 天気ときたら東京の天気が返ってくる
      // APIキーの設定と、ライブラリの読み込みが必要
      if (message_text === "天気") {
        weather_api.weather(function (result) {
          sendMessage.send(req, [ messageTemplate.textMessage(result) ]);
          return;
        });
      // 天気　半角スペース　地名（ローマ字のみ　例：tokyo）でそこの天気が返ってくる
      } else if (message_text.includes('天気')) {
        const words = message_text.split(' ')
        weather_api.weatherWithPlace(words[1], function (result) {
          sendMessage.send(req, [ messageTemplate.textMessage(result) ]);
          return;
        });
      } else {
        sendMessage.send(req, [ messageTemplate.textMessage(message) ]);
        return;
      }
      */

      ////////////////////
      // ぐるなびAPIパート //
      ////////////////////
      // 住所 改行 キーワード
      // のフォーマットでメッセージを送ってください
      // gnavi.api(req.body, message_text, function(result) {
      //   var text = result['name'] + "\n" + result['address'];
      //   sendMessage.send(req, [
      //     messageTemplate.textMessage(text),
      //     messageTemplate.imageMessage(result['shop_image1'], result['shop_image1'])
      //   ]);
      //   return;
      // });

      ///////////////////////
      // GoogleMapAPIパート //
      ///////////////////////
      /*
      googleapi.api(function(result) {
        var text = "成功";
        sendMessage.send(req, [
          messageTemplate.textMessage(text)
          //messageTemplate.imageMessage(result['shop_image1'], result['shop_image1'])
        ]);
        return;
      });
      */

      ///////////////////////
      // pushメッセージのパート //
      ///////////////////////
      //sendMessage.send(req, [messageTemplate.pushMessage("タイトル", "説明")]);

      return;
    }
  );
});

app.listen(app.get('port'), function() {
  console.log('Node app is running');
});

// 送られてきたメッセージタイプをbotの内容に合わせる
// 一致すればtrueを返す
function isValidDataType(req) {
  var eventType = req.body['events'][0];
  var messageType = eventType['message']['type'];

  if (eventType['type'] != 'message') {
    return false; // メッセージではない
  }
  if (messageType != 'text' && messageType != 'image') {
    return false; // テキストでも画像でもない
  }
  return true;
}

function getProfileOption(user_id) {
  return {
    url: 'https://api.line.me/v2/bot/profile/' + user_id,
    proxy: process.env.FIXIE_URL,
    json: true,
    headers: {
      'Authorization': 'Bearer {' + process.env.LINE_CHANNEL_ACCESS_TOKEN + '}'
    }
  };
}

// 署名検証
function validate_signature(signature, body) {
  return signature == crypto.createHmac('sha256', process.env.LINE_CHANNEL_SECRET).update(new Buffer(JSON.stringify(body), 'utf8')).digest('base64');
}