chadtmiller.com/knotless
git that lives in your Atmosphere account
1
10
Rarely reached branches share a line with what always runs
crates/knotless-run/src/lib.rs+5−6
| @@ -2642,12 +2642,11 @@ impl Runner { | ||
let remote = Remote::open(&self.ctx, &url).await?; | ||
let snap = remote.snapshot(&self.ctx).await?; | ||
let me = &self.reporter.identity.did; | ||
let Some(key) = snap.key().map(str::to_string) else { | ||
return Ok(()); | ||
}; | ||
if !names(snap.repo.as_ref(), &key, me) { | ||
return Ok(()); | ||
} | ||
// One with no record, or whose record does not name this runner, | ||
// is passed over. | ||
let key = snap.key().map(str::to_string); | ||
let named = key.filter(|key| names(snap.repo.as_ref(), key, me)); | ||
let Some(key) = named else { return Ok(()) }; | ||
let id = (did.to_string(), key.clone()); | ||
let was = self | ||
.named | ||
crates/knotless-serve/src/card.rs+1−3
| @@ -619,9 +619,7 @@ fn counts(out: &mut String, comments: usize, reviews: usize, size: Option<Size>) | ||
.unwrap(); | ||
x += measure(&said, text, Weight::Regular) + gap; | ||
} | ||
let Some(size) = size else { | ||
return; | ||
}; | ||
let Some(size) = size else { return }; | ||
for (said, fill) in [ | ||
(format!("+{}", size.added), ADDED), | ||
(format!("-{}", size.removed), REMOVED), | ||
crates/knotless-serve/src/moderation.rs+5−4
| @@ -240,13 +240,14 @@ async fn stream(app: Arc<App>, socket: WebSocket, cursor: Option<i64>) { | ||
}, | ||
}; | ||
let Some((seq, label)) = next else { return }; | ||
if seq > sent { | ||
sent = seq; | ||
open = tx | ||
// One read from the past and heard live too is sent once. | ||
let fresh = seq > sent; | ||
sent = sent.max(seq); | ||
open = !fresh | ||
|| tx | ||
.send(Message::Binary(frame(seq, &label).into())) | ||
.await | ||
.is_ok(); | ||
} | ||
} | ||
} | ||