Initial rustls

shotover · Apr 4, 2023 · b0f59d1 · b0f59d1
1 parent 7b91370
commit b0f59d1
Show file tree

Hide file tree

Showing 17 changed files with 396 additions and 13 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/shotover-proxy/tests/cassandra_int_tests/cluster/mod.rs b/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::tls::{TlsConnector, TlsConnectorConfig};
+use shotover::tlsls::{TlsConnector, TlsConnectorConfig};
 use shotover::transforms::cassandra::sink_cluster::{
  node::{CassandraNode, ConnectionFactory},
  topology::{create_topology_task, TaskConnectionInfo},

diff --git a/shotover/Cargo.toml b/shotover/Cargo.toml
@@ -78,3 +78,7 @@ generic-array = { version = "0.14", features = ["serde"] }
 dyn-clone = "1.0.10"
 kafka-protocol = "0.6.0"
 typetag = "0.2.5"
+rustls = { version = "0.21.0", features = ["dangerous_configuration"] }
+tokio-rustls = "0.24"
+rustls-pemfile = "1.0.2"
+rustls-webpki = "0.100.1"
diff --git a/shotover/src/lib.rs b/shotover/src/lib.rs
@@ -33,5 +33,6 @@ mod server;
 pub mod sources;
 pub mod tcp;
 pub mod tls;
+pub mod tlsls;
 pub mod tracing_panic_handler;
 pub mod transforms;
diff --git a/shotover/src/server.rs b/shotover/src/server.rs
@@ -1,6 +1,6 @@
 use crate::codec::{CodecBuilder, CodecReadError};
 use crate::message::Messages;
-use crate::tls::{AcceptError, TlsAcceptor};
+use crate::tlsls::{AcceptError, TlsAcceptor};
 use crate::transforms::chain::{TransformChain, TransformChainBuilder};
 use crate::transforms::Wrapper;
 use anyhow::{anyhow, Context, Result};

diff --git a/shotover/src/sources/cassandra.rs b/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::tls::{TlsAcceptor, TlsAcceptorConfig};
+use crate::tlsls::{TlsAcceptor, TlsAcceptorConfig};
 use crate::transforms::chain::TransformChainBuilder;
 use anyhow::Result;
 use serde::Deserialize;

diff --git a/shotover/src/sources/kafka.rs b/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::tls::{TlsAcceptor, TlsAcceptorConfig};
+use crate::tlsls::{TlsAcceptor, TlsAcceptorConfig};
 use crate::transforms::chain::TransformChainBuilder;
 use anyhow::Result;
 use serde::Deserialize;

diff --git a/shotover/src/sources/redis.rs b/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::tls::{TlsAcceptor, TlsAcceptorConfig};
+use crate::tlsls::{TlsAcceptor, TlsAcceptorConfig};
 use crate::transforms::chain::TransformChainBuilder;
 use anyhow::Result;
 use serde::Deserialize;