Upload 2 files

app.py

@@ -0,0 +1,79 @@
+import streamlit as st
+import web3
+import requests
+import pandas
+
+# Connect to the Sepolia Ethereum blockchain
+w3 = web3.Web3(web3.HTTPProvider(st.secrets["infura"]))
+
+# Variables
+ABI = '[ { "anonymous": false, "inputs": [ { "indexed": false, "internalType": "string", "name": "data", "type": "string" } ], "name": "Store", "type": "event" }, { "inputs": [ { "internalType": "string", "name": "_IPFSHash", "type": "string" } ], "name": "storeHash", "outputs": [], "stateMutability": "nonpayable", "type": "function" } ]'
+
+# Changing the App title
+st.set_page_config(page_title="Survey Data Retriever",)
+
+
+# The following code centralizes all the buttons
+st.markdown("<style>.row-widget.stButton {text-align: center;}</style>", unsafe_allow_html=True)
+
+# Title
+st.title('Survey Data Retriever')
+st.write("# ")
+
+
+# Text field
+contract_address = st.text_input(r"$\textsf{\Large Smart Contract Address}$", '0x42b76d8c32f914630627bf924bd1e06055673cf8')
+
+# Button
+button = st.button("Retrieve Survey Responses")
+
+# Button is pressed
+if button:
+
+    # Starts the progression bar
+    my_bar = st.progress(0, text= "Operation in progress. Please wait.")
+
+    # data frame with the data
+    df = pandas.DataFrame()
+
+    # Getting logs from ETH contract
+    contract = w3.eth.contract( address = contract_address, abi = ABI)
+    logs = contract.events.Store.get_logs(fromBlock= 4635673)
+
+    # Writing a label
+    st.write(r"$\textsf{\normalsize \textbf{IPFS Hashes}}$")
+
+    for i, log in enumerate(logs):        
+
+        # Adjusting progression bard
+        my_bar.progress((i+1)/len(logs), text= "Operation in progress. Please wait.")
+
+        # Writing the hashes
+        st.write(f"**Hash**: {log.args.data}; **Block number**:  {log.blockNumber}")
+
+        # Requesting data from IPFS using INFURA API
+        params = (('arg', log.args.data),)
+        response = requests.post('https://ipfs.infura.io:5001/api/v0/cat', 
+                                 params=params, 
+                                 auth=(st.secrets["username"], st.secrets["password"]))
+           
+        # create a row for the values associated with the 'data' key
+        json_to_row = pandas.json_normalize(response.json())
+
+        # append data to empty data frame
+        df = pandas.concat([df,json_to_row], ignore_index=True)        
+
+    # Printing df
+    st.write("# ")
+    st.write(r" $\textsf{\normalsize \textbf{Response Data}}$")
+    st.write(df)
+
+    # Download button
+    st.download_button("Press to Download",
+                       df.to_csv(index=False).encode('utf-8'),
+                       "responses.csv",
+                       "text/csv",
+                        key='download-csv')
+    
+    # Clearing progression bar
+    my_bar.empty()

requirements.txt

@@ -0,0 +1,4 @@
+web3==6.11.2
+requests==2.31.0
+streamlit==1.28.2
+pandas==2.0.3