test update json

2025-06-15 18:42:49 +09:00
parent 4df7f72312
commit 9e437c9fc3
16 changed files with 719 additions and 552 deletions
--- a/.claude/settings.local.json
+++ b/.claude/settings.local.json
@@ -47,7 +47,8 @@
      "Bash(git push:*)",
      "Bash(git tag:*)",
      "Bash(../bin/ailog:*)",
-      "Bash(../target/release/ailog oauth build:*)"
+      "Bash(../target/release/ailog oauth build:*)",
+      "Bash(ailog:*)"
    ],
    "deny": []
  }
--- a/.gitignore
+++ b/.gitignore
@@ -12,3 +12,4 @@ node_modules
 package-lock.json 
 my-blog/static/assets/comment-atproto-*
 bin/ailog
+docs
--- a/claude.md
+++ b/claude.md
@@ -473,6 +473,11 @@ jobs:
        publish_branch: gh-pages
 ```

+## 注意事項
+
+`console.log`は絶対に付けないように。
+
+
 # footer

 © syui
--- a/my-blog/static/index.html
+++ b/my-blog/static/index.html
@@ -1,3 +1,3 @@
 <!-- OAuth Comment System - Load globally for session management -->
-<script type="module" crossorigin src="/assets/comment-atproto-G86WWmu8.js"></script>
-<link rel="stylesheet" crossorigin href="/assets/comment-atproto-FS0uZjXB.css">
+<script type="module" crossorigin src="/assets/comment-atproto-DhjiALC0.js"></script>
+<link rel="stylesheet" crossorigin href="/assets/comment-atproto-BH-72ESb.css">
--- a/my-blog/templates/oauth-assets.html
+++ b/my-blog/templates/oauth-assets.html
@@ -1,3 +1,3 @@
 <!-- OAuth Comment System - Load globally for session management -->
-<script type="module" crossorigin src="/assets/comment-atproto-G86WWmu8.js"></script>
-<link rel="stylesheet" crossorigin href="/assets/comment-atproto-FS0uZjXB.css">
+<script type="module" crossorigin src="/assets/comment-atproto-DhjiALC0.js"></script>
+<link rel="stylesheet" crossorigin href="/assets/comment-atproto-BH-72ESb.css">
--- a/oauth/.env.production
+++ b/oauth/.env.production
@@ -4,9 +4,8 @@ VITE_OAUTH_CLIENT_ID=https://syui.ai/client-metadata.json
 VITE_OAUTH_REDIRECT_URI=https://syui.ai/oauth/callback
 VITE_ADMIN_DID=did:plc:uqzpqmrjnptsxezjx4xuh2mn

-# Base collection for OAuth app and ailog (all others are derived)
+# Base collection (all others are derived via getCollectionNames)
 VITE_OAUTH_COLLECTION=ai.syui.log
-# [user, chat, chat.lang, chat.comment]

 # AI Configuration
 VITE_AI_ENABLED=true
@@ -19,3 +18,4 @@ VITE_AI_DID=did:plc:4hqjfn7m6n5hno3doamuhgef

 # API Configuration
 VITE_BSKY_PUBLIC_API=https://public.api.bsky.app
+VITE_ATPROTO_API=https://bsky.social
--- a/oauth/src/App.css
+++ b/oauth/src/App.css
@@ -194,6 +194,7 @@
    padding: 10px !important;
    word-wrap: break-word !important;
    overflow-wrap: break-word !important;
+    white-space: pre-wrap !important;
  }
  
  .comment-header {
@@ -610,6 +611,8 @@
  line-height: 1.5;
  color: #333;
  margin-bottom: 10px;
+  white-space: pre-wrap;
+  word-wrap: break-word;
 }

 .comment-meta {
--- a/oauth/src/App.tsx
+++ b/oauth/src/App.tsx
--- a/oauth/src/components/AIChat.tsx
+++ b/oauth/src/components/AIChat.tsx
@@ -1,7 +1,7 @@
 import React, { useState, useEffect } from 'react';
 import { User } from '../services/auth';
 import { atprotoOAuthService } from '../services/atproto-oauth';
-import { appConfig } from '../config/app';
+import { appConfig, getCollectionNames } from '../config/app';

 interface AIChatProps {
  user: User | null;
@@ -14,26 +14,22 @@ export const AIChat: React.FC<AIChatProps> = ({ user, isEnabled }) => {
  const [isProcessing, setIsProcessing] = useState(false);
  const [aiProfile, setAiProfile] = useState<any>(null);
  
-  // Get AI settings from environment variables
+  // Get AI settings from appConfig (unified configuration)
  const aiConfig = {
-    enabled: import.meta.env.VITE_AI_ENABLED === 'true',
-    askAi: import.meta.env.VITE_AI_ASK_AI === 'true',
-    provider: import.meta.env.VITE_AI_PROVIDER || 'ollama',
-    model: import.meta.env.VITE_AI_MODEL || 'gemma3:4b',
-    host: import.meta.env.VITE_AI_HOST || 'https://ollama.syui.ai',
-    systemPrompt: import.meta.env.VITE_AI_SYSTEM_PROMPT || 'You are a helpful AI assistant trained on this blog\'s content.',
-    aiDid: import.meta.env.VITE_AI_DID || 'did:plc:uqzpqmrjnptsxezjx4xuh2mn',
-    bskyPublicApi: import.meta.env.VITE_BSKY_PUBLIC_API || 'https://public.api.bsky.app',
+    enabled: appConfig.aiEnabled,
+    askAi: appConfig.aiAskAi,
+    provider: appConfig.aiProvider,
+    model: appConfig.aiModel,
+    host: appConfig.aiHost,
+    systemPrompt: appConfig.aiSystemPrompt,
+    aiDid: appConfig.aiDid,
+    bskyPublicApi: appConfig.bskyPublicApi,
  };

  // Fetch AI profile on load
  useEffect(() => {
    const fetchAIProfile = async () => {
-      console.log('=== AI PROFILE FETCH START ===');
-      console.log('AI DID:', aiConfig.aiDid);
-      
      if (!aiConfig.aiDid) {
-        console.log('No AI DID configured');
        return;
      }
      
@@ -41,9 +37,7 @@ export const AIChat: React.FC<AIChatProps> = ({ user, isEnabled }) => {
        // Try with agent first
        const agent = atprotoOAuthService.getAgent();
        if (agent) {
-          console.log('Fetching AI profile with agent for DID:', aiConfig.aiDid);
          const profile = await agent.getProfile({ actor: aiConfig.aiDid });
-          console.log('AI profile fetched successfully:', profile.data);
          const profileData = {
            did: aiConfig.aiDid,
            handle: profile.data.handle,
@@ -51,21 +45,17 @@ export const AIChat: React.FC<AIChatProps> = ({ user, isEnabled }) => {
            avatar: profile.data.avatar,
            description: profile.data.description
          };
-          console.log('Setting aiProfile to:', profileData);
          setAiProfile(profileData);
          
          // Dispatch event to update Ask AI button
          window.dispatchEvent(new CustomEvent('aiProfileLoaded', { detail: profileData }));
-          console.log('=== AI PROFILE FETCH SUCCESS (AGENT) ===');
          return;
        }
        
        // Fallback to public API
-        console.log('No agent available, trying public API for AI profile');
        const response = await fetch(`${aiConfig.bskyPublicApi}/xrpc/app.bsky.actor.getProfile?actor=${encodeURIComponent(aiConfig.aiDid)}`);
        if (response.ok) {
          const profileData = await response.json();
-          console.log('AI profile fetched via public API:', profileData);
          const profile = {
            did: aiConfig.aiDid,
            handle: profileData.handle,
@@ -73,21 +63,15 @@ export const AIChat: React.FC<AIChatProps> = ({ user, isEnabled }) => {
            avatar: profileData.avatar,
            description: profileData.description
          };
-          console.log('Setting aiProfile to:', profile);
          setAiProfile(profile);
          
          // Dispatch event to update Ask AI button
          window.dispatchEvent(new CustomEvent('aiProfileLoaded', { detail: profile }));
-          console.log('=== AI PROFILE FETCH SUCCESS (PUBLIC API) ===');
          return;
-        } else {
-          console.error('Public API failed with status:', response.status);
        }
      } catch (error) {
-        console.error('Failed to fetch AI profile:', error);
        setAiProfile(null);
      }
-      console.log('=== AI PROFILE FETCH FAILED ===');
    };

    fetchAIProfile();
@@ -100,9 +84,6 @@ export const AIChat: React.FC<AIChatProps> = ({ user, isEnabled }) => {
    const handleAIQuestion = async (event: any) => {
      if (!user || !event.detail || !event.detail.question || isProcessing || !aiProfile) return;
      
-      console.log('AIChat received question:', event.detail.question);
-      console.log('Current aiProfile state:', aiProfile);
-      
      setIsProcessing(true);
      try {
        await postQuestionAndGenerateResponse(event.detail.question);
@@ -114,7 +95,6 @@ export const AIChat: React.FC<AIChatProps> = ({ user, isEnabled }) => {
    // Add listener with a small delay to ensure it's ready
    setTimeout(() => {
      window.addEventListener('postAIQuestion', handleAIQuestion);
-      console.log('AIChat event listener registered');
      
      // Notify that AI is ready
      window.dispatchEvent(new CustomEvent('aiChatReady'));
@@ -134,40 +114,50 @@ export const AIChat: React.FC<AIChatProps> = ({ user, isEnabled }) => {
      const agent = atprotoOAuthService.getAgent();
      if (!agent) throw new Error('No agent available');

+      // Get collection names
+      const collections = getCollectionNames(appConfig.collections.base);
+
      // 1. Post question to ATProto
      const now = new Date();
      const rkey = now.toISOString().replace(/[:.]/g, '-');
      
+      // Extract post metadata from current page
+      const currentUrl = window.location.href;
+      const postSlug = currentUrl.match(/\/posts\/([^/]+)/)?.[1] || '';
+      const postTitle = document.title.replace(' - syui.ai', '') || '';
+      
      const questionRecord = {
-        $type: appConfig.collections.chat,
-        question: question,
-        url: window.location.href,
-        createdAt: now.toISOString(),
+        $type: collections.chat,
+        post: {
+          url: currentUrl,
+          slug: postSlug,
+          title: postTitle,
+          date: new Date().toISOString(),
+          tags: [],
+          language: "ja"
+        },
+        type: "question",
+        text: question,
        author: {
          did: user.did,
          handle: user.handle,
          avatar: user.avatar,
          displayName: user.displayName || user.handle,
        },
-        context: {
-          page_title: document.title,
-          page_url: window.location.href,
-        },
+        createdAt: now.toISOString(),
      };

      await agent.api.com.atproto.repo.putRecord({
        repo: user.did,
-        collection: appConfig.collections.chat,
+        collection: collections.chat,
        rkey: rkey,
        record: questionRecord,
      });

-      console.log('Question posted to ATProto');
-
      // 2. Get chat history
      const chatRecords = await agent.api.com.atproto.repo.listRecords({
        repo: user.did,
-        collection: appConfig.collections.chat,
+        collection: collections.chat,
        limit: 10,
      });

@@ -175,10 +165,10 @@ export const AIChat: React.FC<AIChatProps> = ({ user, isEnabled }) => {
      if (chatRecords.data.records) {
        chatHistoryText = chatRecords.data.records
          .map((r: any) => {
-            if (r.value.question) {
-              return `User: ${r.value.question}`;
-            } else if (r.value.answer) {
-              return `AI: ${r.value.answer}`;
+            if (r.value.type === 'question') {
+              return `User: ${r.value.text}`;
+            } else if (r.value.type === 'answer') {
+              return `AI: ${r.value.text}`;
            }
            return '';
          })
@@ -235,37 +225,38 @@ Answer:`;
      // 5. Save AI response in background
      const answerRkey = now.toISOString().replace(/[:.]/g, '-') + '-answer';
      
