pmeunier/nest - Change NRBML6UEXH5QCDVL7M4DNEU6XZ72SUKYUIPUTYHEFDOLM3Z6MKCAC

Updating ssh + debug

Created by pmeunier on April 25, 2026

NRBML6UEXH5QCDVL7M4DNEU6XZ72SUKYUIPUTYHEFDOLM3Z6MKCAC

Dependencies

In channels

main

Change contents

Replacement in ui/src/routes/[user]/[repo]/change/+page.svelte at line 16 [2.95158]
B:BD[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.95158]

B:BD[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 [2.319304]

B:BD[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.319304]

B:BD[2.364674] → [2.364674:364711]

                debug!("seek done");

[2.364674]

[2.364711]

                debug!("seek done, checking {:?}", &name);

Insertion in api/src/repository/changestore.rs at line 151 [2.410821]
[4.5298]
[2.415615]
```
            assert!(a > 0 || b > 0);
```
Insertion in api/src/repository/changestore.rs at line 197 [2.410821]
[4.5439]
[2.416957]
```
            assert!(a > 0 || b > 0);
```
Insertion in api/src/replication.rs at line 321 [2.431834]
[6.22814]
[6.22814]
```
                debug!("{:?}", parsed);
```

Replacement in api/src/replication.rs at line 338 [2.431834]

B:BD[6.23650] → [6.23650:23687]

                            .await?;

[6.23650]

[6.23687]

                            .await
                            .unwrap();

Replacement in api/src/replication.rs at line 341 [2.431834]

B:BD[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 [2.431834]

B:BD[6.24271] → [6.24271:24307]

                        .unwrap()?;

[6.24271]

[6.24307]

                        .unwrap()
                        .unwrap();

Replacement in api/src/replication.rs at line 358 [2.431834]

B:BD[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 [2.431834]

B:BD[6.24831] → [6.24831:24870]

                            .spawn()?;

[6.24831]

[6.24870]

                            .spawn()
                            .unwrap();

Replacement in api/src/replication.rs at line 392 [2.431834]

B:BD[7.347] → [7.347:392]

                                    .await?,

[7.347]

[7.392]

                                    .await
                                    .unwrap(),

Replacement in api/src/replication.rs at line 398 [2.431834]

B:BD[7.624] → [7.624:669]

                                    .await?,

[7.624]

[7.669]

                                    .await
                                    .unwrap(),

Insertion in api/src/replication.rs at line 424 [2.431834]

[6.27784]

                                            stdout.flush().await?;

Insertion in api/src/replication.rs at line 446 [2.431834]

[6.29115]

                                            stderr.flush().await?;

Insertion in api/src/jobs.rs at line 167 [6.32096]

[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(());
        }
    }

Deletion in api/src/jobs.rs at line 186 [6.32096]

B:BD[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(());
            }
        }

Insertion in api/src/jobs.rs at line 189 [6.32096]
[6.37148]
[6.37148]
```
    let mut notify_ok = true;
```

Replacement in api/src/jobs.rs at line 195 [6.32096]

B:BD[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.32096]
B:BD[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.32096]

B:BD[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
                }

Insertion in api/src/jobs.rs at line 232 [6.32096]

[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(());
                }

Insertion in api/src/jobs.rs at line 329 [6.32096]
[6.41602]
[6.41602]
```
        stdout.clear();
        stderr.clear();
```
Replacement in api/src/change/mod.rs at line 153 [2.548943]
B:BD[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 [2.548943]

B:BD[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(),
        )

Deletion in api/config.toml at line 43 [4.5869]

B:BD[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"

Insertion in api/config.toml at line 58 [4.5869]
[4.7316]
```
[ci]
filesystem = "logs"
```

Replacement in api/Cargo.toml at line 70 [2.602339]

B:BD[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.604770]
B:BD[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.604770]

B:BD[2.722056] → [3.56109:56187]

checksum = "9baeae0570da88094ec0dfaae410635a8b05386b3e09bf04e957c5ff43a5bcdd"

[2.722056]

[2.722134]

checksum = "3f16880edd3b7400e882d6d9d57c9fa02912dec3305619fea92343303eeba3f2"