Working single post rendering

src/App.ts

@@ -236,9 +236,18 @@ export class App {
     for (let userID of userIDs) {
       // console.log.apply(null, log(`[app] announceUsers, got user:${userID} from peer ${sendingPeerID}`));
       this.sync.addUserPeer(userID, sendingPeerID);
-      if (!(this.sync.shouldSyncUserID(userID) || (this.router.route & (App.Route.USER | App.Route.POST) && userID === this.router.userID))) {
-        console.log.apply(null, log(`[app] announceUser_rpc_response skipping user[${logID(userID)}] from[${logID(sendingPeerID)}]`));
-        continue;
+
+      const isUserOrPostRoute = (this.router.route & (App.Route.USER | App.Route.POST)) !== 0;
+
+      if (isUserOrPostRoute) {
+        if (userID !== this.router.userID) {
+          continue;
+        }
+      } else {
+        if (!this.sync.shouldSyncUserID(userID)) {
+          console.log.apply(null, log(`[app] announceUser_rpc_response skipping user[${logID(userID)}] from[${logID(sendingPeerID)}]`));
+          continue;
+        }
       }
 
       console.log.apply(null, log(`[app] calling getPostIDsForUser for user [${logID(userID)}] on peer [${logID(sendingPeerID)}]`));
@@ -1091,7 +1100,10 @@ export class App {
     let posts: StoragePost[] = [];
 
     if (postID) {
-      posts = await getPostForUser(userID, postID);
+      const post = await getPostForUser(userID, postID);
+
+      posts = post ? [post] : [];
+
     } else {
       posts = await getData(userID, new Date(2022, 8), new Date());
     }

src/PeerManager.ts

@@ -538,7 +538,7 @@ class PeerConnection {
   private chunkSize = (16 * 1024) - 100;
   messageSuperlog: boolean = false;
   sendQueueSuperLog: boolean = false;
-  rpcSuperlog: boolean = true;
+  rpcSuperlog: boolean = false;
   pendingRPCs: Map<
     string,
     { resolve: Function; reject: Function; functionName: string }
@@ -553,12 +553,7 @@ class PeerConnection {
   static config = {
     iceServers: [
       { urls: "stun:ddln.app" },
-      // { urls: "turn:ddln.app", username: "a", credential: "b" },
-      { urls: "stun:stun.l.google.com" }, // keeping this for now as my STUN server is not returning ipv6
-      { urls: "stun:stun1.l.google.com" },
-      //{ urls: "stun:stun2.l.google.com" },
-      //{ urls: "stun:stun3.l.google.com" },
-      //{ urls: "stun:stun4.l.google.com" },
+      { urls: "turn:ddln.app", username: "ddln1", credential: "ddln1" },
     ],
   };
   // longMessageQueue: string[] = [];

src/Sync.ts

@@ -122,7 +122,8 @@ export class Sync {
         'e01eff89-5100-4b35-af4c-1c1bcb007dd0',
         '194696a2-d850-4bb0-98f7-47416b3d1662',
         'f6b21eb1-a0ff-435b-8efc-6a3dd70c0dca',
-        'dd1d92aa-aa24-4166-a925-94ba072a9048'
+        'dd1d92aa-aa24-4166-a925-94ba072a9048',
+        '290dbb4f-6ce1-491a-b90d-51d8efcd3d60'
     ]);
 
     getFollowing(userID: string): string[] {

src/db.ts

@@ -198,15 +198,28 @@ export async function clearData(userID: string) {
     }
 }
 
+
+// TODO - this function can return before the data is stored!
 export async function addDataArray(userID: string, array: any[]): Promise<void> {
     try {
         const { db, transaction, store } = await getDBTransactionStore(userID, "readwrite");
 
 
-        transaction.onerror = (event: Event) => {
-            console.error('Error in adding data:', event);
 
-        }
+
+        let completionPromise =  new Promise<void>((resolve, reject) => {
+            transaction.oncomplete = (event: Event) => {
+               resolve();
+            };
+
+            transaction.onerror = (event: Event) => {
+                console.error('Error in adding data:', event);
+                reject();
+            }
+        });
+
+
+
         // let count = 0;
 
         array.reverse();
@@ -230,6 +243,8 @@ export async function addDataArray(userID: string, array: any[]): Promise<void>
             // }
         }
 
+        return completionPromise;
+
 
     } catch (error) {
         console.error('Error in opening database:', error);