/**
 * @author : 최정우
 * @since : 2022.09.20
 * @dscription : Express 라이브러리 활용 HTTP Web Server 모듈입니다.
 */
const { BASE_DIR, PORT } = require('../../../Global');
const Logger = require('../log/Logger');//Logger(필수)

const express = require('express');
const webServer = express();

const FS = require("fs");
const Transform = require("stream").Transform;


/**
 * @author : 최정우
 * @since : 2022.09.20
 * @dscription : HTTP Server start
 */
webServer.listen(PORT, function () {
    Logger.logging(`★★★ Node.js를 활용한 Web Server 구동(Port:${PORT}) ★★★`);
})

/**
 * @author : 최정우
 * @since : 2022.09.20
 * @dscription : Intercepter 역할을 하는 미들웨어 기능
 */
webServer.use(function (request, response, next) {
    let ip = request.headers['x-forwarded-for'] || request.socket.remoteAddress;
    Logger.logging(`[HTTP] ${request.url} (Method: ${request.method}, IP: ${ip})`);
    next();
});

/**
 * @author : 최정우
 * @since : 2022.09.20
 * @dscription : ROOT URL -> index.html
 */
webServer.get('/', function (request, response) {
    response.sendFile(`${BASE_DIR}/client/views/index.html`);
})

/**
 * @author : 최정우
 * @since : 2022.09.20
 * @dscription : Router's (Controller)
 */
webServer.use("/test", require('../../service/test/router/TestRouter'));

/**
 * @author : 최정우
 * @since : 2022.09.20
 * @dscription : 화면요청 URL 처리
 */
webServer.get('/:pageName', function (request, response, next) {
    const pageName = request.params.pageName; // 'ChuljangList' 등의 동적 페이지 이름 추출
    
    // index.html을 스트리밍하여 페이지에 맞는 URL을 동적으로 설정
    const StreamTransform = new Transform();
    StreamTransform._transform = function (data, encoding, done) {
        let fileContent = data.toString();
        
        // 특정 페이지에 맞는 URL을 변경하는 부분
        let replaceBeforeContent = `<script id="app-start-vue-page">const APP_USER_HTTP_REQUEST_URL = '/';</script>`;
        let replaceAfterContent = `<script id="app-start-vue-page">const APP_USER_HTTP_REQUEST_URL = '/${pageName}';</script>`;
        
        // 파일 내용에서 URL을 변경
        fileContent = fileContent.replace(replaceBeforeContent, replaceAfterContent);
        this.push(fileContent);
        done();
    };
    
    // index.html 파일을 스트리밍하여 반환
    FS.createReadStream(`${BASE_DIR}/client/views/index.html`)
        .pipe(StreamTransform)
        .pipe(response);
});

/**
 * @author : 최정우
 * @since : 2022.09.20
 * @dscription : ROOT URL, Router's, 화면요청 URL 등.. 이 외 나머지 정적 자원에 대한 처리 기능
 */
webServer.get('*.*', function (request, response, next) {
    response.sendFile(`${BASE_DIR}${request.params['0']}.${request.params['1']}`);
})

/**
 * @author : 최정우
 * @since : 2022.09.21
 * @dscription : Global Error Handler (*맨 마지막에 적용해야됨)
 */
webServer.use(function (error, request, response, next) {
    const errorCode = !error.statusCode ? 500 : error.statusCode;
    response.status(errorCode).send('에러가 발생하였습니다. 관리자에게 문의바랍니다.');
    let message = `[Error:${errorCode}] ${request.url}/n ${error.stack}/n`;
    Logger.logging(message);
    //next();
})