Function getFileMetadata

apps/sim/lib/uploads/core/storage-client.ts:28–97

(
  key: string,
  customConfig?: StorageConfig
)

 * @returns File metadata object with userId, workspaceId, originalName, uploadedAt, etc.
 */
export async function getFileMetadata(
  key: string,
  customConfig?: StorageConfig
): Promise<Record<string, string>> {
  const { getFileMetadataByKey } = await import('../server/metadata')
  const metadataRecord = await getFileMetadataByKey(key)

  if (metadataRecord) {
    return {
      userId: metadataRecord.userId,
      workspaceId: metadataRecord.workspaceId || '',
      originalName: metadataRecord.originalName,
      uploadedAt: metadataRecord.uploadedAt.toISOString(),
      purpose: metadataRecord.context,
    }
  }

  if (USE_BLOB_STORAGE) {
    const { getBlobServiceClient } = await import('@/lib/uploads/providers/blob/client')
    const { BLOB_CONFIG } = await import('@/lib/uploads/config')

    let blobServiceClient = await getBlobServiceClient()
    let containerName = BLOB_CONFIG.containerName

    if (customConfig) {
      const { BlobServiceClient, StorageSharedKeyCredential } = await import('@azure/storage-blob')
      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
        )
      }
      containerName = customConfig.containerName || containerName
    }

    const containerClient = blobServiceClient.getContainerClient(containerName)
    const blockBlobClient = containerClient.getBlockBlobClient(key)
    const properties = await blockBlobClient.getProperties()
    return properties.metadata || {}
  }

  if (USE_S3_STORAGE) {
    const { getS3Client } = await import('@/lib/uploads/providers/s3/client')
    const { HeadObjectCommand } = await import('@aws-sdk/client-s3')
    const { S3_CONFIG } = await import('@/lib/uploads/config')

    const s3Client = getS3Client()
    const bucket = customConfig?.bucket || S3_CONFIG.bucket

    if (!bucket) {
      throw new Error('S3 bucket not configured')
    }