pijul/nest - Change D4OFR55J32745WILDBAYROEZNRTIFG7VGQTOYSXO4CAB7K55RG5QC

CI: keeping track of status

Created by pmeunier yesterday at 02:57

D4OFR55J32745WILDBAYROEZNRTIFG7VGQTOYSXO4CAB7K55RG5QC

Dependencies

In channels

main

Change contents

Replacement in ci/src/main.rs at line 216 [2.65]

B:BD[8.1221] → [8.1221:1283]

    let (kill_tx, kill_rx) = tokio::sync::oneshot::channel();

[8.1221]

[8.1283]

    let (kill_tx, mut kill_rx) = tokio::sync::oneshot::channel();

Replacement in ci/src/main.rs at line 279 [2.65]
B:BD[6.11148] → [6.11148:11169]
```
            kill_rx,
```
[6.11148]
[6.11192]
```
            &mut kill_rx,
```
Deletion in ci/src/main.rs at line 282 [2.65]
B:BD[6.11218] → [6.11218:11269]
```
        config.jobs.lock().unwrap().remove(&t.id);
```

Replacement in ci/src/main.rs at line 320 [2.65]

B:BD[6.11855] → [6.11855:11908]

    mut kill_rx: tokio::sync::oneshot::Receiver<()>,

[6.11855]

[6.11968]

    kill_rx: &mut tokio::sync::oneshot::Receiver<()>,

Replacement in ci/src/main.rs at line 356 [2.65]

B:BD[6.12957] → [7.662:725]

    let code = dump_cmd(cmd, &mut files, &mut kill_rx).await?;

[6.12957]

[2.14104]

    let code = dump_cmd(cmd, &mut files, kill_rx).await?;

Replacement in ci/src/main.rs at line 388 [2.65]

B:BD[6.14053] → [7.726:795]

        Ok((dump_cmd(cmd, &mut files, &mut kill_rx).await?, result))

[6.14053]

[6.14173]

        Ok((dump_cmd(cmd, &mut files, kill_rx).await?, result))

Replacement in api/src/replication.rs at line 207 [9.431834]

B:BD[6.41754] → [6.41754:41843]

                                        sync_job(&mut db, s.client, &s.ci, n, id).await;

[6.41754]

[6.41843]

                                        sync_job(s.jobs.clone(), &mut db, s.client, &s.ci, n, id)
                                            .await;

Insertion in api/src/replication.rs at line 392 [9.431834]
[6.43878]
[6.43878]
```
    jobs: crate::config::Jobs,
```

Insertion in api/src/replication.rs at line 399 [9.431834]

[6.44034]

    let (status_tx, status_rx) = tokio::sync::watch::channel(None);
    jobs.lock().unwrap().insert(job, status_rx);

Insertion in api/src/replication.rs at line 431 [9.431834]

[8.2154]

                status_tx.send(Some((status.finished, status.code)));

Replacement in api/src/jobs.rs at line 239 [3.32096]

B:BD[6.52712] → [6.52712:52808]

                        crate::replication::sync_job(&mut db, client, &config.ci, n, id).await;

[6.52712]

[6.52808]

                        crate::replication::sync_job(
                            config.jobs.clone(),
                            &mut db,
                            client,
                            &config.ci,
                            n,
                            id,
                        )
                        .await;

Replacement in api/src/jobs.rs at line 409 [3.32096]

∅:D[4.1619] → [3.36549:36696]

B:BD[3.36549] → [3.36549:36696]

    let Some(mut status) = config
        .jobs
        .lock()
        .unwrap()
        .get(&id)
        .map(|(_, _, w)| w.clone())
    else {

[4.1619]

[3.36696]

    let Some(mut status) = config.jobs.lock().unwrap().get(&id).map(|w| w.clone()) else {

Replacement in api/src/jobs.rs at line 497 [3.32096]

B:BD[5.381] → [5.381:413]

) -> Result<(), crate::Error> {

[5.381]

[3.39324]

) -> Result<Option<chrono::DateTime<chrono::Utc>>, crate::Error> {

Replacement in api/src/jobs.rs at line 520 [3.32096]
B:BD[5.720] → [5.720:747]
```
            return Ok(());
```
[5.720]
[5.747]
```
            return Ok(ended);
```

Insertion in api/src/jobs.rs at line 582 [3.32096]

[5.2635]

[3.40950]

        Ok(ended)
    } else {
        Ok(None)

Deletion in api/src/jobs.rs at line 586 [3.32096]
B:BD[3.40956] → [5.2636:2647]
```
    Ok(())
```

Replacement in api/src/config.rs at line 87 [9.532759]

B:BD[3.43083] → [3.43083:43360]

            (
                tokio::sync::oneshot::Sender<()>,
                tokio::sync::watch::Sender<Option<(chrono::DateTime<chrono::Utc>, Option<i32>)>>,
                tokio::sync::watch::Receiver<Option<(chrono::DateTime<chrono::Utc>, Option<i32>)>>,
            ),

[3.43083]

[3.43360]

            tokio::sync::watch::Receiver<Option<(chrono::DateTime<chrono::Utc>, Option<i32>)>>,