Sending Media Messages

const axios = require('axios');
const FormData = require('form-data');
const fs = require('fs');

class CMzonMediaAPI {
  constructor(apiToken) {
    this.apiToken = apiToken;
    this.baseURL = 'https://api.cmzon.com/v1';
  }

  async uploadMedia(filePath, mediaType) {
    const form = new FormData();
    form.append('file', fs.createReadStream(filePath));
    form.append('type', mediaType);

    try {
      const response = await axios.post(`${this.baseURL}/media`, form, {
        headers: {
          ...form.getHeaders(),
          'Authorization': `Bearer ${this.apiToken}`
        }
      });
      return response.data.id;
    } catch (error) {
      throw new Error(`Media upload failed: ${error.message}`);
    }
  }

  async sendImageMessage(to, mediaId, caption = '') {
    try {
      const response = await axios.post(`${this.baseURL}/messages`, {
        to: to,
        type: 'image',
        image: {
          id: mediaId,
          caption: caption
        }
      }, {
        headers: {
          'Authorization': `Bearer ${this.apiToken}`,
          'Content-Type': 'application/json'
        }
      });
      return response.data;
    } catch (error) {
      throw new Error(`Message send failed: ${error.message}`);
    }
  }

  async sendMediaMessage(to, filePath, mediaType, caption = '') {
    // Upload media first
    const mediaId = await this.uploadMedia(filePath, mediaType);
    
    // Send message with media
    const messageType = this.getMediaMessageType(mediaType);
    return await this.sendMessage(to, mediaId, messageType, caption);
  }

  getMediaMessageType(mediaType) {
    if (mediaType.startsWith('image/')) return 'image';
    if (mediaType.startsWith('video/')) return 'video';
    if (mediaType.startsWith('audio/')) return 'audio';
    return 'document';
  }
}

// Usage
const api = new CMzonMediaAPI(process.env.CMZON_API_TOKEN);

// Send an image
api.sendMediaMessage('+1234567890', './product.jpg', 'image/jpeg', 'Check out our new product!')
  .then(result => console.log('Image sent:', result))
  .catch(error => console.error('Error:', error.message));

import requests
import os
from typing import Dict, Any, Optional

class CMzonMediaAPI:
    def __init__(self, api_token: str):
        self.api_token = api_token
        self.base_url = 'https://api.cmzon.com/v1'
        self.headers = {
            'Authorization': f'Bearer {api_token}'
        }
    
    def upload_media(self, file_path: str, media_type: str) -> str:
        """Upload media file and return media ID"""
        url = f'{self.base_url}/media'
        
        with open(file_path, 'rb') as file:
            files = {'file': file}
            data = {'type': media_type}
            
            try:
                response = requests.post(url, files=files, data=data, headers=self.headers)
                response.raise_for_status()
                return response.json()['id']
            except requests.exceptions.RequestException as e:
                raise Exception(f"Media upload failed: {e}")
    
    def send_media_message(self, to: str, media_id: str, 
                          message_type: str, caption: str = '') -> Dict[str, Any]:
        """Send media message using uploaded media ID"""
        url = f'{self.base_url}/messages'
        
        # Determine message structure based on type
        message_data = {
            'to': to,
            'type': message_type
        }
        
        if message_type == 'image':
            message_data['image'] = {'id': media_id, 'caption': caption}
        elif message_type == 'video':
            message_data['video'] = {'id': media_id, 'caption': caption}
        elif message_type == 'audio':
            message_data['audio'] = {'id': media_id}
        elif message_type == 'document':
            message_data['document'] = {'id': media_id, 'caption': caption}
        
        try:
            response = requests.post(url, json=message_data, headers=self.headers)
            response.raise_for_status()
            return response.json()
        except requests.exceptions.RequestException as e:
            raise Exception(f"Message send failed: {e}")
    
    def send_file_message(self, to: str, file_path: str, 
                         media_type: str, caption: str = '') -> Dict[str, Any]:
        """Complete flow: upload media and send message"""
        # Upload media
        media_id = self.upload_media(file_path, media_type)
        
        # Determine message type
        message_type = self.get_media_message_type(media_type)
        
        # Send message
        return self.send_media_message(to, media_id, message_type, caption)
    
    def get_media_message_type(self, media_type: str) -> str:
        """Determine WhatsApp message type from media type"""
        if media_type.startswith('image/'):
            return 'image'
        elif media_type.startswith('video/'):
            return 'video'
        elif media_type.startswith('audio/'):
            return 'audio'
        else:
            return 'document'

# Usage
api = CMzonMediaAPI(os.getenv('CMZON_API_TOKEN'))

try:
    # Send an image
    result = api.send_file_message(
        to='+1234567890',
        file_path='./product.jpg',
        media_type='image/jpeg',
        caption='Check out our new product!'
    )
    print(f"Message sent: {result}")
except Exception as e:
    print(f"Error: {e}")