Corrected logger and deleted debug leftover

scramjetorg · Jul 5, 2023 · ae6f412 · ae6f412
1 parent 9320fa9
commit ae6f412
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 10 deletions.
diff --git a/python/ChimpInsert/main.py b/python/ChimpInsert/main.py
@@ -14,14 +14,14 @@
 WAIT_TIME_ERROR = 3
 
 class ChimpInsert:
-      def __init__(self, audience_id, config, slack_channel_id, slack_api_url, context):
+      def __init__(self, audience_id, config, slack_channel_id, slack_api_url, logger):
             self.mailchimp = Client()
             self.audience_id = audience_id
             self.mailchimp.set_config(config)
             self.slack_channel_id = slack_channel_id
             self.slack_api_url = slack_api_url
             self.token_header = {'content-type': 'application/json',}
-            self.context = context
+            self.logger = logger
 
       def get_offset(self, audience_id):
             response = self.mailchimp.lists.get_list(audience_id)['stats']
@@ -41,7 +41,7 @@ def insert_info(self, info):
             try:
                   email, fname, lname = info.split(" ")
             except:
-                  self.context.logger.info("Bad data received at topic")
+                  self.logger.info("Bad data received at topic")
 
             try:
                   member_info = {
@@ -54,15 +54,15 @@ def insert_info(self, info):
                   if "auth0-user" in lname:
                         try:
                               response = self.mailchimp.lists.add_list_member(self.audience_id, member_info)
-                              self.context.logger.info("Auth0 user successfully added")
+                              self.logger.info("Auth0 user successfully added")
                               slack_message_resp = requests.post(self.slack_api_url, headers=self.token_header, data=str({"text":f"{email} Auth0 user successfully added"}))
                         except ApiClientError as error:
                               return   
                   elif "auth0-newsletter" in lname:
                         try:
                               member_info['status'] = "subscribed"
                               response = self.mailchimp.lists.add_list_member(self.audience_id, member_info)
-                              self.context.logger.info(f"{email} Auth0 user with newsletter successfully added")
+                              self.logger.info(f"{email} Auth0 user with newsletter successfully added")
                               slack_message_resp = requests.post(self.slack_api_url, headers=self.token_header, data=str({"text":f"{email} Auth0 user with newsletter successfully added"}))
                         except ApiClientError as error:
                               error = json.loads(error.text)
@@ -72,17 +72,17 @@ def insert_info(self, info):
                                     if user_id == -1:
                                           return
                                     response = self.mailchimp.update_list_member(self.audience_id, user_id, {"status" : "subscribed"})
-                                    self.context.logger.info(f"{email} Auth0 user with newsletter successfully added")
+                                    self.logger.info(f"{email} Auth0 user with newsletter successfully added")
                   elif "stripe" in lname:
                         response = self.mailchimp.lists.get_list_members_info(self.audience_id, offset=self.get_offset(self.audience_id))
                         user_id = self.get_info(response, email)
                         if user_id == -1:
                               return
                         response = self.mailchimp.lists.update_list_member_tags(self.audience_id, user_id, {"tags" : [{"name": "Stripe", "status": "active"}]})
-                        self.context.logger.info(f"{email} Stripe user successfully synchronized")
+                        self.logger.info(f"{email} Stripe user successfully synchronized")
                         slack_message_resp = requests.post(self.slack_api_url, headers=self.token_header, data=str({"text":f"{email} Stripe user successfully synchronized"}))
             except:
-                  self.context.logger.info("No data received")
+                  self.logger.info("No data received")
 
 async def run(context, input):
       try:
@@ -93,5 +93,5 @@ async def run(context, input):
       except Exception as error:
             raise Exception(f"Config not loaded: {error}")
 
-      inserter = ChimpInsert(audience_id, config, slack_channel_id, slack_api_url, context)
+      inserter = ChimpInsert(audience_id, config, slack_channel_id, slack_api_url, context.logger)
       return input.each(inserter.insert_info)
diff --git a/python/Stripe/main.py b/python/Stripe/main.py
@@ -25,7 +25,6 @@ def get_fullname(self, user):
       async def get_event(self):
             await asyncio.sleep(3)
             compared = stripe.Event.list(type="customer.created")['data'][-1]
-            tako = stripe.Event.list(type="customer.created")['data']
 
             self.stream.write(self.get_mail(compared)+ " " +self.get_fullname(compared))
             compared = compared['id']