mMDT5_GreenWatch/app/src/main/java/com/example/greenwatch/repositories/DeviceRepository.java

package com.example.greenwatch.repositories;


import androidx.lifecycle.MutableLiveData;

import com.example.greenwatch.models.Device;
import com.example.greenwatch.communication.WiFiCommunication;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.UUID;

public class DeviceRepository {

    private final String delimiter = ", ";
    private final String SensorStatusKey = "An";
    private String localDeviceUUID;
    private static DeviceRepository deviceRepositoryInstance;
    private WiFiCommunication mWiFiCommunication;
    private MutableLiveData<List<Device>> deviceList = new MutableLiveData<>();
    private HashMap<String, Device> connectedDevicesList = new HashMap<>();
    private HashMap<String, String> deviceIDMapper = new HashMap<>();

    private DeviceRepository() {
        setLocalDeviceUUID();
    }

    public static synchronized DeviceRepository getInstance() {
        if (deviceRepositoryInstance == null){
            deviceRepositoryInstance = new DeviceRepository();
        }
        return deviceRepositoryInstance;
    }

    public void setWiFiCommunication(WiFiCommunication wiFiCommunication) {
        this.mWiFiCommunication = wiFiCommunication;
    }

    public MutableLiveData<List<Device>> getConnectedDeviceList() {
        setMutableLiveDataValue();
        return deviceList;
    }

    public void createNewDevice(String timeStamp, String deviceID, boolean sensorStatus, String sensorType, int sensorMassage){
        Device newDevice = new Device(timeStamp, deviceID, sensorStatus, sensorType, sensorMassage);
        setDeviceIDMapper(deviceID);
        addToConnectedDeviceList(newDevice.getDeviceID(), newDevice);
        setMutableLiveDataValue();
    }

    private String messageStringBuilder(String deviceID) {
        StringBuilder message = new StringBuilder();
        Device device = connectedDevicesList.get(deviceID);
        if(device != null) {
            message.append(device.getTimeStamp())
                    .append(delimiter)
                    .append(device.getDeviceID())
                    .append(delimiter)
                    .append(device.getSensorStatus())
                    .append(delimiter)
                    .append(device.getSensorType())
                    .append(delimiter)
                    .append(device.getSensorMassage());
            return message.toString();
        }
        else {
            message.append("")
                    .append(delimiter)
                    .append("")
                    .append(delimiter)
                    .append("")
                    .append(delimiter)
                    .append("")
                    .append(delimiter)
                    .append("");
            return message.toString();
        }
    }

    public String getLocalDeviceUUID() {
        return localDeviceUUID;
    }

    public void updateDevice(String deviceID, String timeStamp, boolean sensorStatus, String sensorType, int sensorMassage) {
        String checkedDeviceID = checkDeviceID(deviceID);
        Device device = connectedDevicesList.get(checkedDeviceID);
        if(device != null) {
            device.setTimeStamp(timeStamp);
            device.setSensorStatus(sensorStatus);
            device.setSensorType(sensorType);
            device.setSensorMassage(sensorMassage);
            addToConnectedDeviceList(checkedDeviceID, device);
            setMutableLiveDataValue();
        }
    }

    public void setTimeStamp(String deviceID, String timeStamp) {
        String checkedDeviceID = checkDeviceID(deviceID);
        Device device = connectedDevicesList.get(checkedDeviceID);
        if(device != null) {
            device.setTimeStamp(timeStamp);
            addToConnectedDeviceList(checkedDeviceID, device);
            setMutableLiveDataValue();
        }
    }

    public String getTimeStamp(String deviceID) {
        String checkedDeviceID = checkDeviceID(deviceID);
        Device device = connectedDevicesList.get(checkedDeviceID);
        if(device != null) {
            return device.getTimeStamp();
        }
        return "";
    }

    public void setDeviceID(String deviceID, String newDeviceID) {
        String checkedDeviceID = checkDeviceID(deviceID);
        Device device = connectedDevicesList.get(checkedDeviceID);
        if(device != null) {
            device.setDeviceID(newDeviceID);
            setDeviceIDMapper(newDeviceID);
            connectedDevicesList.remove(checkedDeviceID);
            addToConnectedDeviceList(newDeviceID, device);
            setMutableLiveDataValue();
        }
    }

