From c52d4b5ae43c202569c8801c312c2b56954ff8a0 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Sun, 25 Oct 2026 23:00:56 +0100
Subject: add clock module

The Clock module is the system clock that every unix timestamp new goes
through.  It comes with an offset that only tests can set.
---
 src/remake/vote.rs | 16 +++++-----------
 1 file changed, 5 insertions(+), 11 deletions(-)

(limited to 'src/remake/vote.rs')

diff --git a/src/remake/vote.rs b/src/remake/vote.rs
index b4936dc..9e28cde 100644
--- a/src/remake/vote.rs
+++ b/src/remake/vote.rs
@@ -28,7 +28,7 @@ use tracing::{info, warn};
 
 use super::Host;
 use super::content;
-use super::records::{self, Decision, EpochRecord, Phase, Record, Register, Vote, unix_millis};
+use super::records::{self, Decision, EpochRecord, Phase, Record, Register, Vote};
 use crate::document::store::StoreError;
 
 /// A majority of `electorate` members.
@@ -235,19 +235,12 @@ pub(super) async fn cast<H: Host>(host: &H) {
 
     // Usually there is nothing to vote on: look first, without writing.
     let (voter, wanted) = (me.clone(), epoch.clone());
+    let now = host.now_millis();
     let due = host
         .read_doc(move |doc| {
             let all = records::load_all(doc);
             let register = records::load_register(doc);
-            let id = choice(
-                &voter,
-                &wanted,
-                &all,
-                &register,
-                started,
-                unix_millis(),
-                grace,
-            )?;
+            let id = choice(&voter, &wanted, &all, &register, started, now, grace)?;
             let content = all
                 .into_iter()
                 .find(|(other, _)| *other == id)
@@ -267,9 +260,10 @@ pub(super) async fn cast<H: Host>(host: &H) {
 
     // Decided again under the write lock, so two passes can't both vote.
     let voter = me.clone();
+    let clock = host.clock();
     let result = host
         .commit_doc(move |doc| -> Result<Option<String>, StoreError> {
-            let now = unix_millis();
+            let now = clock.now_millis();
             let all = records::load_all(doc);
             let register = records::load_register(doc);
             let Some(id) = choice(&voter, &epoch, &all, &register, started, now, grace)
-- 
cgit v1.3.1