From 1923ebe9cffeac9afe00b688e22c8a53ba90a75b Mon Sep 17 00:00:00 2001
From: Rafael Araujo Lehmkuhl <rafael.lehmkuhl93@gmail.com>
Date: Fri, 24 Jan 2025 11:19:30 -0300
Subject: [PATCH] data-lake: Add dedicated menu for monitoring variables

---
 src/App.vue                             |   6 +
 src/views/ConfigurationDataLakeView.vue | 220 ++++++++++++++++++++++++
 2 files changed, 226 insertions(+)
 create mode 100644 src/views/ConfigurationDataLakeView.vue

diff --git a/src/App.vue b/src/App.vue
index 295e8eb98..ab419744c 100644
--- a/src/App.vue
+++ b/src/App.vue
@@ -351,6 +351,7 @@ import { useWidgetManagerStore } from './stores/widgetManager'
 import { ConfigComponent } from './types/general'
 import ConfigurationActionsView from './views/ConfigurationActionsView.vue'
 import ConfigurationAlertsView from './views/ConfigurationAlertsView.vue'
+import ConfigurationDataLakeView from './views/ConfigurationDataLakeView.vue'
 import ConfigurationDevelopmentView from './views/ConfigurationDevelopmentView.vue'
 import ConfigurationGeneralView from './views/ConfigurationGeneralView.vue'
 import ConfigurationJoystickView from './views/ConfigurationJoystickView.vue'
@@ -423,6 +424,11 @@ const configMenu = [
     title: 'Mission',
     component: markRaw(ConfigurationMissionView) as ConfigComponent,
   },
