From bbf17c5a7d2d5f104b258f8ff8f187a159e09b53 Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: Fri, 7 Feb 2025 13:54:56 -0500
Subject: [PATCH] automated terminal push

---
 consumer (copy 1) (copy 1).py | 84 +++++++++++++++++++++++++++++++++++
 consumer (copy 1).py          | 16 +------
 consumer.py                   | 24 +++++++++-
 3 files changed, 108 insertions(+), 16 deletions(-)
 create mode 100644 consumer (copy 1) (copy 1).py

diff --git a/consumer (copy 1) (copy 1).py b/consumer (copy 1) (copy 1).py
new file mode 100644
index 0000000..a775274
--- /dev/null
+++ b/consumer (copy 1) (copy 1).py	
@@ -0,0 +1,84 @@
+import stomp
+import time
+import SullyGnomeRobot
+import RestAPIClient
+
+print("## ")
+print("## starting > JMS consumer (yankee-sully-channels-monthly)")
+print("## ")
+
+class MyListener(stomp.ConnectionListener):
+
+    def on_message(headers, message):
+
+        print("** new message! **")
+
+        print("message / ", message)
+
+        print("messagebody / ", message.body)
+
+        print("checking the value does or doesnt exist in db")
+
+        alreadyExistsSuccess = RestAPIClient.searchURLSuccesses(message.body)
+
+        print("alreadyExistsSuccess / ", alreadyExistsSuccess)
+
+        if alreadyExistsSuccess.lower().strip() == "true":
+    
+            print("this record exists (successes). returning. doing nothing")
+
+            return
+
+        print("didn't exist in success. check in errors now.")
+
+        alreadyExistsFailure = RestAPIClient.searchURLFailures(message.body)
+
+        print("alreadyExistsFailure / ", alreadyExistsFailure)
+
+        if alreadyExistsFailure.lower().strip() == "true":
+
+            print("this record exists (failures). returning. doing nothing")
+
+            return
+
+        print("didn't exist in success or errors. will process now")
+
+        try:
+        
+            SullyGnomeRobot.download(message.body)
+
+        except Exception as e:
+
+            print(f"exception / something went wrong when the sully gnome robot was downloading: {e}")
+
+            RestAPIClient.addDownloadFailure(message.body)
+
+    def on_error(headers, message):
+
+        print('received an error "%s"' % message)
+        
+        RestAPIClient.addDownloadFailure(message.body)
+
+print("## ")
+print("## starting > JMS consumer (yankee-sully-channels-monthly)")
+print("## ")
+
+conn = stomp.Connection([('osiris.yankee.embanet.online', 61613)])
+
+conn.set_listener('', MyListener())
+
+conn.connect('admin', 'password', wait=True)
+
+conn.subscribe('/queue/yankee-sully-channels-monthly', id=1, ack='auto', headers={'activemq.prefetchSize': 10})
+
+print("## ")
+print("## notification > connected to JMS server (yankee-sully-channels-monthly)")
+print("## ")
+
+while True:
+
+    pass
+
+    time.sleep(1)
+    
+conn.disconnect()
diff --git a/consumer (copy 1).py b/consumer (copy 1).py
index a775274..ea209bf 100644
--- a/consumer (copy 1).py	
+++ b/consumer (copy 1).py	
@@ -1,11 +1,8 @@
 import stomp
-import time
+
 import SullyGnomeRobot
 import RestAPIClient
 
-print("## ")
-print("## starting > JMS consumer (yankee-sully-channels-monthly)")
-print("## ")
 
 class MyListener(stomp.ConnectionListener):
 
@@ -59,10 +56,6 @@ class MyListener(stomp.ConnectionListener):
         
         RestAPIClient.addDownloadFailure(message.body)
 
-print("## ")
-print("## starting > JMS consumer (yankee-sully-channels-monthly)")
-print("## ")
-
 conn = stomp.Connection([('osiris.yankee.embanet.online', 61613)])
 
 conn.set_listener('', MyListener())
@@ -71,14 +64,7 @@ conn.connect('admin', 'password', wait=True)
 
 conn.subscribe('/queue/yankee-sully-channels-monthly', id=1, ack='auto', headers={'activemq.prefetchSize': 10})
 
-print("## ")
-print("## notification > connected to JMS server (yankee-sully-channels-monthly)")
-print("## ")
 
-while True:
 
-    pass
-
-    time.sleep(1)
     
 conn.disconnect()
diff --git a/consumer.py b/consumer.py
index ce47b77..319fe55 100644
--- a/consumer.py
+++ b/consumer.py
@@ -1 +1,23 @@
-print("hello")
\ No newline at end of file
+import time
+
+print("## ")
+print("## starting > JMS consumer (yankee-sully-channels-monthly)")
+print("## ")
+
+
+
+
+
+
+
+
+print("## ")
+print("## notification > connected to JMS server (yankee-sully-channels-monthly)")
+print("## ")
+
+
+while True:
+
+    pass
+
+    time.sleep(1)
\ No newline at end of file