Remove openssl

shotover-proxy/tests/cassandra_int_tests/cluster/mod.rs

@@ -2,7 +2,7 @@ use cassandra_protocol::frame::message_startup::BodyReqStartup;
 use cassandra_protocol::frame::Version;
 use shotover::frame::{cassandra::Tracing, CassandraFrame, CassandraOperation, Frame};
 use shotover::message::Message;
-use shotover::tlsls::{TlsConnector, TlsConnectorConfig};
+use shotover::tls::{TlsConnector, TlsConnectorConfig};
 use shotover::transforms::cassandra::sink_cluster::{
  node::{CassandraNode, ConnectionFactory},
  topology::{create_topology_task, TaskConnectionInfo},

shotover/src/lib.rs

@@ -33,6 +33,5 @@ mod server;
 pub mod sources;
 pub mod tcp;
 pub mod tls;
-pub mod tlsls;
 pub mod tracing_panic_handler;
 pub mod transforms;

shotover/src/server.rs

@@ -1,12 +1,13 @@
 use crate::codec::{CodecBuilder, CodecReadError};
 use crate::message::Messages;
-use crate::tlsls::{AcceptError, TlsAcceptor};
+use crate::tls::{AcceptError, TlsAcceptor};
 use crate::transforms::chain::{TransformChain, TransformChainBuilder};
 use crate::transforms::Wrapper;
 use anyhow::{anyhow, Context, Result};
 use futures::future::join_all;
 use futures::{SinkExt, StreamExt};
 use metrics::{register_gauge, Gauge};
+use std::io::ErrorKind;
 use std::net::SocketAddr;
 use std::sync::Arc;
 use tokio::io::{AsyncRead, AsyncWrite};
@@ -363,7 +364,11 @@ fn spawn_read_write_tasks<
  return;
  }
  Err(CodecReadError::Io(err)) => {
- warn!("failed to receive message on tcp stream: {:?}", err);
+ // I suspect (but have not confirmed) that UnexpectedEof occurs here when the ssl client does not send "close notify" before terminating the connection.
+ // We shouldnt report that as a warning because its common for clients to do that for performance reasons.
+ if !matches!(err.kind(), ErrorKind::UnexpectedEof) {
+ warn!("failed to receive message on tcp stream: {:?}", err);
+ }
  return;
  }
  }

shotover/src/sources/cassandra.rs

@@ -2,7 +2,7 @@ use crate::codec::Direction;
 use crate::codec::{cassandra::CassandraCodecBuilder, CodecBuilder};
 use crate::server::TcpCodecListener;
 use crate::sources::Sources;
-use crate::tlsls::{TlsAcceptor, TlsAcceptorConfig};
+use crate::tls::{TlsAcceptor, TlsAcceptorConfig};
 use crate::transforms::chain::TransformChainBuilder;
 use anyhow::Result;
 use serde::Deserialize;

shotover/src/sources/kafka.rs

@@ -1,7 +1,7 @@
 use crate::codec::{kafka::KafkaCodecBuilder, CodecBuilder, Direction};
 use crate::server::TcpCodecListener;
 use crate::sources::Sources;
-use crate::tlsls::{TlsAcceptor, TlsAcceptorConfig};
+use crate::tls::{TlsAcceptor, TlsAcceptorConfig};
 use crate::transforms::chain::TransformChainBuilder;
 use anyhow::Result;
 use serde::Deserialize;

shotover/src/sources/redis.rs

@@ -1,7 +1,7 @@
 use crate::codec::{redis::RedisCodecBuilder, CodecBuilder, Direction};
 use crate::server::TcpCodecListener;
 use crate::sources::Sources;
-use crate::tlsls::{TlsAcceptor, TlsAcceptorConfig};
+use crate::tls::{TlsAcceptor, TlsAcceptorConfig};
 use crate::transforms::chain::TransformChainBuilder;
 use anyhow::Result;
 use serde::Deserialize;