yarn lint

pull/518/head
sachaaaaa 6 years ago
parent a28c581666
commit 7549c45716

@ -594,18 +594,21 @@ class LokiPublicChannelAPI {
more = res.response.meta.more && res.response.data.length >= params.count; more = res.response.meta.more && res.response.data.length >= params.count;
} }
} }
async getMessengerData(adnMessage) { async getMessengerData(adnMessage) {
if (!Array.isArray(adnMessage.annotations) || adnMessage.annotations.length === 0) { if (
!Array.isArray(adnMessage.annotations) ||
adnMessage.annotations.length === 0
) {
return false; return false;
} }
const noteValue = adnMessage.annotations[0].value; const noteValue = adnMessage.annotations[0].value;
// signatures now required // signatures now required
if (!noteValue.sig || typeof noteValue.sig !== 'string') { if (!noteValue.sig || typeof noteValue.sig !== 'string') {
return false; return false;
} }
// timestamp is the only required field we've had since the first deployed version // timestamp is the only required field we've had since the first deployed version
const { timestamp, quote } = noteValue; const { timestamp, quote } = noteValue;
@ -615,7 +618,7 @@ class LokiPublicChannelAPI {
// try to verify signature // try to verify signature
const { sig, sigver } = noteValue; const { sig, sigver } = noteValue;
const annoCopy = [ ...adnMessage.annotations ]; const annoCopy = [...adnMessage.annotations];
// strip out sig and sigver // strip out sig and sigver
annoCopy[0] = _.omit(annoCopy[0], ['value.sig', 'value.sigver']); annoCopy[0] = _.omit(annoCopy[0], ['value.sig', 'value.sigver']);
const verifyObj = { const verifyObj = {
@ -626,10 +629,8 @@ class LokiPublicChannelAPI {
if (adnMessage.reply_to) { if (adnMessage.reply_to) {
verifyObj.reply_to = adnMessage.reply_to; verifyObj.reply_to = adnMessage.reply_to;
} }
const pubKeyBin = StringView.hexToArrayBuffer( const pubKeyBin = StringView.hexToArrayBuffer(adnMessage.user.username);
adnMessage.user.username
);
const sigBin = StringView.hexToArrayBuffer(sig); const sigBin = StringView.hexToArrayBuffer(sig);
try { try {
await libsignal.Curve.async.verifySignature( await libsignal.Curve.async.verifySignature(
@ -664,12 +665,12 @@ class LokiPublicChannelAPI {
log.error(`Unhandled message signature validation error ${e.message}`); log.error(`Unhandled message signature validation error ${e.message}`);
return false; return false;
} }
return { return {
timestamp, timestamp,
quote, quote,
} };
} }
// get channel messages // get channel messages
async pollForMessages() { async pollForMessages() {
@ -706,7 +707,6 @@ class LokiPublicChannelAPI {
if (!res.err && res.response) { if (!res.err && res.response) {
let receivedAt = new Date().getTime(); let receivedAt = new Date().getTime();
res.response.data.reverse().forEach(async adnMessage => { res.response.data.reverse().forEach(async adnMessage => {
// still update our last received if deleted, not signed or not valid // still update our last received if deleted, not signed or not valid
this.lastGot = !this.lastGot this.lastGot = !this.lastGot
? adnMessage.id ? adnMessage.id
@ -722,7 +722,7 @@ class LokiPublicChannelAPI {
) { ) {
return; // Invalid or delete message return; // Invalid or delete message
} }
const messengerData = await this.getMessengerData(adnMessage); const messengerData = await this.getMessengerData(adnMessage);
if (messengerData === false) { if (messengerData === false) {
return; return;
@ -732,7 +732,7 @@ class LokiPublicChannelAPI {
if (!timestamp) { if (!timestamp) {
return; // Invalid message return; // Invalid message
} }
// Duplicate check // Duplicate check
const isDuplicate = message => { const isDuplicate = message => {
// The username in this case is the users pubKey // The username in this case is the users pubKey
@ -760,9 +760,9 @@ class LokiPublicChannelAPI {
timestamp, timestamp,
}, },
].splice(-5); ].splice(-5);
const from = adnMessage.user.name; // profileName const from = adnMessage.user.name; // profileName
const messageData = { const messageData = {
serverId: adnMessage.id, serverId: adnMessage.id,
clientVerified: true, clientVerified: true,
@ -802,7 +802,6 @@ class LokiPublicChannelAPI {
// now process any user meta data updates // now process any user meta data updates
// - update their conversation with a potentially new avatar // - update their conversation with a potentially new avatar
}); });
this.conversation.setLastRetrievedMessage(this.lastGot); this.conversation.setLastRetrievedMessage(this.lastGot);
} }

Loading…
Cancel
Save