Method sendLocalUpload

music_hub/music_hub.ts:858–1007

(
    client: any,
    msg: Api.Message,
    song: ApiSong,
    urlInfo: SongUrlInfo,
    config: MusicHubConfig,
    caption: string,
    session?: SearchSession,
    onProgress?: TransferProgressReporter
  )

          clearInterval(timer);
          timer = undefined;
        }
        await sendLatest(true);
        await updateQueue.catch(() => undefined);
      },
    };
  }

  private async sendLocalUpload(
    client: any,
    msg: Api.Message,
    song: ApiSong,
    urlInfo: SongUrlInfo,
    config: MusicHubConfig,
    caption: string,
    session?: SearchSession,
    onProgress?: TransferProgressReporter
  ): Promise<void> {
    let tempFilePath = "";
    try {
      const response = await axios.get<any>(urlInfo.url, {
        responseType: "stream",
        timeout: DOWNLOAD_TIMEOUT_MS,
        maxContentLength: config.maxUploadBytes,
        maxBodyLength: config.maxUploadBytes,
        headers: {
          "User-Agent": "TeleBox-MusicHub/1.0",
        },
      });

      const reader = response.data as any;
      if (!reader || typeof reader.pipe !== "function") {
        throw new Error("下载响应不是可读流");
      }

      const contentLength = Number(response.headers?.["content-length"]);
      const totalBytes =
        Number.isFinite(contentLength) && contentLength > 0
          ? contentLength
          : urlInfo.size;
      if (totalBytes && totalBytes > config.maxUploadBytes) {
        throw new Error(`文件过大 (${formatBytes(totalBytes)})，超过上传限制 ${formatBytes(config.maxUploadBytes)}`);
      }
      const extension = detectAudioExtension(
        urlInfo.url,
        String(response.headers?.["content-type"] || "")
      );
      const filename = `${sanitizeFilename(`${song.name}-${formatArtists(song.artist)}`)}.${extension}`;
      tempFilePath = path.join(TEMP_DIR, `${Date.now()}_${filename}`);
      let downloadedBytes = 0;

      await onProgress?.({
        stage: "download",
        loadedBytes: 0,
        totalBytes,
        force: true,
      });

      await new Promise<void>((resolve, reject) => {