Optimización seguridad obtención data

avaimet.py

@@ -32,10 +32,10 @@ def obtenData(sftp, dir_data):
     with sftp.open(dir_data, 'rb') as archivo:
       # Leer el contenido del archivo como bytes
       contenido = archivo.read()
-
       print("Imprimiendo contenido: ", contenido)
-      print("182 El tipo de contenido obtenido es: ", type(contenido))
-      
+      print("El tipo de contenido obtenido es: ", type(contenido))
+      print("Esperando 32 segundos, porque analizaremos como es data y como extraer un renglón.")
+      time.sleep(32)
       return contenido
 
 def obtenCaja(userfile):

funciones.py

@@ -1,70 +1,70 @@
-import time
-import avaimet
-
-def getData():
-
-    #Genera conexión inicial.       
-    sshListo, sftpListo = avaimet.conecta()
-    #Obtiene la caja donde está guardados los tokens.
-    dir_data = avaimet.obtenDirData()
-
-    data = avaimet.obtenData(sftpListo, dir_data)    
-    #Cierra la conexión.    
-    avaimet.cierraConexion(sshListo, sftpListo)
-    
-    return data
-
-def getTokens(userfile):
-
-    #Genera conexión inicial.       
-    sshListo, sftpListo = avaimet.conecta()
-    #Obtiene la caja donde está guardados los tokens.
-    caja = avaimet.obtenCaja(userfile)
-    #Obtiene los tokens que hay en esa caja.
-    tokens = avaimet.obtenTokens(sftpListo, caja)
-    #Cierra la conexión.    
-    avaimet.cierraConexion(sshListo, sftpListo)
-    
-    return tokens
-
-def authorize(tokens, work):
-
-    print(f"Task received : {work}, type: {type(work)} ...")
-
-    ##Ésta sección se reutilizará si en lugar de pasar el parámetro token, se pasa el parámetro userfile.
-    #Actualmente no lo pedimos porque es el developer el que pone la cantidad de tokens que el usuario tiene para...
-    #...evitar otra vuelta al server, por mayor certeza o seguridad se puede hacer esa ida. 
-    #En un futuro incluso se pueden hacer los dos tipos de autorización en dos endpoints distintos. O en un solo endpoint con...
-    #...las dos opciones. 
-
-    #Genera conexión inicial.
-    #sshListo, sftpListo = avaimet.conecta()
-    #Obtiene la caja donde está guardados los tokens.
-    #caja = avaimet.obtenCaja(userfile)
-    #Obtiene los tokens que hay en esa caja.
-    #tokens = avaimet.obtenTokens(sftpListo, caja)
-    
-    #True si autoriza o false si no autoriza.
-    result = avaimet.autoriza(tokens, work)
-    
-    #Cierra la conexión.  
-    #avaimet.cierraConexion(sshListo, sftpListo)
-
-    return result
-
-def debitTokens(userfile, work):
-
-    print(f"Task received : {work}, type: {type(work)} ...")
-
-    #Genera conexión inicial.
-    sshListo, sftpListo = avaimet.conecta()
-    #Obtiene la caja donde está guardados los tokens.
-    caja = avaimet.obtenCaja(userfile)
-    #Obtiene los tokens que hay en esa caja.
-    tokens = avaimet.obtenTokens(sftpListo, caja)
-    #Aplica las reglas de ésta app para debitar lo correspondiente.
-    resultado_debitado = avaimet.restaToken(sftpListo, caja, tokens, work)
-    #Cierra la conexión.  
-    avaimet.cierraConexion(sshListo, sftpListo)
-
-    return resultado_debitado
+import time
+import avaimet
+
+def getData():
+
+    #Genera conexión inicial.       
+    sshListo, sftpListo = avaimet.conecta()
+    #Obtiene la caja donde está guardados los tokens.
+    dir_data = avaimet.obtenDirData()
+    #Obtiene el json con los datos.
+    data = avaimet.obtenData(sftpListo, dir_data)    
+    #Cierra la conexión.    
+    avaimet.cierraConexion(sshListo, sftpListo)
+    
+    return data
+
+def getTokens(userfile):
+
+    #Genera conexión inicial.       
+    sshListo, sftpListo = avaimet.conecta()
+    #Obtiene la caja donde está guardados los tokens.
+    caja = avaimet.obtenCaja(userfile)
+    #Obtiene los tokens que hay en esa caja.
+    tokens = avaimet.obtenTokens(sftpListo, caja)
+    #Cierra la conexión.    
+    avaimet.cierraConexion(sshListo, sftpListo)
+    
+    return tokens
+
+def authorize(tokens, work):
+
+    print(f"Task received : {work}, type: {type(work)} ...")
+
+    ##Ésta sección se reutilizará si en lugar de pasar el parámetro token, se pasa el parámetro userfile.
+    #Actualmente no lo pedimos porque es el developer el que pone la cantidad de tokens que el usuario tiene para...
+    #...evitar otra vuelta al server, por mayor certeza o seguridad se puede hacer esa ida. 
+    #En un futuro incluso se pueden hacer los dos tipos de autorización en dos endpoints distintos. O en un solo endpoint con...
+    #...las dos opciones. 
+
+    #Genera conexión inicial.
+    #sshListo, sftpListo = avaimet.conecta()
+    #Obtiene la caja donde está guardados los tokens.
+    #caja = avaimet.obtenCaja(userfile)
+    #Obtiene los tokens que hay en esa caja.
+    #tokens = avaimet.obtenTokens(sftpListo, caja)
+    
+    #True si autoriza o false si no autoriza.
+    result = avaimet.autoriza(tokens, work)
+    
+    #Cierra la conexión.  
+    #avaimet.cierraConexion(sshListo, sftpListo)
+
+    return result
+
+def debitTokens(userfile, work):
+
+    print(f"Task received : {work}, type: {type(work)} ...")
+
+    #Genera conexión inicial.
+    sshListo, sftpListo = avaimet.conecta()
+    #Obtiene la caja donde está guardados los tokens.
+    caja = avaimet.obtenCaja(userfile)
+    #Obtiene los tokens que hay en esa caja.
+    tokens = avaimet.obtenTokens(sftpListo, caja)
+    #Aplica las reglas de ésta app para debitar lo correspondiente.
+    resultado_debitado = avaimet.restaToken(sftpListo, caja, tokens, work)
+    #Cierra la conexión.  
+    avaimet.cierraConexion(sshListo, sftpListo)
+
+    return resultado_debitado

