Fixed bugs with http being appended at wrong time and lastHash not being sent properly

pull/258/head
Beaudan 7 years ago
parent 531ee92dcb
commit 929d272fcc

@ -39,7 +39,7 @@ const fetch = async (url, options = {}) => {
}); });
if (!response.ok) { if (!response.ok) {
throw new textsecure.HTTPError(response); throw new textsecure.HTTPError('Loki_fetch error', response);
} }
let result; let result;

@ -97,7 +97,7 @@ class LokiMessageAPI {
}; };
try { try {
await rpc(nodeUrl, this.snodeServerPort, 'store', params); await rpc(`http://${nodeUrl}`, this.snodeServerPort, 'store', params);
nodeComplete(nodeUrl); nodeComplete(nodeUrl);
successfulRequests += 1; successfulRequests += 1;
@ -150,7 +150,7 @@ class LokiMessageAPI {
await Promise.all( await Promise.all(
swarmNodes swarmNodes
.splice(0, remainingRequests) .splice(0, remainingRequests)
.map(nodeUrl => doRequest(`http://${nodeUrl}`)) .map(nodeUrl => doRequest(nodeUrl))
); );
} }
log.info(`Successful storage message to ${pubKey}`); log.info(`Successful storage message to ${pubKey}`);
@ -177,7 +177,7 @@ class LokiMessageAPI {
try { try {
const result = await rpc( const result = await rpc(
nodeUrl, `http://${nodeUrl}`,
this.snodeServerPort, this.snodeServerPort,
'retrieve', 'retrieve',
params params
@ -186,7 +186,7 @@ class LokiMessageAPI {
nodeComplete(nodeUrl); nodeComplete(nodeUrl);
if (Array.isArray(result.messages) && result.messages.length) { if (Array.isArray(result.messages) && result.messages.length) {
const lastHash = [...result.messages].pop(); const lastHash = [...result.messages].pop().hash;
lokiSnodeAPI.updateLastHash(nodeUrl, lastHash); lokiSnodeAPI.updateLastHash(nodeUrl, lastHash);
callback(result.messages); callback(result.messages);
} }
@ -238,9 +238,7 @@ class LokiMessageAPI {
await Promise.all( await Promise.all(
Object.entries(ourSwarmNodes) Object.entries(ourSwarmNodes)
.splice(0, remainingRequests) .splice(0, remainingRequests)
.map(([nodeUrl, nodeData]) => .map(([nodeUrl, nodeData]) => doRequest(nodeUrl, nodeData))
doRequest(`http://${nodeUrl}`, nodeData)
)
); );
} }
} }

Loading…
Cancel
Save