From 74e8164cd78ac7e44c4cec9a02bad274753d7352 Mon Sep 17 00:00:00 2001 From: Marshall Bowers Date: Thu, 13 Feb 2025 14:31:57 -0500 Subject: [PATCH] collab: Remove `POST /snowflake/events` endpoint (#24817) This PR removes the `POST /snowflake/events` endpoint that was added in #23842, as it is no longer used. Release Notes: - N/A --- crates/collab/src/api.rs | 18 ------------------ 1 file changed, 18 deletions(-) diff --git a/crates/collab/src/api.rs b/crates/collab/src/api.rs index 5762a56cb5..2b8b5ac6fb 100644 --- a/crates/collab/src/api.rs +++ b/crates/collab/src/api.rs @@ -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) -> 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>, - Json(event): Json, -) -> Result<()> { - let kinesis_client = app.kinesis_client.clone(); - let kinesis_stream = app.config.kinesis_stream.clone(); - - event.write(&kinesis_client, &kinesis_stream).await?; - - Ok(()) -}