Upload 4 files

Dockerfile

@@ -0,0 +1,21 @@
+# Menggunakan image Node.js yang lebih stabil
+FROM node:16-slim
+
+
+# Tentukan direktori kerja di dalam container
+WORKDIR /app
+
+# Salin file package.json dan package-lock.json terlebih dahulu
+COPY package*.json ./
+
+# Install dependensi Node.js
+RUN npm install
+
+# Salin seluruh kode aplikasi ke dalam container
+COPY . .
+
+# Ekspose port 3000 yang akan digunakan aplikasi Express
+EXPOSE 3000
+
+# Tentukan perintah untuk menjalankan aplikasi Express.js
+CMD ["npm", "start"]

crc32.js

@@ -0,0 +1,41 @@
+/**
+ * 计算CRC32
+ * @param {ArrayBuffer} buffer - ArrayBuffer
+ */
+export default buffer => {
+  buffer = new Uint8Array(buffer)
+  const module = {
+    polynom: 0xEDB88320,
+    initValue: -1,
+    bytes: 4,
+    table: []
+  }
+  for (let a = 0; a < 256; ++a) {
+    let b = a
+    for (let c = 0; c < 8; ++c) {
+      b = b & 1 ? module.polynom ^ (b >>> 1) : b >>> 1
+    }
+    module.table[a] = b >>> 0
+  }
+  let crc = module.initValue
+  let length = buffer.length
+  let table = module.table
+  for (let a = 0; a < 256; ++a) {
+    let b = a
+    for (let c = 0; c < 8; ++c) {
+      b = b & 1 ? module.polynom ^ (b >>> 1) : b >>> 1
+    }
+    module.table[a] = b >>> 0
+  }
+  for (let i = 0; i < length; ++i) {
+    crc = table[(crc ^ buffer[i]) & 0xFF] ^ (crc >>> 8)
+  }
+  crc ^= module.initValue
+  let HEX_CHARS = '0123456789abcdef'.split('');
+  let hex = '';
+  if (module.bytes > 2) {
+    hex += HEX_CHARS[(crc >> 28) & 0x0F] + HEX_CHARS[(crc >> 24) & 0x0F] + HEX_CHARS[(crc >> 20) & 0x0F] + HEX_CHARS[(crc >> 16) & 0x0F]
+  }
+  hex += HEX_CHARS[(crc >> 12) & 0x0F] + HEX_CHARS[(crc >> 8) & 0x0F] + HEX_CHARS[(crc >> 4) & 0x0F] + HEX_CHARS[crc & 0x0F]
+  return hex
+}

index_part.js

@@ -0,0 +1,109 @@
+import crc32 from './crc32.js'
+import http from 'axios'
+import express from 'express'
+
+const app = express()
+const port = 7860
+
+app.use(express.json())
+app.use(express.urlencoded({ extended: true }))
+
+function splitBuffer(buffer, n) {
+  const partSize = Math.ceil(buffer.length / n)
+  const parts = []
+
+  for (const i = 0; i < n; i++) {
+    const start = i * partSize
+    const end = start + partSize
+    parts.push(buffer.slice(start, end))
+  }
+
+  return parts
+}
+
+app.get('*', async (req, res) => {
+  try {
+    const file_url = req.path.replace(/^\//, '')
+    const file = await http({
+      method: 'GET',
+      url: file_url,
+      responseType: 'arraybuffer'
+    })
+    const files_list = splitBuffer(file, 5)
+    const upload_info = await http({
+      method: 'GET',
+      url: 'https://api.xs.cx/upload/sg'
+    })
+    const upload_part_info = await http({
+      method: 'POST',
+      url: upload_info.data.url,
+      params: {
+        uploadmode: 'part',
+        phase: 'init'
+      },
+      headers: {
+        'authorization': upload_info.data.authorization
+      }
+    })
+    const uploadid = upload_part_info.data.data.uploadid
+    console.log(uploadid)
+    const upload_list = {}
+    await Promise.all(files_list.map(async (item, index) => {
+      const crc32_text = crc32(item)
+      let count = 1
+      while (count && count <= 5) {
+        const upload_result = await http({
+          method: 'POST',
+          url: upload_info.data.url,
+          params: {
+            uploadid: uploadid,
+            part_number: index + 1,
+            phase: 'transfer'
+          },
+          headers: {
+            'content-crc32': crc32_text,
+            'authorization': upload_info.data.authorization
+          },
+          data: item
+        })
+        if (upload_result.data.data.crc32 == crc32_text) {
+          count = 0
+          upload_list[index + 1] = crc32_text
+        } else {
+          count += 1
+          if (count > 5) {
+            throw Error
+          }
+        }
+      }
+    }))
+    const finish = Object.entries(upload_list).map(i => i.join(':')).join(',')
+    const upload_result = await http({
+      method: 'POST',
+      url: upload_info.data.url,
+      params: {
+        uploadid: uploadid,
+        uploadmode: 'part',
+        phase: 'finish'
+      },
+      headers: {
+        'authorization': upload_info.data.authorization
+      },
+      data: finish
+    })
+    if (upload_result.data.code == 2000) {
+      res.send(JSON.stringify({
+        vid: upload_info.data.vid,
+        url: `https://sf16-sg-default.akamaized.net/obj/${upload_info.data.uri}`
+      }))
+    } else {
+      throw Error
+    }
+  } catch (e) {
+    res.send(e.toString())
+  }
+})
+
+app.listen(port, async () => {
+  console.log(`http://localhost:${port}`)
+})

package.json

@@ -0,0 +1,13 @@
+{
+  "name": "xx",
+  "version": "1.0.0",
+  "type": "module",
+  "main": "index.js",
+  "scripts": {
+    "start": "node index"
+  },
+  "dependencies": {
+    "axios": "^1.3.4",
+    "express": "^4.18.2"
+  }
+}