You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
86 lines
2.5 KiB
TypeScript
86 lines
2.5 KiB
TypeScript
import { Constants } from '../../../session';
|
|
|
|
export interface MessageFetchType {
|
|
messages: Array<any>;
|
|
messageFetchTimestamp: number;
|
|
newTopMessage: any;
|
|
previousTopMessage: any;
|
|
}
|
|
|
|
export async function getMessages(
|
|
conversationKey: string,
|
|
currentMessages: Array<any>,
|
|
messageFetchTimestamp: number,
|
|
unreadCount: number,
|
|
onGotMessages?: any,
|
|
numMessages?: number,
|
|
fetchInterval = Constants.CONVERSATION.MESSAGE_FETCH_INTERVAL
|
|
) {
|
|
const timestamp = getTimestamp();
|
|
|
|
// If we have pulled messages in the last interval, don't bother rescanning
|
|
// This avoids getting messages on every re-render.
|
|
const timeBuffer = timestamp - messageFetchTimestamp;
|
|
if (timeBuffer < fetchInterval) {
|
|
// Loopback gets messages after time has elapsed,
|
|
// rather than completely cancelling the fetch.
|
|
// if (loopback) {
|
|
// setTimeout(() => {
|
|
// this.getMessages(numMessages, fetchInterval, false);
|
|
// }, timeBuffer * 1000);
|
|
// }
|
|
|
|
return { newTopMessage: undefined, previousTopMessage: undefined };
|
|
}
|
|
|
|
let msgCount =
|
|
numMessages ||
|
|
Constants.CONVERSATION.DEFAULT_MESSAGE_FETCH_COUNT + unreadCount;
|
|
msgCount =
|
|
msgCount > Constants.CONVERSATION.MAX_MESSAGE_FETCH_COUNT
|
|
? Constants.CONVERSATION.MAX_MESSAGE_FETCH_COUNT
|
|
: msgCount;
|
|
|
|
const messageSet = await window.Signal.Data.getMessagesByConversation(
|
|
conversationKey,
|
|
{ limit: msgCount, MessageCollection: window.Whisper.MessageCollection }
|
|
);
|
|
|
|
// Set first member of series here.
|
|
const messageModels = messageSet.models;
|
|
const messages = [];
|
|
let previousSender;
|
|
for (let i = 0; i < messageModels.length; i++) {
|
|
// Handle firstMessageOfSeries for conditional avatar rendering
|
|
let firstMessageOfSeries = true;
|
|
if (i > 0 && previousSender === messageModels[i].authorPhoneNumber) {
|
|
firstMessageOfSeries = false;
|
|
}
|
|
|
|
messages.push({ ...messageModels[i], firstMessageOfSeries });
|
|
previousSender = messageModels[i].authorPhoneNumber;
|
|
}
|
|
|
|
const previousTopMessage = currentMessages[0]?.id;
|
|
const newTopMessage = messages[0]?.id;
|
|
|
|
const newMessageFetchTimestamp = getTimestamp();
|
|
|
|
// Callback to onGotMessages
|
|
if (onGotMessages) {
|
|
onGotMessages(
|
|
messages,
|
|
newMessageFetchTimestamp,
|
|
previousTopMessage,
|
|
newTopMessage
|
|
);
|
|
}
|
|
|
|
return { newTopMessage, previousTopMessage };
|
|
}
|
|
|
|
export function getTimestamp(asInt = false) {
|
|
const timestamp = Date.now() / 1000;
|
|
return asInt ? Math.floor(timestamp) : timestamp;
|
|
}
|