Update app.py

app.py

@@ -4,40 +4,83 @@ import crypt
 import os
 from huggingface_hub import (upload_file,HfApi)
 
-token_self = os.environ['HF_TOKEN']
-api = HfApi(token=token_self)
-global rec_list
+
 rec_list = []
 pa=os.environ['PASS']
 
 main_chain='https://huggingface.co/datasets/Omnibus/chat-at/raw/main/chat/'
 
-#rec_list,_ = chatchain.update_rec_list(main_chain)
-def update_rec_list():
-    repo = main_chain.split('datasets/',1)[1].split('/raw',1)[0].split('/',1)[0]
-    name = main_chain.split('datasets/',1)[1].split('/raw',1)[0].split('/',1)[1]
-    f_ist = (api.list_repo_files(repo_id=f'{repo}/{name}', repo_type="dataset"))
-    rec_list.clear()
-    rec_list =[]
-    for i,ea in enumerate(f_ist):
-        if "chat/" in ea:
-            try:
-                if not "__Source__" in ea:
-                    rec_list.append(ea.split("/",1)[1].split("/",1)[0])
-            except Exception:
-                pass
-    return rec_list, gr.Dropdown(label="Recipient", choices=[f for f in rec_list])
 rec_list, rec_drop = chatchain.update_rec_list(main_chain)
 
-def up_rec():
-    rec_list,rec_drop = update_rec_list()
-    return gr.Dropdown(label="Recipient", choices=[f for f in rec_list])
 def checkp(inp):
     if inp == pa:
         return gr.update(visible=False), gr.update(visible=True)
     elif inp != pa:
         return gr.update(visible=True), gr.update(visible=False)
 
+
+############################################
+def send_message(send,rec,message):
+    response_send={}
+    response_rec={}
+    show_chain_send={}
+    show_chain_rec={}
+    data_send=None
+    data_rec=None
+    rec_send=None
+    rec_drop=None
+    message_send=None
+    message_rec=None    
+    trans_data=None
+    trans_mes=None
+    balance_send = 0
+    balance_rec = 0
+    mes = "blank message"
+    try:
+        response,message = get_my_chain_send(send)
+        send_rec = response
+        response,message = get_my_chain_rec(rec)
+        lod_rec = response
+        mes1,val,mes2,ind = valid_rec()
+        print (f'val:: {val}')
+        if val == False:
+            p=False 
+            mes = f"Recipient: {rec} Blockchain is not valid. {mes2} at Index {ind}"
+        print(mes)
+        p=True
+        #if z==False:
+        #    mes = b_mes
+        #    p=False
+    except Exception as e:
+        mes = f"An Error Occured: {e}" 
+        p=False
+    print (mes)
+    
+    if p==False:
+        return (mes, p,None,None,None,None,None,None,None,None,None,None,None)
+    if p==True:
+        chatchain.mychain_send.new_transaction(f"{send}",f"{rec}",f"{amount}")
+        message_send = "Transaction Added to Pool"
+        data_send = pd.DataFrame(chatchain.mychain_send.pending_transactions)
+        chatchain.mychain_rec.new_transaction(f"{send}",f"{rec}",f"{amount}")
+        message_rec = "Transaction Added to Pool"
+        data_rec = pd.DataFrame(chatchain.mychain_rec.pending_transactions)
+        response_send, show_chain_send, message_send = mychain_mine_block_send(chain_r=None,chain_n=send)
+        
+        #mychain_mine_block_trans(balance_send, chain_r=None,chain_n=send)
+        
+        response_rec, show_chain_rec, message_rec = mychain_mine_block_rec(chain_r=None,chain_n=rec)
+        mes = (f'Send: {message_send} :: Recieve: {message_rec}')
+        _,rec_send=update_send_list()
+        _,rec_drop=update_rec_list()
+        #trans_bx = merge_trans()
+        #trans_data, mes = bc_utils.bc_transactions(trans_bx)
+        return (mes, p, response_send, response_rec, show_chain_send, show_chain_rec, data_send,  data_rec,  message_send, message_rec, rec_send, rec_drop)
+        
+
+
+
+
 with gr.Blocks() as app:
     with gr.Row(visible=True) as invalid:
         pass_box = gr.Textbox()
@@ -103,6 +146,7 @@ with gr.Blocks() as app:
         #rec_drop = gr.Dropdown.update(label="Recipient", choices=[f for f in rec_list])
         return response,message,rec_drop      
 
+    send_mes.click(send_message,[sender,rec,send_mes],[block_text,out_box_bool,json_out_send,json_out_rec,chain_json_send,chain_json_rec,trans_data_send,trans_data_rec,block_text_send,block_text_rec,send,rec,trans_data])
 
         
     input_key.change(crypt.address,input_key,sender).then(chatchain.update_rec_list,None,rec)