{"header":{"message":"Avoid saving the result","description":null,"timestamp":"2026-06-07T16:56:02.190542324Z","authors":[{}]},"hash":"IS5JL73JHDDJQGGGYBUUJNEBFT3STOKGB7V33M6J44CB2TPOVPXQC","authors":[{"login":"pmeunier","key":"8ES6e1QmLjuQn1DzS2DQRKebzCKPHpdf4E9hfwMqQoe7"}],"deps":{"hashes":[["IS5JL73JHDDJQGGGYBUUJNEBFT3STOKGB7V33M6J44CB2TPOVPXQC","Avoid saving the result"],["AA",null],["YJLEG4WRYKKQJMMDRKIRG4T4L7ZZ7N777EKIRSHHWHNZYWZJ7G5AC","Basic CI infra (no runner yet)"],["W4LOGDLDBZIUUNACCXWWUZGVEGWAXYAZI3C66HYHURFQ3CWZ7XKAC","Removing locks when deploying"],["PCR2LDLTK6XVSBXJL6IMGQP7GSE5UNFCT6WRM2H5EPQ2AZWFRCFAC","update + CI"],["YYJ76Q7V6G7FHSNZ25MU3ZZY5KGXIODBHLWOZUGB4FIKL7PUCNAAC","Initial attempt at CI/CD"],["D4SBRY6KHEAMGUEVWSUYHNCRYXCOC5JJ3N3DQ47ZXOXQGT73VERAC","Initial patch"]],"deps":["YJLEG4WRYKKQJMMDRKIRG4T4L7ZZ7N777EKIRSHHWHNZYWZJ7G5AC","W4LOGDLDBZIUUNACCXWWUZGVEGWAXYAZI3C66HYHURFQ3CWZ7XKAC","PCR2LDLTK6XVSBXJL6IMGQP7GSE5UNFCT6WRM2H5EPQ2AZWFRCFAC"],"known":["YYJ76Q7V6G7FHSNZ25MU3ZZY5KGXIODBHLWOZUGB4FIKL7PUCNAAC"]},"hunks":[{"Replacement":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":49,"ins":{"up_context":[{"change":4,"pos":5240}],"down_context":[{"change":4,"pos":5316}],"flag":"BLOCK","start":0,"end":79,"inode":{"change":2,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":5240},"to":{"change":4,"start":5240,"end":5316},"introduced_by":4}],"inode":{"change":2,"pos":65}},"ins_contents":[{"Add":" tokio::sync::watch::Receiver>,"}],"del_contents":[{"Del":" tokio::sync::watch::Receiver>,\n"}]}},{"Replacement":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":89,"ins":{"up_context":[{"change":4,"pos":6084}],"down_context":[{"change":2,"pos":2720}],"flag":"BLOCK","start":80,"end":271,"inode":{"change":2,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":6084},"to":{"change":4,"start":6084,"end":6235},"introduced_by":4}],"inode":{"change":2,"pos":65}},"ins_contents":[{"Add":" if let Some((_, job)) = config.jobs.lock().unwrap().get(&job) {"},{"Add":" if let Some(s) = &*job.borrow() {"},{"Add":" return Ok(Json(s.clone()));"},{"Add":" }"},{"Add":" }"},{"Add":" Err(Error::NotFound)"}],"del_contents":[{"Del":" let s =\n tokio::fs::read_to_string(&config.config.ci_path.join(&format!(\"{}.status\", job))).await?;\n Ok(Json(serde_json::from_str(&s)?))\n"}]}},{"Edit":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":260,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":11169},"to":{"change":4,"start":11169,"end":11192},"introduced_by":4}],"inode":{"change":2,"pos":65}}},"contents":[{"Del":" status_tx,\n"}]}},{"Replacement":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":264,"ins":{"up_context":[{"change":2,"pos":11139}],"down_context":[{"change":4,"pos":11499}],"flag":"BLOCK","start":272,"end":352,"inode":{"change":2,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":11139},"to":{"change":4,"start":11270,"end":11499},"introduced_by":4}],"inode":{"change":2,"pos":65}},"ins_contents":[{"Add":" if let Ok((code, results)) = result {"},{"Add":" let status = Status {"}],"del_contents":[{"Del":" let (code, results) = result?;\n debug!(\"code = {:?} {:?}\", code, results);\n tokio::fs::write(\n config.config.ci_path.join(&format!(\"{}.status\", t.id)),\n serde_json::to_string(&Status {\n"}]}},{"Replacement":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":269,"ins":{"up_context":[{"change":4,"pos":11592}],"down_context":[{"change":4,"pos":11657}],"flag":"BLOCK","start":353,"end":661,"inode":{"change":2,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":11592},"to":{"change":4,"start":11592,"end":11657},"introduced_by":4}],"inode":{"change":2,"pos":65}},"ins_contents":[{"Add":" };"},{"Add":" status_tx.send(Some(status)).unwrap();"},{"Add":" } else {"},{"Add":" let status = Status {"},{"Add":" code: None,"},{"Add":" results: HashMap::new(),"},{"Add":" finished: chrono::Utc::now(),"},{"Add":" };"},{"Add":" status_tx.send(Some(status)).unwrap();"},{"Add":" }"}],"del_contents":[{"Del":" })\n .unwrap(),\n )\n .await?;\n"}]}},{"Edit":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":290,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":11908},"to":{"change":4,"start":11908,"end":11968},"introduced_by":4}],"inode":{"change":2,"pos":65}}},"contents":[{"Del":" mut status_tx: tokio::sync::watch::Sender>,\n"}]}},{"Replacement":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":324,"ins":{"up_context":[{"change":4,"pos":12957}],"down_context":[{"change":2,"pos":14104}],"flag":"BLOCK","start":662,"end":725,"inode":{"change":2,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":12957},"to":{"change":4,"start":12957,"end":13036},"introduced_by":4}],"inode":{"change":2,"pos":65}},"ins_contents":[{"Add":" let code = dump_cmd(cmd, &mut files, &mut kill_rx).await?;"}],"del_contents":[{"Del":" let code = dump_cmd(cmd, &mut files, &mut kill_rx, &mut status_tx).await?;\n"}]}},{"Replacement":{"inode":{"change":2,"pos":65},"path":"ci/src/main.rs","line":356,"ins":{"up_context":[{"change":4,"pos":14053}],"down_context":[{"change":4,"pos":14173}],"flag":"BLOCK","start":726,"end":795,"inode":{"change":2,"pos":65}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":14053},"to":{"change":4,"start":14053,"end":14173},"introduced_by":4}],"inode":{"change":2,"pos":65}},"ins_contents":[{"Add":" Ok((dump_cmd(cmd, &mut files, &mut kill_rx).await?, result))"}],"del_contents":[{"Del":" Ok((\n dump_cmd(cmd, &mut files, &mut kill_rx, &mut status_tx).await?,\n result,\n ))\n"}]}},{"Replacement":{"inode":{"change":2,"pos":14618},"path":"ci/src/lib.rs","line":6,"ins":{"up_context":[{"change":2,"pos":14641}],"down_context":[{"change":4,"pos":14355}],"flag":"BLOCK","start":796,"end":844,"inode":{"change":2,"pos":14618}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":14641},"to":{"change":4,"start":14314,"end":14355},"introduced_by":4}],"inode":{"change":2,"pos":14618}},"ins_contents":[{"Add":"#[derive(Clone, Debug, Serialize, Deserialize)]"}],"del_contents":[{"Del":"#[derive(Debug, Serialize, Deserialize)]\n"}]}},{"Edit":{"inode":{"change":2,"pos":14618},"path":"ci/src/lib.rs","line":28,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":14881},"to":{"change":4,"start":14881,"end":14942},"introduced_by":4}],"inode":{"change":2,"pos":14618}}},"contents":[{"Del":" status_tx: &mut tokio::sync::watch::Sender>,\n"}]}},{"Edit":{"inode":{"change":2,"pos":14618},"path":"ci/src/lib.rs","line":107,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":17915},"to":{"change":4,"start":17915,"end":17958},"introduced_by":4}],"inode":{"change":2,"pos":14618}}},"contents":[{"Del":" status_tx.send(code).unwrap();\n"}]}},{"Replacement":{"inode":{"change":7,"pos":431834},"path":"api/src/replication.rs","line":421,"ins":{"up_context":[{"change":4,"pos":44709}],"down_context":[{"change":4,"pos":44781}],"flag":"BLOCK","start":845,"end":942,"inode":{"change":7,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":44709},"to":{"change":4,"start":44709,"end":44781},"introduced_by":4}],"inode":{"change":7,"pos":431834}},"ins_contents":[{"Add":" let code = status.status();"},{"Add":" let status = if let reqwest::StatusCode::OK = code {"}],"del_contents":[{"Del":" let status = if let reqwest::StatusCode::OK = status.status() {\n"}]}},{"Edit":{"inode":{"change":7,"pos":431834},"path":"api/src/replication.rs","line":435,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":45235}],"down_context":[{"change":3,"pos":4015}],"flag":"BLOCK","start":943,"end":1346,"inode":{"change":7,"pos":431834}}},"contents":[{"Add":" } else if let reqwest::StatusCode::NOT_FOUND = code {"},{"Add":" use crate::db::jobs::dsl as jobs;"},{"Add":" diesel::update(jobs::jobs.find(job))"},{"Add":" .set(("},{"Add":" jobs::status.eq(None::),"},{"Add":" jobs::ended.eq(chrono::Utc::now()),"},{"Add":" ))"},{"Add":" .execute(db)"},{"Add":" .await"},{"Add":" .unwrap();"},{"Add":" break;"}]}},{"Replacement":{"inode":{"change":7,"pos":431834},"path":"api/src/replication.rs","line":473,"ins":{"up_context":[{"change":4,"pos":46261}],"down_context":[{"change":4,"pos":46342}],"flag":"BLOCK","start":1347,"end":1435,"inode":{"change":7,"pos":431834}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":46261},"to":{"change":4,"start":46261,"end":46342},"introduced_by":4}],"inode":{"change":7,"pos":431834}},"ins_contents":[{"Add":" let (mut status_tx, _status_rx) = tokio::sync::watch::channel(None::);"}],"del_contents":[{"Del":" let (mut status_tx, _status_rx) = tokio::sync::watch::channel(None);\n"}]}},{"Edit":{"inode":{"change":7,"pos":431834},"path":"api/src/replication.rs","line":483,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":46773},"to":{"change":4,"start":46773,"end":46907},"introduced_by":4}],"inode":{"change":7,"pos":431834}}},"contents":[{"Del":" .unwrap();\n ci::dump_cmd(cmd, &mut files, &mut kill_rx, &mut status_tx)\n .await\n"}]}},{"Edit":{"inode":{"change":7,"pos":431834},"path":"api/src/replication.rs","line":484,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":46938}],"down_context":[{"change":3,"pos":6417}],"flag":"BLOCK","start":1436,"end":1512,"inode":{"change":7,"pos":431834}}},"contents":[{"Add":" ci::dump_cmd(cmd, &mut files, &mut kill_rx).await.unwrap();"}]}},{"Edit":{"inode":{"change":7,"pos":431834},"path":"api/src/replication.rs","line":493,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":47307},"to":{"change":4,"start":47307,"end":47441},"introduced_by":4}],"inode":{"change":7,"pos":431834}}},"contents":[{"Del":" .unwrap();\n ci::dump_cmd(cmd, &mut files, &mut kill_rx, &mut status_tx)\n .await\n"}]}},{"Edit":{"inode":{"change":7,"pos":431834},"path":"api/src/replication.rs","line":494,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":47472}],"down_context":[{"change":3,"pos":6516}],"flag":"BLOCK","start":1513,"end":1589,"inode":{"change":7,"pos":431834}}},"contents":[{"Add":" ci::dump_cmd(cmd, &mut files, &mut kill_rx).await.unwrap();"}]}},{"Replacement":{"inode":{"change":5,"pos":32096},"path":"api/src/jobs.rs","line":200,"ins":{"up_context":[{"change":4,"pos":51315}],"down_context":[{"change":4,"pos":51399}],"flag":"BLOCK","start":1590,"end":1682,"inode":{"change":5,"pos":32096}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":51315},"to":{"change":4,"start":51315,"end":51399},"introduced_by":4}],"inode":{"change":5,"pos":32096}},"ins_contents":[{"Add":" crate::replication::get_config_state(&config.repo_locks, repo, channel.clone())"}],"del_contents":[{"Del":" crate::replication::get_config_state(&config.repo_locks, repo, channel)\n"}]}},{"Edit":{"inode":{"change":5,"pos":32096},"path":"api/src/jobs.rs","line":218,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":52062}],"down_context":[{"change":4,"pos":52062}],"flag":"BLOCK","start":1683,"end":1708,"inode":{"change":5,"pos":32096}}},"contents":[{"Add":" channel,"}]}}],"owner":"pijul","repo":"nest","token":"ST1NqfrHoLT9OfaTYB7OSmO8Bm6MVKFEYKLU9I+r6Do=","login":null}

…

Dependencies

Change contents