{"header":{"message":"Update source control resource states in event loop","description":"Further work should add more incrementality to support recording and amending, along with tracking when to fire `onDidChangeFileDecorations`.","timestamp":"2026-01-01T13:22:34.773865596Z","authors":[{}]},"hash":"IDY5SNLOFZ663OCJ2L5NZMFNJXZSGL5O22QQXR5BIV3SJ2VUQIMQC","authors":[{"login":"finchie","key":"6WCsL9cxQoPBLLwR1PUvmFBJi6wGTGFAxcxMovPQCwTZ"}],"deps":{"hashes":[["IDY5SNLOFZ663OCJ2L5NZMFNJXZSGL5O22QQXR5BIV3SJ2VUQIMQC","Update source control resource states in event loop"],["AA",null],["3YGYMEXVHOHRQVPC53MVPSLI2ZJM77MBPWNPDDCL56DNCPUC6XTAC","Create `event_loop` module"],["NB2MF3MYAJ25KNZP3GMHX42LUSBYOX6FTNLIBK3CQ7CMANFZFEGQC","Add `OpenWorkspaceFolder` event"],["XDFSAPI75FQXHD3ZMYBEGROQ35VQC3WQFQ5EJQAWUXTCKR2N62LAC","Create a tokio runtime directly instead of `#[tokio::main]`"],["MGJ23FHFUNT4RSJP3AW5ZALGEDTNZPR4PLHLPOCFNEBIX2WHV2JAC","Assign repository URI to source control in `OpenWorkspaceFolder` events"],["OUADGWKR6A7G3UHCLSC7AWLJIMS45Y56NPVTQ7FENJPYNTAMXXMAC","Create fully-initialized `SourceControl` object in `event_loop`"],["2ZAM5V35CAQD5MOFPZEGU4ERQ2FM5CL5MB2DOJDW2ZQ74IQFBISQC","Move event handling into modules"],["SLTXBK5GTNH3PUZNA5VG7IDICV3NZPWSCTJSE4YPOQEDMWO67PIQC","Recursively discover repositories when handling `OpenWorkspaceFolder` event"],["TWEUQ64DU5ZXAEG67GQSS7GDEZ2O2JR5352WRVIIUK5J7ZOMO5QAC","Move threadsafe function builder logic into function-specific modules"],["QY4Z5ZXZ7G6DZFCTRPX7D6TIDZ5DHSDTLOWFDANIPUHOEKQRAIXAC","Refactor `event_loop/threadsafe_function` file into `event_loop::js_function` module"],["IBVCQSSGPKLQTD4T4TAJZRC4LY3G6FP4QWFEBHN5KEFI44ZGGAXQC","Use `External` to wrap `initialize_source_control` arguments"]],"deps":["3YGYMEXVHOHRQVPC53MVPSLI2ZJM77MBPWNPDDCL56DNCPUC6XTAC","NB2MF3MYAJ25KNZP3GMHX42LUSBYOX6FTNLIBK3CQ7CMANFZFEGQC","XDFSAPI75FQXHD3ZMYBEGROQ35VQC3WQFQ5EJQAWUXTCKR2N62LAC","MGJ23FHFUNT4RSJP3AW5ZALGEDTNZPR4PLHLPOCFNEBIX2WHV2JAC","OUADGWKR6A7G3UHCLSC7AWLJIMS45Y56NPVTQ7FENJPYNTAMXXMAC","2ZAM5V35CAQD5MOFPZEGU4ERQ2FM5CL5MB2DOJDW2ZQ74IQFBISQC","SLTXBK5GTNH3PUZNA5VG7IDICV3NZPWSCTJSE4YPOQEDMWO67PIQC","TWEUQ64DU5ZXAEG67GQSS7GDEZ2O2JR5352WRVIIUK5J7ZOMO5QAC","QY4Z5ZXZ7G6DZFCTRPX7D6TIDZ5DHSDTLOWFDANIPUHOEKQRAIXAC","IBVCQSSGPKLQTD4T4TAJZRC4LY3G6FP4QWFEBHN5KEFI44ZGGAXQC"],"known":[]},"hunks":[{"Edit":{"inode":{"change":2,"pos":171},"path":"editors/vscode/src/event_loop/mod.rs","line":2,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":2543}],"down_context":[{"change":2,"pos":172}],"flag":"BLOCK","start":0,"end":17,"inode":{"change":2,"pos":171}}},"contents":[{"Add":"use std::rc::Rc;"}]}},{"Replacement":{"inode":{"change":2,"pos":171},"path":"editors/vscode/src/event_loop/mod.rs","line":24,"ins":{"up_context":[{"change":6,"pos":2786}],"down_context":[{"change":3,"pos":1618}],"flag":"BLOCK","start":18,"end":179,"inode":{"change":2,"pos":171}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":2786},"to":{"change":6,"start":2786,"end":2939},"introduced_by":6}],"inode":{"change":2,"pos":171}},"ins_contents":[{"Add":" unrecorded_changes: Rc,"},{"Add":" untracked_paths: Rc,"}],"del_contents":[{"Del":" unrecorded_changes: vscode_sys::reference::SourceControlResourceGroupRef,\n untracked_paths: vscode_sys::reference::SourceControlResourceGroupRef,\n"}]}},{"Replacement":{"inode":{"change":2,"pos":171},"path":"editors/vscode/src/event_loop/mod.rs","line":29,"ins":{"up_context":[{"change":2,"pos":455}],"down_context":[{"change":2,"pos":517}],"flag":"BLOCK","start":180,"end":331,"inode":{"change":2,"pos":171}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":455},"to":{"change":10,"start":18,"end":118},"introduced_by":10}],"inode":{"change":2,"pos":171}},"ins_contents":[{"Add":"async fn event_loop("},{"Add":" js_functions: js_function::Functions,"},{"Add":" mut sender: UnboundedSender,"},{"Add":" mut receiver: UnboundedReceiver,"},{"Add":") {"}],"del_contents":[{"Del":"async fn event_loop(js_functions: js_function::Functions, mut receiver: UnboundedReceiver) {\n"}]}},{"Replacement":{"inode":{"change":2,"pos":171},"path":"editors/vscode/src/event_loop/mod.rs","line":49,"ins":{"up_context":[{"change":3,"pos":1760}],"down_context":[{"change":3,"pos":1797}],"flag":"BLOCK","start":332,"end":378,"inode":{"change":2,"pos":171}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1760},"to":{"change":3,"start":1760,"end":1797},"introduced_by":3}],"inode":{"change":2,"pos":171}},"ins_contents":[{"Add":" for event in event_buffer.drain(..) {"}],"del_contents":[{"Del":" for event in &event_buffer {\n"}]}},{"Replacement":{"inode":{"change":2,"pos":171},"path":"editors/vscode/src/event_loop/mod.rs","line":52,"ins":{"up_context":[{"change":5,"pos":1532}],"down_context":[{"change":3,"pos":2519}],"flag":"BLOCK","start":379,"end":638,"inode":{"change":2,"pos":171}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":1532},"to":{"change":10,"start":119,"end":250},"introduced_by":10}],"inode":{"change":2,"pos":171}},"ins_contents":[{"Add":" event::open_workspace_folder::handle("},{"Add":" raw_uri,"},{"Add":" &mut repositories,"},{"Add":" &js_functions,"},{"Add":" &mut sender,"},{"Add":" )"},{"Add":" .await"}],"del_contents":[{"Del":" event::open_workspace_folder::handle(raw_uri, &mut repositories, &js_functions)\n .await\n"}]}},{"Edit":{"inode":{"change":2,"pos":171},"path":"editors/vscode/src/event_loop/mod.rs","line":60,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2537}],"down_context":[{"change":3,"pos":2537}],"flag":"BLOCK","start":639,"end":953,"inode":{"change":2,"pos":171}}},"contents":[{"Add":" Event::UpdateResourceStates { repository_path } => {"},{"Add":" event::update_resource_states::handle("},{"Add":" repository_path,"},{"Add":" &repositories,"},{"Add":" &js_functions,"},{"Add":" )"},{"Add":" .await"},{"Add":" }"}]}},{"Replacement":{"inode":{"change":2,"pos":171},"path":"editors/vscode/src/event_loop/mod.rs","line":85,"ins":{"up_context":[{"change":2,"pos":1124}],"down_context":[{"change":3,"pos":2740}],"flag":"BLOCK","start":954,"end":1023,"inode":{"change":2,"pos":171}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1124},"to":{"change":2,"start":1124,"end":1185},"introduced_by":2}],"inode":{"change":2,"pos":171}},"ins_contents":[{"Add":" if let Err(_existing_value) = EVENT_SENDER.set(sender.clone()) {"}],"del_contents":[{"Del":" if let Err(_existing_value) = EVENT_SENDER.set(sender) {\n"}]}},{"Replacement":{"inode":{"change":2,"pos":171},"path":"editors/vscode/src/event_loop/mod.rs","line":94,"ins":{"up_context":[{"change":4,"pos":161}],"down_context":[{"change":3,"pos":2926}],"flag":"BLOCK","start":1024,"end":1118,"inode":{"change":2,"pos":171}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":4,"pos":161},"to":{"change":10,"start":325,"end":411},"introduced_by":10}],"inode":{"change":2,"pos":171}},"ins_contents":[{"Add":" std::thread::spawn(move || runtime.block_on(event_loop(js_functions, sender, receiver)));"}],"del_contents":[{"Del":" std::thread::spawn(move || runtime.block_on(event_loop(js_functions, receiver)));\n"}]}},{"FileAdd":{"meta":{"basename":"update_resource_states.rs","metadata":0},"context":[{"change":10,"pos":435}],"contents":[{"Add":"use std::rc::Rc;"},{"Add":""},{"Add":"use camino::Utf8PathBuf;"},{"Add":"use napi::bindgen_prelude::{External, FunctionCallContext};"},{"Add":"use pijul_extension::path_state::PathState;"},{"Add":""},{"Add":"use crate::vscode_sys::reference::SourceControlResourceGroupRef;"},{"Add":"use crate::vscode_sys::{SourceControlResourceState, Uri};"},{"Add":""},{"Add":"pub struct Arguments {"},{"Add":" pub repository_path: Utf8PathBuf,"},{"Add":" pub repository_states: Vec<(Utf8PathBuf, PathState)>,"},{"Add":" pub unrecorded_changes: Rc,"},{"Add":" pub untracked_paths: Rc,"},{"Add":"}"},{"Add":""},{"Add":"pub type Prototype = napi::threadsafe_function::ThreadsafeFunction<"},{"Add":" External,"},{"Add":" (),"},{"Add":" External,"},{"Add":" napi::Status,"},{"Add":" false,"},{"Add":" false,"},{"Add":" 0,"},{"Add":">;"},{"Add":""},{"Add":"pub fn build(env: &napi::Env) -> Result {"},{"Add":" env.create_function_from_closure(\"update_resource_states\", callback)?"},{"Add":" .build_threadsafe_function()"},{"Add":" .build()"},{"Add":"}"},{"Add":""},{"Add":"fn callback(function_call_context: FunctionCallContext) -> Result<(), napi::Error> {"},{"Add":" let (external,): (&External,) = function_call_context.args()?;"},{"Add":" let Arguments {"},{"Add":" repository_path,"},{"Add":" repository_states,"},{"Add":" unrecorded_changes,"},{"Add":" untracked_paths,"},{"Add":" } = &**external;"},{"Add":""},{"Add":" let mut modified_resource_states = Vec::new();"},{"Add":" let mut untracked_resource_states = Vec::new();"},{"Add":""},{"Add":" for (relative_path, path_state) in repository_states {"},{"Add":" let absolute_path = repository_path.join(relative_path);"},{"Add":" let resource_uri = Uri::file(function_call_context.env, absolute_path.as_str())?;"},{"Add":""},{"Add":" let resource_state ="},{"Add":" SourceControlResourceState::new(function_call_context.env, &resource_uri)?;"},{"Add":""},{"Add":" match path_state {"},{"Add":" PathState::Untracked => untracked_resource_states.push(resource_state),"},{"Add":" PathState::Tracked(_tracked_state) => modified_resource_states.push(resource_state),"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" unrecorded_changes"},{"Add":" .get_inner(function_call_context.env)?"},{"Add":" .set_resource_states(modified_resource_states)?;"},{"Add":" untracked_paths"},{"Add":" .get_inner(function_call_context.env)?"},{"Add":" .set_resource_states(untracked_resource_states)?;"},{"Add":""},{"Add":" Ok(())"},{"Add":"}"}]}},{"Edit":{"inode":{"change":3,"pos":772},"path":"editors/vscode/src/event_loop/js_function/mod.rs","line":1,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":772}],"down_context":[{"change":11,"pos":0}],"flag":"BLOCK","start":3300,"end":3343,"inode":{"change":3,"pos":772}}},"contents":[{"Add":"use std::rc::Rc;"},{"Add":""},{"Add":"use camino::Utf8PathBuf;"}]}},{"Edit":{"inode":{"change":3,"pos":772},"path":"editors/vscode/src/event_loop/js_function/mod.rs","line":5,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":55}],"down_context":[{"change":3,"pos":808}],"flag":"BLOCK","start":3344,"end":3388,"inode":{"change":3,"pos":772}}},"contents":[{"Add":"use pijul_extension::path_state::PathState;"}]}},{"Edit":{"inode":{"change":3,"pos":772},"path":"editors/vscode/src/event_loop/js_function/mod.rs","line":10,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":91}],"down_context":[{"change":10,"pos":486}],"flag":"BLOCK","start":3389,"end":3421,"inode":{"change":3,"pos":772}}},"contents":[{"Add":"pub mod update_resource_states;"}]}},{"Edit":{"inode":{"change":3,"pos":772},"path":"editors/vscode/src/event_loop/js_function/mod.rs","line":14,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":115}],"down_context":[{"change":5,"pos":729}],"flag":"BLOCK","start":3422,"end":3485,"inode":{"change":3,"pos":772}}},"contents":[{"Add":" update_resource_states: update_resource_states::Prototype,"}]}},{"Edit":{"inode":{"change":3,"pos":772},"path":"editors/vscode/src/event_loop/js_function/mod.rs","line":22,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":79}],"down_context":[{"change":5,"pos":968}],"flag":"BLOCK","start":3486,"end":3559,"inode":{"change":3,"pos":772}}},"contents":[{"Add":" update_resource_states: update_resource_states::build(env)?,"}]}},{"Edit":{"inode":{"change":3,"pos":772},"path":"editors/vscode/src/event_loop/js_function/mod.rs","line":42,"atom":{"NewVertex":{"up_context":[{"change":11,"pos":452}],"down_context":[{"change":11,"pos":452}],"flag":"BLOCK","start":3560,"end":4282,"inode":{"change":3,"pos":772}}},"contents":[{"Add":" .call_async(External::new(arguments))"},{"Add":" .await"},{"Add":" }"},{"Add":""},{"Add":" pub async fn update_resource_states("},{"Add":" &self,"},{"Add":" repository_path: Utf8PathBuf,"},{"Add":" repository_states: Vec<(Utf8PathBuf, PathState)>,"},{"Add":" unrecorded_changes: &Rc,"},{"Add":" untracked_paths: &Rc,"},{"Add":" ) -> Result<(), napi::Error> {"},{"Add":" let arguments = update_resource_states::Arguments {"},{"Add":" repository_path,"},{"Add":" repository_states,"},{"Add":" unrecorded_changes: Rc::clone(unrecorded_changes),"},{"Add":" untracked_paths: Rc::clone(untracked_paths),"},{"Add":" };"},{"Add":""},{"Add":" self.update_resource_states"}]}},{"FileAdd":{"meta":{"basename":"update_resource_states.rs","metadata":0},"context":[{"change":7,"pos":332}],"contents":[{"Add":"use std::collections::HashMap;"},{"Add":""},{"Add":"use camino::Utf8PathBuf;"},{"Add":""},{"Add":"use crate::event_loop::Repository;"},{"Add":"use crate::event_loop::js_function::Functions;"},{"Add":""},{"Add":"#[tracing::instrument(skip(repositories, js_functions))]"},{"Add":"pub async fn handle("},{"Add":" repository_path: Utf8PathBuf,"},{"Add":" repositories: &HashMap,"},{"Add":" js_functions: &Functions,"},{"Add":") {"},{"Add":" let Some(repository) = repositories.get(&repository_path) else {"},{"Add":" tracing::error!(message = \"No repository found\", ?repository_path);"},{"Add":" return;"},{"Add":" };"},{"Add":""},{"Add":" if let Err(error) = js_functions"},{"Add":" .update_resource_states("},{"Add":" repository_path,"},{"Add":" repository.repository.iter_path_states().collect(),"},{"Add":" &repository.unrecorded_changes,"},{"Add":" &repository.untracked_paths,"},{"Add":" )"},{"Add":" .await"},{"Add":" {"},{"Add":" tracing::error!(message = \"Failed to update resource states\", ?error);"},{"Add":" }"},{"Add":"}"}]}},{"Edit":{"inode":{"change":7,"pos":383},"path":"editors/vscode/src/event_loop/event/open_workspace_folder.rs","line":2,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":415}],"down_context":[{"change":7,"pos":415}],"flag":"BLOCK","start":5210,"end":5227,"inode":{"change":7,"pos":383}}},"contents":[{"Add":"use std::rc::Rc;"}]}},{"Edit":{"inode":{"change":7,"pos":383},"path":"editors/vscode/src/event_loop/event/open_workspace_folder.rs","line":6,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":480}],"down_context":[{"change":7,"pos":480}],"flag":"BLOCK","start":5228,"end":5268,"inode":{"change":7,"pos":383}}},"contents":[{"Add":"use tokio::sync::mpsc::UnboundedSender;"}]}},{"Edit":{"inode":{"change":7,"pos":383},"path":"editors/vscode/src/event_loop/event/open_workspace_folder.rs","line":8,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":481},"to":{"change":7,"start":481,"end":516},"introduced_by":7}],"inode":{"change":7,"pos":383}}},"contents":[{"Del":"use crate::event_loop::Repository;\n"}]}},{"Edit":{"inode":{"change":7,"pos":383},"path":"editors/vscode/src/event_loop/event/open_workspace_folder.rs","line":9,"atom":{"NewVertex":{"up_context":[{"change":10,"pos":2114}],"down_context":[{"change":7,"pos":581}],"flag":"BLOCK","start":5269,"end":5313,"inode":{"change":7,"pos":383}}},"contents":[{"Add":"use crate::event_loop::{Event, Repository};"}]}},{"Replacement":{"inode":{"change":7,"pos":383},"path":"editors/vscode/src/event_loop/event/open_workspace_folder.rs","line":13,"ins":{"up_context":[{"change":7,"pos":668}],"down_context":[{"change":7,"pos":687}],"flag":"BLOCK","start":5314,"end":5335,"inode":{"change":7,"pos":383}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":668},"to":{"change":7,"start":668,"end":687},"introduced_by":7}],"inode":{"change":7,"pos":383}},"ins_contents":[{"Add":" raw_uri: String,"}],"del_contents":[{"Del":" raw_uri: &str,\n"}]}},{"Edit":{"inode":{"change":7,"pos":383},"path":"editors/vscode/src/event_loop/event/open_workspace_folder.rs","line":16,"atom":{"NewVertex":{"up_context":[{"change":10,"pos":2203}],"down_context":[{"change":7,"pos":792}],"flag":"BLOCK","start":5336,"end":5377,"inode":{"change":7,"pos":383}}},"contents":[{"Add":" sender: &mut UnboundedSender,"}]}},{"Replacement":{"inode":{"change":7,"pos":383},"path":"editors/vscode/src/event_loop/event/open_workspace_folder.rs","line":18,"ins":{"up_context":[{"change":7,"pos":796}],"down_context":[{"change":7,"pos":847}],"flag":"BLOCK","start":5378,"end":5430,"inode":{"change":7,"pos":383}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":796},"to":{"change":7,"start":796,"end":847},"introduced_by":7}],"inode":{"change":7,"pos":383}},"ins_contents":[{"Add":" let uri = match UriAbsoluteStr::new(&raw_uri) {"}],"del_contents":[{"Del":" let uri = match UriAbsoluteStr::new(raw_uri) {\n"}]}},{"Replacement":{"inode":{"change":7,"pos":383},"path":"editors/vscode/src/event_loop/event/open_workspace_folder.rs","line":125,"ins":{"up_context":[{"change":8,"pos":3473}],"down_context":[{"change":8,"pos":3534}],"flag":"BLOCK","start":5431,"end":5547,"inode":{"change":7,"pos":383}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":8,"pos":3473},"to":{"change":8,"start":3473,"end":3534},"introduced_by":8}],"inode":{"change":7,"pos":383}},"ins_contents":[{"Add":" unrecorded_changes: Rc::new(unrecorded_changes),"},{"Add":" untracked_paths: Rc::new(untracked_paths),"}],"del_contents":[{"Del":" unrecorded_changes,\n untracked_paths,\n"}]}},{"Edit":{"inode":{"change":7,"pos":383},"path":"editors/vscode/src/event_loop/event/open_workspace_folder.rs","line":134,"atom":{"NewVertex":{"up_context":[{"change":8,"pos":3683}],"down_context":[{"change":8,"pos":3683}],"flag":"BLOCK","start":5548,"end":5679,"inode":{"change":7,"pos":383}}},"contents":[{"Add":""},{"Add":" sender"},{"Add":" .send(Event::UpdateResourceStates { repository_path })"},{"Add":" .expect(\"Receiver should be open\");"}]}},{"Edit":{"inode":{"change":7,"pos":3067},"path":"editors/vscode/src/event_loop/event/mod.rs","line":1,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":3067}],"down_context":[{"change":7,"pos":3068}],"flag":"BLOCK","start":5680,"end":5706,"inode":{"change":7,"pos":3067}}},"contents":[{"Add":"use camino::Utf8PathBuf;"},{"Add":""}]}},{"Edit":{"inode":{"change":7,"pos":3067},"path":"editors/vscode/src/event_loop/event/mod.rs","line":4,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":3099}],"down_context":[{"change":7,"pos":3099}],"flag":"BLOCK","start":5707,"end":5739,"inode":{"change":7,"pos":3067}}},"contents":[{"Add":"pub mod update_resource_states;"}]}},{"Edit":{"inode":{"change":7,"pos":3067},"path":"editors/vscode/src/event_loop/event/mod.rs","line":9,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":3175}],"down_context":[{"change":7,"pos":3175}],"flag":"BLOCK","start":5740,"end":5799,"inode":{"change":7,"pos":3067}}},"contents":[{"Add":" UpdateResourceStates { repository_path: Utf8PathBuf },"}]}}],"owner":"finchie","repo":"pijul_extension","token":"euSE4sCpxQ350Vai4QZohSl3XIYqfAE+lzRfjouxBkI=","login":null}

…

Dependencies

Change contents