fix streaming problems and add a regression test

anysphere · Jul 11, 2022 · f89f4b6 · f89f4b6
1 parent 62315f3
commit f89f4b6
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/daemon/rpc/daemon_rpc.cc b/daemon/rpc/daemon_rpc.cc
@@ -642,7 +642,9 @@ Status DaemonRpc::GetMessagesStreamed(
 
   // guarantee: the caller will get each message in the order of the
   // delivered_at timestamp. each message will be delivered exactly once.
-  absl::Time last_delivered_at = absl::InfinitePast();
+  // we do 0 here because the db.get_most_recent_delivered_at returns 0 if no
+  // message found
+  absl::Time last_delivered_at = absl::FromUnixMicros(0);
 
   try {
     auto messages = G.db->get_received_messages(db::MessageQuery{