From 0e72d6400912c641c689bf14684e1c50c14782be Mon Sep 17 00:00:00 2001
From: Rishi Ghan <rishi.ghan@gmail.com>
Date: Tue, 17 Jan 2023 20:10:12 -0800
Subject: [PATCH] =?UTF-8?q?=F0=9F=94=8C=20Setting=20autoReconnect=20to=20t?=
 =?UTF-8?q?rue=20in=20the=20ADCPP=20constructor?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/client/actions/airdcpp.actions.tsx   | 27 ++++++++++++++++++------
 src/client/components/Navbar.tsx         | 19 +++++++++++------
 src/client/context/AirDCPPSocket.tsx     |  8 ++++---
 src/client/services/DcppSearchService.ts |  4 +++-
 4 files changed, 42 insertions(+), 16 deletions(-)

diff --git a/src/client/actions/airdcpp.actions.tsx b/src/client/actions/airdcpp.actions.tsx
index bea68dd..b279a78 100644
--- a/src/client/actions/airdcpp.actions.tsx
+++ b/src/client/actions/airdcpp.actions.tsx
@@ -37,12 +37,27 @@ function sleep(ms: number): Promise<NodeJS.Timeout> {
   return new Promise((resolve) => setTimeout(resolve, ms));
 }
 
-export const setAirDCPPSocketConnectionAsActive = () => async (dispatch) => {
-  console.log("fire, fire, fire");
-  dispatch({
-    type: AIRDCPP_SOCKET_CONNECTED,
-  });
-};
+export const toggleAirDCPPSocketConnectionStatus =
+  (status: String) => async (dispatch) => {
+    console.log("sanul", status);
+    switch (status) {
+      case "connected":
+        dispatch({
+          type: AIRDCPP_SOCKET_CONNECTED,
+        });
+        break;
+
+      case "disconnected":
+        dispatch({
+          type: AIRDCPP_SOCKET_DISCONNECTED,
+        });
+        break;
+
+      default:
+        console.log("Can't set AirDC++ socket status.");
+        break;
+    }
+  };
 export const search =
   (data: SearchData, ADCPPSocket: any, credentials: any) =>
   async (dispatch) => {
diff --git a/src/client/components/Navbar.tsx b/src/client/components/Navbar.tsx
index f5d47c3..095a5c0 100644
--- a/src/client/components/Navbar.tsx
+++ b/src/client/components/Navbar.tsx
@@ -10,9 +10,10 @@ const Navbar: React.FunctionComponent = (props) => {
     (state: RootState) => state.airdcpp.downloadProgressData,
   );
 
-  // const airDCPPSocketConnectionStatus = useSelector((state: RootState) => {
-  //   console.log(state);
-  // });
+  const airDCPPSocketConnectionStatus = useSelector((state: RootState) => {
+    console.log(state);
+    return state.airdcpp.isAirDCPPSocketConnected;
+  });
 
   return (
     <nav className="navbar is-fixed-top">
@@ -88,9 +89,15 @@ const Navbar: React.FunctionComponent = (props) => {
           </div>
           {/* AirDC++ socket connection status */}
           <div className="navbar-item has-dropdown is-hoverable">
-            <a className="navbar-link is-arrowless has-text-success">
-              <i className="fa-solid fa-bolt"></i>
-            </a>
+            {airDCPPSocketConnectionStatus ? (
+              <a className="navbar-link is-arrowless has-text-success">
+                <i className="fa-solid fa-bolt"></i>
+              </a>
+            ) : (
+              <a className="navbar-link is-arrowless has-text-danger">
+                <i className="fa-solid fa-bolt"></i>
+              </a>
+            )}
           </div>
 
           <div className="navbar-item has-dropdown is-hoverable is-mega">
diff --git a/src/client/context/AirDCPPSocket.tsx b/src/client/context/AirDCPPSocket.tsx
index 46992af..103c774 100644
--- a/src/client/context/AirDCPPSocket.tsx
+++ b/src/client/context/AirDCPPSocket.tsx
@@ -1,7 +1,7 @@
 import { isEmpty, isUndefined } from "lodash";
 import React, { createContext, useEffect, useState } from "react";
 import { useDispatch, useSelector } from "react-redux";
-import { setAirDCPPSocketConnectionAsActive } from "../actions/airdcpp.actions";
+import { toggleAirDCPPSocketConnectionStatus } from "../actions/airdcpp.actions";
 import { getSettings } from "../actions/settings.actions";
 
 import AirDCPPSocket from "../services/DcppSearchService";
@@ -57,18 +57,20 @@ const AirDCPPSocketContextProvider = ({ children }) => {
     const initializedAirDCPPSocket = new AirDCPPSocket({
       protocol: `${host.protocol}`,
       hostname: `${host.hostname}:${host.port}`,
+      username: `${host.username}`,
+      password: `${host.password}`,
     });
 
     // connect and disconnect handlers
     initializedAirDCPPSocket.onConnected = (sessionInfo) => {
-      dispatch(setAirDCPPSocketConnectionAsActive());
+      dispatch(toggleAirDCPPSocketConnectionStatus("connected"));
     };
     initializedAirDCPPSocket.onDisconnected = async (
       reason,
       code,
       wasClean,
     ) => {
-      console.log("kulkarni kamal kulthe", reason, code, wasClean);
+      dispatch(toggleAirDCPPSocketConnectionStatus("disconnected"));
     };
 
     const socketConnectionInformation = await initializedAirDCPPSocket.connect(
diff --git a/src/client/services/DcppSearchService.ts b/src/client/services/DcppSearchService.ts
index f7b7845..049cd3c 100644
--- a/src/client/services/DcppSearchService.ts
+++ b/src/client/services/DcppSearchService.ts
@@ -10,7 +10,7 @@ class AirDCPPSocket {
     }
     const options = {
       url: `${socketProtocol}://${configuration.hostname}/api/v1/`,
-      autoReconnect: false,
+      autoReconnect: true,
       reconnectInterval: 5,
       logLevel: "verbose",
       ignoredListenerEvents: [
@@ -18,6 +18,8 @@ class AirDCPPSocket {
         "hash_statistics",
         "hub_counts_updated",
       ],
+      username: `${configuration.username}`,
+      password: `${configuration.password}`,
     };
     const AirDCPPSocketInstance = Socket(options, window.WebSocket as any);
     return AirDCPPSocketInstance;