// CORS 前端地址
var FRONT_END_URL='*'

// 发表评论
addEventListener('fetch', event => {
  event.respondWith(handleRequest(event))
})

async function handleRequest(event) {
  const request = event.request
  const headers = new Headers({
    "Access-Control-Allow-Origin": FRONT_END_URL,
    "Access-Control-Allow-Methods": "GET, POST",
    "Access-Control-Allow-Headers": "*",
  })
  // 如果请求方法是 POST，表示有新评论要发表
  if (request.method === 'POST') {
    // 解析请求体中的 JSON 数据
    const data = await request.json()
    console.log(data)
    // 获取博文 URL、评论内容、时间戳、用户 ID 等信息
    const url = data.url
    const content = data.content
    const timestamp = new Date().toISOString()
    // 根据博文 URL 获取博文 ID
    const postid = await getPostID(url)
    // 生成自增评论 ID 并创建一个新的评论对象
    const comment = {
      content,
      time: timestamp,
      user: data.user, // 用户 id 从请求体中获取
    }
    // 将评论对象以博文 ID 和评论 ID 构成的键存储到 KV 中
    const prefix = data.parent && data.parent.length ? `${postid}|${data.parent}` : `${postid}`
    const key = `${prefix}|${await getNextID(prefix)}`
    await kvComments.put(key, JSON.stringify(comment))
    // 返回一个带有状态码为 200 的成功响应
    return new Response(JSON.stringify({ message: `Comment posted successfully. ID = ${key.split("|").slice(1).join('|')}` }), { status: 200 ,headers})

    // 如果请求方法是 GET，表示要获取博文评论
  } else if (request.method === 'GET') {
    // 从查询参数中获取博文 URL
    const url = new URL(request.url)
    const postUrl = url.searchParams.get('url')
    // 根据博文 URL 获取博文 ID，并检索与该博文相关的所有评论
    const comments = await getComments(postUrl)
    // 返回一个带有状态码为 200 的响应，其中包含所有检索到的评论
    return new Response(JSON.stringify(comments), { status: 200 ,headers })

    // 如果请求方法不是 POST 或 GET，则返回一个“无效请求方法”的错误响应
  } else if (request.method === 'OPTIONS') {
    // 添加 Access-Control-Allow-Methods 和 Access-Control-Allow-Headers
    headers.set('Access-Control-Allow-Methods', 'GET, POST');
    // 返回一个空的响应和带有 CORS 相关头信息的状态码 200
    return new Response(null, { status: 200, headers });
  } else {
    return new Response('Invalid request method.', { status: 405 ,headers })
  }
}

function compareKeys(key1, key2) {
  const keys1 = key1.split('|')
  const keys2 = key2.split('|')

  let i = 0
  while (i < Math.min(keys1.length, keys2.length)) {
    // 比较两个键名中第 i 个数字的大小
    if (parseInt(keys1[i]) < parseInt(keys2[i])) {
      return -1
    } else if (parseInt(keys1[i]) > parseInt(keys2[i])) {
      return 1
    }
    i++
  }

  // 如果前面相同长度的部分都相等，则按照长度升序排列
  if (keys1.length < keys2.length) {
    return -1
  } else if (keys1.length > keys2.length) {
    return 1
  }

  // 如果两个键名完全相等，则认为它们相等
  return 0
}



// 获取评论
async function getComments(postUrl) {
  // 根据博文 URL 获取博文 ID
  const postid = await getPostID(postUrl)
  // 构建一个空评论数组，准备存储检索到的评论
  const comments = []
  let cursor = ''
  // 循环列出与博文 ID 相关的所有评论，直到全部检索完毕
  do {
    // 每次列出 1000 条评论，并指定返回的键以博文 ID 和评论 ID 构成的前缀为 prefix
    const { keys, list_complete } = await kvComments.list({
      prefix: `${postid}|`,
      cursor,
      limit: 1000
    })
    // const keys = 
    console.log(keys.map(key => key.name).sort(compareKeys))
    // 遍历每个键，将其对应的值解析为 JSON 格式后添加到评论数组中
    for (const key of keys.map(key => key.name).sort(compareKeys)) {
      let comment = JSON.parse(await kvComments.get(key))
      comment['key'] = key.split("|").slice(1).join('|')
      comments.push(comment)
    }
    // 设置下一页的游标 cursor，如果已经达到最后一页，则设置 cursor 为 null
    cursor = list_complete ? null : keys[keys.length - 1].name
  } while (cursor)
  // 返回所有检索到的评论数组
  return comments
}

// 获取下一个自增 id
async function getNextID(key) {
  // 从 KV 存储中获取指定键名的 id 值
  const id = await kvCounter.get(key)
  // 如果不存在该键，则将其初始化为 1，并返回 '1' 作为第一个自增 id
  if (id === null) {
    await kvCounter.put(key, '1')
    return '1'
  }
  // 将当前 id 转换为整数，加 1 得到下一个自增 id，然后更新 KV 中的值
  const nextId = parseInt(id) + 1
  await kvCounter.put(key, nextId.toString())
  return nextId.toString()
}

// 获取博文的 postid
async function getPostID(url) {
  // 根据博文 URL 从 KV 的映射表 kvMap 中获取博文 ID
  let postid = await kvMap.get(url)
  // 如果该博文 URL 没有对应的博文 ID，则生成一个新的博文 ID，并将其与该博文 URL 映射起来
  if (postid === null) {
    postid = await getNextID('postid')
    await kvMap.put(url, postid)
  }
  // 返回博文 ID
  return postid
}

{
  "url": "https://example.com/posts/1",
  "content": "这是一条评论",
  "user": "user123",
  "parent": "15|5"
}``` 

#### 响应

- 状态码：`200`
- 响应体（JSON）：
    - `message`：发布评论成功后返回的消息，其中包含新评论的 ID。

示例：



```json
{
  "message": "Comment posted successfully. ID = 15|5|1"
}

[
  {
    "content": "这是一条评论",
    "time": "2023-06-21T08:39:33.747Z",
    "user": "user123",
    "key": "14"
  },
  {
    "content": "这是一条评论",
    "time": "2023-06-21T08:40:26.493Z",
    "user": "user123",
    "key": "15"
  },
  {
    "content": "这是一条评论",
    "time": "2023-06-21T08:41:10.868Z",
    "user": "user123",
    "key": "15|1"
  },
  {
    "content": "这是一条评论",
    "time": "2023-06-21T08:42:58.501Z",
    "user": "user123",
    "key": "15|2"
  },
  {
    "content": "这是一条评论",
    "time": "2023-06-21T08:43:15.987Z",
    "user": "user123",
    "key": "15|3"
  },
]