chore: clippy
This commit is contained in:
parent
f622f47550
commit
64daf6eb2f
4 changed files with 7 additions and 7 deletions
|
@ -91,9 +91,9 @@ async fn main() {
|
||||||
let (kill_introducer, introducer_fut) =
|
let (kill_introducer, introducer_fut) =
|
||||||
Ctx::spawn_bootstrap(c, d.as_ref().clone()).await.unwrap();
|
Ctx::spawn_bootstrap(c, d.as_ref().clone()).await.unwrap();
|
||||||
|
|
||||||
let c = ctx.clone();
|
let _c = ctx.clone();
|
||||||
let d = db.clone();
|
let _d = db.clone();
|
||||||
let f = federate.clone();
|
let _f = federate.clone();
|
||||||
|
|
||||||
let socket_addr = settings.server.get_ip();
|
let socket_addr = settings.server.get_ip();
|
||||||
HttpServer::new(move || {
|
HttpServer::new(move || {
|
||||||
|
|
|
@ -122,7 +122,7 @@ impl Handler<AddSearchMaster> for Master {
|
||||||
type Result = MessageResult<AddSearchMaster>;
|
type Result = MessageResult<AddSearchMaster>;
|
||||||
|
|
||||||
fn handle(&mut self, m: AddSearchMaster, ctx: &mut Self::Context) -> Self::Result {
|
fn handle(&mut self, m: AddSearchMaster, ctx: &mut Self::Context) -> Self::Result {
|
||||||
let (tx, rx) = channel();
|
let (tx, _rx) = channel();
|
||||||
match self.get_site(&m.0) {
|
match self.get_site(&m.0) {
|
||||||
None => {
|
None => {
|
||||||
let _ = tx.send(Ok(None));
|
let _ = tx.send(Ok(None));
|
||||||
|
@ -235,7 +235,7 @@ impl Handler<AddCounter> for Master {
|
||||||
|
|
||||||
fn handle(&mut self, m: AddCounter, _ctx: &mut Self::Context) -> Self::Result {
|
fn handle(&mut self, m: AddCounter, _ctx: &mut Self::Context) -> Self::Result {
|
||||||
// let (tx, rx) = channel();
|
// let (tx, rx) = channel();
|
||||||
let counter: Counter = m.counter.into();
|
let counter: Counter = m.counter;
|
||||||
let addr = counter.start();
|
let addr = counter.start();
|
||||||
self.add_site(addr, m.id);
|
self.add_site(addr, m.id);
|
||||||
// tx.send(Ok(())).unwrap();
|
// tx.send(Ok(())).unwrap();
|
||||||
|
|
|
@ -90,7 +90,7 @@ pub async fn search(
|
||||||
db: &BoxDB,
|
db: &BoxDB,
|
||||||
query: String,
|
query: String,
|
||||||
) -> ServiceResult<Vec<db_core::Repository>> {
|
) -> ServiceResult<Vec<db_core::Repository>> {
|
||||||
let responses = ctx.search_repository(&db, query).await?;
|
let responses = ctx.search_repository(db, query).await?;
|
||||||
|
|
||||||
Ok(responses)
|
Ok(responses)
|
||||||
}
|
}
|
||||||
|
|
|
@ -65,7 +65,7 @@ impl Ctx {
|
||||||
let mut federated_resp = Vec::default();
|
let mut federated_resp = Vec::default();
|
||||||
|
|
||||||
for starchart in db.search_mini_index(&query).await?.iter() {
|
for starchart in db.search_mini_index(&query).await?.iter() {
|
||||||
if db.is_starchart_imported(&Url::parse(&starchart)?).await? {
|
if db.is_starchart_imported(&Url::parse(starchart)?).await? {
|
||||||
log::debug!("{starchart} is imported");
|
log::debug!("{starchart} is imported");
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue