chore: bump ajj 0.3.4 → 0.7.0

ResponsePayload changed from enum (Success/Failure) to newtype
struct wrapping Result. Update all call sites and adapt
subscription notification code to use the new permit-based API.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: prestwich

Cargo.toml

@@ -56,7 +56,7 @@ signet-rpc = { version = "0.16.0", path = "crates/rpc" }
 init4-bin-base = { version = "0.19.0", features = ["alloy"] }
 
 # ajj
-ajj = { version = "0.3.4" }
+ajj = { version = "0.7.0" }
 
 # trevm
 trevm = { version = "0.34.0", features = ["full_env_cfg"] }

crates/rpc/src/debug/endpoints.rs

@@ -90,7 +90,7 @@ where
             tracing::debug!(tx_index = idx, tx_hash = ?tx.hash(), "Traced transaction");
         }
 
-        ResponsePayload::Success(frames)
+        ResponsePayload(Ok(frames))
     }
     .instrument(span);
 
@@ -163,7 +163,7 @@ where
 
         let res = response_tri!(crate::debug::tracer::trace(trevm, &opts, tx_info)).0;
 
-        ResponsePayload::Success(res)
+        ResponsePayload(Ok(res))
     }
     .instrument(span);
 

crates/rpc/src/eth/endpoints.rs

@@ -474,7 +474,7 @@ where
 
         let execution_result = response_tri!(trevm.call().map_err(EvmErrored::into_error)).0;
 
-        ResponsePayload::Success(execution_result)
+        ResponsePayload(Ok(execution_result))
     }
     .instrument(span);
 
@@ -498,14 +498,14 @@ where
     normalize_gas_stateless(&mut params.0, max_gas);
 
     await_handler!(@response_option hctx.spawn_with_ctx(|hctx| async move {
-        let res = match run_call(hctx, params, ctx).await {
-            ResponsePayload::Success(res) => res,
-            ResponsePayload::Failure(err) => return ResponsePayload::Failure(err),
+        let res = match run_call(hctx, params, ctx).await.0 {
+            Ok(res) => res,
+            Err(err) => return ResponsePayload(Err(err)),
         };
 
         match res {
             ExecutionResult::Success { output, .. } => {
-                ResponsePayload::Success(output.data().clone())
+                ResponsePayload(Ok(output.data().clone()))
             }
             ExecutionResult::Revert { output, .. } => {
                 ResponsePayload::internal_error_with_message_and_obj(
@@ -577,7 +577,7 @@ where
         let (estimate, _) = response_tri!(trevm.estimate_gas().map_err(EvmErrored::into_error));
 
         match estimate {
-            EstimationResult::Success { limit, .. } => ResponsePayload::Success(U64::from(limit)),
+            EstimationResult::Success { limit, .. } => ResponsePayload(Ok(U64::from(limit))),
             EstimationResult::Revert { reason, .. } => {
                 ResponsePayload::internal_error_with_message_and_obj(
                     "execution reverted".into(),

crates/rpc/src/inspect/endpoints.rs

@@ -30,7 +30,7 @@ where
             );
         };
 
-        ResponsePayload::Success(output)
+        ResponsePayload(Ok(output))
     };
 
     await_handler!(@response_option hctx.spawn_blocking(task))

crates/rpc/src/interest/subs.rs

@@ -211,7 +211,9 @@ impl SubscriptionTask {
     ) {
         let SubscriptionTask { id, filter, token, mut notifs } = self;
 
-        let Some(sender) = ajj_ctx.notifications() else { return };
+        if !ajj_ctx.notifications_enabled() {
+            return;
+        };
 
         // Buffer for notifications to be sent to the client
         let mut notif_buffer = filter.empty_sub_buffer();
@@ -230,7 +232,9 @@ impl SubscriptionTask {
                 if !notif_buffer.is_empty() {
                     // NB: we reserve half the capacity to avoid blocking other
                     // usage. This is a heuristic and can be adjusted as needed.
-                    sender.reserve_many(min(sender.max_capacity() / 2, notif_buffer.len())).await
+                    ajj_ctx
+                        .permit_many(min(ajj_ctx.notification_capacity() / 2, notif_buffer.len()))
+                        .await
                 } else {
                     // If the notification buffer is empty, just never return
                     pending().await
@@ -263,7 +267,7 @@ impl SubscriptionTask {
                 permits = permit_fut => {
                     let _guard = span.enter();
                     // channel closed
-                    let Ok(permits) = permits else {
+                    let Some(permits) = permits else {
                         trace!("channel to client closed");
                         break
                     };
@@ -291,7 +295,7 @@ impl SubscriptionTask {
                             trace!(?item, "failed to serialize notification");
                             continue
                         };
-                        permit.send(brv);
+                        let _ = permit.send(brv);
                     }
                 }
                 notif_res = notifs.recv() => {

crates/rpc/src/signet/endpoints.rs

@@ -62,7 +62,7 @@ where
 
         response_tri!(trevm.drive_bundle(&mut driver).map_err(|e| e.into_error()));
 
-        ResponsePayload::Success(driver.into_response())
+        ResponsePayload(Ok(driver.into_response()))
     };
 
     let task = async move {