copyObject.ts

import { FastifyInstance, FastifyRequest } from 'fastify'
import { FromSchema } from 'json-schema-to-ts'
import { createDefaultSchema } from '../../routes-helper'
import { AuthenticatedRequest } from '../../types'
import { ROUTE_OPERATIONS } from '../operations'
import { parseUserMetadata } from '@storage/uploader'
import { objectSchema } from '@storage/schemas'

const copyRequestBodySchema = {
  type: 'object',
  properties: {
    bucketId: { type: 'string', examples: ['avatars'] },
    sourceKey: { type: 'string', examples: ['folder/source.png'] },
    destinationBucket: { type: 'string', examples: ['users'] },
    destinationKey: { type: 'string', examples: ['folder/destination.png'] },
    metadata: {
      type: 'object',
      properties: {
        cacheControl: { type: 'string' },
        mimetype: { type: 'string' },
      },
    },
    copyMetadata: { type: 'boolean', examples: [true] },
  },
  required: ['sourceKey', 'bucketId', 'destinationKey'],
} as const
const successResponseSchema = {
  type: 'object',
  properties: {
    Id: { type: 'string' },
    Key: { type: 'string', examples: ['folder/destination.png'] },
    ...objectSchema.properties,
  },
  required: ['Key'],
}
interface copyRequestInterface extends AuthenticatedRequest {
  Body: FromSchema<typeof copyRequestBodySchema>
}

export default async function routes(fastify: FastifyInstance) {
  const summary = 'Copies an object'

  const schema = createDefaultSchema(successResponseSchema, {
    body: copyRequestBodySchema,
    summary,
    tags: ['object'],
  })

  fastify.post<copyRequestInterface>(
    '/copy',
    {
      schema,
      config: {
        operation: { type: ROUTE_OPERATIONS.COPY_OBJECT },
        resources: (req: FastifyRequest<copyRequestInterface>) => {
          const { sourceKey, destinationKey, bucketId, destinationBucket } = req.body
          return [`${bucketId}/${sourceKey}`, `${destinationBucket || bucketId}/${destinationKey}`]
        },
      },
    },
    async (request, response) => {
      const { sourceKey, destinationKey, bucketId, destinationBucket, metadata } = request.body

      const destinationBucketId = destinationBucket || bucketId
      const userMetadata = request.headers['x-metadata']

      const result = await request.storage.from(bucketId).copyObject({
        sourceKey,
        destinationBucket: destinationBucketId,
        destinationKey,
        owner: request.owner,
        userMetadata:
          typeof userMetadata === 'string' ? parseUserMetadata(userMetadata) : undefined,
        metadata: metadata,
        copyMetadata: request.body.copyMetadata ?? true,
        upsert: request.headers['x-upsert'] === 'true',
        signal: request.signals.disconnect.signal,
      })

      return response.status(result.httpStatusCode ?? 200).send({
        // Deprecated, remove in next major
        Id: result.destObject.id,
        Key: `${destinationBucketId}/${destinationKey}`,

        ...result.destObject,
      })
    }
  )
}