Revert "Merge pull request dmnd-pool#95 from Fi3/FixLuxFirmware"

This reverts commit 51db807, reversing
changes made to 5c4f978.

Author: jbesraa

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "demand-cli"
-version = "0.1.13"
+version = "0.1.12"
 edition = "2021"
 
 [dependencies]

Cargo.toml

@@ -1,4 +1,4 @@
-use std::{net::{IpAddr, SocketAddr}, sync::Arc};
+use std::net::{IpAddr, SocketAddr};
 
 use crate::{
     config::Configuration,
@@ -8,7 +8,6 @@ use futures::{
     stream::{SplitSink, SplitStream},
     SinkExt, StreamExt,
 };
-use roles_logic_sv2::utils::Mutex;
 use tokio::{
     net::{TcpListener, TcpStream},
     sync::mpsc::{channel, Receiver, Sender},
@@ -73,10 +72,9 @@ impl Downstream {
         sender: Sender<String>,
     ) {
         let (writer, reader) = framed.split();
-        let firmware = Arc::new(Mutex::new(Firmware::Uninitialized));
         let result = tokio::select! {
-            result1 = Self::receive_from_downstream_and_relay_up(reader, sender, firmware.clone()) => result1,
-            result2 = Self::receive_from_upstream_and_relay_down(writer, receiver, firmware.clone()) => result2,
+            result1 = Self::receive_from_downstream_and_relay_up(reader, sender) => result1,
+            result2 = Self::receive_from_upstream_and_relay_down(writer, receiver) => result2,
         };
         // upstream disconnected make sure to clean everything before exit
         match result {
@@ -88,24 +86,12 @@ impl Downstream {
     async fn receive_from_downstream_and_relay_up(
         mut recv: SplitStream<Framed<TcpStream, LinesCodec>>,
         send: Sender<String>,
-        firmware: Arc<Mutex<Firmware>>,
     ) -> Sv1IngressError {
-        let mut is_subscribed = false;
         let task = tokio::spawn(async move {
             while let Some(Ok(message)) = recv.next().await {
                 if Configuration::sv1_ingress_log() {
                     info!("Sending msg to upstream: {}", message);
                 }
-                if ! is_subscribed {
-                    if message.contains("mining.subscribe") {
-                        is_subscribed = true;
-                        if message.contains("LUXminer") {
-                            firmware.safe_lock(|f| *f = Firmware::Luxor).unwrap();
-                        } else {
-                            firmware.safe_lock(|f| *f = Firmware::Other).unwrap();
-                        }
-                    }
-                }
                 if send.send(message).await.is_err() {
                     error!("Upstream dropped trying to send");
                     return Sv1IngressError::TranslatorDropped;
@@ -123,21 +109,12 @@ impl Downstream {
     async fn receive_from_upstream_and_relay_down(
         mut send: SplitSink<Framed<TcpStream, LinesCodec>, String>,
         mut recv: Receiver<String>,
-        firmware_: Arc<Mutex<Firmware>>,
     ) -> Sv1IngressError {
-        let mut firmware = Firmware::Uninitialized;
         let task = tokio::spawn(async move {
             while let Some(message) = recv.recv().await {
-                let mut message = message.replace(['\n', '\r'], "");
-                if !firmware.is_initialized() {
-                    firmware = firmware_.safe_lock(|f| *f).unwrap();
-                } else if firmware.is_luxor() {
-                    if let Some(pos) = message.find('{') {
-                        message.insert_str(pos + 1, r#""id":null,"#);
-                    }
-                }
+                let message = message.replace(['\n', '\r'], "");
                 if Configuration::sv1_ingress_log() {
-                    info!("Sending msg to downstream_: {}", message);
+                    info!("Sending msg to downstream: {}", message);
                 }
                 if send.send(message).await.is_err() {
                     warn!("Downstream dropped while trying to send message down");
@@ -157,19 +134,3 @@ impl Downstream {
         }
     }
 }
-
-#[derive(Debug,Clone,Copy)]
-enum Firmware {
-    Luxor,
-    Other,
-    Uninitialized,
-}
-
-impl Firmware {
-    fn is_initialized(&self) -> bool {
-        !matches!(self, Firmware::Uninitialized)
-    }
-    fn is_luxor(&self) -> bool {
-        matches!(self, Firmware::Luxor)
-    }
-}