forked from deadvey/button
style: order imports
This commit is contained in:
+21
-18
@@ -1,22 +1,25 @@
|
||||
use std::{
|
||||
collections::HashMap,
|
||||
fs,
|
||||
io::Write,
|
||||
sync::{Arc, Mutex, mpsc},
|
||||
};
|
||||
|
||||
use axum::{
|
||||
extract::ws::{Message, WebSocket, WebSocketUpgrade},
|
||||
Router,
|
||||
extract::{
|
||||
State,
|
||||
ws::{Message, WebSocket, WebSocketUpgrade},
|
||||
},
|
||||
response::{Html, IntoResponse},
|
||||
routing::get,
|
||||
Router,
|
||||
};
|
||||
use std::collections::HashMap;
|
||||
use axum::extract::State;
|
||||
use futures::StreamExt as _;
|
||||
use rand::random_bool;
|
||||
use futures::stream::StreamExt;
|
||||
use serde_json;
|
||||
use serde_json::json;
|
||||
use serde::{Deserialize, Serialize};
|
||||
use std::fs;
|
||||
use std::io::Write;
|
||||
use std::sync::mpsc;
|
||||
use std::sync::{Mutex, Arc};
|
||||
use tokio::time::{sleep,Duration};
|
||||
use regex::Regex;
|
||||
use serde::{Deserialize, Serialize};
|
||||
use serde_json::json;
|
||||
use tokio::time::{Duration, sleep};
|
||||
|
||||
#[derive(Deserialize,Serialize,Debug,Ord,Eq,PartialEq,PartialOrd,Clone)]
|
||||
struct Entry
|
||||
@@ -80,7 +83,7 @@ async fn main() {
|
||||
let app = Router::new()
|
||||
.route("/", get(index))
|
||||
.route("/ws", get(ws_handler))
|
||||
.route("/leaderboard", get(leaderboard))
|
||||
.route("/leaderboard", get(leaderboard))
|
||||
.with_state(state);
|
||||
|
||||
let listener = tokio::net::TcpListener::bind("0.0.0.0:8084")
|
||||
@@ -241,10 +244,10 @@ async fn handle_socket
|
||||
|
||||
fn validate_name(input: String) -> String {
|
||||
let input = input.trim();
|
||||
if input == "null"
|
||||
{
|
||||
return "anon".to_string();
|
||||
}
|
||||
if input == "null"
|
||||
{
|
||||
return "anon".to_string();
|
||||
}
|
||||
// Length check
|
||||
if input.is_empty() || input.len() > 32 {
|
||||
return "anon".to_string();
|
||||
|
||||
Reference in New Issue
Block a user