Update app.py

app.py

@@ -17,25 +17,30 @@ def analyze_and_output(my_id, my_pw, target_id, progress=gr.Progress()):
         
         posts_data = []
         hashtags = []
-        reply_users = []    # メンション・リプライ
-        repost_users = []   # リポストした相手
-        like_users = []     # いいねした相手
+        reply_users = []    
+        repost_users = []   
+        like_users = []     
         
         max_limit = 1000 
         
-        # --- 1. 投稿フィードの分析 (リプライ・リポスト) ---
+        # --- 1. 投稿フィードの分析 ---
         progress(0, desc="フィードを取得中...")
         cursor = None
         while len(posts_data) < max_limit:
             response = client.get_author_feed(actor=profile.did, limit=100, cursor=cursor)
             for feed_view in response.feed:
+                # 安全策1: 投稿自体が存在するか
+                if not feed_view.post or not hasattr(feed_view.post, 'author'):
+                    continue
+
                 # リポストの分析
                 if feed_view.reason and hasattr(feed_view.reason, 'by'):
-                    # 自分がリポストした投稿の、元の投稿者
-                    orig_author = feed_view.post.author.handle
-                    if orig_author != target_handle:
-                        repost_users.append(orig_author)
-                    continue # リポスト自体は本文解析から除外
+                    # 安全策2: リポスト元の投稿者が存在するか
+                    if hasattr(feed_view.post, 'author') and feed_view.post.author:
+                        orig_author = feed_view.post.author.handle
+                        if orig_author != target_handle:
+                            repost_users.append(orig_author)
+                    continue 
 
                 post = feed_view.post
                 if post.author.handle == target_handle:
@@ -43,46 +48,52 @@ def analyze_and_output(my_id, my_pw, target_id, progress=gr.Progress()):
                     post_url = f"https://bsky.app/profile/{target_handle}/post/{rkey}"
                     
                     posts_data.append({
-                        'text': post.record.text,
+                        'text': post.record.text if hasattr(post.record, 'text') else "",
                         'created_at': pd.to_datetime(post.record.created_at),
                         'likes': post.like_count,
                         'reposts': post.repost_count,
-                        'score': post.like_count + post.repost_count,
+                        'score': (post.like_count or 0) + (post.repost_count or 0),
                         'url': post_url
                     })
 
-                    hashtags.extend(re.findall(r'#(\w+)', post.record.text))
+                    if hasattr(post.record, 'text'):
+                        hashtags.extend(re.findall(r'#(\w+)', post.record.text))
                     
-                    # リプライ・メンション相手
+                    # 安全策3: リプライ相手の存在チェック
                     if feed_view.reply and feed_view.reply.parent:
-                        if hasattr(feed_view.reply.parent, 'author'):
-                            parent_author = feed_view.reply.parent.author.handle
+                        parent = feed_view.reply.parent
+                        if hasattr(parent, 'author') and parent.author:
+                            parent_author = parent.author.handle
                             if parent_author != target_handle:
                                 reply_users.append(parent_author)
 
             cursor = response.cursor
             if not cursor or len(posts_data) >= max_limit: break
-            progress(len(posts_data)/max_limit * 0.5, desc=f"フィード解析中...")
+            progress(min(len(posts_data)/max_limit * 0.5, 0.5), desc=f"{len(posts_data)}件取得中...")
 
         # --- 2. いいね一覧の分析 ---
         progress(0.6, desc="いいねした相手を分析中...")
         like_cursor = None
-        # いいねは直近200件程度をサンプルとして取得（API負荷考慮）
         for _ in range(2): 
-            likes_resp = client.get_actor_likes(actor=profile.did, limit=100, cursor=like_cursor)
-            for like_item in likes_resp.feed:
-                if like_item.post and like_item.post.author:
-                    l_author = like_item.post.author.handle
-                    if l_author != target_handle:
-                        like_users.append(l_author)
-            like_cursor = likes_resp.cursor
-            if not like_cursor: break
+            try:
+                likes_resp = client.get_actor_likes(actor=profile.did, limit=100, cursor=like_cursor)
+                for like_item in likes_resp.feed:
+                    # 安全策4: いいね先の投稿者が存在するか
+                    if like_item.post and hasattr(like_item.post, 'author') and like_item.post.author:
+                        l_author = like_item.post.author.handle
+                        if l_author != target_handle:
+                            like_users.append(l_author)
+                like_cursor = likes_resp.cursor
+                if not like_cursor: break
+            except:
+                break # いいね取得でエラーが出ても止まらないようにする
 
-        if not posts_data: return "データなし", "", "", "終了"
+        if not posts_data: return "有効な投稿データが見つかりませんでした", "", "", "終了"
 
         # --- 3. HTML作成 ---
         df = pd.DataFrame(posts_data)
-        first_post = df.iloc[-1]
+        df = df.sort_values('created_at', ascending=True) # 古い順にして初投稿を確定
+        first_post = df.iloc[0]
         days_active = max((datetime.now().replace(tzinfo=None) - first_post['created_at'].replace(tzinfo=None)).days, 1)
 
         stats_html = f"""
@@ -99,7 +110,6 @@ def analyze_and_output(my_id, my_pw, target_id, progress=gr.Progress()):
         </div>
         """
 
-        # ランキングHTML
         def make_rank_list(title, icon, counter_list):
             html = f"<b>{icon} {title}</b><div style='font-size: 0.85em; color: #444; margin: 5px 0 15px 0;'>"
             if not counter_list: return html + "データなし</div>"
@@ -118,15 +128,12 @@ def analyze_and_output(my_id, my_pw, target_id, progress=gr.Progress()):
         </div>
         """
 
-        # ベストポスト等 (前回同様)
         top_3 = df.sort_values('score', ascending=False).head(3)
-        posts_html = f"<h4>🌱 初投稿 ({first_post['created_at'].strftime('%Y/%m/%d')})</h4><p style='font-size: 0.9em; background:#f9f9f9; padding:10px; border-radius:5px;'>{first_post['text']}</p><h4 style='color: #ff4081;'>🏆 ベストポスト Top 3</h4>"
+        posts_html = f"<h4>🌱 取得範囲内の初投稿 ({first_post['created_at'].strftime('%Y/%m/%d')})</h4><p style='font-size: 0.9em; background:#f9f9f9; padding:10px; border-radius:5px;'>{first_post['text']}</p><h4 style='color: #ff4081;'>🏆 ベストポスト Top 3</h4>"
         for i, (_, row) in enumerate(top_3.iterrows(), 1):
             posts_html += f"<div style='border: 1px solid #ffc107; padding: 10px; margin-bottom: 8px; border-radius: 8px; font-size: 0.9em;'><b>第{i}位</b> (❤️{row['likes']} 🔄{row['reposts']})<br>{row['text'][:80]}...<br><a href='{row['url']}' target='_blank' style='color:#ff4081;'>投稿を見る</a></div>"
 
         return stats_html, rank_html, posts_html, "解析完了！"
 
     except Exception as e:
-        return f"エラー: {str(e)}", "", "", "失敗"
-
-# (Gradio UI部分は変更なし)
+        return f"エラー詳細: {str(e)}", "", "", "失敗"