Skip to content

Commit efd4730

Browse files
committed
fix: prefix peer addresses with protocol
1 parent d386096 commit efd4730

File tree

1 file changed

+7
-4
lines changed
  • src/backend/src/modules/broadcast/connection

1 file changed

+7
-4
lines changed

src/backend/src/modules/broadcast/connection/CLink.js

+7-4
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,10 @@ class CLink extends BaseLink {
4141
}
4242

4343
connect () {
44-
const address = this.config.address;
44+
let address = this.config.address;
45+
if ( ! address.startsWith('https://') ) {
46+
address = `https://${address}`;
47+
}
4548
const socket = this.modules.sioclient(address, {
4649
transports: ['websocket'],
4750
path: '/wssinternal',
@@ -54,7 +57,7 @@ class CLink extends BaseLink {
5457
});
5558
socket.on('connect', () => {
5659
this.log.info(`connected`, {
57-
address: this.config.address
60+
address,
5861
});
5962

6063
const require = this.require;
@@ -76,12 +79,12 @@ class CLink extends BaseLink {
7679
});
7780
socket.on('disconnect', () => {
7881
this.log.info(`disconnected`, {
79-
address: this.config.address
82+
address,
8083
});
8184
});
8285
socket.on('connect_error', e => {
8386
this.log.info(`connection error`, {
84-
address: this.config.address,
87+
address,
8588
message: e.message,
8689
});
8790
});

0 commit comments

Comments
 (0)