collab: Remove `POST /snowflake/events` endpoint (#24817)
Marshall Bowers
created
This PR removes the `POST /snowflake/events` endpoint that was added in
#23842, as it is no longer used.
Release Notes:
- N/A
Change summary
crates/collab/src/api.rs | 18 ------------------
1 file changed, 18 deletions(-)
Detailed changes
@@ -5,7 +5,6 @@ pub mod extensions;
pub mod ips_file;
pub mod slack;
-use crate::api::events::SnowflakeRow;
use crate::{
auth,
db::{User, UserId},
@@ -100,7 +99,6 @@ pub fn routes(rpc_server: Arc<rpc::Server>) -> Router<(), Body> {
.route("/user", get(get_authenticated_user))
.route("/users/:id/access_tokens", post(create_access_token))
.route("/rpc_server_snapshot", get(get_rpc_server_snapshot))
- .route("/snowflake/events", post(write_snowflake_event))
.merge(billing::router())
.merge(contributors::router())
.layer(
@@ -247,19 +245,3 @@ async fn create_access_token(
encrypted_access_token,
}))
}
-
-/// An endpoint that writes a Snowflake event to our event stream.
-///
-/// This endpoint is exposed such that other internal services can write
-/// telemetry events without needing to talk to AWS Kinesis directly.
-async fn write_snowflake_event(
- Extension(app): Extension<Arc<AppState>>,
- Json(event): Json<SnowflakeRow>,
-) -> Result<()> {
- let kinesis_client = app.kinesis_client.clone();
- let kinesis_stream = app.config.kinesis_stream.clone();
-
- event.write(&kinesis_client, &kinesis_stream).await?;
-
- Ok(())
-}