Topic Publish Example with Hyper-Express about hyper-express HOT 3 CLOSED

I also tried this based on what I read in the discussions
Server.publish('locationHb', 'you are now subscribed to locationHb')
But this also doesn't seem to send the message

from hyper-express.

Hi, so MQTT is essentially a URL protocol which determines how Publish/Subscribing will work between multiple parties.

The reason why your example is not working is because connections must first subscribe to a topic using the Websocket.subscribe(topic) method.

Then whenever you want to publish a message to all connections on a Server instance, you can simply do Server.publish(topic, message) to broadcast a message.

Below is a simple example of this:

const crypto = require('crypto');
const HyperExpress = require('hyper-express');
const Server = new HyperExpress.Server();

// Create an endpoint for accepting websocket connections
Server.ws('/connect', (ws) => {
    // Attach a unique identifier to each connection
    ws.id = crypto.randomUUID();
    
    // Subscribe the connection to "OUR_TOPIC_NAME"
    ws.subscribe('OUR_TOPIC_NAME');
    console.log(`Websocket Connection ${ws.id} Is Now Connected & Subscribed To OUR_TOPIC_NAME!`);
    
    // Bind any handlers here for this connection, we will bind the close handler so we can log closure
    ws.on('close', (code, message) => {
        console.log(`Websocket Connection ${ws.id} Has Disconnected!`);
    });
});

// Now you can publish a message to all connections over the "OUR_TOPIC_NAME" topic like below
Server.publish('OUR_TOPIC_NAME', 'This is a message for OUR_TOPIC_NAME subscribers!');

I'll also be adding an example for MQTT Pub/Sub in the Examples section of the documentation in the next update.

Hope this helps!

from hyper-express.

awesome, that works, I appreciate the example. Yes, I needed to have ws.subscribe('topic') instead of ws.subscribe = 'topic' and as you showed there Server.publish - Thank you!

from hyper-express.