LINE BOT開発 IGRスクレイピング編

npm i --save axios

'use strict'

const axios = require('axios');
const URL = `http://www.igr.jp/`;

axios.get(URL, {
    firstName: 'Fred',
    lastName: 'Flintstone'
  })
  .then((response) => {
    console.log(response.data);
  })
  .catch((error) => {
    console.log(error);
  });

node igr.js

'use strict'

const axios = require('axios');
const URL = `http://www.igr.jp/`;

axios.get(URL, {
    firstName: 'Fred',
    lastName: 'Flintstone'
  })
  .then((response) => {
    // console.log(response.data);
    let item = response.data;
    let status = item.match(/operatinginfo"><strong>(.*?)<\/strong>/)[1];
    console.log(status);
  })
  .catch((error) => {
    console.log(error);
  });

$ node igr.js
平常通り運行しております

'use strict';

const http = require('http');
const https = require('https');
const crypto = require('crypto');

const HOST = 'api.line.me'; 
const REPLY_PATH = '/v2/bot/message/reply';//リプライ用
const CH_SECRET = ''; //Channel Secretを指定
const CH_ACCESS_TOKEN = ''; //Channel Access Tokenを指定
const SIGNATURE = crypto.createHmac('sha256', CH_SECRET);
const PORT = 3000;

const axios = require('axios');
const URL = `http://www.igr.jp/`;

/**
 * httpリクエスト部分
 */
const client = (replyToken, SendMessageObject) => {    
    let postDataStr = JSON.stringify({ replyToken: replyToken, messages: SendMessageObject });
    let options = {
        host: HOST,
        port: 443,
        path: REPLY_PATH,
        method: 'POST',
        headers: {
            'Content-Type': 'application/json; charset=UTF-8',
            'X-Line-Signature': SIGNATURE,
            'Authorization': `Bearer ${CH_ACCESS_TOKEN}`,
            'Content-Length': Buffer.byteLength(postDataStr)
        }
    };

    return new Promise((resolve, reject) => {
        let req = https.request(options, (res) => {
                    let body = '';
                    res.setEncoding('utf8');
                    res.on('data', (chunk) => {
                        body += chunk;
                    });
                    res.on('end', () => {
                        resolve(body);
                    });
        });

        req.on('error', (e) => {
            reject(e);
        });
        req.write(postDataStr);
        req.end();
    });
};

http.createServer((req, res) => {    
    if(req.url !== '/' || req.method !== 'POST'){
        res.writeHead(200, {'Content-Type': 'text/plain;charset=utf-8'});
        res.end('こんにちは');
    }

    let body = '';
    req.on('data', (chunk) => {
        body += chunk;
    });        
    req.on('end', () => {
        if(body === ''){
          console.log('bodyが空です。');
          return;
        }

        let WebhookEventObject = JSON.parse(body).events[0];
        console.log(WebhookEventObject);        
        //メッセージが送られて来た場合
        if(WebhookEventObject.type === 'message'){
            let SendMessageObject;
            if(WebhookEventObject.message.type !== 'text')return;

                let status;
                axios.get(URL)
                .then((response) => {
                    // console.log(response.data);
                    let item = response.data;
                    status = item.match(/operatinginfo"><strong>(.*?)<\/strong>/)[1];
                    console.log(status);

                    SendMessageObject = [{
                        type: 'text',
                        text: status
                    }];

                    client(WebhookEventObject.replyToken, SendMessageObject)
                    .then((body)=>{
                        console.log(body);
                    },(e)=>{console.log(e)});

                });
        }

        res.writeHead(200, {'Content-Type': 'text/plain'});
        res.end('su');
    });

}).listen(PORT);

console.log(`Server running at ${PORT}`);