{"header":{"message":"first working prototype","description":null,"timestamp":"2024-02-19T21:06:23.847750243Z","authors":[{}]},"hash":"2GEILJZTYWEJEMN4PWFQYLQXZZ44BVCJFM5XW35EUGS3GQZB3CPQC","authors":[{"login":"hardliner66","key":"B5bgFxujKQnkKNBFAwbJFG5fU9pLbJ3L9rxcaYV7yQA5"}],"deps":{"hashes":[["2GEILJZTYWEJEMN4PWFQYLQXZZ44BVCJFM5XW35EUGS3GQZB3CPQC","first working prototype"],["AA",null],["KJK5LRQDGEQLVSS2SIOINZNNH6T4NKAJB24QWWSFLI3KZLLIDYPAC","basic structures"],["KM3TEIVBG6FP7H3AXNWYBIUSXRIN4ILGQY7TV2EQ5VCYQ6ER66YAC","init"],["Q76TG3J5E6NYS5AB2JV5J5GOE57K6IGGPAI5OAQAQVAXGO2LSAOAC",""]],"deps":["KJK5LRQDGEQLVSS2SIOINZNNH6T4NKAJB24QWWSFLI3KZLLIDYPAC"],"known":["KM3TEIVBG6FP7H3AXNWYBIUSXRIN4ILGQY7TV2EQ5VCYQ6ER66YAC"]},"hunks":[{"Edit":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":5,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":150}],"down_context":[{"change":3,"pos":150}],"flag":"BLOCK","start":0,"end":25,"inode":{"change":3,"pos":49}}},"contents":[{"Add":"use std::time::Duration;"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":11,"ins":{"up_context":[{"change":3,"pos":269}],"down_context":[{"change":3,"pos":345}],"flag":"BLOCK","start":26,"end":55,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":269},"to":{"change":2,"start":0,"end":50},"introduced_by":2}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":"use tokio::process::Command;"}],"del_contents":[{"Del":"use tokio::process::{Child, ChildStdin, Command};\n"}]}},{"Edit":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":13,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":363}],"down_context":[{"change":3,"pos":363}],"flag":"BLOCK","start":56,"end":96,"inode":{"change":3,"pos":49}}},"contents":[{"Add":"use tokio::sync::mpsc::UnboundedSender;"}]}},{"Edit":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":21,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":518},"to":{"change":3,"start":518,"end":536},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":536},"to":{"change":2,"start":96,"end":119},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":119},"to":{"change":3,"start":554,"end":570},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":554},"to":{"change":3,"start":554,"end":570},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":570},"to":{"change":2,"start":120,"end":183},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":183},"to":{"change":3,"start":628,"end":634},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":628},"to":{"change":3,"start":628,"end":634},"introduced_by":3}],"inode":{"change":3,"pos":49}}},"contents":[{"Del":"}\n\nstruct Actor {\n"},{"Del":" stdin: ChildStdin,\n"},{"Del":"}\n\nimpl Actor {\n"},{"Del":" fn new(stdin: ChildStdin) -> Self {\n Self { stdin }\n"},{"Del":" }\n"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":24,"ins":{"up_context":[{"change":3,"pos":665}],"down_context":[{"change":3,"pos":773}],"flag":"BLOCK","start":97,"end":212,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":665},"to":{"change":3,"start":665,"end":773},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":773},"to":{"change":2,"start":184,"end":287},"introduced_by":2}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":" static ref ACTORS: Arc>>> = Arc::new(Mutex::new(HashMap::new()));"}],"del_contents":[{"Del":" static ref ACTORS: Arc>>>> = Arc::new(Mutex::new(HashMap::new()));\n"},{"Del":" static ref SPAWN_REQUESTS: Arc>> = Arc::new(Mutex::new(Vec::new()));\n"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":27,"ins":{"up_context":[{"change":3,"pos":776}],"down_context":[{"change":3,"pos":932}],"flag":"BLOCK","start":213,"end":466,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":776},"to":{"change":2,"start":288,"end":369},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":369},"to":{"change":3,"start":844,"end":932},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":844},"to":{"change":3,"start":844,"end":932},"introduced_by":3}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":"async fn spawn_actor("},{"Add":" spawn_actor: SpawnActor,"},{"Add":" block: bool,"},{"Add":" tx: UnboundedSender<(Uuid, SpawnActor)>,"},{"Add":") -> anyhow::Result {"},{"Add":" if !spawn_actor.executable.is_file() {"},{"Add":" bail!(\"{} is not a file\", spawn_actor.executable.display());"}],"del_contents":[{"Del":"async fn spawn_actor(executable: PathBuf, block: bool) -> anyhow::Result {\n"},{"Del":" if !executable.is_file() {\n bail!(\"{} is not a file\", executable.display());\n"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":36,"ins":{"up_context":[{"change":3,"pos":939}],"down_context":[{"change":3,"pos":1042}],"flag":"BLOCK","start":467,"end":628,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":939},"to":{"change":3,"start":939,"end":1042},"introduced_by":3}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":" if !spawn_actor.executable.executable() {"},{"Add":" bail!("},{"Add":" \"{} is not an executable file\","},{"Add":" spawn_actor.executable.display()"},{"Add":" );"}],"del_contents":[{"Del":" if !executable.executable() {\n bail!(\"{} is not an executable file\", executable.display());\n"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":43,"ins":{"up_context":[{"change":3,"pos":1049}],"down_context":[{"change":3,"pos":1094}],"flag":"BLOCK","start":629,"end":718,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1049},"to":{"change":3,"start":1049,"end":1094},"introduced_by":3}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":" let mut child = Command::new(spawn_actor.executable)"},{"Add":" .args(spawn_actor.args)"}],"del_contents":[{"Del":" let mut child = Command::new(executable)\n"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":63,"ins":{"up_context":[{"change":2,"pos":723}],"down_context":[{"change":2,"pos":953}],"flag":"BLOCK","start":719,"end":781,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":723},"to":{"change":2,"start":723,"end":953},"introduced_by":2}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":" if let Err(e) = other.send(message) {"}],"del_contents":[{"Del":" let mut other = other.lock().await;\n let message = serde_json::to_string(&message).unwrap();\n if let Err(e) = other.stdin.write_all(message.as_bytes()).await {\n"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":68,"ins":{"up_context":[{"change":2,"pos":1135}],"down_context":[{"change":2,"pos":1267}],"flag":"BLOCK","start":782,"end":837,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1135},"to":{"change":2,"start":1135,"end":1267},"introduced_by":2}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":" tx.send((uuid, message)).unwrap();"}],"del_contents":[{"Del":" let mut spawn_requests = SPAWN_REQUESTS.lock().await;\n spawn_requests.push((uuid, message));\n"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":102,"ins":{"up_context":[{"change":2,"pos":2062}],"down_context":[{"change":2,"pos":2425}],"flag":"BLOCK","start":838,"end":1714,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":2062},"to":{"change":2,"start":2062,"end":2425},"introduced_by":2}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":" spawn(async move {"},{"Add":" let (tx, mut rx) = tokio::sync::mpsc::unbounded_channel::();"},{"Add":" spawn(async move {"},{"Add":" while let Some(message) = rx.recv().await {"},{"Add":" let msg = serde_json::to_string(&message).unwrap();"},{"Add":" stdin"},{"Add":" .write_all(format!(\"{msg}\\n\").as_bytes())"},{"Add":" .await"},{"Add":" .expect(\"Failed to write to child stdin\");"},{"Add":" stdin.flush().await.expect(\"Failed to flush child stdin\");"},{"Add":" }"},{"Add":" });"},{"Add":""},{"Add":" let init_message = Message {"},{"Add":" to: uuid,"},{"Add":" from: None,"},{"Add":" payload: serde_json::json!({"},{"Add":" \"id\": uuid,"},{"Add":" }),"},{"Add":" };"},{"Add":" tx.send(init_message)"},{"Add":" .expect(\"Failed to write to child stdin\");"}],"del_contents":[{"Del":" let init_message = Message {\n to: uuid,\n from: None,\n payload: serde_json::json!({\n \"id\": uuid,\n }),\n };\n let msg = serde_json::to_string(&init_message)?;\n stdin\n .write_all(msg.as_bytes())\n .await\n .expect(\"Failed to write to child stdin\");\n"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":125,"ins":{"up_context":[{"change":2,"pos":2426}],"down_context":[{"change":3,"pos":2619}],"flag":"BLOCK","start":1715,"end":1814,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":2426},"to":{"change":2,"start":2426,"end":2542},"introduced_by":2}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":" let mut actors = ACTORS.lock().await;"},{"Add":" actors.insert(uuid, tx);"},{"Add":" });"}],"del_contents":[{"Del":" let mut actors = ACTORS.lock().await;\n actors.insert(uuid, Arc::new(Mutex::new(Actor::new(stdin))));\n"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":141,"ins":{"up_context":[{"change":3,"pos":2852}],"down_context":[{"change":2,"pos":3470}],"flag":"BLOCK","start":1815,"end":3597,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2852},"to":{"change":2,"start":2594,"end":3470},"introduced_by":2}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":" let (tx, mut rx) = tokio::sync::mpsc::unbounded_channel::<(Uuid, SpawnActor)>();"},{"Add":""},{"Add":" {"},{"Add":" let tx = tx.clone();"},{"Add":" spawn(async move {"},{"Add":" loop {"},{"Add":" if let Some((uuid, request)) = rx.recv().await {"},{"Add":" match spawn_actor(request, false, tx.clone()).await {"},{"Add":" Ok(new_uid) => {"},{"Add":" let message = Message {"},{"Add":" from: None,"},{"Add":" to: uuid,"},{"Add":" payload: serde_json::json!({"},{"Add":" \"type\": \"spawned\","},{"Add":" \"status\": \"ok\","},{"Add":" \"id\": new_uid,"},{"Add":" }),"},{"Add":" };"},{"Add":" let actors = ACTORS.lock().await;"},{"Add":" let actor = actors.get(&uuid).unwrap();"},{"Add":" actor.send(message).unwrap();"},{"Add":" }"},{"Add":" Err(e) => {"},{"Add":" let message = Message {"},{"Add":" from: None,"},{"Add":" to: uuid,"},{"Add":" payload: serde_json::json!({"},{"Add":" \"type\": \"spawned\","},{"Add":" \"status\": \"error\","},{"Add":" \"error\": format!(\"{e}\"),"},{"Add":" }),"},{"Add":" };"},{"Add":" let actors = ACTORS.lock().await;"},{"Add":" let actor = actors.get(&uuid).unwrap();"},{"Add":" actor.send(message).unwrap();"},{"Add":" }"},{"Add":" }"},{"Add":" }"},{"Add":" tokio::time::sleep(Duration::from_millis(500)).await;"}],"del_contents":[{"Del":" spawn(async {\n let mut spawn_requests = SPAWN_REQUESTS.lock().await;\n loop {\n if let Some((uuid, request)) = spawn_requests.pop() {\n let new_uid = spawn_actor(request.executable, false).await.unwrap();\n let message = Message {\n from: None,\n to: uuid,\n payload: serde_json::json!({\n \"type\": \"spawned\",\n \"status\": \"ok\",\n \"id\": new_uid,\n }),\n };\n let actors = ACTORS.lock().await;\n let mut actor = actors.get(&uuid).unwrap().lock().await;\n actor\n .stdin\n .write_all(serde_json::to_string(&message).unwrap().as_bytes())\n .await\n .unwrap();\n"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":181,"ins":{"up_context":[{"change":2,"pos":3484}],"down_context":[{"change":3,"pos":2892}],"flag":"BLOCK","start":3598,"end":3616,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":3484},"to":{"change":2,"start":3484,"end":3502},"introduced_by":2}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":" });"},{"Add":" }"}],"del_contents":[{"Del":" }\n });\n"}]}},{"Replacement":{"inode":{"change":3,"pos":49},"path":"src/main.rs","line":184,"ins":{"up_context":[{"change":3,"pos":2893}],"down_context":[{"change":2,"pos":3549}],"flag":"BLOCK","start":3617,"end":3777,"inode":{"change":3,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2893},"to":{"change":2,"start":3503,"end":3549},"introduced_by":2}],"inode":{"change":3,"pos":49}},"ins_contents":[{"Add":" _ = spawn_actor("},{"Add":" SpawnActor {"},{"Add":" executable,"},{"Add":" args: Vec::new(),"},{"Add":" },"},{"Add":" true,"},{"Add":" tx.clone(),"},{"Add":" )"},{"Add":" .await?;"}],"del_contents":[{"Del":" _ = spawn_actor(executable, true).await?;\n"}]}},{"Edit":{"inode":{"change":3,"pos":2938},"path":"src/lib.rs","line":12,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":3167}],"down_context":[{"change":3,"pos":3167}],"flag":"BLOCK","start":3778,"end":3864,"inode":{"change":3,"pos":2938}}},"contents":[{"Add":""},{"Add":"//'{\"type\": \"message\", \"to\": \"73f31d83-a71e-4e32-a74a-263d3139f54d\", \"payload\": {}}'"}]}},{"Edit":{"inode":{"change":3,"pos":2938},"path":"src/lib.rs","line":19,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":3763}],"down_context":[{"change":3,"pos":3279}],"flag":"BLOCK","start":3865,"end":3914,"inode":{"change":3,"pos":2938}}},"contents":[{"Add":" #[serde(default)]"},{"Add":" pub args: Vec,"}]}},{"Edit":{"inode":{"change":2,"pos":3861},"path":"src/bin/test-actor.rs","line":1,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":3861},"to":{"change":2,"start":3862,"end":3893},"introduced_by":2}],"inode":{"change":2,"pos":3861}}},"contents":[{"Del":"use std::io::{self, BufRead};\n\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3861},"path":"src/bin/test-actor.rs","line":2,"ins":{"up_context":[{"change":2,"pos":3917}],"down_context":[{"change":2,"pos":3979}],"flag":"BLOCK","start":3915,"end":4041,"inode":{"change":2,"pos":3861}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":3917},"to":{"change":2,"start":3917,"end":3979},"introduced_by":2}],"inode":{"change":2,"pos":3861}},"ins_contents":[{"Add":"use serde::Serialize;"},{"Add":"use tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};"},{"Add":"use uaf::{LogMessage, Message, SpawnActor};"}],"del_contents":[{"Del":"use tokio::io::AsyncWriteExt;\nuse uaf::{LogMessage, Message};\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3861},"path":"src/bin/test-actor.rs","line":17,"ins":{"up_context":[{"change":2,"pos":4266}],"down_context":[{"change":2,"pos":4303}],"flag":"BLOCK","start":4042,"end":4087,"inode":{"change":2,"pos":3861}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":4266},"to":{"change":2,"start":4266,"end":4303},"introduced_by":2}],"inode":{"change":2,"pos":3861}},"ins_contents":[{"Add":"fn send_message(message: &T) {"}],"del_contents":[{"Del":"fn send_message(message: &Message) {\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3861},"path":"src/bin/test-actor.rs","line":24,"ins":{"up_context":[{"change":2,"pos":4434}],"down_context":[{"change":2,"pos":4532}],"flag":"BLOCK","start":4088,"end":4212,"inode":{"change":2,"pos":3861}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":4434},"to":{"change":2,"start":4434,"end":4532},"introduced_by":2}],"inode":{"change":2,"pos":3861}},"ins_contents":[{"Add":" let stdin = tokio::io::stdin();"},{"Add":" let stdin_reader = BufReader::new(stdin);"},{"Add":" let mut lines = stdin_reader.lines();"}],"del_contents":[{"Del":" let stdin = io::stdin();\n let mut reader = stdin.lock();\n let mut line = String::new();\n"}]}},{"Replacement":{"inode":{"change":2,"pos":3861},"path":"src/bin/test-actor.rs","line":29,"ins":{"up_context":[{"change":2,"pos":4556}],"down_context":[{"change":2,"pos":4608}],"flag":"BLOCK","start":4213,"end":4275,"inode":{"change":2,"pos":3861}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":4556},"to":{"change":2,"start":4556,"end":4608},"introduced_by":2}],"inode":{"change":2,"pos":3861}},"ins_contents":[{"Add":" while let Some(line) = lines.next_line().await.unwrap() {"}],"del_contents":[{"Del":" while let Ok(_) = reader.read_line(&mut line) {\n"}]}},{"Edit":{"inode":{"change":2,"pos":3861},"path":"src/bin/test-actor.rs","line":34,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":4835}],"down_context":[{"change":2,"pos":4835}],"flag":"BLOCK","start":4276,"end":4483,"inode":{"change":2,"pos":3861}}},"contents":[{"Add":""},{"Add":" if count == 5 {"},{"Add":" send_message(&SpawnActor {"},{"Add":" executable: std::path::PathBuf::from(\"/usr/bin/cat\"),"},{"Add":" args: vec![\"-h\".to_string()],"},{"Add":" });"},{"Add":" }"},{"Add":""}]}},{"Edit":{"inode":{"change":2,"pos":3861},"path":"src/bin/test-actor.rs","line":43,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":4836}],"down_context":[{"change":2,"pos":4836}],"flag":"BLOCK","start":4484,"end":4539,"inode":{"change":2,"pos":3861}}},"contents":[{"Add":" if count == 8 {"},{"Add":" return;"},{"Add":" }"},{"Add":""}]}},{"FileAdd":{"meta":{"basename":"LOG.TXT","metadata":0},"context":[{"change":5,"pos":1}],"contents":[{"Add":"0{\"type\":\"Message\",\"from\":null,\"to\":\"35c87090-2182-4d5a-9a64-6cd105722066\",\"payload\":{\"id\":\"35c87090-2182-4d5a-9a64-6cd105722066\"}}"},{"Add":"{\"type\":\"Message\",\"from\":null,\"to\":\"35c87090-2182-4d5a-9a64-6cd105722066\",\"payload\":{\"id\":\"35c87090-2182-4d5a-9a64-6cd105722066\"}}"},{"Add":"{\"type\":\"Message\",\"from\":\"35c87090-2182-4d5a-9a64-6cd105722066\",\"to\":\"35c87090-2182-4d5a-9a64-6cd105722066\",\"payload\":{\"status\":\"ok\",\"count\":1}}"}]}}],"owner":"hardliner66","repo":"uaf","token":"PfrIJrZUAPzJ/wXxEi/DBg2d1qp11LU6tOPKgXOw9wU=","login":null}

…

Dependencies

Change contents