Remove websocket support

Author: rukai

Cargo.lock

@@ -27,7 +27,7 @@ debug = true
 # * out of rack routing checks?
 scylla = { version = "=1.4.0", features = ["openssl-010"] }
 bytes = { version = "1.11.1", features = ["serde"] }
-tokio = { version = "1.44.2", features = ["full"] }
+tokio = { version = "1.44.2", features = ["full", "net"] }
 tokio-util = { version = "0.7.7", features = ["codec"] }
 itertools = "0.14.0"
 openssl = { version = "0.10.72", features = ["vendored"] }

Cargo.toml

@@ -3,6 +3,10 @@
 Any breaking changes to the `topology.yaml` or `shotover` rust API should be documented here.
 This assists us in knowing when to make the next release a breaking release and assists users with making upgrades to new breaking releases.
 
+## 0.8.0
+
+* Removed websocket support
+
 ## 0.6.0
 
 Redis has been renamed to Valkey.

changelog.md

@@ -39,11 +39,6 @@ Cassandra:
   # The transport that cassandra communication will occur over.
   # TCP is the only Cassandra protocol conforming transport.
   transport: Tcp
-  
-  # alternatively:
-  #
-  # Use the Cassandra protocol over WebSockets using a Shotover compatible driver.
-  # transport: WebSocket
 
   chain:
     Transform1

docs/src/sources.md

@@ -1,10 +1,8 @@
 use crate::{CONNECTION_REFUSED_OS_ERROR, shotover_process};
 use cassandra_protocol::frame::message_error::{ErrorBody, ErrorType};
-use cassandra_protocol::types::cassandra_type::CassandraType;
 use cdrs_tokio::frame::events::{
     SchemaChange, SchemaChangeOptions, SchemaChangeTarget, SchemaChangeType, ServerEvent,
 };
-use fred::rustls::crypto::aws_lc_rs::default_provider;
 use futures::Future;
 use futures::future::join_all;
 use pretty_assertions::assert_eq;
@@ -23,8 +21,7 @@ use test_helpers::connection::cassandra::Compression;
 use test_helpers::connection::cassandra::ProtocolVersion;
 use test_helpers::connection::cassandra::{
     CassandraConnection, CassandraConnectionBuilder, CassandraDriver, CassandraDriver::Cdrs,
-    CassandraDriver::Java, CassandraDriver::Scylla, CqlWsSession, ResultValue, assert_query_result,
-    run_query,
+    CassandraDriver::Java, CassandraDriver::Scylla, ResultValue, assert_query_result, run_query,
 };
 use test_helpers::connection::valkey_connection::ValkeyConnectionCreator;
 use test_helpers::docker_compose::docker_compose;
@@ -1072,63 +1069,6 @@ async fn test_protocol_v5_compression_encode(#[case] driver: CassandraDriver) {
     }
 }
 
-#[tokio::test(flavor = "multi_thread")]
-async fn passthrough_websockets() {
-    let _docker_compose =
-        docker_compose("tests/test-configs/cassandra/passthrough-websocket/docker-compose.yaml");
-
-    let shotover =
-        shotover_process("tests/test-configs/cassandra/passthrough-websocket/topology.yaml")
-            .start()
-            .await;
-
-    let mut session = CqlWsSession::new("ws://0.0.0.0:9042").await;
-    let rows = session.query("SELECT bootstrapped FROM system.local").await;
-    assert_eq!(rows, vec![vec![CassandraType::Varchar("COMPLETED".into())]]);
-
-    shotover.shutdown_and_then_consume_events(&[]).await;
-}
-
-#[cfg(feature = "alpha-transforms")]
-#[tokio::test(flavor = "multi_thread")]
-async fn encode_websockets() {
-    let _docker_compose =
-        docker_compose("tests/test-configs/cassandra/passthrough-websocket/docker-compose.yaml");
-
-    let shotover =
-        shotover_process("tests/test-configs/cassandra/passthrough-websocket/topology-encode.yaml")
-            .start()
-            .await;
-
-    let mut session = CqlWsSession::new("ws://0.0.0.0:9042").await;
-    let rows = session.query("SELECT bootstrapped FROM system.local").await;
-    assert_eq!(rows, vec![vec![CassandraType::Varchar("COMPLETED".into())]]);
-
-    shotover.shutdown_and_then_consume_events(&[]).await;
-}
-
-#[tokio::test(flavor = "multi_thread")]
-async fn passthrough_tls_websockets() {
-    test_helpers::cert::generate_cassandra_test_certs();
-    let _docker_compose = docker_compose(
-        "tests/test-configs/cassandra/passthrough-websocket-tls/docker-compose.yaml",
-    );
-
-    let shotover =
-        shotover_process("tests/test-configs/cassandra/passthrough-websocket-tls/topology.yaml")
-            .start()
-            .await;
-
-    let ca_cert = "tests/test-configs/cassandra/tls/certs/localhost_CA.crt";
-
-    default_provider().install_default().ok();
-    let mut session = CqlWsSession::new_tls("wss://0.0.0.0:9042", ca_cert).await;
-    let rows = session.query("SELECT bootstrapped FROM system.local").await;
-    assert_eq!(rows, vec![vec![CassandraType::Varchar("COMPLETED".into())]]);
-
-    shotover.shutdown_and_then_consume_events(&[]).await;
-}
-
 #[apply(all_cassandra_drivers)]
 #[tokio::test(flavor = "multi_thread")]
 async fn cassandra_5_passthrough(#[case] driver: CassandraDriver) {