feat: enhance realtime globe functionality

- Reintroduced the realtime dashboard tab in the navigation menu.
- Updated Globe component to utilize geographic coordinates for live session locations.
- Added dynamic resizing for the globe based on viewport width.
- Implemented stop rotation feature on mouse down for better user interaction.
- Cleaned up commented code and improved type definitions in event logging.

app/components/dashboard/Nav.vue

@@ -18,9 +18,9 @@ const route = useRoute()
         <TabsTrigger value="/dashboard/analysis">
           {{ $t('nav.analysis') }}
         </TabsTrigger>
-        <!-- <TabsTrigger value="/dashboard/realtime">
+        <TabsTrigger value="/dashboard/realtime">
           {{ $t('nav.realtime') }}
-        </TabsTrigger> -->
+        </TabsTrigger>
       </TabsList>
     </Tabs>
     <slot name="left" />

app/components/dashboard/realtime/Globe.vue

@@ -1,49 +1,74 @@
 <script setup>
+import { useElementSize } from '@vueuse/core'
 import { scaleSequentialSqrt } from 'd3-scale'
 import { interpolateYlOrRd } from 'd3-scale-chromatic'
 import Globe from 'globe.gl'
 import { debounce } from 'lodash-es'
+import { MeshPhongMaterial } from 'three'
+
+const props = defineProps({
+  minutes: {
+    type: Number,
+    default: 60,
+  },
+})
 
 const countries = ref({})
+const locations = ref([])
 
