Architecture

src/
├── commands/        # Slash command implementations
├── models/          # Data types, DB models, API responses
├── utils/           # Shared utilities, API clients, DB helpers
├── schema.rs        # Diesel schema (AUTO-GENERATED - never edit)
└── main.rs          # Bot entry point and event routing
migrations/          # Diesel SQL migrations

src/commands/
├── anime/
│   ├── mod.rs
│   ├── command.rs      # Command registration and execution
│   └── queries.rs      # GraphQL queries for AniList API
├── manga/
├── songs/
├── register/
│   └── command.rs      # OAuth link command and response handling
├── ping.rs             # Simple single-file command
├── help.rs
├── whoami.rs           # Shows linked AniList account for the caller
└── mod.rs              # Module exports

src/models/
├── db/
│   ├── user.rs         # Database models (Diesel)
│   └── mod.rs
├── anilist_anime.rs    # AniList anime API response types
├── anilist_manga.rs    # AniList manga API response types
├── anilist_common.rs   # Shared AniList types
├── mal_response.rs     # MyAnimeList API response types
├── transformers.rs     # Convert API responses to Discord embeds
└── mod.rs

src/utils/
├── requests/
│   ├── anilist.rs      # AniList API client
│   ├── my_anime_list.rs # MAL API client
│   └── mod.rs
├── database.rs         # Diesel connection and helpers
├── redis.rs            # Redis caching layer
├── spotify.rs          # Spotify API integration
├── formatter.rs        # Text formatting utilities
├── fuzzy.rs            # Fuzzy string matching
├── privacy.rs          # User ID hashing for Sentry
├── statics.rs          # Constants and environment variables
└── mod.rs

#[instrument(name = "command.anime.run", skip(ctx, interaction))]
pub async fn run(ctx: &Context, interaction: &mut CommandInteraction) {
    // Defer immediately for long operations
    let _ = interaction.defer(&ctx.http).await;

    // Blocking API call wrapped in spawn_blocking
    let anime_result = match task::spawn_blocking(move || {
        AniListSource.fetch_anime(&search_term)
    }).await {
        Ok(result) => result,
        Err(e) => {
            error!(error = %e, "spawn_blocking panicked");
            None
        }
    };

    // Handle response...
}