Function downloadSteam

daemon/src/tools/steam_cmd.ts:22–64

(url: string)

}

export async function downloadSteam(url: string): Promise<string> {
  const tmpPath = path.normalize(path.join(process.cwd(), "lib", "tmp_steamcmd.zip"));
  logger.info(`Starting Steam command line tool download: ${url} --> ${tmpPath}`);

  return new Promise(async (resolve, reject) => {
    try {
      // Ensure target directory exists
      const targetDir = path.dirname(tmpPath);
      if (!fs.existsSync(targetDir)) {
        fs.mkdirsSync(targetDir);
      }

      // Remove existing file if it exists
      if (fs.existsSync(tmpPath)) {
        fs.removeSync(tmpPath);
      }

      // Download file
      const response = await axios<Readable>({
        url: url,
        responseType: "stream",
        timeout: 1000 * 60 * 10, // 10 minutes timeout
        headers: getCommonHeaders(url)
      });

      // Create write stream
      const writeStream = fs.createWriteStream(path.normalize(tmpPath));

      // Use pipeline to handle streams
      pipeline(response.data, writeStream, async (err) => {
        if (err) {
          fs.remove(tmpPath, () => {});
          reject(err);
        } else {
          fs.chmod(tmpPath, 0o755, () => {});
          resolve(tmpPath);
        }
      });
    } catch (error: any) {
      reject(error.message || error);
    }
  });
}