Function uploadSourceMaps

src/crashlytics/sourcemap.ts:250–297

(
  mappings: SourceMapMapping[],
  request: {
    projectId: string;
    bucketName: string;
    appVersion: string;
    options: CommandOptions;
  },
)

 * Orchestrates direct parallel uploads with safe rate limiting concurrency checks and retry actions.
 */
export async function uploadSourceMaps(
  mappings: SourceMapMapping[],
  request: {
    projectId: string;
    bucketName: string;
    appVersion: string;
    options: CommandOptions;
  },
): Promise<UploadResult> {
  const { projectId, bucketName, appVersion, options } = request;
  const limit = pLimit(CONCURRENCY);
  const results = await Promise.all(
    mappings.map((mapping) =>
      limit(async () => {
        const uploadRequest: UploadRequest = {
          projectId,
          mappingFile: mapping.mapFilePath,
          obfuscatedFilePath: mapping.obfuscatedFilePath,
          bucketName,
          appVersion,
          options,
        };
        let success = await uploadMap(uploadRequest, 1);
        if (!success) {
          // Wait 5s and retry
          await new Promise((res) => setTimeout(res, options.retryDelay || 5000));
          success = await uploadMap(uploadRequest);
        }
        return success;
      }),
    ),
  );

  let successCount = 0;
  const failedFiles: string[] = [];
  for (const [i, success] of results.entries()) {
    if (success) {
      successCount++;
    } else {
      failedFiles.push(mappings[i].mapFilePath);
    }
  }

  return {
    successCount,
    failedFiles,
  };
}

/**
 * Prepares zip archive bundle assets and performs file upload tasks to Google Cloud Storage.