Socialflow/server/services/cloudinary.ts

import { v2 as cloudinary } from 'cloudinary';
import { storage } from '../storage';

class CloudinaryService {
  async uploadMedia(
    file: Buffer | string,
    fileName: string,
    userId: string,
    mimeType: string
  ): Promise<{
    publicId: string;
    originalUrl: string;
    facebookFeedUrl: string | null;
    instagramFeedUrl: string | null;
    instagramStoryUrl: string | null;
  }> {
    // Get any available Cloudinary config (shared across all users)
    const config = await storage.getAnyCloudinaryConfig();

    if (!config) {
      throw new Error('Cloudinary configuration not found. Please ask an administrator to configure Cloudinary in Settings first.');
    }

    // Configure Cloudinary with user's credentials
    cloudinary.config({
      cloud_name: config.cloudName,
      api_key: config.apiKey,
      api_secret: config.apiSecret,
      secure: true,
    });

    const isVideo = mimeType.startsWith('video/');

    // Define eager transformations for images (generated during upload)
    // Note: Eager transformations are not applied to videos in this flow to avoid timeouts or huge processing
    const eagerTransformations = !isVideo ? [
      { width: 1080, height: 1080, crop: 'fill', gravity: 'center' },                        // Facebook Feed (square, no borders)
      { width: 1080, height: 1080, crop: 'pad', gravity: 'center', background: 'auto' },     // Instagram Feed
      { width: 1080, height: 1920, crop: 'pad', gravity: 'center', background: 'auto' }      // Instagram Story
    ] : undefined;

    const uploadOptions = {
      folder: 'social-flow',
      public_id: `${Date.now()}-${fileName.replace(/\.[^/.]+$/, '')}`,
      resource_type: isVideo ? 'video' : 'image',
      eager: eagerTransformations,
      eager_async: false, // Generate transformations immediately
    };

    let uploadResult;

    if (typeof file === 'string') {
      // Upload from file path (streamed by SDK)
      uploadResult = await cloudinary.uploader.upload(file, {
        ...uploadOptions,
        resource_type: isVideo ? 'video' : 'image', // Type assertion for SDK
      } as any);
    } else {
      // Upload from buffer (memory)
      uploadResult = await new Promise<any>((resolve, reject) => {
        const uploadStream = cloudinary.uploader.upload_stream(
          uploadOptions as any,
          (error, result) => {
            if (error) reject(error);
            else resolve(result);
          }
        );
        uploadStream.end(file);
      });
    }

    const publicId = uploadResult.public_id;
    const originalUrl = uploadResult.secure_url;

    // Extract eager transformation URLs (generated by Cloudinary during upload)
    let facebookFeedUrl = null;
    let instagramFeedUrl = null;
    let instagramStoryUrl = null;

    if (!isVideo && uploadResult.eager && uploadResult.eager.length === 3) {
      facebookFeedUrl = uploadResult.eager[0].secure_url;      // Facebook Feed (1200x630)
      instagramFeedUrl = uploadResult.eager[1].secure_url;     // Instagram Feed (1080x1080)
      instagramStoryUrl = uploadResult.eager[2].secure_url;    // Instagram Story (1080x1920)
    }

    return {
      publicId,
      originalUrl,
      facebookFeedUrl,
      instagramFeedUrl,
      instagramStoryUrl,
    };
  }

  async deleteMedia(publicId: string, userId: string, mediaType: 'image' | 'video'): Promise<void> {
    // Get any available Cloudinary config (shared across all users)
    const config = await storage.getAnyCloudinaryConfig();

    if (!config) {
      throw new Error('Cloudinary configuration not found. Please ask an administrator to configure Cloudinary in Settings first.');
    }

    cloudinary.config({
      cloud_name: config.cloudName,
      api_key: config.apiKey,
      api_secret: config.apiSecret,
      secure: true,
    });

    await cloudinary.uploader.destroy(publicId, {
      resource_type: mediaType,
    });
  }

  async uploadStoryImageWithText(buffer: Buffer, originalFileName: string): Promise<string> {
    const config = await storage.getAnyCloudinaryConfig();

    if (!config) {
      throw new Error('Cloudinary configuration not found. Please ask an administrator to configure Cloudinary in Settings first.');
    }

    cloudinary.config({
      cloud_name: config.cloudName,
      api_key: config.apiKey,
      api_secret: config.apiSecret,
      secure: true,
    });

    const uploadResult = await new Promise<any>((resolve, reject) => {
      const uploadStream = cloudinary.uploader.upload_stream(
        {
          folder: 'social-flow/stories',
          public_id: `story-${Date.now()}-${originalFileName.replace(/\.[^/.]+$/, '')}`,
          resource_type: 'image',
        },
        (error, result) => {
          if (error) reject(error);
          else resolve(result);
        }
      );

      uploadStream.end(buffer);
    });

    return uploadResult.secure_url;
  }

  async uploadLogo(buffer: Buffer, fileName: string): Promise<{ publicId: string; url: string }> {
    const config = await storage.getAnyCloudinaryConfig();

    if (!config) {
      throw new Error('Cloudinary configuration not found. Please ask an administrator to configure Cloudinary in Settings first.');
    }

    cloudinary.config({
      cloud_name: config.cloudName,
      api_key: config.apiKey,
      api_secret: config.apiSecret,
      secure: true,
    });

    const uploadResult = await new Promise<any>((resolve, reject) => {
      const uploadStream = cloudinary.uploader.upload_stream(
        {
          folder: 'social-flow/logos',
          public_id: `logo-${Date.now()}-${fileName.replace(/\.[^/.]+$/, '')}`,
          resource_type: 'image',
        },
        (error, result) => {
          if (error) reject(error);
          else resolve(result);
        }
      );

      uploadStream.end(buffer);
    });

    return {
      publicId: uploadResult.public_id,
      url: uploadResult.secure_url,
    };
  }

  async deleteLogo(publicId: string): Promise<void> {
    const config = await storage.getAnyCloudinaryConfig();

    if (!config) {
      throw new Error('Cloudinary configuration not found. Please ask an administrator to configure Cloudinary in Settings first.');
    }

    cloudinary.config({
      cloud_name: config.cloudName,
      api_key: config.apiKey,
      api_secret: config.apiSecret,
      secure: true,
    });

    await cloudinary.uploader.destroy(publicId, {
      resource_type: 'image',
    });
  }
}

export const cloudinaryService = new CloudinaryService();