Ya dejo andandando algo

Wpp1State.py

@@ -48,7 +48,7 @@ class StateMail():
     def __init__(self):
     def __init__(self):
         self.Consultas = {}#{MailUSer-pass-host-str(port):{"hora": datetime.datetime.now, "estado": self.chequear_stado_WB(telefono)},}
         self.Consultas = {}#{MailUSer-pass-host-str(port):{"hora": datetime.datetime.now, "estado": self.chequear_stado_WB(telefono)},}
         self.MailRompedor = []
         self.MailRompedor = []
-        
+
     def chequear_stado_Server(self, User, Pass, Port, Host):
     def chequear_stado_Server(self, User, Pass, Port, Host):
         try:
         try:
             self.SMTPcliente(User, Pass, Port, Host)
             self.SMTPcliente(User, Pass, Port, Host)
@@ -62,6 +62,8 @@ class StateMail():
         respuesta en cache durante 60 segundos para mejorar performance y si no esta
         respuesta en cache durante 60 segundos para mejorar performance y si no esta
         disponible no se almasena y la proxima respuesta debera hacerse contra el server
         disponible no se almasena y la proxima respuesta debera hacerse contra el server
         remoto para asegurarme de q se solucione el problema"""
         remoto para asegurarme de q se solucione el problema"""
+        if Host == "MAILMASIVO":
+            return(True)
         test = self.revisarCache(User, Pass, Port, Host)
         test = self.revisarCache(User, Pass, Port, Host)
         if not test == "Vencido":
         if not test == "Vencido":
             return(test)
             return(test)

process.py

@@ -66,7 +66,8 @@ class Process:
   def _send(self,state,serv):
   def _send(self,state,serv):
     salio = 0
     salio = 0
     rows = self.conn.query("SELECT * FROM msg WHERE state = ? and serv = ? ",(state,serv))
     rows = self.conn.query("SELECT * FROM msg WHERE state = ? and serv = ? ",(state,serv))
-    print("cantidad pendiente ", serv, len(rows))
+    if not len(rows) == 0:
+      print("cantidad pendiente ", serv, len(rows))
     for query in DBconnection.parseToTable(rows):
     for query in DBconnection.parseToTable(rows):
       # si no existe la carpeta borrar el mensaje
       # si no existe la carpeta borrar el mensaje
       if not os.path.exists(query[Table.path]):
       if not os.path.exists(query[Table.path]):
@@ -98,9 +99,9 @@ class Process:
       # parcialmente enviado
       # parcialmente enviado
       elif partial:
       elif partial:
         self.conn.query("UPDATE msg SET state = ?, type = ? WHERE id = ?",(States.partial,json.dumps(d),query[Table.id]))
         self.conn.query("UPDATE msg SET state = ?, type = ? WHERE id = ?",(States.partial,json.dumps(d),query[Table.id]))
-    if salio > 20:
-      print("corto para q no se aga larga proces 100")
-      return()
+      if salio > 20:
+        print("corto para q no se haga larga proces linea 100")
+        return()
   # devuelve el estado de un mensaje, lo archiva si está enviado
   # devuelve el estado de un mensaje, lo archiva si está enviado
 
 
 
 

services.py

@@ -183,7 +183,7 @@ class Mail(ServiceBase):
     return(n)
     return(n)
 
 
   def sendGrid(self, msg, smtp):
   def sendGrid(self, msg, smtp):
-    #import ipdb; ipdb.set_trace()
+    print("Saliendo por sendgrid")
     texto = open(self.TextoaEnviar, "r").read()
     texto = open(self.TextoaEnviar, "r").read()
     Mail=smtp["username"]
     Mail=smtp["username"]
     KeyAPI=smtp["password"]
     KeyAPI=smtp["password"]