Update func_facebook.py

func_facebook.py

@@ -1,37 +1,36 @@
 import facebook
 import requests
-
 from func_ai import analyze_sentiment
 
 GRAPH_API_URL = 'https://graph.facebook.com/v20.0'
 
-
 def hide_negative_comments(token):
     def init_facebook_client(token):
+        print("Инициализация клиента Facebook.")
         return facebook.GraphAPI(access_token=token)
 
     def get_facebook_posts():
+        print("Получение постов.")
         params = {
-            'include_inline_create': 'true'  # Параметры запроса
+            'include_inline_create': 'true'
         }
         graph = init_facebook_client(token)
         
-        # Fetching user posts
         user_posts_data = graph.get_object(id='me/posts', fields='id,message,created_time')
         user_posts = user_posts_data.get('data', [])
+        print(f"Найдено {len(user_posts)} пользовательских постов.")
     
-        # Fetching ads posts
         ads_posts_data = graph.get_object('me/ads_posts', **params)
         ads_posts = ads_posts_data.get('data', [])
+        print(f"Найдено {len(ads_posts)} рекламных постов.")
         
-        # Combine the posts from both sources
         all_posts = user_posts + ads_posts
+        print(f"Всего постов: {len(all_posts)}.")
         
         return all_posts
 
-
-
     def get_comments_for_post(post_id):
+        print(f"Получение комментариев для поста {post_id}.")
         graph = init_facebook_client(token)
         comments = []
         url = f'{post_id}/comments'
@@ -40,23 +39,25 @@ def hide_negative_comments(token):
             comments_data = graph.get_object(id=url, **params)
             visible_comments = [comment for comment in comments_data.get('data', []) if not comment.get('is_hidden', False)]
             comments.extend(visible_comments)
+            print(f"Найдено {len(visible_comments)} видимых комментариев для поста {post_id}.")
             if 'paging' in comments_data and 'next' in comments_data['paging']:
                 url = comments_data['paging']['next']
-                params = {}  # The 'next' URL already includes access token and fields
+                params = {}
             else:
                 break
         return comments
 
     def filter_comments(comments, sentiments):
-        print("Фильтруем негативные комментарии.")
+        print("Фильтрация негативных комментариев.")
         negative_comments = []
         for comment, sentiment in zip(comments, sentiments):
             if sentiment['label'].lower() == 'negative':
-                print(f"Найден негативный комментарий: {comment['message']}")
+                print(f"Негативный комментарий найден: {comment['message']}")
                 negative_comments.append(comment)
         return negative_comments
 
     def hide_comment(comment_id):
+        print(f"Скрытие комментария {comment_id}.")
         graph = init_facebook_client(token)
         try:
             graph.request(f'{comment_id}', post_args={'is_hidden': True}, method='POST')
@@ -102,6 +103,7 @@ def hide_negative_comments(token):
 
 
 def get_page_id(page_access_token):
+    print("Получение ID страницы.")
     url = f"{GRAPH_API_URL}/me"
     params = {
         "access_token": page_access_token,
@@ -116,6 +118,7 @@ def get_page_id(page_access_token):
 
 
 def get_posts(page_id, page_access_token):
+    print(f"Получение постов для страницы {page_id}.")
     url = f"{GRAPH_API_URL}/{page_id}/posts"
     url_ads = f"{GRAPH_API_URL}/{page_id}/ads_posts?include_inline_create=true"
     params = {
@@ -126,7 +129,6 @@ def get_posts(page_id, page_access_token):
     posts = []
     
     while True:
-        # Выполняем запрос для обычных постов
         response = requests.get(url, params=params)
         data = response.json()
 
@@ -134,10 +136,9 @@ def get_posts(page_id, page_access_token):
             print(f"Ошибка при получении постов: {data['error']}")
             break
         
-        # Добавляем обычные посты в общий список
         posts.extend(data.get("data", []))
-        
-        # Обрабатываем посты с рекламы
+        print(f"Получено {len(data.get('data', []))} постов.")
+
         response_ads = requests.get(url_ads, params={"access_token": page_access_token, "fields": "id,message"})
         data_ads = response_ads.json()
 
@@ -145,14 +146,12 @@ def get_posts(page_id, page_access_token):
             print(f"Ошибка при получении рекламных постов: {data_ads['error']}")
             break
         
-        # Добавляем рекламные посты в общий список
         posts.extend(data_ads.get("data", []))
+        print(f"Получено {len(data_ads.get('data', []))} рекламных постов.")
         
-        # Проверяем, есть ли следующие страницы для обычных постов
         if 'paging' in data and 'next' in data['paging']:
             url = data['paging']['next']
-            # Удаляем параметры, так как они уже в URL
-            params = {}  
+            params = {}
         else:
             break
 
@@ -160,6 +159,7 @@ def get_posts(page_id, page_access_token):
 
 
 def get_comments(post_id, page_access_token):
+    print(f"Получение комментариев для поста {post_id}.")
     url = f"{GRAPH_API_URL}/{post_id}/comments"
     params = {
         "access_token": page_access_token,
@@ -173,6 +173,7 @@ def get_comments(post_id, page_access_token):
             print(f"Ошибка при получении комментариев к посту {post_id}: {data['error']}")
             break
         comments.extend(data.get("data", []))
+        print(f"Найдено {len(data.get('data', []))} комментариев.")
         if 'paging' in data and 'next' in data['paging']:
             url = data['paging']['next']
             params = {}
@@ -182,6 +183,7 @@ def get_comments(post_id, page_access_token):
 
 
 def has_page_replied(comment_id, page_id, page_access_token):
+    print(f"Проверка ответа на комментарий {comment_id}.")
     url = f"{GRAPH_API_URL}/{comment_id}/comments"
     params = {
         "access_token": page_access_token,
@@ -195,6 +197,7 @@ def has_page_replied(comment_id, page_id, page_access_token):
             return False
         for reply in data.get("data", []):
             if reply['from']['id'] == page_id:
+                print(f"Страница {page_id} уже ответила на комментарий {comment_id}.")
                 return True
         if 'paging' in data and 'next' in data['paging']:
             url = data['paging']['next']
@@ -240,6 +243,7 @@ def get_unanswered_comments(page_access_token):
 
 
 def reply_comment(comment_id, message, token):
+    print(f"Отправка ответа на комментарий {comment_id}.")
     url = f"{GRAPH_API_URL}/{comment_id}/comments"
     params = {
         'access_token': token,