import {
  initializeS3Client,
  uploadToS3,
  downloadFromS3,
  deleteFromS3,
  listFromS3,
  getSignedUrlForS3,
  getPublicUrl,
  batchDeleteFromS3,
} from '@xenterprises/fastify-ximagepipeline/s3'

import { initializeS3Client, uploadToS3, getPublicUrl } from '@xenterprises/fastify-ximagepipeline/s3'

const r2Config = {
  endpoint: process.env.R2_ENDPOINT,
  accessKeyId: process.env.R2_ACCESS_KEY_ID,
  secretAccessKey: process.env.R2_SECRET_ACCESS_KEY,
  bucket: process.env.R2_BUCKET,
}

const client = initializeS3Client(r2Config)

const buffer = fs.readFileSync('./thumbnail.webp')
await uploadToS3(client, r2Config.bucket, 'media/thumb.webp', buffer, {
  contentType: 'image/webp',
  cacheControl: 'public, max-age=31536000',
})

const url = getPublicUrl(r2Config, 'media/thumb.webp')
console.log(url) // https://r2.example.com/my-bucket/media/thumb.webp

import { initializeS3Client, getSignedUrlForS3 } from '@xenterprises/fastify-ximagepipeline/s3'

const client = initializeS3Client(r2Config)

fastify.get('/originals/:key', async (request, reply) => {
  const url = await getSignedUrlForS3(
    client,
    r2Config.bucket,
    `originals/${request.params.key}`,
    900 // 15 minutes
  )
  return reply.redirect(url)
})

import { initializeS3Client, batchDeleteFromS3 } from '@xenterprises/fastify-ximagepipeline/s3'

const client = initializeS3Client(r2Config)

const { deleted } = await batchDeleteFromS3(
  client,
  r2Config.bucket,
  `staging/user-${userId}/`
)

console.log(`Removed ${deleted} staging objects`)

import { initializeS3Client, downloadFromS3, uploadToS3 } from '@xenterprises/fastify-ximagepipeline/s3'
import { processImage } from '@xenterprises/fastify-ximagepipeline/image'

const client = initializeS3Client(r2Config)

const original = await downloadFromS3(client, r2Config.bucket, 'originals/photo.jpg')
const { variants } = await processImage(original, 'gallery', pluginConfig)

for (const [name, buf] of Object.entries(variants)) {
  await uploadToS3(client, r2Config.bucket, `media/photo-${name}.webp`, buf, {
    contentType: 'image/webp',
  })
}

import: "@xenterprises/fastify-ximagepipeline/s3"
use-when: >
  When you need direct S3/R2 operations (upload, download, delete, list, signed URLs)
  outside of the plugin's automatic pipeline — e.g. in migration scripts, custom workers,
  or tooling that shares the same R2 bucket as the image pipeline.
functions:
  - initializeS3Client: Create an S3Client from R2/S3 config
  - uploadToS3: Upload a buffer with metadata and cache headers
  - downloadFromS3: Download an object as a Buffer
  - deleteFromS3: Delete a single object by key
  - listFromS3: List objects by key prefix
  - getSignedUrlForS3: Generate a temporary pre-signed URL (default 1 hour)
  - getPublicUrl: Build a public URL without signing
  - batchDeleteFromS3: Delete up to 1000 objects by prefix in one call