feat: add e2e for internal bridge tx

TESTSINVENTORY.md

@@ -285,6 +285,7 @@ Table of tests currently implemented or being implemented in the E2E repository.
 | Test block gas limit increase to 60M | [Link](./tests/fusaka/eip7935.bats#L19) | |
 | Test execute multiple claimMessages via testClaim with internal reentrancy and bridgeAsset call | [Link](./tests/aggkit/claim-reetrancy.bats#L472) | |
 | Test inject invalid GER on L2 (bridges are valid) | [Link](./tests/aggkit/bridge-sovereign-chain-e2e.bats#L212) | |
+| Test internal bridge transactions -> 2 bridge tx with different amounts | [Link](./tests/aggkit/internal-bridge-tx.bats#L62) | |
 | Test invalid GER injection case A (FEP mode) | [Link](./tests/aggkit/latest-n-injected-ger.bats#L825) | |
 | Test invalid GER injection case A (PP mode) | [Link](./tests/aggkit/latest-n-injected-ger.bats#L716) | |
 | Test invalid GER injection case B2 (FEP mode) | [Link](./tests/aggkit/latest-n-injected-ger.bats#L396) | |

core/contracts/bridgeAsset/InternalBridgeTx.sol

@@ -0,0 +1,111 @@
+// SPDX-License-Identifier: AGPL-3.0
+
+pragma solidity ^0.8.20;
+import "./Interfaces.sol";
+
+contract InternalBridgeTx {
+    event MessageReceived(address destinationAddress);
+    event BridgeTransactionExecuted(uint32 destinationNetwork, address destinationAddress, uint256 amount);
+    event UpdateBridgeParameters();
+
+    IPolygonZkEVMBridgeV2 public immutable bridgeAddress;
+
+    // First bridge transaction parameters
+    uint32 destinationNetwork1;
+    address destinationAddress1;
+    uint256 amount1;
+    address token1;
+    bool forceUpdateGlobalExitRoot1;
+    bytes permitData1;
+
+    // Second bridge transaction parameters
+    uint32 destinationNetwork2;
+    address destinationAddress2;
+    uint256 amount2;
+    address token2;
+    bool forceUpdateGlobalExitRoot2;
+    bytes permitData2;
+
+    bytes data;
+
+    constructor(IPolygonZkEVMBridgeV2 _bridgeAddress) {
+        bridgeAddress = _bridgeAddress;
+    }
+
+    function updateBridgeParameters(
+        // First bridge transaction parameters
+        uint32 _destinationNetwork1,
+        address _destinationAddress1,
+        uint256 _amount1,
+        address _token1,
+        bool _forceUpdateGlobalExitRoot1,
+        bytes calldata _permitData1,
+        // Second bridge transaction parameters
+        uint32 _destinationNetwork2,
+        address _destinationAddress2,
+        uint256 _amount2,
+        address _token2,
+        bool _forceUpdateGlobalExitRoot2,
+        bytes calldata _permitData2
+    ) public {
+        // Set first bridge transaction parameters
+        destinationNetwork1 = _destinationNetwork1;
+        destinationAddress1 = _destinationAddress1;
+        amount1 = _amount1;
+        token1 = _token1;
+        forceUpdateGlobalExitRoot1 = _forceUpdateGlobalExitRoot1;
+        permitData1 = _permitData1;
+
+        // Set second bridge transaction parameters
+        destinationNetwork2 = _destinationNetwork2;
+        destinationAddress2 = _destinationAddress2;
+        amount2 = _amount2;
+        token2 = _token2;
+        forceUpdateGlobalExitRoot2 = _forceUpdateGlobalExitRoot2;
+        permitData2 = _permitData2;
+
+        emit UpdateBridgeParameters();
+    }
+
+    function onMessageReceived(
+        bytes memory data1
+    ) external payable {
+        data = data1;
+
+        // First bridge transaction
+        try bridgeAddress.bridgeAsset{value: amount1}(
+            destinationNetwork1,
+            destinationAddress1,
+            amount1,
+            token1,
+            forceUpdateGlobalExitRoot1,
+            permitData1
+        ) {
+            emit BridgeTransactionExecuted(destinationNetwork1, destinationAddress1, amount1);
+        } catch {
+            // First bridge transaction failed, continue with second transaction
+        }
+
+        // Second bridge transaction
+        try bridgeAddress.bridgeAsset{value: amount2}(
+            destinationNetwork2,
+            destinationAddress2,
+            amount2,
+            token2,
+            forceUpdateGlobalExitRoot2,
+            permitData2
+        ) {
+            emit BridgeTransactionExecuted(destinationNetwork2, destinationAddress2, amount2);
+        } catch {
+            // Second bridge transaction failed, transaction continues
+        }
+
+        emit MessageReceived(msg.sender);
+    }
+
+    // Function to receive ETH
+    receive() external payable {}
+
+    // Fallback function
+    fallback() external payable {}
+}

core/helpers/agglayer-cdk-common-setup.bash

@@ -119,7 +119,7 @@ _resolve_required_urls() {
 
     # AGGKIT_BRIDGE_URL
     aggkit_bridge_url=$(_resolve_url_or_use_env AGGKIT_BRIDGE_URL \
-        "aggkit-001-bridge" "rest" "cdk-node-001" "rest" \
+        "aggkit-001" "rest" "cdk-node-001" "rest" \
         "Failed to resolve aggkit bridge url from all fallback nodes" true)
     export aggkit_bridge_url
 

core/helpers/scripts/aggkit_bridge_service.bash

@@ -515,6 +515,53 @@ function get_bridge() {
     return 1
 }
 
+function get_total_bridges() {
+    local network_id="$1"
+    local aggkit_url="$2"
+    local max_attempts="$3"
+    local poll_frequency="$4"
+
+    local attempt=0
+    local bridges_result=""
+
+    while ((attempt < max_attempts)); do
+        ((attempt++))
+        log "🔎 Attempt $attempt/$max_attempts: fetching total bridges \
+(network id = $network_id, bridge indexer url = $aggkit_url)"
+
+        # Capture both stdout (bridges result) and stderr (error message)
+        bridges_result=$(curl -s -H "Content-Type: application/json" \
+            "$aggkit_url/bridge/v1/bridges?network_id=$network_id" 2>&1)
+
+        # Check if the response contains an error
+        if [[ "$bridges_result" == *"error"* || "$bridges_result" == *"Error"* ]]; then
+            log "⚠️ Error: $bridges_result"
+            sleep "$poll_frequency"
+            continue
+        fi
+
+        if [[ "$bridges_result" == "" ]]; then
+            log "Empty bridges response retrieved, retrying in ${poll_frequency}s..."
+            sleep "$poll_frequency"
+            continue
+        fi
+
+        # Extract the total number of bridges
+        local total_bridges
+        total_bridges=$(echo "$bridges_result" | jq -r '.count')
+
+        if [[ "$total_bridges" != "null" && "$total_bridges" != "" ]]; then
+            echo "$total_bridges"
+            return 0
+        fi
+
+        sleep "$poll_frequency"
+    done
+
+    log "❌ Failed to find total bridges after $max_attempts attempts."
+    return 1
+}
+
 function log() {
     echo "[$(date '+%Y-%m-%d %H:%M:%S')] $1" >&3
 }