From 11267c842fedc64df1d745aedfe34fdf0e498fe8 Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Tue, 29 Aug 2023 13:08:55 -0700
Subject: [PATCH] first impl of batch ops

---
 datastore/threadproxyds.nim | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/datastore/threadproxyds.nim b/datastore/threadproxyds.nim
index bd49de1..7339642 100644
--- a/datastore/threadproxyds.nim
+++ b/datastore/threadproxyds.nim
@@ -65,6 +65,11 @@ method delete*(
   self: ThreadProxyDatastore,
   keys: seq[Key]
 ): Future[?!void] {.async.} =
+
+  for key in keys:
+    if err =? (await self.delete(key)).errorOption:
+      return failure err
+
   return success()
 
 method get*(
@@ -110,7 +115,12 @@ method put*(
   self: ThreadProxyDatastore,
   batch: seq[BatchEntry]
 ): Future[?!void] {.async.} =
-  raiseAssert("Not implemented!")
+
+  for entry in batch:
+    if err =? (await self.put(entry.key, entry.data)).errorOption:
+      return failure err
+
+  return success()
 
 method close*(
   self: ThreadProxyDatastore