yeagerai
diff --git a/‎.env.example
+5 b/‎.env.example
+5
diff --git a/‎backend/consensus/base.py
+33 b/‎backend/consensus/base.py
+33
diff --git a/‎backend/database_handler/transactions_processor.py
+36-91 b/‎backend/database_handler/transactions_processor.py
+36-91
@@ -61,6 +61,11 @@ HARDHAT_URL = 'http://hardhat'
 HARDHAT_PORT = '8545'
 HARDHAT_PRIVATE_KEY = '0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae784d7bf4f2ff80'
 
+# Consensus Parameters
+CONSENSUS_CONTRACT_ADDRESS = '0x0000000000000000000000000000000000000000'
+DEFAULT_NUM_INITIAL_VALIDATORS = 5
+DEFAULT_CONSENSUS_MAX_ROTATIONS = 3
+
 # LLM Providers Configuration
 # If you want to use OpenAI LLMs, add your key here
 OPENAIKEY               = '<add_your_openai_api_key_here>'
 
@@ -324,6 +324,8 @@ def execute_transfer(
                     TransactionStatus.UNDETERMINED,
                     msg_handler,
                 )
+
+                transactions_processor.create_rollup_transaction(transaction.hash)
                 return
 
             # Update the balance of the sender account
@@ -349,6 +351,8 @@ def execute_transfer(
             msg_handler,
         )
 
