Optimize broadcast report query based on timestamp (#21)

samagra-comms · Aug 29, 2023 · 831029c · 831029c
1 parent ef5d5d6
commit 831029c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/uci/dao/repository/XMessageRepository.java b/src/main/java/com/uci/dao/repository/XMessageRepository.java
@@ -34,7 +34,7 @@ public interface XMessageRepository extends ReactiveCassandraRepository<XMessage
     Flux<XMessageDAO> findById(UUID uuid);
 
     @AllowFiltering
-    Flux<Slice<XMessageDAO>> findAllByBotUuid(UUID botUuid, CassandraPageRequest pageRequest);
+    Flux<Slice<XMessageDAO>> findAllByBotUuidAndTimestampAfter(UUID botUuid, LocalDateTime timestamp, CassandraPageRequest pageRequest);
 
     @AllowFiltering
     Flux<XMessageDAO> findFirstByAppAndUserIdAndFromIdAndMessageStateOrderByTimestampDesc(String app, String userID, String fromId, String messageState);