commit
a560699787
GPG Key ID:
0104BC05F41B77B8
@ -0,0 +1,2 @@
|
||||
/target
|
||||
/.direnv
|
||||
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,23 @@
|
||||
[package]
|
||||
name = "quiclime"
|
||||
version = "0.1.0"
|
||||
edition = "2021"
|
||||
|
||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||
|
||||
[dependencies]
|
||||
anyhow = { version = "1.0.71", features = ["backtrace"] }
|
||||
async-trait = "0.1.68"
|
||||
axum = "0.6.18"
|
||||
env_logger = "0.10.0"
|
||||
idna = "0.4.0"
|
||||
log = "0.4.19"
|
||||
parking_lot = "0.12.1"
|
||||
quinn = "0.10.1"
|
||||
rand = "0.8.5"
|
||||
rustls = "*"
|
||||
rustls-pemfile = "1.0.2"
|
||||
serde = { version = "1.0.164", features = ["derive"] }
|
||||
serde_json = "1.0.97"
|
||||
thiserror = "1.0.40"
|
||||
tokio = { version = "1.28.2", features = ["rt-multi-thread", "fs", "macros", "io-util", "net"] }
|
||||
@ -0,0 +1,3 @@
|
||||
{
|
||||
"text": "Unknown server. Check address and try again."
|
||||
}
|
||||
Binary file not shown.
@ -0,0 +1,312 @@
|
||||
use std::{net::SocketAddr, sync::Arc, time::Duration};
|
||||
|
||||
use anyhow::Context;
|
||||
use axum::{
|
||||
http::StatusCode,
|
||||
routing::{get, post},
|
||||
};
|
||||
use log::{error, info};
|
||||
use netty::{Handshake, NettyReadError};
|
||||
use quinn::{Connecting, ConnectionError, Endpoint, ServerConfig, TransportConfig};
|
||||
use routing::RoutingTable;
|
||||
use rustls::{Certificate, PrivateKey};
|
||||
use tokio::{
|
||||
io::{AsyncReadExt, AsyncWriteExt},
|
||||
net::TcpStream,
|
||||
};
|
||||
|
||||
use crate::{
|
||||
netty::WriteExtNetty,
|
||||
proto::{ClientboundControlMessage, ServerboundControlMessage},
|
||||
};
|
||||
|
||||
mod netty;
|
||||
mod proto;
|
||||
mod routing;
|
||||
mod unicode_madness;
|
||||
mod wordlist;
|
||||
|
||||
fn any_private_keys(rd: &mut dyn std::io::BufRead) -> Result<Vec<Vec<u8>>, std::io::Error> {
|
||||
let mut keys = Vec::<Vec<u8>>::new();
|
||||
|
||||
loop {
|
||||
match rustls_pemfile::read_one(rd)? {
|
||||
None => return Ok(keys),
|
||||
Some(rustls_pemfile::Item::ECKey(key)) => keys.push(key),
|
||||
Some(rustls_pemfile::Item::PKCS8Key(key)) => keys.push(key),
|
||||
Some(rustls_pemfile::Item::RSAKey(key)) => keys.push(key),
|
||||
_ => {}
|
||||
};
|
||||
}
|
||||
}
|
||||
|
||||
fn get_certs() -> anyhow::Result<(Vec<Certificate>, PrivateKey)> {
|
||||
let mut cert_file = std::io::BufReader::new(std::fs::File::open(
|
||||
std::env::var("QUICLIME_CERT_PATH").context("Reading QUICLIME_CERT_PATH")?,
|
||||
)?);
|
||||
let certs = rustls_pemfile::certs(&mut cert_file)?
|
||||
.into_iter()
|
||||
.map(Certificate)
|
||||
.collect();
|
||||
let mut key_file = std::io::BufReader::new(std::fs::File::open(
|
||||
std::env::var("QUICLIME_KEY_PATH").context("Reading QUICLIME_KEY_PATH")?,
|
||||
)?);
|
||||
let key = PrivateKey(
|
||||
any_private_keys(&mut key_file)?
|
||||
.into_iter()
|
||||
.next()
|
||||
.ok_or(anyhow::anyhow!("No private key?"))?,
|
||||
);
|
||||
Ok((certs, key))
|
||||
}
|
||||
|
||||
async fn create_server_config() -> anyhow::Result<ServerConfig> {
|
||||
let (cert_chain, key_der) = tokio::task::spawn_blocking(get_certs).await??;
|
||||
let mut rustls_config = rustls::ServerConfig::builder()
|
||||
.with_safe_defaults()
|
||||
.with_no_client_auth()
|
||||
.with_single_cert(cert_chain, key_der)?;
|
||||
rustls_config.alpn_protocols = vec![b"quiclime".to_vec()];
|
||||
let mut config = ServerConfig::with_crypto(Arc::new(rustls_config));
|
||||
let mut transport = TransportConfig::default();
|
||||
transport
|
||||
.max_concurrent_bidi_streams(1u32.into())
|
||||
.max_concurrent_uni_streams(0u32.into())
|
||||
.keep_alive_interval(Some(Duration::from_secs(5)));
|
||||
config.transport_config(Arc::new(transport));
|
||||
Ok(config)
|
||||
}
|
||||
|
||||
#[tokio::main]
|
||||
async fn main() -> anyhow::Result<()> {
|
||||
env_logger::init();
|
||||
// JUSTIFICATION: this lives until the end of the entire program
|
||||
let endpoint = Box::leak(Box::new(Endpoint::server(
|
||||
create_server_config().await?,
|
||||
std::env::var("QUICLIME_BIND_ADDR_QUIC")
|
||||
.context("Reading QUICLIME_BIND_ADDR_QUIC")?
|
||||
.parse()?,
|
||||
)?));
|
||||
// JUSTIFICATION: this lives until the end of the entire program
|
||||
let routing_table = Box::leak(Box::new(routing::RoutingTable::new(
|
||||
std::env::var("QUICLIME_BASE_DOMAIN").context("Reading QUICLIME_BASE_DOMAIN")?,
|
||||
)));
|
||||
tokio::try_join!(
|
||||
listen_quic(endpoint, routing_table),
|
||||
listen_control(endpoint, routing_table),
|
||||
listen_minecraft(routing_table)
|
||||
)?;
|
||||
Ok(())
|
||||
}
|
||||
|
||||
async fn try_handle_quic(
|
||||
connection: Connecting,
|
||||
routing_table: &RoutingTable,
|
||||
) -> anyhow::Result<()> {
|
||||
let connection = connection.await?;
|
||||
info!(
|
||||
"QUIClime connection established to: {}",
|
||||
connection.remote_address()
|
||||
);
|
||||
let (mut send_control, mut recv_control) = connection.accept_bi().await?;
|
||||
info!("Control channel open: {}", connection.remote_address());
|
||||
let mut handle = loop {
|
||||
let mut buf = vec![0u8; recv_control.read_u8().await? as _];
|
||||
recv_control.read_exact(&mut buf).await?;
|
||||
if let Ok(parsed) = serde_json::from_slice(&buf) {
|
||||
match parsed {
|
||||
ServerboundControlMessage::RequestDomainAssignment => {
|
||||
let handle = routing_table.register().await;
|
||||
info!(
|
||||
"Domain assigned to {}: {}",
|
||||
connection.remote_address(),
|
||||
handle.domain()
|
||||
);
|
||||
let response =
|
||||
serde_json::to_vec(&ClientboundControlMessage::DomainAssignmentComplete {
|
||||
domain: handle.domain().to_string(),
|
||||
})?;
|
||||
send_control.write_all(&[response.len() as u8]).await?;
|
||||
send_control.write_all(&response).await?;
|
||||
break handle;
|
||||
}
|
||||
}
|
||||
} else {
|
||||
let response = serde_json::to_vec(&ClientboundControlMessage::UnknownMessage)?;
|
||||
send_control.write_all(&[response.len() as u8]).await?;
|
||||
send_control.write_all(&response).await?;
|
||||
}
|
||||
};
|
||||
tokio::select! {
|
||||
e = connection.closed() => {
|
||||
match e {
|
||||
ConnectionError::ConnectionClosed(_) => Ok(()),
|
||||
ConnectionError::ApplicationClosed(_) => Ok(()),
|
||||
ConnectionError::LocallyClosed => Ok(()),
|
||||
e => Err(e.into())
|
||||
}
|
||||
},
|
||||
r = async {
|
||||
while let Some(remote) = handle.next().await {
|
||||
match remote {
|
||||
routing::RouterRequest::RouteRequest(remote) => {
|
||||
let pair = connection.open_bi().await;
|
||||
if let Err(ConnectionError::ApplicationClosed(_)) = pair {
|
||||
break;
|
||||
} else if let Err(ConnectionError::ConnectionClosed(_)) = pair {
|
||||
break;
|
||||
}
|
||||
remote.send(pair?).map_err(|e| anyhow::anyhow!("{:?}", e))?;
|
||||
}
|
||||
routing::RouterRequest::BroadcastRequest(message) => {
|
||||
let response =
|
||||
serde_json::to_vec(&ClientboundControlMessage::RequestMessageBroadcast {
|
||||
message,
|
||||
})?;
|
||||
send_control.write_all(&[response.len() as u8]).await?;
|
||||
send_control.write_all(&response).await?;
|
||||
}
|
||||
}
|
||||
}
|
||||
Ok(())
|
||||
} => r
|
||||
}
|
||||
}
|
||||
|
||||
async fn handle_quic(connection: Connecting, routing_table: &RoutingTable) {
|
||||
if let Err(e) = try_handle_quic(connection, routing_table).await {
|
||||
error!("Error handling QUIClime connection: {}", e);
|
||||
};
|
||||
info!("Finished handling QUIClime connection");
|
||||
}
|
||||
|
||||
async fn listen_quic(
|
||||
endpoint: &'static Endpoint,
|
||||
routing_table: &'static RoutingTable,
|
||||
) -> anyhow::Result<()> {
|
||||
while let Some(connection) = endpoint.accept().await {
|
||||
tokio::spawn(handle_quic(connection, routing_table));
|
||||
}
|
||||
Ok(())
|
||||
}
|
||||
|
||||
async fn listen_control(
|
||||
endpoint: &'static Endpoint,
|
||||
routing_table: &'static RoutingTable,
|
||||
) -> anyhow::Result<()> {
|
||||
let app = axum::Router::new()
|
||||
.route(
|
||||
"/metrics",
|
||||
get(|| async { format!("host_count {}", routing_table.size()) }),
|
||||
)
|
||||
.route(
|
||||
"/reload-certs",
|
||||
post(|| async {
|
||||
match create_server_config().await {
|
||||
Ok(config) => {
|
||||
endpoint.set_server_config(Some(config));
|
||||
(StatusCode::OK, "Success".to_string())
|
||||
}
|
||||
Err(e) => (StatusCode::INTERNAL_SERVER_ERROR, format!("{}", e)),
|
||||
}
|
||||
}),
|
||||
)
|
||||
.route(
|
||||
"/broadcast",
|
||||
post(move |body: String| async move { routing_table.broadcast(&body) }),
|
||||
)
|
||||
.route(
|
||||
"/stop",
|
||||
post(|| async {
|
||||
endpoint.close(0u32.into(), b"e4mc closing");
|
||||
}),
|
||||
);
|
||||
axum::Server::bind(
|
||||
&std::env::var("QUICLIME_BIND_ADDR_WEB")
|
||||
.context("Reading QUICLIME_BIND_ADDR_WEB")?
|
||||
.parse()?,
|
||||
)
|
||||
.serve(app.into_make_service())
|
||||
.await?;
|
||||
Ok(())
|
||||
}
|
||||
|
||||
async fn try_handle_minecraft(
|
||||
mut connection: TcpStream,
|
||||
routing_table: &'static RoutingTable,
|
||||
) -> anyhow::Result<()> {
|
||||
let peer = connection.peer_addr()?;
|
||||
info!("Minecraft client connected from: {}", peer);
|
||||
let handshake = netty::read_packet(&mut connection).await;
|
||||
if let Err(NettyReadError::LegacyServerListPing) = handshake {
|
||||
connection
|
||||
.write_all(include_bytes!("legacy_serverlistping_response.bin"))
|
||||
.await?;
|
||||
return Ok(());
|
||||
}
|
||||
let handshake = Handshake::new(&handshake?)?;
|
||||
let address = match handshake.normalized_address() {
|
||||
Some(addr) => addr,
|
||||
None => return politely_disconnect(connection, handshake).await,
|
||||
};
|
||||
let (mut send_host, mut recv_host) = match routing_table.route(&address).await {
|
||||
Some(pair) => pair,
|
||||
None => return politely_disconnect(connection, handshake).await,
|
||||
};
|
||||
handshake.send(&mut send_host).await?;
|
||||
let (mut recv_client, mut send_client) = connection.split();
|
||||
tokio::select! {
|
||||
_ = tokio::io::copy(&mut recv_client, &mut send_host) => (),
|
||||
_ = tokio::io::copy(&mut recv_host, &mut send_client) => ()
|
||||
}
|
||||
_ = connection.shutdown().await;
|
||||
_ = send_host.finish().await;
|
||||
_ = recv_host.stop(0u32.into());
|
||||
info!("Minecraft client disconnected from: {}", peer);
|
||||
Ok(())
|
||||
}
|
||||
|
||||
async fn politely_disconnect(
|
||||
mut connection: TcpStream,
|
||||
handshake: Handshake,
|
||||
) -> anyhow::Result<()> {
|
||||
match handshake.next_state {
|
||||
netty::HandshakeType::Status => {
|
||||
let mut buf = vec![];
|
||||
buf.write_varint(0).await?;
|
||||
buf.write_string(include_str!("./serverlistping_response.json"))
|
||||
.await?;
|
||||
connection.write_varint(buf.len() as i32).await?;
|
||||
connection.write_all(&buf).await?;
|
||||
}
|
||||
netty::HandshakeType::Login => {
|
||||
let _ = netty::read_packet(&mut connection).await?;
|
||||
let mut buf = vec![];
|
||||
buf.write_varint(0).await?;
|
||||
buf.write_string(include_str!("./disconnect_response.json"))
|
||||
.await?;
|
||||
connection.write_varint(buf.len() as i32).await?;
|
||||
connection.write_all(&buf).await?;
|
||||
}
|
||||
}
|
||||
Ok(())
|
||||
}
|
||||
|
||||
async fn handle_minecraft(connection: TcpStream, routing_table: &'static RoutingTable) {
|
||||
if let Err(e) = try_handle_minecraft(connection, routing_table).await {
|
||||
error!("Error handling Minecraft connection: {}", e.backtrace());
|
||||
};
|
||||
}
|
||||
|
||||
async fn listen_minecraft(routing_table: &'static RoutingTable) -> anyhow::Result<()> {
|
||||
let server = tokio::net::TcpListener::bind(
|
||||
std::env::var("QUICLIME_BIND_ADDR_MC")
|
||||
.context("Reading QUICLIME_BIND_ADDR_MC")?
|
||||
.parse::<SocketAddr>()?,
|
||||
)
|
||||
.await?;
|
||||
while let Ok((connection, _)) = server.accept().await {
|
||||
tokio::spawn(handle_minecraft(connection, routing_table));
|
||||
}
|
||||
Ok(())
|
||||
}
|
||||
@ -0,0 +1,204 @@
|
||||
use std::io::Read;
|
||||
|
||||
use tokio::io::{AsyncReadExt, AsyncWriteExt};
|
||||
|
||||
use async_trait::async_trait;
|
||||
use log::error;
|
||||
use thiserror::Error;
|
||||
|
||||
#[derive(Error, Debug)]
|
||||
pub enum NettyReadError {
|
||||
#[error("{0}")]
|
||||
IoError(std::io::Error),
|
||||
#[error("Was not a netty packet, but a Legacy ServerListPing")]
|
||||
LegacyServerListPing,
|
||||
}
|
||||
|
||||
impl From<std::io::Error> for NettyReadError {
|
||||
fn from(value: std::io::Error) -> Self {
|
||||
Self::IoError(value)
|
||||
}
|
||||
}
|
||||
|
||||
impl From<std::io::ErrorKind> for NettyReadError {
|
||||
fn from(value: std::io::ErrorKind) -> Self {
|
||||
Self::IoError(value.into())
|
||||
}
|
||||
}
|
||||
|
||||
pub trait ReadExtNetty: Read {
|
||||
fn read_u8(&mut self) -> Result<u8, NettyReadError> {
|
||||
let mut buf = [0u8];
|
||||
self.read_exact(&mut buf)?;
|
||||
Ok(buf[0])
|
||||
}
|
||||
|
||||
fn read_u16(&mut self) -> Result<u16, NettyReadError> {
|
||||
let mut buf = [0u8; 2];
|
||||
self.read_exact(&mut buf)?;
|
||||
Ok(u16::from_be_bytes(buf))
|
||||
}
|
||||
|
||||
fn read_string(&mut self) -> Result<String, NettyReadError> {
|
||||
let len = self.read_varint()?;
|
||||
let mut buf = vec![0u8; len as usize];
|
||||
self.read_exact(&mut buf)?;
|
||||
String::from_utf8(buf).map_err(|_| std::io::ErrorKind::InvalidData.into())
|
||||
}
|
||||
|
||||
fn read_varint(&mut self) -> Result<i32, NettyReadError> {
|
||||
let mut res = 0i32;
|
||||
for i in 0..5 {
|
||||
let part = self.read_u8()?;
|
||||
res |= (part as i32 & 0x7F) << (7 * i);
|
||||
if part & 0x80 == 0 {
|
||||
return Ok(res);
|
||||
}
|
||||
}
|
||||
error!("Varint is invalid");
|
||||
Err(std::io::ErrorKind::InvalidData.into())
|
||||
}
|
||||
|
||||
// fn read_packet_compressed(&mut self) -> Result<Vec<u8>, NettyReadError> {
|
||||
// let len = self.read_varint()?;
|
||||
// let len_decompressed = self.read_varint()?;
|
||||
// let mut buf = vec![0u8; len as usize];
|
||||
// self.read_exact(&mut buf)?;
|
||||
// if len_decompressed == 0 {
|
||||
// return Ok(buf);
|
||||
// }
|
||||
// let mut buf_decompressed = vec![0u8; len_decompressed as usize];
|
||||
// if flate2::Decompress::new(true)
|
||||
// .decompress(&buf, &mut buf_decompressed, flate2::FlushDecompress::Finish)
|
||||
// .is_err()
|
||||
// {
|
||||
// return Err(std::io::ErrorKind::InvalidData.into());
|
||||
// };
|
||||
// Ok(buf_decompressed)
|
||||
// }
|
||||
}
|
||||
|
||||
pub async fn read_packet(mut reader: impl AsyncReadExt + Unpin) -> Result<Vec<u8>, NettyReadError> {
|
||||
let len = read_varint(&mut reader).await?;
|
||||
let mut buf = vec![0u8; len as usize];
|
||||
if len == 254 {
|
||||
let mut temp = [0u8];
|
||||
reader.read_exact(&mut temp).await?;
|
||||
if temp[0] == 0xFA {
|
||||
// FE 01 FA: Legacy ServerListPing
|
||||
return Err(NettyReadError::LegacyServerListPing);
|
||||
}
|
||||
buf[0] = temp[0];
|
||||
reader.read_exact(&mut buf[1..]).await?;
|
||||
} else {
|
||||
reader.read_exact(&mut buf).await?;
|
||||
}
|
||||
Ok(buf)
|
||||
}
|
||||
|
||||
async fn read_varint(mut reader: impl AsyncReadExt + Unpin) -> Result<i32, NettyReadError> {
|
||||
let mut res = 0i32;
|
||||
for i in 0..5 {
|
||||
let part = reader.read_u8().await?;
|
||||
res |= (part as i32 & 0x7F) << (7 * i);
|
||||
if part & 0x80 == 0 {
|
||||
return Ok(res);
|
||||
}
|
||||
}
|
||||
error!("Varint is invalid");
|
||||
Err(std::io::ErrorKind::InvalidData.into())
|
||||
}
|
||||
|
||||
impl<T: Read> ReadExtNetty for T {}
|
||||
|
||||
#[async_trait]
|
||||
pub trait WriteExtNetty: AsyncWriteExt + Unpin {
|
||||
async fn write_varint(&mut self, mut val: i32) -> std::io::Result<()> {
|
||||
for _ in 0..5 {
|
||||
if val & !0x7F == 0 {
|
||||
self.write_all(&[val as u8]).await?;
|
||||
return Ok(());
|
||||
}
|
||||
self.write_all(&[(val & 0x7F | 0x80) as u8]).await?;
|
||||
val >>= 7;
|
||||
}
|
||||
Err(std::io::ErrorKind::InvalidData.into())
|
||||
}
|
||||
|
||||
async fn write_string(&mut self, s: &str) -> std::io::Result<()> {
|
||||
self.write_varint(s.len() as i32).await?;
|
||||
self.write_all(s.as_bytes()).await?;
|
||||
Ok(())
|
||||
}
|
||||
}
|
||||
|
||||
#[derive(Debug, Clone)]
|
||||
pub struct Handshake {
|
||||
protocol_version: i32,
|
||||
server_address: String,
|
||||
server_port: u16,
|
||||
pub next_state: HandshakeType,
|
||||
}
|
||||
|
||||
#[derive(Debug, Clone, Copy)]
|
||||
#[repr(i32)]
|
||||
pub enum HandshakeType {
|
||||
Status = 1,
|
||||
Login = 2,
|
||||
}
|
||||
|
||||
impl Handshake {
|
||||
pub fn new(mut packet: &[u8]) -> anyhow::Result<Self> {
|
||||
let packet_type = packet.read_varint()?;
|
||||
if packet_type != 0 {
|
||||
Err(anyhow::anyhow!("Not a Handshake packet"))
|
||||
} else {
|
||||
let protocol_version = packet.read_varint()?;
|
||||
let server_address = packet.read_string()?;
|
||||
let server_port = ReadExtNetty::read_u16(&mut packet)?;
|
||||
let next_state = match packet.read_varint()? {
|
||||
1 => HandshakeType::Status,
|
||||
2 => HandshakeType::Login,
|
||||
_ => return Err(anyhow::anyhow!("Invalid next state")),
|
||||
};
|
||||
Ok(Self {
|
||||
protocol_version,
|
||||
server_address,
|
||||
server_port,
|
||||
next_state,
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
pub async fn send(
|
||||
&self,
|
||||
mut writer: impl AsyncWriteExt + Unpin + Send,
|
||||
) -> tokio::io::Result<()> {
|
||||
let mut buf = vec![];
|
||||
buf.write_varint(0).await?;
|
||||
buf.write_varint(self.protocol_version).await?;
|
||||
buf.write_string(&self.server_address).await?;
|
||||
buf.write_all(&self.server_port.to_be_bytes()).await?;
|
||||
buf.write_varint(self.next_state as i32).await?;
|
||||
writer.write_varint(buf.len() as i32).await?;
|
||||
writer.write_all(&buf).await?;
|
||||
Ok(())
|
||||
}
|
||||
|
||||
pub fn normalized_address(&self) -> Option<String> {
|
||||
crate::unicode_madness::validate_and_normalize_domain(
|
||||
// yes, Forge has three different suffixes that they attach to the server address
|
||||
if let Some(fml3_stripped) = self.server_address.strip_suffix("\0FML3\0") {
|
||||
fml3_stripped
|
||||
} else if let Some(fml2_stripped) = self.server_address.strip_suffix("\0FML2\0") {
|
||||
fml2_stripped
|
||||
} else if let Some(fml_stripped) = self.server_address.strip_suffix("\0FML\0") {
|
||||
fml_stripped
|
||||
} else {
|
||||
&self.server_address
|
||||
},
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
impl<T: AsyncWriteExt + Unpin> WriteExtNetty for T {}
|
||||
@ -0,0 +1,17 @@
|
||||
use serde::{Deserialize, Serialize};
|
||||
|
||||
#[derive(Serialize, Deserialize)]
|
||||
#[serde(tag = "kind")]
|
||||
#[serde(rename_all = "snake_case")]
|
||||
pub enum ServerboundControlMessage {
|
||||
RequestDomainAssignment,
|
||||
}
|
||||
|
||||
#[derive(Serialize, Deserialize)]
|
||||
#[serde(tag = "kind")]
|
||||
#[serde(rename_all = "snake_case")]
|
||||
pub enum ClientboundControlMessage {
|
||||
UnknownMessage,
|
||||
DomainAssignmentComplete { domain: String },
|
||||
RequestMessageBroadcast { message: String },
|
||||
}
|
||||
@ -0,0 +1,117 @@
|
||||
use log::info;
|
||||
use log::warn;
|
||||
use parking_lot::RwLock;
|
||||
use quinn::RecvStream;
|
||||
use quinn::SendStream;
|
||||
use rand::prelude::*;
|
||||
use std::collections::HashMap;
|
||||
use tokio::sync::mpsc;
|
||||
use tokio::sync::oneshot;
|
||||
|
||||
#[derive(Debug)]
|
||||
pub enum RouterRequest {
|
||||
RouteRequest(RouterCallback),
|
||||
BroadcastRequest(String),
|
||||
}
|
||||
|
||||
type RouterCallback = oneshot::Sender<(SendStream, RecvStream)>;
|
||||
type RouteRequestReceiver = mpsc::UnboundedSender<RouterRequest>;
|
||||
|
||||
#[derive(Default)]
|
||||
pub struct RoutingTable {
|
||||
table: RwLock<HashMap<String, RouteRequestReceiver>>,
|
||||
base_domain: String,
|
||||
}
|
||||
|
||||
impl RoutingTable {
|
||||
pub fn new(base_domain: String) -> Self {
|
||||
RoutingTable {
|
||||
table: Default::default(),
|
||||
base_domain,
|
||||
}
|
||||
}
|
||||
|
||||
pub fn size(&self) -> usize {
|
||||
self.table.read().len()
|
||||
}
|
||||
|
||||
pub fn broadcast(&self, message: &str) {
|
||||
for sender in self.table.read().values() {
|
||||
sender
|
||||
.send(RouterRequest::BroadcastRequest(message.to_string()))
|
||||
.unwrap();
|
||||
}
|
||||
}
|
||||
|
||||
pub async fn route(&self, domain: &str) -> Option<(SendStream, RecvStream)> {
|
||||
let (send, recv) = oneshot::channel();
|
||||
self.table
|
||||
.read()
|
||||
.get(domain)?
|
||||
.send(RouterRequest::RouteRequest(send))
|
||||
.ok()?;
|
||||
recv.await.ok()
|
||||
}
|
||||
|
||||
pub async fn register(&self) -> RoutingHandle {
|
||||
let mut lock = self.table.write();
|
||||
let mut domain = format!(
|
||||
"{}-{}.{}",
|
||||
crate::wordlist::ID_WORDS
|
||||
.choose(&mut rand::thread_rng())
|
||||
.unwrap(),
|
||||
crate::wordlist::ID_WORDS
|
||||
.choose(&mut rand::thread_rng())
|
||||
.unwrap(),
|
||||
self.base_domain
|
||||
);
|
||||
while lock.contains_key(&domain) {
|
||||
warn!(
|
||||
"Randomly selected domain {} conflicts; trying again",
|
||||
domain
|
||||
);
|
||||
domain = format!(
|
||||
"{}-{}.{}",
|
||||
crate::wordlist::ID_WORDS
|
||||
.choose(&mut rand::thread_rng())
|
||||
.unwrap(),
|
||||
crate::wordlist::ID_WORDS
|
||||
.choose(&mut rand::thread_rng())
|
||||
.unwrap(),
|
||||
self.base_domain
|
||||
);
|
||||
}
|
||||
domain = crate::unicode_madness::validate_and_normalize_domain(&domain)
|
||||
.expect("Resulting domain is not valid");
|
||||
let (send, recv) = mpsc::unbounded_channel();
|
||||
lock.insert(domain.clone(), send);
|
||||
RoutingHandle {
|
||||
recv,
|
||||
domain,
|
||||
parent: self,
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
pub struct RoutingHandle<'a> {
|
||||
recv: mpsc::UnboundedReceiver<RouterRequest>,
|
||||
domain: String,
|
||||
parent: &'a RoutingTable,
|
||||
}
|
||||
|
||||
impl RoutingHandle<'_> {
|
||||
pub async fn next(&mut self) -> Option<RouterRequest> {
|
||||
self.recv.recv().await
|
||||
}
|
||||
|
||||
pub fn domain(&self) -> &str {
|
||||
&self.domain
|
||||
}
|
||||
}
|
||||
|
||||
impl Drop for RoutingHandle<'_> {
|
||||
fn drop(&mut self) {
|
||||
info!("Removing stale entry for {}", self.domain);
|
||||
self.parent.table.write().remove(&self.domain);
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,13 @@
|
||||
{
|
||||
"version": {
|
||||
"name": "e4mc",
|
||||
"protocol": -1
|
||||
},
|
||||
"players": {
|
||||
"max": 0,
|
||||
"online": 0
|
||||
},
|
||||
"description": {
|
||||
"text": "Unknown server. Check address and try again."
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,16 @@
|
||||
pub fn validate_and_normalize_domain(domain: &str) -> Option<String> {
|
||||
// yes, this madness is how you actually validate domains
|
||||
// https://url.spec.whatwg.org/#host-writing
|
||||
// I don't do any more normalisation because domain_to_ascii already does nameprep
|
||||
match idna::domain_to_ascii_strict(domain) {
|
||||
Ok(domain) => {
|
||||
let (domain, err) = idna::domain_to_unicode(&domain);
|
||||
if err.is_err() {
|
||||
None
|
||||
} else {
|
||||
Some(domain)
|
||||
}
|
||||
}
|
||||
Err(_) => None,
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,213 @@
|
||||
pub const ID_WORDS: [&str; 2048] = [
|
||||
"abandon", "ability", "able", "about", "above", "absent", "absorb", "abstract", "absurd",
|
||||
"abuse", "access", "accident", "account", "accuse", "achieve", "acid", "acoustic", "acquire",
|
||||
"across", "act", "action", "actor", "actress", "actual", "adapt", "add", "addict", "address",
|
||||
"adjust", "admit", "adult", "advance", "advice", "aerobic", "affair", "afford", "afraid",
|
||||
"again", "age", "agent", "agree", "ahead", "aim", "air", "airport", "aisle", "alarm", "album",
|
||||
"alcohol", "alert", "alien", "all", "alley", "allow", "almost", "alone", "alpha", "already",
|
||||
"also", "alter", "always", "amateur", "amazing", "among", "amount", "amused", "analyst",
|
||||
"anchor", "ancient", "anger", "angle", "angry", "animal", "ankle", "announce", "annual",
|
||||
"another", "answer", "antenna", "antique", "anxiety", "any", "apart", "apology", "appear",
|
||||
"apple", "approve", "april", "arch", "arctic", "area", "arena", "argue", "arm", "armed",
|
||||
"armor", "army", "around", "arrange", "arrest", "arrive", "arrow", "art", "artefact", "artist",
|
||||
"artwork", "ask", "aspect", "assault", "asset", "assist", "assume", "asthma", "athlete",
|
||||
"atom", "attack", "attend", "attitude", "attract", "auction", "audit", "august", "aunt",
|
||||
"author", "auto", "autumn", "average", "avocado", "avoid", "awake", "aware", "away", "awesome",
|
||||
"awful", "awkward", "axis", "baby", "bachelor", "bacon", "badge", "bag", "balance", "balcony",
|
||||
"ball", "bamboo", "banana", "banner", "bar", "barely", "bargain", "barrel", "base", "basic",
|
||||
"basket", "battle", "beach", "bean", "beauty", "because", "become", "beef", "before", "begin",
|
||||
"behave", "behind", "believe", "below", "belt", "bench", "benefit", "best", "betray", "better",
|
||||
"between", "beyond", "bicycle", "bid", "bike", "bind", "biology", "bird", "birth", "bitter",
|
||||
"black", "blade", "blame", "blanket", "blast", "bleak", "bless", "blind", "blood", "blossom",
|
||||
"blouse", "blue", "blur", "blush", "board", "boat", "body", "boil", "bomb", "bone", "bonus",
|
||||
"book", "boost", "border", "boring", "borrow", "boss", "bottom", "bounce", "box", "boy",
|
||||
"bracket", "brain", "brand", "brass", "brave", "bread", "breeze", "brick", "bridge", "brief",
|
||||
"bright", "bring", "brisk", "broccoli", "broken", "bronze", "broom", "brother", "brown",
|
||||
"brush", "bubble", "buddy", "budget", "buffalo", "build", "bulb", "bulk", "bullet", "bundle",
|
||||
"bunker", "burden", "burger", "burst", "bus", "business", "busy", "butter", "buyer", "buzz",
|
||||
"cabbage", "cabin", "cable", "cactus", "cage", "cake", "call", "calm", "camera", "camp", "can",
|
||||
"canal", "cancel", "candy", "cannon", "canoe", "canvas", "canyon", "capable", "capital",
|
||||
"captain", "car", "carbon", "card", "cargo", "carpet", "carry", "cart", "case", "cash",
|
||||
"casino", "castle", "casual", "cat", "catalog", "catch", "category", "cattle", "caught",
|
||||
"cause", "caution", "cave", "ceiling", "celery", "cement", "census", "century", "cereal",
|
||||
"certain", "chair", "chalk", "champion", "change", "chaos", "chapter", "charge", "chase",
|
||||
"chat", "cheap", "check", "cheese", "chef", "cherry", "chest", "chicken", "chief", "child",
|
||||
"chimney", "choice", "choose", "chronic", "chuckle", "chunk", "churn", "cigar", "cinnamon",
|
||||
"circle", "citizen", "city", "civil", "claim", "clap", "clarify", "claw", "clay", "clean",
|
||||
"clerk", "clever", "click", "client", "cliff", "climb", "clinic", "clip", "clock", "clog",
|
||||
"close", "cloth", "cloud", "clown", "club", "clump", "cluster", "clutch", "coach", "coast",
|
||||
"coconut", "code", "coffee", "coil", "coin", "collect", "color", "column", "combine", "come",
|
||||
"comfort", "comic", "common", "company", "concert", "conduct", "confirm", "congress",
|
||||
"connect", "consider", "control", "convince", "cook", "cool", "copper", "copy", "coral",
|
||||
"core", "corn", "correct", "cost", "cotton", "couch", "country", "couple", "course", "cousin",
|
||||
"cover", "coyote", "crack", "cradle", "craft", "cram", "crane", "crash", "crater", "crawl",
|
||||
"crazy", "cream", "credit", "creek", "crew", "cricket", "crime", "crisp", "critic", "crop",
|
||||
"cross", "crouch", "crowd", "crucial", "cruel", "cruise", "crumble", "crunch", "crush", "cry",
|
||||
"crystal", "cube", "culture", "cup", "cupboard", "curious", "current", "curtain", "curve",
|
||||
"cushion", "custom", "cute", "cycle", "dad", "damage", "damp", "dance", "danger", "daring",
|
||||
"dash", "daughter", "dawn", "day", "deal", "debate", "debris", "decade", "december", "decide",
|
||||
"decline", "decorate", "decrease", "deer", "defense", "define", "defy", "degree", "delay",
|
||||
"deliver", "demand", "demise", "denial", "dentist", "deny", "depart", "depend", "deposit",
|
||||
"depth", "deputy", "derive", "describe", "desert", "design", "desk", "despair", "destroy",
|
||||
"detail", "detect", "develop", "device", "devote", "diagram", "dial", "diamond", "diary",
|
||||
"dice", "diesel", "diet", "differ", "digital", "dignity", "dilemma", "dinner", "dinosaur",
|
||||
"direct", "dirt", "disagree", "discover", "disease", "dish", "dismiss", "disorder", "display",
|
||||
"distance", "divert", "divide", "divorce", "dizzy", "doctor", "document", "dog", "doll",
|
||||
"dolphin", "domain", "donate", "donkey", "donor", "door", "dose", "double", "dove", "draft",
|
||||
"dragon", "drama", "drastic", "draw", "dream", "dress", "drift", "drill", "drink", "drip",
|
||||
"drive", "drop", "drum", "dry", "duck", "dumb", "dune", "during", "dust", "dutch", "duty",
|
||||
"dwarf", "dynamic", "eager", "eagle", "early", "earn", "earth", "easily", "east", "easy",
|
||||
"echo", "ecology", "economy", "edge", "edit", "educate", "effort", "egg", "eight", "either",
|
||||
"elbow", "elder", "electric", "elegant", "element", "elephant", "elevator", "elite", "else",
|
||||
"embark", "embody", "embrace", "emerge", "emotion", "employ", "empower", "empty", "enable",
|
||||
"enact", "end", "endless", "endorse", "enemy", "energy", "enforce", "engage", "engine",
|
||||
"enhance", "enjoy", "enlist", "enough", "enrich", "enroll", "ensure", "enter", "entire",
|
||||
"entry", "envelope", "episode", "equal", "equip", "era", "erase", "erode", "erosion", "error",
|
||||
"erupt", "escape", "essay", "essence", "estate", "eternal", "ethics", "evidence", "evil",
|
||||
"evoke", "evolve", "exact", "example", "excess", "exchange", "excite", "exclude", "excuse",
|
||||
"execute", "exercise", "exhaust", "exhibit", "exile", "exist", "exit", "exotic", "expand",
|
||||
"expect", "expire", "explain", "expose", "express", "extend", "extra", "eye", "eyebrow",
|
||||
"fabric", "face", "faculty", "fade", "faint", "faith", "fall", "false", "fame", "family",
|
||||
"famous", "fan", "fancy", "fantasy", "farm", "fashion", "fat", "fatal", "father", "fatigue",
|
||||
"fault", "favorite", "feature", "february", "federal", "fee", "feed", "feel", "female",
|
||||
"fence", "festival", "fetch", "fever", "few", "fiber", "fiction", "field", "figure", "file",
|
||||
"film", "filter", "final", "find", "fine", "finger", "finish", "fire", "firm", "first",
|
||||
"fiscal", "fish", "fit", "fitness", "fix", "flag", "flame", "flash", "flat", "flavor", "flee",
|
||||
"flight", "flip", "float", "flock", "floor", "flower", "fluid", "flush", "fly", "foam",
|
||||
"focus", "fog", "foil", "fold", "follow", "food", "foot", "force", "forest", "forget", "fork",
|
||||
"fortune", "forum", "forward", "fossil", "foster", "found", "fox", "fragile", "frame",
|
||||
"frequent", "fresh", "friend", "fringe", "frog", "front", "frost", "frown", "frozen", "fruit",
|
||||
"fuel", "fun", "funny", "furnace", "fury", "future", "gadget", "gain", "galaxy", "gallery",
|
||||
"game", "gap", "garage", "garbage", "garden", "garlic", "garment", "gas", "gasp", "gate",
|
||||
"gather", "gauge", "gaze", "general", "genius", "genre", "gentle", "genuine", "gesture",
|
||||
"ghost", "giant", "gift", "giggle", "ginger", "giraffe", "girl", "give", "glad", "glance",
|
||||
"glare", "glass", "glide", "glimpse", "globe", "gloom", "glory", "glove", "glow", "glue",
|
||||
"goat", "goddess", "gold", "good", "goose", "gorilla", "gospel", "gossip", "govern", "gown",
|
||||
"grab", "grace", "grain", "grant", "grape", "grass", "gravity", "great", "green", "grid",
|
||||
"grief", "grit", "grocery", "group", "grow", "grunt", "guard", "guess", "guide", "guilt",
|
||||
"guitar", "gun", "gym", "habit", "hair", "half", "hammer", "hamster", "hand", "happy",
|
||||
"harbor", "hard", "harsh", "harvest", "hat", "have", "hawk", "hazard", "head", "health",
|
||||
"heart", "heavy", "hedgehog", "height", "hello", "helmet", "help", "hen", "hero", "hidden",
|
||||
"high", "hill", "hint", "hip", "hire", "history", "hobby", "hockey", "hold", "hole", "holiday",
|
||||
"hollow", "home", "honey", "hood", "hope", "horn", "horror", "horse", "hospital", "host",
|
||||
"hotel", "hour", "hover", "hub", "huge", "human", "humble", "humor", "hundred", "hungry",
|
||||
"hunt", "hurdle", "hurry", "hurt", "husband", "hybrid", "ice", "icon", "idea", "identify",
|
||||
"idle", "ignore", "ill", "illegal", "illness", "image", "imitate", "immense", "immune",
|
||||
"impact", "impose", "improve", "impulse", "inch", "include", "income", "increase", "index",
|
||||
"indicate", "indoor", "industry", "infant", "inflict", "inform", "inhale", "inherit",
|
||||
"initial", "inject", "injury", "inmate", "inner", "innocent", "input", "inquiry", "insane",
|
||||
"insect", "inside", "inspire", "install", "intact", "interest", "into", "invest", "invite",
|
||||
"involve", "iron", "island", "isolate", "issue", "item", "ivory", "jacket", "jaguar", "jar",
|
||||
"jazz", "jealous", "jeans", "jelly", "jewel", "job", "join", "joke", "journey", "joy", "judge",
|
||||
"juice", "jump", "jungle", "junior", "junk", "just", "kangaroo", "keen", "keep", "ketchup",
|
||||
"key", "kick", "kid", "kidney", "kind", "kingdom", "kiss", "kit", "kitchen", "kite", "kitten",
|
||||
"kiwi", "knee", "knife", "knock", "know", "lab", "label", "labor", "ladder", "lady", "lake",
|
||||
"lamp", "language", "laptop", "large", "later", "latin", "laugh", "laundry", "lava", "law",
|
||||
"lawn", "lawsuit", "layer", "lazy", "leader", "leaf", "learn", "leave", "lecture", "left",
|
||||
"leg", "legal", "legend", "leisure", "lemon", "lend", "length", "lens", "leopard", "lesson",
|
||||
"letter", "level", "liar", "liberty", "library", "license", "life", "lift", "light", "like",
|
||||
"limb", "limit", "link", "lion", "liquid", "list", "little", "live", "lizard", "load", "loan",
|
||||
"lobster", "local", "lock", "logic", "lonely", "long", "loop", "lottery", "loud", "lounge",
|
||||
"love", "loyal", "lucky", "luggage", "lumber", "lunar", "lunch", "luxury", "lyrics", "machine",
|
||||
"mad", "magic", "magnet", "maid", "mail", "main", "major", "make", "mammal", "man", "manage",
|
||||
"mandate", "mango", "mansion", "manual", "maple", "marble", "march", "margin", "marine",
|
||||
"market", "marriage", "mask", "mass", "master", "match", "material", "math", "matrix",
|
||||
"matter", "maximum", "maze", "meadow", "mean", "measure", "meat", "mechanic", "medal", "media",
|
||||
"melody", "melt", "member", "memory", "mention", "menu", "mercy", "merge", "merit", "merry",
|
||||
"mesh", "message", "metal", "method", "middle", "midnight", "milk", "million", "mimic", "mind",
|
||||
"minimum", "minor", "minute", "miracle", "mirror", "misery", "miss", "mistake", "mix", "mixed",
|
||||
"mixture", "mobile", "model", "modify", "mom", "moment", "monitor", "monkey", "monster",
|
||||
"month", "moon", "moral", "more", "morning", "mosquito", "mother", "motion", "motor",
|
||||
"mountain", "mouse", "move", "movie", "much", "muffin", "mule", "multiply", "muscle", "museum",
|
||||
"mushroom", "music", "must", "mutual", "myself", "mystery", "myth", "naive", "name", "napkin",
|
||||
"narrow", "nasty", "nation", "nature", "near", "neck", "need", "negative", "neglect",
|
||||
"neither", "nephew", "nerve", "nest", "net", "network", "neutral", "never", "news", "next",
|
||||
"nice", "night", "noble", "noise", "nominee", "noodle", "normal", "north", "nose", "notable",
|
||||
"note", "nothing", "notice", "novel", "now", "nuclear", "number", "nurse", "nut", "oak",
|
||||
"obey", "object", "oblige", "obscure", "observe", "obtain", "obvious", "occur", "ocean",
|
||||
"october", "odor", "off", "offer", "office", "often", "oil", "okay", "old", "olive", "olympic",
|
||||
"omit", "once", "one", "onion", "online", "only", "open", "opera", "opinion", "oppose",
|
||||
"option", "orange", "orbit", "orchard", "order", "ordinary", "organ", "orient", "original",
|
||||
"orphan", "ostrich", "other", "outdoor", "outer", "output", "outside", "oval", "oven", "over",
|
||||
"own", "owner", "oxygen", "oyster", "ozone", "pact", "paddle", "page", "pair", "palace",
|
||||
"palm", "panda", "panel", "panic", "panther", "paper", "parade", "parent", "park", "parrot",
|
||||
"party", "pass", "patch", "path", "patient", "patrol", "pattern", "pause", "pave", "payment",
|
||||
"peace", "peanut", "pear", "peasant", "pelican", "pen", "penalty", "pencil", "people",
|
||||
"pepper", "perfect", "permit", "person", "pet", "phone", "photo", "phrase", "physical",
|
||||
"piano", "picnic", "picture", "piece", "pig", "pigeon", "pill", "pilot", "pink", "pioneer",
|
||||
"pipe", "pistol", "pitch", "pizza", "place", "planet", "plastic", "plate", "play", "please",
|
||||
"pledge", "pluck", "plug", "plunge", "poem", "poet", "point", "polar", "pole", "police",
|
||||
"pond", "pony", "pool", "popular", "portion", "position", "possible", "post", "potato",
|
||||
"pottery", "poverty", "powder", "power", "practice", "praise", "predict", "prefer", "prepare",
|
||||
"present", "pretty", "prevent", "price", "pride", "primary", "print", "priority", "prison",
|
||||
"private", "prize", "problem", "process", "produce", "profit", "program", "project", "promote",
|
||||
"proof", "property", "prosper", "protect", "proud", "provide", "public", "pudding", "pull",
|
||||
"pulp", "pulse", "pumpkin", "punch", "pupil", "puppy", "purchase", "purity", "purpose",
|
||||
"purse", "push", "put", "puzzle", "pyramid", "quality", "quantum", "quarter", "question",
|
||||
"quick", "quit", "quiz", "quote", "rabbit", "raccoon", "race", "rack", "radar", "radio",
|
||||
"rail", "rain", "raise", "rally", "ramp", "ranch", "random", "range", "rapid", "rare", "rate",
|
||||
"rather", "raven", "raw", "razor", "ready", "real", "reason", "rebel", "rebuild", "recall",
|
||||
"receive", "recipe", "record", "recycle", "reduce", "reflect", "reform", "refuse", "region",
|
||||
"regret", "regular", "reject", "relax", "release", "relief", "rely", "remain", "remember",
|
||||
"remind", "remove", "render", "renew", "rent", "reopen", "repair", "repeat", "replace",
|
||||
"report", "require", "rescue", "resemble", "resist", "resource", "response", "result",
|
||||
"retire", "retreat", "return", "reunion", "reveal", "review", "reward", "rhythm", "rib",
|
||||
"ribbon", "rice", "rich", "ride", "ridge", "rifle", "right", "rigid", "ring", "riot", "ripple",
|
||||
"risk", "ritual", "rival", "river", "road", "roast", "robot", "robust", "rocket", "romance",
|
||||
"roof", "rookie", "room", "rose", "rotate", "rough", "round", "route", "royal", "rubber",
|
||||
"rude", "rug", "rule", "run", "runway", "rural", "sad", "saddle", "sadness", "safe", "sail",
|
||||
"salad", "salmon", "salon", "salt", "salute", "same", "sample", "sand", "satisfy", "satoshi",
|
||||
"sauce", "sausage", "save", "say", "scale", "scan", "scare", "scatter", "scene", "scheme",
|
||||
"school", "science", "scissors", "scorpion", "scout", "scrap", "screen", "script", "scrub",
|
||||
"sea", "search", "season", "seat", "second", "secret", "section", "security", "seed", "seek",
|
||||
"segment", "select", "sell", "seminar", "senior", "sense", "sentence", "series", "service",
|
||||
"session", "settle", "setup", "seven", "shadow", "shaft", "shallow", "share", "shed", "shell",
|
||||
"sheriff", "shield", "shift", "shine", "ship", "shiver", "shock", "shoe", "shoot", "shop",
|
||||
"short", "shoulder", "shove", "shrimp", "shrug", "shuffle", "shy", "sibling", "sick", "side",
|
||||
"siege", "sight", "sign", "silent", "silk", "silly", "silver", "similar", "simple", "since",
|
||||
"sing", "siren", "sister", "situate", "six", "size", "skate", "sketch", "ski", "skill", "skin",
|
||||
"skirt", "skull", "slab", "slam", "sleep", "slender", "slice", "slide", "slight", "slim",
|
||||
"slogan", "slot", "slow", "slush", "small", "smart", "smile", "smoke", "smooth", "snack",
|
||||
"snake", "snap", "sniff", "snow", "soap", "soccer", "social", "sock", "soda", "soft", "solar",
|
||||
"soldier", "solid", "solution", "solve", "someone", "song", "soon", "sorry", "sort", "soul",
|
||||
"sound", "soup", "source", "south", "space", "spare", "spatial", "spawn", "speak", "special",
|
||||
"speed", "spell", "spend", "sphere", "spice", "spider", "spike", "spin", "spirit", "split",
|
||||
"spoil", "sponsor", "spoon", "sport", "spot", "spray", "spread", "spring", "spy", "square",
|
||||
"squeeze", "squirrel", "stable", "stadium", "staff", "stage", "stairs", "stamp", "stand",
|
||||
"start", "state", "stay", "steak", "steel", "stem", "step", "stereo", "stick", "still",
|
||||
"sting", "stock", "stomach", "stone", "stool", "story", "stove", "strategy", "street",
|
||||
"strike", "strong", "struggle", "student", "stuff", "stumble", "style", "subject", "submit",
|
||||
"subway", "success", "such", "sudden", "suffer", "sugar", "suggest", "suit", "summer", "sun",
|
||||
"sunny", "sunset", "super", "supply", "supreme", "sure", "surface", "surge", "surprise",
|
||||
"surround", "survey", "suspect", "sustain", "swallow", "swamp", "swap", "swarm", "swear",
|
||||
"sweet", "swift", "swim", "swing", "switch", "sword", "symbol", "symptom", "syrup", "system",
|
||||
"table", "tackle", "tag", "tail", "talent", "talk", "tank", "tape", "target", "task", "taste",
|
||||
"tattoo", "taxi", "teach", "team", "tell", "ten", "tenant", "tennis", "tent", "term", "test",
|
||||
"text", "thank", "that", "theme", "then", "theory", "there", "they", "thing", "this",
|
||||
"thought", "three", "thrive", "throw", "thumb", "thunder", "ticket", "tide", "tiger", "tilt",
|
||||
"timber", "time", "tiny", "tip", "tired", "tissue", "title", "toast", "tobacco", "today",
|
||||
"toddler", "toe", "together", "toilet", "token", "tomato", "tomorrow", "tone", "tongue",
|
||||
"tonight", "tool", "tooth", "top", "topic", "topple", "torch", "tornado", "tortoise", "toss",
|
||||
"total", "tourist", "toward", "tower", "town", "toy", "track", "trade", "traffic", "tragic",
|
||||
"train", "transfer", "trap", "trash", "travel", "tray", "treat", "tree", "trend", "trial",
|
||||
"tribe", "trick", "trigger", "trim", "trip", "trophy", "trouble", "truck", "true", "truly",
|
||||
"trumpet", "trust", "truth", "try", "tube", "tuition", "tumble", "tuna", "tunnel", "turkey",
|
||||
"turn", "turtle", "twelve", "twenty", "twice", "twin", "twist", "two", "type", "typical",
|
||||
"ugly", "umbrella", "unable", "unaware", "uncle", "uncover", "under", "undo", "unfair",
|
||||
"unfold", "unhappy", "uniform", "unique", "unit", "universe", "unknown", "unlock", "until",
|
||||
"unusual", "unveil", "update", "upgrade", "uphold", "upon", "upper", "upset", "urban", "urge",
|
||||
"usage", "use", "used", "useful", "useless", "usual", "utility", "vacant", "vacuum", "vague",
|
||||
"valid", "valley", "valve", "van", "vanish", "vapor", "various", "vast", "vault", "vehicle",
|
||||
"velvet", "vendor", "venture", "venue", "verb", "verify", "version", "very", "vessel",
|
||||
"veteran", "viable", "vibrant", "vicious", "victory", "video", "view", "village", "vintage",
|
||||
"violin", "virtual", "virus", "visa", "visit", "visual", "vital", "vivid", "vocal", "voice",
|
||||
"void", "volcano", "volume", "vote", "voyage", "wage", "wagon", "wait", "walk", "wall",
|
||||
"walnut", "want", "warfare", "warm", "warrior", "wash", "wasp", "waste", "water", "wave",
|
||||
"way", "wealth", "weapon", "wear", "weasel", "weather", "web", "wedding", "weekend", "weird",
|
||||
"welcome", "west", "wet", "whale", "what", "wheat", "wheel", "when", "where", "whip",
|
||||
"whisper", "wide", "width", "wife", "wild", "will", "win", "window", "wine", "wing", "wink",
|
||||
"winner", "winter", "wire", "wisdom", "wise", "wish", "witness", "wolf", "woman", "wonder",
|
||||
"wood", "wool", "word", "work", "world", "worry", "worth", "wrap", "wreck", "wrestle", "wrist",
|
||||
"write", "wrong", "yard", "year", "yellow", "you", "young", "youth", "zebra", "zero", "zone",
|
||||
"zoo",
|
||||
];
|
||||
Loading…
Reference in new issue