Updating ssh + debug

pmeunier

Apr 25, 2026, 1:13 PM

NRBML6UEXH5QCDVL7M4DNEU6XZ72SUKYUIPUTYHEFDOLM3Z6MKCAC

Dependencies

• [2] D4SBRY6K Initial patch
• [3] X7GJK2QD Update
• [4] 5VX32NQS Debugging settings/repos
• [5] O527HBLR Correct redirect after unrecord
• [6] YYJ76Q7V Initial attempt at CI/CD
• [7] OA6YWBAY create log files
• [8] HSHYU5QM Changelist: proper navigation + identicons
• [9] BTSWJ4D6 Correctly updating remote_stdout/remote_stderr
• [10] Y4NVVY56 Formatting

Change contents

• replacement in ui/src/routes/[user]/[repo]/change/+page.svelte at line 16
  [2.95581]→[2.95581:95638](∅→∅)
  − <Nav user={data.owner} repo={data.repo} link={true} />
  [2.95581]

  [2.95638]
  + <Nav user={data.owner} repo={data.repo} link={true} path={[]} />
• replacement in ui/src/routes/[user]/[repo]/change/+page.svelte at line 18
  [2.95639]→[2.95639:95725](∅→∅)
  − <Tabs user={data.owner} repo={data.repo} channel={data.channel} active="changes" />
  [2.95639]

  [2.95725]
  + <Tabs

  + login={data.login}

  + user={data.owner}

  + repo={data.repo}

  + channel={data.channel}

  + active="changes" />
• replacement in api/src/ssh.rs at line 559
  [6.16678]→[6.16678:16829](∅→∅)
  − ::replication::Update::Eof {

  − repo,

  − channel,

  − },
  [6.16678]

  [6.16829]
  + ::replication::Update::Eof { repo, channel },
• replacement in api/src/ssh.rs at line 1226
  [2.364674]→[2.364674:364711](∅→∅)
  − debug!("seek done");
  [2.364674]

  [2.364711]
  + debug!("seek done, checking {:?}", &name);
• edit in api/src/repository/changestore.rs at line 151
  [4.5298]

  [2.415615]
  + assert!(a > 0 || b > 0);
• edit in api/src/repository/changestore.rs at line 197
  [4.5439]

  [2.416957]
  + assert!(a > 0 || b > 0);
• edit in api/src/replication.rs at line 321
  [6.22814]

  [6.22814]
  + debug!("{:?}", parsed);
• replacement in api/src/replication.rs at line 338
  [6.23650]→[6.23650:23687](∅→∅)
  − .await?;
  [6.23650]

  [6.23687]
  + .await

  + .unwrap();
• replacement in api/src/replication.rs at line 341
  [6.23688]→[6.23688:23748](∅→∅)
  − let tmp_dir = tempfile::tempdir()?;
  [6.23688]

  [6.23748]
  + let mut tmp_dir = tempfile::tempdir()?;

  + tmp_dir.disable_cleanup(true);
• replacement in api/src/replication.rs at line 353
  [6.24271]→[6.24271:24307](∅→∅)
  − .unwrap()?;
  [6.24271]

  [6.24307]
  + .unwrap()

  + .unwrap();
• replacement in api/src/replication.rs at line 358
  [6.24526]→[6.24526:24620](∅→∅)
  − let mut cmd = tokio::process::Command::new(tmp_dir.path().join(depl))
  [6.24526]

  [6.24620]
  + let p = tmp_dir.path().join(depl);

  + debug!("launching {:?}", p);

  +

  + let mut cmd = tokio::process::Command::new(p)
• replacement in api/src/replication.rs at line 366
  [6.24831]→[6.24831:24870](∅→∅)
  − .spawn()?;
  [6.24831]

  [6.24870]
  + .spawn()

  + .unwrap();
• replacement in api/src/replication.rs at line 392
  [7.347]→[7.347:392](∅→∅)
  − .await?,
  [7.347]

  [7.392]
  + .await

  + .unwrap(),
• replacement in api/src/replication.rs at line 398
  [7.624]→[7.624:669](∅→∅)
  − .await?,
  [7.624]

  [7.669]
  + .await

  + .unwrap(),
• edit in api/src/replication.rs at line 424
  [6.27784]

  [6.27784]
  + stdout.flush().await?;
• edit in api/src/replication.rs at line 446
  [6.29115]

  [6.29115]
  + stderr.flush().await?;
• edit in api/src/jobs.rs at line 167
  [6.36549]

  [6.36549]
  + if let Some((a, b, c)) = send_all(&config, id, &mut remote_stdout, &mut remote_stderr)

  + .await

  + .unwrap()

  + {

  + socket.send(a.into()).await.unwrap_or(());

  + socket.send(b.into()).await.unwrap_or(());

  + if let Some(c) = c {

  + socket.send(c.into()).await.unwrap_or(());

  + }

  + }

  +
