From 1ca5ce53b87587fd6e2c11da81f9ddd049fc6752 Mon Sep 17 00:00:00 2001
From: Andrey Dolgolev <andrey@simiotics.com>
Date: Wed, 15 Sep 2021 18:10:44 +0300
Subject: [PATCH] Add load newer logic.

---
 frontend/src/components/EntriesNavigation.js | 10 ----------
 frontend/src/core/hooks/useStream.js         |  4 ++++
 2 files changed, 4 insertions(+), 10 deletions(-)

diff --git a/frontend/src/components/EntriesNavigation.js b/frontend/src/components/EntriesNavigation.js
index 504aeb16..f5593649 100644
--- a/frontend/src/components/EntriesNavigation.js
+++ b/frontend/src/components/EntriesNavigation.js
@@ -465,16 +465,6 @@ const EntriesNavigation = () => {
                 ))}
               {previousEvent && !eventsIsFetching ? (
                 <Center>
-                  <Button
-                    onClick={() => {
-                      setCursor(cursor + PAGE_SIZE);
-                    }}
-                    variant="outline"
-                    colorScheme="suggested"
-                  >
-                    {" "}
-                    Page++{`${cursor}/${streamCache.length}`}
-                  </Button>
                   <Button
                     onClick={() => {
                       console.log(streamCache.length > cursor + PAGE_SIZE);
diff --git a/frontend/src/core/hooks/useStream.js b/frontend/src/core/hooks/useStream.js
index 7b9d8ccb..67a44dc0 100644
--- a/frontend/src/core/hooks/useStream.js
+++ b/frontend/src/core/hooks/useStream.js
@@ -5,6 +5,7 @@ import { useQuery, useQueryClient } from "react-query";
 import { queryCacheProps } from "./hookCommon";
 import { defaultStreamBoundary } from "../services/servertime.service.js";
 import { PAGE_SIZE } from "../constants";
+import { useCounter } from "@chakra-ui/counter";
 const useStream = (q, streamCache, setStreamCache, cursor, setCursor) => {
   const [streamQuery, setStreamQuery] = useState(q || "");
   const [events, setEvents] = useState([]);
@@ -208,6 +209,9 @@ const useStream = (q, streamCache, setStreamCache, cursor, setCursor) => {
             let oldEventsList = streamCache;
 
             setStreamCache([...newEvents.events, ...oldEventsList]);
+            if (oldEventsList > 0) {
+              setCursor(cursor + newEvents.events.length);
+            }
 
             updateStreamBoundaryWith(newEvents.stream_boundary, {
               ignoreStart: true,