add take-fact-or-kick

desks/realm/lib/db.hoon

@@ -1174,9 +1174,10 @@
     ++  en-vent
       |=  =vent
       ^-  json
-      %+  frond
-        %row-id
-      (row-id-to-json id.vent)
+      ?-  -.vent
+        %ack     s/%ack
+        %row-id  (frond row-id+(row-id-to-json id.vent))
+      ==
     ::
     ++  en-db-changes
       |=  chs=db-changes

desks/realm/sur/db.hoon

@@ -166,5 +166,6 @@
 ::
 +$  vent
   $%  [%row-id =id:common]
+      [%ack ~]
   ==
 --

desks/realm/ted/venter.hoon

@@ -4,14 +4,15 @@
 :: it will give back the id of the `%create`ed object
 /-  spider, db
 /+  *strandio
+|^
 =,  strand=strand:spider
 ^-  thread:spider
 |=  arg=vase
 =/  m  (strand ,vase)
 ^-  form:m
 =/  axn=(unit action:db)  !<((unit action:db) arg)
 ?~  axn  (strand-fail %no-arg ~)
-?.  ?=(%create -.u.axn)  (strand-fail %no-arg ~)
+?.  ?=(%create -.u.axn)  (strand-fail %bad-action ~)
 ;<  our=@p   bind:m  get-our
 ;<  now=@da  bind:m  get-time
 =/  data-path=path   path.input-row.u.axn
@@ -25,5 +26,27 @@
 ;<  host=ship  bind:m  (scry ship scry-path)
 ;<  ~        bind:m  (watch wire [host %db] wire)
 ;<  ~        bind:m  (poke [host %db] db-action+!>([%create [our now] +>.u.axn]))
-;<  =cage    bind:m  (take-fact wire)
-(pure:m q.cage)
+;<  cage=(unit cage)  bind:m  (take-fact-or-kick wire)
+?^  cage
+  (pure:m q.u.cage)
+(pure:m !>([%ack ~]))
+::
+++  take-fact-or-kick
+  |=  =wire
+  =/  m  (strand ,(unit cage))
+  ^-  form:m
+  |=  tin=strand-input:strand
+  ?+  in.tin  `[%skip ~]
+      ~  `[%wait ~]
+    ::
+      [~ %agent * %fact *]
+    ?.  =(watch+wire wire.u.in.tin)
+      `[%skip ~]
+    `[%done (some cage.sign.u.in.tin)]
+    ::
+      [~ %agent * %kick *]
+    ?.  =(watch+wire wire.u.in.tin)
+      `[%skip ~]
+    `[%done ~]
+  ==
+--