Added optionnal logs

Author: ludovic

js-src/Websocket.ts

@@ -2,7 +2,7 @@ import { AxiosResponse } from "axios";
 import axios from 'axios';
 import { Channel } from "./Channel";
 
-export type Options = { authEndpoint: string, host: string };
+export type Options = { authEndpoint: string, host: string, debug: boolean };
 export type MessageBody = { event: string, channel?: string, data: object };
 
 export class Websocket {
@@ -25,6 +25,7 @@ export class Websocket {
     private pingInterval: NodeJS.Timeout;
 
     private connect(host: string): void {
+        this.options.debug && console.log('Connecting');
 
         this.websocket = new WebSocket(host)
 
@@ -50,6 +51,8 @@ export class Websocket {
             }
 
             if (message.channel) {
+                this.options.debug && console.log(`Received event ${message.event} on channel ${message.channel}`)
+
                 if (this.listeners[message.channel] && this.listeners[message.channel][message.event]) {
                     this.listeners[message.channel][message.event](message.data)
                 }
@@ -66,6 +69,7 @@ export class Websocket {
 
         this.websocket.onclose = () => {
             if (this.socketId && !this.closing || !this.socketId) {
+                this.options.debug && console.info('Connection lost, reconnecting...');
                 setTimeout(() => {
                     this.socketId = undefined
                     this.connect(host)
@@ -76,6 +80,8 @@ export class Websocket {
         this.on('whoami', ({ socket_id: socketId }) => {
             this.socketId = socketId
 
+            this.options.debug && console.log(`just set socketId to ${socketId}`)
+
             while (this.channelBacklog.length) {
                 const channel = this.channelBacklog[0]
 
@@ -89,6 +95,7 @@ export class Websocket {
         // send ping every 60 seconds to keep connection alive
         this.pingInterval = setInterval(() => {
             if (this.websocket.readyState === this.websocket.OPEN) {
+                this.options.debug && console.log('Sending ping')
                 this.send({
                     event: 'ping',
                 })
@@ -109,7 +116,7 @@ export class Websocket {
         try {
             return JSON.parse(body)
         } catch (error) {
-            console.error('Error parsing message', error)
+            this.options.debug && console.error(error)
 
             return undefined
         }
@@ -152,11 +159,13 @@ export class Websocket {
 
     private actuallySubscribe(channel: Channel): void {
         if (channel.name.startsWith('private-') || channel.name.startsWith('presence-')) {
+            this.options.debug && console.log(`Sending auth request for channel ${channel.name}`)
 
             axios.post(this.options.authEndpoint, {
                 socket_id: this.getSocketId(),
                 channel_name: channel.name,
             }).then((response: AxiosResponse) => {
+                this.options.debug && console.log(`Subscribing to channels ${channel.name}`)
 
                 this.send({
                     event: 'subscribe',
@@ -166,9 +175,11 @@ export class Websocket {
                     },
                 })
             }).catch((error) => {
-                console.error('Error while subscribing to private channel :',error)
+                this.options.debug && console.log(`Auth request for channel ${channel.name} failed`)
+                this.options.debug && console.error(error)
             })
         } else {
+            this.options.debug && console.log(`Subscribing to channels ${channel.name}`)
 
             this.send({
                 event: 'subscribe',