feat: 添加自動刪除功能

config.yml

@@ -1 +1,2 @@
 path: string
+deleteAfter: number

index.ts

@@ -2,21 +2,24 @@ import fs from 'fs'
 import got, {HTTPError, Options} from 'got'
 import YAML from 'yaml'
 
-import {timeout} from './util.js'
+import {Iconfig, IrequestData} from './types.js'
-import {IrequestData} from './types.js'
 
-const path: string = YAML.parse(fs.readFileSync('../config.yml', 'utf-8')).path
+const config: Iconfig = YAML.parse(fs.readFileSync('../config.yml', 'utf-8'))
+const lock: string[] = []
 
-fs.watch(path, async function (event, filename) {
+fs.watch(config.path, async function (event, filename) {
-  if (!(filename && event === 'change')) return
+  if (!(filename && event === 'change') || lock.includes(filename)) return
-  const jpath: string = `${path}/${filename}`
+  lock.push(filename)
+  const jpath: string = `${config.path}/${filename}`
   const requestData: IrequestData = JSON.parse(fs.readFileSync(jpath).toString())
   if (requestData.Processed === true) return
   const method: any = requestData.Request.Mode.toUpperCase()
   if (!['GET', 'POST', 'PUT', 'PATCH', 'HEAD', 'DELETE', 'OPTIONS', 'TRACE'].includes(method)) {
+    console.error('無效的請求方式')
     return
   }
   requestData.Response = {Headers: {}}
+  console.log(`接收到請求:${filename} => ${method} ${requestData.Request.URL}`)
   try {
     const res = await got({
       url: requestData.Request.URL,
@@ -35,8 +38,15 @@ fs.watch(path, async function (event, filename) {
       requestData.Response.StatusCode = error.response.statusCode
     } else {
       requestData.Response.StatusCode = -1
+      console.error(`處理失敗:${filename}\n`, error)
     }
   }
   requestData.Processed = true
   fs.writeFileSync(jpath, JSON.stringify(requestData))
+  setTimeout(() => {
+    fs.unlinkSync(jpath)
+    setTimeout(() => {
+      lock.splice(lock.indexOf(filename), 1)
+    }, 300)
+  }, config.deleteAfter * 1000)
 })

types.ts

@@ -12,3 +12,8 @@ export interface IrequestData {
   }
   Processed?: boolean
 }
+
+export interface Iconfig {
+  path: string
+  deleteAfter: number
+}

util.ts

@@ -1,6 +0,0 @@
-export function timeout(ms: number): Promise<unknown> {
-    return new Promise((resolve, reject) => {
-      setTimeout(resolve, ms)
-    })
-  }
-