clean up dead code

Author: ananthb

src/ai.rs

@@ -1,4 +1,4 @@
-use serde::{Deserialize, Serialize};
+use serde::Serialize;
 use worker::*;
 
 use crate::types::ExtractedEvent;
@@ -17,12 +17,6 @@ struct Message {
     content: String,
 }
 
-#[derive(Deserialize)]
-#[allow(dead_code)]
-struct AiResponse {
-    response: Option<String>,
-}
-
 // ============================================================================
 // Responder AI Generation
 // ============================================================================

src/helpers.rs

@@ -310,21 +310,6 @@ pub fn day_name(day: u32) -> &'static str {
     }
 }
 
-/// Get short day name
-#[allow(dead_code)]
-pub fn day_name_short(day: u32) -> &'static str {
-    match day {
-        0 => "Sun",
-        1 => "Mon",
-        2 => "Tue",
-        3 => "Wed",
-        4 => "Thu",
-        5 => "Fri",
-        6 => "Sat",
-        _ => "?",
-    }
-}
-
 /// Add CORS headers to a response
 pub fn add_cors_headers(
     mut response: Response,

src/storage.rs

@@ -264,24 +264,6 @@ pub async fn get_events(
     Ok(events)
 }
 
-#[allow(dead_code)]
-pub async fn get_event(db: &D1Database, id: &str) -> Result<Option<CalendarEvent>> {
-    let stmt = db.prepare(
-        "SELECT id, calendar_id, title, description, start_time, end_time,
-                all_day, recurrence_rule, created_at, updated_at
-         FROM events WHERE id = ?",
-    );
-
-    let results = stmt.bind(&[id.into()])?.all().await?;
-    let rows = results.results::<serde_json::Value>()?;
-
-    if let Some(row) = rows.into_iter().next() {
-        Ok(serde_json::from_value(row).ok())
-    } else {
-        Ok(None)
-    }
-}
-
 pub async fn save_event(db: &D1Database, event: &CalendarEvent) -> Result<()> {
     let stmt = db.prepare(
         "INSERT OR REPLACE INTO events
@@ -421,25 +403,6 @@ pub async fn get_booking(db: &D1Database, id: &str) -> Result<Option<Booking>> {
     }
 }
 
-#[allow(dead_code)]
-pub async fn get_booking_by_token(db: &D1Database, token: &str) -> Result<Option<Booking>> {
-    let stmt = db.prepare(
-        "SELECT id, calendar_id, booking_link_id, slot_date, slot_time, duration,
-                name, email, phone, notes, fields_data, status, confirmation_token,
-                created_at, updated_at
-         FROM bookings WHERE confirmation_token = ?",
-    );
-
-    let results = stmt.bind(&[token.into()])?.all().await?;
-    let rows = results.results::<serde_json::Value>()?;
-
-    if let Some(row) = rows.into_iter().next() {
-        Ok(serde_json::from_value(row).ok())
-    } else {
-        Ok(None)
-    }
-}
-
 pub async fn save_booking(db: &D1Database, booking: &Booking) -> Result<()> {
     let status_str = match booking.status {
         BookingStatus::Pending => "pending",
@@ -605,70 +568,6 @@ pub async fn save_instagram_post(db: &D1Database, post: &ProcessedPost) -> Resul
 // D1 Operations (Event Sources)
 // ============================================================================
 
-#[allow(dead_code)]
-pub async fn get_event_source_by_event_id(
-    db: &D1Database,
-    event_id: &str,
-) -> Result<Option<EventSource>> {
-    let stmt = db.prepare(
-        "SELECT id, event_id, contact_id, source_type, source_id, external_id, created_at
-         FROM event_sources WHERE event_id = ?",
-    );
-
-    let results = stmt.bind(&[event_id.into()])?.all().await?;
-    let rows = results.results::<serde_json::Value>()?;
-
-    if let Some(row) = rows.into_iter().next() {
-        Ok(serde_json::from_value(row).ok())
-    } else {
-        Ok(None)
-    }
-}
-
-#[allow(dead_code)]
-pub async fn get_event_source_by_contact_id(
-    db: &D1Database,
-    contact_id: i64,
-) -> Result<Option<EventSource>> {
-    let stmt = db.prepare(
-        "SELECT id, event_id, contact_id, source_type, source_id, external_id, created_at
-         FROM event_sources WHERE contact_id = ?",
-    );
-
-    let results = stmt.bind(&[contact_id.into()])?.all().await?;
-    let rows = results.results::<serde_json::Value>()?;
-
-    if let Some(row) = rows.into_iter().next() {
-        Ok(serde_json::from_value(row).ok())
-    } else {
-        Ok(None)
-    }
-}
-
-#[allow(dead_code)]
-pub async fn get_event_source_by_external_id(
-    db: &D1Database,
-    source_type: &str,
-    external_id: &str,
-) -> Result<Option<EventSource>> {
-    let stmt = db.prepare(
-        "SELECT id, event_id, contact_id, source_type, source_id, external_id, created_at
-         FROM event_sources WHERE source_type = ? AND external_id = ?",
-    );
-
-    let results = stmt
-        .bind(&[source_type.into(), external_id.into()])?
-        .all()
-        .await?;
-    let rows = results.results::<serde_json::Value>()?;
-
-    if let Some(row) = rows.into_iter().next() {
-        Ok(serde_json::from_value(row).ok())
-    } else {
-        Ok(None)
-    }
-}
-
 pub async fn save_event_source(db: &D1Database, source: &EventSource) -> Result<()> {
     let stmt = db.prepare(
         "INSERT OR REPLACE INTO event_sources

src/types.rs

@@ -551,15 +551,13 @@ pub struct InstagramMedia {
 // WhatsApp Types
 // ============================================================================
 
-#[allow(dead_code)]
 #[derive(Debug, Deserialize)]
 pub struct WhatsAppWebhook {
     pub object: String,
     #[serde(default)]
     pub entry: Vec<WebhookEntry>,
 }
 
-#[allow(dead_code)]
 #[derive(Debug, Deserialize)]
 pub struct WebhookEntry {
     pub id: String,
@@ -573,7 +571,6 @@ pub struct WebhookChange {
     pub value: WebhookValue,
 }
 
-#[allow(dead_code)]
 #[derive(Debug, Deserialize)]
 pub struct WebhookValue {
     pub messaging_product: String,
@@ -584,7 +581,6 @@ pub struct WebhookValue {
     pub messages: Vec<WhatsAppMessage>,
 }
 
-#[allow(dead_code)]
 #[derive(Debug, Deserialize)]
 pub struct WebhookMetadata {
     pub display_phone_number: String,
@@ -618,7 +614,6 @@ pub struct TextMessage {
     pub body: String,
 }
 
-#[allow(dead_code)]
 #[derive(Debug, Clone)]
 pub struct IncomingMessage {
     pub from: String,