ChatModel.java

package de.stephanlindauer.criticalmaps.model;

import androidx.annotation.NonNull;

import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;

import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.Date;
import java.util.List;

import javax.inject.Inject;
import javax.inject.Singleton;

import de.stephanlindauer.criticalmaps.model.chat.ReceivedChatMessage;
import de.stephanlindauer.criticalmaps.utils.AeSimpleSHA1;
import timber.log.Timber;


@Singleton
public class ChatModel {

    private final UserModel userModel;
    private List<ReceivedChatMessage> receivedChatMessages = new ArrayList<>();

    public static final int MESSAGE_MAX_LENGTH = 255;

    @Inject
    public ChatModel(UserModel userModel) {
        this.userModel = userModel;
    }

    @NonNull
    public List<ReceivedChatMessage> getReceivedChatMessages() {
        return this.receivedChatMessages;
    }

    public void setFromJson(JSONArray jsonArray) throws JSONException,
            UnsupportedEncodingException {
        receivedChatMessages = new ArrayList<>(jsonArray.length());

        for (int i = 0; i < jsonArray.length(); i++) {
            JSONObject jsonObject = jsonArray.getJSONObject(i);

            String device = URLDecoder.decode(jsonObject.getString("device"), "UTF-8");
            String identifier = URLDecoder.decode(jsonObject.getString("identifier"), "UTF-8");
            String message = URLDecoder.decode(jsonObject.getString("message"), "UTF-8");
            Date timestamp = new Date(Long.parseLong(jsonObject.getString("timestamp")) * 1000);

            receivedChatMessages.add(new ReceivedChatMessage(message, timestamp));
        }

        receivedChatMessages.sort(Comparator.comparing(ReceivedChatMessage::getTimestamp));
    }

    public JSONObject createNewOutgoingMessage(String message) {
        JSONObject messageObject = new JSONObject();
        try {
            messageObject.put("text", urlEncodeMessage(message));
            messageObject.put("identifier", AeSimpleSHA1.SHA1(message + Math.random()));
            messageObject.put("device", userModel.getChangingDeviceToken());
        } catch (JSONException e) {
            Timber.d(e);
        }
        return messageObject;
    }

    private String urlEncodeMessage(String messageToEncode) {
        try {
            return URLEncoder.encode(messageToEncode, "UTF-8");
        } catch (UnsupportedEncodingException e) {
            return "";
        }
    }
}