Fix demo folder generation

README.md

@@ -15,7 +15,7 @@ make update
 make all
 
 # Run the Text Interface
-./build/tui
+./build/tui --name=<unique_id>
 ```
 
 ## Details

examples/pingpong.nim

@@ -0,0 +1,69 @@
+import chronicles
+import chronos
+
+import chat_sdk
+import content_types
+
+
+proc getContent(content: ContentFrame): string =
+  # Skip type checks and assume its a TextFrame
+  let m = decode(content.bytes, TextFrame).valueOr:
+        raise newException(ValueError, fmt"Badly formed Content")
+      return fmt"{m}"
+
+proc main() {.async.} =
+
+  # Create Configurations
+  var cfg_saro = DefaultConfig()
+  var cfg_raya = DefaultConfig()
+
+  # Cross pollinate Peers - No Waku discovery is used in this example
+  cfg_saro.staticPeers.add(cfg_raya.getMultiAddr())
+  cfg_raya.staticPeers.add(cfg_saro.getMultiAddr())
+
+  # Create Clients
+  var saro = newClient(cfg_saro, createIdentity("Saro"))
+  var raya = newClient(cfg_raya, createIdentity("Raya"))
+
+  # Wire Callbacks
+  saro.onNewMessage(proc(convo: Conversation, msg: ContentFrame) {.async.} =
+    echo "    Saro  <------        :: " & getContent(msg)
+    await sleepAsync(10000)
+    discard await convo.sendMessage(saro.ds, initTextFrame("Ping").toContentFrame())
+    )
+
+  saro.onDeliveryAck(proc(convo: Conversation, msgId: string) {.async.} =
+    echo "    Saro -- Read Receipt for " & msgId
+  )
+
+
+
+
+  raya.onNewMessage(proc(convo: Conversation, msg: ContentFrame) {.async.} =
+    echo "           ------>  Raya :: " & getContent(msg)
+    await sleepAsync(10000)
+    sdiscard  await convo.sendMessage(raya.ds, initTextFrame("Pong").toContentFrame())
+  )
+
+  raya.onNewConversation(proc(convo: Conversation) {.async.} =
+    echo "           ------>  Raya :: New Conversation: " & convo.id()
+    discard await convo.sendMessage(raya.ds, initTextFrame("Hello").toContentFrame())
+  )
+  raya.onDeliveryAck(proc(convo: Conversation, msgId: string) {.async.} =
+    echo "    raya -- Read Receipt for " & msgId
+  )
+
+
+  await saro.start()
+  await raya.start()
+
+  await sleepAsync(5000)
+
+  # Perform OOB Introduction: Raya -> Saro
+  let raya_bundle = raya.createIntroBundle()
+  discard await saro.newPrivateConversation(raya_bundle)
+
+  await sleepAsync(10000) # Run for some time 
+
+  saro.stop()
+  raya.stop()

examples/tui/persistence.nim

@@ -57,8 +57,12 @@ proc toIdent(s: SavedConfig): Identity =
 proc register(name: string, multiAddr: string) {.async.} =
 
   notice "Registering Account", name=name, maddr=multiAddr
+
+  if not dirExists(REGISTRATION_DIR):
+    createDir(REGISTRATION_DIR)
+
   try:
-    writeFile(joinPath(".registry", fmt"{name.toLower()}.maddr"), multiAddr)
+    writeFile(joinPath(REGISTRATION_DIR, fmt"{name.toLower()}.maddr"), multiAddr)
   except IOError as e:
     echo "Failed to write registration file: ", e.msg
     raise e
@@ -105,6 +109,10 @@ proc saveCfg(name:string, cfg: Config) =
 
   let json = jsonutils.toJson(s)
 
+
+  if not dirExists(KEY_DIR):
+    createDir(KEY_DIR)
+
   try:
     writeFile(joinPath(KEY_DIR, fmt"{name.toLower()}.cfg"), $json)
   except IOError as e: