Add application file

README.md

@@ -3,6 +3,7 @@ title: Eths
 emoji: 📚
 colorFrom: blue
 colorTo: yellow
+python_version: 3.9.2
 sdk: streamlit
 sdk_version: 1.26.0
 app_file: app.py

pages/4_🕵️‍♀️_Ethscriptions Data.py

@@ -8,7 +8,6 @@ from datetime import datetime, timezone
 import threading
 import base64
 
-test1 = '233'
 # 使用你的Ethereum节点的RPC地址
 w3 = Web3(Web3.HTTPProvider("https://mainnet.infura.io/v3/9bbc614b8a1d49d59869e97d0ee3bf61"))
 
@@ -22,7 +21,9 @@ ethscrptions_db_file = os.path.join(parent_dir, 'data', 'ethscriptions_data.db')
 ethscriptions_con = sqlite3.connect(ethscrptions_db_file)
 ethscriptions_cur = ethscriptions_con.cursor()
 
+
 def get_eths_data():
+    global eths_conn, eths_cur
     # Initialize connection to SQLite database
     eths_conn = sqlite3.connect(eths_db_file)
     eths_cur = eths_conn.cursor()
@@ -72,7 +73,7 @@ def get_eths_data():
                     eths_cur.execute('INSERT INTO eths_data VALUES (?,?,?,?,?,?,?,?,?)', data)
                     eths_conn.commit()
         except Exception as e:
-            pass
+            print(e)
         time.sleep(60)
 
 
@@ -101,24 +102,22 @@ def get_ethscriptions_data():
             # 获取该区块中所有交易的列表
             transactions = block['transactions']
             for tx in transactions:
-                print(tx['input'])
-                print(type(tx['input']))
                 input_data = tx['input']
 
                 if input_data.startswith(r"0x646174613a2c"):
                     # if bytes.fromhex(input_data).startswith(b"data:,"):
 
                     existing_data = ethscriptions_thread_cur.execute("SELECT * FROM data WHERE data=?",
-                                                              (input_data,)).fetchone()
+                                                                     (input_data,)).fetchone()
 
                     if not existing_data:
                         timestamp = datetime.fromtimestamp(block['timestamp'], tz=timezone.utc)
 
                         ethscriptions_thread_cur.execute('''INSERT INTO data (block_time, block_number, data, owner, hash) 
                             VALUES (?, ?, ?, ?, ?)''',
-                                                  (
-                                                      timestamp, tx['blockNumber'], input_data, tx['to'],
-                                                      tx['hash'].hex()))
+                                                         (
+                                                             timestamp, tx['blockNumber'], input_data, tx['to'],
+                                                             tx['hash'].hex()))
 
                         ethscriptions_thread_con.commit()
                         print(f'-----{input_data}-----')
@@ -176,12 +175,12 @@ if eths_data:
 
         eths_stakers = st.metric(label='ETHS TVL', value=f'${eths_data[0][8]:,.0f}')
 
-
 ethscriptions_cur.execute("SELECT block_number FROM process_blocks")
 result = ethscriptions_cur.fetchone()
 processed_block = result[0]
 latest_block_number = w3.eth.block_number
-st.markdown(f'EthPen Ethscriptions Index Status：当前 Ethereum 最高区块：{latest_block_number}，已处理区块：{processed_block}')
+st.markdown(
+    f'EthPen Ethscriptions Index Status：当前 Ethereum 最高区块：{latest_block_number}，已处理区块：{processed_block}')
 
 download = st.checkbox('⏬️', value=False)
 if download:
@@ -191,33 +190,27 @@ if download:
     ethscrptions_db_file = os.path.join(parent_dir, 'data', 'ethscriptions_data.db')
     st.download_button(
         label='下载数据库',
-        data=open(ethscrptions_db_file,'rb'),
+        data=open(ethscrptions_db_file, 'rb'),
         file_name='ethscriptions_data.db',
         mime='application/octet-stream'
     )
+
+# 查询state列的值
+ethscriptions_cur.execute("SELECT state FROM thread_start_state")
+state_value = ethscriptions_cur.fetchone()[0]
+if state_value == "0":
     # 修改状态值
-    old_state = "0"
-    ethscriptions_cur.execute("UPDATE thread_start_state SET state = ?", (old_state,))
+    new_state = "1"
+    ethscriptions_cur.execute("UPDATE thread_start_state SET state = ?", (new_state,))
     ethscriptions_con.commit()
 
-while True:
-    time.sleep(10)
-    # 查询state列的值
-    ethscriptions_cur.execute("SELECT state FROM thread_start_state")
-    state_value = ethscriptions_cur.fetchone()[0]
-    if state_value == "0":
-        # 修改状态值
-        new_state = "1"
-        ethscriptions_cur.execute("UPDATE thread_start_state SET state = ?", (new_state,))
-        ethscriptions_con.commit()
-
-        eths_thread = threading.Thread(target=get_eths_data)
-        ethscriptions_thread = threading.Thread(target=get_ethscriptions_data)
-
-        # 启动线程
-        eths_thread.start()
-        ethscriptions_thread.start()
-
-        # 等待线程结束
-        eths_thread.join()
-        ethscriptions_thread.join()
+    eths_thread = threading.Thread(target=get_eths_data)
+    ethscriptions_thread = threading.Thread(target=get_ethscriptions_data)
+
+    # 启动线程
+    eths_thread.start()
+    ethscriptions_thread.start()
+
+    # 等待线程结束
+    eths_thread.join()
+    ethscriptions_thread.join()