Skip to content

Commit d98d93f

Browse files
committed
refactor: [#1485] simplify event mods in pakages using the events pkg
1 parent 97eb20a commit d98d93f

File tree

12 files changed

+63
-48
lines changed

12 files changed

+63
-48
lines changed

packages/http-tracker-core/src/event/mod.rs renamed to packages/http-tracker-core/src/event.rs

Lines changed: 21 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,3 @@
1-
pub mod bus;
2-
pub mod receiver;
3-
pub mod sender;
4-
51
use std::net::{IpAddr, SocketAddr};
62

73
use bittorrent_http_tracker_protocol::v1::services::peer_ip_resolver::RemoteClientAddr;
@@ -98,6 +94,27 @@ impl From<ConnectionContext> for LabelSet {
9894
}
9995
}
10096

97+
pub mod sender {
98+
use std::sync::Arc;
99+
100+
use super::Event;
101+
102+
pub type Sender = Option<Arc<dyn torrust_tracker_events::sender::Sender<Event = Event>>>;
103+
pub type Broadcaster = torrust_tracker_events::broadcaster::Broadcaster<Event>;
104+
}
105+
106+
pub mod receiver {
107+
use super::Event;
108+
109+
pub type Receiver = Box<dyn torrust_tracker_events::receiver::Receiver<Event = Event>>;
110+
}
111+
112+
pub mod bus {
113+
use crate::event::Event;
114+
115+
pub type EventBus = torrust_tracker_events::bus::EventBus<Event>;
116+
}
117+
101118
#[cfg(test)]
102119
pub mod test {
103120

packages/http-tracker-core/src/event/bus.rs

Lines changed: 0 additions & 3 deletions
This file was deleted.

packages/http-tracker-core/src/event/receiver.rs

Lines changed: 0 additions & 3 deletions
This file was deleted.

packages/http-tracker-core/src/event/sender.rs

Lines changed: 0 additions & 6 deletions
This file was deleted.

packages/udp-tracker-core/src/event/mod.rs renamed to packages/udp-tracker-core/src/event.rs

Lines changed: 21 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,3 @@
1-
pub mod bus;
2-
pub mod receiver;
3-
pub mod sender;
4-
51
use std::net::SocketAddr;
62

73
use bittorrent_primitives::info_hash::InfoHash;
@@ -70,3 +66,24 @@ impl From<ConnectionContext> for LabelSet {
7066
])
7167
}
7268
}
69+
70+
pub mod sender {
71+
use std::sync::Arc;
72+
73+
use super::Event;
74+
75+
pub type Sender = Option<Arc<dyn torrust_tracker_events::sender::Sender<Event = Event>>>;
76+
pub type Broadcaster = torrust_tracker_events::broadcaster::Broadcaster<Event>;
77+
}
78+
79+
pub mod receiver {
80+
use super::Event;
81+
82+
pub type Receiver = Box<dyn torrust_tracker_events::receiver::Receiver<Event = Event>>;
83+
}
84+
85+
pub mod bus {
86+
use crate::event::Event;
87+
88+
pub type EventBus = torrust_tracker_events::bus::EventBus<Event>;
89+
}

packages/udp-tracker-core/src/event/bus.rs

Lines changed: 0 additions & 3 deletions
This file was deleted.

packages/udp-tracker-core/src/event/receiver.rs

Lines changed: 0 additions & 3 deletions
This file was deleted.

packages/udp-tracker-core/src/event/sender.rs

Lines changed: 0 additions & 6 deletions
This file was deleted.

packages/udp-tracker-server/src/event/mod.rs renamed to packages/udp-tracker-server/src/event.rs

Lines changed: 21 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,3 @@
1-
pub mod bus;
2-
pub mod receiver;
3-
pub mod sender;
4-
51
use std::fmt;
62
use std::net::SocketAddr;
73
use std::time::Duration;
@@ -112,3 +108,24 @@ impl From<ConnectionContext> for LabelSet {
112108
])
113109
}
114110
}
111+
112+
pub mod sender {
113+
use std::sync::Arc;
114+
115+
use super::Event;
116+
117+
pub type Sender = Option<Arc<dyn torrust_tracker_events::sender::Sender<Event = Event>>>;
118+
pub type Broadcaster = torrust_tracker_events::broadcaster::Broadcaster<Event>;
119+
}
120+
121+
pub mod receiver {
122+
use super::Event;
123+
124+
pub type Receiver = Box<dyn torrust_tracker_events::receiver::Receiver<Event = Event>>;
125+
}
126+
127+
pub mod bus {
128+
use crate::event::Event;
129+
130+
pub type EventBus = torrust_tracker_events::bus::EventBus<Event>;
131+
}

packages/udp-tracker-server/src/event/bus.rs

Lines changed: 0 additions & 3 deletions
This file was deleted.

0 commit comments

Comments
 (0)