- // Requests by pods id
- const requestsToMake = {}
-
- requests.forEach(function (poolRequest) {
- poolRequest.to.forEach(function (toPodId) {
- if (!requestsToMake[toPodId]) {
- requestsToMake[toPodId] = {
- ids: [],
- datas: []
+ // We want to group requests by destinations pod and endpoint
+ const requestsToMakeGrouped = {}
+ Object.keys(requests).forEach(function (toPodId) {
+ requests[toPodId].forEach(function (data) {
+ const request = data.request
+ const pod = data.pod
+ const hashKey = toPodId + request.endpoint
+
+ if (!requestsToMakeGrouped[hashKey]) {
+ requestsToMakeGrouped[hashKey] = {
+ toPod: pod,
+ endpoint: request.endpoint,
+ ids: [], // request ids, to delete them from the DB in the future
+ datas: [] // requests data,