Merge remote-tracking branch 'upstream/development' into feat-beam-li…

…st-filter-style

beam/config/api-extractor.json

@@ -5,5 +5,16 @@
 	"docModel": {
 		"enabled": true,
 		"projectFolderUrl": "https://github.com/agritheory/stonecrop/tree/development/beam"
+	},
+
+	"messages": {
+		"extractorMessageReporting": {
+			// Disable this validation at your own risk:  Processing an incorrect file type
+			// may lead to other errors.  Function bodies may incorrectly get emitted in the
+			// .d.ts rollup.
+			"ae-wrong-input-file-type": {
+				"logLevel": "none"
+			}
+		}
 	}
 }

beam/package.json

@@ -40,6 +40,7 @@
 		"test:ui": "vitest --ui"
 	},
 	"dependencies": {
+		"mqtt": "^5.10.1",
 		"onscan.js": "^1.5.2",
 		"vue": "^3.5.6"
 	},

beam/src/composables/mqtt.ts

@@ -0,0 +1,41 @@
+import mqtt, { type MqttClient, type IClientOptions } from 'mqtt'
+import { onMounted, onUnmounted, ref } from 'vue'
+
+interface IMqttStream extends IClientOptions {
+	topics?: string[]
+}
+
+export const useMqttStream = (options?: IMqttStream) => {
+	const client = ref<MqttClient>(null)
+	const messages = ref<Record<string, string[]>>({})
+
+	onMounted(() => {
+		client.value = mqtt.connect(options)
+
+		if (!options.topics) {
+			options.topics = ['#']
+		}
+
+		for (const topic of options.topics) {
+			client.value.subscribe(topic, err => {
+				if (err) {
+					throw err
+				}
+			})
+		}
+
+		client.value.on('message', (topic, message) => {
+			if (!messages.value[topic]) {
+				messages.value[topic] = []
+			}
+
+			messages.value[topic].push(message.toString())
+		})
+	})
+
+	onUnmounted(() => {
+		client.value.end()
+	})
+
+	return { messages }
+}

beam/src/index.ts

@@ -21,6 +21,7 @@ import Navbar from '@/components/Navbar.vue'
 import ScanInput from '@/components/ScanInput.vue'
 import SplitColumn from '@/components/SplitColumn.vue'
 import ToggleArrow from '@/components/ToggleArrow.vue'
+import { useMqttStream } from '@/composables/mqtt'
 import 'themes/beam.css'
 
 /**
@@ -75,4 +76,5 @@ export {
 	SplitColumn,
 	ToggleArrow,
 	install,
+	useMqttStream,
 }

common/changes/@stonecrop/beam/feat-mqtt-stream_2024-11-05-10-26.json

@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@stonecrop/beam",
+      "comment": "add MQTT stream composable",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@stonecrop/beam"
+}

common/config/rush/browser-approved-packages.json

@@ -166,6 +166,10 @@
       "name": "monaco-editor",
       "allowedCategories": [ "prototype" ]
     },
+    {
+      "name": "mqtt",
+      "allowedCategories": [ "prototype" ]
+    },
     {
       "name": "node-sass",
       "allowedCategories": [ "prototype" ]