{"header":{"message":"Implement UNIX signal receiver for controlled shutdown.","description":null,"timestamp":"2022-08-05T19:33:54.9161205Z","authors":[{}]},"hash":"FPX4JMCJTVSWMV76OY5NIZ6IOZ4GGNLGAX5J43EBBHR3XRXTLMWAC","authors":[{"login":"mvarjon","key":"BmtceA6r9wJnMV6vSg14Vz97AmUdThh226FwF1GeXMqC"}],"deps":{"hashes":[["FPX4JMCJTVSWMV76OY5NIZ6IOZ4GGNLGAX5J43EBBHR3XRXTLMWAC","Implement UNIX signal receiver for controlled shutdown."],["AA",null],["DBEJ4WF23FBK5QPXENXCT6P43JBJQU36RGYMQT5CAA53EZUCW7VQC","Abstract the stop conditions coming from OS."],["QMX7PEQ2HRFG5D52OIVRHBDTWV2DHLZ2GQPDD5AMEC5CGZDAJG4QC","Revision 2 of the Mediator interface structure."],["JDHEU3V74X2S4XHZQKWZIN4DPY7X3QZCIKMF7UYNUO3ZTLQLK55AC","Revision 4 of the Mediator struct (starting point for async)."],["IX73DI3JJBWPP7NDCWXD6OFZVHC6LPEMEWUGLAO2W3DW2UZPDLNAC","Setup logging infrastructure."],["WZU7DT3XXIH4WXNZEHZJBTW6PUMQDTHAUIX7EGV6NZYPZXUJU3GQC","Handle Ctrl+C from terminal."],["EQDUMQSNRCJGYQZL4M6GODYKUG2UMO4G5VWESE6DK4BMWJKGC3HQC","Basic high level architecture draft."],["YYIJHZJACO7NJWIPN5JNJ225Y2Q7KWQKGYAHPRSKAVAFCROAMS5QC","Starting template for the IRC server code."],["FPW5OOEALUVPYC23DNZOCEYLPHSNB2FPNHHIX6MQKWWARO6BA5BQC","Add dependency to tokio crate in preparation for async modifications."]],"deps":["DBEJ4WF23FBK5QPXENXCT6P43JBJQU36RGYMQT5CAA53EZUCW7VQC"],"known":["EQDUMQSNRCJGYQZL4M6GODYKUG2UMO4G5VWESE6DK4BMWJKGC3HQC","QMX7PEQ2HRFG5D52OIVRHBDTWV2DHLZ2GQPDD5AMEC5CGZDAJG4QC","JDHEU3V74X2S4XHZQKWZIN4DPY7X3QZCIKMF7UYNUO3ZTLQLK55AC","IX73DI3JJBWPP7NDCWXD6OFZVHC6LPEMEWUGLAO2W3DW2UZPDLNAC","WZU7DT3XXIH4WXNZEHZJBTW6PUMQDTHAUIX7EGV6NZYPZXUJU3GQC"]},"hunks":[{"Replacement":{"inode":{"change":2,"pos":40},"path":"src/signal_guard.rs","line":1,"ins":{"up_context":[{"change":2,"pos":40}],"down_context":[],"flag":"BLOCK","start":0,"end":2856,"inode":{"change":2,"pos":40}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":40},"to":{"change":2,"start":41,"end":239},"introduced_by":2}],"inode":{"change":2,"pos":40}},"ins_contents":[{"Add":"use futures::prelude::*;"},{"Add":"use futures::stream::FuturesUnordered;"},{"Add":"use log::info;"},{"Add":"use std::collections::HashMap;"},{"Add":"use tokio::signal::unix::{signal, SignalKind};"},{"Add":"use tokio::sync::broadcast::Sender;"},{"Add":""},{"Add":"pub struct SignalGuard {}"},{"Add":""},{"Add":"impl SignalGuard {"},{"Add":" pub async fn wait_for_stop(signal_forwarder: &Sender) -> Option<()> {"},{"Add":" // Default behavior in UNIX is to terminate process when any of the"},{"Add":" // following signals are received. In each of these case we initiate"},{"Add":" // the controlled shutdown."},{"Add":" let mut interrupt_stream = signal(SignalKind::interrupt()).ok()?;"},{"Add":" let mut terminate_stream = signal(SignalKind::terminate()).ok()?;"},{"Add":" let mut alarm_stream = signal(SignalKind::alarm()).ok()?;"},{"Add":" let mut hangup_stream = signal(SignalKind::hangup()).ok()?;"},{"Add":" let mut quit_stream = signal(SignalKind::quit()).ok()?;"},{"Add":" let mut user_defined1_stream = signal(SignalKind::user_defined1()).ok()?;"},{"Add":" let mut user_defined2_stream = signal(SignalKind::user_defined2()).ok()?;"},{"Add":""},{"Add":" let interrupt_future = interrupt_stream.recv();"},{"Add":" let terminate_future = terminate_stream.recv();"},{"Add":" let alarm_future = alarm_stream.recv();"},{"Add":" let hangup_future = hangup_stream.recv();"},{"Add":" let quit_future = quit_stream.recv();"},{"Add":" let user_defined1_future = user_defined1_stream.recv();"},{"Add":" let user_defined2_future = user_defined2_stream.recv();"},{"Add":""},{"Add":" let all_futures = vec!["},{"Add":" interrupt_future,"},{"Add":" terminate_future,"},{"Add":" alarm_future,"},{"Add":" hangup_future,"},{"Add":" quit_future,"},{"Add":" user_defined1_future,"},{"Add":" user_defined2_future,"},{"Add":" ];"},{"Add":""},{"Add":" let mut signal_map = HashMap::with_capacity(all_futures.len());"},{"Add":""},{"Add":" signal_map.insert(0, SignalKind::interrupt().as_raw_value());"},{"Add":" signal_map.insert(1, SignalKind::terminate().as_raw_value());"},{"Add":" signal_map.insert(2, SignalKind::alarm().as_raw_value());"},{"Add":" signal_map.insert(3, SignalKind::hangup().as_raw_value());"},{"Add":" signal_map.insert(4, SignalKind::quit().as_raw_value());"},{"Add":" signal_map.insert(5, SignalKind::user_defined1().as_raw_value());"},{"Add":" signal_map.insert(6, SignalKind::user_defined2().as_raw_value());"},{"Add":""},{"Add":" let all_futures = all_futures"},{"Add":" .into_iter()"},{"Add":" .enumerate()"},{"Add":" .map(|(i, fut)| fut.map(move |res| (i, res)))"},{"Add":" .collect::>();"},{"Add":""},{"Add":" // use collection as a stream, await only first 1 future to complete"},{"Add":" let first_one = all_futures.take(1).collect::>().await;"},{"Add":" let signal_index = first_one[0].0;"},{"Add":""},{"Add":" // Currently we mask all signals to SIGTERM."},{"Add":" let received = signal_map[&signal_index];"},{"Add":""},{"Add":" info!(\"SIGNAL_GUARD: RECEIVED CODE {} FROM OS\", received);"},{"Add":""},{"Add":" signal_forwarder.send(received).unwrap();"},{"Add":""},{"Add":" Option::Some(())"},{"Add":" }"},{"Add":"}"}],"del_contents":[{"Del":"use tokio::signal;\n\npub struct SignalGuard {}\n\nimpl SignalGuard {\n pub async fn wait_for_stop() -> Result<(), std::io::Error> {\n let guard = signal::ctrl_c().await;\n\n guard\n }\n}\n"}]}},{"Replacement":{"inode":{"change":3,"pos":36},"path":"src/shutdown.rs","line":1,"ins":{"up_context":[{"change":3,"pos":36}],"down_context":[],"flag":"BLOCK","start":2857,"end":3675,"inode":{"change":3,"pos":36}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":36},"to":{"change":2,"start":240,"end":1058},"introduced_by":2}],"inode":{"change":3,"pos":36}},"ins_contents":[{"Add":"// Adapted from: https://github.com/tokio-rs/mini-redis/blob/069a8e5ee0de445ad3e642548d196ef6b4fa8bc1/src/shutdown.rs"},{"Add":""},{"Add":"use tokio::sync::broadcast;"},{"Add":""},{"Add":"pub struct Shutdown {"},{"Add":" /// The receive half of the channel used to listen for shutdown."},{"Add":" notify: broadcast::Receiver,"},{"Add":"}"},{"Add":""},{"Add":"impl Shutdown {"},{"Add":" /// Create a new `Shutdown` backed by the given `broadcast::Receiver`."},{"Add":" pub fn new(notify: broadcast::Receiver) -> Self {"},{"Add":" Self { notify }"},{"Add":" }"},{"Add":""},{"Add":" #[allow(dead_code)]"},{"Add":" pub fn replicate(&self) -> Self {"},{"Add":" Self {"},{"Add":" notify: self.notify.resubscribe(),"},{"Add":" }"},{"Add":" }"},{"Add":""},{"Add":" /// Receive the shutdown notice, waiting if necessary."},{"Add":" pub async fn recv(&mut self) {"},{"Add":" // Cannot receive a \"lag error\" as only one value is ever sent."},{"Add":" let _ = self.notify.recv().await;"},{"Add":" }"},{"Add":"}"}],"del_contents":[{"Del":"// Adapted from: https://github.com/tokio-rs/mini-redis/blob/069a8e5ee0de445ad3e642548d196ef6b4fa8bc1/src/shutdown.rs\n\nuse tokio::sync::broadcast;\n\npub struct Shutdown {\n /// The receive half of the channel used to listen for shutdown.\n notify: broadcast::Receiver,\n}\n\nimpl Shutdown {\n /// Create a new `Shutdown` backed by the given `broadcast::Receiver`.\n pub fn new(notify: broadcast::Receiver) -> Self {\n Self { notify }\n }\n\n #[allow(dead_code)]\n pub fn replicate(&self) -> Self {\n Self {\n notify: self.notify.resubscribe(),\n }\n }\n\n /// Receive the shutdown notice, waiting if necessary.\n pub async fn recv(&mut self) {\n // Cannot receive a \"lag error\" as only one value is ever sent.\n let _ = self.notify.recv().await;\n }\n}\n"}]}},{"Replacement":{"inode":{"change":3,"pos":891},"path":"src/service.rs","line":1,"ins":{"up_context":[{"change":3,"pos":891}],"down_context":[],"flag":"BLOCK","start":3676,"end":4115,"inode":{"change":3,"pos":891}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":891},"to":{"change":2,"start":1059,"end":1498},"introduced_by":2}],"inode":{"change":3,"pos":891}},"ins_contents":[{"Add":"use tokio::time::{sleep, Duration};"},{"Add":"pub struct Service {}"},{"Add":""},{"Add":"pub struct ServiceError {}"},{"Add":""},{"Add":"impl Service {"},{"Add":" pub fn new() -> Self {"},{"Add":" Self {}"},{"Add":" }"},{"Add":""},{"Add":" pub async fn wait(&self) -> Result {"},{"Add":" sleep(Duration::from_secs(7)).await;"},{"Add":" Result::Ok(117)"},{"Add":" }"},{"Add":""},{"Add":" pub async fn serve(&self, _handle: u64) -> Result<(), ServiceError> {"},{"Add":" sleep(Duration::from_secs(15)).await;"},{"Add":" Result::Ok(())"},{"Add":" }"},{"Add":"}"}],"del_contents":[{"Del":"use tokio::time::{sleep, Duration};\npub struct Service {}\n\npub struct ServiceError {}\n\nimpl Service {\n pub fn new() -> Self {\n Self {}\n }\n\n pub async fn wait(&self) -> Result {\n sleep(Duration::from_secs(7)).await;\n Result::Ok(117)\n }\n\n pub async fn serve(&self, _handle: u64) -> Result<(), ServiceError> {\n sleep(Duration::from_secs(15)).await;\n Result::Ok(())\n }\n}\n"}]}},{"Edit":{"inode":{"change":9,"pos":49},"path":"src/main.rs","line":4,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":1537}],"down_context":[{"change":3,"pos":2673}],"flag":"BLOCK","start":4116,"end":4130,"inode":{"change":9,"pos":49}}},"contents":[{"Add":"use exitcode;"}]}},{"Replacement":{"inode":{"change":9,"pos":49},"path":"src/main.rs","line":34,"ins":{"up_context":[{"change":3,"pos":3490}],"down_context":[{"change":3,"pos":2200}],"flag":"BLOCK","start":4131,"end":4210,"inode":{"change":9,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3490},"to":{"change":2,"start":1557,"end":1604},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":1604},"to":{"change":3,"start":3525,"end":3733},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3525},"to":{"change":3,"start":3525,"end":3733},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3733},"to":{"change":2,"start":1605,"end":1662},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":1662},"to":{"change":3,"start":3782,"end":3891},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3782},"to":{"change":3,"start":3782,"end":3891},"introduced_by":3},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3891},"to":{"change":2,"start":1663,"end":1726},"introduced_by":2},{"previous":"","flag":"DELETED","from":{"change":2,"pos":1726},"to":{"change":3,"start":3939,"end":4160},"introduced_by":2},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":3939},"to":{"change":3,"start":3939,"end":4160},"introduced_by":3}],"inode":{"change":9,"pos":49}},"ins_contents":[{"Add":" info!(\"MAIN: PARKED\");"},{"Add":" SignalGuard::wait_for_stop(&shutdown_tx).await;"}],"del_contents":[{"Del":" match SignalGuard::wait_for_stop().await {\n"},{"Del":" Ok(()) =>\n // Once we receive the signal here we need\n // to be sure that we exit the application\n // as e.g. CTRL-C is no longer processed if\n // pressed again.\n {\n"},{"Del":" info!(\"MAIN: STOP SIGNAL RECEIVED FROM OS\");\n"},{"Del":" // SIGTERM is 15\n let received = 15;\n shutdown_tx.send(received).unwrap();\n"},{"Del":" info!(\"MAIN: SEND STOP CONTROL SIGNAL TO SERVER\");\n"},{"Del":" }\n Err(err) => {\n error!(\"MAIN: Unable to listen for shutdown signal: {}\", err);\n // we also shut down in case of error\n panic!(\"MAIN: Abnormal shutdown.\");\n }\n }\n"}]}},{"Edit":{"inode":{"change":9,"pos":49},"path":"src/main.rs","line":37,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":2201}],"down_context":[{"change":3,"pos":4161}],"flag":"BLOCK","start":4211,"end":4315,"inode":{"change":9,"pos":49}}},"contents":[{"Add":" info!(\"MAIN: STOP SIGNAL RECEIVED FROM OS\");"},{"Add":" info!(\"MAIN: SEND STOP CONTROL SIGNAL TO SERVER\");"}]}},{"Edit":{"inode":{"change":9,"pos":49},"path":"src/main.rs","line":40,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4198}],"down_context":[{"change":3,"pos":2201}],"flag":"BLOCK","start":4316,"end":4317,"inode":{"change":9,"pos":49}}},"contents":[{"Add":""}]}},{"Replacement":{"inode":{"change":9,"pos":49},"path":"src/main.rs","line":46,"ins":{"up_context":[{"change":3,"pos":4259}],"down_context":[{"change":3,"pos":4280}],"flag":"BLOCK","start":4318,"end":4350,"inode":{"change":9,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":4259},"to":{"change":3,"start":4259,"end":4280},"introduced_by":3}],"inode":{"change":9,"pos":49}},"ins_contents":[{"Add":" exit(exitcode::OK);"}],"del_contents":[{"Del":" exit(0);\n"}]}},{"Replacement":{"inode":{"change":9,"pos":49},"path":"src/main.rs","line":50,"ins":{"up_context":[{"change":2,"pos":1819}],"down_context":[{"change":2,"pos":1841}],"flag":"BLOCK","start":4351,"end":4389,"inode":{"change":9,"pos":49}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1819},"to":{"change":2,"start":1819,"end":1841},"introduced_by":2}],"inode":{"change":9,"pos":49}},"ins_contents":[{"Add":" exit(exitcode::SOFTWARE);"}],"del_contents":[{"Del":" exit(-1);\n"}]}},{"Replacement":{"inode":{"change":3,"pos":2991},"path":"log4rs.config.yml","line":1,"ins":{"up_context":[{"change":3,"pos":2991}],"down_context":[],"flag":"BLOCK","start":4390,"end":4503,"inode":{"change":3,"pos":2991}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":2991},"to":{"change":2,"start":1852,"end":1965},"introduced_by":2}],"inode":{"change":3,"pos":2991}},"ins_contents":[{"Add":"refresh_rate: 30 seconds"},{"Add":""},{"Add":"appenders:"},{"Add":" stdout:"},{"Add":" kind: console"},{"Add":""},{"Add":"root:"},{"Add":" level: trace"},{"Add":" appenders:"},{"Add":" - stdout"}],"del_contents":[{"Del":"refresh_rate: 30 seconds\n\nappenders:\n stdout:\n kind: console\n\nroot:\n level: trace\n appenders:\n - stdout\n"}]}},{"Replacement":{"inode":{"change":3,"pos":1080},"path":"adr/Design.md","line":1,"ins":{"up_context":[{"change":3,"pos":1080}],"down_context":[],"flag":"BLOCK","start":4504,"end":8017,"inode":{"change":3,"pos":1080}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":3,"pos":1080},"to":{"change":2,"start":1966,"end":5479},"introduced_by":2}],"inode":{"change":3,"pos":1080}},"ins_contents":[{"Add":"# Concepts"},{"Add":""},{"Add":"This chapter describes the core concepts around the implementation and the IRC specification. Some material may be restated from the source but it is gathered here for reference purposes."},{"Add":""},{"Add":"## IRC"},{"Add":""},{"Add":"For the core IRC concepts see: [IRC concepts](https://modern.ircdocs.horse/#irc-concepts)"},{"Add":""},{"Add":"## Implementation"},{"Add":""},{"Add":"### Client"},{"Add":""},{"Add":"This is something that sends bytes to our server according to the IRC protocol (something that communicates with the server but is not a server). This is also something outside of this implementation and this is modelled as something from which we receive and send bytes to."},{"Add":""},{"Add":"### Server"},{"Add":""},{"Add":"This is our implementation which communicates with the client and other servers in the same network. According to IRC specification network consists of servers and even though there is server to server protocols available in practise one network consists of same server implementations and they can use any protocol they wish to communicate state changes between them. We will utilize this in our implementation."},{"Add":""},{"Add":"### User"},{"Add":""},{"Add":"This entity models a real user (either human or bot) which uses the client to communicate with our server."},{"Add":""},{"Add":"### Channel"},{"Add":""},{"Add":"Channels represent the logical conversation groups in an IRC network. These are synced between servers in the network. This entity ties users to channels in which they can exchange messages."},{"Add":""},{"Add":"### Capability"},{"Add":""},{"Add":"When the client connects to the server they first have an exchange of information which tells the client what capabilities the server provides. This allows the client to establish reasonable communication with the server. In the implementation different capabilities are implemented in a modular manner which are queried during runtime to provide the capability information to the client."},{"Add":""},{"Add":"# Architecture"},{"Add":""},{"Add":"In general principle we follow modular monolith approach where we have a single executable for the application but that application is composed of modules which are independent and focus on specific features (capabilities) and the runtime then ties these together. In addition there are modules which handles the low-level work of communication."},{"Add":""},{"Add":"## Components"},{"Add":""},{"Add":"### Server"},{"Add":""},{"Add":"This is the main high-level component that drives our server instance."},{"Add":""},{"Add":"#### Capability"},{"Add":""},{"Add":"There are multiple capability components that each implement a specific functionality to the server."},{"Add":""},{"Add":"### Pool"},{"Add":""},{"Add":"This is the component which tracks the running service instance in the network it is attached to. Network can consist of single server instance. State changes in this instance are then propagated to other servers in pool."},{"Add":""},{"Add":"#### Server Communicator"},{"Add":""},{"Add":"This sub-component of the pool manages the communication between server instances."},{"Add":""},{"Add":"### State Manager"},{"Add":""},{"Add":"This component maintains the state information (users, channels, etc.) for the current instance. It is linked to the pool component and the pool observes the changes in the state manager and propagates them forward and vice versa. That is pool may receive state update from a different server instance and pool then signals these changes to this instance's state manager."},{"Add":""},{"Add":"### Protocol Stack"},{"Add":""},{"Add":"This component maintains the reference information for different communication and message components about specific IRC code constants and other similar information in the IRC protocol."},{"Add":""},{"Add":"### Communicator"},{"Add":""},{"Add":"This component is responsible for sending and receiving bytes between client and server. It ensures the correct formatting of messages and their validation. This component is also linked to the state manager."}],"del_contents":[{"Del":"# Concepts\n\nThis chapter describes the core concepts around the implementation and the IRC specification. Some material may be restated from the source but it is gathered here for reference purposes.\n\n## IRC\n\nFor the core IRC concepts see: [IRC concepts](https://modern.ircdocs.horse/#irc-concepts)\n\n## Implementation\n\n### Client\n\nThis is something that sends bytes to our server according to the IRC protocol (something that communicates with the server but is not a server). This is also something outside of this implementation and this is modelled as something from which we receive and send bytes to.\n\n### Server\n\nThis is our implementation which communicates with the client and other servers in the same network. According to IRC specification network consists of servers and even though there is server to server protocols available in practise one network consists of same server implementations and they can use any protocol they wish to communicate state changes between them. We will utilize this in our implementation.\n\n### User\n\nThis entity models a real user (either human or bot) which uses the client to communicate with our server.\n\n### Channel\n\nChannels represent the logical conversation groups in an IRC network. These are synced between servers in the network. This entity ties users to channels in which they can exchange messages.\n\n### Capability\n\nWhen the client connects to the server they first have an exchange of information which tells the client what capabilities the server provides. This allows the client to establish reasonable communication with the server. In the implementation different capabilities are implemented in a modular manner which are queried during runtime to provide the capability information to the client.\n\n# Architecture\n\nIn general principle we follow modular monolith approach where we have a single executable for the application but that application is composed of modules which are independent and focus on specific features (capabilities) and the runtime then ties these together. In addition there are modules which handles the low-level work of communication.\n\n## Components\n\n### Server\n\nThis is the main high-level component that drives our server instance.\n\n#### Capability\n\nThere are multiple capability components that each implement a specific functionality to the server.\n\n### Pool\n\nThis is the component which tracks the running service instance in the network it is attached to. Network can consist of single server instance. State changes in this instance are then propagated to other servers in pool.\n\n#### Server Communicator\n\nThis sub-component of the pool manages the communication between server instances.\n\n### State Manager\n\nThis component maintains the state information (users, channels, etc.) for the current instance. It is linked to the pool component and the pool observes the changes in the state manager and propagates them forward and vice versa. That is pool may receive state update from a different server instance and pool then signals these changes to this instance's state manager.\n\n### Protocol Stack\n\nThis component maintains the reference information for different communication and message components about specific IRC code constants and other similar information in the IRC protocol.\n\n### Communicator\n\nThis component is responsible for sending and receiving bytes between client and server. It ensures the correct formatting of messages and their validation. This component is also linked to the state manager.\n"}]}},{"Edit":{"inode":{"change":9,"pos":123},"path":"Cargo.toml","line":11,"atom":{"NewVertex":{"up_context":[{"change":9,"pos":395}],"down_context":[{"change":3,"pos":3106}],"flag":"BLOCK","start":8018,"end":8037,"inode":{"change":9,"pos":123}}},"contents":[{"Add":"exitcode = \"1.1.2\""}]}},{"Edit":{"inode":{"change":9,"pos":123},"path":"Cargo.toml","line":13,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":3121}],"down_context":[{"change":3,"pos":3121}],"flag":"BLOCK","start":8038,"end":8057,"inode":{"change":9,"pos":123}}},"contents":[{"Add":"futures = \"0.3.21\""}]}},{"Edit":{"inode":{"change":9,"pos":431},"path":"Cargo.lock","line":66,"atom":{"NewVertex":{"up_context":[{"change":10,"pos":1955}],"down_context":[{"change":3,"pos":4128}],"flag":"BLOCK","start":8058,"end":8250,"inode":{"change":9,"pos":431}}},"contents":[{"Add":"name = \"exitcode\""},{"Add":"version = \"1.1.2\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"de853764b47027c2e862a995c34978ffa63c1501f2e15f987ba11bd4f9bba193\""},{"Add":""},{"Add":"[[package]]"}]}},{"Edit":{"inode":{"change":9,"pos":431},"path":"Cargo.lock","line":76,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4302}],"down_context":[{"change":3,"pos":4302}],"flag":"BLOCK","start":8251,"end":10522,"inode":{"change":9,"pos":431}}},"contents":[{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"futures\""},{"Add":"version = \"0.3.21\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"f73fe65f54d1e12b726f517d3e2135ca3125a437b6d998caf1962961f7172d9e\""},{"Add":"dependencies = ["},{"Add":" \"futures-channel\","},{"Add":" \"futures-core\","},{"Add":" \"futures-executor\","},{"Add":" \"futures-io\","},{"Add":" \"futures-sink\","},{"Add":" \"futures-task\","},{"Add":" \"futures-util\","},{"Add":"]"},{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"futures-channel\""},{"Add":"version = \"0.3.21\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"c3083ce4b914124575708913bca19bfe887522d6e2e6d0952943f5eac4a74010\""},{"Add":"dependencies = ["},{"Add":" \"futures-core\","},{"Add":" \"futures-sink\","},{"Add":"]"},{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"futures-core\""},{"Add":"version = \"0.3.21\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"0c09fd04b7e4073ac7156a9539b57a484a8ea920f79c7c675d05d289ab6110d3\""},{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"futures-executor\""},{"Add":"version = \"0.3.21\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"9420b90cfa29e327d0429f19be13e7ddb68fa1cccb09d65e5706b8c7a749b8a6\""},{"Add":"dependencies = ["},{"Add":" \"futures-core\","},{"Add":" \"futures-task\","},{"Add":" \"futures-util\","},{"Add":"]"},{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"futures-io\""},{"Add":"version = \"0.3.21\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"fc4045962a5a5e935ee2fdedaa4e08284547402885ab326734432bed5d12966b\""},{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"futures-macro\""},{"Add":"version = \"0.3.21\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"33c1e13800337f4d4d7a316bf45a567dbcb6ffe087f16424852d97e97a91f512\""},{"Add":"dependencies = ["},{"Add":" \"proc-macro2\","},{"Add":" \"quote\","},{"Add":" \"syn\","},{"Add":"]"},{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"futures-sink\""},{"Add":"version = \"0.3.21\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"21163e139fa306126e6eedaf49ecdb4588f939600f0b1e770f4205ee4b7fa868\""},{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"futures-task\""},{"Add":"version = \"0.3.21\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"57c66a976bf5909d801bbef33416c41372779507e7a6b3a5e25e4749c58f776a\""},{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"futures-util\""},{"Add":"version = \"0.3.21\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"d8b7abd5d659d9b90c8cba917f6ec750a74e2dc23902ef9cd4cc8c8b22e6036a\""},{"Add":"dependencies = ["},{"Add":" \"futures-channel\","},{"Add":" \"futures-core\","},{"Add":" \"futures-io\","},{"Add":" \"futures-macro\","},{"Add":" \"futures-sink\","},{"Add":" \"futures-task\","},{"Add":" \"memchr\","},{"Add":" \"pin-project-lite\","},{"Add":" \"pin-utils\","},{"Add":" \"slab\","},{"Add":"]"}]}},{"Edit":{"inode":{"change":9,"pos":431},"path":"Cargo.lock","line":271,"atom":{"NewVertex":{"up_context":[{"change":10,"pos":2829}],"down_context":[{"change":3,"pos":5964}],"flag":"BLOCK","start":10523,"end":10548,"inode":{"change":9,"pos":431}}},"contents":[{"Add":" \"exitcode\","},{"Add":" \"futures\","}]}},{"Edit":{"inode":{"change":9,"pos":431},"path":"Cargo.lock","line":368,"atom":{"NewVertex":{"up_context":[{"change":10,"pos":4444}],"down_context":[{"change":10,"pos":4444}],"flag":"BLOCK","start":10549,"end":10742,"inode":{"change":9,"pos":431}}},"contents":[{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"pin-utils\""},{"Add":"version = \"0.1.0\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"8b870d8c151b6f2fb93e84a13146138f05d02ed11c7e7c54f8826aaaf7c9f184\""}]}},{"Edit":{"inode":{"change":9,"pos":431},"path":"Cargo.lock","line":474,"atom":{"NewVertex":{"up_context":[{"change":10,"pos":5556}],"down_context":[{"change":10,"pos":5556}],"flag":"BLOCK","start":10743,"end":10962,"inode":{"change":9,"pos":431}}},"contents":[{"Add":"]"},{"Add":""},{"Add":"[[package]]"},{"Add":"name = \"slab\""},{"Add":"version = \"0.4.7\""},{"Add":"source = \"registry+https://github.com/rust-lang/crates.io-index\""},{"Add":"checksum = \"4614a76b2a8be0058caa9dbbaf66d988527d86d003c11a94fbd335d7661edcef\""},{"Add":"dependencies = ["},{"Add":" \"autocfg\","}]}}],"owner":"mvarjon","repo":"plan9","token":"kZTzlfBkYY2kBioQNrbezpebcWZeNsBeTNM5v7xmEB4=","login":null}

…

Dependencies

Change contents