fix findAnchoringSealEvent, add AnchorQuerier (#172)

Co-authored-by: Petteri Stenius <[email protected]>

src/keria/app/agenting.py

@@ -709,7 +709,9 @@ def recur(self, tyme, deeds=None):
                 seqNoDo = querying.SeqNoQuerier(hby=self.hby, hab=self.agentHab, pre=pre, sn=sn)
                 self.extend([seqNoDo])
             elif "anchor" in msg:
-                pass
+                anchor = msg['anchor']
+                anchorDo = querying.AnchorQuerier(hby=self.hby, hab=self.agentHab, pre=pre, anchor=anchor)
+                self.extend([anchorDo])
             else:
                 qryDo = querying.QueryDoer(hby=self.hby, hab=self.agentHab, pre=pre, kvy=self.kvy)
                 self.extend([qryDo])

src/keria/core/longrunning.py

@@ -294,7 +294,7 @@ def status(self, op):
                         operation.done = False
                 elif "anchor" in op.metadata:
                     anchor = op.metadata["anchor"]
-                    if self.hby.db.findAnchoringEvent(op.oid, anchor=anchor) is not None:
+                    if self.hby.db.findAnchoringSealEvent(op.oid, seal=anchor) is not None:
                         operation.done = True
                         operation.response = asdict(kever.state())
                     else:

tests/app/test_agenting.py

@@ -381,7 +381,12 @@ def test_querier(helpers):
         # Anchor not implemented yet
         qry.queries.append(dict(pre="EI7AkI40M11MS7lkTCb10JC9-nDt-tXwQh44OHAFlv_9", anchor={}))
         qry.recur(1.0, deeds=deeds)
-        assert len(qry.doers) == 0
+        assert len(qry.doers) == 1
+        anchorDoer = qry.doers[0]
+        assert isinstance(anchorDoer, querying.AnchorQuerier) is True
+        assert anchorDoer.pre == "EI7AkI40M11MS7lkTCb10JC9-nDt-tXwQh44OHAFlv_9"
+        assert anchorDoer.anchor == {}
+        qry.doers.remove(anchorDoer)
 
         qry.queries.append(dict(pre="EI7AkI40M11MS7lkTCb10JC9-nDt-tXwQh44OHAFlv_9"))
         qry.recur(1.0, deeds=deeds)