Function useFetchMessages

lib/shared/message-utils.js:625–675

(
  threadInfo: ThreadInfo,
)

  +numMessagesToFetch?: ?number,
};
function useFetchMessages(
  threadInfo: ThreadInfo,
): (options?: ?FetchMessagesOptions) => Promise<void> {
  const oldestMessageServerID = useOldestMessageServerID(threadInfo.id);
  const callFetchMessagesBeforeCursor = useFetchMessagesBeforeCursor();
  const callFetchMostRecentMessages = useFetchMostRecentMessages();
  const dispatchActionPromise = useDispatchActionPromise();
  const farcasterMessageFetching = useFarcasterMessageFetching();

  React.useEffect(() => {
    registerFetchKey(fetchMessagesBeforeCursorActionTypes);
    registerFetchKey(fetchMostRecentMessagesActionTypes);
  }, []);

  const threadID = threadInfo.id;
  const messageIDs = useSelector(
    state => state.messageStore.threads[threadID]?.messageIDs,
  );

  return React.useCallback(
    async (options?: ?FetchMessagesOptions) => {
      const numMessagesToFetch = options?.numMessagesToFetch;

      await threadSpecs[threadInfo.type].protocol().fetchMessages(
        {
          numMessagesToFetch,
          threadID,
          currentNumberOfFetchedMessages: messageIDs?.length ?? 0,
          oldestMessageServerID,
        },
        {
          fetchMessagesFromDB,
          keyserverFetchMessagesBeforeCursor: callFetchMessagesBeforeCursor,
          keyserverFetchMostRecentMessages: callFetchMostRecentMessages,
          dispatchActionPromise,
          farcasterMessageFetching,
        },
      );
    },
    [
      callFetchMessagesBeforeCursor,
      callFetchMostRecentMessages,
      dispatchActionPromise,
      farcasterMessageFetching,
      messageIDs?.length,
      oldestMessageServerID,
      threadID,
      threadInfo.type,
    ],
  );
}

export {
  robotextForMessageInfo,