kiln: add autocommit

bin/solid.pill

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:5c41d46da7d12258f46dee61f7350701600b73f08ac5076c6b070378b3fc9ece
-size 15526512
+oid sha256:8f485263d12df43413475c7d6dddfe899f997856f77a770194eb21b0aa6f61d0
+size 15903722

pkg/arvo/app/hood.hoon

@@ -139,6 +139,7 @@
 ++  made-kiln                 (wrap take-made):from-kiln
 ++  mere-kiln                 (wrap take-mere):from-kiln
 ++  mere-kiln-sync            (wrap take-mere-sync):from-kiln
+++  wake-kiln-autocommit      (wrap take-wake-autocommit):from-kiln
 ++  wake-kiln-overload        (wrap take-wake-overload):from-kiln
 ++  wake-helm-automass        (wrap take-wake-automass):from-helm
 ++  onto-drum                 (wrap take-onto):from-drum
@@ -172,6 +173,7 @@
 ++  poke-kiln-label           (wrap poke-label):from-kiln
 ++  poke-kiln-merge           (wrap poke-merge):from-kiln
 ++  poke-kiln-cancel          (wrap poke-cancel):from-kiln
+++  poke-kiln-cancel-autocommit  (wrap poke-cancel-autocommit):from-kiln
 ++  poke-kiln-mount           (wrap poke-mount):from-kiln
 ++  poke-kiln-rm              (wrap poke-rm):from-kiln
 ++  poke-kiln-schedule        (wrap poke-schedule):from-kiln

pkg/arvo/gen/hood/cancel-autocommit.hoon

@@ -0,0 +1,13 @@
+::
+::::  /hoon/cancel-autocommit/hood/gen
+  ::
+/?    309
+::
+::::
+  ::
+:-  %say
+|=  $:  [now=@da eny=@uvJ bec=beak]
+        ~
+        ~
+    ==
+[%kiln-cancel-autocommit ~]

pkg/arvo/gen/hood/commit.hoon

@@ -9,7 +9,7 @@
 :-  %say
 |=  $:  {now/@da eny/@uvJ bec/beak}
         {mon/term ~}
-        ~
+        auto=_|
     ==
 :-  %kiln-commit
-mon
+[mon auto]

pkg/arvo/lib/hood/kiln.hoon

@@ -19,6 +19,7 @@
         cur-arvo/@uvI                                   ::
         cur-zuse/@uvI                                   ::
         cur-vanes/(map @tas @uvI)                       ::
+        commit-timer/{way/wire nex/@da tim/@dr mon=term}
     ==                                                  ::
 ++  per-desk                                            ::  per-desk state
     $:  auto/?                                          ::  escalate on failure
@@ -74,6 +75,7 @@
           {$wipe wire @ud}                              ::
           [%keep wire compiler-cache-size=@ud build-cache-size=@ud]
           {$wait wire @da}                              ::
+          {$rest wire @da}                              ::
           {$warp wire ship riff}                        ::
       ==                                                ::
     ++  pear                                            ::  poke fruit
@@ -100,8 +102,19 @@
   ~[leaf+"from {<sud>}" leaf+"on {<who>}" leaf+"to {<syd>}"]
 ::
 ++  poke-commit
-  |=  mon/kiln-commit
-  abet:(emit %dirk /commit mon)
+  |=  [mon/kiln-commit auto=?]
+  =<  abet
+  =.  +>.$  (emit %dirk /commit mon)
+  ?.  auto
+    +>.$
+  =/  recur  ~s1
+  =.  commit-timer
+    [/kiln/autocommit (add now recur) recur mon]
+  (emit %wait way.commit-timer nex.commit-timer)
+::
+++  poke-cancel-autocommit
+  |=  ~
+  abet:(emit %rest way.commit-timer nex.commit-timer)
 ::
 ++  poke-mount
   |=  kiln-mount
@@ -361,6 +374,20 @@
   ~&  %wake-overload-deprecated
   abet
 ::
+++  take-wake-autocommit
+  |=  [way=wire error=(unit tang)]
+  ?^  error
+    %-  (slog u.error)
+    ~&  %kiln-wake-autocommit-fail
+    abet
+  =.  nex.commit-timer  (add now tim.commit-timer)
+  =<  abet
+  %-  emil
+  :~  [%dirk /commit mon.commit-timer]
+      [%wait way.commit-timer nex.commit-timer]
+  ==
+::
+::
 ++  spam
   |=  mes/(list tank)
   ((slog mes) ..spam)