|
|
@ -553,8 +553,6 @@
|
|
|
|
}
|
|
|
|
}
|
|
|
|
);
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
console.log('[vince][fr] messages:', messages);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (typeof status === 'string') {
|
|
|
|
if (typeof status === 'string') {
|
|
|
|
// eslint-disable-next-line no-param-reassign
|
|
|
|
// eslint-disable-next-line no-param-reassign
|
|
|
|
status = [status];
|
|
|
|
status = [status];
|
|
|
@ -562,12 +560,6 @@
|
|
|
|
// Get the pending friend requests that match the direction
|
|
|
|
// Get the pending friend requests that match the direction
|
|
|
|
// If no direction is supplied then return all pending friend requests
|
|
|
|
// If no direction is supplied then return all pending friend requests
|
|
|
|
return messages.models.filter(m => {
|
|
|
|
return messages.models.filter(m => {
|
|
|
|
console.log('[vince][fr] status:', status);
|
|
|
|
|
|
|
|
console.log('[vince][fr] m.get(`friendStatus`):', m.get('friendStatus'));
|
|
|
|
|
|
|
|
console.log('[vince][fr] m:', m);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
console.log('[vince][fr] status.includes(m.get(`friendStatus`):', status.includes(m.get('friendStatus')));
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!status.includes(m.get('friendStatus'))) {
|
|
|
|
if (!status.includes(m.get('friendStatus'))) {
|
|
|
|
return false;
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -997,14 +989,24 @@
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
const allConversationsWithUser = allDevices.map(d => ConversationController.get(d));
|
|
|
|
const allConversationsWithUser = allDevices.map(d =>
|
|
|
|
|
|
|
|
ConversationController.get(d)
|
|
|
|
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
const pendingRequests = await allConversationsWithUser.reduce(async (requestsP, conversation) => {
|
|
|
|
const pendingRequests = await allConversationsWithUser.reduce(
|
|
|
|
|
|
|
|
async (requestsP, conversation) => {
|
|
|
|
const requests = await requestsP;
|
|
|
|
const requests = await requestsP;
|
|
|
|
const request = (await conversation.getFriendRequests(direction, status))[0];
|
|
|
|
const request = (await conversation.getFriendRequests(
|
|
|
|
|
|
|
|
direction,
|
|
|
|
|
|
|
|
status
|
|
|
|
|
|
|
|
))[0];
|
|
|
|
|
|
|
|
|
|
|
|
return request ? requests.concat({ conversation, request }) : requests;
|
|
|
|
return request
|
|
|
|
}, []);
|
|
|
|
? requests.concat({ conversation, request })
|
|
|
|
|
|
|
|
: requests;
|
|
|
|
|
|
|
|
},
|
|
|
|
|
|
|
|
[]
|
|
|
|
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
|
|
await Promise.all(
|
|
|
|
await Promise.all(
|
|
|
|
pendingRequests.map(async friendRequest => {
|
|
|
|
pendingRequests.map(async friendRequest => {
|
|
|
@ -1680,8 +1682,6 @@
|
|
|
|
const model = this.addSingleMessage(attributes);
|
|
|
|
const model = this.addSingleMessage(attributes);
|
|
|
|
const message = MessageController.register(model.id, model);
|
|
|
|
const message = MessageController.register(model.id, model);
|
|
|
|
|
|
|
|
|
|
|
|
console.log('[vince][core] Sending message:', message);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
await window.Signal.Data.saveMessage(message.attributes, {
|
|
|
|
await window.Signal.Data.saveMessage(message.attributes, {
|
|
|
|
forceSave: true,
|
|
|
|
forceSave: true,
|
|
|
|
Message: Whisper.Message,
|
|
|
|
Message: Whisper.Message,
|
|
|
|