package com.radar;

import android.content.Context;
import android.location.Location;
import android.util.Log;

import androidx.annotation.NonNull;
import androidx.annotation.Nullable;

import com.facebook.react.ReactApplication;
import com.facebook.react.ReactInstanceManager;
import com.facebook.react.ReactNativeHost;
import com.facebook.react.bridge.Arguments;
import com.facebook.react.bridge.ReactContext;
import com.facebook.react.bridge.ReactMethod;
import com.facebook.react.bridge.WritableMap;
import com.facebook.react.modules.core.DeviceEventManagerModule;

import io.radar.sdk.Radar;
import io.radar.sdk.RadarReceiver;
import io.radar.sdk.model.RadarEvent;
import io.radar.sdk.model.RadarUser;
import java.util.concurrent.atomic.AtomicInteger;

public class RadarOldArchReceiver extends RadarReceiver {

    private ReactNativeHost reactNativeHost;
    private static final String TAG = "RadarOldArchReceiver";
    protected boolean hasListeners = false;

    private void sendEvent(final String eventName, final Object data) {
        final ReactInstanceManager reactInstanceManager = reactNativeHost.getReactInstanceManager();
        ReactContext reactContext = reactInstanceManager.getCurrentReactContext();
        if (reactContext != null && hasListeners) {
            reactContext.getJSModule(DeviceEventManagerModule.RCTDeviceEventEmitter.class).emit(eventName, data);
        }
    }

    @Override
    public void onEventsReceived(@NonNull Context context, @NonNull RadarEvent[] events, @Nullable RadarUser user) {
        try {
            ReactApplication reactApplication = ((ReactApplication)context.getApplicationContext());
            reactNativeHost = reactApplication.getReactNativeHost();

            WritableMap map = Arguments.createMap();
            map.putArray("events", RadarUtils.arrayForJson(RadarEvent.toJson(events)));
            if (user != null) {
                map.putMap("user", RadarUtils.mapForJson(user.toJson()));
            }

            sendEvent("eventsEmitter", map);
        } catch (Exception e) {
            Log.e(TAG, "Exception", e);
        }
    }

    @Override
    public void onLocationUpdated(@NonNull Context context, @NonNull Location location, @NonNull RadarUser user) {
        try {
            ReactApplication reactApplication = ((ReactApplication)context.getApplicationContext());
            reactNativeHost = reactApplication.getReactNativeHost();

            WritableMap map = Arguments.createMap();
            map.putMap("location", RadarUtils.mapForJson(Radar.jsonForLocation(location)));
            map.putMap("user", RadarUtils.mapForJson(user.toJson()));

            sendEvent("locationEmitter", map);
        } catch (Exception e) {
            Log.e(TAG, "Exception", e);
        }
    }

    @Override
    public void onClientLocationUpdated(@NonNull Context context, @NonNull Location location, boolean stopped, @NonNull Radar.RadarLocationSource source) {
        try {
            ReactApplication reactApplication = ((ReactApplication)context.getApplicationContext());
            reactNativeHost = reactApplication.getReactNativeHost();

            WritableMap map = Arguments.createMap();
            map.putMap("location", RadarUtils.mapForJson(Radar.jsonForLocation(location)));
            map.putBoolean("stopped", stopped);
            map.putString("source", source.toString());

            sendEvent("clientLocationEmitter", map);
        } catch (Exception e) {
            Log.e(TAG, "Exception", e);
        }
    }

    @Override
    public void onError(@NonNull Context context, @NonNull Radar.RadarStatus status) {
        try {
            ReactApplication reactApplication = ((ReactApplication)context.getApplicationContext());
            reactNativeHost = reactApplication.getReactNativeHost();

            WritableMap map = Arguments.createMap();
            map.putString("status", status.toString());

            sendEvent("errorEmitter", map);
        } catch (Exception e) {
            Log.e(TAG, "Exception", e);
        }
    }

    @Override
    public void onLog(@NonNull Context context, @NonNull String message) {
        try {
            ReactApplication reactApplication = ((ReactApplication)context.getApplicationContext());
            reactNativeHost = reactApplication.getReactNativeHost();

            WritableMap map = Arguments.createMap();
            map.putString("message", message);

            sendEvent("logEmitter", map);
        } catch (Exception e) {
            Log.e(TAG, "Exception", e);
        }
    }

}