-async function getWorldMapJSON() {
+const el = useTemplateRef('globeEl')
+const { width } = useElementSize(el)
+const size = computed(() => ({
+  width: width.value,
+  height: width.value > 768 ? width.value * 0.6 : width.value,
+}))
+
+const globeEl = ref()
+const hexAltitude = ref(0.001)
+const highest = computed(() => {
+  return locations.value.reduce((acc, curr) => Math.max(acc, curr.count), 0) || 1
+})
+
+let globe = null
+
+async function getGlobeJSON() {
   const data = await $fetch('/countries.geojson')
   countries.value = data
 }
 
-const liveSessionLocations = computed(() => {
+async function getLiveLocations() {
-  const map = new Map()
+  const { data } = await useAPI('/api/logs/locations', {
-  // data.forEach((item) => {
+    query: {
-  //   if (!item.country)
+      startAt: Math.floor(Date.now() / 1000) - 60 * props.minutes,
-  //     return
+    },
-  //   if (!map.has(item.country))
+  })
-  //     map.set(item.country, { lat: 37.75100, lon: -122.4194, count: 1 })
+  locations.value = data?.map(e => ({
+    lat: e.latitude,
+    lng: e.longitude,
+    count: Math.max(1, +e.count / highest.value),
+  }))
+}
 
-  //   map.get(item.country).count += 1
+function initGlobe() {
-  // })
+  const normalized = 5 / props.minutes
+  const weightColor = scaleSequentialSqrt(interpolateYlOrRd).domain([0, highest.value * normalized * 15])
 
-  return Array.from(map.values())
+  globe = new Globe(globeEl.value)
-})
+    .width(size.value.width)
-
+    .height(size.value.height)
-const highest = computed(() => {
+    // .globeOffset([width.value > 768 ? -100 : 0, width.value > 768 ? 0 : 100])
-  return liveSessionLocations.value.reduce((acc, curr) => Math.max(acc, curr.count), 0) || 1
+    .atmosphereColor('rgba(170, 170, 200, 1)')
-})
+    .globeMaterial(new MeshPhongMaterial({
-
+      color: 'hsl(220.9, 30.3%, 16%)',
-const normalized = 5 / 5
+      transparent: false,
-const weightColor = scaleSequentialSqrt(interpolateYlOrRd).domain([0, highest.value * normalized * 15])
+      opacity: 1,
-
+    }))
-const globeEl = ref()
-const hexAltitude = ref(0.001)
-
-onMounted(async () => {
-  await getWorldMapJSON()
-  const globe = new Globe(globeEl.value)
     .backgroundColor('rgba(0,0,0,0)')
     .hexPolygonsData(countries.value.features)
     .hexPolygonResolution(3)
     .hexPolygonMargin(0.2)
     .hexBinResolution(3)
-    .hexBinPointsData(liveSessionLocations.value)
+    .hexBinPointsData(locations.value)
     .hexPolygonAltitude(() => hexAltitude.value)
     .hexBinMerge(true)
     .hexBinPointWeight('count')
@@ -51,12 +76,11 @@ onMounted(async () => {
     .hexTopColor(d => weightColor(d.sumWeight))
     .hexSideColor(d => weightColor(d.sumWeight))
     .onGlobeReady(() => {
-      globe.pointOfView({ lat: 20, lng: -36, altitude: 2 })
+      globe.pointOfView({ lat: 20, lng: -36, altitude: width.value > 768 ? 2 : 3 })
       globe.controls().autoRotate = true
       globe.controls().autoRotateSpeed = 0.2
     })
 
-  // 监听缩放，动态调整 hexAltitude
   globe.controls().addEventListener('end', debounce(() => {
     const distance = Math.round(globe.controls().getDistance())
     let nextAlt = 0.005
@@ -67,9 +91,27 @@ onMounted(async () => {
     if (nextAlt !== hexAltitude.value)
       hexAltitude.value = nextAlt
   }, 200))
+}
+
+function stopRotation() {
+  if (globe) {
+    globe.controls().autoRotate = false
+  }
+}
+
+watch(width, () => {
+  if (globe) {
+    globe.width(size.value.width)
+    globe.height(size.value.height)
+  }
+})
+
+onMounted(async () => {
+  await Promise.all([getGlobeJSON(), getLiveLocations()])
+  initGlobe()
 })
 </script>
 
 <template>
-  <div ref="globeEl" style="width: 100%; height: 600px;" />
+  <div ref="globeEl" @mousedown="stopRotation" />
 </template>

app/components/dashboard/realtime/Index.vue

@@ -7,5 +7,6 @@
       <!-- add filter -->
     </div>
     <DashboardRealtimeGlobe />
+    <!-- <DashboardRealtimeLogs /> -->
   </main>
 </template>

server/api/logs/events.ts

@@ -17,7 +17,7 @@ interface WAEEvents {
 
 function events2logs(events: WAEEvents[]) {
   return events.map((event) => {
-    const blobs = Array.from({ length: Object.keys(blobsMap).length }).fill(0).reduce((_, _c, i) => {
+    const blobs = Array.from({ length: Object.keys(blobsMap).length }).fill(0).reduce<string[]>((_, _c, i) => {
       _.push(event[`blob${i + 1}`])
       return _
     }, [])
@@ -25,7 +25,6 @@ function events2logs(events: WAEEvents[]) {
       ...blobs2logs(blobs),
       id: event.index1,
       timestamp: event.timestamp,
-      _sample_interval: event._sample_interval,
     }
   })
 }

server/api/logs/locations.ts

@@ -0,0 +1,22 @@
+import type { H3Event } from 'h3'
+import { QuerySchema } from '@@/schemas/query'
+
+const { select, and, notEq } = SqlBricks
+
+function query2sql(query: Query, event: H3Event): string {
+  const filter = query2filter(query)
+  const { dataset } = useRuntimeConfig(event)
+  const sql = select(`blob8 as ${blobsMap.blob8},double1 as ${doublesMap.double1},double2 as ${doublesMap.double2},count() as count`)
+    .from(dataset)
+    .where(and([notEq('double1', 0), notEq('double2', 0), filter]))
+    .groupBy([blobsMap.blob8, doublesMap.double1, doublesMap.double2])
+  appendTimeFilter(sql, query)
+  return sql.toString()
+}
+
+export default eventHandler(async (event) => {
+  const query = await getValidatedQuery(event, QuerySchema.parse)
+  const sql = query2sql(query, event)
+
+  return useWAE(event, sql)
+})