From 631ed63dbdc7167df4de02a55b5c2ef1cea909e9 Mon Sep 17 00:00:00 2001 From: mat <27899617+mat-1@users.noreply.github.com> Date: Sun, 27 Nov 2022 16:25:07 -0600 Subject: Swarm (#36) * make azalea-pathfinder dir * start writing d* lite impl * more work on d* lite * work more on implementing d* lite * full d* lite impl * updated edges * add next() function * add NoPathError * why does dstar lite not work * fix d* lite implementation * make the test actually check the coords * replace while loop with if statement * fix clippy complaints * make W only have to be PartialOrd * fix PartialOrd issues * implement mtd* lite * add a test to mtd* lite * remove normal d* lite * make heuristic only take in one arg * add `success` function * Update README.md * evil black magic to make .entity not need dimension * start adding moves * slightly improve the vec3/position situation new macro that implements all the useful functions * moves stuff * make it compile * update deps in az-pathfinder * make it compile again * more pathfinding stuff * add Bot::look_at * replace EntityMut and EntityRef with just Entity * block pos pathfinding stuff * rename movedirection to walkdirection * execute path every tick * advance path * change az-pf version * make azalea_client keep plugin state * fix Plugins::get * why does it think there is air * start debugging incorrect air * update some From methods to use rem_euclid * start adding swarm * fix deadlock i still don't understand why it was happening but the solution was to keep the Client::player lock for shorter so it didn't overlap with the Client::dimension lock * make lookat actually work probably * fix going too fast * Update main.rs * make a thing immutable * direction_looking_at * fix rotations * import swarm in an example * fix stuff from merge * remove azalea_pathfinder import * delete azalea-pathfinder crate already in azalea::pathfinder module * swarms * start working on shared dimensions * Shared worlds work * start adding Swarm::add_account * add_account works * change "client" to "bot" in some places * Fix issues from merge * Update world.rs * add SwarmEvent::Disconnect(Account) * almost add SwarmEvent::Chat and new plugin system it panics rn * make plugins have to provide the State associated type * improve comments * make fn build slightly cleaner * fix SwarmEvent::Chat * change a println in bot/main.rs * Client::shutdown -> disconnect * polish fix clippy warnings + improve some docs a bit * fix shared worlds* *there's a bug that entities and bots will have their positions exaggerated because the relative movement packet is applied for every entity once per bot * i am being trolled by rust for some reason some stuff is really slow for literally no reason and it makes no sense i am going insane * make world an RwLock again * remove debug messages * fix skipping event ticks unfortunately now sending events is `.send().await?` instead of just `.send()` * fix deadlock + warnings * turns out my floor_mod impl was wrong and i32::rem_euclid has the correct behavior LOL * still errors with lots of bots * make swarm iter & fix new chunks not loading * improve docs * start fixing tests * fix all the tests except the examples i don't know how to exclude them from the tests * improve docs some more --- azalea-protocol/src/connect.rs | 73 +++++++++++++++++++++++++++++++++--------- 1 file changed, 57 insertions(+), 16 deletions(-) (limited to 'azalea-protocol/src/connect.rs') diff --git a/azalea-protocol/src/connect.rs b/azalea-protocol/src/connect.rs index 00685d3c..567e4c40 100755 --- a/azalea-protocol/src/connect.rs +++ b/azalea-protocol/src/connect.rs @@ -44,8 +44,22 @@ pub struct WriteConnection { /// /// Join an offline-mode server and go through the handshake. /// ```rust,no_run +/// use azalea_protocol::{ +/// resolver, +/// connect::Connection, +/// packets::{ +/// ConnectionProtocol, PROTOCOL_VERSION, +/// login::{ +/// ClientboundLoginPacket, +/// serverbound_hello_packet::ServerboundHelloPacket, +/// serverbound_key_packet::{ServerboundKeyPacket, NonceOrSaltSignature} +/// }, +/// handshake::client_intention_packet::ClientIntentionPacket +/// } +/// }; +/// /// #[tokio::main] -/// async fn main() -> anyhow::Result<()> { +/// async fn main() -> Result<(), Box> { /// let resolved_address = resolver::resolve_address(&"localhost".try_into().unwrap()).await?; /// let mut conn = Connection::new(&resolved_address).await?; /// @@ -97,8 +111,8 @@ pub struct WriteConnection { /// break (conn.game(), p.game_profile); /// } /// ClientboundLoginPacket::LoginDisconnect(p) => { -/// println!("login disconnect: {}", p.reason); -/// bail!("{}", p.reason); +/// eprintln!("login disconnect: {}", p.reason); +/// return Err("login disconnect".into()); /// } /// ClientboundLoginPacket::CustomQuery(p) => {} /// } @@ -258,24 +272,51 @@ impl Connection { /// # Examples /// /// ```rust,no_run - /// let token = azalea_auth::auth(azalea_auth::AuthOpts { - /// ..Default::default() - /// }) - /// .await; - /// let player_data = azalea_auth::get_profile(token).await; + /// use azalea_auth::AuthResult; + /// use azalea_protocol::connect::Connection; + /// use azalea_protocol::packets::login::{ + /// ClientboundLoginPacket, + /// serverbound_key_packet::{ServerboundKeyPacket, NonceOrSaltSignature} + /// }; + /// use uuid::Uuid; + /// # use azalea_protocol::ServerAddress; + /// + /// # async fn example() -> Result<(), Box> { + /// let AuthResult { access_token, profile } = azalea_auth::auth( + /// "example@example.com", + /// azalea_auth::AuthOpts::default() + /// ).await.expect("Couldn't authenticate"); + /// # + /// # let address = ServerAddress::try_from("example@example.com").unwrap(); + /// # let resolved_address = azalea_protocol::resolver::resolve_address(&address).await?; /// - /// let mut connection = azalea::Connection::new(&server_address).await?; + /// let mut conn = Connection::new(&resolved_address).await?; /// /// // transition to the login state, in a real program we would have done a handshake first - /// connection.login(); + /// let mut conn = conn.login(); /// - /// match connection.read().await? { - /// ClientboundLoginPacket::Hello(p) => { - /// // tell Mojang we're joining the server - /// connection.authenticate(&token, player_data.uuid, p).await?; - /// } - /// _ => {} + /// match conn.read().await? { + /// ClientboundLoginPacket::Hello(p) => { + /// // tell Mojang we're joining the server & enable encryption + /// let e = azalea_crypto::encrypt(&p.public_key, &p.nonce).unwrap(); + /// conn.authenticate( + /// &access_token, + /// &Uuid::parse_str(&profile.id).expect("Invalid UUID"), + /// e.secret_key, + /// p + /// ).await?; + /// conn.write( + /// ServerboundKeyPacket { + /// nonce_or_salt_signature: NonceOrSaltSignature::Nonce(e.encrypted_nonce), + /// key_bytes: e.encrypted_public_key, + /// }.get() + /// ).await?; + /// conn.set_encryption_key(e.secret_key); + /// } + /// _ => {} /// } + /// # Ok(()) + /// # } /// ``` pub async fn authenticate( &self, -- cgit v1.2.3