From 34f33ff038a469dca0a56d64ee56d2069cf20d15 Mon Sep 17 00:00:00 2001 From: Joscha Date: Sun, 14 May 2023 14:44:49 +0200 Subject: [PATCH] Rename Snapshot to ConnSnapshot --- CHANGELOG.md | 1 + examples/testbot_instance.rs | 4 ++-- examples/testbot_instances.rs | 4 ++-- src/bot/commands.rs | 4 ++-- src/bot/instance.rs | 15 +++++++++------ 5 files changed, 16 insertions(+), 12 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 83728c3..68a21f0 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -24,6 +24,7 @@ Procedure when bumping the version number: - **(breaking)** `bot::command::ClapCommand::execute` now returns a `Result` instead of a `Result<(), E>` - **(breaking)** `bot::command::Command::execute` now returns a `Result` instead of a `Result<(), E>` - **(breaking)** `bot::commands::Commands::handle_packet` now returns a `Result` instead of a `Result<(), E>` +- **(breaking)** `bot::instance::Snapshot` renamed to `ConnSnapshot` - **(breaking)** `conn::Conn::connect` now returns `conn::Result` - `bot::instance::Instance` now implements `Clone` diff --git a/examples/testbot_instance.rs b/examples/testbot_instance.rs index dd90f0e..5b932b3 100644 --- a/examples/testbot_instance.rs +++ b/examples/testbot_instance.rs @@ -3,7 +3,7 @@ use euphoxide::api::packet::ParsedPacket; use euphoxide::api::{Data, Nick, Send}; -use euphoxide::bot::instance::{Event, ServerConfig, Snapshot}; +use euphoxide::bot::instance::{ConnSnapshot, Event, ServerConfig}; use time::OffsetDateTime; use tokio::sync::mpsc; @@ -43,7 +43,7 @@ fn format_delta(delta: time::Duration) -> String { parts.join(" ") } -async fn on_packet(packet: ParsedPacket, snapshot: Snapshot) -> Result<(), ()> { +async fn on_packet(packet: ParsedPacket, snapshot: ConnSnapshot) -> Result<(), ()> { let data = match packet.content { Ok(data) => data, Err(err) => { diff --git a/examples/testbot_instances.rs b/examples/testbot_instances.rs index 4632597..a8a6848 100644 --- a/examples/testbot_instances.rs +++ b/examples/testbot_instances.rs @@ -3,7 +3,7 @@ use euphoxide::api::packet::ParsedPacket; use euphoxide::api::{Data, Nick, Send}; -use euphoxide::bot::instance::{Event, ServerConfig, Snapshot}; +use euphoxide::bot::instance::{ConnSnapshot, Event, ServerConfig}; use euphoxide::bot::instances::Instances; use time::OffsetDateTime; use tokio::sync::mpsc; @@ -44,7 +44,7 @@ fn format_delta(delta: time::Duration) -> String { parts.join(" ") } -async fn on_packet(packet: ParsedPacket, snapshot: Snapshot) -> Result<(), ()> { +async fn on_packet(packet: ParsedPacket, snapshot: ConnSnapshot) -> Result<(), ()> { let data = match packet.content { Ok(data) => data, Err(err) => { diff --git a/src/bot/commands.rs b/src/bot/commands.rs index e276757..a37cb5d 100644 --- a/src/bot/commands.rs +++ b/src/bot/commands.rs @@ -3,7 +3,7 @@ use crate::api::{Data, SendEvent}; use crate::conn; use super::command::{Command, Context}; -use super::instance::{InstanceConfig, Snapshot}; +use super::instance::{ConnSnapshot, InstanceConfig}; pub struct Commands { commands: Vec + Send + Sync>>, @@ -55,7 +55,7 @@ impl Commands { &self, config: &InstanceConfig, packet: &ParsedPacket, - snapshot: &Snapshot, + snapshot: &ConnSnapshot, bot: &mut B, ) -> Result { let msg = match &packet.content { diff --git a/src/bot/instance.rs b/src/bot/instance.rs index e6d2741..58b1e3e 100644 --- a/src/bot/instance.rs +++ b/src/bot/instance.rs @@ -193,12 +193,12 @@ impl InstanceConfig { /// Snapshot of a [`Conn`]'s state immediately after receiving a packet. #[derive(Debug, Clone)] -pub struct Snapshot { +pub struct ConnSnapshot { pub conn_tx: ConnTx, pub state: State, } -impl Snapshot { +impl ConnSnapshot { fn from_conn(conn: &Conn) -> Self { Self { conn_tx: conn.tx().clone(), @@ -224,8 +224,8 @@ impl Snapshot { #[derive(Debug)] pub enum Event { Connecting(InstanceConfig), - Connected(InstanceConfig, Snapshot), - Packet(InstanceConfig, ParsedPacket, Snapshot), + Connected(InstanceConfig, ConnSnapshot), + Packet(InstanceConfig, ParsedPacket, ConnSnapshot), Disconnected(InstanceConfig), Stopped(InstanceConfig), } @@ -458,7 +458,10 @@ impl Instance { .map_err(RunError::CouldNotConnect)?; Self::set_cookies(config, cookies); - on_event(Event::Connected(config.clone(), Snapshot::from_conn(&conn))); + on_event(Event::Connected( + config.clone(), + ConnSnapshot::from_conn(&conn), + )); let conn_tx = conn.tx().clone(); select! { @@ -474,7 +477,7 @@ impl Instance { ) -> Result<(), RunError> { loop { let packet = conn.recv().await.map_err(RunError::Conn)?; - let snapshot = Snapshot::from_conn(conn); + let snapshot = ConnSnapshot::from_conn(conn); match &packet.content { Ok(Data::SnapshotEvent(snapshot)) => {