Function headBlobObject

apps/sim/lib/uploads/providers/blob/client.ts:392–438

(
  key: string,
  customConfig?: BlobConfig
)

 * Returns null when the blob is missing.
 */
export async function headBlobObject(
  key: string,
  customConfig?: BlobConfig
): Promise<{ size: number; contentType?: string } | null> {
  const { BlobServiceClient, StorageSharedKeyCredential } = await import('@azure/storage-blob')
  let blobServiceClient: BlobServiceClientType
  let containerName: string

  if (customConfig) {
    if (customConfig.connectionString) {
      blobServiceClient = BlobServiceClient.fromConnectionString(customConfig.connectionString)
    } else if (customConfig.accountName && customConfig.accountKey) {
      const credential = new StorageSharedKeyCredential(
        customConfig.accountName,
        customConfig.accountKey
      )
      blobServiceClient = new BlobServiceClient(
        `https://${customConfig.accountName}.blob.core.windows.net`,
        credential
      )
    } else {
      throw new Error('Invalid custom blob configuration')
    }
    containerName = customConfig.containerName
  } else {
    blobServiceClient = await getBlobServiceClient()
    containerName = BLOB_CONFIG.containerName
  }

  const containerClient = blobServiceClient.getContainerClient(containerName)
  const blockBlobClient = containerClient.getBlockBlobClient(key)

  try {
    const properties = await blockBlobClient.getProperties()
    return {
      size: properties.contentLength ?? 0,
      contentType: properties.contentType,
    }
  } catch (err) {
    const status = (err as { statusCode?: number }).statusCode
    const code = (err as { code?: string }).code
    if (status === 404 || code === 'BlobNotFound') {
      return null
    }
    throw err
  }
}

/**
 * Delete a file from Azure Blob Storage