kopia lustrzana https://github.com/bugout-dev/moonstream
Add load older events in second request.
rodzic
700fab47f5
commit
e5b48e4674
|
@ -58,7 +58,7 @@ MOONSTREAM_ETHEREUM_WEB3_PROVIDER_URI = os.environ.get(
|
|||
"MOONSTREAM_ETHEREUM_WEB3_PROVIDER_URI", ""
|
||||
)
|
||||
if MOONSTREAM_ETHEREUM_WEB3_PROVIDER_URI == "":
|
||||
raise ValueError("MOONSTREAM_WEB3_PROVIDER_URI environment variable must be set")
|
||||
raise ValueError("MOONSTREAM_ETHEREUM_WEB3_PROVIDER_URI environment variable must be set")
|
||||
MOONSTREAM_NODE_ETHEREUM_IPC_PORT = os.environ.get(
|
||||
"MOONSTREAM_NODE_ETHEREUM_IPC_PORT", 8545
|
||||
)
|
||||
|
|
|
@ -60,6 +60,7 @@ const EntriesNavigation = () => {
|
|||
const { cursor, setCursor, streamCache, setStreamCache } =
|
||||
useContext(DataContext);
|
||||
const ui = useContext(UIContext);
|
||||
const [firstLoading, setFirstLoading] = useState(true);
|
||||
const { isOpen, onOpen, onClose } = useDisclosure();
|
||||
const { subscriptionsCache } = useSubscriptions();
|
||||
const [initialized, setInitialized] = useState(false);
|
||||
|
@ -87,6 +88,7 @@ const EntriesNavigation = () => {
|
|||
loadNewerEventsIsFetching,
|
||||
previousEventIsFetching,
|
||||
nextEventIsFetching,
|
||||
olderEvent,
|
||||
} = useStream(
|
||||
ui.searchTerm.q,
|
||||
streamCache,
|
||||
|
@ -104,6 +106,13 @@ const EntriesNavigation = () => {
|
|||
nextEventRefetch();
|
||||
previousEventRefetch();
|
||||
setInitialized(true);
|
||||
} else if (
|
||||
streamCache.length == 0 &&
|
||||
olderEvent?.event_timestamp &&
|
||||
firstLoading
|
||||
) {
|
||||
loadPreviousEventHandler();
|
||||
setFirstLoading(false);
|
||||
}
|
||||
}, [
|
||||
streamBoundary,
|
||||
|
|
|
@ -367,6 +367,7 @@ const useStream = (q, streamCache, setStreamCache, cursor, setCursor) => {
|
|||
loadNewerEventsIsFetching,
|
||||
loadPreviousEventHandler,
|
||||
loadNewesEventHandler,
|
||||
olderEvent,
|
||||
};
|
||||
};
|
||||
export default useStream;
|
||||
|
|
Ładowanie…
Reference in New Issue