{"header":{"message":"WIP","description":null,"timestamp":"2024-04-02T20:09:55.445501Z","authors":[{}]},"hash":"6WIH3U43354JLREJ2CU7RSFPXJ4ZOWKY6T2KCZRH5FBD6S3MZ5BAC","authors":[{"login":"dblsaiko","key":"CFbqMkwG4nTc9WA817hB7d94hHr5XwgvDXAtY7hfzw8m"}],"deps":{"hashes":[["6WIH3U43354JLREJ2CU7RSFPXJ4ZOWKY6T2KCZRH5FBD6S3MZ5BAC","WIP"],["AA",null],["OYN2YVPAN6L3X6HZXJI6B2GYGL2W5AXRK6CVDJRWALS5OENNB5UAC","Create `pijul_remote` crate"],["ISCWVXO6UN37V2QMR75ZWS7H5E7WYZCGR6TX3EDFOFRVCAPMIVUAC","Progress bar for push"],["UDHP4ZVBQZT2VBURB2MDCU2IZDNMCAFSIUKWRBDQ5BWMFKSN2LYQC","Fixing SSH asynchronicity issues"],["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","Fixing the bad changes in history (unfortunately, by rebooting)."],["L4JXJHWXYNCL4QGJXNKKTOKKTAXKKXBJUUY7HFZGEUZ5A2V5H34QC","pijul/*: reorganize imports and remove extern crate"],["4RV7T4SRYIQLBW3EZFWBO5G65QAVG2GHPI4KMDDZERCX65KQWSPQC","Migrate from `pijul::config` to `pijul-config`"],["5QTMRUXNE2XNJCMLN6MQN24UEZ55EFC3LIR4PO6OPNTT5KEL7WXQC","Fixing a race condition between progress bars"],["2D7P2VKJASU7QDQZHGCLBIT6G2V5WUFYLWTCEVVEI2EZHGM6XYRAC","Change completions (where the whole progress bar story started)"],["G7HJHNFDZCGOPGVETNYK7BDDPJXHEIPGZJEJXBGBXSWPWEX3BIQQC","Migrate from `pijul_interaction::progress` to `pijul_interaction`"]],"deps":["OYN2YVPAN6L3X6HZXJI6B2GYGL2W5AXRK6CVDJRWALS5OENNB5UAC"],"known":["SXEYMYF7P4RZMZ46WPL4IZUTSQ2ATBWYZX7QNVMS3SGOYXYOHAGQC","UDHP4ZVBQZT2VBURB2MDCU2IZDNMCAFSIUKWRBDQ5BWMFKSN2LYQC","ISCWVXO6UN37V2QMR75ZWS7H5E7WYZCGR6TX3EDFOFRVCAPMIVUAC"]},"hunks":[{"FileAdd":{"meta":{"basename":"pipe.rs","metadata":0},"context":[{"change":2,"pos":41}],"contents":[{"Add":"use std::collections::BTreeMap;"},{"Add":"use std::future::Future;"},{"Add":"use std::path::{Path, PathBuf};"},{"Add":"use std::pin::Pin;"},{"Add":"use std::sync::Mutex;"},{"Add":"use std::task::{Context, Poll, Waker};"},{"Add":""},{"Add":"use futures_util::future::BoxFuture;"},{"Add":"use futures_util::FutureExt;"},{"Add":"use pijul_interaction::ProgressBar;"},{"Add":"use tokio::sync::mpsc;"},{"Add":""},{"Add":"use crate::{RemoteRepo, CS};"},{"Add":""},{"Add":"pub struct FetchChangesState<'a> {"},{"Add":" shared: Mutex>,"},{"Add":"}"},{"Add":""},{"Add":"struct Shared<'a> {"},{"Add":" task: BoxFuture<'a, Result>,"},{"Add":" changes: BTreeMap,"},{"Add":"}"},{"Add":""},{"Add":"struct ChangeState {"},{"Add":" wakers: Vec,"},{"Add":"}"},{"Add":""},{"Add":"impl<'a> FetchChangesState<'a> {"},{"Add":" pub fn new("},{"Add":" remote: &'a mut RemoteRepo,"},{"Add":" progress_bar: ProgressBar,"},{"Add":" dest_dir: T,"},{"Add":" full: bool,"},{"Add":" ) -> Self"},{"Add":" where"},{"Add":" T: AsRef + Send + 'a,"},{"Add":" {"},{"Add":" let (in_tx, mut in_rx) = mpsc::unbounded_channel();"},{"Add":" let (mut out_tx, out_rx) = mpsc::channel(100);"},{"Add":""},{"Add":" let task = async move {"},{"Add":" remote"},{"Add":" .download_changes("},{"Add":" progress_bar,"},{"Add":" &mut in_rx,"},{"Add":" &mut out_tx,"},{"Add":" dest_dir.as_ref(),"},{"Add":" full,"},{"Add":" )"},{"Add":" .await"},{"Add":" }"},{"Add":" .boxed();"},{"Add":""},{"Add":" FetchChangesState {"},{"Add":" shared: Mutex::new(Shared {"},{"Add":" task,"},{"Add":" changes: Default::default(),"},{"Add":" }),"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" pub fn fetch(&mut self, cs: CS) -> FetchJob {"},{"Add":" todo!()"},{"Add":" }"},{"Add":"}"},{"Add":""},{"Add":"pub struct FetchJob<'a> {"},{"Add":" shared: &'a Mutex>,"},{"Add":"}"},{"Add":""},{"Add":"impl<'a> Future for FetchJob<'a> {"},{"Add":" type Output = bool;"},{"Add":""},{"Add":" fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll {"},{"Add":" let mut shared = self.shared.lock().unwrap();"},{"Add":""},{"Add":" shared.task.poll_unpin(cx);"},{"Add":" "},{"Add":" todo!()"},{"Add":" }"},{"Add":"}"}]}},{"Edit":{"inode":{"change":3,"pos":52474},"path":"pijul-remote/src/lib.rs","line":4,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":438}],"down_context":[{"change":3,"pos":10335}],"flag":"BLOCK","start":1831,"end":1850,"inode":{"change":3,"pos":52474}}},"contents":[{"Add":"use std::pin::Pin;"}]}},{"Edit":{"inode":{"change":3,"pos":52474},"path":"pijul-remote/src/lib.rs","line":6,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":10355}],"down_context":[{"change":7,"pos":438}],"flag":"BLOCK","start":1851,"end":1872,"inode":{"change":3,"pos":52474}}},"contents":[{"Add":"use std::task::Poll;"}]}},{"Edit":{"inode":{"change":3,"pos":52474},"path":"pijul-remote/src/lib.rs","line":10,"atom":{"NewVertex":{"up_context":[{"change":8,"pos":245}],"down_context":[{"change":9,"pos":363}],"flag":"BLOCK","start":1873,"end":1902,"inode":{"change":3,"pos":52474}}},"contents":[{"Add":"use futures::{Sink, Stream};"}]}},{"Edit":{"inode":{"change":3,"pos":52474},"path":"pijul-remote/src/lib.rs","line":35,"atom":{"NewVertex":{"up_context":[{"change":10,"pos":344}],"down_context":[{"change":11,"pos":37}],"flag":"BLOCK","start":1903,"end":1914,"inode":{"change":3,"pos":52474}}},"contents":[{"Add":"mod pipe;"},{"Add":""}]}},{"Replacement":{"inode":{"change":3,"pos":52474},"path":"pijul-remote/src/lib.rs","line":1166,"ins":{"up_context":[{"change":3,"pos":66586}],"down_context":[{"change":3,"pos":66587}],"flag":"BLOCK","start":1915,"end":1920,"inode":{"change":3,"pos":52474}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":66586},"to":{"change":3,"start":66586,"end":66587},"introduced_by":3}],"inode":{"change":3,"pos":52474}},"ins_contents":[{"Add":" "}],"del_contents":[{"Del":"\n"}]}}],"owner":"dblsaiko","repo":"pijul","token":"k5hu/x37hPFL7IQI/RspYIPWc3wXBTpLEnANaVuWHXc=","login":null}

…

Dependencies

Change contents