var express = require('express');
const request = require('request');
const bodyParser = require('body-parser');
var app = express();
var static = require('serve-static');

const fs = require('fs');
const path = require('path');
const HTTPS = require('https');
const TARGET_URL = 'https://api.line.me/v2/bot/message/reply'
const TOKEN = 'sqNjA99TptppqvcoVFAnU7Kawsl+s7l+JgnZ7r2is97qrFQraIn0sLQ6mTsIPvXLG7FNK34rvjkXbgwuy0/bgrUn4J5eYPn4H/IH27MdimpiXo/yv+obIN9IKlqR+EF2gLmuXSxMU/LWzyGxCk1G0gdB04t89/1O/w1cDnyilFU='
//const PAPAGO_URL = 'https://openapi.naver.com/v1/papago/n2mt'
//const PAPAGO_ID = 'AH9WUFCtTrz9xnJ6dpxB'
//const PAPAGO_SECRET = 'um7UxSvbxD'

const domain = "www.chyoss.tk"
const sslport = 23023;

app.use(bodyParser.json());
//전역변수 선언
var isstart;
var isforecast = 0;
var jsonForforecast;
// body-parser를 이용해 application/x-www-form-urlencoded 파싱
app.use(bodyParser.urlencoded({ extended: false }))

// body-parser를 이용해 application/json 파싱
app.use(bodyParser.json())

// public 폴더를 static으로 오픈
app.use('/public', static(path.join(__dirname, 'public')));

var router = express.Router();
 
router.route('/process/maprealtime').get(function(req, res){
    console.log('process/mapreatime 호출됨');
    res.end();
});


router.route('/process/maprealtime').get(function(req, res){
    console.log('process/mapreatime 호출됨');
    res.end();
});

router.route('/process/construction').get(function(req, res){
    console.log('process/maprealconstruction 호출됨');
    res.end();
});

router.route('/process/mapcctv').get(function(req, res){
    console.log('process/mapcctv 호출됨');
    res.end();
});



function jsonforecast(callback){
    var url2 = 'http://data.ex.co.kr/openapi/safeDriving/forecast';
    var queryParams2  = '?' + encodeURIComponent('key') + '=4365330273'; /* Service Key*/
    queryParams2 += '&' + encodeURIComponent('type') + '=' + encodeURIComponent('json'); /* */
    var obj
    request(
        {
        url: url2 + queryParams2,
        method: 'GET'
    }, function (error, response, body) {
        console.log('Status', response.statusCode);
        console.log('Headers', JSON.stringify(response.headers));
        console.log('Reponse received', body);
        obj = JSON.parse(body);
        console.log(obj);
        callback(obj);
    });
   
};



app.use('/', router);


function ishello(istext){
    if (istext == '종료'){
        return false;
    }
    if(istext == '안녕'){
        return true;
    }
}

function firstforecast(isforecast, eventObj){
    if(isforecast == '1'){
        return 1;
    }
    else if(isforecast == '2'){
        return 2;
    }
    else{
        helloworld(eventObj);
        return;
    }
}
app.post('/hook', function (req, res) {

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

    isstart = ishello(message.text);
    isforecast = firstforecast(message.text, eventObj);

    if(isstart == true){
        console.log('[request hello] ', message);
        //console.log(count);
        helloworld(eventObj );
        isstart = false;
    }
    if(isstart == false){
        console.log('사용자가 종료를 입력했습니다.');
        isforecast = null;
    }

    if(isforecast == 1){
        console.log('[request Order] ', message);
        findroad(eventObj);
    }
    else if (isforecast == 2){
        console.log('[request Order] ', message);
        viewhtml(eventObj);
    }
    



    res.sendStatus(200);
});

function helloworld(eventObj){
    request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken":eventObj.replyToken,
                "messages":[
                    {
                        "type":"text",
                        "text":"안녕하세요, 교통정보 알리미입니다."
                    },
                    {
                        "type":"text",
                        "text":"무엇이 궁금하신가요??"
                    },
                    {
                        "type":"text",
                        "text":"현재 교통 예보가 궁금하시다면 1번을, 실시간 교통혼잡 상황을 보실려면 2번을 눌러주세요"
                    }
                ]
            }
        },(error, response, body) => {
            console.log(body)
        });
}

