// 服務(wù)端入口文件
// 1. 創(chuàng)建KOA的實(shí)例對象
const Koa = require('koa') // 引入koa
const app = new Koa() // 創(chuàng)建koa 實(shí)例
// 2.綁定中間件
// 第一層 響應(yīng)時間的中間件
const resDuration = require('./middleware/response_duration')
app.use(resDuration)
// 第二層 設(shè)置響應(yīng)頭的中間件
const resHeader = require('./middleware/response_header')
app.use(resHeader)
// 第三層 處理業(yè)務(wù)邏輯的中間件
const resData = require('./middleware/response_data')
app.use(resData)
// 3.綁定端口號
app.listen(2903)
const webSocketService = require('./service/web_socket_service')
// 開啟服務(wù)器的監(jiān)聽，監(jiān)聽客戶端的鏈接
// 當(dāng)某一個客戶端連接成功之后，就會對這個客戶端進(jìn)行message 事件的監(jiān)聽
webSocketService.listen()

// 計(jì)算響應(yīng)總耗時的中間件
module.exports = async (context,next) =>{
// 記錄開始時間
  const start = Date.now()
// 讓內(nèi)層的中間件得到執(zhí)行
  await next()
// 記錄結(jié)束的時間
  const end = Date.now()
// 準(zhǔn)備時間數(shù)據(jù)
  const  duration = end - start
// 設(shè)置響應(yīng)頭 X-Response-Time
  context.set('X-Response-Time',duration + 'ms')
}

// 設(shè)置響應(yīng)頭的中間件
module.exports = async (context,next) =>{
  // 增加響應(yīng)頭 解讀 json文件  utf-8格式防止亂碼
  const  contentType = 'application/json; charset=utf-8'
  context.set('Content-Type',contentType)
  // 下面兩行增加跨域配置
  context.set('Access-Control-Allow-Origin','*')
  context.set('Access-Control-Allow-Methods','OPTIONS,GET,PUT,POST,DELETE')
  //context.response.body = '{"success":true}'
  await next()
}

// 處理業(yè)務(wù)邏輯的中間件 讀取某個json文件的數(shù)據(jù)
// 引入 node path內(nèi)置模塊 用于拼接路徑
const path = require('path')
// 具體處理對應(yīng)文件的工具
const fileUtils = require('../utils/file_utils')
module.exports = async (context,next) => {
  // 根據(jù)url 提取關(guān)鍵字 再拼接絕對路徑
  const url = context.request.url // /api/seller
  let filePath = url.replace('/api','')
  filePath = path.join('../data',filePath,'.json') // ../data/seller.json
  filePath = path.join(__dirname,filePath)
try {
  const ret = await fileUtils.getFileJsonData(filePath)
  context.response.body = ret
}catch (e) {
  const errMsg = {
    message:'讀取文件內(nèi)容失敗，文件資源不存在',
    status:404
  }
  context.response.body = JSON.stringify(errMsg)
}
  //console.log(filePath)
  await next()
}

// 讀取文件的工具方法
const fs = require('fs') // 引入fs文件模塊  fs.readFile 用來讀取文件
module.exports.getFileJsonData = (filePath) =>{
return new Promise((resolve, reject) => {
  // fs.readFile 三個參數(shù)  1.文件的路徑 2.文件所要讀取的編碼 3.promise 函數(shù)
  fs.readFile(filePath,'utf-8',(error,data)=>{
    if (error){
      // 讀取文件失敗
      reject(error)
    }else {
      // 讀取文件成功
      resolve(data)
    }
  })
})
}