Method upload

backend/src/upload/upload.service.ts:71–159

* Upload a file to either S3/Cloudflare R2 or local storage based on configuration * @param file File to upload (can be a GraphQL FileUpload or a Buffer) * @param mimetype File mimetype (required when uploading a Buffer) * @param subdirectory Directory path to store the file in * @return

(
    file: FileUpload | Buffer,
    mimetype?: string,
    subdirectory: string = 'uploads',
  )

   * @returns Promise with the upload result
   */
  async upload(
    file: FileUpload | Buffer,
    mimetype?: string,
    subdirectory: string = 'uploads',
  ): Promise<UploadResult> {
    // Generate filename
    const fileExtension = mimetype?.split('/')[1] || 'jpg';
    const filename = `${uuidv4()}.${fileExtension}`;
    const key = `${subdirectory}/${filename}`;

    // Handle different file input types
    if (Buffer.isBuffer(file)) {
      // Direct buffer upload
      if (!mimetype) {
        throw new Error('Mimetype is required when uploading a buffer');
      }

      if (this.s3Client) {
        // Upload to S3/Cloudflare R2
        await this.s3Client.send(
          new PutObjectCommand({
            Bucket: this.configService.s3Config.bucketName,
            Key: key,
            Body: file,
            ContentType: mimetype,
          }),
        );

        // Get the appropriate URL for the uploaded file
        const bucketUrl = this.getBucketUrl();

        return { url: path.join(bucketUrl, key), key };
      } else {
        // Upload to local storage from buffer
        const directory = path.join(this.mediaDir, subdirectory);
        if (!existsSync(directory)) {
          mkdirSync(directory, { recursive: true });
        }

        const filePath = path.join(directory, filename);

        try {
          await fs.promises.writeFile(filePath, file);
          return { url: `/media/${key}`, key };
        } catch (error) {
          throw new Error(`Failed to upload file: ${error.message}`);
        }
      }
    } else {
      // GraphQL FileUpload
      const { createReadStream, mimetype: fileMimetype } = await file;

      if (this.s3Client) {
        // Convert stream to buffer and upload to S3/Cloudflare R2
        const buffer = await this.streamToBuffer(createReadStream());

        await this.s3Client.send(
          new PutObjectCommand({