Add Basic Files

app.py

@@ -10,15 +10,27 @@ def authenticate(username, password):
     return False
 
 #Función principal
-def greet(name):
+def runpy(access, name):
 
     var_secreta = os.environ.get("huggingface_key")
     print("Esto es var_secreta: ", var_secreta)
         
     return "Tervetuloa " + name + "!!"
 
-iface = gr.Interface(fn=greet, inputs="text", outputs="text")
+#iface = gr.Interface(fn=runpy, inputs="text", outputs="text")
 
-iface.launch()
+with gr.Blocks() as demo: 
+
+    input_userfile = gr.Text(label="Userfile")
+    input_content = gr.Text(label="content")
+    btn = gr.Button(value="Submit")
+    output_tokens = gr.Text(label="Tokens")
+    output_resultado = gr.Text(label="Resultado")
+
+    #Actions
+    btn.click(runpy, inputs=[input_userfile, input_content], outputs=[output_tokens, output_resultado])
+
+demo.launch()
+#iface.launch()
 #iface.launch(auth=("admin", "pass1234"))
 #iface.launch(auth=authenticate)

flux_capacitor.py

@@ -0,0 +1,53 @@
+import theApp
+import nodes
+import sulkuGateway
+import time
+
+#Flux capacitor une la Autenticación y la App.
+def do(access, content):
+
+	print("Entré a flux_capacitor.do...")
+	time.sleep(8)
+	#AUTENTICACIÓN#
+ 	#Obten cantidad de tokens dispobibles vía Sulku para ese usuario.
+	resultado = sulkuGateway.getTokens(access)
+
+	#Un try para convertirlo en entero porque quizá bajo alguna circunstancia no sea un número lo que regresa y marcará error al aplicarle int().
+	try:
+		resultado = int(resultado)
+	except ValueError:
+		# Manejar el error de conversión a entero
+		print("Error 401: return value is not int.")
+		
+	except Exception as e:
+		# Manejar otros errores genéricos
+		print("Error 402: Unexpected error convertirng the result:", e)
+		
+	#Si el resultado es un entero, es token.
+	if isinstance(resultado, int): 
+		#El númmero si es un entero.
+		tokens = resultado
+		continuar = True
+		print("Access granted.")
+		print("Your amount of available tokens is: ", tokens)
+	else: 
+		print("Message:", resultado)
+		continuar = False
+
+	#ACCIÓN#
+	print("Performing action, processing...")
+	if continuar is True and theApp.saldoParaAccion(tokens):
+		resultado = theApp.getResult(content)
+		print("Process completed.")
+	else: 
+		print(f"Message: Not enough tokens to perform {nodes.work} action.")
+		resultado = 0
+      
+	#CHARGE TOKENS
+	#Si se generó un resultado de AI entonces si hay que debitar el token correspondiente basado en la regla propia de la app.
+	if resultado != 0:
+		sulkuGateway.debitTokens(access, nodes.work)
+	else:
+		"No tokens will be charged because no outcome was produced."
+		
+	return tokens, resultado

sulkuGateway.py

@@ -0,0 +1,40 @@
+import time
+import nodes
+import requests
+import gradio_client
+
+def getTokens(sulkukey):
+
+    print("Entre a SulkiGateway...")
+    time.sleep(7)
+
+    print("A punto de hacer llamado a cliente de API via Sulku...")
+    time.sleep(3)
+    try:
+        client = gradio_client.Client("Moibe/sulku", verbose=False)
+        resultado = client.predict(sulkukey, api_name="/getTokens")
+        
+        return resultado
+    
+    # except gradio_client.exceptions.APIError as e:
+    #     print(f"Error 404 calling the API: {e}")
+    #     return None
+    except requests.exceptions.RequestException as e:
+        print(f"Error 405: Network error, {e}")
+        return None
+
+
+def debitTokens(sulkukey, work):
+     
+    client = gradio_client.Client(nodes.validator, nodes.hf_token, verbose=False)
+        
+    tokens = client.predict(
+            sulkukey,
+            work,
+            api_name="/debitTokens"
+    ) 
+
+    print(f"Available tokens now: {tokens}.")   
+    time.sleep(1) 
+
+    return tokens

theApp.py

@@ -0,0 +1,32 @@
+import time
+import nodes
+import gradio_client
+
+def saldoParaAccion(tokens):
+  #Donde 1 es el cobro por acción, es decir, tiene capacidad por lo menos de realizar una acción.
+   if tokens >= 1: 			
+    return True
+
+   else:
+    print("Not enough tokens to perform the action, add more.")
+    return False
+
+
+def getResult(content): 
+
+    print("Processing content: ", content)
+    time.sleep(1)
+
+    if nodes.work == "picswap":
+      print("Work specs ok, action: ",  nodes.work)
+      time.sleep(1)
+
+      #Aquí es donde ya no será un llamado de api si no la app itself. Listo OK!.
+      result = f"y el resultado es: Tervetuluo {content} !"
+      #Revisa si la app en cuestión podría regresar algún resultado extraño además del esperado. Esto se revisa en la otra App.
+      return result
+    
+    else: 
+      print("Work specs aren't correct. Please fix or contact app.")
+      #Regresa cero si el trabajo no se realizó por haber especificado incorrectamente el Work.
+      return 0