+        transactions_processor.create_rollup_transaction(transaction.hash)
+
     def run_appeal_window_loop(self):
         """
         Run the loop to handle the appeal window.
@@ -784,6 +788,10 @@ async def handle(self, context):
             context.msg_handler,
         )
 
+        context.transactions_processor.create_rollup_transaction(
+            context.transaction.hash
+        )
+
         # Unpack the leader and validators
         [leader, *remaining_validators] = validators
 
@@ -851,6 +859,10 @@ async def handle(self, context):
             context.msg_handler,
         )
 
+        context.transactions_processor.create_rollup_transaction(
+            context.transaction.hash
+        )
+
         # Create validator nodes for each validator
         context.validator_nodes = [
             context.node_factory(
@@ -898,6 +910,10 @@ async def handle(self, context):
             context.msg_handler,
         )
 
+        context.transactions_processor.create_rollup_transaction(
+            context.transaction.hash
+        )
+
         # Process each validation result and update the context
         for i, validation_result in enumerate(context.validation_results):
             # Store the vote from each validator node
@@ -977,6 +993,11 @@ async def handle(self, context):
                     TransactionStatus.PENDING,
                     context.msg_handler,
                 )
+
+                context.transactions_processor.create_rollup_transaction(
+                    context.transaction.hash
+                )
+
                 context.transactions_processor.set_transaction_appeal_failed(
                     context.transaction.hash,
                     0,
@@ -1036,6 +1057,10 @@ async def handle(self, context):
             context.msg_handler,
         )
 
+        context.transactions_processor.create_rollup_transaction(
+            context.transaction.hash
+        )
+
         # Set the transaction result
         context.transactions_processor.set_transaction_result(
             context.transaction.hash, context.consensus_data.to_dict()
@@ -1130,6 +1155,10 @@ async def handle(self, context):
             context.msg_handler,
         )
 
+        context.transactions_processor.create_rollup_transaction(
+            context.transaction.hash
+        )
+
         # Set the transaction result with the current consensus data
         context.transactions_processor.set_transaction_result(
             context.transaction.hash,
@@ -1161,6 +1190,10 @@ async def handle(self, context):
             context.msg_handler,
         )
 
+        context.transactions_processor.create_rollup_transaction(
+            context.transaction.hash
+        )
+
         # Insert pending transactions generated by contract-to-contract calls
         pending_transactions = (
             context.transaction.consensus_data.leader_receipt.pending_transactions
 
@@ -16,6 +16,8 @@
 from backend.database_handler.contract_snapshot import ContractSnapshot
 import os
 
+from backend.rollup.consensus_service import ConsensusService
+
 
 class TransactionAddressFilter(Enum):
     ALL = "all"
@@ -145,64 +147,6 @@ def insert_transaction(
         )
         ghost_contract_address = None
 
-        if type == TransactionType.DEPLOY_CONTRACT.value:
-            # Hardhat account
-            account = self.web3.eth.accounts[0]
-            private_key = os.environ.get("HARDHAT_PRIVATE_KEY")
-
-            # Ghost contract
-            # Read contract ABI and bytecode from compiled contract
-            # contract_file = os.path.join(
-            #     os.getcwd(),
-            #     "app/hardhat/artifacts/contracts/GhostContract.sol/GhostContract.json",
-            # )
-
-            # with open(contract_file, "r") as f:
-            #     contract_json = json.loads(f.read())
-            #     abi = contract_json["abi"]
-            #     bytecode = contract_json["bytecode"]
-
-            # # Create the contract instance
-            # contract = self.web3.eth.contract(abi=abi, bytecode=bytecode)
-
-            # # Build the transaction
-            # gas_estimate = self.web3.eth.estimate_gas(
-            #     contract.constructor().build_transaction(
-            #         {
-            #             "from": account,
-            #             "nonce": self.web3.eth.get_transaction_count(account),
-            #             "gasPrice": 0,
-            #         }
-            #     )
-            # )
-            # transaction = contract.constructor().build_transaction(
-            #     {
-            #         "from": account,
-            #         "nonce": self.web3.eth.get_transaction_count(account),
-            #         "gas": gas_estimate,
-            #         "gasPrice": 0,
-            #     }
-            # )
-
-            # # Sign the transaction
-            # signed_tx = self.web3.eth.account.sign_transaction(
-            #     transaction, private_key=private_key
-            # )
-
-            # # Send the transaction
-            # tx_hash = self.web3.eth.send_raw_transaction(signed_tx.raw_transaction)
-
-            # # Wait for the transaction receipt
-            # receipt = self.web3.eth.wait_for_transaction_receipt(tx_hash)
-            # ghost_contract_address = receipt.contractAddress
-
-        elif type == TransactionType.RUN_CONTRACT.value:
-            genlayer_contract_address = to_address
-            # contract_snapshot = ContractSnapshot(
-            #     genlayer_contract_address, self.session
-            # )
-            # ghost_contract_address = contract_snapshot.ghost_contract_address
-
         new_transaction = Transactions(
             hash=transaction_hash,
             from_address=from_address,
@@ -235,9 +179,6 @@ def insert_transaction(
 
         self.session.flush()  # So that `created_at` gets set
 
-        if type != TransactionType.SEND.value:
-            self.create_rollup_transaction(new_transaction.hash)
-
         return new_transaction.hash
 
     def get_transaction_by_hash(self, transaction_hash: str) -> dict | None:
@@ -280,36 +221,40 @@ def create_rollup_transaction(self, transaction_hash: str):
         account = self.web3.eth.accounts[0]
         private_key = os.environ.get("HARDHAT_PRIVATE_KEY")
 
-        # gas_estimate = self.web3.eth.estimate_gas(
-        #     {
-        #         "from": account,
-        #         "to": transaction.ghost_contract_address,
-        #         "value": transaction.value,
-        #         "data": rollup_input_data,
-        #     }
-        # )
-
-        # transaction = {
-        #     "from": account,
-        #     "to": transaction.ghost_contract_address,
-        #     "value": transaction.value,
-        #     "data": rollup_input_data,
-        #     "nonce": self.web3.eth.get_transaction_count(account),
-        #     "gas": gas_estimate,
-        #     "gasPrice": 0,
-        # }
-
-        # # Sign and send the transaction
-        # signed_tx = self.web3.eth.account.sign_transaction(
-        #     transaction, private_key=private_key
-        # )
-        # tx_hash = self.web3.eth.send_raw_transaction(signed_tx.raw_transaction)
-
-        # # Wait for transaction to be actually mined and get the receipt
-        # receipt = self.web3.eth.wait_for_transaction_receipt(tx_hash)
-
-        # # Get full transaction details including input data
-        # transaction = self.web3.eth.get_transaction(tx_hash)
+        try:
+            gas_estimate = self.web3.eth.estimate_gas(
+                {
+                    "from": account,
+                    "to": transaction.ghost_contract_address,
+                    "value": transaction.value,
+                    "data": rollup_input_data,
+                }
+            )
+
+            transaction = {
+                "from": account,
+                "to": transaction.ghost_contract_address,
+                "value": transaction.value,
+                "data": rollup_input_data,
+                "nonce": self.web3.eth.get_transaction_count(account),
+                "gas": gas_estimate,
+                "gasPrice": 0,
+            }
+
+            # Sign and send the transaction
+            signed_tx = self.web3.eth.account.sign_transaction(
+                transaction, private_key=private_key
+            )
+            tx_hash = self.web3.eth.send_raw_transaction(signed_tx.raw_transaction)
+
+            # Wait for transaction to be actually mined and get the receipt
+            receipt = self.web3.eth.wait_for_transaction_receipt(tx_hash)
+
+            # Get full transaction details including input data
+            transaction = self.web3.eth.get_transaction(tx_hash)
+
+        except Exception as e:
+            print(f"Error creating rollup transaction: {e}")
 
     def get_transaction_count(self, address: str) -> int:
         count = (