Viber

POST https://api.bitpanyun.com/v1/messages/viber
Content-Type: application/json
Authorization: Bearer YOUR_API_KEY

{
  "to": "USER_ID",
  "from": "YOUR_BOT_ID",
  "type": "text",
  "text": "Hello from PantheonCloud Viber integration!",
  "reply_url": "https://your-server.com/webhook"
}

{
  "event": "message",
  "timestamp": 1626357600000,
  "message_token": "1234567890123456789",
  "sender": {
    "id": "VIBER_USER_ID",
    "name": "John Doe",
    "avatar": "https://example.com/avatar.jpg"
  },
  "message": {
    "type": "text",
    "text": "Hello, I need help",
    "tracking_data": "campaign-123"
  },
  "message_id": "msg_abc123def456",
  "channel": "viber"
}

const express = require('express');
const app = express();
app.use(express.json());

// Viber webhook endpoint
app.post('/webhook/viber', (req, res) => {
  const webhookData = req.body;
  
  // Log the incoming webhook data
  console.log('Received Viber webhook:', webhookData);
  
  // Handle different event types
  switch (webhookData.event) {
    case 'message':
      // Process incoming message
      handleIncomingMessage(webhookData);
      break;
      
    case 'delivered':
      // Handle message delivery confirmation
      updateMessageStatus(webhookData.message_token, 'delivered');
      break;
      
    case 'seen':
      // Handle message seen confirmation
      updateMessageStatus(webhookData.message_token, 'seen');
      break;
      
    case 'failed':
      // Handle message failure
      handleMessageFailure(webhookData);
      break;
      
    case 'conversation_started':
      // Handle new conversation
      welcomeNewUser(webhookData.sender);
      break;
  }
  
  // Always respond with 200 OK to acknowledge receipt
  res.status(200).send({ status: 'ok' });
});

function handleIncomingMessage(webhookData) {
  const userMessage = webhookData.message.text;
  const userId = webhookData.sender.id;
  
  // Process message and prepare response
  // This is where you would implement your business logic
  console.log(`User ${userId} sent: ${userMessage}`);
  
  // Example: Send a reply using the PantheonCloud API
  sendReply(userId, `Thank you for your message: ${userMessage}`);
}

function sendReply(userId, message) {
  // Implement API call to send reply through PantheonCloud
  // ...
}

app.listen(3000, () => {
  console.log('Webhook server running on port 3000');
});