function viewhtml(eventObj){
    request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken":eventObj.replyToken,
                "messages":[
                    {
                        "type":"text",
                        "text":"실시간 교통상황 웹페이지로 안내합니다."
                    },
                    {
                        "type":"text",
                        "text":"https://www.chyoss.tk:23023/public/maprealtime.html"
                    },
                    {
                        "type":"text",
                        "text":"종료를 입력하시면 종료됩니다."
                    }
                ]
            }
        },(error, response, body) => {
            console.log(body)
        });
}



function findroad(eventObj){
    jsonforecast(function(object){
        var obj = object;
        jsonForforecast = obj;
        console.log(jsonForforecast);
        request.post(
            {
                url: TARGET_URL,
                headers: {
                    'Authorization': `Bearer ${TOKEN}`
                },
                json: {
                    "replyToken":eventObj.replyToken,
                    "messages":[
                        {
                            "type":"text",
                            "text":"교통예보를 시작합니다."
                        },
                        {
                            "type":"text",
                            "text":jsonForforecast.list[0].sdate+ ', ' + jsonForforecast.list[0].stime + '기준입니다.'
                        },
                        {
                            "type":"text",
                            "text": '현재 전국 교통량은 ' + jsonForforecast.list[0].cjunkook + '대 이며, 지방방향 교통량은 ' + jsonForforecast.list[0].cjibangDir + '대, 서울방향 교통량은 ' + jsonForforecast.list[0].cseoulDir + '대입니다.'
                        },
                        {
                            "type":"text",
                            "text":"버스기준으로 보시겠습니까 아니면 일반 승용차 기준으로 보시겠습니까? 버스기준으로 보실려면 1번을, 일반 승용차 기준으로 보실려면 2번을 입력해 주세요."
                        }
                    ]
                }
            },(error, response, body) => {
                console.log(body)
            });
    });

}





// var url1 = 'http://data.ex.co.kr/openapi/odtraffic/trafficAmountByCongest';
// var queryParams1 = '?' + encodeURIComponent('key') + '=4365330273'; /* Service Key*/
// queryParams1 += '&' + encodeURIComponent('type') + '=' + encodeURIComponent('json'); /* */

// request({
//     url: url1 + queryParams1,
//     method: 'GET'
// }, function (error, response, body) {
//     console.log('Status', response.statusCode);
//     console.log('Headers', JSON.stringify(response.headers));
//     console.log('Reponse received', body);
//     var obj = JSON.parse(body);
//     console.log(obj);
//     console.log(obj.list[0])
// });




// var url3 = 'http://data.ex.co.kr/openapi/trafficapi/trafficAll';
// var queryParams3  = '?' + encodeURIComponent('key') + '=4365330273'; /* Service Key*/
// queryParams3 += '&' + encodeURIComponent('type') + '=' + encodeURIComponent('json'); /* */

// request({
//     url: url3 + queryParams3,
//     method: 'GET'

// }, function (error, response, body) {
//     console.log('Status', response.statusCode);
//     console.log('Headers', JSON.stringify(response.headers));
//     console.log('Reponse received', body);
//     var obj = JSON.parse(body);
//     console.log(obj);
//     console.log(obj.trafficAll[0]);
// });


// var url4 = 'http://data.ex.co.kr/openapi/trafficapi/trafficRegion';
// var queryParams4  = '?' + encodeURIComponent('key') + '=4365330273'; /* Service Key*/
// queryParams4 += '&' + encodeURIComponent('type') + '=' + encodeURIComponent('json'); /* */

// request({
//     url: url4 + queryParams4,
//     method: 'GET'

// }, function (error, response, body) {
//     console.log('Status', response.statusCode);
//     console.log('Headers', JSON.stringify(response.headers));
//     console.log('Reponse received', body);
//     var obj = JSON.parse(body);
//     console.log(obj);
//     console.log(obj.trafficRegion[0]);
// });

// var url5 = 'http://data.ex.co.kr/openapi/business/conveniServiceArea';
// var queryParams5  = '?' + encodeURIComponent('key') + '=4365330273'; /* Service Key*/
// queryParams5 += '&' + encodeURIComponent('type') + '=' + encodeURIComponent('json'); /* */

// request({
//     url: url5 + queryParams5,
//     method: 'GET'

// }, function (error, response, body) {
//     console.log('Status', response.statusCode);
//     console.log('Headers', JSON.stringify(response.headers));
//     console.log('Reponse received', body);
//     var obj = JSON.parse(body);
//     console.log(obj);
//     console.log(obj.list[0]);
// });






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);
  }