Skip to content

Commit b2cf5d9

Browse files
josecelanojosecelano
committed
refactor: [#1444] rename variable
1 parent 07d1314 commit b2cf5d9

10 files changed

Lines changed: 49 additions & 45 deletions

File tree

‎packages/axum-http-tracker-server/src/server.rs‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -271,14 +271,15 @@ mod tests {
271271
let http_tracker_config = Arc::new(http_tracker_config.clone());
272272

273273
// HTTP core stats
274-
let keeper = bittorrent_http_tracker_core::statistics::setup::factory(configuration.core.tracker_usage_statistics);
275-
let http_stats_event_sender = keeper.sender();
276-
let http_stats_repository = keeper.repository();
274+
let http_core_stats_keeper =
275+
bittorrent_http_tracker_core::statistics::setup::factory(configuration.core.tracker_usage_statistics);
276+
let http_stats_event_sender = http_core_stats_keeper.sender();
277+
let http_stats_repository = http_core_stats_keeper.repository();
277278

278279
if configuration.core.tracker_usage_statistics {
279280
// todo: this should be started like the other jobs during `app::start`
280281
// and keep the join handle in a list of jobs.
281-
let _unused = keeper.run_event_listener();
282+
let _unused = http_core_stats_keeper.run_event_listener();
282283
}
283284

284285
let tracker_core_container = Arc::new(TrackerCoreContainer::initialize(&core_config));

‎packages/axum-http-tracker-server/src/v1/handlers/announce.rs‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -161,14 +161,15 @@ mod tests {
161161
));
162162

163163
// HTTP core stats
164-
let keeper = bittorrent_http_tracker_core::statistics::setup::factory(config.core.tracker_usage_statistics);
165-
let http_stats_event_sender = keeper.sender();
166-
let _http_stats_repository = keeper.repository();
164+
let http_core_stats_keeper =
165+
bittorrent_http_tracker_core::statistics::setup::factory(config.core.tracker_usage_statistics);
166+
let http_stats_event_sender = http_core_stats_keeper.sender();
167+
let _http_stats_repository = http_core_stats_keeper.repository();
167168

168169
if config.core.tracker_usage_statistics {
169170
// todo: this should be started like the other jobs during `app::start`
170171
// and keep the join handle in a list of jobs.
171-
let _unused = keeper.run_event_listener();
172+
let _unused = http_core_stats_keeper.run_event_listener();
172173
}
173174

174175
let announce_service = Arc::new(AnnounceService::new(

‎packages/axum-http-tracker-server/src/v1/handlers/scrape.rs‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -132,14 +132,15 @@ mod tests {
132132
let scrape_handler = Arc::new(ScrapeHandler::new(&whitelist_authorization, &in_memory_torrent_repository));
133133

134134
// HTTP core stats
135-
let keeper = bittorrent_http_tracker_core::statistics::setup::factory(config.core.tracker_usage_statistics);
136-
let http_stats_event_sender = keeper.sender();
137-
let _http_stats_repository = keeper.repository();
135+
let http_core_stats_keeper =
136+
bittorrent_http_tracker_core::statistics::setup::factory(config.core.tracker_usage_statistics);
137+
let http_stats_event_sender = http_core_stats_keeper.sender();
138+
let _http_stats_repository = http_core_stats_keeper.repository();
138139

139140
if config.core.tracker_usage_statistics {
140141
// todo: this should be started like the other jobs during `app::start`
141142
// and keep the join handle in a list of jobs.
142-
let _unused = keeper.run_event_listener();
143+
let _unused = http_core_stats_keeper.run_event_listener();
143144
}
144145

145146
(

‎packages/http-tracker-core/benches/helpers/util.rs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -56,14 +56,14 @@ pub fn initialize_core_tracker_services_with_config(config: &Configuration) -> (
5656
));
5757

5858
// HTTP core stats
59-
let keeper = statistics::setup::factory(config.core.tracker_usage_statistics);
60-
let http_stats_event_sender = keeper.sender();
61-
let _http_stats_repository = keeper.repository();
59+
let http_core_stats_keeper = statistics::setup::factory(config.core.tracker_usage_statistics);
60+
let http_stats_event_sender = http_core_stats_keeper.sender();
61+
let _http_stats_repository = http_core_stats_keeper.repository();
6262

6363
if config.core.tracker_usage_statistics {
6464
// todo: this should be started like the other jobs during `app::start`
6565
// and keep the join handle in a list of jobs.
66-
let _unused = keeper.run_event_listener();
66+
let _unused = http_core_stats_keeper.run_event_listener();
6767
}
6868

6969
(

‎packages/http-tracker-core/src/container.rs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -63,14 +63,14 @@ impl HttpTrackerCoreServices {
6363
#[must_use]
6464
pub fn initialize_from(tracker_core_container: &Arc<TrackerCoreContainer>) -> Arc<Self> {
6565
// HTTP core stats
66-
let keeper = statistics::setup::factory(tracker_core_container.core_config.tracker_usage_statistics);
67-
let http_stats_event_sender = keeper.sender();
68-
let http_stats_repository = keeper.repository();
66+
let http_core_stats_keeper = statistics::setup::factory(tracker_core_container.core_config.tracker_usage_statistics);
67+
let http_stats_event_sender = http_core_stats_keeper.sender();
68+
let http_stats_repository = http_core_stats_keeper.repository();
6969

7070
if tracker_core_container.core_config.tracker_usage_statistics {
7171
// todo: this should be started like the other jobs during `app::start`
7272
// and keep the join handle in a list of jobs.
73-
let _unused = keeper.run_event_listener();
73+
let _unused = http_core_stats_keeper.run_event_listener();
7474
}
7575

7676
let http_announce_service = Arc::new(AnnounceService::new(

‎packages/http-tracker-core/src/services/announce.rs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -253,14 +253,14 @@ mod tests {
253253
));
254254

255255
// HTTP core stats
256-
let keeper = statistics::setup::factory(config.core.tracker_usage_statistics);
257-
let http_stats_event_sender = keeper.sender();
258-
let _http_stats_repository = keeper.repository();
256+
let http_core_stats_keeper = statistics::setup::factory(config.core.tracker_usage_statistics);
257+
let http_stats_event_sender = http_core_stats_keeper.sender();
258+
let _http_stats_repository = http_core_stats_keeper.repository();
259259

260260
if config.core.tracker_usage_statistics {
261261
// todo: this should be started like the other jobs during `app::start`
262262
// and keep the join handle in a list of jobs.
263-
let _unused = keeper.run_event_listener();
263+
let _unused = http_core_stats_keeper.run_event_listener();
264264
}
265265

266266
(

‎packages/http-tracker-core/src/services/scrape.rs‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -273,9 +273,9 @@ mod tests {
273273
let core_config = Arc::new(configuration.core.clone());
274274

275275
// HTTP core stats
276-
let keeper = statistics::setup::factory(false);
277-
let http_stats_event_sender = keeper.sender();
278-
let _http_stats_repository = keeper.repository();
276+
let http_core_stats_keeper = statistics::setup::factory(false);
277+
let http_stats_event_sender = http_core_stats_keeper.sender();
278+
let _http_stats_repository = http_core_stats_keeper.repository();
279279

280280
let container = initialize_services_with_configuration(&configuration);
281281

@@ -465,9 +465,9 @@ mod tests {
465465
let container = initialize_services_with_configuration(&config);
466466

467467
// HTTP core stats
468-
let keeper = statistics::setup::factory(false);
469-
let http_stats_event_sender = keeper.sender();
470-
let _http_stats_repository = keeper.repository();
468+
let http_core_stats_keeper = statistics::setup::factory(false);
469+
let http_stats_event_sender = http_core_stats_keeper.sender();
470+
let _http_stats_repository = http_core_stats_keeper.repository();
471471

472472
let info_hash = sample_info_hash();
473473
let info_hashes = vec![info_hash];

‎packages/http-tracker-core/src/statistics/services.rs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -89,14 +89,14 @@ mod tests {
8989
let in_memory_torrent_repository = Arc::new(InMemoryTorrentRepository::default());
9090

9191
// HTTP core stats
92-
let keeper = statistics::setup::factory(config.core.tracker_usage_statistics);
93-
let _http_stats_event_sender = keeper.sender();
94-
let http_stats_repository = keeper.repository();
92+
let http_core_stats_keeper = statistics::setup::factory(config.core.tracker_usage_statistics);
93+
let _http_stats_event_sender = http_core_stats_keeper.sender();
94+
let http_stats_repository = http_core_stats_keeper.repository();
9595

9696
if config.core.tracker_usage_statistics {
9797
// todo: this should be started like the other jobs during `app::start`
9898
// and keep the join handle in a list of jobs.
99-
let _unused = keeper.run_event_listener();
99+
let _unused = http_core_stats_keeper.run_event_listener();
100100
}
101101

102102
let tracker_metrics = get_metrics(in_memory_torrent_repository.clone(), http_stats_repository).await;

‎packages/http-tracker-core/src/statistics/setup.rs‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -40,14 +40,14 @@ mod test {
4040
let tracker_usage_statistics = false;
4141

4242
// HTTP core stats
43-
let keeper = factory(tracker_usage_statistics);
44-
let http_stats_event_sender = keeper.sender();
45-
let _http_stats_repository = keeper.repository();
43+
let http_core_stats_keeper = factory(tracker_usage_statistics);
44+
let http_stats_event_sender = http_core_stats_keeper.sender();
45+
let _http_stats_repository = http_core_stats_keeper.repository();
4646

4747
if tracker_usage_statistics {
4848
// todo: this should be started like the other jobs during `app::start`
4949
// and keep the join handle in a list of jobs.
50-
let _unused = keeper.run_event_listener();
50+
let _unused = http_core_stats_keeper.run_event_listener();
5151
}
5252

5353
assert!(http_stats_event_sender.is_none());
@@ -58,9 +58,9 @@ mod test {
5858
let tracker_usage_statistics = true;
5959

6060
// HTTP core stats
61-
let keeper = factory(tracker_usage_statistics);
62-
let http_stats_event_sender = keeper.sender();
63-
let _http_stats_repository = keeper.repository();
61+
let http_core_stats_keeper = factory(tracker_usage_statistics);
62+
let http_stats_event_sender = http_core_stats_keeper.sender();
63+
let _http_stats_repository = http_core_stats_keeper.repository();
6464

6565
assert!(http_stats_event_sender.is_some());
6666
}

‎packages/rest-tracker-api-core/src/statistics/services.rs‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -147,14 +147,15 @@ mod tests {
147147
let ban_service = Arc::new(RwLock::new(BanService::new(MAX_CONNECTION_ID_ERRORS_PER_IP)));
148148

149149
// HTTP core stats
150-
let keeper = bittorrent_http_tracker_core::statistics::setup::factory(config.core.tracker_usage_statistics);
151-
let _http_stats_event_sender = keeper.sender();
152-
let http_stats_repository = keeper.repository();
150+
let http_core_stats_keeper =
151+
bittorrent_http_tracker_core::statistics::setup::factory(config.core.tracker_usage_statistics);
152+
let _http_stats_event_sender = http_core_stats_keeper.sender();
153+
let http_stats_repository = http_core_stats_keeper.repository();
153154

154155
if config.core.tracker_usage_statistics {
155156
// todo: this should be started like the other jobs during `app::start`
156157
// and keep the join handle in a list of jobs.
157-
let _unused = keeper.run_event_listener();
158+
let _unused = http_core_stats_keeper.run_event_listener();
158159
}
159160

160161
// UDP core stats

0 commit comments

Comments
 (0)