From 789cba142e62549c467ff3e693dfb4c689a2f2c8 Mon Sep 17 00:00:00 2001
From: fiatjaf <fiatjaf@alhur.es>
Date: Thu, 18 Feb 2021 20:22:06 -0300
Subject: [PATCH] finish removing ramda.

---
 pool.js | 34 +++++++++++++++++-----------------
 1 file changed, 17 insertions(+), 17 deletions(-)

diff --git a/pool.js b/pool.js
index f3232dc..dc2b9d8 100644
--- a/pool.js
+++ b/pool.js
@@ -1,8 +1,6 @@
 import {getEventHash, signEvent} from './event'
 import {relayConnect, normalizeRelayURL} from './relay'
 
-const R = require('ramda')
-
 export function relayPool(globalPrivateKey) {
   const relays = {}
   const globalSub = []
@@ -101,21 +99,23 @@ export function relayPool(globalPrivateKey) {
         }
       }
 
-      await R.map(async relay => {
-        try {
-          await relay.publish(event)
-          statusCallback(0, relay.url)
-          let {unsub} = relay.sub(
-            () => {
-              statusCallback(1, relay.url)
-            },
-            {id: event.id}
-          )
-          setTimeout(unsub, 5000)
-        } catch (err) {
-          statusCallback(-1, relay.url)
-        }
-      }, R.filter(R.pipe(R.prop('policy'), R.prop('write'), R.equals(true)), relays))
+      Object.values(relays)
+        .filter(({policy}) => policy.write)
+        .map(async ({relay}) => {
+          try {
+            await relay.publish(event)
+            statusCallback(0, relay.url)
+            let {unsub} = relay.sub(
+              () => {
+                statusCallback(1, relay.url)
+              },
+              {id: event.id}
+            )
+            setTimeout(unsub, 5000)
+          } catch (err) {
+            statusCallback(-1, relay.url)
+          }
+        })
 
       return event
     }