// Using @azure/storage-blob
import { BlobServiceClient, StorageSharedKeyCredential } from '@azure/storage-blob'

const accountName = process.env.AZURE_STORAGE_ACCOUNT_NAME || ''
const accountKey = process.env.AZURE_STORAGE_ACCOUNT_KEY || ''

const sharedKeyCredential = new StorageSharedKeyCredential(accountName, accountKey)
const blobServiceClient = new BlobServiceClient(
  `https://${accountName}.blob.core.windows.net`,
  sharedKeyCredential
)

const containerClient = blobServiceClient.getContainerClient(
  process.env.AZURE_CONTAINER_NAME || 'mycontainer'
)

// Create container
await containerClient.createIfNotExists({
  access: 'blob', // 'blob', 'container', or 'private'
})

// Upload blob
const blockBlobClient = containerClient.getBlockBlobClient('path/to/file.jpg')
await blockBlobClient.upload(fileBuffer, fileBuffer.length, {
  blobHTTPHeaders: {
    blobContentType: 'image/jpeg',
  },
  metadata: {
    userId: '123',
    originalName: 'photo.jpg',
  },
})

// Download blob
const downloadResponse = await blockBlobClient.download()
const fileContent = await streamToBuffer(downloadResponse.readableStreamBody)

// Delete blob
await blockBlobClient.delete()

// List blobs
for await (const blob of containerClient.listBlobsFlat()) {
  console.log(blob.name, blob.properties.contentLength)
}

// Generate SAS URL
import { generateBlobSASQueryParameters, BlobSASPermissions, StorageSharedKeyCredential } from '@azure/storage-blob'

const sasToken = generateBlobSASQueryParameters(
  {
    containerName: 'mycontainer',
    blobName: 'path/to/file.jpg',
    permissions: BlobSASPermissions.parse('r'), // read
    startsOn: new Date(),
    expiresOn: new Date(new Date().valueOf() + 3600 * 1000), // 1 hour
  },
  sharedKeyCredential
).toString()

const sasUrl = `https://${accountName}.blob.core.windows.net/mycontainer/path/to/file.jpg?${sasToken}`

// Copy blob
const sourceBlobClient = containerClient.getBlockBlobClient('source/file.jpg')
const destBlobClient = containerClient.getBlockBlobClient('dest/file.jpg')
await destBlobClient.beginCopyFromURL(sourceBlobClient.url)

// Set blob metadata
await blockBlobClient.setMetadata({
  category: 'profile',
  uploadedBy: 'user-123',
})

// Get blob properties
const properties = await blockBlobClient.getProperties()
console.log(properties.contentType, properties.contentLength, properties.metadata)

async function uploadFile(file: Buffer, filename: string, userId: string) {
  const blobName = `users/${userId}/${Date.now()}-${filename}`
  const blobClient = containerClient.getBlockBlobClient(blobName)
  
  await blobClient.upload(file, file.length, {
    blobHTTPHeaders: {
      blobContentType: getContentType(filename),
    },
    metadata: {
      userId,
      originalName: filename,
      uploadedAt: new Date().toISOString(),
    },
  })
  
  return {
    blobName,
    url: blobClient.url,
  }
}

async function generateTemporaryUrl(blobName: string, expiresInMinutes: number = 60) {
  const blobClient = containerClient.getBlockBlobClient(blobName)
  const sasToken = generateBlobSASQueryParameters(
    {
      containerName: containerClient.containerName,
      blobName,
      permissions: BlobSASPermissions.parse('r'),
      expiresOn: new Date(Date.now() + expiresInMinutes * 60 * 1000),
    },
    sharedKeyCredential
  ).toString()
  
  return `${blobClient.url}?${sasToken}`
}

AZURE_STORAGE_ACCOUNT_NAME=myaccount
AZURE_STORAGE_ACCOUNT_KEY=your-account-key
AZURE_CONTAINER_NAME=mycontainer
AZURE_STORAGE_CONNECTION_STRING=DefaultEndpointsProtocol=https;AccountName=...

import { DefaultAzureCredential } from '@azure/identity'

const blobServiceClient = new BlobServiceClient(
  `https://${accountName}.blob.core.windows.net`,
  new DefaultAzureCredential()
)