Commit 2c96aa60 authored by Matheus Jardim's avatar Matheus Jardim

added missing data to realMessage

parent b575b920
...@@ -2,7 +2,9 @@ package chat.rocket.persistence.realm.repositories; ...@@ -2,7 +2,9 @@ package chat.rocket.persistence.realm.repositories;
import android.os.Looper; import android.os.Looper;
import android.support.v4.util.Pair; import android.support.v4.util.Pair;
import com.fernandocejas.arrow.optional.Optional; import com.fernandocejas.arrow.optional.Optional;
import io.reactivex.Flowable; import io.reactivex.Flowable;
import io.reactivex.Single; import io.reactivex.Single;
import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.android.schedulers.AndroidSchedulers;
...@@ -12,6 +14,7 @@ import io.realm.Sort; ...@@ -12,6 +14,7 @@ import io.realm.Sort;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import chat.rocket.core.models.Message; import chat.rocket.core.models.Message;
import chat.rocket.core.models.Room; import chat.rocket.core.models.Room;
import chat.rocket.core.models.User; import chat.rocket.core.models.User;
...@@ -75,10 +78,11 @@ public class RealmMessageRepository extends RealmRepository implements MessageRe ...@@ -75,10 +78,11 @@ public class RealmMessageRepository extends RealmRepository implements MessageRe
RealmUser realmUser = realmMessage.getUser(); RealmUser realmUser = realmMessage.getUser();
if (realmUser == null) { if (realmUser == null) {
realmUser = new RealmUser(); realmUser = realm.where(RealmUser.class)
.equalTo(RealmUser.ID, message.getUser().getId())
.findFirst();
} }
realmMessage.setUser(realmUser);
realmUser.setId(message.getUser().getId());
realm.beginTransaction(); realm.beginTransaction();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment