From 856c0b380c67b2e00bd62ee06dca537ccebb41c0 Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Tue, 29 Aug 2023 13:00:01 -0700
Subject: [PATCH] impl has

---
 datastore/threadproxyds.nim | 16 +++++++++++++---
 1 file changed, 13 insertions(+), 3 deletions(-)

diff --git a/datastore/threadproxyds.nim b/datastore/threadproxyds.nim
index 7ddbd8a..bd49de1 100644
--- a/datastore/threadproxyds.nim
+++ b/datastore/threadproxyds.nim
@@ -29,7 +29,19 @@ method has*(
   self: ThreadProxyDatastore,
   key: Key
 ): Future[?!bool] {.async.} =
-  return success(true)
+
+  without ret =? newThreadResult(bool), err:
+    return failure(err)
+
+  try:
+    has(ret, self.tds, key)
+    await wait(ret[].signal)
+  finally:
+    echo "closing signal"
+    ret[].signal.close()
+
+  echo "\nSharedDataStore:has:value: ", ret[].repr
+  return success(ret[].value)
 
 method delete*(
   self: ThreadProxyDatastore,
@@ -39,7 +51,6 @@ method delete*(
   without ret =? newThreadResult(void), err:
     return failure(err)
 
-  echo "res: ", ret
   try:
     delete(ret, self.tds, key)
     await wait(ret[].signal)
@@ -50,7 +61,6 @@ method delete*(
   echo "\nSharedDataStore:put:value: ", ret[].repr
   return success()
 
-
 method delete*(
   self: ThreadProxyDatastore,
   keys: seq[Key]