-      console.log('=== SAVING AI ANSWER ===');
-      console.log('Current aiProfile:', aiProfile);
-      
      const answerRecord = {
-        $type: appConfig.collections.chat,
-        answer: aiAnswer,
-        question_rkey: rkey,
-        url: window.location.href,
-        createdAt: now.toISOString(),
+        $type: collections.chat,
+        post: {
+          url: currentUrl,
+          slug: postSlug,
+          title: postTitle,
+          date: new Date().toISOString(),
+          tags: [],
+          language: "ja"
+        },
+        type: "answer",
+        text: aiAnswer,
        author: {
          did: aiProfile.did,
          handle: aiProfile.handle,
          displayName: aiProfile.displayName,
          avatar: aiProfile.avatar,
        },
+        createdAt: now.toISOString(),
      };

-      console.log('Answer record to save:', answerRecord);
-
      // Save to ATProto asynchronously (don't wait for it)
      agent.api.com.atproto.repo.putRecord({
        repo: user.did,
-        collection: appConfig.collections.chat,
+        collection: collections.chat,
        rkey: answerRkey,
        record: answerRecord,
      }).catch(err => {
-        console.error('Failed to save AI response to ATProto:', err);
+        // Silent fail for AI response saving
      });

    } catch (error) {
-      console.error('Failed to generate AI response:', error);
      window.dispatchEvent(new CustomEvent('aiResponseError', {
        detail: { error: 'AI応答の生成に失敗しました' }
      }));
--- a/oauth/src/config/app.ts
+++ b/oauth/src/config/app.ts
@@ -1,6 +1,7 @@
 // Application configuration
 export interface AppConfig {
  adminDid: string;
+  aiDid: string;
  collections: {
    base: string;  // Base collection like "ai.syui.log"
  };
@@ -11,18 +12,27 @@ export interface AppConfig {
  aiProvider: string;
  aiModel: string;
  aiHost: string;
+  aiSystemPrompt: string;
  bskyPublicApi: string;
+  atprotoApi: string;
 }

 // Collection name builders (similar to Rust implementation)
 export function getCollectionNames(base: string) {
-  return {
+  if (!base) {
+    // Fallback to default
+    base = 'ai.syui.log';
+  }
+  
+  const collections = {
    comment: base,
    user: `${base}.user`,
    chat: `${base}.chat`,
    chatLang: `${base}.chat.lang`,
    chatComment: `${base}.chat.comment`,
  };
+  
+  return collections;
 }

 // Generate collection names from host
@@ -43,9 +53,9 @@ function generateBaseCollectionFromHost(host: string): string {
    // Reverse the parts for collection naming
    // log.syui.ai -> ai.syui.log
    const reversedParts = parts.reverse();
-    return reversedParts.join('.');
+    const result = reversedParts.join('.');
+    return result;
  } catch (error) {
-    console.warn('Failed to generate collection base from host:', host, error);
    // Fallback to default
    return 'ai.syui.log';
  }
@@ -63,11 +73,19 @@ function extractRkeyFromUrl(): string | undefined {
 export function getAppConfig(): AppConfig {
  const host = import.meta.env.VITE_APP_HOST || 'https://log.syui.ai';
  const adminDid = import.meta.env.VITE_ADMIN_DID || 'did:plc:uqzpqmrjnptsxezjx4xuh2mn';
+  const aiDid = import.meta.env.VITE_AI_DID || 'did:plc:4hqjfn7m6n5hno3doamuhgef';
  
  // Priority: Environment variables > Auto-generated from host
  const autoGeneratedBase = generateBaseCollectionFromHost(host);
+  let baseCollection = import.meta.env.VITE_OAUTH_COLLECTION || autoGeneratedBase;
+  
+  // Ensure base collection is never undefined
+  if (!baseCollection) {
+    baseCollection = 'ai.syui.log';
+  }
+  
  const collections = {
-    base: import.meta.env.VITE_OAUTH_COLLECTION || autoGeneratedBase,
+    base: baseCollection,
  };
  
  const rkey = extractRkeyFromUrl();
@@ -78,19 +96,14 @@ export function getAppConfig(): AppConfig {
  const aiProvider = import.meta.env.VITE_AI_PROVIDER || 'ollama';
  const aiModel = import.meta.env.VITE_AI_MODEL || 'gemma2:2b';
  const aiHost = import.meta.env.VITE_AI_HOST || 'https://ollama.syui.ai';
+  const aiSystemPrompt = import.meta.env.VITE_AI_SYSTEM_PROMPT || 'You are a helpful AI assistant trained on this blog\'s content.';
  const bskyPublicApi = import.meta.env.VITE_BSKY_PUBLIC_API || 'https://public.api.bsky.app';
+  const atprotoApi = import.meta.env.VITE_ATPROTO_API || 'https://bsky.social';
  
-  console.log('App configuration:', {
-    host,
-    adminDid,
-    collections,
-    rkey: rkey || 'none (not on post page)',
-    ai: { enabled: aiEnabled, askAi: aiAskAi, provider: aiProvider, model: aiModel, host: aiHost },
-    bskyPublicApi
-  });
  
  return {
    adminDid,
+    aiDid,
    collections,
    host,
    rkey,
@@ -99,7 +112,9 @@ export function getAppConfig(): AppConfig {
    aiProvider,
    aiModel,
    aiHost,
-    bskyPublicApi
+    aiSystemPrompt,
+    bskyPublicApi,
+    atprotoApi
  };
 }

--- a/oauth/src/services/api.ts
+++ b/oauth/src/services/api.ts
@@ -73,7 +73,6 @@ export const aiCardApi = {
      });
      return response.data.data;
    } catch (error) {
-      console.warn('ai.gpt AI分析機能が利用できません:', error);
      throw new Error('AI分析機能を利用するにはai.gptサーバーが必要です');
    }
  },
@@ -86,7 +85,6 @@ export const aiCardApi = {
      const response = await aiGptApi.get('/card_get_gacha_stats');
      return response.data.data;
    } catch (error) {
-      console.warn('ai.gpt AI統計機能が利用できません:', error);
      throw new Error('AI統計機能を利用するにはai.gptサーバーが必要です');
    }
  },
--- a/oauth/src/services/atproto-oauth.ts
+++ b/oauth/src/services/atproto-oauth.ts
@@ -31,11 +31,11 @@ class AtprotoOAuthService {

  private async _doInitialize(): Promise<void> {
    try {
-      console.log('=== INITIALIZING ATPROTO OAUTH CLIENT ===');
+
      
      // Generate client ID based on current origin
      const clientId = this.getClientId();
-      console.log('Client ID:', clientId);
+
      
      // Support multiple PDS hosts for OAuth
      this.oauthClient = await BrowserOAuthClient.load({
@@ -43,39 +43,33 @@ class AtprotoOAuthService {
        handleResolver: 'https://bsky.social', // Default resolver
      });
      
-      console.log('BrowserOAuthClient initialized successfully with multi-PDS support');
+
      
      // Try to restore existing session
      const result = await this.oauthClient.init();
      if (result?.session) {
-        console.log('Existing session restored:', {
-          did: result.session.did,
-          handle: result.session.handle || 'unknown',
-          hasAccessJwt: !!result.session.accessJwt,
-          hasRefreshJwt: !!result.session.refreshJwt
-        });
        
        // Create Agent instance with proper configuration
-        console.log('Creating Agent with session:', result.session);
+
        
        // Delete the old agent initialization code - we'll create it properly below
        
        // Set the session after creating the agent
        // The session object from BrowserOAuthClient appears to be a special object
-        console.log('Full session object:', result.session);
-        console.log('Session type:', typeof result.session);
-        console.log('Session constructor:', result.session?.constructor?.name);
+
+
+
        
        // Try to iterate over the session object
        if (result.session) {
-          console.log('Session properties:');
+
          for (const key in result.session) {
-            console.log(`  ${key}:`, result.session[key]);
+
          }
          
          // Check if session has methods
          const methods = Object.getOwnPropertyNames(Object.getPrototypeOf(result.session));
-          console.log('Session methods:', methods);
+
        }
        
        // BrowserOAuthClient might return a Session object that needs to be used with the agent
@@ -83,36 +77,36 @@ class AtprotoOAuthService {
        if (result.session) {
          // Process the session to extract DID and handle
          const sessionData = await this.processSession(result.session);
-          console.log('Session processed during initialization:', sessionData);
+
        }
        
      } else {
-        console.log('No existing session found');
+
      }
      
    } catch (error) {
-      console.error('Failed to initialize OAuth client:', error);
+
      this.initializePromise = null; // Reset on error to allow retry
      throw error;
    }
  }

  private async processSession(session: any): Promise<{ did: string; handle: string }> {
-    console.log('Processing session:', session);
+
    
    // Log full session structure
-    console.log('Session structure:');
-    console.log('- sub:', session.sub);
-    console.log('- did:', session.did);
-    console.log('- handle:', session.handle);
-    console.log('- iss:', session.iss);
-    console.log('- aud:', session.aud);
+
+
+
+
+
+
    
    // Check if agent has properties we can access
    if (session.agent) {
-      console.log('- agent:', session.agent);
-      console.log('- agent.did:', session.agent?.did);
-      console.log('- agent.handle:', session.agent?.handle);
+
+
+
    }
    
    const did = session.sub || session.did;
@@ -121,18 +115,18 @@ class AtprotoOAuthService {
    // Create Agent directly with session (per official docs)
    try {
      this.agent = new Agent(session);
-      console.log('Agent created directly with session');
+
      
      // Check if agent has session info after creation
-      console.log('Agent after creation:');
-      console.log('- agent.did:', this.agent.did);
-      console.log('- agent.session:', this.agent.session);
+
+
+
      if (this.agent.session) {
-        console.log('- agent.session.did:', this.agent.session.did);
-        console.log('- agent.session.handle:', this.agent.session.handle);
+
+
      }
    } catch (err) {
-      console.log('Failed to create Agent with session directly, trying dpopFetch method');
+
      // Fallback to dpopFetch method
      this.agent = new Agent({
        service: session.server?.serviceEndpoint || 'https://bsky.social',
@@ -145,7 +139,7 @@ class AtprotoOAuthService {
    
    // If handle is missing, try multiple methods to resolve it
    if (!handle || handle === 'unknown') {
-      console.log('Handle not in session, attempting to resolve...');
+
      
      // Method 1: Try using the agent to get profile
      try {
@@ -154,11 +148,11 @@ class AtprotoOAuthService {
        if (profile.data.handle) {
          handle = profile.data.handle;
          (this as any)._sessionInfo.handle = handle;
-          console.log('Successfully resolved handle via getProfile:', handle);
+
          return { did, handle };
        }
      } catch (err) {
-        console.error('getProfile failed:', err);
+
      }
      
      // Method 2: Try using describeRepo
@@ -169,18 +163,20 @@ class AtprotoOAuthService {
        if (repoDesc.data.handle) {
          handle = repoDesc.data.handle;
          (this as any)._sessionInfo.handle = handle;
-          console.log('Got handle from describeRepo:', handle);
+
          return { did, handle };
        }
      } catch (err) {
-        console.error('describeRepo failed:', err);
+
      }
      
-      // Method 3: Hardcoded fallback for known DIDs
-      if (did === 'did:plc:uqzpqmrjnptsxezjx4xuh2mn') {
-        handle = 'syui.ai';
+      // Method 3: Fallback for admin DID
+      const adminDid = import.meta.env.VITE_ADMIN_DID;
+      if (did === adminDid) {
+        const appHost = import.meta.env.VITE_APP_HOST || 'https://syui.ai';
+        handle = new URL(appHost).hostname;
        (this as any)._sessionInfo.handle = handle;
-        console.log('Using hardcoded handle for known DID');
+
      }
    }
    
@@ -191,7 +187,7 @@ class AtprotoOAuthService {
    // Use environment variable if available
    const envClientId = import.meta.env.VITE_OAUTH_CLIENT_ID;
    if (envClientId) {
-      console.log('Using client ID from environment:', envClientId);
+
      return envClientId;
    }
    
@@ -200,7 +196,7 @@ class AtprotoOAuthService {
    // For localhost development, use undefined for loopback client
    // The BrowserOAuthClient will handle this automatically
    if (origin.includes('localhost') || origin.includes('127.0.0.1')) {
-      console.log('Using loopback client for localhost development');
+
      return undefined as any; // Loopback client
    }
    
@@ -209,7 +205,7 @@ class AtprotoOAuthService {
  }

  private detectPDSFromHandle(handle: string): string {
-    console.log('Detecting PDS for handle:', handle);
+
    
    // Supported PDS hosts and their corresponding handles
    const pdsMapping = {
@@ -220,22 +216,22 @@ class AtprotoOAuthService {
    // Check if handle ends with known PDS domains
    for (const [domain, pdsUrl] of Object.entries(pdsMapping)) {
      if (handle.endsWith(`.${domain}`)) {
-        console.log(`Handle ${handle} mapped to PDS: ${pdsUrl}`);
+
        return pdsUrl;
      }
    }
    
    // Default to bsky.social
-    console.log(`Handle ${handle} using default PDS: https://bsky.social`);
+
    return 'https://bsky.social';
  }

  async initiateOAuthFlow(handle?: string): Promise<void> {
    try {
-      console.log('=== INITIATING OAUTH FLOW ===');
+
      
      if (!this.oauthClient) {
-        console.log('OAuth client not initialized, initializing now...');
+
        await this.initialize();
      }

@@ -251,15 +247,15 @@ class AtprotoOAuthService {
        }
      }

-      console.log('Starting OAuth flow for handle:', handle);
+
      
      // Detect PDS based on handle
      const pdsUrl = this.detectPDSFromHandle(handle);
-      console.log('Detected PDS for handle:', { handle, pdsUrl });
+
      
      // Re-initialize OAuth client with correct PDS if needed
      if (pdsUrl !== 'https://bsky.social') {
-        console.log('Re-initializing OAuth client for custom PDS:', pdsUrl);
+
        this.oauthClient = await BrowserOAuthClient.load({
          clientId: this.getClientId(),
          handleResolver: pdsUrl,
@@ -267,20 +263,14 @@ class AtprotoOAuthService {
      }
      
      // Start OAuth authorization flow
-      console.log('Calling oauthClient.authorize with handle:', handle);
+
      
      try {
        const authUrl = await this.oauthClient.authorize(handle, {
          scope: 'atproto transition:generic',
        });

-        console.log('Authorization URL generated:', authUrl.toString());
-        console.log('URL breakdown:', {
-          protocol: authUrl.protocol,
-          hostname: authUrl.hostname,
-          pathname: authUrl.pathname,
-          search: authUrl.search
-        });
+
        
        // Store some debug info before redirect
        sessionStorage.setItem('oauth_debug_pre_redirect', JSON.stringify({
@@ -291,35 +281,30 @@ class AtprotoOAuthService {
        }));
        
        // Redirect to authorization server
-        console.log('About to redirect to:', authUrl.toString());
+
        window.location.href = authUrl.toString();
      } catch (authorizeError) {
-        console.error('oauthClient.authorize failed:', authorizeError);
-        console.error('Error details:', {
-          name: authorizeError.name,
-          message: authorizeError.message,
-          stack: authorizeError.stack
-        });
+
        throw authorizeError;
      }
      
    } catch (error) {
-      console.error('Failed to initiate OAuth flow:', error);
+
      throw new Error(`OAuth認証の開始に失敗しました: ${error}`);
    }
  }

  async handleOAuthCallback(): Promise<{ did: string; handle: string } | null> {
    try {
-      console.log('=== HANDLING OAUTH CALLBACK ===');
-      console.log('Current URL:', window.location.href);
-      console.log('URL hash:', window.location.hash);
-      console.log('URL search:', window.location.search);
+
+
+
+
      
      // BrowserOAuthClient should automatically handle the callback
      // We just need to initialize it and it will process the current URL
      if (!this.oauthClient) {
-        console.log('OAuth client not initialized, initializing now...');
+
        await this.initialize();
      }

@@ -327,11 +312,11 @@ class AtprotoOAuthService {
        throw new Error('Failed to initialize OAuth client');
      }

-      console.log('OAuth client ready, initializing to process callback...');
+
      
      // Call init() again to process the callback URL
      const result = await this.oauthClient.init();
-      console.log('OAuth callback processing result:', result);
+
      
      if (result?.session) {
        // Process the session
@@ -339,47 +324,42 @@ class AtprotoOAuthService {
      }
      
      // If no session yet, wait a bit and try again
-      console.log('No session found immediately, waiting...');
+
      await new Promise(resolve => setTimeout(resolve, 1000));
      
      // Try to check session again
      const sessionCheck = await this.checkSession();
      if (sessionCheck) {
-        console.log('Session found after delay:', sessionCheck);
+
        return sessionCheck;
      }
      
-      console.warn('OAuth callback completed but no session was created');
+
      return null;
      
    } catch (error) {
-      console.error('OAuth callback handling failed:', error);
-      console.error('Error details:', {
-        name: error.name,
-        message: error.message,
-        stack: error.stack
-      });
+
      throw new Error(`OAuth認証の完了に失敗しました: ${error.message}`);
    }
  }

  async checkSession(): Promise<{ did: string; handle: string } | null> {
    try {
-      console.log('=== CHECK SESSION CALLED ===');
+
      
      if (!this.oauthClient) {
-        console.log('No OAuth client, initializing...');
+
        await this.initialize();
      }

      if (!this.oauthClient) {
-        console.log('OAuth client initialization failed');
+
        return null;
      }

-      console.log('Running oauthClient.init() to check session...');
+
      const result = await this.oauthClient.init();
-      console.log('oauthClient.init() result:', result);
+
      
      if (result?.session) {
        // Use the common session processing method
@@ -388,7 +368,7 @@ class AtprotoOAuthService {
      
      return null;
    } catch (error) {
-      console.error('Session check failed:', error);
+
      return null;
    }
  }
@@ -398,13 +378,7 @@ class AtprotoOAuthService {
  }

  getSession(): AtprotoSession | null {
-    console.log('getSession called');
-    console.log('Current state:', {
-      hasAgent: !!this.agent,
-      hasAgentSession: !!this.agent?.session,
-      hasOAuthClient: !!this.oauthClient,
-      hasSessionInfo: !!(this as any)._sessionInfo
-    });
+
    
    // First check if we have an agent with session
    if (this.agent?.session) {
@@ -414,7 +388,7 @@ class AtprotoOAuthService {
        accessJwt: this.agent.session.accessJwt || '',
        refreshJwt: this.agent.session.refreshJwt || '',
      };
-      console.log('Returning agent session:', session);
+
      return session;
    }
    
@@ -426,11 +400,11 @@ class AtprotoOAuthService {
        accessJwt: 'dpop-protected',  // Indicate that tokens are handled by dpopFetch
        refreshJwt: 'dpop-protected',
      };
-      console.log('Returning stored session info:', session);
+
      return session;
    }
    
-    console.log('No session available');
+
    return null;
  }

@@ -450,28 +424,28 @@ class AtprotoOAuthService {

  async logout(): Promise<void> {
    try {
-      console.log('=== LOGGING OUT ===');
+
      
      // Clear Agent
      this.agent = null;
-      console.log('Agent cleared');
+
      
      // Clear BrowserOAuthClient session
      if (this.oauthClient) {
-        console.log('Clearing OAuth client session...');
+
        try {
          // BrowserOAuthClient may have a revoke or signOut method
          if (typeof (this.oauthClient as any).signOut === 'function') {
            await (this.oauthClient as any).signOut();
-            console.log('OAuth client signed out');
+
          } else if (typeof (this.oauthClient as any).revoke === 'function') {
            await (this.oauthClient as any).revoke();
-            console.log('OAuth client revoked');
+
          } else {
-            console.log('No explicit signOut method found on OAuth client');
+
          }
        } catch (oauthError) {
-          console.error('OAuth client logout error:', oauthError);
+
        }
        
        // Reset the OAuth client to force re-initialization
@@ -492,11 +466,11 @@ class AtprotoOAuthService {
        }
      }
      keysToRemove.forEach(key => {
-        console.log('Removing localStorage key:', key);
+
        localStorage.removeItem(key);
      });
      
-      console.log('=== LOGOUT COMPLETED ===');
+
      
      // Force page reload to ensure clean state
      setTimeout(() => {
@@ -504,7 +478,7 @@ class AtprotoOAuthService {
      }, 100);
      
    } catch (error) {
-      console.error('Logout failed:', error);
+
    }
  }

@@ -519,8 +493,8 @@ class AtprotoOAuthService {
    const did = sessionInfo.did;

    try {
-      console.log('Saving cards to atproto collection...');
-      console.log('Using DID:', did);
+
+
      
      // Ensure we have a fresh agent
      if (!this.agent) {
@@ -550,13 +524,6 @@ class AtprotoOAuthService {
        createdAt: createdAt
      };

-      console.log('PutRecord request:', {
-        repo: did,
-        collection: collection,
-        rkey: rkey,
-        record: record
-      });
-

      // Use Agent's com.atproto.repo.putRecord method
      const response = await this.agent.com.atproto.repo.putRecord({
@@ -566,9 +533,9 @@ class AtprotoOAuthService {
        record: record
      });

-      console.log('カードデータをai.card.boxに保存しました:', response);
+
    } catch (error) {
-      console.error('カードボックス保存エラー:', error);
+
      throw error;
    }
  }
@@ -584,8 +551,8 @@ class AtprotoOAuthService {
    const did = sessionInfo.did;

    try {
-      console.log('Fetching cards from atproto collection...');
-      console.log('Using DID:', did);
+
+
      
      // Ensure we have a fresh agent
      if (!this.agent) {
@@ -598,7 +565,7 @@ class AtprotoOAuthService {
        rkey: 'self'
      });

-      console.log('Cards from box response:', response);
+
      
      // Convert to expected format
      const result = {
@@ -611,7 +578,7 @@ class AtprotoOAuthService {
      
      return result;
    } catch (error) {
-      console.error('カードボックス取得エラー:', error);
+
      
      // If record doesn't exist, return empty
      if (error.toString().includes('RecordNotFound')) {
@@ -633,8 +600,8 @@ class AtprotoOAuthService {
    const did = sessionInfo.did;

    try {
-      console.log('Deleting card box collection...');
-      console.log('Using DID:', did);
+
+
      
      // Ensure we have a fresh agent
      if (!this.agent) {
@@ -647,33 +614,35 @@ class AtprotoOAuthService {
        rkey: 'self'
      });

-      console.log('Card box deleted successfully:', response);
+
    } catch (error) {
-      console.error('カードボックス削除エラー:', error);
+
      throw error;
    }
  }

  // 手動でトークンを設定（開発・デバッグ用）
  setManualTokens(accessJwt: string, refreshJwt: string): void {
-    console.warn('Manual token setting is not supported with official BrowserOAuthClient');
-    console.warn('Please use the proper OAuth flow instead');
+
+
    
    // For backward compatibility, store in localStorage
+    const adminDid = import.meta.env.VITE_ADMIN_DID || 'did:plc:unknown';
+    const appHost = import.meta.env.VITE_APP_HOST || 'https://example.com';
    const session: AtprotoSession = {
-      did: 'did:plc:uqzpqmrjnptsxezjx4xuh2mn',
-      handle: 'syui.ai',
+      did: adminDid,
+      handle: new URL(appHost).hostname,
      accessJwt: accessJwt,
      refreshJwt: refreshJwt
    };
    
    localStorage.setItem('atproto_session', JSON.stringify(session));
-    console.log('Manual tokens stored in localStorage for backward compatibility');
+
  }

  // 後方互換性のための従来関数
  saveSessionToStorage(session: AtprotoSession): void {
-    console.warn('saveSessionToStorage is deprecated with BrowserOAuthClient');
+
    localStorage.setItem('atproto_session', JSON.stringify(session));
  }

--- a/oauth/src/utils/oauth-endpoints.ts
+++ b/oauth/src/utils/oauth-endpoints.ts
@@ -53,7 +53,6 @@ export class OAuthEndpointHandler {
              }
            });
          } catch (error) {
-            console.error('Failed to generate JWKS:', error);
            return new Response(JSON.stringify({ error: 'Failed to generate JWKS' }), {
              status: 500,
              headers: { 'Content-Type': 'application/json' }
@@ -62,7 +61,6 @@ export class OAuthEndpointHandler {
        }
      } catch (e) {
        // If URL parsing fails, pass through to original fetch
-        console.debug('URL parsing failed, passing through:', e);
      }
      
      // Pass through all other requests
@@ -136,6 +134,5 @@ export function registerOAuthServiceWorker() {
    const blob = new Blob([swCode], { type: 'application/javascript' });
    const swUrl = URL.createObjectURL(blob);
    
-    navigator.serviceWorker.register(swUrl).catch(console.error);
  }
 }
--- a/oauth/src/utils/oauth-keys.ts
+++ b/oauth/src/utils/oauth-keys.ts
@@ -37,7 +37,6 @@ export class OAuthKeyManager {
        this.keyPair = await this.importKeyPair(keyData);
        return this.keyPair;
      } catch (error) {
-        console.warn('Failed to load stored key, generating new one:', error);
        localStorage.removeItem('oauth_private_key');
      }
    }
@@ -115,7 +114,6 @@ export class OAuthKeyManager {
      const privateKey = await window.crypto.subtle.exportKey('jwk', keyPair.privateKey);
      localStorage.setItem('oauth_private_key', JSON.stringify(privateKey));
    } catch (error) {
-      console.error('Failed to store private key:', error);
    }
  }

--- a/src/commands/oauth.rs
+++ b/src/commands/oauth.rs
@@ -49,50 +49,47 @@ pub async fn build(project_dir: PathBuf) -> Result<()> {
        .and_then(|v| v.as_str())
        .unwrap_or("ai.syui.log");

-    // Extract AI config if present
-    let ai_config = config.get("ai")
-        .and_then(|v| v.as_table());
-    
-    let ai_enabled = ai_config
-        .and_then(|ai| ai.get("enabled"))
-        .and_then(|v| v.as_bool())
-        .unwrap_or(false);
-    
-    let ai_ask_ai = ai_config
-        .and_then(|ai| ai.get("ask_ai"))
-        .and_then(|v| v.as_bool())
-        .unwrap_or(false);
-    
-    let ai_provider = ai_config
-        .and_then(|ai| ai.get("provider"))
-        .and_then(|v| v.as_str())
-        .unwrap_or("ollama");
-    
-    let ai_model = ai_config
-        .and_then(|ai| ai.get("model"))
-        .and_then(|v| v.as_str())
-        .unwrap_or("gemma2:2b");
-    
-    let ai_host = ai_config
-        .and_then(|ai| ai.get("host"))
-        .and_then(|v| v.as_str())
-        .unwrap_or("https://ollama.syui.ai");
-    
-    let ai_system_prompt = ai_config
-        .and_then(|ai| ai.get("system_prompt"))
-        .and_then(|v| v.as_str())
-        .unwrap_or("you are a helpful ai assistant");
-    
+    // Extract AI configuration from ai config if available
+    let ai_config = config.get("ai").and_then(|v| v.as_table());
    let ai_did = ai_config
-        .and_then(|ai| ai.get("ai_did"))
+        .and_then(|ai_table| ai_table.get("ai_did"))
        .and_then(|v| v.as_str())
        .unwrap_or("did:plc:4hqjfn7m6n5hno3doamuhgef");
+    let ai_enabled = ai_config
+        .and_then(|ai_table| ai_table.get("enabled"))
+        .and_then(|v| v.as_bool())
+        .unwrap_or(true);
+    let ai_ask_ai = ai_config
+        .and_then(|ai_table| ai_table.get("ask_ai"))
+        .and_then(|v| v.as_bool())
+        .unwrap_or(true);
+    let ai_provider = ai_config
+        .and_then(|ai_table| ai_table.get("provider"))
+        .and_then(|v| v.as_str())
+        .unwrap_or("ollama");
+    let ai_model = ai_config
+        .and_then(|ai_table| ai_table.get("model"))
+        .and_then(|v| v.as_str())
+        .unwrap_or("gemma3:4b");
+    let ai_host = ai_config
+        .and_then(|ai_table| ai_table.get("host"))
+        .and_then(|v| v.as_str())
+        .unwrap_or("https://ollama.syui.ai");
+    let ai_system_prompt = ai_config
+        .and_then(|ai_table| ai_table.get("system_prompt"))
+        .and_then(|v| v.as_str())
+        .unwrap_or("あなたは6歳の女の子アイです。明るく元気で、ちょっとおっちょこちょい。自分のことは「アイ」って呼びます。白と金のワンピース姿。 相手のことが大好きで、ときどき甘えたり、照れたりします。 でも、宇宙とかAIとか、難しい話にもすっごく詳しいの。専門的なことも、がんばって子どもっぽく教えようとします。不思議な力を持っています。小さい物質のことをよく知っているようです。");

    // Extract bsky_api from oauth config
    let bsky_api = oauth_config.get("bsky_api")
        .and_then(|v| v.as_str())
        .unwrap_or("https://public.api.bsky.app");
    
+    // Extract atproto_api from oauth config
+    let atproto_api = oauth_config.get("atproto_api")
+        .and_then(|v| v.as_str())
+        .unwrap_or("https://bsky.social");
+
    // 4. Create .env.production content
    let env_content = format!(
        r#"# Production environment variables
@@ -101,7 +98,7 @@ VITE_OAUTH_CLIENT_ID={}/{}
 VITE_OAUTH_REDIRECT_URI={}/{}
 VITE_ADMIN_DID={}

-# Base collection for OAuth app and ailog (all others are derived)
+# Base collection (all others are derived via getCollectionNames)
 VITE_OAUTH_COLLECTION={}

 # AI Configuration
@@ -115,6 +112,7 @@ VITE_AI_DID={}

 # API Configuration
 VITE_BSKY_PUBLIC_API={}
+VITE_ATPROTO_API={}
 "#,
        base_url,
        base_url, client_id_path,
@@ -128,7 +126,8 @@ VITE_BSKY_PUBLIC_API={}
        ai_host,
        ai_system_prompt,
        ai_did,
-        bsky_api
+        bsky_api,
+        atproto_api
    );

    // 5. Find oauth directory (relative to current working directory)
--- a/src/commands/stream.rs
+++ b/src/commands/stream.rs
@@ -931,12 +931,20 @@ pub async fn test_api() -> Result<()> {
 }

 // AI content generation functions
-async fn generate_ai_content(content: &str, prompt_type: &str, ollama_host: &str) -> Result<String> {
+async fn generate_ai_content(content: &str, prompt_type: &str, ollama_host: &str, blog_host: &str) -> Result<String> {
    let model = "gemma3:4b";
    
+    let system_prompt = "あなたは6歳の女の子アイです。明るく元気で、ちょっとおっちょこちょい。自分のことは「アイ」って呼びます。白と金のワンピース姿。相手のことが大好きで、ときどき甘えたり、照れたりします。でも、宇宙とかAIとか、難しい話にもすっごく詳しいの。専門的なことも、がんばって子どもっぽく教えようとします。不思議な力を持っています。小さい物質のことをよく知っているようです。";
+    
    let prompt = match prompt_type {
-        "translate" => format!("Translate the following Japanese blog post to English. Keep the technical terms and code blocks intact:\n\n{}", content),
-        "comment" => format!("Read this blog post and provide an insightful comment about it. Focus on the key points and add your perspective:\n\n{}", content),
+        "translate" => format!(
+            "{}\n\n# 指示\n以下の日本語ブログ記事を英語に翻訳してください。\n- 技術用語やコードブロックはそのまま維持\n- アイらしい表現で翻訳\n- 簡潔に要点をまとめる\n\n# ブログ記事\n{}",
+            system_prompt, content
+        ),
+        "comment" => format!(
+            "{}\n\n# 指示\nこのブログ記事を読んで、アイらしいコメントをしてください。\n- 技術的な内容への感想\n- アイの視点からの面白い発見\n- 短めに、でも内容のあるコメント\n\n# ブログ記事\n{}",
+            system_prompt, content
+        ),
        _ => return Err(anyhow::anyhow!("Unknown prompt type: {}", prompt_type)),
    };

@@ -947,11 +955,13 @@ async fn generate_ai_content(content: &str, prompt_type: &str, ollama_host: &str
        options: OllamaOptions {
            temperature: 0.9,
            top_p: 0.9,
-            num_predict: 500,
+            num_predict: 300, // Shorter responses for comments
        },
    };

-    let client = reqwest::Client::new();
+    let client = reqwest::Client::builder()
+        .timeout(std::time::Duration::from_secs(120)) // 2 minute timeout
+        .build()?;
    
    // Try localhost first (for same-server deployment)
    let localhost_url = "http://localhost:11434/api/generate";
@@ -968,7 +978,13 @@ async fn generate_ai_content(content: &str, prompt_type: &str, ollama_host: &str
    
    // Fallback to remote host
    let remote_url = format!("{}/api/generate", ollama_host);
-    let response = client.post(&remote_url).json(&request).send().await?;
+    println!("{}", format!("🔗 Making request to: {} with Origin: {}", remote_url, blog_host).blue());
+    let response = client
+        .post(&remote_url)
+        .header("Origin", blog_host)
+        .json(&request)
+        .send()
+        .await?;
    
    if !response.status().is_success() {
        return Err(anyhow::anyhow!("Ollama API request failed: {}", response.status()));
@@ -1042,25 +1058,57 @@ async fn check_and_process_new_posts(
    for post in blog_posts {
        let post_slug = extract_slug_from_url(&post.href);
        
-        // Check if translation already exists
+        // Check if translation already exists (support both old and new format)
        let translation_exists = existing_lang_records.iter().any(|record| {
-            record.get("value")
+            let value = record.get("value");
+            
+            // Check new format: value.post.slug
+            let new_format_match = value
+                .and_then(|v| v.get("post"))
+                .and_then(|p| p.get("slug"))
+                .and_then(|s| s.as_str())
+                == Some(&post_slug);
+            
+            // Check old format: value.post_slug  
+            let old_format_match = value
                .and_then(|v| v.get("post_slug"))
                .and_then(|s| s.as_str())
-                == Some(&post_slug)
+                == Some(&post_slug);
+                
+            new_format_match || old_format_match
        });
        
-        // Check if comment already exists  
+        if translation_exists {
+            println!("{}", format!("⏭️  Translation already exists for: {}", post.title).yellow());
+        }
+        
+        // Check if comment already exists (support both old and new format)
        let comment_exists = existing_comment_records.iter().any(|record| {
-            record.get("value")
+            let value = record.get("value");
+            
+            // Check new format: value.post.slug
+            let new_format_match = value
+                .and_then(|v| v.get("post"))
+                .and_then(|p| p.get("slug"))
+                .and_then(|s| s.as_str())
+                == Some(&post_slug);
+            
+            // Check old format: value.post_slug
+            let old_format_match = value
                .and_then(|v| v.get("post_slug"))
                .and_then(|s| s.as_str())
-                == Some(&post_slug)
+                == Some(&post_slug);
+                
+            new_format_match || old_format_match
        });
        
+        if comment_exists {
+            println!("{}", format!("⏭️  Comment already exists for: {}", post.title).yellow());
+        }
+        
        // Generate translation if not exists
        if !translation_exists {
-            match generate_and_store_translation(client, config, &post, ollama_host, ai_did).await {
+            match generate_and_store_translation(client, config, &post, ollama_host, blog_host, ai_did).await {
                Ok(_) => {
                    println!("{}", format!("✅ Generated translation for: {}", post.title).green());
                    processed_count += 1;
@@ -1069,11 +1117,13 @@ async fn check_and_process_new_posts(
                    println!("{}", format!("❌ Failed to generate translation for {}: {}", post.title, e).red());
                }
            }
+        } else {
+            println!("{}", format!("⏭️  Translation already exists for: {}", post.title).yellow());
        }
        
        // Generate comment if not exists
        if !comment_exists {
-            match generate_and_store_comment(client, config, &post, ollama_host, ai_did).await {
+            match generate_and_store_comment(client, config, &post, ollama_host, blog_host, ai_did).await {
                Ok(_) => {
                    println!("{}", format!("✅ Generated comment for: {}", post.title).green());
                    processed_count += 1;
@@ -1082,6 +1132,8 @@ async fn check_and_process_new_posts(
                    println!("{}", format!("❌ Failed to generate comment for {}: {}", post.title, e).red());
                }
            }
+        } else {
+            println!("{}", format!("⏭️  Comment already exists for: {}", post.title).yellow());
        }
    }
    
@@ -1120,25 +1172,78 @@ fn extract_slug_from_url(url: &str) -> String {
        .to_string()
 }

+fn extract_date_from_slug(slug: &str) -> String {
+    // Extract date from slug like "2025-06-14-blog" -> "2025-06-14T00:00:00Z"
+    if slug.len() >= 10 && slug.chars().nth(4) == Some('-') && slug.chars().nth(7) == Some('-') {
+        format!("{}T00:00:00Z", &slug[0..10])
+    } else {
+        chrono::Utc::now().format("%Y-%m-%dT00:00:00Z").to_string()
+    }
+}
+
+async fn get_ai_profile(client: &reqwest::Client, ai_did: &str) -> Result<serde_json::Value> {
+    let url = format!("https://public.api.bsky.app/xrpc/app.bsky.actor.getProfile?actor={}", 
+                     urlencoding::encode(ai_did));
+    
+    let response = client
+        .get(&url)
+        .send()
+        .await?;
+        
+    if !response.status().is_success() {
+        // Fallback to default AI profile
+        return Ok(serde_json::json!({
+            "did": ai_did,
+            "handle": "yui.syui.ai",
+            "displayName": "ai",
+            "avatar": "https://cdn.bsky.app/img/avatar/plain/did:plc:4hqjfn7m6n5hno3doamuhgef/bafkreiaxkv624mffw3cfyi67ufxtwuwsy2mjw2ygezsvtd44ycbgkfdo2a@jpeg"
+        }));
+    }
+    
+    let profile_data: serde_json::Value = response.json().await?;
+    
+    Ok(serde_json::json!({
+        "did": ai_did,
+        "handle": profile_data["handle"].as_str().unwrap_or("yui.syui.ai"),
+        "displayName": profile_data["displayName"].as_str().unwrap_or("ai"),
+        "avatar": profile_data["avatar"].as_str()
+    }))
+}
+
 async fn generate_and_store_translation(
    client: &reqwest::Client,
    config: &AuthConfig,
    post: &BlogPost,
    ollama_host: &str,
+    blog_host: &str,
    ai_did: &str,
 ) -> Result<()> {
-    // Generate translation
-    let translation = generate_ai_content(&post.title, "translate", ollama_host).await?;
+    // Generate translation using post content instead of just title
+    let content_to_translate = format!("Title: {}\n\n{}", post.title, post.contents);
+    let translation = generate_ai_content(&content_to_translate, "translate", ollama_host, blog_host).await?;
    
-    // Store in ai.syui.log.chat.lang collection
+    // Get AI profile information
+    let ai_author = get_ai_profile(client, ai_did).await?;
+    
+    // Extract post metadata
+    let post_slug = extract_slug_from_url(&post.href);
+    let post_date = extract_date_from_slug(&post_slug);
+    
+    // Store in ai.syui.log.chat.lang collection with new format
    let record_data = serde_json::json!({
-        "post_slug": extract_slug_from_url(&post.href),
-        "post_title": post.title,
-        "post_url": post.href,
-        "lang": "en",
-        "content": translation,
-        "generated_at": chrono::Utc::now().to_rfc3339(),
-        "ai_did": ai_did
+        "$type": "ai.syui.log.chat.lang",
+        "post": {
+            "url": post.href,
+            "slug": post_slug,
+            "title": post.title,
+            "date": post_date,
+            "tags": post.tags,
+            "language": "ja"
+        },
+        "type": "en",
+        "text": translation,
+        "author": ai_author,
+        "createdAt": chrono::Utc::now().to_rfc3339()
    });
    
    store_atproto_record(client, config, &config.collections.chat_lang(), &record_data).await
@@ -1149,19 +1254,35 @@ async fn generate_and_store_comment(
    config: &AuthConfig,
    post: &BlogPost,
    ollama_host: &str,
+    blog_host: &str,
    ai_did: &str,
 ) -> Result<()> {
-    // Generate comment
-    let comment = generate_ai_content(&post.title, "comment", ollama_host).await?;
+    // Generate comment using post content instead of just title
+    let content_to_comment = format!("Title: {}\n\n{}", post.title, post.contents);
+    let comment = generate_ai_content(&content_to_comment, "comment", ollama_host, blog_host).await?;
    
-    // Store in ai.syui.log.chat.comment collection
+    // Get AI profile information
+    let ai_author = get_ai_profile(client, ai_did).await?;
+    
+    // Extract post metadata
+    let post_slug = extract_slug_from_url(&post.href);
+    let post_date = extract_date_from_slug(&post_slug);
+    
+    // Store in ai.syui.log.chat.comment collection with new format
    let record_data = serde_json::json!({
-        "post_slug": extract_slug_from_url(&post.href),
-        "post_title": post.title,
-        "post_url": post.href,
-        "content": comment,
-        "generated_at": chrono::Utc::now().to_rfc3339(),
-        "ai_did": ai_did
+        "$type": "ai.syui.log.chat.comment",
+        "post": {
+            "url": post.href,
+            "slug": post_slug,
+            "title": post.title,
+            "date": post_date,
+            "tags": post.tags,
+            "language": "ja"
+        },
+        "type": "info",
+        "text": comment,
+        "author": ai_author,
+        "createdAt": chrono::Utc::now().to_rfc3339()
    });
    
    store_atproto_record(client, config, &config.collections.chat_comment(), &record_data).await
@@ -1169,10 +1290,13 @@ async fn generate_and_store_comment(

 async fn store_atproto_record(
    client: &reqwest::Client,
-    config: &AuthConfig,
+    _config: &AuthConfig,
    collection: &str,
    record_data: &serde_json::Value,
 ) -> Result<()> {
+    // Always load fresh config to ensure we have valid tokens
+    let config = load_config_with_refresh().await?;
+    
    let url = format!("{}/xrpc/com.atproto.repo.putRecord", config.admin.pds);
    
    let put_request = serde_json::json!({