Method insert_sample

mserver/MasterService/src/repository.rs:473–490

(
        &self,
        server_id: &str,
        observed_unix_ms: i64,
        players: i32,
    )

            Dialect::Sqlite => {
                "SELECT token_hash, last_seen_unix_ms FROM servers WHERE server_id = ?"
            }
        };
        let target = sqlx::query(&self.bind_sql(target_query))
            .bind(new_server_id)
            .fetch_optional(&mut *transaction)
            .await?;
        if let Some(target) = target {
            let target_hash = target.try_get::<Option<String>, _>(0)?;
            let target_last_seen = target.try_get::<i64, _>(1)?;
            if target_hash.as_deref() != Some(token_hash)
                && now_unix_ms - target_last_seen < recovery_ms
            {
                transaction.rollback().await?;
                return Ok(TokenRelocation::Conflict);
            }
            sqlx::query(&self.bind_sql("DELETE FROM servers WHERE server_id = ?"))
                .bind(new_server_id)
                .execute(&mut *transaction)
                .await?;
        }