dev: use aquatic instead of local one

packages/primitives/src/lib.rs

@@ -7,9 +7,7 @@
 use std::collections::BTreeMap;
 use std::time::Duration;
 
-use aquatic_udp_protocol::{AnnounceEvent, NumberOfBytes};
 use info_hash::InfoHash;
-use serde::Serialize;
 
 pub mod info_hash;
 pub mod pagination;
@@ -20,48 +18,6 @@ pub mod torrent_metrics;
 /// Duration since the Unix Epoch.
 pub type DurationSinceUnixEpoch = Duration;
 
-/// Serializes a `DurationSinceUnixEpoch` as a Unix timestamp in milliseconds.
-/// # Errors
-///
-/// Will return `serde::Serializer::Error` if unable to serialize the `unix_time_value`.
-pub fn ser_unix_time_value<S: serde::Serializer>(unix_time_value: &DurationSinceUnixEpoch, ser: S) -> Result<S::Ok, S::Error> {
-    #[allow(clippy::cast_possible_truncation)]
-    ser.serialize_u64(unix_time_value.as_millis() as u64)
-}
-
-#[derive(Serialize)]
-pub enum AnnounceEventSer {
-    Started,
-    Stopped,
-    Completed,
-    None,
-}
-
-/// Serializes a `Announce Event` as a enum.
-///
-/// # Errors
-///
-/// If will return an error if the internal serializer was to fail.
-pub fn ser_announce_event<S: serde::Serializer>(announce_event: &AnnounceEvent, ser: S) -> Result<S::Ok, S::Error> {
-    let event_ser = match announce_event {
-        AnnounceEvent::Started => AnnounceEventSer::Started,
-        AnnounceEvent::Stopped => AnnounceEventSer::Stopped,
-        AnnounceEvent::Completed => AnnounceEventSer::Completed,
-        AnnounceEvent::None => AnnounceEventSer::None,
-    };
-
-    ser.serialize_some(&event_ser)
-}
-
-/// Serializes a `Announce Event` as a i64.
-///
-/// # Errors
-///
-/// If will return an error if the internal serializer was to fail.
-pub fn ser_number_of_bytes<S: serde::Serializer>(number_of_bytes: &NumberOfBytes, ser: S) -> Result<S::Ok, S::Error> {
-    ser.serialize_i64(number_of_bytes.0.get())
-}
-
 /// IP version used by the peer to connect to the tracker: IPv4 or IPv6
 #[derive(PartialEq, Eq, Debug)]
 pub enum IPVersion {