const express = require('express');
const request = require('request');
const talk = require('./talk')

const fs = require('fs');
const path = require('path');
const HTTPS = require('https');
const bodyParser = require('body-parser');

// var latitude = 37.2429832;
// var longitude = 127.0749535;
// var locationAdd = "경기 용인시 기흥구 서그내로49번길 13"
// var location_name = "카페 서천"


const TARGET_URL = 'https://api.line.me/v2/bot/message/reply'
const tokens = JSON.parse(fs.readFileSync("setting.json"))
const sslport = 23023;
const domain = tokens.domain
const TOKEN = tokens.channel
const id = tokens.id
const pw = tokens.pw

var first = false; //첫 시도인지
var second = false; //첫번째 분류 선택했는지
var destCar = "";
var destination = [];

function sendText(replyToken, messages) {
    request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken": replyToken,
                "messages": [
                    {
                        "type": "text",
                        "text": messages
                    }
                ]
            }
        }, (error, response, body) => {
            console.log(body)
        });
}

// https://developers.line.biz/en/reference/messaging-api/#image-message
// OR
// https://developers.line.biz/en/reference/messaging-api/#location-message

function sendImage(replyToken, imageUrl) {
    request.post(
        {
            url: TARGET_URL,
            headers: {
                'Authorization': `Bearer ${TOKEN}`
            },
            json: {
                "replyToken": replyToken,
                "messages": [
                    {
                        "type": "location",
                        "title": locationName,
                        "address": locationAdd,
                        "latitude": latitude,
                        "longitude": longitude
                    }
                ]
            }
        }, (error, response, body) => {
            console.log(body)
        });
}

