Replace EE with requestDeduplicator

src/graphql/operations/votes.ts

@@ -1,7 +1,7 @@
 import graphqlFields from 'graphql-fields';
 import db from '../../helpers/mysql';
 import { buildWhereQuery, checkLimits, formatProposal, formatSpace, formatVote } from '../helpers';
-import serve from '../../helpers/ee';
+import serve from '../../helpers/requestDeduplicator';
 import log from '../../helpers/log';
 import { capture } from '@snapshot-labs/snapshot-sentry';
 

src/helpers/requestDeduplicator.ts

@@ -0,0 +1,22 @@
+import { sha256 } from './utils';
+
+const ongoingRequests = new Map();
+
+export default async function serve(id, action, args) {
+  const key = sha256(id);
+  if (!ongoingRequests.has(key)) {
+    const requestPromise = action(...args)
+      .then(result => {
+        ongoingRequests.delete(key);
+        return result;
+      })
+      .catch(e => {
+        console.log('EventEmitter Error', e);
+        ongoingRequests.delete(key);
+        throw { error: true, e };
+      });
+    ongoingRequests.set(key, requestPromise);
+  }
+
+  return ongoingRequests.get(key);
+}