cafkafk/nix-weather
cafkafk/nix-weather
1
1
Fork 0
Code Issues 5 Pull requests Projects Releases 3 Packages Activity Actions

refactor: cleanup code

Browse source 
Signed-off-by: Christina Sørensen <christina@cafkafk.com>
This commit is contained in:
Christina Sørensen 2024-03-15 12:12:11 +01:00
parent c54ac4f5a3
commit 7c26cf1437
Signed by: cafkafk
GPG key ID: 26C542FD97F965CE
1 changed files with 21 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
src/main.rs
View file

@ -3,12 +3,15 @@
// //
// SPDX-License-Identifier: AGPL-3.0-only // SPDX-License-Identifier: AGPL-3.0-only
use std::{io, net::{IpAddr, SocketAddr}}; use std::{
io,
net::{IpAddr, SocketAddr},
};
use dns_lookup::lookup_host; use dns_lookup::lookup_host;
use futures::{stream, StreamExt, future::join_all}; use futures::{future::join_all, stream, StreamExt};
use rayon::prelude::*;
use itertools::Itertools; use itertools::Itertools;
use rayon::prelude::*;
#[allow(unused)] #[allow(unused)]
use log::{debug, error, info, trace, warn}; use log::{debug, error, info, trace, warn};
@ -42,7 +45,7 @@ mod nix {
"--json", "--json",
"--option", "--option",
"eval-cache", "eval-cache",
"true" "true",
]) ])
.output() .output()
.unwrap(); .unwrap();
@ -78,8 +81,8 @@ mod nix {
mod net { mod net {
use std::{net::SocketAddr, time::Duration}; use std::{net::SocketAddr, time::Duration};
use reqwest::{StatusCode, ClientBuilder, Client};
use async_recursion::async_recursion; use async_recursion::async_recursion;
use reqwest::{Client, ClientBuilder, StatusCode};
use tokio::time::sleep; use tokio::time::sleep;
#[async_recursion] #[async_recursion]
@ -117,10 +120,16 @@ async fn main() -> io::Result<()> {
let domain_addr = SocketAddr::new(ips[0], 443); let domain_addr = SocketAddr::new(ips[0], 443);
let client = reqwest::Client::builder().resolve(domain, domain_addr).build().unwrap(); let client = reqwest::Client::builder()
.resolve(domain, domain_addr)
.build()
.unwrap();
let binding = get_requisites("DBCAC"); let binding = get_requisites("DBCAC");
let connection_buffer = binding.lines().map(|line| line.to_owned()).collect::<Vec<_>>(); let connection_buffer = binding
.lines()
.map(|line| line.to_owned())
.collect::<Vec<_>>();
// FIXME make constant // FIXME make constant
let slide = 100; let slide = 100;
@ -137,7 +146,11 @@ async fn main() -> io::Result<()> {
}) })
.collect_vec(); .collect_vec();
let sum: usize = join_all(tasks).await.into_iter().map(|result| result.unwrap()).sum(); let sum: usize = join_all(tasks)
.await
.into_iter()
.map(|result| result.unwrap())
.sum();
println!("sum {:#?}", sum); println!("sum {:#?}", sum);