Merge pull request #416 from shocknet/share-posts-fixes

Share posts fixes
shocknet · Nov 25, 2020 · 7f5d07d · 7f5d07d
2 parents a2869aa + 4280806
commit 7f5d07d
Showing 1 changed file with 3 additions and 6 deletions.
diff --git a/app/store/sagas/shared-posts.ts b/app/store/sagas/shared-posts.ts
@@ -1,4 +1,4 @@
-import { eventChannel, END, EventChannel } from 'redux-saga'
+import { eventChannel, END, EventChannel, buffers } from 'redux-saga'
 import {
   takeEvery,
   select,
@@ -35,15 +35,11 @@ const handleShockEvent = (
       pickBy(data, v => v !== null),
     ).filter(k => k !== '_')
 
-    console.log(sharedPostsReceived)
-
     const sharedPostsDeleted = Object.keys(
       // get deleted sharedPosts
       pickBy(data, v => v == null),
     ).filter(k => k !== '_')
 
-    console.log(sharedPostsDeleted)
-
     if (size(sharedPostsDeleted)) {
       emit(
         Actions.removedSeveralSharedPosts(
@@ -116,7 +112,7 @@ function createSocketChannel(
       socket.off('*')
       socket.close()
     }
-  })
+  }, buffers.expanding(10))
 }
 
 function* handlePublicKeySocket(chan: EventChannel<RelevantAction>) {
@@ -174,6 +170,7 @@ function* watchSharedPosts() {
 
         yield cancel(task)
       }
+      publicKeysWithSockets.clear()
     }
   } catch (e) {
     Logger.log(`Error inside watchSharedPosts*()`)