Update app.py

app.py

@@ -37,39 +37,54 @@ def upload_json_to_ipfs(data):
         st.write(f"Error uploading to Pinata: {e}")
 
 # function that uploads to blockchain
-def upload_to_blockchain(hash):
+def upload_to_blockchain(ipfs_hash):
     print("starting blockchain upload")
+
     w3 = web3.Web3(web3.HTTPProvider(st.secrets["infura"]))
+    if not w3.is_connected():
+        raise RuntimeError("Failed to connect to Ethereum network")
+
+    try:
+        contract_address = st.secrets["ContractAddress"]
+        checksum_address = w3.to_checksum_address(contract_address)
+    except Exception as e:
+        raise ValueError(f"Invalid contract address: {contract_address}\nError: {e}")
 
-    # create an instance of our contract
-    contract = w3.eth.contract(address=st.secrets["ContractAddress"], abi = abi)
+    try:
+        assert isinstance(abi, list), "ABI must be a list"
+    except Exception as e:
+        raise ValueError(f"ABI format error: {e}")
+
+    contract = w3.eth.contract(address=checksum_address, abi=abi)
 
     print("Sending from:", st.secrets["EthWallet"])
-    print("To contract:", st.secrets["ContractAddress"])
-    print("Function input (IPFS hash):", hash)
+    print("To contract:", checksum_address)
+    print("Function input (IPFS hash):", ipfs_hash)
     print("Nonce:", w3.eth.get_transaction_count(st.secrets["EthWallet"]))
 
-    # Call your function: 11155111 is Sepolia's id
-    call_function = contract.functions.storeHash(hash).build_transaction({"chainId": 11155111, 
-                                                                            "from": st.secrets["EthWallet"],
-                                                                            "nonce": w3.eth.get_transaction_count(st.secrets["EthWallet"])})
+    # Build transaction
+    call_function = contract.functions.storeHash(ipfs_hash).build_transaction({
+        "chainId": 11155111,
+        "from": st.secrets["EthWallet"],
+        "nonce": w3.eth.get_transaction_count(st.secrets["EthWallet"]),
+        "gas": 300000,
+        "gasPrice": w3.to_wei("10", "gwei")
+    })
 
     # Sign transaction
     signed_tx = w3.eth.account.sign_transaction(call_function, private_key=st.secrets["pk"])
 
-
-
-    
     # Send transaction
-    send_tx = w3.eth.send_raw_transaction(signed_tx.raw_transaction)
+    tx_hash = w3.eth.send_raw_transaction(signed_tx.raw_transaction)
 
     # Wait for transaction receipt
-    tx_receipt = w3.eth.wait_for_transaction_receipt(send_tx)
+    tx_receipt = w3.eth.wait_for_transaction_receipt(tx_hash)
+
+    print("Transaction successful!")
+    print("ETH Tx Hash:", tx_receipt.transactionHash.hex())
 
-    print("ETH Hash:")
-    print(tx_receipt.logs[0].transactionHash.hex())
+    return tx_receipt.transactionHash.hex()
 
-    return tx_receipt.logs[0].transactionHash.hex()
 
 def get_ipfs_hashes():
     w3 = web3.Web3(web3.HTTPProvider(st.secrets["infura"]))