Update Linkedin_Data_API_Calls.py

Linkedin_Data_API_Calls.py

@@ -144,3 +144,40 @@ def fetch_posts_and_stats(comm_client_id, community_token, org_urn, count=10):
         post["category"] = structured["category"]
 
     return posts, org_name, sentiments
+
+def prepare_data_for_bubble(posts, sentiments):
+    li_posts = []
+    li_post_stats = []
+    li_post_comments = []
+
+    for post in posts:
+        li_posts.append({
+            "author_urn": post["author_urn"],
+            "id": post["id"],
+            "is_ad": post["is_ad"],
+            "media_type": post["media_type"],
+            "published_at": post["published_at"],
+            "sentiment": sentiments.get(post["id"], {}).get("sentiment", "Neutral"),
+            "text": post["text"]
+        })
+
+        li_post_stats.append({
+            "clickCount": post["clicks"],
+            "commentCount": post["comments"],
+            "engagement": post["engagement"],
+            "impressionCount": post["impressions"],
+            "likeCount": post["likes"],
+            "shareCount": post["shares"],
+            "uniqueImpressionsCount": post.get("uniqueImpressionsCount", 0),
+            "post_id": post["id"]
+        })
+
+        for comment in post.get("comments_data", []):
+            message = comment.get('message', {}).get('text')
+            if message:
+                li_post_comments.append({
+                    "comment_text": message,
+                    "post_id": post["id"]
+                })
+
+    return li_posts, li_post_stats, li_post_comments