Function ensureBackend

apps/sim/lib/uploads/core/storage-service.ts:284–291

()

  const drainPending = (): Buffer<ArrayBuffer> => Buffer.concat(pendingChunks, pendingBytes)

  const ensureBackend = async (): Promise<MultipartBackend> => {
    if (!backend) {
      backend = USE_BLOB_STORAGE
        ? await createBlobBackend(key, createBlobConfig(config), contentType)
        : await createS3Backend(key, createS3Config(config), contentType, context)
    }
    return backend
  }

  const dispatchPart = async (body: Buffer): Promise<void> => {
    // Bound concurrency: wait for a free slot before starting another part.