var express = require('express');
const request = require('request');
const TARGET_URL = 'https://api.line.me/v2/bot/message/reply'
const TOKEN = 'Your Token'
const PAPAGO_URL = 'https://openapi.naver.com/v1/papago/n2mt'
const PAPAGO_D_URL = 'https://openapi.naver.com/v1/papago/detectLangs'
const PAPAGO_ID = 'Your Papago_ID'
const PAPAGO_SECRET = 'Your Papago_Secret'
const WEATHER_TARGET_URL = 'http://apis.data.go.kr/1360000/VilageFcstInfoService/getVilageFcst';
const weather_key = 'Your Key';

const fs = require('fs');
const path = require('path');
const HTTPS = require('https');
const domain = "Your Domain"
const sslport = Your port;

const bodyParser = require('body-parser');
var app = express();
var async = require('async');
const { resolve } = require('path');

var Language_Detect_Array = new Array();
var User_Info_Array = new Array();
var Weahter_Detect_Array = new Array();

Weahter_Detect_Array[0] =
{
    "Region" : '수원',
    "nx" : 61,
    "ny" : 120
}
Weahter_Detect_Array[1] =
{
    "Region" : '서울',
    "nx" : 60,
    "ny" : 127
}
Weahter_Detect_Array[2] =
{
    "Region" : '밀양',
    "nx" : 92,
    "ny" : 83
}

Language_Detect_Array[0] =
{
    "Message" : '영어',
    "PapagoLanguage" : 'en'
}
Language_Detect_Array[1] =
{
    "Message" : '일본어',
    "PapagoLanguage" : 'ja'
}
Language_Detect_Array[2] =
{
    "Message" : '프랑스어',
    "PapagoLanguage" : 'fr'
}
Language_Detect_Array[3] =
{
    "Message" : '한국어',
    "PapagoLanguage" : 'ko'
}

User_Info_Array[0] =
{
    UserId : null,
    UserPapagoLanguage : '',
    UserRegion : '수원',
}

app.use(bodyParser.json());
app.post('/hook', function (req, res) {

    var eventObj = req.body.events[0];
    var message = eventObj.message.text;
    var replyToken = eventObj.replyToken;
    var userid = eventObj.source.userId;

    AsyncFunction(message, replyToken, userid);

    res.sendStatus(200);
});

async function AsyncFunction(message, replyToken, userid)
{
    var User_Location = search_user_info(userid); 
    var DetectLanguage = await detector(message);
    if(DetectLanguage != 'ko') var TransToKoreanMessage = await trans(DetectLanguage, message, 'ko'); else var TransToKoreanMessage = message;
    console.log(TransToKoreanMessage);
    var DetectChange = Detect_Papago_Language_Change(TransToKoreanMessage, User_Location);
    if (DetectChange) DetectChange = Detect_Weather_Region_Change(TransToKoreanMessage, User_Location);
    if(TransToKoreanMessage != '날씨')
    {
    if(DetectLanguage != User_Info_Array[User_Location].UserPapagoLanguage) var TransToUserSettingMessage = await trans(DetectLanguage, message, User_Info_Array[User_Location].UserPapagoLanguage);
    var Messaging = await messaging(TransToUserSettingMessage, replyToken, DetectChange);
    console.log("log-Message: ", Messaging);
    }
    else
    weathercheck(replyToken, userid, DetectLanguage);
}

async function weathercheck(replyToken, userid, DetectLanguage)
{
    var User_Location = search_user_info(userid); 
    var location = user_location(User_Location);
    var timevalue = make_time()
    var url = make_url(timevalue, location);
    var message = await weather_get(url, User_Location);
    if(DetectLanguage != 'ko')
    message = await trans ('ko', message, DetectLanguage)
    var Messaging = await messaging(message, replyToken, 1);
    console.log("log-Message: ", Messaging);
}

function detector (message)
//언어 감지
{  
    return new Promise(function(resolve, reject)
    {
        request.post
        (
            {
                url: PAPAGO_D_URL,
                headers:
                {
                    'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',
                    'X-Naver-Client-Id': `${PAPAGO_ID}`,
                    'X-Naver-Client-Secret': `${PAPAGO_SECRET}`
                },
                body: 'query='+message,
                json:true
            },(error, response, body) => 
            {
                if(!error && response.statusCode == 200)
                {
                    var DetectLanguage = body.langCode;
                    resolve(DetectLanguage);
                }
                else
                {
                    reject(new Error('Request is failed'));
                }
            }
        )
    })
}

function messaging(message, replyToken, DetectChange)
//메시지 보내기
{
    return new Promise(function(resolve, reject)
    {
        if(DetectChange)
        request.post
        (
            {
                url: TARGET_URL,
                headers: 
                {
                    'Authorization': `Bearer ${TOKEN}`
                },
                json: 
                {
                    "replyToken":replyToken,
                    "messages":
                    [
                        {
                            "type":"text",
                            "text":message
                        }
                    ]
    
                }
            }, (error, response, body) =>
            {
                if(!error && response.statusCode == 200)
                resolve('정상적으로 전송 되었습니다.');
            }
        );
    })
}

