1 files changed, 3 insertions, 6 deletions
diff --git a/src/message/repo.rs b/src/message/repo.rs
index 2ca409d..5b199a7 100644
--- a/src/message/repo.rs
+++ b/src/message/repo.rs
@@ -4,7 +4,7 @@ use super::{snapshot::Message, History, Id};
 use crate::{
     channel::{self, Channel},
     clock::DateTime,
-    event::{Instant, Sequence},
+    event::{Instant, ResumePoint, Sequence},
     login::{self, Login},
 };
 
@@ -69,7 +69,7 @@ impl<'c> Messages<'c> {
     pub async fn in_channel(
         &mut self,
         channel: &channel::History,
-        resume_at: Option<Sequence>,
+        resume_at: ResumePoint,
     ) -> Result<Vec<History>, sqlx::Error> {
         let channel_id = channel.id();
         let messages = sqlx::query!(
@@ -203,10 +203,7 @@ impl<'c> Messages<'c> {
         Ok(messages)
     }
 
-    pub async fn replay(
-        &mut self,
-        resume_at: Option<Sequence>,
-    ) -> Result<Vec<History>, sqlx::Error> {
+    pub async fn replay(&mut self, resume_at: ResumePoint) -> Result<Vec<History>, sqlx::Error> {
         let messages = sqlx::query!(
             r#"
                 select