Update bluesky_fetcher.py

bluesky_fetcher.py

@@ -34,6 +34,35 @@ class BlueskyFetcher:
                         post_id = parts[-1]
                         web_url = f"https://bsky.app/profile/{author.get('handle', '')}/post/{post_id}"
                 
+                # Extract quote post if present
+                quote_post = None
+                embed = post.get("embed", {})
+                embed_type = embed.get("$type", "")
+                
+                # Quote post (app.bsky.embed.record#view)
+                if "record" in embed_type or embed_type == "app.bsky.embed.record#view":
+                    quoted = embed.get("record", {})
+                    if quoted.get("$type") == "app.bsky.embed.record#viewRecord" or "value" in quoted:
+                        quote_author = quoted.get("author", {})
+                        quote_value = quoted.get("value", {})
+                        quote_post = {
+                            "author_handle": quote_author.get("handle", ""),
+                            "author_name": quote_author.get("displayName", ""),
+                            "text": quote_value.get("text", "")
+                        }
+                
+                # Quote post with media (app.bsky.embed.recordWithMedia#view)
+                if "recordWithMedia" in embed_type:
+                    quoted = embed.get("record", {}).get("record", {})
+                    if quoted:
+                        quote_author = quoted.get("author", {})
+                        quote_value = quoted.get("value", {})
+                        quote_post = {
+                            "author_handle": quote_author.get("handle", ""),
+                            "author_name": quote_author.get("displayName", ""),
+                            "text": quote_value.get("text", "")
+                        }
+                
                 posts.append({
                     "uri": uri,
                     "platform": "bluesky",
@@ -42,7 +71,8 @@ class BlueskyFetcher:
                     "author_avatar": author.get("avatar", ""),
                     "text": record.get("text", ""),
                     "created_at": record.get("createdAt", ""),
-                    "web_url": web_url
+                    "web_url": web_url,
+                    "quote_post": quote_post
                 })
         except:
             pass