Record notification events

class MyAppService : FirebaseMessagingService() {
    override fun onMessageReceived(remoteMessage: RemoteMessage) {
        // Convert the RemoteMessage into a NotificationPayload
        val notificationPayload = NotificationPayload(NotificationContentProvider.FCM(remoteMessage.data))

        // Amplify should handle notification if it is sent from Pinpoint
        val isAmplifyMessage = Amplify.Notifications.Push.shouldHandleNotification(notificationPayload)
        if (isAmplifyMessage) {
            // let Amplify handle foreground and background message received
            Amplify.Notifications.Push.handleNotificationReceived(notificationPayload,
                { Log.i("MyAmplifyApp", "Successfully handled a notification") },
                { Log.e("MyAmplifyApp", "Error handling notification", error) }
            )
        }
    }
}

class MyAppService : FirebaseMessagingService() {
    override fun onMessageReceived(remoteMessage: RemoteMessage) {
        // Convert the RemoteMessage into a NotificationPayload
        val notificationPayload = NotificationPayload(NotificationContentProvider.FCM(remoteMessage.data))

        // Amplify should handle notification if it is sent from Pinpoint
        val isAmplifyMessage = Amplify.Notifications.Push.shouldHandleNotification(notificationPayload)
        if (isAmplifyMessage) {
            try {
                // let Amplify handle foreground and background message received
                Amplify.Notifications.Push.handleNotificationReceived(notificationPayload)
                Log.i("MyAmplifyApp", "Successfully handled a notification")
            } catch (error: PushNotificationsException) {
                Log.e("MyAmplifyApp", "Error handling notification", error)
            }
        }
    }
}

class MyAppService extends FirebaseMessagingService() {
    @Override
    public void onMessageReceived(RemoteMessage remoteMessage) {
        // Convert the RemoteMessage into a NotificationPayload
        NotificationPayload notificationPayload = NotificationPayload.builder(
            new NotificationContentProvider.FCM(remoteMessage.getData())
        ).build();

        // Amplify should handle notification if it is sent from Pinpoint
        boolean isAmplifyMessage = Amplify.Notifications.Push.shouldHandleNotification(notificationPayload);
        if (isAmplifyMessage) {
            // let Amplify handle foreground and background message received
            RxAmplify.Notifications.Push.handleNotificationReceived(notificationPayload).subscribe(
                result -> Log.i("MyAmplifyApp", "Successfully handled a notification"),
                error -> Log.e("MyAmplifyApp", "Error handling notification", error)
            );
        }
    }
}

class MyAppService : FirebaseMessagingService() {
    override fun onMessageReceived(remoteMessage: RemoteMessage) {
        // Convert the RemoteMessage into a NotificationPayload
        val notificationPayload = NotificationPayload(NotificationContentProvider.FCM(remoteMessage.data))

        // Amplify should handle notification if it is sent from Pinpoint
        val isAmplifyMessage = Amplify.Notifications.Push.shouldHandleNotification(notificationPayload)
        if (isAmplifyMessage) {
            // Record notification received with Amplify
            Amplify.Notifications.Push.recordNotificationReceived(notificationPayload,
                { Log.i("MyAmplifyApp", "Successfully recorded a notification received") },
                { Log.e("MyAmplifyApp", "Error recording notification received", error) }
            )
        }
    }
}

class MyAppService : FirebaseMessagingService() {
    override fun onMessageReceived(remoteMessage: RemoteMessage) {
        // Convert the RemoteMessage into a NotificationPayload
        val notificationPayload = NotificationPayload(NotificationContentProvider.FCM(remoteMessage.data))

        // Amplify should handle notification if it is sent from Pinpoint
        val isAmplifyMessage = Amplify.Notifications.Push.shouldHandleNotification(notificationPayload)
        if (isAmplifyMessage) {
            try {
                // let Amplify handle foreground and background message received
                Amplify.Notifications.Push.recordNotificationReceived(notificationPayload)
                Log.i("MyAmplifyApp", "Successfully recorded a notification received")
            } catch (error: PushNotificationsException) {
                Log.e("MyAmplifyApp", "Error recording notification received", error)
            }
        }
    }
}

class MyAppService extends FirebaseMessagingService() {
    @Override
    public void onMessageReceived(RemoteMessage remoteMessage) {
        // Convert the RemoteMessage into a NotificationPayload
        NotificationPayload notificationPayload = NotificationPayload.builder(
            new NotificationContentProvider.FCM(remoteMessage.getData())
        ).build();

        // Amplify should handle notification if it is sent from Pinpoint
        boolean isAmplifyMessage = Amplify.Notifications.Push.shouldHandleNotification(notificationPayload);
        if (isAmplifyMessage) {
            // let Amplify handle foreground and background message received
            RxAmplify.Notifications.Push.recordNotificationReceived(notificationPayload).subscribe(
                () -> Log.i("MyAmplifyApp", "Successfully recorded a notification received"),
                error -> Log.e("MyAmplifyApp", "Error recording notification received", error)
            );
        }
    }
}

class LaunchActivity : AppCompatActivity() {
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)

        // Get the payload from the intent
        NotificationPayload.fromIntent(intent)?.let {
            // Record notification opened when activity launches
            Amplify.Notifications.Push.recordNotificationOpened(it,
                { Log.i("MyAmplifyApp", "Successfully recorded notification opened") },
                { Log.e("MyAmplifyApp", "Error recording notification opened", error) }
            )
        }
    }
}

class LaunchActivity : AppCompatActivity() {
    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)

        try {
            // Get the payload from the intent
            NotificationPayload.fromIntent(intent)?.let {
                // Record notification opened when activity launches
                Amplify.Notifications.Push.recordNotificationOpened(it)
                Log.i("MyAmplifyApp", "Successfully recorded notification opened")
            }
        } catch (error: PushNotificationsException) {
            Log.e("MyAmplifyApp", "Error recording notification opened", error)
        }
    }
}

class LaunchActivity extends AppCompatActivity() {
    @Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        NotificationPayload payload = NotificationPayload.fromIntent(getIntent());

        if (payload != null) {
            // Record notification opened when activity launches
            RxAmplify.Notifications.Push.recordNotificationOpened(payload).subscribe(
                () -> Log.i("MyAmplifyApp", "Successfully recorded notification opened"),
                error -> Log.e("MyAmplifyApp", "Error recording notification opened", error)
            );
        }
    }
}