    public String getDeviceID(String deviceID) {
        String checkedDeviceID = checkDeviceID(deviceID);
        Device device = connectedDevicesList.get(checkedDeviceID);
        if(device != null) {
            return device.getDeviceID();
        }
        return "";
    }

    public void setSensorStatus(String deviceID, boolean sensorStatus) {
        String checkedDeviceID = checkDeviceID(deviceID);
        Device device = connectedDevicesList.get(checkedDeviceID);
        if(device != null) {
            device.setSensorStatus(sensorStatus);
            addToConnectedDeviceList(checkedDeviceID, device);
            setMutableLiveDataValue();
        }
    }

    public boolean getSensorStatus(String deviceID) {
        String checkedDeviceID = checkDeviceID(deviceID);
        Device device = connectedDevicesList.get(checkedDeviceID);
        if(device != null) {
            return device.getSensorStatus();
        }
        return false;
    }

    public void setSensorType(String deviceID, String sensorType) {
        String checkedDeviceID = checkDeviceID(deviceID);
        Device device = connectedDevicesList.get(checkedDeviceID);
        if(device != null) {
            device.setSensorType(sensorType);
            addToConnectedDeviceList(checkedDeviceID, device);
            setMutableLiveDataValue();
        }
    }

    public String getSensorType(String deviceID) {
        String checkedDeviceID = checkDeviceID(deviceID);
        Device device = connectedDevicesList.get(checkedDeviceID);
        if(device != null) {
            return device.getSensorType();
        }
        return "";
    }

    public void setSensorMassage(String deviceID, int sensorMessage) {
        String checkedDeviceID = checkDeviceID(deviceID);
        Device device = connectedDevicesList.get(checkedDeviceID);
        if(device != null) {
            device.setSensorMassage(sensorMessage);
            addToConnectedDeviceList(checkedDeviceID, device);
            setMutableLiveDataValue();
        }
    }

    public int getSensorMassage(String deviceID) {
        String checkedDeviceID = checkDeviceID(deviceID);
        Device device = connectedDevicesList.get(checkedDeviceID);
        if(device != null) {
            return device.getSensorMassage();
        }
        return 0;
    }

    private void setMutableLiveDataValue() {
        List<Device> list = new ArrayList<>(connectedDevicesList.values());
        deviceList.setValue(list);
    }

    private void addToConnectedDeviceList(String key, Device device) {
        connectedDevicesList.put(key, device);
        if (key.equals(checkDeviceID(localDeviceUUID))) {
            mWiFiCommunication.setNewMessage(messageStringBuilder(device.getDeviceID()),true);
        }
    }

    private String checkDeviceID(String deviceID) {
        if(!deviceIDMapper.isEmpty() && deviceID.equals(localDeviceUUID)) {
            return deviceIDMapper.get(deviceID);
        }
        return deviceID;
    }

    private void setDeviceIDMapper(String deviceID) {
        deviceIDMapper.put(localDeviceUUID, deviceID);
    }

    private void setLocalDeviceUUID(){
        this.localDeviceUUID = UUID.randomUUID().toString();
    }

    private String[] messageStringSplitter(String message) {
        return message.split(delimiter);
    }

    public void getNewReceivedMessage(String newMessage) {
        String[] messageString = messageStringSplitter(newMessage);
        String timeStamp = messageString[0];
        String deviceID = messageString[1];
        boolean sensorStatus = convertSensorStatus(messageString[2]);
        String sensorType = messageString[3];
        int sensorMassage = Integer.valueOf(messageString[4]);

        if (deviceID.equals(checkDeviceID(localDeviceUUID))) {
            return;
        }

        if(!connectedDevicesList.containsKey(deviceID)) {
            createNewDevice(timeStamp, deviceID, sensorStatus, sensorType, sensorMassage);
        }
        else {
            updateDevice(deviceID, timeStamp, sensorStatus, sensorType, sensorMassage);
        }
    }

    private boolean convertSensorStatus(String status) {
        return status.equals(SensorStatusKey);
    }
}