From bd6f5b15447db70efc54db524b4ba8750268e38e Mon Sep 17 00:00:00 2001
From: zhangtao25 <wr.zhang25@gmail.com>
Date: Thu, 21 Nov 2024 17:34:47 +0800
Subject: [PATCH] chore: repo overall update

---
 tools/collectjs/index.js | 105 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 105 insertions(+)
 create mode 100644 tools/collectjs/index.js

diff --git a/tools/collectjs/index.js b/tools/collectjs/index.js
new file mode 100644
index 00000000..b2cb2cb9
--- /dev/null
+++ b/tools/collectjs/index.js
@@ -0,0 +1,105 @@
+(async () => {
+  /*
+  /coverage/client适配
+
+  可能性
+  1. coverage file + formData的meta数据
+  2. 压缩过和没压缩过的数据。
+  3. 如果是其他端发送的话，也要支持纯json格式
+   */
+
+  /*
+* note:
+* 1. 需要延时添加，避免出现全局__coverage__未定义的情况
+* 2. 考虑兼容性，如不支持CompressionStream的浏览器，使用只能使用json格式
+* 3. 注意检测数据体积大小，浏览器版本做统计
+* 4. 发送数据前，发送预检测请求，后续统计收发数据的成功率
+* 5. 关注 https://developer.chrome.com/blog/fetch-later-api-origin-trial?hl=zh-cn
+*
+*
+* */
+  const timeout = 500
+
+  async function compressDataWithStream (data) {
+    const textEncoder = new TextEncoder()
+    const input = textEncoder.encode(data)
+
+    const compressionStream = new CompressionStream('gzip')
+    const writer = compressionStream.writable.getWriter()
+    writer.write(input)
+    writer.close()
+
+    const compressedData = []
+    const reader = compressionStream.readable.getReader()
+    let result
+    while (!(result = await reader.read()).done) {
+      compressedData.push(result.value)
+    }
+    return new Blob(compressedData) // 压缩后的数据为 Blob
+  }
+
+  function assemblyData () {
+    // 组装数据，确保最小
+
+    const cov = Object.entries(window.__coverage__).map(([path, { b, f, s }]) => ({
+      path,
+      b,
+      f,
+      s,
+    })).reduce((acc, { path, b, f, s }) => {
+      acc[path] = { b, f, s }
+      return acc
+    })
+
+    // 获取meta参数
+
+    const { projectID, sha, instrumentCwd,dsn } = Object.values(window.__coverage__)[0]
+    return {
+      coverage: cov,
+      projectID,
+      sha,
+      instrumentCwd,
+      dsn
+    }
+  }
+
+  async function collectCoverageData (timing) {
+
+    const {coverage,projectID,sha,instrumentCwd,dsn} = assemblyData()
+
+    const fd = new FormData()
+
+
+    const blob = await compressDataWithStream(JSON.stringify(coverage))
+
+    // 覆盖率数据
+    fd.append('coverage', blob)
+    // canyon数据
+    fd.append('projectID', projectID)
+    fd.append('sha', sha)
+    fd.append('instrumentCwd', instrumentCwd)
+    // 触发时机
+    fd.append('timing', timing)
+
+    navigator.sendBeacon(
+      dsn,
+      fd,
+    )
+  }
+
+  const timerHandler = () => {
+    window.addEventListener('unload', () => {
+      collectCoverageData('unload')
+    })
+    document.addEventListener('visibilitychange', () => {
+      collectCoverageData('visibilitychange')
+    })
+  }
+
+  if (window.__coverage__){
+    // 设置延时
+    setTimeout(timerHandler, timeout)
+  } else {
+    console.log('canyon: no coverage data')
+  }
+})()