Remove fallback sessions (#47)

* Remove Amplitude integration

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* Remove dead FallbackSession code

FallbackSession was used for reading old bancho.py sessions from Redis
but was never called anywhere in the codebase. Remove the struct, all
helper functions, and clean up unused imports.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

---------

Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>

Author: cmyui

src/entities/sessions.rs

@@ -28,58 +28,3 @@ pub struct CreateSessionArgs {
     pub silence_end: Option<chrono::DateTime<chrono::Utc>>,
     pub ip_address: IpAddr,
 }
-
-#[derive(Debug, Deserialize, Serialize)]
-pub struct FallbackSession {
-    pub token_id: String,
-    pub user_id: i64,
-    pub username: String,
-    pub privileges: i64,
-    pub whitelist: u8,
-    pub kicked: bool,
-    pub login_time: f64,
-    pub ping_time: f64,
-    pub utc_offset: i8,
-    pub tournament: bool,
-    pub block_non_friends_dm: bool,
-    pub spectating_token_id: Option<String>,
-    pub spectating_user_id: Option<String>,
-    pub latitude: f64,
-    pub longitude: f64,
-    pub ip: String,
-    pub country: u8,
-    pub away_message: Option<String>,
-    pub match_id: Option<i64>,
-
-    pub match_slot_id: Option<u8>,
-
-    pub last_np: Option<FallbackLastNp>,
-    pub silence_end_time: i64,
-    pub protocol_version: i64,
-    pub spam_rate: i64,
-
-    // stats
-    pub action_id: u8,
-    pub action_text: String,
-    pub action_md5: String,
-    pub action_mods: i64,
-    pub game_mode: u8,
-    pub relax: bool,
-    pub autopilot: bool,
-    pub beatmap_id: i64,
-    pub ranked_score: i64,
-    pub accuracy: f32,
-    pub playcount: i64,
-    pub total_score: i64,
-    pub global_rank: i64,
-    pub pp: i64,
-
-    pub amplitude_device_id: Option<String>,
-}
-
-#[derive(Debug, Deserialize, Serialize)]
-pub struct FallbackLastNp {
-    pub beatmap_id: i64,
-    pub mods: i64,
-    pub accuracy: f32,
-}

src/repositories/sessions.rs

@@ -1,8 +1,7 @@
-use crate::common::chat;
 use crate::common::chat::safe_username;
-use crate::common::context::{Context, PoolContext};
+use crate::common::context::Context;
 use crate::common::redis_json::Json;
-use crate::entities::sessions::{CreateSessionArgs, FallbackSession, Session};
+use crate::entities::sessions::{CreateSessionArgs, Session};
 use redis::AsyncCommands;
 use std::ops::DerefMut;
 use uuid::Uuid;
@@ -161,109 +160,3 @@ pub async fn set_private_dms<C: Context>(
     session.private_dms = private_dms;
     update(ctx, session).await
 }
-
-const FALLBACK_SESSIONS_KEY: &str = "bancho:tokens:json";
-
-fn make_fallback_user_id_key(user_id: i64) -> String {
-    format!("bancho:tokens:ids:{user_id}")
-}
-
-fn make_fallback_username_key(username: &str) -> String {
-    let safe_username = chat::safe_username(username);
-    format!("bancho:tokens:names:{safe_username}")
-}
-
-fn make_fallback_key(session_id: &str) -> String {
-    format!("bancho:tokens:{session_id}")
-}
-
-fn make_fallback_channels_key(session_id: &str) -> String {
-    format!("{}:channels", make_fallback_key(session_id))
-}
-
-fn make_fallback_spectators_key(session_id: &str) -> String {
-    format!("{}:spectators", make_fallback_key(session_id))
-}
-
-fn make_fallback_streams_key(session_id: &str) -> String {
-    format!("{}:streams", make_fallback_key(session_id))
-}
-
-fn make_fallback_stream_offsets_key(session_id: &str) -> String {
-    format!("{}:stream_offsets", make_fallback_key(session_id))
-}
-
-fn make_fallback_message_history_key(session_id: &str) -> String {
-    format!("{}:message_history", make_fallback_key(session_id))
-}
-
-fn make_fallback_sent_away_messages_key(session_id: &str) -> String {
-    format!("{}:sent_away_messages", make_fallback_key(session_id))
-}
-
-fn make_fallback_processing_lock_key(session_id: &str) -> String {
-    format!("{}:processing_lock", make_fallback_key(session_id))
-}
-
-fn make_fallback_user_stream_key(session_id: &str) -> String {
-    format!("bancho:streams:tokens/{session_id}:messages")
-}
-
-fn make_fallback_user_stream_messages_key(session_id: &str) -> String {
-    format!("bancho:streams:tokens/{session_id}:messages:messages")
-}
-
-pub async fn fetch_one_fallback<C: Context>(
-    ctx: &C,
-    session_id: Uuid,
-) -> anyhow::Result<Option<FallbackSession>> {
-    let mut redis = ctx.redis().await?;
-    let session: Option<Json<FallbackSession>> = redis
-        .hget(FALLBACK_SESSIONS_KEY, session_id.to_string())
-        .await?;
-    Ok(session.map(Json::into_inner))
-}
-
-pub async fn delete_fallback<C: Context>(ctx: &C, session: FallbackSession) -> anyhow::Result<()> {
-    let mut redis = ctx.redis().await?;
-    let id_key = make_fallback_user_id_key(session.user_id);
-    let name_key = make_fallback_username_key(&session.username);
-    let channels_key = make_fallback_channels_key(&session.token_id);
-    let spectators_key = make_fallback_spectators_key(&session.token_id);
-    let streams_key = make_fallback_streams_key(&session.token_id);
-    let stream_offsets_key = make_fallback_stream_offsets_key(&session.token_id);
-    let user_stream_key = make_fallback_user_stream_key(&session.token_id);
-    let user_stream_messages_key = make_fallback_user_stream_messages_key(&session.token_id);
-    let msg_history_key = make_fallback_message_history_key(&session.token_id);
-    let afk_msgs_key = make_fallback_sent_away_messages_key(&session.token_id);
-    let processing_lock_key = make_fallback_processing_lock_key(&session.token_id);
-    redis::pipe()
-        .atomic()
-        .hdel(FALLBACK_SESSIONS_KEY, session.token_id)
-        .ignore()
-        .del(id_key)
-        .ignore()
-        .del(name_key)
-        .ignore()
-        .del(channels_key)
-        .ignore()
-        .del(spectators_key)
-        .ignore()
-        .del(streams_key)
-        .ignore()
-        .del(stream_offsets_key)
-        .ignore()
-        .del(user_stream_key)
-        .ignore()
-        .del(user_stream_messages_key)
-        .ignore()
-        .del(msg_history_key)
-        .ignore()
-        .del(afk_msgs_key)
-        .ignore()
-        .del(processing_lock_key)
-        .ignore()
-        .exec_async(redis.deref_mut())
-        .await?;
-    Ok(())
-}