Push Notifications

public interface IPushNotificationService {
    static final String BEAN_NAME = "push.notification.service";
    
    public enum PushNotificationServiceTypes {
        FIREBASE_CLOUD_MESSAGING("fcm"),
        APPLE_PUSH_NOTIFICATION("apn");
        
        private String name;
        
        PushNotificationServiceTypes(String name) {
            this.name = name;
        }
        
        @Override
        public String toString() {
            return this.name;
        }
    }
    
    /**
     * Send notification to a topic
     */
    Result sendNotification(String topic, JSONObject jsonMessage, String serviceName);
    
    /**
     * Send notification to both FCM and APN
     */
    Result sendNotification(String topic, JSONObject jsonMessage);
    
    /**
     * Send notification to specific subscriber IDs
     */
    Result sendNotification(List<String> subscriberIds, JSONObject jsonMessage);
    
    /**
     * Send notification to specific subscribers via specific service
     */
    Result sendNotification(List<String> subscriberIds, JSONObject jsonMessage, String serviceName);
}

{
  "pushNotificationEnabled": true,
  "firebaseServiceAccountFile": "/usr/local/antmedia/webapps/LiveApp/WEB-INF/firebase-service-account.json"
}

{
  "apnEnabled": true,
  "apnKeyPath": "/usr/local/antmedia/webapps/LiveApp/WEB-INF/apn-key.p8",
  "apnKeyId": "YOUR_KEY_ID",
  "apnTeamId": "YOUR_TEAM_ID",
  "apnBundleId": "com.yourcompany.yourapp",
  "apnProduction": false
}

# Send to all subscribers of a topic
curl -X POST "http://localhost:5080/LiveApp/rest/v2/push-notification/send" \
  -H "Content-Type: application/json" \
  -d '{
    "topic": "stream-updates",
    "message": {
      "title": "Stream Started",
      "body": "Your favorite streamer is now live!",
      "streamId": "stream123"
    },
    "service": "fcm"
  }'

import io.antmedia.pushnotification.IPushNotificationService;
import org.json.simple.JSONObject;

public class NotificationExample {
    
    public void notifyStreamStart(String streamId, String streamerName) {
        IPushNotificationService pushService = 
            (IPushNotificationService) context.getBean(
                IPushNotificationService.BEAN_NAME);
        
        JSONObject message = new JSONObject();
        message.put("title", "Stream Started");
        message.put("body", streamerName + " is now live!");
        message.put("streamId", streamId);
        message.put("action", "watch-stream");
        
        // Send to topic
        Result result = pushService.sendNotification(
            "stream-" + streamId, 
            message
        );
        
        if (result.isSuccess()) {
            logger.info("Notification sent successfully");
        }
    }
}

{
  "listenerHookURL": "http://localhost:3000/webhook",
  "pushNotificationEnabled": true
}

import com.google.firebase.messaging.FirebaseMessaging

class MainActivity : AppCompatActivity() {
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        
        // Get FCM token
        FirebaseMessaging.getInstance().token.addOnCompleteListener { task ->
            if (task.isSuccessful) {
                val token = task.result
                // Send token to your server for subscriber management
                registerDevice(token)
            }
        }
        
        // Subscribe to topics
        FirebaseMessaging.getInstance().subscribeToTopic("stream-updates")
    }
    
    private fun registerDevice(token: String) {
        // Send to AMS or your backend
        // Store token with user ID for targeted notifications
    }
}

import UIKit
import UserNotifications
import Firebase

@UIApplicationMain
class AppDelegate: UIResponder, UIApplicationDelegate {
    
    func application(_ application: UIApplication,
                    didFinishLaunchingWithOptions launchOptions: [UIApplication.LaunchOptionsKey: Any]?) -> Bool {
        
        // Configure Firebase
        FirebaseApp.configure()
        
        // Request notification permissions
        UNUserNotificationCenter.current().requestAuthorization(options: [.alert, .badge, .sound]) { granted, error in
            if granted {
                DispatchQueue.main.async {
                    application.registerForRemoteNotifications()
                }
            }
        }
        
        return true
    }
    
    func application(_ application: UIApplication,
                    didRegisterForRemoteNotificationsWithDeviceToken deviceToken: Data) {
        // Send token to server
        let token = deviceToken.map { String(format: "%02.2hhx", $0) }.joined()
        registerDevice(token: token)
    }
    
    func userNotificationCenter(_ center: UNUserNotificationCenter,
                               didReceive response: UNNotificationResponse,
                               withCompletionHandler completionHandler: @escaping () -> Void) {
        
        let userInfo = response.notification.request.content.userInfo
        
        if let streamId = userInfo["streamId"] as? String,
           let action = userInfo["action"] as? String {
            
            switch action {
            case "watch-stream":
                openStream(streamId: streamId)
            default:
                break
            }
        }
        
        completionHandler()
    }
}