Adds monster collections.

Android/app/src/main/java/com/majinnaibu/monstercards/data/CollectionDAO.java

@@ -0,0 +1,55 @@
+package com.majinnaibu.monstercards.data;
+
+import androidx.room.Dao;
+import androidx.room.Delete;
+import androidx.room.Insert;
+import androidx.room.OnConflictStrategy;
+import androidx.room.Query;
+import androidx.room.Update;
+
+import com.majinnaibu.monstercards.models.Collection;
+import com.majinnaibu.monstercards.models.CollectionMonster;
+import com.majinnaibu.monstercards.models.CollectionWithCount;
+import com.majinnaibu.monstercards.models.Monster;
+
+import java.util.List;
+
+import io.reactivex.rxjava3.core.Completable;
+import io.reactivex.rxjava3.core.Flowable;
+
+@Dao
+public interface CollectionDAO {
+
+    @Query("SELECT * FROM collections")
+    Flowable<List<Collection>> getAll();
+
+    @Query("SELECT collections.*, COUNT(collection_monsters.id) as monsterCount FROM collections LEFT JOIN collection_monsters ON collections.id = collection_monsters.collection_id GROUP BY collections.id")
+    Flowable<List<CollectionWithCount>> getCollectionsWithCount();
+
+    @Query("SELECT * FROM collections WHERE id = :id LIMIT 1")
+    Flowable<Collection> getById(String id);
+
+    @Insert(onConflict = OnConflictStrategy.REPLACE)
+    Completable save(Collection... collections);
+
+    @Delete
+    Completable delete(Collection collection);
+
+    @Query("SELECT monsters.* FROM monsters INNER JOIN collection_monsters ON monsters.id = collection_monsters.monster_id WHERE collection_monsters.collection_id = :collectionId ORDER BY collection_monsters.ordinal ASC, collection_monsters.id ASC")
+    Flowable<List<Monster>> getMonstersForCollection(String collectionId);
+
+    @Query("SELECT * FROM collection_monsters WHERE collection_id = :collectionId ORDER BY ordinal ASC, id ASC")
+    Flowable<List<CollectionMonster>> getCollectionMonstersForCollection(String collectionId);
+
+    @Insert
+    Completable addMonsterToCollection(CollectionMonster... collectionMonsters);
+
+    @Query("DELETE FROM collection_monsters WHERE collection_id = :collectionId AND monster_id = :monsterId")
+    Completable removeMonsterFromCollection(String collectionId, String monsterId);
+
+    @Query("DELETE FROM collection_monsters WHERE id = :id")
+    Completable removeCollectionMonsterById(long id);
+
+    @Update
+    Completable updateCollectionMonsters(List<CollectionMonster> collectionMonsters);
+}

Android/app/src/main/java/com/majinnaibu/monstercards/data/MonsterRepository.java

@@ -4,6 +4,9 @@ import androidx.annotation.NonNull;
 
 import com.majinnaibu.monstercards.AppDatabase;
 import com.majinnaibu.monstercards.helpers.StringHelper;
+import com.majinnaibu.monstercards.models.Collection;
+import com.majinnaibu.monstercards.models.CollectionMonster;
+import com.majinnaibu.monstercards.models.CollectionWithCount;
 import com.majinnaibu.monstercards.models.Monster;
 
 import java.util.ArrayList;
@@ -80,6 +83,82 @@ public class MonsterRepository {
         return result;
     }
 
+    public Flowable<List<Collection>> getCollections() {
+        return m_db.collectionDAO()
+                .getAll()
+                .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread());
+    }
+
+    public Flowable<List<CollectionWithCount>> getCollectionsWithCount() {
+        return m_db.collectionDAO()
+                .getCollectionsWithCount()
+                .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread());
+    }
+
+    public Flowable<Collection> getCollection(@NonNull UUID collectionId) {
+        return m_db.collectionDAO()
+                .getById(collectionId.toString())
+                .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread());
+    }
+
+    public Completable saveCollection(Collection collection) {
+        Completable result = m_db.collectionDAO().save(collection);
+        result.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
+        return result;
+    }
+
+    public Completable deleteCollection(Collection collection) {
+        Completable result = m_db.collectionDAO().delete(collection);
+        result.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
+        return result;
+    }
+
+    public Flowable<List<Monster>> getMonstersForCollection(@NonNull UUID collectionId) {
+        return m_db.collectionDAO()
+                .getMonstersForCollection(collectionId.toString())
+                .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread());
+    }
+
+    public Flowable<List<CollectionMonster>> getCollectionMonstersForCollection(@NonNull UUID collectionId) {
+        return m_db.collectionDAO()
+                .getCollectionMonstersForCollection(collectionId.toString())
+                .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread());
+    }
+
+    public Completable addMonsterToCollection(@NonNull UUID collectionId, @NonNull UUID monsterId) {
+        return addMonsterToCollection(collectionId, monsterId, 0);
+    }
+
+    public Completable addMonsterToCollection(@NonNull UUID collectionId, @NonNull UUID monsterId, int ordinal) {
+        CollectionMonster collectionMonster = new CollectionMonster(collectionId, monsterId, ordinal);
+        Completable result = m_db.collectionDAO().addMonsterToCollection(collectionMonster);
+        result.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
+        return result;
+    }
+
+    public Completable removeMonsterFromCollection(@NonNull UUID collectionId, @NonNull UUID monsterId) {
+        Completable result = m_db.collectionDAO().removeMonsterFromCollection(collectionId.toString(), monsterId.toString());
+        result.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
+        return result;
+    }
+
+    public Completable removeCollectionMonsterById(long junctionId) {
+        Completable result = m_db.collectionDAO().removeCollectionMonsterById(junctionId);
+        result.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
+        return result;
+    }
+
+    public Completable updateCollectionMonsters(List<CollectionMonster> collectionMonsters) {
+        Completable result = m_db.collectionDAO().updateCollectionMonsters(collectionMonsters);
+        result.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
+        return result;
+    }
+
     private static class Helpers {
         static boolean monsterMatchesSearch(Monster monster, String searchText) {
             if (StringHelper.isNullOrEmpty(searchText)) {