refactor: [MR-603] Typed canister queues and references

rs/execution_environment/src/hypervisor/tests.rs

@@ -5414,7 +5414,6 @@ fn call_with_best_effort_response_test_helper(
     match test
         .canister_state_mut(canister_receiver)
         .system_state
-        .queues_mut()
         .pop_input()
         .unwrap()
     {

rs/messaging/src/routing/stream_builder/tests.rs

@@ -1018,11 +1018,7 @@ fn canister_states_with_outputs<M: Into<RequestOrResponse>>(
                     NO_DEADLINE,
                 );
                 push_input(canister_state, req.into());
-                canister_state
-                    .system_state
-                    .queues_mut()
-                    .pop_input()
-                    .unwrap();
+                canister_state.system_state.pop_input().unwrap();
 
                 canister_state.push_output_response(rep);
             }

rs/protobuf/def/state/queues/v1/queues.proto

@@ -195,6 +195,15 @@ message CanisterQueues {
   repeated CanisterQueuePair canister_queues = 9;
   MessagePool pool = 10;
 
+  // A reference to a callback, used as a compact reject response (e.g. an
+  // expired best-effort callback; or one whose response was shed while in an
+  // input queue.
+  message CallbackReference {
+    uint64 id = 1;
+    uint64 callback_id = 2;
+  }
+  repeated CallbackReference shed_responses = 12;
+
   enum NextInputQueue {
     NEXT_INPUT_QUEUE_UNSPECIFIED = 0;
     NEXT_INPUT_QUEUE_LOCAL_SUBNET = 1;

rs/protobuf/src/gen/state/state.queues.v1.rs

@@ -270,6 +270,8 @@ pub struct CanisterQueues {
     pub canister_queues: ::prost::alloc::vec::Vec<canister_queues::CanisterQueuePair>,
     #[prost(message, optional, tag = "10")]
     pub pool: ::core::option::Option<MessagePool>,
+    #[prost(message, repeated, tag = "12")]
+    pub shed_responses: ::prost::alloc::vec::Vec<canister_queues::CallbackReference>,
     #[prost(enumeration = "canister_queues::NextInputQueue", tag = "6")]
     pub next_input_source: i32,
     #[prost(message, repeated, tag = "7")]
@@ -293,6 +295,17 @@ pub mod canister_queues {
         #[prost(message, optional, tag = "3")]
         pub output_queue: ::core::option::Option<super::CanisterQueue>,
     }
+    /// A reference to a callback, used as a compact reject response (e.g. an
+    /// expired best-effort callback; or one whose response was shed while in an
+    /// input queue.
+    #[allow(clippy::derive_partial_eq_without_eq)]
+    #[derive(Clone, PartialEq, ::prost::Message)]
+    pub struct CallbackReference {
+        #[prost(uint64, tag = "1")]
+        pub id: u64,
+        #[prost(uint64, tag = "2")]
+        pub callback_id: u64,
+    }
     #[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
     #[repr(i32)]
     pub enum NextInputQueue {

rs/protobuf/src/gen/types/state.queues.v1.rs

@@ -265,6 +265,8 @@ pub struct CanisterQueues {
     pub canister_queues: ::prost::alloc::vec::Vec<canister_queues::CanisterQueuePair>,
     #[prost(message, optional, tag = "10")]
     pub pool: ::core::option::Option<MessagePool>,
+    #[prost(message, repeated, tag = "12")]
+    pub shed_responses: ::prost::alloc::vec::Vec<canister_queues::CallbackReference>,
     #[prost(enumeration = "canister_queues::NextInputQueue", tag = "6")]
     pub next_input_source: i32,
     #[prost(message, repeated, tag = "7")]
@@ -288,6 +290,17 @@ pub mod canister_queues {
         #[prost(message, optional, tag = "3")]
         pub output_queue: ::core::option::Option<super::CanisterQueue>,
     }
+    /// A reference to a callback, used as a compact reject response (e.g. an
+    /// expired best-effort callback; or one whose response was shed while in an
+    /// input queue.
+    #[allow(clippy::derive_partial_eq_without_eq)]
+    #[derive(Clone, PartialEq, ::prost::Message)]
+    pub struct CallbackReference {
+        #[prost(uint64, tag = "1")]
+        pub id: u64,
+        #[prost(uint64, tag = "2")]
+        pub callback_id: u64,
+    }
     #[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
     #[repr(i32)]
     pub enum NextInputQueue {