From 89ed77e5d87574b9eb391a9c984f56138a0d0767 Mon Sep 17 00:00:00 2001
From: dakkar <dakkar@thenautilus.net>
Date: Mon, 16 Mar 2020 15:20:33 +0000
Subject: actually working cache updating in ByAddresses

---
 lib/MaildirIndexer/Index/ByAddresses.rakumod | 14 ++++++++++----
 lib/MaildirIndexer/LogTimelineSchema.rakumod |  2 ++
 2 files changed, 12 insertions(+), 4 deletions(-)

(limited to 'lib')

diff --git a/lib/MaildirIndexer/Index/ByAddresses.rakumod b/lib/MaildirIndexer/Index/ByAddresses.rakumod
index b2127de..0b77d15 100644
--- a/lib/MaildirIndexer/Index/ByAddresses.rakumod
+++ b/lib/MaildirIndexer/Index/ByAddresses.rakumod
@@ -16,10 +16,14 @@ has Numeric %!p-address-given-mailbox;
 has Int $!total-count;
 
 has Numeric %!cached-p-given-mailbox;
-has Instant $!last-cached-at .= from-posix(0);
+has Supplier $!update-cache .= new;
 
 constant $NOT-ZERO = 1e-15;
 
+submethod TWEAK() {
+    $!update-cache.Supply.stable(10).tap({ self.do-update-cache() });
+}
+
 method dump() {
 }
 
@@ -42,8 +46,11 @@ submethod account-for(Str @addresses,Str $mailbox,Int $step) {
         }
     }
 
-    # update the cache every 10 seconds
-    if ((now - $!last-cached-at) > 10) {
+    $!update-cache.emit(Any);
+}
+
+submethod do-update-cache() {
+    MaildirIndexer::LogTimelineSchema::Index::Cache.log: {
         for $!count-by-mailbox.keys -> Str $mailbox {
             my Numeric $p = $!count-by-mailbox{$mailbox} / $!total-count;
 
@@ -54,7 +61,6 @@ submethod account-for(Str @addresses,Str $mailbox,Int $step) {
 
             %!cached-p-given-mailbox{$mailbox} = $p;
         }
-        $!last-cached-at = now;
     }
 }
 
diff --git a/lib/MaildirIndexer/LogTimelineSchema.rakumod b/lib/MaildirIndexer/LogTimelineSchema.rakumod
index ea0d2fc..1e95e65 100644
--- a/lib/MaildirIndexer/LogTimelineSchema.rakumod
+++ b/lib/MaildirIndexer/LogTimelineSchema.rakumod
@@ -20,3 +20,5 @@ class Index::Rm does Log::Timeline::Task['MaildirIndexer','Index','rm path'] { }
 class Index::Find does Log::Timeline::Task['MaildirIndexer','Index','finding mailbox'] { };
 
 class Server::Serve does Log::Timeline::Task['MaildirIndexer','Server','serving a request'] { };
+
+class Index::Cache does Log::Timeline::Task['MaildirIndexer','Index','update cache'] { };
-- 
cgit v1.2.3