Fix handling empty messages (#48)

* feat: add flag to control rate limit

* fix: handling empty messages

Author: paulobressan

Diff for: examples/manifest.yaml

@@ -205,8 +205,8 @@ data:
     [[tiers]]
     name = "0"
     [[tiers.rates]]
-    interval = "1s"
-    limit = 10
+    interval = "1m"
+    limit = 1
 
     [[tiers]]
     name = "1"
@@ -247,6 +247,8 @@ spec:
               value: "0.0.0.0:9187"
             - name: OGMIOS_PORT
               value: "80"
+            - name: OGMIOS_DNS
+              value: "prj-mainnet-test.svc.cluster.local"
             - name: SSL_CRT_PATH
               value: "/ogmios-proxy/localhost.crt"
             - name: SSL_KEY_PATH

Diff for: proxy/src/proxy.rs

@@ -196,20 +196,16 @@ async fn handle_websocket(
                 state.metrics.inc_ws_total_connection(&proxy_req);
 
                 let client_in = async {
-                    loop {
-                        let result = client_incoming.try_next().await;
+                    while let Some(result) = client_incoming.next().await {
                         match result {
                             Ok(data) => {
-                                if let Some(data) = data {
-                                    limiter(state.clone(), proxy_req.consumer.as_ref().unwrap())
-                                        .await;
-                                    if let Err(err) = instance_outgoing.send(data).await {
-                                        error!(
-                                            error = err.to_string(),
-                                            "fail to send data to instance"
-                                        );
-                                        break;
-                                    }
+                                limiter(state.clone(), proxy_req.consumer.as_ref().unwrap()).await;
+                                if let Err(err) = instance_outgoing.send(data).await {
+                                    error!(
+                                        error = err.to_string(),
+                                        "fail to send data to instance"
+                                    );
+                                    break;
                                 }
                             }
                             Err(err) => {