Method run

src/peerhandler.rs:88–118

(&self)

	}

	pub async fn run(&self) {
		loop {
			let one_second = Duration::from_secs(1);

			sleep(one_second);

			let mut local_port = 0;
			{
				let mut gateway_receive_lock = self.gateway_receive.lock().unwrap();

				if let Ok(peer) = gateway_receive_lock.try_recv() {
					local_port = peer.local_port;
				}
			}
			if local_port > 0 {
				let peer_mngr = self.peer_manager.clone();
				let secp_ctx = Secp256k1::new();
				let pubkey = PublicKey::from_secret_key(&secp_ctx, &SecretKey::from_slice(&[42;32]).unwrap());
				let peer_addr = format!("[::1]:{}", local_port).parse().unwrap();
				println!("[CIVKITD] - NOISE: opening outgoing noise connection!");
				lightning_net_tokio::connect_outbound(Arc::clone(&peer_mngr), pubkey, peer_addr).await;

				//TODO: the peer key should be read from the Noise connection
				let secp_ctx = Secp256k1::new();
				let seckey = SecretKey::from_slice(&[42; 32]).unwrap();
				let pubkey = PublicKey::from_secret_key(&secp_ctx, &seckey);
				let nostr_peer = NostrPeer::new(pubkey);
				log_new_peer_db(nostr_peer);
			}
		}
	}
}