revert some changes, for debugging

example/whoami.yaml

@@ -3,8 +3,8 @@ kind: Deployment
 metadata:
   name: whoami
   namespace: default
-  annotations:
-    chisel-operator.io/exit-node-name: "my-exit-node"
+  # annotations:
+    # chisel-operator.io/exit-node-name: "my-exit-node"
 spec:
   replicas: 1
   selector:

src/daemon.rs

@@ -277,7 +277,7 @@ async fn reconcile_svcs(obj: Arc<Service>, ctx: Arc<Context>) -> Result<Action,
     // if it is, then we don't need to do anything
     // !!!!! WHY IS IT STILL LOOPING
 
-    tokio::time::sleep(Duration::from_secs(5)).await;
+    // tokio::time::sleep(Duration::from_secs(5)).await;
 
 
     let exit_node_ip = node.get_host().await;

src/deployment.rs

@@ -62,7 +62,13 @@ fn convert_service_port(svcport: ServicePort) -> String {
 /// values obtained from the `node` parameter.
 pub async fn generate_remote_arg(node: &ExitNode) -> String {
     // todo: what about ECDSA keys?
-    format!("{}:{}", node.get_host().await, node.spec.port)
+
+    let host = node.get_host().await;
+
+    debug!(host = ?host, "Host");
+    let output = format!("{}:{}", host, node.spec.port);
+    debug!(output = ?output, "Output");
+    output
 }
 
 /// This function generates arguments for a tunnel based on a given service.

src/main.rs

@@ -69,6 +69,7 @@ async fn main() -> Result<()> {
     let env_filter = EnvFilter::try_from_default_env().or_else(|_| EnvFilter::try_new("info"))?
     .add_directive("tower=off".parse().unwrap())
     .add_directive("hyper=error".parse().unwrap())
+    .add_directive("kube_client=error".parse().unwrap())
     .add_directive("tokio_util=error".parse().unwrap());
 
     // let telemetry = tracing_opentelemetry::layer().with_tracer(init_tracer().await);