From 22c9d8556a048ab410a288570974d8a6ee6c5a73 Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Tue, 29 Aug 2023 12:50:36 -0700
Subject: [PATCH] rename sharedds to threadproxyds

---
 datastore/{sharedds.nim => threadproxyds.nim} | 22 +++++++++----------
 ...testsharedds.nim => testthreadproxyds.nim} | 12 +++++-----
 2 files changed, 17 insertions(+), 17 deletions(-)
 rename datastore/{sharedds.nim => threadproxyds.nim} (85%)
 rename tests/datastore/{testsharedds.nim => testthreadproxyds.nim} (95%)

diff --git a/datastore/sharedds.nim b/datastore/threadproxyds.nim
similarity index 85%
rename from datastore/sharedds.nim
rename to datastore/threadproxyds.nim
index 41fcdf9..111008f 100644
--- a/datastore/sharedds.nim
+++ b/datastore/threadproxyds.nim
@@ -22,30 +22,30 @@ export key, query
 push: {.upraises: [].}
 
 type
-  SharedDatastore* = ref object of Datastore
-    # stores*: Table[Key, SharedDatastore]
+  ThreadProxyDatastore* = ref object of Datastore
+    # stores*: Table[Key, ThreadProxyDatastore]
     tds: ThreadDatastorePtr
 
 method has*(
-  self: SharedDatastore,
+  self: ThreadProxyDatastore,
   key: Key
 ): Future[?!bool] {.async.} =
   return success(true)
 
 method delete*(
-  self: SharedDatastore,
+  self: ThreadProxyDatastore,
   key: Key
 ): Future[?!void] {.async.} =
   return success()
 
 method delete*(
-  self: SharedDatastore,
+  self: ThreadProxyDatastore,
   keys: seq[Key]
 ): Future[?!void] {.async.} =
   return success()
 
 method get*(
-  self: SharedDatastore,
+  self: ThreadProxyDatastore,
   key: Key
 ): Future[?!seq[byte]] {.async.} =
 
@@ -64,7 +64,7 @@ method get*(
   return success(data)
 
 method put*(
-  self: SharedDatastore,
+  self: ThreadProxyDatastore,
   key: Key,
   data: seq[byte]
 ): Future[?!void] {.async.} =
@@ -84,13 +84,13 @@ method put*(
   return success()
 
 method put*(
-  self: SharedDatastore,
+  self: ThreadProxyDatastore,
   batch: seq[BatchEntry]
 ): Future[?!void] {.async.} =
   raiseAssert("Not implemented!")
 
 method close*(
-  self: SharedDatastore
+  self: ThreadProxyDatastore
 ): Future[?!void] {.async.} =
   # TODO: how to handle failed close?
   echo "ThreadDatastore: FREE: "
@@ -106,9 +106,9 @@ method close*(
 
 proc newSharedDataStore*(
   ds: Datastore,
-): ?!SharedDatastore =
+): ?!ThreadProxyDatastore =
 
-  var self = SharedDatastore()
+  var self = ThreadProxyDatastore()
 
   let value = newSharedPtr(ThreadDatastore)
   echo "\nnewDataStore: threadId:", getThreadId()
diff --git a/tests/datastore/testsharedds.nim b/tests/datastore/testthreadproxyds.nim
similarity index 95%
rename from tests/datastore/testsharedds.nim
rename to tests/datastore/testthreadproxyds.nim
index a0888d2..893ba1c 100644
--- a/tests/datastore/testsharedds.nim
+++ b/tests/datastore/testthreadproxyds.nim
@@ -9,18 +9,18 @@ import pkg/stew/results
 import pkg/stew/byteutils
 
 import pkg/datastore/memoryds
-import pkg/datastore/sharedds
+import pkg/datastore/threadproxyds
 
 import ./dscommontests
 import ./querycommontests
 
 import pretty
 
-suite "Test Basic SharedDatastore":
+suite "Test Basic ThreadProxyDatastore":
   var
-    sds: SharedDatastore
+    sds: ThreadProxyDatastore
     mem: MemoryDatastore
-    res: SharedDatastore
+    res: ThreadProxyDatastore
     key1: Key
     data: seq[byte]
 
@@ -50,11 +50,11 @@ suite "Test Basic SharedDatastore":
     # res3.cancel()
     # # print "res3: ", res3
 
-suite "Test Basic SharedDatastore":
+suite "Test Basic ThreadProxyDatastore":
 
   var
     memStore: MemoryDatastore
-    ds: SharedDatastore
+    ds: ThreadProxyDatastore
     key = Key.init("/a/b").tryGet()
     bytes = "some bytes".toBytes
     otherBytes = "some other bytes".toBytes