Developer tools: Add WS connection test

Depends on openhab/openhab-core#4540. Signed-off-by: Florian Hotze <dev@florianhotze.com>
openhab · Jan 4, 2025 · 54126ad · 54126ad
1 parent 75e8667
commit 54126ad
Show file tree

Hide file tree

Showing 2 changed files with 44 additions and 10 deletions.
diff --git a/bundles/org.openhab.ui/web/build/webpack.config.js b/bundles/org.openhab.ui/web/build/webpack.config.js
@@ -69,15 +69,17 @@ module.exports = {
     ],
     allowedHosts: "all",
     historyApiFallback: true,
-    proxy: [{
-      context: ['/auth', '/rest', '/chart', '/proxy', '/icon', '/static', '/changePassword', '/createApiToken', '/audio'],
-      target: apiBaseUrl
-    },
-    {
-      context: "/ws/logs",
-      target: apiBaseUrl,
-      ws: true
-    }]
+    proxy: [
+      {
+        context: ['/auth', '/rest', '/chart', '/proxy', '/icon', '/static', '/changePassword', '/createApiToken', '/audio'],
+        target: apiBaseUrl
+      },
+      {
+        context: ['/ws/logs', '/ws/events'],
+        target: apiBaseUrl,
+        ws: true
+      }
+    ]
   },
   performance: {
     maxAssetSize: 2048000,

diff --git a/bundles/org.openhab.ui/web/src/pages/developer/developer-tools.vue b/bundles/org.openhab.ui/web/src/pages/developer/developer-tools.vue
@@ -56,14 +56,14 @@
         </f7-block>
       </f7-tab>
       <f7-tab id="debug-tab" @tab:show="() => this.currentTab = 'debug'" :tab-active="currentTab === 'debug'">
+        <!-- Test SSE connection -->
         <f7-block class="block-narrow">
           <f7-row>
             <f7-col>
               <f7-block>
                 <f7-block-title class="after-big-title">
                   Test SSE connection
                 </f7-block-title>
-                <p>Start a SSE connection to check the different implementations</p>
                 <f7-button text="Stream Events" @click="startSSE()" v-if="!sseClient" />
                 <f7-button text="Stop Streaming" @click="stopSSE()" v-if="sseClient" />
                 <f7-list media-list>
@@ -73,6 +73,24 @@
             </f7-col>
           </f7-row>
         </f7-block>
+        <!-- Test WebSocket connection -->
+        <f7-block class="block-narrow">
+          <f7-row>
+            <f7-col>
+              <f7-block>
+                <f7-block-title class="after-big-title">
+                  Test WebSocket connection
+                </f7-block-title>
+                <f7-button text="Stream Events" @click="startWS()" v-if="!wsClient" />
+                <f7-button text="Stop Streaming" @click="stopWS()" v-if="wsClient" />
+                <f7-list media-list>
+                  <f7-list-item v-for="event in wsEvents" :key="event.time.getTime()" :title="event.topic" :subtitle="event.payload" :after="event.type" />
+                </f7-list>
+              </f7-block>
+            </f7-col>
+          </f7-row>
+        </f7-block>
+        <!-- Test an icon -->
         <f7-block class="block-narrow">
           <f7-row>
             <f7-col>
@@ -116,6 +134,8 @@ export default {
       currentTab: 'menu',
       sseClient: null,
       sseEvents: [],
+      wsClient: null,
+      wsEvents: [],
       icon: 'lightbulb',
       split: this.$device.desktop ? 'vertical' : 'horizontal'
     }
@@ -135,6 +155,18 @@ export default {
       this.$oh.sse.close(this.sseClient)
       this.sseClient = null
       this.sseEvents = []
+    },
+    startWS () {
+      this.wsClient = this.$oh.ws.connect('/ws/events', (event) => {
+        event.time = new Date()
+        this.wsEvents.unshift(...[event])
+        this.wsEvents.splice(5)
+      })
+    },
+    stopWS () {
+      this.$oh.ws.close(this.wsClient)
+      this.wsClient = null
+      this.wsEvents = []
     }
   },
   asyncComputed: {