test: add nextest.toml to limit concurrency

.config/nextest.toml

@@ -1,6 +1,14 @@
 [test-groups]
-rest-service-same-port = { max-threads = 1 }
+serial-integration = { max-threads = 1 }
+
+[[profile.default.overrides]]
+filter = 'package(solana-listener)'
+threads-required = 2
+
+[[profile.default.overrides]]
+filter = 'package(solana-event-forwarder)'
+threads-required = 2
 
 [[profile.default.overrides]]
 filter = 'package(rest-service)'
-test-group = 'rest-service-same-port'
+test-group = 'serial-integration'

crates/solana-event-forwarder/src/component.rs

@@ -614,7 +614,6 @@ mod tests {
     use crate::SolanaEventForwarder;
 
     #[test_log::test(tokio::test)]
-    #[serial]
     async fn event_forwrding_only_call_contract() {
         // setup
         let (mut fixture, rpc_client) = setup().await;
@@ -684,7 +683,6 @@ mod tests {
     }
 
     #[test_log::test(tokio::test)]
-    #[serial]
     async fn event_forwrding_message_approved() {
         // setup
         let (mut fixture, rpc_client) = setup().await;
@@ -778,7 +776,6 @@ mod tests {
     }
 
     #[test_log::test(tokio::test)]
-    #[serial]
     async fn event_forwrding_two_message_approved() {
         // setup
         let (mut fixture, rpc_client) = setup().await;
@@ -901,7 +898,6 @@ mod tests {
     }
 
     #[test_log::test(tokio::test)]
-    #[serial]
     async fn event_forwrding_execute_message() {
         // setup
         let (mut fixture, rpc_client) = setup().await;
@@ -1191,7 +1187,6 @@ mod tests {
     }
 
     #[test_log::test(tokio::test)]
-    #[serial]
     async fn event_forwrding_only_gas_event() {
         // setup
         let (mut fixture, rpc_client) = setup().await;
@@ -1278,7 +1273,6 @@ mod tests {
     }
 
     #[test_log::test(tokio::test)]
-    #[serial]
     async fn event_forwrding_with_gas_and_contract_call() {
         // setup
         let (mut fixture, rpc_client) = setup().await;

crates/solana-listener/src/component/signature_batch_scanner.rs

@@ -333,13 +333,11 @@ pub(crate) mod test {
     }
 
     #[test_log::test(tokio::test)]
-    #[serial]
     async fn can_initialize_gateway() {
         let _fixture = setup().await;
     }
 
     #[test_log::test(tokio::test)]
-    #[serial]
     async fn signature_range_fetcher() {
         let mut fixture = setup().await;
         let (gas_config, gas_init_sig, counter_pda, _init_memo_sig) =
@@ -466,7 +464,6 @@ pub(crate) mod test {
     }
 
     #[test_log::test(tokio::test)]
-    #[serial]
     async fn fetch_large_range_of_signatures() {
         let mut fixture = setup().await;
         let (gas_config, _gas_init_sig, counter_pda, _init_memo_sig) =