chore: repo overall update

tools/canyon-sdk/package.json

@@ -1,6 +1,6 @@
 {
   "name": "canyon-sdk",
-  "version": "2.0.0-beta.2",
+  "version": "2.0.0-beta.3",
   "files": [
     "dist"
   ],

tools/canyon-sdk/src/main.ts

@@ -1,2 +1,104 @@
-import { add } from './helpers/add';
-console.log(add(1,2));
+(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)
+
+    // 要发探测数据，id客户端生成
+
+    navigator.sendBeacon(
+      dsn,
+      fd,
+    )
+  }
+
+  const timerHandler = () => {
+    if (window.__coverage__){
+      window.addEventListener('unload', () => {
+        collectCoverageData('unload')
+      })
+      document.addEventListener('visibilitychange', () => {
+        collectCoverageData('visibilitychange')
+      })
+    } else {
+      console.log('canyon: no coverage data')
+    }
+  }
+
+  // setTimeout(timerHandler, timeout)
+})()