var express = require('express');
const request = require('request');
const TARGET_URL = 'https://api.line.me/v2/bot/message/reply'
const TOKEN = 'dRrig7gYkvGL/5LmEw7+bU7GTkASTlc83Uw3KKfHrGyGKKxwYcQGnZQ8XO/Azs/QQtzpsimowtvW7e6IfdMQfwXWliMfDhIQl8Frik4Smx7fuQxf3SIb8xy3lbjUeb16eKh+6dpuKsHR+eq52f43QgdB04t89/1O/w1cDnyilFU='
const fs = require('fs');
const path = require('path');
const HTTPS = require('https');
const domain = "2020105648.oss2021.tk"
const sslport = 23023;
const bodyParser = require('body-parser');
const axios = require('axios')
const cheerio = require('cheerio')
var app = express();
var cron = require('node-cron');
var stock_code = "005930"
app.use(bodyParser.json());

app.post('/hook', function (req, res) {

    var eventObj = req.body.events[0];
    var source = eventObj.source;
    var message = eventObj.message; 


    let stockList = [];
    //import './stock_names.txt';

    fs.readFile('./stock_names.txt', 'utf8', (err,data) => { // 파일 import하고 stockList로 저장
        if (err){
            console.error(err)
            return
        }
        var tempstockList = data.toString().split("\n"); // ex) stockList = [[012312 ~~],[123012 ~~],[192312 ~~],[192310 ~~],[...]]
        for (x in tempstockList){
            var stockList = tempstockList[i].toString().split(" "); // ex) stockList = [[012312,~~],[1230012,~~],[1923,~~],[192310,~~],[...]]
        }
        // for (i in stockList) {
        //     console.log(stockList[i]);
        // }
    })

    // request log
    console.log('======================', new Date() ,'======================');
    console.log('[request]', req.body);
    console.log('[request source] ', eventObj.source);
    console.log('[request message]', eventObj.message);

    var s_code = get_stock_code(stockList,stock_code,eventObj.replyToken,eventObj.message.text);
    var wanted_price = get_wanted_price(eventObj.replyToken,eventObj.message.text);

    cron.schedule('*/5 * * * *', () => {
        compare(s_code, wanted_price);
    });



    // if (eventObj.message.text == "영어"){
    //     lan = "en"
    // }
    // else if (eventObj.message.text == "일본어"){
    //     lan = "ja"
    // }
    // else if (eventObj.message.text == "프랑스어"){
    //     lan = "fr"
    // }
    // else{
    //     trans(eventObj.replyToken, eventObj.message.text);
    // }    


    // request.post(
    //     {
    //         url: TARGET_URL,
    //         headers: {
    //             'Authorization': `Bearer ${TOKEN}`
    //         },
    //         json: {
    //             "replyToken":eventObj.replyToken,
    //             "messages":[
    //                 {
    //                     "type":"text",
    //                     "text":"Hello, user"
    //                 },
    //                 {
    //                     "type":"text",
    //                     "text":"May I help you?"
    //                 }
    //             ]
    //         }
    //     },(error, response, body) => {
    //         console.log(body)
    //     });
    

    res.sendStatus(200);
});

function get_stock_code(stockList,stock_code,replyToken,message){
    for (let i = 0; i<stockList.length; i++) {
        if (eventObj.message.text == stockList[i][1]){  // 입력한거 나오면 코드로 바꿔줌
            stock_code = stockList[i][0]
            return stock_code
        }
        else{                                           // stockList에 없으면 없다고 보냄
            request.post(
                {
                    url: TARGET_URL,
                    headers: {
                        'Authorization': `Bearer ${TOKEN}`
                    },
                    json: {
                        "replyToken":eventObj.replyToken,
                        "messages":[
                            {
                                "type":"text",
                                "text":"Not in list"
                            },
                        ]
                    }
                },(error, response, body) => {
                    console.log(body)
                });
        }

    }
}

function get_wanted_price(replyToken,message){
    if (message < 0){
        request.post(
            {
                url: TARGET_URL,
                headers: {
                    'Authorization': `Bearer ${TOKEN}`
                },
                json: {
                    "replyToken":eventObj.replyToken,
                    "messages":[
                        {
                            "type":"text",
                            "text":"Price must be positive number"
                        },
                    ]
                }
            },(error, response, body) => {
                console.log(body)
            });
    }

}

function compare(s_code, wanted_price){
    const temp = axios.get(`https://finance.naver.com/item/main.nhn?code=${s_code}%22`).then(
            res => {
                let urList = [];
                const $ = cheerio.load(res.data)
                const $bodyList = $("dl.blind").children("dd").text();
                const result = $bodyList.slice(73, 80)   // 실시간으로 변하는 주식 가격 scrape
                console.log(result)
            }
        )
    
    if (int(result) <= wanted_price){
        request.post(
            {
                url: TARGET_URL,
                headers: {
                    'Authorization': `Bearer ${TOKEN}`
                },
                json: {
                    "replyToken":eventObj.replyToken,
                    "messages":[
                        {
                            "type":"text",
                            "text":"Reached wanted price!"
                        },
                    ]
                }
            },(error, response, body) => {
                console.log(body)
            });
    }



    
}


try {
    const option = {
      ca: fs.readFileSync('/etc/letsencrypt/live/' + domain +'/fullchain.pem'),
      key: fs.readFileSync(path.resolve(process.cwd(), '/etc/letsencrypt/live/' + domain +'/privkey.pem'), 'utf8').toString(),
      cert: fs.readFileSync(path.resolve(process.cwd(), '/etc/letsencrypt/live/' + domain +'/cert.pem'), 'utf8').toString(),
    };
  
    HTTPS.createServer(option, app).listen(sslport, () => {
      console.log(`[HTTPS] Server is started on port ${sslport}`);
    });
  } catch (error) {
    console.log('[HTTPS] HTTPS 오류가 발생하였습니다. HTTPS 서버는 실행되지 않습니다.');
    console.log(error);
  }