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.js

@@ -0,0 +1,146 @@
+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 }))
+
+const upload_buffer = async data => {
+  try {
+    const file = Buffer.from(data)
+    const hash = crc32(file)
+    const upload_info = await http({
+      method: 'GET',
+      url: 'https://api.xs.cx/upload/sg'
+    })
+    const upload_result = await http({
+      method: 'POST',
+      url: upload_info.data.url,
+      headers: {
+        'content-crc32': hash,
+        'authorization': upload_info.data.authorization
+      },
+      data: file
+    })
+    if (upload_result.status == 200) {
+      return {
+        vid: upload_info.data.vid,
+        url: `https://sf16-sg-default.akamaized.net/obj/${upload_info.data.uri}`
+      }
+    } else {
+      throw Error
+    }
+  } catch (e) {
+    console.log(e.toString())
+  }
+}
+
+const upload_file = async url => {
+  try {
+    const file_url = url
+    const file = await http({
+      method: 'GET',
+      url: file_url,
+      responseType: 'arraybuffer'
+    })
+    const hash = crc32(file.data)
+    const upload_info = await http({
+      method: 'GET',
+      url: 'https://api.xs.cx/upload/sg'
+    })
+    const upload_result = await http({
+      method: 'POST',
+      url: upload_info.data.url,
+      headers: {
+        'content-crc32': hash,
+        'authorization': upload_info.data.authorization
+      },
+      data: file.data
+    })
+    if (upload_result.status == 200) {
+      return {
+        vid: upload_info.data.vid,
+        url: `https://sf16-sg-default.akamaized.net/obj/${upload_info.data.uri}`
+      }
+    } else {
+      throw Error
+    }
+  } catch (e) {
+    console.log(e.toString())
+  }
+}
+
+const m3u8_parse = async url => {
+  while (true) {
+    try {
+      const m3u8_file = await http({
+        method: 'GET',
+        url: url
+      })
+      if (m3u8_file.status != 200) {
+        console.log(`[m3u8加载失败] ${url}`)
+        return
+      }
+      let text = m3u8_file.data
+      const is_m3u8 = m3u8_file.data.match(/\n.*?\.m3u8(\n|$)/gim)?.at(0)
+      if (is_m3u8) {
+        let new_url
+        if (/^\nhttp/i.test(url)) {
+          new_url = is_m3u8.replace('\n', '')
+        } else {
+          new_url = url.replace(url.split('/').pop(), is_m3u8.replace('\n', ''))
+        }
+        text = m3u8_parse(new_url)
+      } else {
+        const queue = text.match(/\n.*.(ts|png|jpg|jpeg|gif|webp)/gim)
+        while (queue.length) {
+          await Promise.all(queue.splice(0, 500).map(async item => {
+            let ts_url
+            if (/^\nhttp/i.test(item)) {
+              ts_url = item.replace('\n', '')
+            } else {
+              ts_url = url.replace(url.split('/').pop(), item.replace('\n', ''))
+            }
+            let upload_result
+            while (!upload_result) {
+              try {
+                const result = await upload_file(ts_url)
+                if (/^http/i.test(result.url)) {
+                  upload_result = result.url
+                  // console.log({
+                  //   a: ts_url,
+                  //   b: upload_result
+                  // })
+                } else {
+                  console.log(`[上传失败] ${url}`)
+                }
+              } catch (e) {
+                console.log(e, ts_url)
+              }
+            }
+            text = text.replace(item, `\n${upload_result}`);
+          }))
+        }
+      }
+      return text
+    } catch (e) {
+      console.log(e)
+    }
+  }
+}
+
+app.get('*', async (req, res) => {
+  try {
+    if (/favicon.ico/.test(req.path)) return
+    res.send(await upload_buffer(await m3u8_parse(req.path.replace(/^\//, ''))))
+  } catch (e) {
+    res.send(e.toString())
+  }
+})
+
+app.listen(port, async () => {
+  console.log(`http://localhost:${port}`)
+})

package.json

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