go-uploads

import { net } from 'electron';
import { createReadStream } from 'fs';

function uploadSingle(putUrl, filePath) {
  return new Promise((resolve, reject) => {
    const stream = createReadStream(filePath);
    const request = net.request({ method: 'PUT', url: putUrl });
    stream.on('error', reject);
    request.on('error', reject);
    request.on('response', (response) => {
      let body = '';
      response.on('data', (chunk) => (body += chunk));
      response.on('end', () => {
        if (response.statusCode === 200) resolve(JSON.parse(body));
        else reject(new Error('Upload failed: ' + response.statusCode));
      });
    });
    stream.pipe(request);
  });
}

// 分片上传（≥ 2MB）
for (let i = 0; i < chunkUrls.length; i++) {
  const start = i * chunkSize;
  const end = Math.min(start + chunkSize, totalSize);
  const stream = createReadStream(filePath,
    { start, end: end - 1 });
  await putStream(chunkUrls[i], stream);
}
// 全部传完后通知合并（必须！）
await fetch(notifyUrl, {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({ key, uploadId })
});

// 1. 获取配置
const config = await fetch('/api/upload/config', {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({ mime: file.type,
    filename: file.name, size: file.size })
});
const { data } = await config.json();

// 2. 单文件上传
await fetch(data.putUrl, {
  method: 'PUT',
  body: file   // File / Blob 直接作为 body
});

// 3. 分片上传
for (let i = 0; i < data.chunkUrls.length; i++) {
  const start = i * data.chunkSize;
  const end = Math.min(start + data.chunkSize, file.size);
  const chunk = file.slice(start, end); // Blob.slice()
  await fetch(data.chunkUrls[i], { method: 'PUT', body: chunk });
}
// 4. 通知合并
await fetch(data.notifyUrl, {
  method: 'POST',
  headers: { 'Content-Type': 'application/json' },
  body: JSON.stringify({ key: data.key, uploadId: data.uploadId })
});

// 小程序端（PHP 中转）
const getConfig = () => new Promise((resolve, reject) => {
  wx.request({
    url: 'https://your-server.com/api/upload/config',
    method: 'POST',
    data: { mime: 'image/jpeg', filename: 'photo.jpg',
            size: 102400 },
    header: { 'x-api-key': 'your-api-key' },
    success: (res) => resolve(res.data.data),
    fail: reject
  });
});

// 单文件：直接给 PHP
wx.uploadFile({
  url: 'https://your-server.com/api/upload/proxy',
  filePath: filePath, name: 'file',
  formData: { key: data.key, putUrl: data.putUrl },
  success: (res) => resolve(JSON.parse(res.data)),
  fail: reject
});

// PHP 端代理转发 PUT 到 go-uploads
public function proxyUpload() {
    $file = $this->request->file('file');
    $putUrl = $this->request->post('putUrl');
    $ch = curl_init($putUrl);
    curl_setopt($ch, CURLOPT_PUT, true);
    curl_setopt($ch, CURLOPT_INFILE,
        fopen($file->getRealPath(), 'r'));
    curl_setopt($ch, CURLOPT_INFILESIZE, $file->getSize());
    curl_exec($ch);
    curl_close($ch);
}

// Swift 单文件
var request = URLRequest(url: URL(string: putURL)!)
request.httpMethod = "PUT"
request.setValue("application/octet-stream",
  forHTTPHeaderField: "Content-Type")
let (data, response) = try await URLSession.shared
  .upload(for: request, fromFile: fileURL)

// Swift 分片
let handle = try FileHandle(forReadingFrom: fileURL)
for (index, chunkURL) in config.chunkUrls.enumerated() {
  let start = Int64(index) * config.chunkSize
  let end = min(start + config.chunkSize, fileSize)
  try handle.seek(toOffset: UInt64(start))
  let chunkData = handle.readData(ofLength: Int(end - start))
  // PUT chunkData ...
}
// 通知合并 POST {key, uploadId}

// Kotlin 单文件（OkHttp）
val requestBody = file.asRequestBody(
  "application/octet-stream".toMediaType())
val request = Request.Builder().url(putUrl)
  .put(requestBody).build()

// Kotlin 分片
for ((index, chunkUrl) in config.chunkUrls.withIndex()) {
  val start = index.toLong() * config.chunkSize
  val end = minOf(start + config.chunkSize, totalSize)
  val chunkData = file.inputStream().use { input ->
    input.skip(start); input.readBytes() }
  // PUT chunkData ...
}
// 通知合并 POST {key, uploadId}