Merge pull request #87 from OffchainLabs/seq-inbox-bridge

Move event and delayed inbox messages read to the bridge

Author: yahgwai

src/bridge/AbsBridge.sol

@@ -14,11 +14,15 @@ import {
     NotSequencerInbox,
     NotOutbox,
     InvalidOutboxSet,
-    BadSequencerMessageNumber
+    BadSequencerMessageNumber,
+    EmptyDelayedMessagesRead,
+    DelayedBackwards,
+    DelayedTooFar
 } from "../libraries/Error.sol";
 import "./IBridge.sol";
 import "./Messages.sol";
 import "../libraries/DelegateCallAware.sol";
+import "./ISequencerInbox.sol";
 
 import {L1MessageType_batchPostingReport} from "../libraries/MessageTypes.sol";
 
@@ -55,8 +59,15 @@ abstract contract AbsBridge is Initializable, DelegateCallAware, IBridge {
 
     uint256 public override sequencerReportedSubMessageCount;
 
+    uint256 public totalDelayedMessagesRead;
+
     address internal constant EMPTY_ACTIVEOUTBOX = address(type(uint160).max);
 
+    function postUpgradeInit() external onlyDelegated onlyProxyOwner {
+        totalDelayedMessagesRead = ISequencerInbox(sequencerInbox).totalDelayedMessagesRead();
+        if (totalDelayedMessagesRead == 0) revert EmptyDelayedMessagesRead();
+    }
+
     modifier onlyRollupOrOwner() {
         if (msg.sender != address(rollup)) {
             address rollupOwner = rollup.owner();
@@ -101,7 +112,9 @@ abstract contract AbsBridge is Initializable, DelegateCallAware, IBridge {
         bytes32 dataHash,
         uint256 afterDelayedMessagesRead,
         uint256 prevMessageCount,
-        uint256 newMessageCount
+        uint256 newMessageCount,
+        TimeBounds memory timeBounds,
+        BatchDataLocation batchDataLocation
     )
         external
         onlySequencerInbox
@@ -119,6 +132,9 @@ abstract contract AbsBridge is Initializable, DelegateCallAware, IBridge {
         ) {
             revert BadSequencerMessageNumber(sequencerReportedSubMessageCount, prevMessageCount);
         }
+        if (afterDelayedMessagesRead > delayedInboxAccs.length) revert DelayedTooFar();
+        if (afterDelayedMessagesRead < totalDelayedMessagesRead) revert DelayedBackwards();
+
         sequencerReportedSubMessageCount = newMessageCount;
         seqMessageIndex = sequencerInboxAccs.length;
         if (sequencerInboxAccs.length > 0) {
@@ -129,6 +145,18 @@ abstract contract AbsBridge is Initializable, DelegateCallAware, IBridge {
         }
         acc = keccak256(abi.encodePacked(beforeAcc, dataHash, delayedAcc));
         sequencerInboxAccs.push(acc);
+        totalDelayedMessagesRead = afterDelayedMessagesRead;
+
+        emit SequencerBatchDelivered(
+            seqMessageIndex,
+            beforeAcc,
+            acc,
+            delayedAcc,
+            afterDelayedMessagesRead,
+            timeBounds,
+            batchDataLocation,
+            msg.sender
+        );
     }
 
     /// @inheritdoc IBridge
@@ -304,5 +332,5 @@ abstract contract AbsBridge is Initializable, DelegateCallAware, IBridge {
      * variables without shifting down storage in the inheritance chain.
      * See https://docs.openzeppelin.com/contracts/4.x/upgradeable#storage_gaps
      */
-    uint256[40] private __gap;
+    uint256[39] private __gap;
 }

src/bridge/IBridge.sol

@@ -4,10 +4,24 @@
 
 // solhint-disable-next-line compiler-version
 pragma solidity >=0.6.9 <0.9.0;
+pragma experimental ABIEncoderV2;
 
 import "./IOwnable.sol";
 
 interface IBridge {
+    enum BatchDataLocation {
+        TxInput,
+        SeparateBatchEvent,
+        NoData
+    }
+
+    struct TimeBounds {
+        uint64 minTimestamp;
+        uint64 maxTimestamp;
+        uint64 minBlockNumber;
+        uint64 maxBlockNumber;
+    }
+
     event MessageDelivered(
         uint256 indexed messageIndex,
         bytes32 indexed beforeInboxAcc,
@@ -26,6 +40,17 @@ interface IBridge {
         bytes data
     );
 
+    event SequencerBatchDelivered(
+        uint256 indexed batchSequenceNumber,
+        bytes32 indexed beforeAcc,
+        bytes32 indexed afterAcc,
+        bytes32 delayedAcc,
+        uint256 afterDelayedMessagesRead,
+        TimeBounds timeBounds,
+        BatchDataLocation dataLocation,
+        address sequencerInbox
+    );
+
     event InboxToggle(address indexed inbox, bool enabled);
 
     event OutboxToggle(address indexed outbox, bool enabled);
@@ -66,13 +91,17 @@ interface IBridge {
 
     function sequencerMessageCount() external view returns (uint256);
 
+    function totalDelayedMessagesRead() external view returns (uint256);
+
     // ---------- onlySequencerInbox functions ----------
 
     function enqueueSequencerMessage(
         bytes32 dataHash,
         uint256 afterDelayedMessagesRead,
         uint256 prevMessageCount,
-        uint256 newMessageCount
+        uint256 newMessageCount,
+        TimeBounds memory timeBounds,
+        BatchDataLocation dataLocation
     )
         external
         returns (

src/bridge/ISequencerInbox.sol

@@ -23,29 +23,6 @@ interface ISequencerInbox is IDelayedMessageProvider {
         uint256 futureSeconds;
     }
 
-    struct TimeBounds {
-        uint64 minTimestamp;
-        uint64 maxTimestamp;
-        uint64 minBlockNumber;
-        uint64 maxBlockNumber;
-    }
-
-    enum BatchDataLocation {
-        TxInput,
-        SeparateBatchEvent,
-        NoData
-    }
-
-    event SequencerBatchDelivered(
-        uint256 indexed batchSequenceNumber,
-        bytes32 indexed beforeAcc,
-        bytes32 indexed afterAcc,
-        bytes32 delayedAcc,
-        uint256 afterDelayedMessagesRead,
-        TimeBounds timeBounds,
-        BatchDataLocation dataLocation
-    );
-
     event OwnerFunctionCalled(uint256 indexed id);
 
     /// @dev a separate event that emits batch data when this isn't easily accessible in the tx.input
@@ -57,6 +34,8 @@ interface ISequencerInbox is IDelayedMessageProvider {
     /// @dev a keyset was invalidated
     event InvalidateKeyset(bytes32 indexed keysetHash);
 
+    /// @notice The total number of delated messages read in the bridge
+    /// @dev    We surface this here for backwards compatibility
     function totalDelayedMessagesRead() external view returns (uint256);
 
     function bridge() external view returns (IBridge);