+  {
+    icon: 'mdi-database-outline',
+    title: 'Data-lake',
+    component: markRaw(ConfigurationDataLakeView) as ConfigComponent,
+  },
   {
     icon: 'mdi-run-fast',
     title: 'Actions',
diff --git a/src/views/ConfigurationDataLakeView.vue b/src/views/ConfigurationDataLakeView.vue
new file mode 100644
index 000000000..8818d23fc
--- /dev/null
+++ b/src/views/ConfigurationDataLakeView.vue
@@ -0,0 +1,220 @@
+<template>
+  <BaseConfigurationView>
+    <template #title>Data Lake</template>
+    <template #content>
+      <div class="flex-col overflow-y-auto ml-[10px] pr-3 -mr-[10px] -mb-[10px] max-h-[80vh]">
+        <ExpansiblePanel no-top-divider no-bottom-divider :is-expanded="!interfaceStore.isOnPhoneScreen">
+          <template #title>Variables monitor</template>
+          <template #info>
+            <p>View, manage, and create data lake variables.</p>
+          </template>
+          <template #content>
+            <div class="flex justify-center flex-col ml-2 mb-8 mt-2 w-full h-full">
+              <div class="mb-4 flex items-center gap-2">
+                <div class="relative flex-1">
+                  <input
+                    v-model="searchQuery"
+                    type="text"
+                    placeholder="Search variables..."
+                    class="w-full px-3 py-2 bg-[#FFFFFF22] rounded-md text-white placeholder-gray-400 outline-none focus:ring-2 focus:ring-blue-500"
+                  />
+                  <span
+                    v-if="searchQuery"
+                    class="absolute right-2 top-1/2 -translate-y-1/2 text-gray-400 hover:text-white cursor-pointer mdi mdi-close-circle"
+                    @click="searchQuery = ''"
+                  />
+                </div>
+              </div>
+              <v-data-table
+                :items="filteredVariables"
+                items-per-page="10"
+                density="compact"
+                class="w-full h-full rounded-md bg-[#FFFFFF11] elevation-1"
+                theme="dark"
+                :style="interfaceStore.globalGlassMenuStyles"
+                :headers="[
+                  { title: 'Name', align: 'start', key: 'name', width: '220px', fixed: true },
+                  { title: 'ID', align: 'start', key: 'id', width: '200px', fixed: true },
+                  { title: 'Type', align: 'center', key: 'type', width: '100px', fixed: true },
+                  { title: 'Current Value', align: 'start', key: 'value', width: '220px', fixed: true },
+                ]"
+                :header-props="{ style: { backgroundColor: 'rgba(0, 0, 0, 0.1)' } }"
+              >
+                <template #item="{ item }">
+                  <tr>
+                    <td>
+                      <div class="flex items-center justify-left rounded-xl mx-1 w-[220px]">
+                        <p class="w-full whitespace-nowrap overflow-hidden text-ellipsis">{{ item.name }}</p>
+                      </div>
+                    </td>
+                    <td>
+                      <div class="flex items-center justify-start gap-2 rounded-xl mx-1">
+                        <p class="w-[200px] whitespace-nowrap overflow-hidden text-ellipsis">{{ item.id }}</p>
+                        <button
+                          :class="[
+                            'transition-colors duration-200',
+                            copiedId === item.id
+                              ? 'text-green-400 hover:text-green-400'
+                              : 'text-gray-400 hover:text-white',
+                          ]"
+                          title="Copy ID"
+                          @click="handleCopy(item.id)"
+                        >
+                          <span class="mdi mdi-content-copy" />
+                        </button>
+                      </div>
+                    </td>
+                    <td>
+                      <div class="flex items-center justify-center rounded-xl mx-1">
+                        <p class="w-[100px] whitespace-nowrap overflow-hidden text-ellipsis text-center">
+                          {{ item.type }}
+                        </p>
+                      </div>
+                    </td>
+                    <td>
+                      <div class="flex items-center justify-start rounded-xl mx-1">
+                        <p class="w-[220px] whitespace-nowrap overflow-hidden text-ellipsis text-left font-mono">
+                          {{ parsedCurrentValue(item.id) }}
+                        </p>
+                      </div>
+                    </td>
+                  </tr>
+                </template>
+                <template #no-data>
+                  <tr>
+                    <td colspan="4" class="text-center flex items-center justify-center h-[50px] w-full">
+                      <p class="text-[16px] ml-[170px] w-full">No data lake variables found</p>
+                    </td>
+                  </tr>
+                </template>
+              </v-data-table>
+            </div>
+          </template>
+        </ExpansiblePanel>
+      </div>
+    </template>
+  </BaseConfigurationView>
+</template>
+
+<script setup lang="ts">
+import Fuse from 'fuse.js'
+import { computed, onMounted, onUnmounted, ref, watch } from 'vue'
+
+import ExpansiblePanel from '@/components/ExpansiblePanel.vue'
+import {
+  DataLakeVariable,
+  getAllDataLakeVariablesInfo,
+  getDataLakeVariableData,
+  listenDataLakeVariable,
+  listenToDataLakeVariablesInfoChanges,
+  unlistenDataLakeVariable,
+  unlistenToDataLakeVariablesInfoChanges,
+} from '@/libs/actions/data-lake'
+import { copyToClipboard } from '@/libs/utils'
+import { useAppInterfaceStore } from '@/stores/appInterface'
+
+import BaseConfigurationView from './BaseConfigurationView.vue'
+
+const interfaceStore = useAppInterfaceStore()
+
+const copiedId = ref<string | null>(null)
+const handleCopy = async (id: string): Promise<void> => {
+  await copyToClipboard(id)
+  copiedId.value = id
+  setTimeout(() => {
+    copiedId.value = null
+  }, 2000)
+}
+
+const availableDataLakeVariables = ref<DataLakeVariable[]>([])
+const currentValues = ref<Record<string, string | number | boolean | undefined>>({})
+
+const listeners = ref<Record<string, string>>({})
+let dataLakeVariableInfoListenerId: string | undefined
+
+const setupVariableListeners = (): void => {
+  cleanupVariableListeners()
+
+  availableDataLakeVariables.value.forEach((variable) => {
+    currentValues.value[variable.id] = getDataLakeVariableData(variable.id)
+
+    const listenerId = listenDataLakeVariable(variable.id, (value) => {
+      currentValues.value[variable.id] = value
+    })
+
+    listeners.value[variable.id] = listenerId
+  })
+}
+
+const cleanupVariableListeners = (): void => {
+  Object.entries(listeners.value).forEach(([id, listenerId]) => {
+    console.log(`Unlistening to ${id}.`)
+    unlistenDataLakeVariable(id, listenerId)
+  })
+}
+
+onMounted(() => {
+  availableDataLakeVariables.value = Object.values(getAllDataLakeVariablesInfo())
+  dataLakeVariableInfoListenerId = listenToDataLakeVariablesInfoChanges((variables) => {
+    availableDataLakeVariables.value = Object.values(variables)
+  })
+
+  setupVariableListeners()
+})
+
+onUnmounted(() => {
+  cleanupVariableListeners()
+
+  if (dataLakeVariableInfoListenerId) {
+    unlistenToDataLakeVariablesInfoChanges(dataLakeVariableInfoListenerId)
+  }
+})
+
+watch(availableDataLakeVariables, () => setupVariableListeners())
+
+const parsedCurrentValue = (id: string): string => {
+  if (currentValues.value[id] === undefined) return ''
+
+  if (availableDataLakeVariables.value.find((variable) => variable.id === id)?.type === 'number') {
+    return String(currentValues.value[id])
+  }
+
+  return String(currentValues.value[id])
+}
+
+/**
+ * Search query for filtering variables
+ */
+const searchQuery = ref('')
+
+/**
+ * Computed property that returns filtered variables based on the search query
+ * Uses Fuse.js for fuzzy search on variable names and descriptions
+ */
+const filteredVariables = computed(() => {
+  if (!searchQuery.value) return availableDataLakeVariables.value
+
+  const fuse = new Fuse<DataLakeVariable>(availableDataLakeVariables.value, {
+    keys: ['name', 'description'],
+    threshold: 0.3,
+  })
+  return fuse.search(searchQuery.value).map((result) => result.item)
+})
+</script>
+
+<style scoped>
+.v-data-table ::v-deep tbody tr:hover {
+  background-color: rgba(0, 0, 0, 0.1) !important;
+}
+
+:deep(.v-data-table) {
+  height: 100%;
+  display: flex;
+  flex-direction: column;
+  table-layout: fixed;
+}
+
+:deep(.v-data-table__wrapper) {
+  flex-grow: 1;
+}
+</style>