init

app/src/main/java/cc/n0th1ng/tripmoney/data/dao/ExpenseDao.kt

@@ -3,27 +3,58 @@ package cc.n0th1ng.tripmoney.data.dao
 import androidx.paging.PagingSource
 import androidx.room.Dao
 import androidx.room.Delete
-import androidx.room.Insert
 import androidx.room.Query
 import androidx.room.Transaction
 import androidx.room.Upsert
+import cc.n0th1ng.tripmoney.data.dto.SummaryPerCategoryRaw
 import cc.n0th1ng.tripmoney.data.entity.Expense
 import cc.n0th1ng.tripmoney.data.entity.ExpenseDto
+import kotlinx.coroutines.flow.Flow
 
 @Dao
 interface ExpenseDao {
     @Upsert
     suspend fun insert(expense: Expense)
 
-    @Transaction
     @Query(
         """
         SELECT * FROM expense WHERE trip_id = :tripId
         ORDER BY DATETIME(expense.datetime) DESC
     """
     )
-    fun expenseDto(tripId: Int): PagingSource<Int, ExpenseDto>
+    fun expenseDtoPaged(tripId: Int): PagingSource<Int, ExpenseDto>
+
+    @Transaction
+    @Query(
+    """
+        SELECT * FROM expense WHERE trip_id = :tripId
+        ORDER BY DATETIME(expense.datetime) DESC
+    """
+    )
+    fun expenseDto(tripId: Int): Flow<List<ExpenseDto>>
 
     @Delete
     suspend fun delete(expense: Expense)
+
+    @Query(
+        """
+    SELECT
+        c.id as categoryId,
+        c.name as categoryName,
+        c.icon as icon,
+        c.color as color,
+        SUM(e.amount) as amount,
+        e.currency as currency
+    FROM
+        expense e
+    JOIN
+        category c ON e.category_id = c.id
+    WHERE
+        e.trip_id = :tripId
+    GROUP BY
+        c.id, c.name, c.icon, c.color, e.currency
+    """
+    )
+    fun summaryPerCategoryRaw(tripId: Int): Flow<List<SummaryPerCategoryRaw>>
+
 }

app/src/main/java/cc/n0th1ng/tripmoney/data/dao/TripDao.kt

@@ -23,4 +23,9 @@ interface TripDao {
 
     @Delete
     suspend fun delete(trip: Trip)
+
+    @Query(
+        "SELECT * FROM trip where trip.id = :tripId"
+    )
+    fun trip(tripId: Int): Trip?
 }