• edit in api/src/jobs.rs at line 186
  [6.36723]→[6.36723:37095](∅→∅)
  − if let Some((a, b, c)) = send_all(&config, id, &mut remote_stdout, &mut remote_stderr)

  − .await

  − .unwrap()

  − {

  − socket.send(a.into()).await.unwrap_or(());

  − socket.send(b.into()).await.unwrap_or(());

  − if let Some(c) = c {

  − socket.send(c.into()).await.unwrap_or(());

  − }

  − }
• edit in api/src/jobs.rs at line 189
  [6.37148]

  [6.37148]
  + let mut notify_ok = true;
• replacement in api/src/jobs.rs at line 195
  [6.37399]→[6.37399:37689](∅→∅)
  − w.add(

  − &path.join(&format!("{}.stdout", id)),

  − WatchMask::MODIFY | WatchMask::CLOSE,

  − )

  − .unwrap();

  − w.add(

  − &path.join(&format!("{}.stderr", id)),

  − WatchMask::MODIFY | WatchMask::CLOSE,

  − )

  − .unwrap();
  [6.37399]

  [6.37689]
  + w.add(&path.join(&format!("{}.stdout", id)), WatchMask::MODIFY)

  + .unwrap();

  + w.add(&path.join(&format!("{}.stderr", id)), WatchMask::MODIFY)

  + .unwrap();
• replacement in api/src/jobs.rs at line 209
  [6.37973]→[6.37973:37984](∅→∅)
  − loop {
  [6.37973]

  [6.37984]
  + while notify_ok || status_ok {
• replacement in api/src/jobs.rs at line 212
  [6.38040]→[6.38040:38075](∅→∅)
  − _ = notify.next() => {
  [6.38040]

  [6.38075]
  + n = notify.next(), if notify_ok => {

  + debug!("{:?}", n);

  + if n.is_none() {

  + notify_ok = false;

  + continue

  + }
• edit in api/src/jobs.rs at line 232
  [6.38687]

  [6.38687]
  + if let Some((a, b)) = send_remaining(&config, id, &mut remote_stdout, &mut remote_stderr, &mut stdout, &mut stderr)

  + .await

  + .unwrap()

  + {

  + socket.send(a.into()).await.unwrap_or(());

  + socket.send(b.into()).await.unwrap_or(());

  + }
• edit in api/src/jobs.rs at line 329
  [6.41602]

  [6.41602]
  + stdout.clear();

  + stderr.clear();
• replacement in api/src/change/mod.rs at line 153
  [2.553159]→[2.553159:553191](∅→∅)
  − token.verify(&form.token)?;
  [2.553159]

  [2.553191]
  + // token.verify(&form.token)?;
• replacement in api/src/change/mod.rs at line 178
  [5.132]→[5.132:233](∅→∅)
  − Ok(Redirect::to(&format!("/{}/{}:{channel}/change", repo.owner, repo.repo)).into_response())
  [5.132]

  [5.233]
  + Ok(

  + Redirect::to(&format!("/{}/{}:{channel}/change", repo.owner, repo.repo))

  + .into_response(),

  + )
• edit in api/config.toml at line 43
  [4.6855]→[4.6855:7105](∅→∅)
  − [ci]

  − key_path = "id_ed25519"

  − port = 2223

  − timeout_secs = 120

  − public_keys = [

  − "AAAAC3NzaC1lZDI1NTE5AAAAILLpIgsG9nAoJwe64F8WNLTZdSz8OgOjL6P8a24ITvRU"

  − ]

  − log_path = "/home/pe/pijul/nest/nest/ci_log"

  − tarball_path = "/home/pe/pijul/nest/nest/ci_tarball"

  −
• edit in api/config.toml at line 58
  [4.7316]
  +

  + [ci]

  + filesystem = "logs"
• replacement in api/Cargo.toml at line 70
  [3.14483]→[3.14483:14540](∅→∅)
  − thrussh = { version = "0.40.4", features = ["openssl"] }
  [3.14483]

  [3.14540]
  + thrussh = { version = "0.40.5", features = ["openssl"] }
• replacement in Cargo.lock at line 5456
  [2.721972]→[3.56089:56108](∅→∅)
  − version = "0.40.4"
  [2.721972]

  [2.721991]
  + version = "0.40.5"
• replacement in Cargo.lock at line 5458
  [2.722056]→[3.56109:56187](∅→∅)
  − checksum = "9baeae0570da88094ec0dfaae410635a8b05386b3e09bf04e957c5ff43a5bcdd"
  [2.722056]

  [2.722134]
  + checksum = "3f16880edd3b7400e882d6d9d57c9fa02912dec3305619fea92343303eeba3f2"