[MOD/WIP] Separate DB entries for the txns

src/User.c

@@ -977,39 +977,57 @@ HashMap *
 UserGetTransaction(User *user, char *transaction, char *path)
 {
     HashMap *devices;
+    DbRef *ref;
 
     if (!user || !transaction || !path)
     {
         return NULL;
     } 
 
-    devices = JsonValueAsObject(
+    ref = DbLock(user->db, 
-        HashMapGet(UserGetDevices(user), UserGetDeviceId(user))
+        4, 
+        "users", user->name, 
+        "txns", UserGetDeviceId(user)
     );
 
-    return JsonDuplicate(JsonValueAsObject(
+    devices = DbJson(ref);
-        JsonGet(devices, 3, "transactions", path, transaction)
+    devices = JsonValueAsObject(JsonGet(devices, 2, path, transaction));
-    ));
+    devices = JsonDuplicate(devices);
+    DbUnlock(user->db, ref);
 
+    return devices;
 }
 
 void
 UserSetTransaction(User *user, char *transaction, char *path, HashMap *resp)
 {
     HashMap *devices;
+    DbRef *ref;
     if (!user || !transaction || !path || !resp)
     {
         return;
     } 
-    devices = JsonValueAsObject(
+    if (!(ref = DbLock(user->db, 
-        HashMapGet(UserGetDevices(user), UserGetDeviceId(user))
+        4, 
+        "users", user->name, 
+        "txns", UserGetDeviceId(user)
+    )))
+    {
+        ref = DbCreate(user->db, 
+            4, 
+            "users", user->name, 
+            "txns", UserGetDeviceId(user)
         );
+    }
+    devices = DbJson(ref);
 
     /* Overwrite the transaction */
     JsonValueFree(JsonSet(
         devices, JsonValueObject(JsonDuplicate(resp)),
-        3, "transactions", path, transaction
+        2, path, transaction
     ));
+
+    DbUnlock(user->db, ref);
 }
 void
 UserAddInvite(User *user, char *roomId)