package com.onesignal.cordova;

import com.onesignal.OneSignal;
import com.onesignal.notifications.IPermissionObserver;
import com.onesignal.user.state.IUserStateObserver;
import com.onesignal.user.state.UserChangedState;
import com.onesignal.user.state.UserState;
import com.onesignal.user.subscriptions.IPushSubscriptionObserver;
import com.onesignal.user.subscriptions.PushSubscriptionChangedState;
import com.onesignal.user.subscriptions.PushSubscriptionState;
import org.apache.cordova.CallbackContext;
import org.json.JSONException;
import org.json.JSONObject;

public class OneSignalObserverController {
    private static CallbackContext jsPermissionObserverCallBack;
    private static CallbackContext jsSubscriptionObserverCallBack;
    private static CallbackContext jsUserObserverCallBack;

    private static IPermissionObserver permissionObserver;
    private static IPushSubscriptionObserver pushSubscriptionObserver;
    private static IUserStateObserver userStateObserver;

    public static boolean addPermissionObserver(CallbackContext callbackContext) {
        jsPermissionObserverCallBack = callbackContext;
        if (permissionObserver == null) {
            permissionObserver = new IPermissionObserver() {
                @Override
                public void onNotificationPermissionChange(boolean permission) {
                    CallbackHelper.callbackSuccessBoolean(jsPermissionObserverCallBack, permission);
                }
            };
            OneSignal.getNotifications().addPermissionObserver(permissionObserver);
        }
        return true;
    }

    public static boolean addPushSubscriptionObserver(CallbackContext callbackContext) {
        jsSubscriptionObserverCallBack = callbackContext;
        if (pushSubscriptionObserver == null) {
            pushSubscriptionObserver = new IPushSubscriptionObserver() {
                @Override
                public void onPushSubscriptionChange(PushSubscriptionChangedState state) {
                    PushSubscriptionState pushSubscription = state.getCurrent();

                    if (!(pushSubscription instanceof PushSubscriptionState)) {
                        return;
                    }

                    try {
                        JSONObject hash = new JSONObject();
                        hash.put("current", createPushSubscriptionProperties(state.getCurrent()));
                        hash.put("previous", createPushSubscriptionProperties(state.getPrevious()));

                        CallbackHelper.callbackSuccess(jsSubscriptionObserverCallBack, hash);

                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            };
            OneSignal.getUser().getPushSubscription().addObserver(pushSubscriptionObserver);
        }
        return true;
    }

    public static boolean addUserStateObserver(CallbackContext callbackContext) {
        jsUserObserverCallBack = callbackContext;
        if (userStateObserver == null) {
            userStateObserver = new IUserStateObserver() {
                @Override
                public void onUserStateChange(UserChangedState state) {
                    UserState current = state.getCurrent();

                    if (!(current instanceof UserState)) {
                        return;
                    }

                    try {
                        JSONObject hash = new JSONObject();
                        hash.put("current", createUserIds(current));

                        CallbackHelper.callbackSuccess(jsUserObserverCallBack, hash);

                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            };
            OneSignal.getUser().addObserver(userStateObserver);
        }
        return true;
    }

    private static JSONObject createUserIds(UserState user) {
        JSONObject userIds = new JSONObject();
        try {
            String externalId = user.getExternalId();
            String onesignalId = user.getOnesignalId();

            userIds.put("externalId", OneSignalUtils.getStringOrJSONObjectNull(externalId));
            userIds.put("onesignalId", OneSignalUtils.getStringOrJSONObjectNull(onesignalId));
        } catch (JSONException e) {
            e.printStackTrace();
        }
        return userIds;
    }

    private static JSONObject createPushSubscriptionProperties(PushSubscriptionState pushSubscription) {
        JSONObject pushSubscriptionProperties = new JSONObject();
        try {
            String id = pushSubscription.getId();
            String token = pushSubscription.getToken();

            pushSubscriptionProperties.put("id", OneSignalUtils.getStringOrJSONObjectNull(id));
            pushSubscriptionProperties.put("token", OneSignalUtils.getStringOrJSONObjectNull(token));
            pushSubscriptionProperties.put("optedIn", pushSubscription.getOptedIn());
        } catch (JSONException e) {
            e.printStackTrace();
        }
        return pushSubscriptionProperties;
    }
}