MQTT JS/TS Implementation

Question

question

joshuaattridge asked May 18, '22

MQTT JS/TS Implementation

Hello All!

I am attempting to connect to the Victron MQTT broker using typescript using this package mqtt - npm (npmjs.com)

This is the code I currently have (I have replaced some parts with * to hide personal information but I can assure that these details are correct):

const mqtt = require('mqtt')
const TRUSTED_CA_LIST = `-----BEGIN CERTIFICATE-----
***
***
***
***
***
-----END CERTIFICATE-----`

function _get_vrm_broker_url(vrm_id: string) {
    var sum = 0
    for (var i = 0; i < vrm_id.length; i++) {
        sum += vrm_id.charCodeAt(i)
    }
    var broker_index = sum % 128
    return "mqtt" + broker_index + ".victronenergy.com"
}

const client = mqtt.connect('mqtts://' + _get_vrm_broker_url('*****'), {
    username: '*****',
    password: '*****',
    ca: TRUSTED_CA_LIST,
})

client.on('connect', function () {
    console.log('connected')
})

However when I test this in the browser I get the following error message:

WebSocket connection to 'wss://mqtt91.victronenergy.com/' failed: Error in connection establishment: net::ERR_CERT_AUTHORITY_INVALID

I hope someone can tell me where I'm going wrong and lead me in the right direction,

thank you for your time!

Josh

MQTT javascript

2 |3000

Attachments: Up to 8 attachments (including images) can be used with a maximum of 190.8 MiB each and 286.6 MiB total.

Modifications Space

Node Red Space

Answer 1 · 2022-05-18T15:14:15Z

gone-sailing answered · May 18, 2022 at 03:14 PM

Try MQTT not WS as the protocol.

1

2 |3000

Attachments: Up to 8 attachments (including images) can be used with a maximum of 190.8 MiB each and 286.6 MiB total.

joshuaattridge commented · May 18, 2022 at 03:20 PM

Hi,

thanks for replying so quickly,

I tried this and I get the same error, I added *protocolId: 'MQTT'* as one of the options on the mqtt.connect call.

Also I believe as this is coming from a browser you have to use web sockets rather than direct MQTT, but please correct me if I'm wrong.

0 ·

Answer 2 · 2022-05-19T07:27:41Z

gone-sailing answered · May 19, 2022 at 07:27 AM

There is nothing in the dbus-Mqtt documentation to suggest that web sockets is enabled in the VRM Mqtt servers. It seems it’s just MQTT over ssl.

https://github.com/victronenergy/dbus-mqtt

2

2 |3000

Attachments: Up to 8 attachments (including images) can be used with a maximum of 190.8 MiB each and 286.6 MiB total.

joshuaattridge commented · May 19, 2022 at 07:49 AM

No it doesn't however the Victron web-app uses websockets victronenergy/venus-html5-app: HTML5 App including Javascript library that communicates with Venus OS over MQTT websockets (github.com) which suggests it is possible.

0 ·

gone-sailing joshuaattridge commented · May 20, 2022 at 06:53 AM

I believe that web app communicates with the MQTT server on your own local Venus GX device. You are trying to connect to Victron’s VRM servers.

0 ·

Answer 3 · 2022-05-20T08:40:36Z

joshuaattridge answered · May 20, 2022 at 08:40 AM

So I finally figured out how to get this working.

If you want to have a MQTT connection Victron broker using a browser (Javascript/Typescript) then you need to have the following parameters:

host: wss://webmqtt***.victronenergy.com

username: YOURVRMUSERNAME

password: YOURVRMPASSWORD

I found out that Victron have another broker address that works with web sockets so on the address rather than having 'mqtt.' you need to have 'webmqtt.' I hope you find this useful please look at this programming example below:

const mqtt = require('mqtt')

function _get_vrm_broker_url(vrm_id: string) {
    var sum = 0
    for (var i = 0; i < vrm_id.length; i++) {
        sum += vrm_id.charCodeAt(i)
    }
    var broker_index = sum % 128
    return "webmqtt" + broker_index + ".victronenergy.com"
}

const client = mqtt.connect('wss://' + _get_vrm_broker_url('YOURVRMDEVICEID'), {
    username: 'YOURVRMUSERNAME',
    password: 'YOURVRMPASSWORD',
})

client.on('connect', function () {
    console.log('connected')
    client.subscribe('#', function (err) {
        if (!err) {
            console.log('no error')
        }
    })
})
client.on('message', function (topic, message) {
    // message is Buffer
    console.log(topic.toString(), message.toString())
    client.end()
})

And thanks to @gone-sailing for the help you provided :D

2 |3000

Attachments: Up to 8 attachments (including images) can be used with a maximum of 190.8 MiB each and 286.6 MiB total.

Answer 4 · 2022-08-28T23:20:55Z

taylortops answered · Aug 28, 2022 at 11:20 PM

Could you please show how you're handling the keepalive.

2

2 |3000

Attachments: Up to 8 attachments (including images) can be used with a maximum of 190.8 MiB each and 286.6 MiB total.

joshuaattridge commented · Aug 30, 2022 at 08:23 AM

Yes of course.

So on the connection I have added a function that will loop every 5 seconds and publish to the keep alive topic

client.on('connect', function () {
  (function theLoop() {
    setTimeout(() => {
      client.publish('R/YOURVRMDEVICEID/keepalive', '')
      theLoop();
    }, 5000);
  })();
})

0 ·

taylortops joshuaattridge commented · Oct 08, 2022 at 06:13 AM

Many Thanks. I found that 55secs was a nice interval.

0 ·

Answer 5 · 2024-03-05T18:38:09Z

goups answered · Mar 05 at 06:38 PM

As a side note, here are the settings to connect to the WebSocket with SSL

Is there a way to connect without SSL ? Which port ?

capture-decran-le-2024-03-05-a-133310.png (100.4 KiB)

2 |3000

Attachments: Up to 8 attachments (including images) can be used with a maximum of 190.8 MiB each and 286.6 MiB total.

question