From fd372d09fc676e4fc07ea2e090b61b193166f018 Mon Sep 17 00:00:00 2001
From: Erki Aas <eaas@k-space.ee>
Date: Mon, 7 Nov 2022 16:43:22 +0200
Subject: [PATCH] Started with new streaming implementation

---
 src/components/LogViewer.vue | 28 ++++++++++++++++++++++------
 src/stores/index.js          | 13 ++++++++++++-
 2 files changed, 34 insertions(+), 7 deletions(-)

diff --git a/src/components/LogViewer.vue b/src/components/LogViewer.vue
index 7b4568b..f02bf15 100644
--- a/src/components/LogViewer.vue
+++ b/src/components/LogViewer.vue
@@ -1,7 +1,15 @@
 <template>
-  <div style="height: 100%; width: 100%">
+  <div style="height: 100%; width: 100%; text-align: right">
+      <v-btn
+          color="blue-grey"
+          class="ma-2"
+          :prepend-icon="streaming ? 'mdi-pause' :'mdi-play'"
+          @click="toggleFilterQueryStreaming"
+      >
+        Stream new lines
+      </v-btn>
   <ag-grid-vue
-      style="width: 100%; height: 100%;"
+      style="width: 100%; height: calc(100% - 52px);"
       class="ag-theme-material"
       @grid-ready="onGridReady"
       :defaultColDef="defaultColDef"
@@ -22,6 +30,7 @@
 import { AgGridVue } from "ag-grid-vue3";
 import "ag-grid-community/styles//ag-grid.css";
 import "ag-grid-community/styles//ag-theme-material.css";
+import { VBtn } from 'vuetify/components/VBtn'
 import ExamineLogModal from "./Modal/ExamineLogModal.vue";
 import ComboboxFilter from "./Filter/ComboboxFilter.js";
 import flattenObj from "../helpers/flattenObj";
@@ -33,7 +42,8 @@ export default {
   components: {
     ExamineLogModal,
     AgGridVue,
-    ComboboxFilter
+    ComboboxFilter,
+    VBtn
   },
   data() {
     return {
@@ -46,14 +56,18 @@ export default {
     }
   },
   computed: {
-    filterQuery() {
-      return this.$store.state.filterQuery
-    },
+    ...mapGetters([
+      'filterQuery',
+      'streaming',
+    ]),
   },
   watch: {
     filterQuery() {
       this.setupStream()
     },
+    streaming() {
+      this.setupStream()
+    },
   },
   created() {
     // TODO: monitor actual URL
@@ -63,6 +77,7 @@ export default {
     ...mapActions({
       setFilterOptions: 'setFilterOptions',
       setFilterQuery: 'setFilterQuery',
+      toggleFilterQueryStreaming: 'toggleFilterQueryStreaming',
     }),
     setupStream() {
       this.es && this.es.close();
@@ -103,6 +118,7 @@ export default {
               query[column.colId] = column.filterActive
             }
           })
+          query['streaming'] = this.streaming
           this.setFilterQuery(query)
         }
       });
diff --git a/src/stores/index.js b/src/stores/index.js
index c9737d8..9cb374b 100644
--- a/src/stores/index.js
+++ b/src/stores/index.js
@@ -3,9 +3,12 @@ import { createStore } from "vuex"
 const store = createStore({
   state: {
     filterOptions: {},
-    filterQuery: {}
+    filterQuery: {},
   },
   getters: {
+    streaming (state) {
+      return state.filterQuery['streaming'] ?? false
+    },
     filterQuery (state) {
       return state.filterQuery
     }
@@ -17,6 +20,9 @@ const store = createStore({
     setFilterQuery(context, payload) {
       context.commit("SET_FILTER_QUERY", payload);
     },
+    toggleFilterQueryStreaming(context) {
+      context.commit("TOGGLE_FILTER_QUERY_STREAMING");
+    },
   },
   mutations: {
     SET_FILTER_OPTIONS(state, payload) {
@@ -25,6 +31,11 @@ const store = createStore({
     SET_FILTER_QUERY(state, payload) {
       state.filterQuery = payload
     },
+    TOGGLE_FILTER_QUERY_STREAMING(state) {
+      let query = state.filterQuery
+      query['streaming'] = !(query['streaming'] ?? false)
+      state.filterQuery = query
+    },
   },
 });