Create func_facebook

func_facebook

@@ -0,0 +1,208 @@
+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):
+        return facebook.GraphAPI(access_token=token)
+
+    def get_facebook_posts():
+        graph = init_facebook_client(token)
+        posts_data = graph.get_object(id='me/posts', fields='id,message,created_time')
+        return posts_data.get('data', [])
+
+    def get_comments_for_all_posts(posts):
+        all_comments = []
+        graph = init_facebook_client(token)
+        for post in posts:
+            comments_data = graph.get_object(id=f'{post["id"]}/comments', fields='message,created_time,id,is_hidden')
+            visible_comments = [comment for comment in comments_data.get('data', []) if
+                                not comment.get('is_hidden', False)]
+            all_comments.extend(visible_comments)
+        return all_comments
+
+    def filter_comments(comments, sentiments):
+        print("Фильтруем негативные комментарии.")
+        negative_comments = []
+        for comment, sentiment in zip(comments, sentiments):
+            if sentiment['label'].lower() == 'negative':
+                print(f"Найден негативный комментарий: {comment['message']}")
+                negative_comments.append(comment)
+        return negative_comments
+
+    def hide_comment(comment_id):
+        graph = init_facebook_client(token)
+        try:
+            graph.request(f'{comment_id}', post_args={'is_hidden': True}, method='POST')
+            return True
+        except facebook.GraphAPIError as e:
+            print(f"Ошибка при скрытии комментария {comment_id}: {e}")
+            return False
+
+    posts = get_facebook_posts()
+    if not posts:
+        print("Нет постов для обработки.")
+        return []
+
+    comments = get_comments_for_all_posts(posts)
+    if not comments:
+        print("Нет комментариев для обработки.")
+        return []
+
+    comments_text = [comment['message'] for comment in comments]
+    sentiments = analyze_sentiment(comments_text)
+    negative_comments = filter_comments(comments, sentiments)
+
+    hidden_comments = []
+    for comment in negative_comments:
+        if hide_comment(comment['id']):
+            hidden_comments.append({
+                'id': comment['id'],
+                'message': comment['message']
+            })
+
+    return hidden_comments
+
+
+def get_facebook_comments(post_id, ACCESS_TOKEN):
+    print(f"Получаем комментарии для поста: {post_id}")
+    url = f"{GRAPH_API_URL}/{post_id}/comments"
+    params = {
+        'access_token': ACCESS_TOKEN,
+        'filter': 'stream'
+    }
+    response = requests.get(url, params=params)
+    if response.status_code == 200:
+        print("Комментарии успешно получены.")
+        return response.json().get('data', [])
+    else:
+        print(f"Ошибка при получении комментариев: {response.text}")
+        return []
+
+
+def get_page_id(page_access_token):
+    url = f"{GRAPH_API_URL}/me"
+    params = {
+        "access_token": page_access_token,
+        "fields": "id,name"
+    }
+    response = requests.get(url, params=params)
+    data = response.json()
+    if 'error' in data:
+        print(f"Ошибка при получении ID страницы: {data['error']}")
+        return None
+    return data.get("id")
+
+
+def get_posts(page_id, page_access_token):
+    url = f"{GRAPH_API_URL}/{page_id}/posts"
+    params = {
+        "access_token": page_access_token,
+        "fields": "id"
+        # Максимальное количество постов за запрос
+    }
+    posts = []
+    while True:
+        response = requests.get(url, params=params)
+        data = response.json()
+        if 'error' in data:
+            print(f"Ошибка при получении постов: {data['error']}")
+            break
+        posts.extend(data.get("data", []))
+        if 'paging' in data and 'next' in data['paging']:
+            url = data['paging']['next']
+            params = {}  # Следующие запросы уже содержат все параметры в URL
+        else:
+            break
+    return posts
+
+
+def get_comments(post_id, page_access_token):
+    url = f"{GRAPH_API_URL}/{post_id}/comments"
+    params = {
+        "access_token": page_access_token,
+        "fields": "id,from,message,is_hidden",
+
+    }
+    comments = []
+    while True:
+        response = requests.get(url, params=params)
+        data = response.json()
+        if 'error' in data:
+            print(f"Ошибка при получении комментариев к посту {post_id}: {data['error']}")
+            break
+        comments.extend(data.get("data", []))
+        if 'paging' in data and 'next' in data['paging']:
+            url = data['paging']['next']
+            params = {}  # Следующие запросы уже содержат все параметры в URL
+        else:
+            break
+    return comments
+
+
+def has_page_replied(comment_id, page_id, page_access_token):
+    url = f"{GRAPH_API_URL}/{comment_id}/comments"
+    params = {
+        "access_token": page_access_token,
+        "fields": "from{id}",
+
+    }
+    while True:
+        response = requests.get(url, params=params)
+        data = response.json()
+        if 'error' in data:
+            print(f"Ошибка при получении ответов на комментарий {comment_id}: {data['error']}")
+            return False
+        for reply in data.get("data", []):
+            if reply['from']['id'] == page_id:
+                return True
+        if 'paging' in data and 'next' in data['paging']:
+            url = data['paging']['next']
+            params = {}
+        else:
+            break
+    return False
+
+
+def get_unanswered_comments(page_access_token):
+    page_id = get_page_id(page_access_token)
+    if not page_id:
+        return []
+
+    print(f"ID Страницы: {page_id}")
+    posts = get_posts(page_id, page_access_token)
+    unanswered_comments = []
+
+    for post in posts:
+        post_id = post['id']
+        print(f"Обработка поста: {post_id}")
+        comments = get_comments(post_id, page_access_token)
+
+        for comment in comments:
+            if comment.get('is_hidden', False):
+                continue
+            comment_id = comment['id']
+            print(f"Проверка комментария: {comment_id}")
+            if not has_page_replied(comment_id, page_id, page_access_token):
+                unanswered_comments.append(comment)
+
+    return unanswered_comments
+
+
+def reply_comment(comment_id, message, token):
+    url = f"{GRAPH_API_URL}/{comment_id}/comments"
+    params = {
+        'access_token': token,
+        'message': message
+    }
+    response = requests.post(url, params=params)
+    if response.status_code == 200:
+        print(f"Ответ успешно отправлен на комментарий {comment_id}.")
+        return True
+    else:
+        print(f"Ошибка при отправке ответа: {response.text}")
+        return False