function trans (DetectLanguage, message, TransLanguage)
//언어 번역
{
    return new Promise(function(resolve, reject)
    {
        request.post(
            {
                url: PAPAGO_URL,
                headers: 
                {
                    'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',
                    'X-Naver-Client-Id': `${PAPAGO_ID}`,
                    'X-Naver-Client-Secret': `${PAPAGO_SECRET}`
                },
                body: 'source='+DetectLanguage+'&target='+TransLanguage+'&text='+message,
                json:true
            },(error, response, body) => 
            {
                if(!error && response.statusCode == 200)
                {
                    var transMessage = body.message.result.translatedText;
                    console.log('transMessage: ', transMessage);
                    resolve(transMessage);
                }
            }
            );
    })
}

function search_user_info (userid)
//유저 생성 또는 위치 찾기
{
    for(var i in User_Info_Array)
    {
        if (User_Info_Array[i].UserId == userid)
        {
            //기존 유저
            return i;
            break;
        }
        else if ( i == User_Info_Array.length-1)
        {
            //새로운 유저
        User_Info_Array[User_Info_Array.length] = 
            {
                UserId : userid,
                UserPapagoLanguage : 'en',
                UserRegion : '수원'
            }
            return User_Info_Array.length-1;
        }
    }
}

function Detect_Papago_Language_Change (TransToKoreanMessage, User_Location)
//번역 언어 변경 감지
{
    for(var i in Language_Detect_Array) // Detect Language change 
    {
        if (TransToKoreanMessage == Language_Detect_Array[i].Message)
        {
            //언어 변경 감지o
            User_Info_Array[User_Location].UserPapagoLanguage = Language_Detect_Array[i].PapagoLanguage;
            return 0;

            break;
        }
        else if ( i == Language_Detect_Array.length-1)
        {
            //언어 변경 감지x
            return 1;
        }
    }
}

function Detect_Weather_Region_Change (TransToKoreanMessage, User_Location)
//지역 변경 감지
{
    for(var i in Weahter_Detect_Array)
    {
        if (TransToKoreanMessage == Weahter_Detect_Array[i].Region)
        {
            //지역 변경 감지o
            User_Info_Array[User_Location].UserRegion = Weahter_Detect_Array[i].Region
            return 0;
            break;
        }
        else if ( i == Weahter_Detect_Array.length-1)
        {
            //지역 변경 감지x
            return 1;
        }
    }
}

function make_time()
{
    var today = new Date();
    var value = new Object();
    var dd = today.getDate();
    var mm = today.getMonth()+1;
    var yyyy = today.getFullYear();
    var hours = today.getHours();
    var minutes = today.getMinutes();

    if(minutes < 30){
        // 30분보다 작으면 한시간 전 값
        hours = hours - 1;
        if(hours < 0){
            // 자정 이전은 전날로 계산
            today.setDate(today.getDate() - 1);
            dd = today.getDate();
            mm = today.getMonth()+1;
            yyyy = today.getFullYear();
            hours = 23;
        }
    }
    if(mm<10) {
        mm='0'+mm
    }
    if(dd<10) {
        dd='0'+dd
    } 
    today = yyyy+""+mm+""+dd;

    for (var i = 0; i<9; i++)
    {
        var temp = i+1;
        if(3*i <= hours && 3*temp >= hours)
        {
            if(3*i-1<10)
            value.hours = '0'+3*i-1;
            else
            value.hours = 3*i-1;
            value.hours += '00';
            break;
        }
    }
    value.today = today;
    return value;
}

function make_url(timevalue, location)
{
    var serviceKey = weather_key;
    var pageNo = '1';
    var numOfRows = '5';
    var dataType = 'JSON';
    var base_date = timevalue.today;
    var base_time = timevalue.hours;
    var nx = location.nx;
    var ny = location.ny;

    var url = `${WEATHER_TARGET_URL}`;
    url += '?serviceKey='+serviceKey;
    url += '&pageNo='+pageNo;
    url += '&numOfRows='+numOfRows;
    url += '&dataType='+dataType;
    url += '&base_date='+base_date;
    url += '&base_time='+base_time;
    url += '&nx='+nx;
    url += '&ny='+ny;
    return url;
}

function user_location(User_Location)
{
    var location_info = new Object();
    for(var i in Weahter_Detect_Array)
    {
        if (User_Info_Array[User_Location].UserRegion == Weahter_Detect_Array[i].Region)
        {
            location_info.nx = Weahter_Detect_Array[i].nx;
            location_info.ny = Weahter_Detect_Array[i].ny;
            return location_info;
            break;
        }
    }
}


function weather_get (url, User_Location)
{
    return new Promise(function(resolve, reject)
    {
    request.get(
        {
            url: url,
        },(error, response, body) => 
        {
            if(!error && response.statusCode == 200)
            {
                var weatherObj = JSON.parse(response.body);
                resolve(User_Info_Array[User_Location].UserRegion+'에 4시간 안에 비가 올 확률은 '+weatherObj.response.body.items.item[0].fcstValue+'% 입니다.');
            }
            else{
                console.log('Error', error);
            }
        }
    )
    });
}

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