var app = express();
app.use(bodyParser.json());
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] ', eventObj.source);
    console.log('[request message]', eventObj.message);

    if (first == false && eventObj.message.text == "처음") {
        request.post(
            {
                url: TARGET_URL,
                headers: {
                    'Authorization': `Bearer ${TOKEN}`
                },
                json: {
                    "replyToken": eventObj.replyToken,
                    "messages": [
                        {
                            "type": "text",
                            "text": "카테고리를 선택해주세요.\n1. 식사\n2. 카페\n3. 술\n4. 놀거리\n(숫자만 입력해주세요)"
                        }
                    ]
                },
            }, (error, response, body) => {
                console.log(body)
            });
        first = true;
    }

    else if (first == true && second == false) {

        if (eventObj.message.text == 1) { //식사 선택
            request.post(
                {
                    url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
                        "replyToken": eventObj.replyToken,
                        "messages": [{ "type": "text", "text": "[식사] 키워드를 선택해주세요\n1. 양식\n2. 한식\n3. 중식\n4. 일식\n5. 기타\n(숫자만 입력해주세요)" }]
                    }
                }, (error, response, body) => {
                    console.log(body)
                });
            destCar = "meal";
        } else if (eventObj.message.text == 2) { //카페 선택
            request.post(
                {
                    url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
                        "replyToken": eventObj.replyToken,
                        "messages": [{ "type": "text", "text": "[카페] 키워드를 선택해주세요\n1. 감성\n2. 카공\n3. 디저트\n(숫자만 입력해주세요)" }]
                    }
                }, (error, response, body) => {
                    console.log(body)
                });
            destCar = "cafe";
        } else if (eventObj.message.text == 3) { //술 선택
            request.post(
                {
                    url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
                        "replyToken": eventObj.replyToken,
                        "messages": [{ "type": "text", "text": "[술] 키워드를 선택해주세요\n1. 소주\n2. 이자카야\n3. 막걸리\n4. 맥주\n(숫자만 입력해주세요)" }]
                    }
                }, (error, response, body) => {
                    console.log(body)
                });
            destCar = "bar"
        } else if (eventObj.message.text == 4) { //놀거리 선택
            request.post(
                {
                    url: TARGET_URL, headers: { 'Authorization': `Bearer ${TOKEN}` }, json: {
                        "replyToken": eventObj.replyToken,
                        "messages": [{ "type": "text", "text": "[놀거리] 키워드를 선택해주세요\n1. 노래방\n2. 피시방\n3. 기타\n(숫자만 입력해주세요)" }]
                    }
                }, (error, response, body) => {
                    console.log(body)
                });
            destCar = "play"
        }
        chooseFile();
        second = true;

    }

    else if (first == true && second == true) {
        if (destCar == "meal") {
            if (eventObj.message.text == 1) { var randpick = randomNum(0, 6); destination = results[randpick] }
            else if (eventObj.message.text == 2) { var randpick = randomNum(7, 19); destination = results[randpick] }
            else if (eventObj.message.text == 3) { var randpick = randomNum(20, 25); destination = results[randpick] }
            else if (eventObj.message.text == 4) { var randpick = randomNum(26, 36); destination = results[randpick] }
            else if (eventObj.message.text == 5) { var randpick = randomNum(37, 46); destination = results[randpick] }
        }
        else if (destCar == "cafe") {
            if (eventObj.message.text == 1) { var randpick = randomNum(0, 5); destination = results[randpick] }
            else if (eventObj.message.text == 2) { var randpick = randomNum(6, 12); destination = results[randpick] }
            else if (eventObj.message.text == 3) { var randpick = randomNum(13, 17); destination = results[randpick] }
        }
        else if (destCar == "bar") {
            if (eventObj.message.text == 1) { var randpick = randomNum(0, 5); destination = results[randpick] }
            else if (eventObj.message.text == 2) { var randpick = randomNum(6, 11); destination = results[randpick] }
            else if (eventObj.message.text == 3) { var randpick = randomNum(12, 15); destination = results[randpick] }
            else if (eventObj.message.text == 4) { var randpick = randomNum(16, 20); destination = results[randpick] }
        }
        else if (destCar == "play") {
            if (eventObj.message.text == 1) { var randpick = randomNum(0, 3); destination = results[randpick] }
            else if (eventObj.message.text == 2) { var randpick = randomNum(4, 8); destination = results[randpick] }
            else if (eventObj.message.text == 3) { var randpick = randomNum(9, 13); destination = results[randpick] }
        }


    }
    res.sendStatus(200);
});

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(app).listen(sslport, () => {
        console.log(`[HTTPS] Server is started on port ${sslport}`);
    });
} catch (error) {
    console.log('[HTTPS] HTTPS 오류가 발생하였습니다. HTTPS 서버는 실행되지 않습니다.');
    console.log(error);
}


const csv = require('csv-parser')
const results = [];

chooseFile = function () {
    if (destCar == "cafe") {
        fs.createReadStream('cafe_list.csv')
            .pipe(csv())
            .on('data', (data) => results.push(data))
            .on('end', () => {
                console.log(results);
            });
    }
    else if (destCar == "meal") {
        fs.createReadStream('meal_list.csv')
            .pipe(csv())
            .on('data', (data) => results.push(data))
            .on('end', () => {
                console.log(results);
            });
    }
    else if (destCar == "play") {
        fs.createReadStream('play_list.csv')
            .pipe(csv())
            .on('data', (data) => results.push(data))
            .on('end', () => {
                console.log(results);
            });
    }
    else if (destCar == "bar") {
        fs.createReadStream('bar_list.csv')
            .pipe(csv())
            .on('data', (data) => results.push(data))
            .on('end', () => {
                console.log(results);
            });
    }
}

function randomNum(min, max) {
    var randNum = Math.floor(Math.random() * (max - min + 1)) + min;
    return randNum;
}

function getX() {
    return destination.x;
}
function getY() {
    return destination.y;
}
function getName() {
    return destination.name;
}
function getAddress() {
    return destination.address;
}

//export { getX, getY, getName, getAddress }