main.py

@@ -1,77 +1,76 @@
-from fastapi import FastAPI
-import funciones
-
-app = FastAPI()
-
-@app.get("/")
-def start(): 
-
-    return {"Status":"Deployed"}
-
-## GET DATA ##
-
-#Vía Path
-@app.get("/getData/")
-def getData():
-    data = funciones.getData()
-    
-    print("Tipo de resultado:", type(data))
-    return data
-
-#Vía Query 
-#Quizá no es necesaria vía Query porque no pide parámetros.
-@app.get("/getDataQ/")
-def getData():
-    data = funciones.getData()
-    print("Tipo de resultado:", type(data))
-    return data
-
-
-## GET TOKENS ##
-
-#Vía Path
-@app.get("/getTokens/{userfile}")
-def getTokens(userfile: str):
-    tokens = funciones.getTokens(userfile)
-    print("Tipo de resultado:", type(tokens))
-    return tokens
-
-#Vía Query 
-@app.get("/getTokensQ/")
-def getTokens(userfile: str = "gAAAAABmEZA4SLBC2YczouOrjIEi9WNCNGOIvyUcqBUnzxNsftXTdy54KaX9x8mAjFkABSI6FJrdZDQKk_5lpJOgJoMChxlniw=="):
-    tokens = funciones.getTokens(userfile)
-    print("Tipo de resultado:", type(tokens))
-    return tokens
-
-## AUTHORIZE WORK ##
-
-#Vía Parameters
-@app.get("/authorize/{tokens}/{work}")
-def authorize(tokens: int, work: str):
-    autorizacion = funciones.authorize(tokens, work)
-    print("Tipo de resultado:", type(autorizacion))
-    return autorizacion
-
-#Vía Query
-@app.get("/authorizeQ/")
-def authorize(tokens: int, work: str = "picswap"):
-    autorizacion = funciones.authorize(tokens,work) 
-    print("Tipo de resultado:", type(autorizacion))
-    return autorizacion
-
-
-## DEBIT TOKENS ##
-
-#Vía Parámeters
-@app.get("/debitTokens/{userfile}/{work}")
-def debitTokens(userfile: str, work: str):
-    tokens = funciones.debitTokens(userfile,work) 
-    print("Tipo de resultado:", type(tokens))
-    return tokens
-
-#Vía Query
-@app.get("/debitTokensQ/")
-def debitTokens(userfile: str, work: str = "picswap"):
-    tokens = funciones.debitTokens(userfile,work) 
-    print("Tipo de resultado:", type(tokens))
+from fastapi import FastAPI
+import funciones
+
+app = FastAPI()
+
+@app.get("/")
+def start(): 
+
+    return {"Status":"Deployed"}
+
+## GET DATA ##
+
+#Vía Path
+@app.get("/getData/")
+def getData():
+    data = funciones.getData()    
+    print("Tipo de resultado:", type(data))
+    return data
+
+#Vía Query 
+#Quizá no es necesaria vía Query porque no pide parámetros.
+@app.get("/getDataQ/")
+def getData():
+    data = funciones.getData()
+    print("Tipo de resultado:", type(data))
+    return data
+
+
+## GET TOKENS ##
+
+#Vía Path
+@app.get("/getTokens/{userfile}")
+def getTokens(userfile: str):
+    tokens = funciones.getTokens(userfile)
+    print("Tipo de resultado:", type(tokens))
+    return tokens
+
+#Vía Query 
+@app.get("/getTokensQ/")
+def getTokens(userfile: str = "gAAAAABmEZA4SLBC2YczouOrjIEi9WNCNGOIvyUcqBUnzxNsftXTdy54KaX9x8mAjFkABSI6FJrdZDQKk_5lpJOgJoMChxlniw=="):
+    tokens = funciones.getTokens(userfile)
+    print("Tipo de resultado:", type(tokens))
+    return tokens
+
+## AUTHORIZE WORK ##
+
+#Vía Parameters
+@app.get("/authorize/{tokens}/{work}")
+def authorize(tokens: int, work: str):
+    autorizacion = funciones.authorize(tokens, work)
+    print("Tipo de resultado:", type(autorizacion))
+    return autorizacion
+
+#Vía Query
+@app.get("/authorizeQ/")
+def authorize(tokens: int, work: str = "picswap"):
+    autorizacion = funciones.authorize(tokens,work) 
+    print("Tipo de resultado:", type(autorizacion))
+    return autorizacion
+
+
+## DEBIT TOKENS ##
+
+#Vía Parámeters
+@app.get("/debitTokens/{userfile}/{work}")
+def debitTokens(userfile: str, work: str):
+    tokens = funciones.debitTokens(userfile,work) 
+    print("Tipo de resultado:", type(tokens))
+    return tokens
+
+#Vía Query
+@app.get("/debitTokensQ/")
+def debitTokens(userfile: str, work: str = "picswap"):
+    tokens = funciones.debitTokens(userfile,work) 
+    print("Tipo de resultado:", type(tokens))
     return tokens