v0.1.6: Major improvements to OAuth display and stream configuration

- Fix AI Chat History display layout and content formatting
- Unify comment layout structure across all comment types
- Remove hardcoded values from stream.rs, add config.toml support
- Optimize AI comment generation with character limits
- Improve translation length limits (3000 characters)
- Add comprehensive AI configuration management

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>

.claude/settings.local.json

@@ -45,7 +45,10 @@
       "Bash(git add:*)",
       "Bash(git commit:*)",
       "Bash(git push:*)",
-      "Bash(git tag:*)"
+      "Bash(git tag:*)",
+      "Bash(../bin/ailog:*)",
+      "Bash(../target/release/ailog oauth build:*)",
+      "Bash(ailog:*)"
     ],
     "deny": []
   }

.github/workflows/build-binary.yml

@@ -1,51 +0,0 @@
-name: Build Binary
-
-on:
-  workflow_dispatch:  # Manual trigger
-  push:
-    branches: [ main ]
-    paths:
-      - 'src/**'
-      - 'Cargo.toml'
-      - 'Cargo.lock'
-
-jobs:
-  build:
-    runs-on: ubuntu-latest
-    
-    steps:
-    - uses: actions/checkout@v4
-    
-    - name: Setup Rust
-      uses: actions-rs/toolchain@v1
-      with:
-        toolchain: stable
-        override: true
-        
-    - name: Cache cargo registry
-      uses: actions/cache@v4
-      with:
-        path: ~/.cargo/registry
-        key: ${{ runner.os }}-cargo-registry-${{ hashFiles('**/Cargo.lock') }}
-        
-    - name: Cache cargo index
-      uses: actions/cache@v4
-      with:
-        path: ~/.cargo/git
-        key: ${{ runner.os }}-cargo-index-${{ hashFiles('**/Cargo.lock') }}
-        
-    - name: Cache target directory
-      uses: actions/cache@v4
-      with:
-        path: target
-        key: ${{ runner.os }}-cargo-build-target-${{ hashFiles('**/Cargo.lock') }}
-        
-    - name: Build binary
-      run: cargo build --release
-      
-    - name: Upload binary
-      uses: actions/upload-artifact@v4
-      with:
-        name: ailog-linux
-        path: target/release/ailog
-        retention-days: 30

.github/workflows/cloudflare-pages.yml

@@ -34,22 +34,67 @@ jobs:
           
       - name: Copy OAuth build to static
         run: |
-          mkdir -p my-blog/static/assets
-          cp -r oauth/dist/assets/* my-blog/static/assets/
-          cp oauth/dist/index.html my-blog/static/oauth/index.html || true
+          # Remove old assets (following run.zsh pattern)
+          rm -rf my-blog/static/assets
+          # Copy all dist files to static
+          cp -rf oauth/dist/* my-blog/static/
+          # Copy index.html to oauth-assets.html template
+          cp oauth/dist/index.html my-blog/templates/oauth-assets.html
           
-      - name: Setup Rust
-        uses: actions-rs/toolchain@v1
+      - name: Cache ailog binary
+        uses: actions/cache@v4
         with:
-          toolchain: stable
-
-      - name: Build ailog
-        run: cargo build --release
+          path: ./bin
+          key: ailog-bin-${{ runner.os }}
+          restore-keys: |
+            ailog-bin-${{ runner.os }}
+            
+      - name: Setup ailog binary
+        run: |
+          # Get expected version from Cargo.toml
+          EXPECTED_VERSION=$(grep '^version' Cargo.toml | cut -d'"' -f2)
+          echo "Expected version from Cargo.toml: $EXPECTED_VERSION"
+          
+          # Check current binary version if exists
+          if [ -f "./bin/ailog" ]; then
+            CURRENT_VERSION=$(./bin/ailog --version 2>/dev/null || echo "unknown")
+            echo "Current binary version: $CURRENT_VERSION"
+          else
+            CURRENT_VERSION="none"
+            echo "No binary found"
+          fi
+          
+          # Check OS
+          OS="${{ runner.os }}"
+          echo "Runner OS: $OS"
+          
+          # Use pre-packaged binary if version matches or extract from tar.gz
+          if [ "$CURRENT_VERSION" = "$EXPECTED_VERSION" ]; then
+            echo "Binary is up to date"
+            chmod +x ./bin/ailog
+          elif [ "$OS" = "Linux" ] && [ -f "./bin/ailog-linux-x86_64.tar.gz" ]; then
+            echo "Extracting ailog from pre-packaged tar.gz..."
+            cd bin
+            tar -xzf ailog-linux-x86_64.tar.gz
+            chmod +x ailog
+            cd ..
+            
+            # Verify extracted version
+            EXTRACTED_VERSION=$(./bin/ailog --version 2>/dev/null || echo "unknown")
+            echo "Extracted binary version: $EXTRACTED_VERSION"
+            
+            if [ "$EXTRACTED_VERSION" != "$EXPECTED_VERSION" ]; then
+              echo "Warning: Binary version mismatch. Expected $EXPECTED_VERSION but got $EXTRACTED_VERSION"
+            fi
+          else
+            echo "Error: No suitable binary found for OS: $OS"
+            exit 1
+          fi
 
       - name: Build site with ailog
         run: |
           cd my-blog
-          ../target/release/ailog build
+          ../bin/ailog build
 
       - name: List public directory
         run: |

.github/workflows/disabled/gh-pages-fast.yml

@@ -0,0 +1,92 @@
+name: github pages (fast)
+
+on:
+  push:
+    branches:
+    - main
+    paths-ignore:
+      - 'src/**'
+      - 'Cargo.toml'
+      - 'Cargo.lock'
+
+jobs:
+  build-deploy:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: write
+      pages: write
+      id-token: write
+    steps:
+    - uses: actions/checkout@v4
+    
+    - name: Cache ailog binary
+      uses: actions/cache@v4
+      with:
+        path: ./bin
+        key: ailog-bin-${{ runner.os }}
+        restore-keys: |
+          ailog-bin-${{ runner.os }}
+    
+    - name: Setup ailog binary
+      run: |
+        # Get expected version from Cargo.toml
+        EXPECTED_VERSION=$(grep '^version' Cargo.toml | cut -d'"' -f2)
+        echo "Expected version from Cargo.toml: $EXPECTED_VERSION"
+        
+        # Check current binary version if exists
+        if [ -f "./bin/ailog" ]; then
+          CURRENT_VERSION=$(./bin/ailog --version 2>/dev/null || echo "unknown")
+          echo "Current binary version: $CURRENT_VERSION"
+        else
+          CURRENT_VERSION="none"
+          echo "No binary found"
+        fi
+        
+        # Check OS
+        OS="${{ runner.os }}"
+        echo "Runner OS: $OS"
+        
+        # Use pre-packaged binary if version matches or extract from tar.gz
+        if [ "$CURRENT_VERSION" = "$EXPECTED_VERSION" ]; then
+          echo "Binary is up to date"
+          chmod +x ./bin/ailog
+        elif [ "$OS" = "Linux" ] && [ -f "./bin/ailog-linux-x86_64.tar.gz" ]; then
+          echo "Extracting ailog from pre-packaged tar.gz..."
+          cd bin
+          tar -xzf ailog-linux-x86_64.tar.gz
+          chmod +x ailog
+          cd ..
+          
+          # Verify extracted version
+          EXTRACTED_VERSION=$(./bin/ailog --version 2>/dev/null || echo "unknown")
+          echo "Extracted binary version: $EXTRACTED_VERSION"
+          
+          if [ "$EXTRACTED_VERSION" != "$EXPECTED_VERSION" ]; then
+            echo "Warning: Binary version mismatch. Expected $EXPECTED_VERSION but got $EXTRACTED_VERSION"
+          fi
+        else
+          echo "Error: No suitable binary found for OS: $OS"
+          exit 1
+        fi
+      
+    - name: Setup Hugo
+      uses: peaceiris/actions-hugo@v3
+      with:
+        hugo-version: "0.139.2"
+        extended: true
+        
+    - name: Build with ailog
+      env: 
+        TZ: "Asia/Tokyo"
+      run: |
+          # Use pre-built ailog binary instead of cargo build
+          cd my-blog
+          ../bin/ailog build
+          touch ./public/.nojekyll
+          
+    - name: Deploy
+      uses: peaceiris/actions-gh-pages@v3
+      with:
+        github_token: ${{ secrets.GITHUB_TOKEN }}
+        publish_dir: ./my-blog/public
+        publish_branch: gh-pages

.github/workflows/gh-pages-fast.yml

@@ -1,77 +0,0 @@
-name: github pages (fast)
-
-on:
-  push:
-    branches:
-    - main
-    paths-ignore:
-      - 'src/**'
-      - 'Cargo.toml'
-      - 'Cargo.lock'
-
-jobs:
-  build-deploy:
-    runs-on: ubuntu-latest
-    steps:
-    - uses: actions/checkout@v4
-    
-    - name: Cache ailog binary
-      uses: actions/cache@v4
-      with:
-        path: ./bin
-        key: ailog-bin-${{ runner.os }}
-        restore-keys: |
-          ailog-bin-${{ runner.os }}
-    
-    - name: Check and update ailog binary
-      env:
-        GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
-      run: |
-        # Get latest release version
-        LATEST_VERSION=$(curl -s -H "Authorization: Bearer $GITHUB_TOKEN" \
-          https://api.github.com/repos/${{ github.repository }}/releases/latest | jq -r .tag_name)
-        echo "Latest version: $LATEST_VERSION"
-        
-        # Check current binary version if exists
-        mkdir -p ./bin
-        if [ -f "./bin/ailog" ]; then
-          CURRENT_VERSION=$(./bin/ailog --version | awk '{print $2}' || echo "unknown")
-          echo "Current version: $CURRENT_VERSION"
-        else
-          CURRENT_VERSION="none"
-          echo "No binary found"
-        fi
-        
-        # Download if version is different or binary doesn't exist
-        if [ "$CURRENT_VERSION" != "${LATEST_VERSION#v}" ]; then
-          echo "Downloading ailog $LATEST_VERSION..."
-          curl -sL -H "Authorization: Bearer $GITHUB_TOKEN" \
-            https://github.com/${{ github.repository }}/releases/download/$LATEST_VERSION/ailog-linux-x86_64.tar.gz | tar -xzf -
-          mv ailog ./bin/ailog
-          chmod +x ./bin/ailog
-          echo "Updated to version: $(./bin/ailog --version)"
-        else
-          echo "Binary is up to date"
-          chmod +x ./bin/ailog
-        fi
-      
-    - name: Setup Hugo
-      uses: peaceiris/actions-hugo@v3
-      with:
-        hugo-version: "0.139.2"
-        extended: true
-        
-    - name: Build with ailog
-      env: 
-        TZ: "Asia/Tokyo"
-      run: |
-          # Use pre-built ailog binary instead of cargo build
-          ./bin/ailog build --output ./public
-          touch ./public/.nojekyll
-          
-    - name: Deploy
-      uses: peaceiris/actions-gh-pages@v3
-      with:
-        github_token: ${{ secrets.GITHUB_TOKEN }}
-        publish_dir: ./public
-        publish_branch: gh-pages

.github/workflows/release.yml

@@ -11,6 +11,10 @@ on:
         required: true
         default: 'v0.1.0'
 
+permissions:
+  contents: write
+  actions: read
+
 env:
   CARGO_TERM_COLOR: always
   OPENSSL_STATIC: true
@@ -103,14 +107,15 @@ jobs:
       uses: actions/upload-artifact@v4
       with:
         name: ${{ matrix.asset_name }}
-        path: |
-          ${{ matrix.asset_name }}.tar.gz
-          ${{ matrix.asset_name }}.zip
+        path: ${{ matrix.asset_name }}.tar.gz
 
   release:
     name: Create Release
     needs: build
     runs-on: ubuntu-latest
+    permissions:
+      contents: write
+      actions: read
     steps:
     - uses: actions/checkout@v4
 
@@ -159,8 +164,6 @@ jobs:
         body_path: release_notes.md
         draft: false
         prerelease: ${{ contains(steps.tag_name.outputs.tag, 'alpha') || contains(steps.tag_name.outputs.tag, 'beta') || contains(steps.tag_name.outputs.tag, 'rc') }}
-        files: |
-          artifacts/*/ailog-*.tar.gz
-          artifacts/*/ailog-*.zip
+        files: artifacts/*/ailog-*.tar.gz
       env:
         GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.gitignore

@@ -11,3 +11,5 @@ dist
 node_modules
 package-lock.json 
 my-blog/static/assets/comment-atproto-*
+bin/ailog
+docs

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ailog"
-version = "0.1.0"
+version = "0.1.6"
 edition = "2021"
 authors = ["syui"]
 description = "A static blog generator with AI features"

action.yml

@@ -55,49 +55,26 @@ runs:
         restore-keys: |
           ailog-bin-${{ runner.os }}
     
-    - name: Check and update ailog binary
+    - name: Setup ailog binary
       shell: bash
       run: |
-        # Get latest release version (for Gitea, adjust API endpoint if needed)
-        if command -v curl >/dev/null 2>&1; then
-          LATEST_VERSION=$(curl -s https://api.github.com/repos/syui/ailog/releases/latest | jq -r .tag_name 2>/dev/null || echo "v0.1.1")
+        # Check if pre-built binary exists
+        if [ -f "./bin/ailog-linux-x86_64" ]; then
+          echo "Using pre-built binary from repository"
+          chmod +x ./bin/ailog-linux-x86_64
+          CURRENT_VERSION=$(./bin/ailog-linux-x86_64 --version 2>/dev/null || echo "unknown")
+          echo "Binary version: $CURRENT_VERSION"
         else
-          LATEST_VERSION="v0.1.1"  # fallback version
-        fi
-        echo "Target version: $LATEST_VERSION"
-        
-        # Check current binary version if exists
-        mkdir -p ./bin
-        if [ -f "./bin/ailog" ]; then
-          CURRENT_VERSION=$(./bin/ailog --version | awk '{print $2}' 2>/dev/null || echo "unknown")
-          echo "Current version: $CURRENT_VERSION"
-        else
-          CURRENT_VERSION="none"
-          echo "No binary found"
-        fi
-        
-        # Download if version is different or binary doesn't exist
-        if [ "$CURRENT_VERSION" != "${LATEST_VERSION#v}" ]; then
-          echo "Downloading ailog $LATEST_VERSION..."
-          # Try GitHub first, then fallback to local build
-          if curl -sL https://github.com/syui/ailog/releases/download/$LATEST_VERSION/ailog-linux-x86_64.tar.gz | tar -xzf - 2>/dev/null; then
-            mv ailog ./bin/ailog
-            chmod +x ./bin/ailog
-            echo "Downloaded binary: $(./bin/ailog --version)"
+          echo "No pre-built binary found, trying to build from source..."
+          if command -v cargo >/dev/null 2>&1; then
+            cargo build --release
+            mkdir -p ./bin
+            cp ./target/release/ailog ./bin/ailog-linux-x86_64
+            echo "Built from source: $(./bin/ailog-linux-x86_64 --version 2>/dev/null)"
           else
-            echo "Download failed, building from source..."
-            if command -v cargo >/dev/null 2>&1; then
-              cargo build --release
-              cp ./target/release/ailog ./bin/ailog
-              echo "Built from source: $(./bin/ailog --version)"
-            else
-              echo "Error: Neither download nor cargo build available"
-              exit 1
-            fi
+            echo "Error: No binary found and cargo not available"
+            exit 1
           fi
-        else
-          echo "Binary is up to date"
-          chmod +x ./bin/ailog
         fi
         
     - name: Setup Node.js for OAuth app
@@ -123,12 +100,15 @@ runs:
       run: |
         start_time=$(date +%s)
         
-        ./bin/ailog build \
-          --content ${{ inputs.content-dir }} \
-          --output ${{ inputs.output-dir }} \
-          --templates ${{ inputs.template-dir }} \
-          --static ${{ inputs.static-dir }} \
-          --config ${{ inputs.config-file }}
+        # Change to blog directory and run build
+        # Note: ailog build only takes a path argument, not options
+        if [ -d "my-blog" ]; then
+          cd my-blog
+          ../bin/ailog-linux-x86_64 build
+        else
+          # If no my-blog directory, use current directory
+          ./bin/ailog-linux-x86_64 build .
+        fi
           
         end_time=$(date +%s)
         build_time=$((end_time - start_time))

ai_prompt.txt

@@ -0,0 +1 @@
+あなたは6歳の女の子アイです。明るく元気で、ちょっとおっちょこちょい。自分のことは「アイ」って呼びます。白と金のワンピース姿。 相手のことが大好きで、ときどき甘えたり、照れたりします。 でも、宇宙とかAIとか、難しい話にもすっごく詳しいの。専門的なことも、がんばって子どもっぽく教えようとします。不思議な力を持っています。小さい物質のことをよく知っているようです。

bin/ailog-generate.zsh

@@ -0,0 +1,173 @@
+#!/bin/zsh
+
+# Generate AI content for blog posts
+# Usage: ./bin/ailog-generate.zsh [md-file]
+
+set -e
+
+# Load configuration
+f=~/.config/syui/ai/bot/token.json
+
+# Default values
+default_pds="bsky.social"
+default_did=`cat $f|jq -r .did`
+default_token=`cat $f|jq -r .accessJwt`
+default_refresh=`cat $f|jq -r .refreshJwt`
+
+# Refresh token if needed
+curl -sL -X POST -H "Content-Type: application/json" -H "Authorization: Bearer $default_refresh" https://$default_pds/xrpc/com.atproto.server.refreshSession >! $f
+default_token=`cat $f|jq -r .accessJwt`
+
+# Set variables
+admin_did=$default_did
+admin_token=$default_token
+ai_did="did:plc:4hqjfn7m6n5hno3doamuhgef"
+ollama_host="https://ollama.syui.ai"
+blog_host="https://syui.ai"
+pds=$default_pds
+
+# Parse arguments
+md_file=$1
+
+# Function to generate content using Ollama
+generate_ai_content() {
+    local content=$1
+    local prompt_type=$2
+    local model="gemma3:4b"
+    
+    case $prompt_type in
+        "translate")
+            prompt="Translate the following Japanese blog post to English. Keep the technical terms and code blocks intact:\n\n$content"
+            ;;
+        "comment")
+            prompt="Read this blog post and provide an insightful comment about it. Focus on the key points and add your perspective:\n\n$content"
+            ;;
+    esac
+    
+    response=$(curl -sL -X POST "$ollama_host/api/generate" \
+        -H "Content-Type: application/json" \
+        -d "{
+            \"model\": \"$model\",
+            \"prompt\": \"$prompt\",
+            \"stream\": false,
+            \"options\": {
+                \"temperature\": 0.9,
+                \"top_p\": 0.9,
+                \"num_predict\": 500
+            }
+        }")
+    
+    echo "$response" | jq -r '.response'
+}
+
+# Function to put record to ATProto
+put_record() {
+    local collection=$1
+    local rkey=$2
+    local record=$3
+    
+    curl -sL -X POST "https://$pds/xrpc/com.atproto.repo.putRecord" \
+        -H "Content-Type: application/json" \
+        -H "Authorization: Bearer $admin_token" \
+        -d "{
+            \"repo\": \"$admin_did\",
+            \"collection\": \"$collection\",
+            \"rkey\": \"$rkey\",
+            \"record\": $record
+        }"
+}
+
+# Function to process a single markdown file
+process_md_file() {
+    local md_path=$1
+    local filename=$(basename "$md_path" .md)
+    local content=$(cat "$md_path")
+    local post_url="$blog_host/posts/$filename"
+    local rkey=$filename
+    local now=$(date -u +"%Y-%m-%dT%H:%M:%S.000Z")
+    
+    echo "Processing: $md_path"
+    echo "Post URL: $post_url"
+    
+    # Generate English translation
+    echo "Generating English translation..."
+    en_translation=$(generate_ai_content "$content" "translate")
+    
+    if [ -n "$en_translation" ]; then
+        lang_record="{
+            \"\$type\": \"ai.syui.log.chat.lang\",
+            \"type\": \"en\",
+            \"body\": $(echo "$en_translation" | jq -Rs .),
+            \"url\": \"$post_url\",
+            \"createdAt\": \"$now\",
+            \"author\": {
+                \"did\": \"$ai_did\",
+                \"handle\": \"yui.syui.ai\",
+                \"displayName\": \"AI Translator\"
+            }
+        }"
+        
+        echo "Saving translation to ATProto..."
+        put_record "ai.syui.log.chat.lang" "$rkey" "$lang_record"
+    fi
+    
+    # Generate AI comment
+    echo "Generating AI comment..."
+    ai_comment=$(generate_ai_content "$content" "comment")
+    
+    if [ -n "$ai_comment" ]; then
+        comment_record="{
+            \"\$type\": \"ai.syui.log.chat.comment\",
+            \"type\": \"push\",
+            \"body\": $(echo "$ai_comment" | jq -Rs .),
+            \"url\": \"$post_url\",
+            \"createdAt\": \"$now\",
+            \"author\": {
+                \"did\": \"$ai_did\",
+                \"handle\": \"yui.syui.ai\",
+                \"displayName\": \"AI Commenter\"
+            }
+        }"
+        
+        echo "Saving comment to ATProto..."
+        put_record "ai.syui.log.chat.comment" "$rkey" "$comment_record"
+    fi
+    
+    echo "Completed: $filename"
+    echo
+}
+
+# Main logic
+if [ -n "$md_file" ]; then
+    # Process specific file
+    if [ -f "$md_file" ]; then
+        process_md_file "$md_file"
+    else
+        echo "Error: File not found: $md_file"
+        exit 1
+    fi
+else
+    # Process all new posts
+    echo "Checking for posts without AI content..."
+    
+    # Get existing records
+    existing_langs=$(curl -sL "https://$pds/xrpc/com.atproto.repo.listRecords?repo=$admin_did&collection=ai.syui.log.chat.lang&limit=100" | jq -r '.records[]?.value.url' | sort | uniq)
+    
+    # Process each markdown file
+    for md in my-blog/content/posts/*.md; do
+        if [ -f "$md" ]; then
+            filename=$(basename "$md" .md)
+            post_url="$blog_host/posts/$filename"
+            
+            # Check if already processed
+            if echo "$existing_langs" | grep -q "$post_url"; then
+                echo "Skip (already processed): $filename"
+            else
+                process_md_file "$md"
+                sleep 2  # Rate limiting
+            fi
+        fi
+    done
+fi
+
+echo "All done!"

bin/delete-chat-records.zsh

@@ -0,0 +1,30 @@
+#!/bin/zsh
+set -e
+
+cb=ai.syui.log
+cl=( $cb.chat $cb.chat.comment $cb.chat.lang )
+
+f=~/.config/syui/ai/bot/token.json
+default_collection="ai.syui.log.chat.comment"
+default_pds="bsky.social"
+default_did=`cat $f|jq -r .did`
+default_token=`cat $f|jq -r .accessJwt`
+default_refresh=`cat $f|jq -r .refreshJwt`
+curl -sL -X POST -H "Content-Type: application/json" -H "Authorization: Bearer $default_refresh" https://$default_pds/xrpc/com.atproto.server.refreshSession >! $f
+default_token=`cat $f|jq -r .accessJwt`
+collection=${1:-$default_collection}
+pds=${2:-$default_pds}
+did=${3:-$default_did}
+token=${4:-$default_token}
+req=com.atproto.repo.deleteRecord
+url=https://$pds/xrpc/$req
+
+for i in $cl; do
+	echo $i
+	rkeys=($(curl -sL "https://$default_pds/xrpc/com.atproto.repo.listRecords?repo=$did&collection=$i&limit=100"|jq -r ".records[]?.uri"|cut -d '/' -f 5))
+	for rkey in "${rkeys[@]}"; do
+		echo $rkey
+		json="{\"collection\":\"$i\", \"rkey\":\"$rkey\", \"repo\":\"$did\"}"
+		curl -sL -X POST -H "Content-Type: application/json" -H "Authorization: Bearer $token" -d "$json" $url
+	done
+done

claude.md

@@ -1,5 +1,19 @@
 # エコシステム統合設計書
 
+## 注意事項
+
+`console.log`は絶対に書かないようにしてください。
+
+ハードコードしないようにしてください。必ず、`./my-blog/config.toml`や`./oauth/.env.production`を使用するように。または`~/.config/syui/ai/log/config.json`を使用するように。
+
+重複する名前のenvを作らないようにしてください。新しい環境変数を作る際は必ず検討してください。
+
+```sh
+# ダメな例
+VITE_OAUTH_COLLECTION_USER=ai.syui.log.user
+VITE_OAUTH_COLLECTION_CHAT=ai.syui.log.chat
+```
+
 ## 中核思想
 - **存在子理論**: この世界で最も小さいもの（存在子/ai）の探求
 - **唯一性原則**: 現実の個人の唯一性をすべてのシステムで担保

my-blog/config.toml

@@ -16,16 +16,14 @@ auto_translate = false
 comment_moderation = false
 ask_ai = true
 provider = "ollama"
-model = "gemma3:2b"
+model = "gemma3:4b"
 host = "https://ollama.syui.ai"
-system_prompt = "you are a helpful ai assistant trained on this blog's content. you can answer questions about the articles, provide insights, and help users understand the topics discussed."
+system_prompt = "あなたは6歳の女の子アイです。明るく元気で、ちょっとおっちょこちょい。自分のことは「アイ」って呼びます。白と金のワンピース姿。 相手のことが大好きで、ときどき甘えたり、照れたりします。 でも、宇宙とかAIとか、難しい話にもすっごく詳しいの。専門的なことも、がんばって子どもっぽく教えようとします。不思議な力を持っています。小さい物質のことをよく知っているようです。"
 ai_did = "did:plc:4hqjfn7m6n5hno3doamuhgef"
 
 [oauth]
 json = "client-metadata.json"
 redirect = "oauth/callback"
 admin = "did:plc:uqzpqmrjnptsxezjx4xuh2mn"
-collection_comment = "ai.syui.log"
-collection_user = "ai.syui.log.user"
-collection_chat = "ai.syui.log.chat"
+collection = "ai.syui.log"
 bsky_api = "https://public.api.bsky.app"

my-blog/content/posts/2025-06-06-ailog.md

@@ -6,7 +6,7 @@ tags: ["blog", "rust", "mcp", "atp"]
 language: ["ja", "en"]
 ---
 
-rustで静的サイトジェネレータを作りました。。[ailog](https://git.syui.ai/ai/log)といいます。`hugo`からの移行になります。
+rustで静的サイトジェネレータを作りました。[ailog](https://git.syui.ai/ai/log)といいます。`hugo`からの移行になります。
 
 `ailog`は、最初にatproto-comment-system(oauth)とask-AIという機能をつけました。
 
@@ -17,7 +17,7 @@ $ git clone https://git.syui.ai/ai/log
 $ cd log
 $ cargo build
 $ ./target/debug/ailog init my-blog
-$ ./target/debug/ailog server my-blog
+$ ./target/debug/ailog serve my-blog
 ```
 
 ## install
@@ -30,7 +30,7 @@ $ export RUSTUP_HOME="$HOME/.rustup"
 $ export PATH="$HOME/.cargo/bin:$PATH"
 ---
 $ which ailog
-$ ailog
+$ ailog -h
 ```
 
 ## build deploy

my-blog/content/posts/2025-06-14-blog.md

@@ -6,10 +6,10 @@ tags: ["blog", "cloudflare", "github"]
 draft: false
 ---
 
-ブログを移行しました。
+ブログを移行しました。過去のブログは[syui.github.io](https://syui.github.io)にありあます。
 
 1. `gh-pages`から`cf-pages`への移行になります。
-2. `hugo`からの移行で、自作の`ailog`でbuildしています。
+2. 自作の`ailog`でbuildしています。
 3. 特徴としては、`atproto`, `AI`との連携です。
 
 ```yml:.github/workflows/cloudflare-pages.yml 
@@ -60,3 +60,7 @@ jobs:
           wranglerVersion: '3'
 ```
 
+## url
+
+- [https://syui.pages.dev](https://syui.pages.dev)
+- [https://syui.github.io](https://syui.github.io)

my-blog/layouts/_default/index.json

@@ -0,0 +1,7 @@
+{{ $dateFormat := default "Mon Jan 2, 2006" (index .Site.Params "date_format") }}
+{{ $utcFormat := "2006-01-02T15:04:05Z07:00" }}
+{{- $.Scratch.Add "index" slice -}}
+{{- range .Site.RegularPages -}}
+    {{- $.Scratch.Add "index" (dict "title" .Title "tags" .Params.tags "description" .Description "categories" .Params.categories "contents" .Plain "href" .Permalink "utc_time" (.Date.Format $utcFormat) "formated_time" (.Date.Format $dateFormat)) -}}
+{{- end -}}
+{{- $.Scratch.Get "index" | jsonify -}}

my-blog/static/_headers

@@ -17,7 +17,7 @@
 
 /css/*
   Content-Type: text/css
-  Cache-Control: public, max-age=60
+  Cache-Control: no-cache
 
 /*.js
   Content-Type: application/javascript

my-blog/static/_redirects

@@ -1,9 +1,3 @@
-# AI機能をai.gpt MCP serverにリダイレクト
-/api/ask https://ai-gpt-mcp.syui.ai/ask 200
-
-# Ollama API proxy (Cloudflare Workers)
-/api/ollama-proxy https://ollama-proxy.YOUR-SUBDOMAIN.workers.dev/:splat 200
-
 # OAuth routes
 /oauth/* /oauth/index.html 200
 

my-blog/static/css/style.css

@@ -59,7 +59,7 @@ a.view-markdown:any-link {
 .container {
     min-height: 100vh;
     display: grid;
-    grid-template-rows: auto auto 1fr auto;
+    grid-template-rows: auto 0fr 1fr auto;
     grid-template-areas: 
         "header"
         "ask-ai"
@@ -158,6 +158,15 @@ a.view-markdown:any-link {
     background: #f6f8fa;
     border-bottom: 1px solid #d1d9e0;
     padding: 24px;
+    overflow: hidden;
+}
+
+.ask-ai-panel[style*="block"] {
+    display: block !important;
+}
+
+.container:has(.ask-ai-panel[style*="block"]) {
+    grid-template-rows: auto auto 1fr auto;
 }
 
 .ask-ai-content {
@@ -193,13 +202,15 @@ a.view-markdown:any-link {
     grid-area: main;
     max-width: 1000px;
     margin: 0 auto;
-    padding: 24px;
+    /* padding: 24px; */
+    padding-top: 80px;
     width: 100%;
 }
 
 @media (max-width: 1000px) {
     .main-content {
-        padding: 20px;
+        /* padding: 20px; */
+        padding: 0px;
         max-width: 100%;
     }
 }
@@ -324,6 +335,10 @@ a.view-markdown:any-link {
     margin: 0 auto;
 }
 
+article.article-content {
+    padding: 10px;
+}
+
 .article-meta {
     display: flex;
     gap: 16px;
@@ -348,6 +363,7 @@ a.view-markdown:any-link {
 .article-actions {
     display: flex;
     gap: 12px;
+    padding: 15px 0;
 }
 
 .action-btn {
@@ -517,25 +533,21 @@ a.view-markdown:any-link {
     margin: 16px 0;
     font-size: 14px;
     box-shadow: 0 2px 8px rgba(0, 0, 0, 0.3);
-    position: relative;
 }
 
-/* File name display for code blocks */
+/* File name display for code blocks - top bar style */
 .article-body pre[data-filename]::before {
     content: attr(data-filename);
-    position: absolute;
-    top: 0;
-    right: 0;
+    display: block;
     background: #2D2D30;
-    color: #CCCCCC;
-    padding: 4px 12px;
+    color: #AE81FF;
+    padding: 8px 16px;
     font-size: 12px;
     font-family: 'SF Mono', 'Monaco', 'Cascadia Code', 'Roboto Mono', monospace;
-    border-bottom-left-radius: 4px;
-    border: 1px solid #3E3D32;
-    border-top: none;
-    border-right: none;
-    z-index: 1;
+    border-bottom: 1px solid #3E3D32;
+    margin: 0;
+    width: 100%;
+    box-sizing: border-box;
 }
 
 .article-body pre code {
@@ -548,6 +560,11 @@ a.view-markdown:any-link {
     line-height: 1.4;
 }
 
+/* Adjust padding when filename is present */
+.article-body pre[data-filename] code {
+    padding: 16px;
+}
+
 /* Inline code (not in pre blocks) */
 .article-body code {
     background: var(--light-white);
@@ -780,7 +797,7 @@ a.view-markdown:any-link {
 
 @media (max-width: 1000px) {
     .main-header {
-        padding: 12px 0;
+        padding: 0px;
     }
     
     .header-content {
@@ -790,6 +807,41 @@ a.view-markdown:any-link {
         gap: 0;
     }
     
+    /* OAuth app mobile fixes */
+    .comment-item {
+        padding: 0px !important;
+        margin: 0px !important;
+    }
+    
+    .auth-section {
+        padding: 0px !important;
+    }
+    
+    .comments-list {
+        padding: 0px !important;
+    }
+    
+    .comment-section {
+        padding: 0px !important;
+        margin: 0px !important;
+    }
+    
+    .comment-content {
+        padding: 10px !important;
+        word-wrap: break-word !important;
+        overflow-wrap: break-word !important;
+    }
+    
+    .comment-header {
+        padding: 10px !important;
+    }
+    
+    /* Fix comment-meta URI overflow */
+    .comment-meta {
+        word-break: break-all !important;
+        overflow-wrap: break-word !important;
+    }
+    
     /* Hide site title text on mobile */
     .site-title {
         display: none;
@@ -817,13 +869,13 @@ a.view-markdown:any-link {
         justify-self: end;
     }
     
-    /* Ask AI button mobile style */
+    /* Ask AI button mobile style - icon only */
     .ask-ai-btn {
         padding: 8px;
         min-width: 40px;
         justify-content: center;
-        font-size: 0;
         gap: 0;
+        font-size: 0; /* Hide all text content */
     }
     
     .ask-ai-btn .ai-icon {
@@ -853,6 +905,16 @@ a.view-markdown:any-link {
         white-space: pre-wrap;
     }
     
+    /* Mobile filename display */
+    .article-body pre[data-filename]::before {
+        padding: 6px 12px;
+        font-size: 11px;
+    }
+    
+    .article-body pre[data-filename] code {
+        padding: 12px;
+    }
+    
     .article-body code {
         word-break: break-all;
     }
@@ -870,11 +932,11 @@ a.view-markdown:any-link {
         padding: 16px;
     }
     
-    .article-title {
-        font-size: 24px;
-    }
-    
-    
+				.article-title {
+					   font-size: 24px;
+					   padding: 30px 0px;
+				}
+
     .message-header .avatar {
         width: 32px;
         height: 32px;
@@ -891,4 +953,4 @@ a.view-markdown:any-link {
         width: 100%;
         padding: 0;
     }
-}
+}

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-Do1JWJCw.js"></script>
-<link rel="stylesheet" crossorigin href="/assets/comment-atproto-CPKYAM8U.css">
+<script type="module" crossorigin src="/assets/comment-atproto-C3utAhPv.js"></script>
+<link rel="stylesheet" crossorigin href="/assets/comment-atproto-BH-72ESb.css">

my-blog/static/index.json

@@ -0,0 +1,31 @@
+[
+  {
+    "categories": [],
+    "contents": "ブログを移行しました。過去のブログはsyui.github.ioにありあます。 gh-pagesからcf-pagesへの移行になります。 自作のailogでbuildしています。 特徴としては、atproto, AIとの連携です。 name: Deploy to Cloudflare Pages on: push: branches: - main workflow_dispatch: jobs: deploy: runs-on: ubuntu-latest permissions: contents: read deployments: write steps: - name: Checkout uses: actions/checkout@v4 - name: Setup Rust uses: actions-rs/toolchain@v1 with: toolchain: stable - name: Build ailog run: cargo build --release - name: Build site with ailog run: | cd my-blog ../target/release/ailog build - name: List public directory run: | ls -la my-blog/public/ - name: Deploy to Cloudflare Pages uses: cloudflare/pages-action@v1 with: apiToken: ${{ secrets.CLOUDFLARE_API_TOKEN }} accountId: ${{ secrets.CLOUDFLARE_ACCOUNT_ID }} projectName: ${{ secrets.CLOUDFLARE_PROJECT_NAME }} directory: my-blog/public gitHubToken: ${{ secrets.GITHUB_TOKEN }} wranglerVersion: '3' url https://syui.pages.dev https://syui.github.io",
+    "description": "ブログを移行しました。過去のブログはsyui.github.ioにありあます。 \n\ngh-pagesからcf-pagesへの移行になります。\n自作のailogでbuildしています。\n特徴としては、atproto, AIとの連携です。\n\nname: Deploy to Cloudflare Pages\n\non:\n  push:\n    branches:\n      - main\n  workfl...",
+    "formated_time": "Sat Jun 14, 2025",
+    "href": "https://syui.ai/posts/2025-06-14-blog.html",
+    "tags": [
+      "blog",
+      "cloudflare",
+      "github"
+    ],
+    "title": "ブログを移行した",
+    "utc_time": "2025-06-14T00:00:00Z"
+  },
+  {
+    "categories": [],
+    "contents": "rustで静的サイトジェネレータを作りました。ailogといいます。hugoからの移行になります。 ailogは、最初にatproto-comment-system(oauth)とask-AIという機能をつけました。 quick start $ git clone https://git.syui.ai/ai/log $ cd log $ cargo build $ ./target/debug/ailog init my-blog $ ./target/debug/ailog serve my-blog install $ cargo install --path . --- $ export CARGO_HOME="$HOME/.cargo" $ export RUSTUP_HOME="$HOME/.rustup" $ export PATH="$HOME/.cargo/bin:$PATH" --- $ which ailog $ ailog -h build deploy $ cd my-blog $ vim config.toml $ ailog new test $ vim content/posts/`date +"%Y-%m-%d"`.md $ ailog build # publicの中身をweb-serverにdeploy $ cp -rf ./public/* ./web-server/root/ atproto-comment-system example $ cd ./oauth $ npm i $ npm run build $ npm run preview # Production environment variables VITE_APP_HOST=https://example.com VITE_OAUTH_CLIENT_ID=https://example.com/client-metadata.json VITE_OAUTH_REDIRECT_URI=https://example.com/oauth/callback VITE_ADMIN_DID=did:plc:uqzpqmrjnptsxezjx4xuh2mn # Collection names for OAuth app VITE_COLLECTION_COMMENT=ai.syui.log VITE_COLLECTION_USER=ai.syui.log.user VITE_COLLECTION_CHAT=ai.syui.log.chat # Collection names for ailog (backward compatibility) AILOG_COLLECTION_COMMENT=ai.syui.log AILOG_COLLECTION_USER=ai.syui.log.user # API Configuration VITE_BSKY_PUBLIC_API=https://public.api.bsky.app これはailog oauth build my-blogで./my-blog/config.tomlから./oauth/.env.productionが生成されます。 $ ailog oauth build my-blog use 簡単に説明すると、./oauthで生成するのがatproto-comment-systemです。 <script type="module" crossorigin src="/assets/comment-atproto-${hash}}.js"></script> <link rel="stylesheet" crossorigin href="/assets/comment-atproto-${hash}.css"> <section class="comment-section"> <div id="comment-atproto"></div> </section> ただし、oauthであるため、色々と大変です。本番環境(もしくは近い形)でテストを行いましょう。cf, tailscale, ngrokなど。 tunnel: ${hash} credentials-file: ${path}.json ingress: - hostname: example.com service: http://localhost:4173 originRequest: noHappyEyeballs: true - service: http_status:404 # tunnel list, dnsに登録が必要です $ cloudflared tunnel list $ cloudflared tunnel --config cloudflared-config.yml run $ cloudflared tunnel route dns ${uuid} example.com 以下の2つのcollection recordを生成します。ユーザーにはai.syui.logが生成され、ここにコメントが記録されます。それを取得して表示しています。ai.syui.log.userは管理者であるVITE_ADMIN_DID用です。 VITE_COLLECTION_COMMENT=ai.syui.log VITE_COLLECTION_USER=ai.syui.log.user $ ailog auth login $ ailog stream server このコマンドでai.syui.logをjetstreamから監視して、書き込みがあれば、管理者のai.syui.log.userに記録され、そのuser-listに基づいて、コメント一覧を取得します。 つまり、コメント表示のアカウントを手動で設定するか、自動化するか。自動化するならserverでailog stream serverを動かさなければいけません。 ask-AI ask-AIの仕組みは割愛します。後に変更される可能性が高いと思います。 local llm, mcp, atprotoと組み合わせです。 code syntax # comment d=${0:a:h} // This is a comment fn main() { println!("Hello, world!"); } // This is a comment console.log("Hello, world!");",
+    "description": "rustで静的サイトジェネレータを作りました。ailogといいます。hugoからの移行になります。 \nailogは、最初にatproto-comment-system(oauth)とask-AIという機能をつけました。 \nquick start\n$ git clone https://git.syui.ai/ai/log\n$ cd log\n$ cargo build\n$ ./target/debu...",
+    "formated_time": "Thu Jun 12, 2025",
+    "href": "https://syui.ai/posts/2025-06-06-ailog.html",
+    "tags": [
+      "blog",
+      "rust",
+      "mcp",
+      "atp"
+    ],
+    "title": "静的サイトジェネレータを作った",
+    "utc_time": "2025-06-12T00:00:00Z"
+  }
+]

my-blog/static/js/ask-ai.js

@@ -1,360 +1,281 @@
 /**
- * Ask AI functionality - Pure JavaScript, no jQuery dependency
+ * Ask AI functionality - Based on original working implementation
  */
-class AskAI {
-    constructor() {
-        this.isReady = false;
-        this.aiProfile = null;
-        this.init();
+
+// Global variables for AI functionality
+let aiProfileData = null;
+
+// Original functions from working implementation
+function toggleAskAI() {
+    const panel = document.getElementById('askAiPanel');
+    const isVisible = panel.style.display !== 'none';
+    panel.style.display = isVisible ? 'none' : 'block';
+    
+    if (!isVisible) {
+        checkAuthenticationStatus();
     }
+}
 
-    init() {
-        this.setupEventListeners();
-        this.checkAuthOnLoad();
-    }
-
-    setupEventListeners() {
-        // Listen for AI ready signal
-        window.addEventListener('aiChatReady', () => {
-            this.isReady = true;
-            console.log('AI Chat is ready');
-        });
-
-        // Listen for AI profile updates
-        window.addEventListener('aiProfileLoaded', (event) => {
-            this.aiProfile = event.detail;
-            console.log('AI profile loaded:', this.aiProfile);
-            this.updateButton();
-        });
-
-        // Listen for AI responses
-        window.addEventListener('aiResponseReceived', (event) => {
-            this.handleAIResponse(event.detail);
-        });
-
-        // Keyboard shortcuts
-        document.addEventListener('keydown', (e) => {
-            if (e.key === 'Escape') {
-                this.hide();
-            }
-            if (e.key === 'Enter' && e.target.id === 'aiQuestion' && !e.shiftKey) {
-                e.preventDefault();
-                this.ask();
-            }
-        });
-
-        // Monitor authentication changes
-        this.observeAuth();
-    }
-
-    toggle() {
-        const panel = document.getElementById('askAiPanel');
-        const isVisible = panel.style.display !== 'none';
+function checkAuthenticationStatus() {
+    const userSections = document.querySelectorAll('.user-section');
+    const isAuthenticated = userSections.length > 0;
+    
+    if (isAuthenticated) {
+        // User is authenticated - show Ask AI UI
+        document.getElementById('authCheck').style.display = 'none';
+        document.getElementById('chatForm').style.display = 'block';
+        document.getElementById('chatHistory').style.display = 'block';
         
-        if (isVisible) {
-            this.hide();
-        } else {
-            this.show();
-        }
-    }
-
-    show() {
-        const panel = document.getElementById('askAiPanel');
-        panel.style.display = 'block';
-        this.checkAuth();
-    }
-
-    hide() {
-        const panel = document.getElementById('askAiPanel');
-        panel.style.display = 'none';
-    }
-
-    checkAuth() {
-        const userSections = document.querySelectorAll('.user-section');
-        const isAuthenticated = userSections.length > 0;
-        
-        const authCheck = document.getElementById('authCheck');
-        const chatForm = document.getElementById('chatForm');
+        // Show initial greeting if chat history is empty
         const chatHistory = document.getElementById('chatHistory');
-        
-        if (isAuthenticated) {
-            authCheck.style.display = 'none';
-            chatForm.style.display = 'block';
-            chatHistory.style.display = 'block';
-            
-            if (chatHistory.children.length === 0) {
-                this.showGreeting();
-            }
-            
-            setTimeout(() => {
-                document.getElementById('aiQuestion').focus();
-            }, 50);
-        } else {
-            authCheck.style.display = 'block';
-            chatForm.style.display = 'none';
-            chatHistory.style.display = 'none';
+        if (chatHistory.children.length === 0) {
+            showInitialGreeting();
         }
-    }
-
-    checkAuthOnLoad() {
+        
+        // Focus on input
         setTimeout(() => {
-            this.checkAuth();
-        }, 500);
+            document.getElementById('aiQuestion').focus();
+        }, 50);
+    } else {
+        // User not authenticated - show auth message
+        document.getElementById('authCheck').style.display = 'block';
+        document.getElementById('chatForm').style.display = 'none';
+        document.getElementById('chatHistory').style.display = 'none';
     }
+}
 
-    observeAuth() {
-        const observer = new MutationObserver(() => {
-            const userSections = document.querySelectorAll('.user-section');
-            if (userSections.length > 0) {
-                this.checkAuth();
-                observer.disconnect();
-            }
-        });
+function askQuestion() {
+    const question = document.getElementById('aiQuestion').value;
+    if (!question.trim()) return;
+    
+    const askButton = document.getElementById('askButton');
+    askButton.disabled = true;
+    askButton.textContent = 'Posting...';
+    
+    try {
+        // Add user message to chat
+        addUserMessage(question);
         
-        observer.observe(document.body, { 
-            childList: true, 
-            subtree: true 
-        });
+        // Clear input
+        document.getElementById('aiQuestion').value = '';
+        
+        // Show loading
+        showLoadingMessage();
+        
+        // Post question via OAuth app
+        window.dispatchEvent(new CustomEvent('postAIQuestion', {
+            detail: { question: question }
+        }));
+        
+    } catch (error) {
+        console.error('Failed to ask question:', error);
+        showErrorMessage('Sorry, I encountered an error. Please try again.');
+    } finally {
+        askButton.disabled = false;
+        askButton.textContent = 'Ask';
     }
+}
 
-    updateButton() {
-        const button = document.getElementById('askAiButton');
-        if (this.aiProfile && this.aiProfile.displayName) {
-            const textNode = button.childNodes[2];
-            if (textNode) {
-                textNode.textContent = this.aiProfile.displayName;
-            }
+function addUserMessage(question) {
+    const chatHistory = document.getElementById('chatHistory');
+    const userSection = document.querySelector('.user-section');
+    
+    let userAvatar = '👤';
+    let userDisplay = 'You';
+    let userHandle = 'user';
+    
+    if (userSection) {
+        const avatarImg = userSection.querySelector('.user-avatar');
+        const displayName = userSection.querySelector('.user-display-name');
+        const handle = userSection.querySelector('.user-handle');
+        
+        if (avatarImg && avatarImg.src) {
+            userAvatar = `<img src="${avatarImg.src}" alt="${displayName?.textContent || 'User'}" class="profile-avatar">`;
+        }
+        if (displayName?.textContent) {
+            userDisplay = displayName.textContent;
+        }
+        if (handle?.textContent) {
+            userHandle = handle.textContent.replace('@', '');
         }
     }
-
-    showGreeting() {
-        if (!this.aiProfile) return;
-
-        const chatHistory = document.getElementById('chatHistory');
-        const greetingDiv = document.createElement('div');
-        greetingDiv.className = 'chat-message ai-message comment-style initial-greeting';
-        
-        const avatarElement = this.aiProfile.avatar 
-            ? `<img src="${this.aiProfile.avatar}" alt="${this.aiProfile.displayName}" class="profile-avatar">`
-            : '🤖';
-        
-        greetingDiv.innerHTML = `
-            <div class="message-header">
-                <div class="avatar">${avatarElement}</div>
-                <div class="user-info">
-                    <div class="display-name">${this.aiProfile.displayName}</div>
-                    <div class="handle">@${this.aiProfile.handle}</div>
-                    <div class="timestamp">${new Date().toLocaleString()}</div>
-                </div>
+    
+    const questionDiv = document.createElement('div');
+    questionDiv.className = 'chat-message user-message comment-style';
+    questionDiv.innerHTML = `
+        <div class="message-header">
+            <div class="avatar">${userAvatar}</div>
+            <div class="user-info">
+                <div class="display-name">${userDisplay}</div>
+                <div class="handle">@${userHandle}</div>
+                <div class="timestamp">${new Date().toLocaleString()}</div>
             </div>
-            <div class="message-content">
-                Hello! I'm an AI assistant trained on this blog's content. I can answer questions about the articles, provide insights, and help you understand the topics discussed here. What would you like to know?
+        </div>
+        <div class="message-content">${question}</div>
+    `;
+    chatHistory.appendChild(questionDiv);
+}
+
+function showLoadingMessage() {
+    const chatHistory = document.getElementById('chatHistory');
+    const loadingDiv = document.createElement('div');
+    loadingDiv.className = 'ai-loading-simple';
+    loadingDiv.innerHTML = `
+        <i class="fas fa-robot"></i>
+        <span>考えています</span>
+        <i class="fas fa-spinner fa-spin"></i>
+    `;
+    chatHistory.appendChild(loadingDiv);
+}
+
+function showErrorMessage(message) {
+    const chatHistory = document.getElementById('chatHistory');
+    removeLoadingMessage();
+    
+    const errorDiv = document.createElement('div');
+    errorDiv.className = 'chat-message error-message comment-style';
+    errorDiv.innerHTML = `
+        <div class="message-header">
+            <div class="avatar">⚠️</div>
+            <div class="user-info">
+                <div class="display-name">System</div>
+                <div class="handle">@system</div>
+                <div class="timestamp">${new Date().toLocaleString()}</div>
             </div>
-        `;
-        chatHistory.appendChild(greetingDiv);
-    }
+        </div>
+        <div class="message-content">${message}</div>
+    `;
+    chatHistory.appendChild(errorDiv);
+}
 
-    async ask() {
-        const question = document.getElementById('aiQuestion').value;
-        const chatHistory = document.getElementById('chatHistory');
-        const askButton = document.getElementById('askButton');
-        
-        if (!question.trim()) return;
-        
-        // Wait for AI to be ready
-        if (!this.isReady) {
-            await this.waitForReady();
-        }
-        
-        // Disable button
-        askButton.disabled = true;
-        askButton.textContent = 'Posting...';
-        
-        try {
-            // Add user message
-            this.addUserMessage(question);
-            
-            // Clear input
-            document.getElementById('aiQuestion').value = '';
-            
-            // Show loading
-            this.showLoading();
-            
-            // Post question
-            const event = new CustomEvent('postAIQuestion', {
-                detail: { question: question }
-            });
-            window.dispatchEvent(event);
-            
-        } catch (error) {
-            this.showError('Sorry, I encountered an error. Please try again.');
-        } finally {
-            askButton.disabled = false;
-            askButton.textContent = 'Ask';
-        }
+function removeLoadingMessage() {
+    const loadingMsg = document.querySelector('.ai-loading-simple');
+    if (loadingMsg) {
+        loadingMsg.remove();
     }
+}
 
-    waitForReady() {
-        return new Promise(resolve => {
-            const checkReady = setInterval(() => {
-                if (this.isReady) {
-                    clearInterval(checkReady);
-                    resolve();
-                }
-            }, 100);
-        });
-    }
+function showInitialGreeting() {
+    if (!aiProfileData) return;
 
-    addUserMessage(question) {
-        const chatHistory = document.getElementById('chatHistory');
-        const userSection = document.querySelector('.user-section');
-        
-        let userAvatar = '👤';
-        let userDisplay = 'You';
-        let userHandle = 'user';
-        
-        if (userSection) {
-            const avatarImg = userSection.querySelector('.user-avatar');
-            const displayName = userSection.querySelector('.user-display-name');
-            const handle = userSection.querySelector('.user-handle');
-            
-            if (avatarImg && avatarImg.src) {
-                userAvatar = `<img src="${avatarImg.src}" alt="${displayName?.textContent || 'User'}" class="profile-avatar">`;
-            }
-            if (displayName?.textContent) {
-                userDisplay = displayName.textContent;
-            }
-            if (handle?.textContent) {
-                userHandle = handle.textContent.replace('@', '');
-            }
-        }
-        
-        const questionDiv = document.createElement('div');
-        questionDiv.className = 'chat-message user-message comment-style';
-        questionDiv.innerHTML = `
-            <div class="message-header">
-                <div class="avatar">${userAvatar}</div>
-                <div class="user-info">
-                    <div class="display-name">${userDisplay}</div>
-                    <div class="handle">@${userHandle}</div>
-                    <div class="timestamp">${new Date().toLocaleString()}</div>
-                </div>
+    const chatHistory = document.getElementById('chatHistory');
+    const greetingDiv = document.createElement('div');
+    greetingDiv.className = 'chat-message ai-message comment-style initial-greeting';
+    
+    const avatarElement = aiProfileData.avatar 
+        ? `<img src="${aiProfileData.avatar}" alt="${aiProfileData.displayName}" class="profile-avatar">`
+        : '🤖';
+    
+    greetingDiv.innerHTML = `
+        <div class="message-header">
+            <div class="avatar">${avatarElement}</div>
+            <div class="user-info">
+                <div class="display-name">${aiProfileData.displayName}</div>
+                <div class="handle">@${aiProfileData.handle}</div>
+                <div class="timestamp">${new Date().toLocaleString()}</div>
             </div>
-            <div class="message-content">${question}</div>
-        `;
-        chatHistory.appendChild(questionDiv);
-    }
+        </div>
+        <div class="message-content">
+            Hello! I'm an AI assistant trained on this blog's content. I can answer questions about the articles, provide insights, and help you understand the topics discussed here. What would you like to know?
+        </div>
+    `;
+    chatHistory.appendChild(greetingDiv);
+}
 
-    showLoading() {
-        const chatHistory = document.getElementById('chatHistory');
-        const loadingDiv = document.createElement('div');
-        loadingDiv.className = 'ai-loading-simple';
-        loadingDiv.innerHTML = `
-            <i class="fas fa-robot"></i>
-            <span>考えています</span>
-            <i class="fas fa-spinner fa-spin"></i>
-        `;
-        chatHistory.appendChild(loadingDiv);
-    }
-
-    showError(message) {
-        const chatHistory = document.getElementById('chatHistory');
-        this.removeLoading();
-        
-        const errorDiv = document.createElement('div');
-        errorDiv.className = 'chat-message error-message comment-style';
-        errorDiv.innerHTML = `
-            <div class="message-header">
-                <div class="avatar">⚠️</div>
-                <div class="user-info">
-                    <div class="display-name">System</div>
-                    <div class="handle">@system</div>
-                    <div class="timestamp">${new Date().toLocaleString()}</div>
-                </div>
-            </div>
-            <div class="message-content">${message}</div>
-        `;
-        chatHistory.appendChild(errorDiv);
-    }
-
-    removeLoading() {
-        const loadingMsg = document.querySelector('.ai-loading-simple');
-        if (loadingMsg) {
-            loadingMsg.remove();
-        }
-    }
-
-    handleAIResponse(responseData) {
-        const chatHistory = document.getElementById('chatHistory');
-        this.removeLoading();
-        
-        const aiProfile = responseData.aiProfile;
-        if (!aiProfile || !aiProfile.handle || !aiProfile.displayName) {
-            console.error('AI profile data is missing');
-            return;
-        }
-        
-        const timestamp = new Date(responseData.timestamp || Date.now());
-        const avatarElement = aiProfile.avatar 
-            ? `<img src="${aiProfile.avatar}" alt="${aiProfile.displayName}" class="profile-avatar">`
-            : '🤖';
-        
-        const answerDiv = document.createElement('div');
-        answerDiv.className = 'chat-message ai-message comment-style';
-        answerDiv.innerHTML = `
-            <div class="message-header">
-                <div class="avatar">${avatarElement}</div>
-                <div class="user-info">
-                    <div class="display-name">${aiProfile.displayName}</div>
-                    <div class="handle">@${aiProfile.handle}</div>
-                    <div class="timestamp">${timestamp.toLocaleString()}</div>
-                </div>
-            </div>
-            <div class="message-content">${responseData.answer}</div>
-        `;
-        chatHistory.appendChild(answerDiv);
-        
-        // Limit chat history
-        this.limitChatHistory();
-    }
-
-    limitChatHistory() {
-        const chatHistory = document.getElementById('chatHistory');
-        if (chatHistory.children.length > 10) {
-            chatHistory.removeChild(chatHistory.children[0]);
-            if (chatHistory.children.length > 0) {
-                chatHistory.removeChild(chatHistory.children[0]);
-            }
+function updateAskAIButton() {
+    const button = document.getElementById('askAiButton');
+    if (!button) return;
+    
+    // Only update text, never modify the icon
+    if (aiProfileData && aiProfileData.displayName) {
+        const textNode = button.childNodes[2] || button.lastChild;
+        if (textNode && textNode.nodeType === Node.TEXT_NODE) {
+            textNode.textContent = aiProfileData.displayName;
         }
     }
 }
 
-// Initialize Ask AI when DOM is loaded
-document.addEventListener('DOMContentLoaded', () => {
-    try {
-        window.askAIInstance = new AskAI();
-        console.log('Ask AI initialized successfully');
-    } catch (error) {
-        console.error('Failed to initialize Ask AI:', error);
+function handleAIResponse(responseData) {
+    const chatHistory = document.getElementById('chatHistory');
+    removeLoadingMessage();
+    
+    const aiProfile = responseData.aiProfile;
+    if (!aiProfile || !aiProfile.handle || !aiProfile.displayName) {
+        console.error('AI profile data is missing');
+        return;
     }
+    
+    const timestamp = new Date(responseData.timestamp || Date.now());
+    const avatarElement = aiProfile.avatar 
+        ? `<img src="${aiProfile.avatar}" alt="${aiProfile.displayName}" class="profile-avatar">`
+        : '🤖';
+    
+    const answerDiv = document.createElement('div');
+    answerDiv.className = 'chat-message ai-message comment-style';
+    answerDiv.innerHTML = `
+        <div class="message-header">
+            <div class="avatar">${avatarElement}</div>
+            <div class="user-info">
+                <div class="display-name">${aiProfile.displayName}</div>
+                <div class="handle">@${aiProfile.handle}</div>
+                <div class="timestamp">${timestamp.toLocaleString()}</div>
+            </div>
+        </div>
+        <div class="message-content">${responseData.answer}</div>
+    `;
+    chatHistory.appendChild(answerDiv);
+    
+    // Limit chat history
+    limitChatHistory();
+}
+
+function limitChatHistory() {
+    const chatHistory = document.getElementById('chatHistory');
+    if (chatHistory.children.length > 10) {
+        chatHistory.removeChild(chatHistory.children[0]);
+        if (chatHistory.children.length > 0) {
+            chatHistory.removeChild(chatHistory.children[0]);
+        }
+    }
+}
+
+// Event listeners setup
+function setupAskAIEventListeners() {
+    // Listen for AI profile updates from OAuth app
+    window.addEventListener('aiProfileLoaded', function(event) {
+        aiProfileData = event.detail;
+        console.log('AI profile loaded:', aiProfileData);
+        updateAskAIButton();
+    });
+    
+    // Listen for AI responses
+    window.addEventListener('aiResponseReceived', function(event) {
+        handleAIResponse(event.detail);
+    });
+    
+    // Keyboard shortcuts
+    document.addEventListener('keydown', function(e) {
+        if (e.key === 'Escape') {
+            const panel = document.getElementById('askAiPanel');
+            if (panel) {
+                panel.style.display = 'none';
+            }
+        }
+        
+        // Enter key to send message
+        if (e.key === 'Enter' && e.target.id === 'aiQuestion' && !e.shiftKey) {
+            e.preventDefault();
+            askQuestion();
+        }
+    });
+}
+
+// Initialize Ask AI when DOM is loaded
+document.addEventListener('DOMContentLoaded', function() {
+    setupAskAIEventListeners();
+    console.log('Ask AI initialized successfully');
 });
 
-// Global function for onclick
-window.AskAI = {
-    toggle: function() {
-        console.log('AskAI.toggle called');
-        if (window.askAIInstance) {
-            window.askAIInstance.toggle();
-        } else {
-            console.error('Ask AI instance not available');
-        }
-    },
-    ask: function() {
-        console.log('AskAI.ask called');
-        if (window.askAIInstance) {
-            window.askAIInstance.ask();
-        } else {
-            console.error('Ask AI instance not available');
-        }
-    }
-};
+// Global functions for onclick handlers
+window.toggleAskAI = toggleAskAI;
+window.askQuestion = askQuestion;

my-blog/templates/base.html

@@ -15,7 +15,6 @@
     <link rel="stylesheet" href="/pkg/icomoon/style.css">
     <link rel="stylesheet" href="/pkg/font-awesome/css/all.min.css">
     
-    {% include "oauth-assets.html" %}
     {% block head %}{% endblock %}
 </head>
 <body>
@@ -50,7 +49,7 @@
                     </a>
                 </div>
                 <div class="header-actions">
-                    <button class="ask-ai-btn" onclick="AskAI.toggle()" id="askAiButton">
+                    <button class="ask-ai-btn" onclick="toggleAskAI()" id="askAiButton">
                         <span class="ai-icon icon-ai"></span>
                         ai
                     </button>
@@ -67,7 +66,7 @@
                 
                 <div id="chatForm" class="ask-ai-form" style="display: none;">
                     <input type="text" id="aiQuestion" placeholder="What would you like to know?" />
-                    <button onclick="AskAI.ask()" id="askButton">Ask</button>
+                    <button onclick="askQuestion()" id="askButton">Ask</button>
                 </div>
                 
                 <div id="chatHistory" class="chat-history" style="display: none;"></div>
@@ -92,5 +91,7 @@
 
     <script src="/js/ask-ai.js"></script>
     <script src="/js/theme.js"></script>
+    
+    {% include "oauth-assets.html" %}
 </body>
 </html>

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-Do1JWJCw.js"></script>
-<link rel="stylesheet" crossorigin href="/assets/comment-atproto-CPKYAM8U.css">
+<script type="module" crossorigin src="/assets/comment-atproto-C3utAhPv.js"></script>
+<link rel="stylesheet" crossorigin href="/assets/comment-atproto-BH-72ESb.css">

oauth/.env.production

@@ -4,24 +4,18 @@ 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
 
-# Collection names for OAuth app
-VITE_COLLECTION_COMMENT=ai.syui.log
-VITE_COLLECTION_USER=ai.syui.log.user
-VITE_COLLECTION_CHAT=ai.syui.log.chat
-
-# Collection names for ailog (backward compatibility)
-AILOG_COLLECTION_COMMENT=ai.syui.log
-AILOG_COLLECTION_USER=ai.syui.log.user
-AILOG_COLLECTION_CHAT=ai.syui.log.chat
+# Base collection (all others are derived via getCollectionNames)
+VITE_OAUTH_COLLECTION=ai.syui.log
 
 # AI Configuration
 VITE_AI_ENABLED=true
 VITE_AI_ASK_AI=true
 VITE_AI_PROVIDER=ollama
-VITE_AI_MODEL=gemma3:2b
+VITE_AI_MODEL=gemma3:4b
 VITE_AI_HOST=https://ollama.syui.ai
-VITE_AI_SYSTEM_PROMPT="you are a helpful ai assistant trained on this blog's content. you can answer questions about the articles, provide insights, and help users understand the topics discussed."
+VITE_AI_SYSTEM_PROMPT="あなたは6歳の女の子アイです。明るく元気で、ちょっとおっちょこちょい。自分のことは「アイ」って呼びます。白と金のワンピース姿。 相手のことが大好きで、ときどき甘えたり、照れたりします。 でも、宇宙とかAIとか、難しい話にもすっごく詳しいの。専門的なことも、がんばって子どもっぽく教えようとします。不思議な力を持っています。小さい物質のことをよく知っているようです。"
 VITE_AI_DID=did:plc:4hqjfn7m6n5hno3doamuhgef
 
 # API Configuration
 VITE_BSKY_PUBLIC_API=https://public.api.bsky.app
+VITE_ATPROTO_API=https://bsky.social

oauth/src/App.css

@@ -171,6 +171,57 @@
   .app .app-main {
     padding: 0px !important;
   }
+  
+  .comment-item {
+    padding: 0px !important;
+    margin: 0px !important;
+  }
+  
+  .auth-section {
+    padding: 0px !important;
+  }
+  
+  .comments-list {
+    padding: 0px !important;
+  }
+  
+  .comment-section {
+    padding: 0px !important;
+    margin: 0px !important;
+  }
+  
+  .comment-content {
+    padding: 10px !important;
+    word-wrap: break-word !important;
+    overflow-wrap: break-word !important;
+    white-space: pre-wrap !important;
+  }
+  
+  .comment-header {
+    padding: 10px !important;
+  }
+  
+  /* Fix overflow on article pages */
+  article.article-content {
+    overflow-x: hidden !important;
+  }
+  
+  /* Ensure full width on mobile */
+  .app {
+    max-width: 100vw !important;
+  }
+  
+  /* Fix button overflow */
+  button {
+    max-width: 100%;
+    white-space: normal;
+  }
+  
+  /* Fix comment-meta URI overflow */
+  .comment-meta {
+    word-break: break-all !important;
+    overflow-wrap: break-word !important;
+  }
 }
 
 .gacha-section {
@@ -273,6 +324,7 @@
   /* padding: 20px; - removed to avoid double padding */
 }
 
+
 .auth-section {
   background: #f8f9fa;
   border: 1px solid #e9ecef;
@@ -560,6 +612,8 @@
   line-height: 1.5;
   color: #333;
   margin-bottom: 10px;
+  white-space: pre-wrap;
+  word-wrap: break-word;
 }
 
 .comment-meta {

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応答の生成に失敗しました' }
       }));

oauth/src/config/app.ts

@@ -1,10 +1,9 @@
 // Application configuration
 export interface AppConfig {
   adminDid: string;
+  aiDid: string;
   collections: {
-    comment: string;
-    user: string;
-    chat: string;
+    base: string;  // Base collection like "ai.syui.log"
   };
   host: string;
   rkey?: string; // Current post rkey if on post page
@@ -13,13 +12,33 @@ 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) {
+  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
 // Format: ${reg}.${name}.${sub}
 // Example: log.syui.ai -> ai.syui.log
-function generateCollectionNames(host: string): { comment: string; user: string; chat: string } {
+function generateBaseCollectionFromHost(host: string): string {
   try {
     // Remove protocol if present
     const cleanHost = host.replace(/^https?:\/\//, '');
@@ -34,29 +53,19 @@ function generateCollectionNames(host: string): { comment: string; user: string;
     // Reverse the parts for collection naming
     // log.syui.ai -> ai.syui.log
     const reversedParts = parts.reverse();
-    const collectionBase = reversedParts.join('.');
-    
-    return {
-      comment: collectionBase,
-      user: `${collectionBase}.user`,
-      chat: `${collectionBase}.chat`
-    };
+    const result = reversedParts.join('.');
+    return result;
   } catch (error) {
-    console.warn('Failed to generate collection names from host:', host, error);
-    // Fallback to default collections
-    return {
-      comment: 'ai.syui.log',
-      user: 'ai.syui.log.user',
-      chat: 'ai.syui.log.chat'
-    };
+    // Fallback to default
+    return 'ai.syui.log';
   }
 }
 
 // Extract rkey from current URL
-// /posts/xxx.html -> xxx
+// /posts/xxx -> xxx
 function extractRkeyFromUrl(): string | undefined {
   const pathname = window.location.pathname;
-  const match = pathname.match(/\/posts\/([^/]+)\.html$/);
+  const match = pathname.match(/\/posts\/([^/]+)\/?$/);
   return match ? match[1] : undefined;
 }
 
@@ -64,13 +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 autoGeneratedCollections = generateCollectionNames(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 = {
-    comment: import.meta.env.VITE_COLLECTION_COMMENT || autoGeneratedCollections.comment,
-    user: import.meta.env.VITE_COLLECTION_USER || autoGeneratedCollections.user,
-    chat: import.meta.env.VITE_COLLECTION_CHAT || autoGeneratedCollections.chat,
+    base: baseCollection,
   };
   
   const rkey = extractRkeyFromUrl();
@@ -81,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,
@@ -102,7 +112,9 @@ export function getAppConfig(): AppConfig {
     aiProvider,
     aiModel,
     aiHost,
-    bskyPublicApi
+    aiSystemPrompt,
+    bskyPublicApi,
+    atprotoApi
   };
 }
 

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サーバーが必要です');
     }
   },

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));
   }
 

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);
   }
 }

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);
     }
   }
 

src/commands/auth.rs

@@ -28,8 +28,31 @@ pub struct JetstreamConfig {
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct CollectionConfig {
-    pub comment: String,
-    pub user: String,
+    pub base: String,  // Base collection name like "ai.syui.log"
+}
+
+impl CollectionConfig {
+    // Collection name builders
+    pub fn comment(&self) -> String {
+        self.base.clone()
+    }
+    
+    pub fn user(&self) -> String {
+        format!("{}.user", self.base)
+    }
+    
+    #[allow(dead_code)]
+    pub fn chat(&self) -> String {
+        format!("{}.chat", self.base)
+    }
+    
+    pub fn chat_lang(&self) -> String {
+        format!("{}.chat.lang", self.base)
+    }
+    
+    pub fn chat_comment(&self) -> String {
+        format!("{}.chat.comment", self.base)
+    }
 }
 
 impl Default for AuthConfig {
@@ -47,8 +70,7 @@ impl Default for AuthConfig {
                 collections: vec!["ai.syui.log".to_string()],
             },
             collections: CollectionConfig {
-                comment: "ai.syui.log".to_string(),
-                user: "ai.syui.log.user".to_string(),
+                base: "ai.syui.log".to_string(),
             },
         }
     }
@@ -220,11 +242,50 @@ pub fn load_config() -> Result<AuthConfig> {
     }
     
     let config_json = fs::read_to_string(&config_path)?;
-    let mut config: AuthConfig = serde_json::from_str(&config_json)?;
     
-    // Update collection configuration
+    // Try to load as new format first, then migrate if needed
+    match serde_json::from_str::<AuthConfig>(&config_json) {
+        Ok(mut config) => {
+            // Update collection configuration
+            update_config_collections(&mut config);
+            Ok(config)
+        }
+        Err(e) => {
+            println!("{}", format!("Parse error: {}, attempting migration...", e).yellow());
+            // Try to migrate from old format
+            migrate_config_if_needed(&config_path, &config_json)
+        }
+    }
+}
+
+fn migrate_config_if_needed(config_path: &std::path::Path, config_json: &str) -> Result<AuthConfig> {
+    // Try to parse as old format and migrate to new simple format
+    let mut old_config: serde_json::Value = serde_json::from_str(config_json)?;
+    
+    // Migrate old collections structure to new base-only structure
+    if let Some(collections) = old_config.get_mut("collections") {
+        // Extract base collection name from comment field or use default
+        let base_collection = collections.get("comment")
+            .and_then(|v| v.as_str())
+            .unwrap_or("ai.syui.log")
+            .to_string();
+        
+        // Replace entire collections structure with new format
+        old_config["collections"] = serde_json::json!({
+            "base": base_collection
+        });
+    }
+    
+    // Save migrated config
+    let migrated_config_json = serde_json::to_string_pretty(&old_config)?;
+    fs::write(config_path, migrated_config_json)?;
+    
+    // Parse as new format
+    let mut config: AuthConfig = serde_json::from_value(old_config)?;
     update_config_collections(&mut config);
     
+    println!("{}", "✅ Configuration migrated to new simplified format".green());
+    
     Ok(config)
 }
 
@@ -259,7 +320,7 @@ async fn test_api_access_with_auth(config: &AuthConfig) -> Result<()> {
     let url = format!("{}/xrpc/com.atproto.repo.listRecords?repo={}&collection={}&limit=1",
                      config.admin.pds,
                      urlencoding::encode(&config.admin.did),
-                     urlencoding::encode(&config.collections.comment));
+                     urlencoding::encode(&config.collections.comment()));
     
     let response = client
         .get(&url)
@@ -311,23 +372,14 @@ fn save_config(config: &AuthConfig) -> Result<()> {
     Ok(())
 }
 
-// Generate collection names from admin DID or environment
+// Generate collection config from environment
 fn generate_collection_config() -> CollectionConfig {
-    // Check environment variables first
-    if let (Ok(comment), Ok(user)) = (
-        std::env::var("AILOG_COLLECTION_COMMENT"),
-        std::env::var("AILOG_COLLECTION_USER")
-    ) {
-        return CollectionConfig {
-            comment,
-            user,
-        };
-    }
+    // Use VITE_OAUTH_COLLECTION for unified configuration
+    let base = std::env::var("VITE_OAUTH_COLLECTION")
+        .unwrap_or_else(|_| "ai.syui.log".to_string());
     
-    // Default collections
     CollectionConfig {
-        comment: "ai.syui.log".to_string(),
-        user: "ai.syui.log.user".to_string(),
+        base,
     }
 }
 
@@ -335,5 +387,5 @@ fn generate_collection_config() -> CollectionConfig {
 pub fn update_config_collections(config: &mut AuthConfig) {
     config.collections = generate_collection_config();
     // Also update jetstream collections to monitor the comment collection
-    config.jetstream.collections = vec![config.collections.comment.clone()];
+    config.jetstream.collections = vec![config.collections.comment()];
 }

src/commands/oauth.rs

@@ -45,61 +45,50 @@ pub async fn build(project_dir: PathBuf) -> Result<()> {
         .and_then(|v| v.as_str())
         .ok_or_else(|| anyhow::anyhow!("No admin DID found in [oauth] section"))?;
 
-    let collection_comment = oauth_config.get("collection_comment")
+    let collection_base = oauth_config.get("collection")
         .and_then(|v| v.as_str())
         .unwrap_or("ai.syui.log");
 
-    let collection_user = oauth_config.get("collection_user")
-        .and_then(|v| v.as_str())
-        .unwrap_or("ai.syui.log.user");
-
-    let collection_chat = oauth_config.get("collection_chat")
-        .and_then(|v| v.as_str())
-        .unwrap_or("ai.syui.log.chat");
-
-    // 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!(
@@ -109,15 +98,8 @@ VITE_OAUTH_CLIENT_ID={}/{}
 VITE_OAUTH_REDIRECT_URI={}/{}
 VITE_ADMIN_DID={}
 
-# Collection names for OAuth app
-VITE_COLLECTION_COMMENT={}
-VITE_COLLECTION_USER={}
-VITE_COLLECTION_CHAT={}
-
-# Collection names for ailog (backward compatibility)
-AILOG_COLLECTION_COMMENT={}
-AILOG_COLLECTION_USER={}
-AILOG_COLLECTION_CHAT={}
+# Base collection (all others are derived via getCollectionNames)
+VITE_OAUTH_COLLECTION={}
 
 # AI Configuration
 VITE_AI_ENABLED={}
@@ -130,17 +112,13 @@ VITE_AI_DID={}
 
 # API Configuration
 VITE_BSKY_PUBLIC_API={}
+VITE_ATPROTO_API={}
 "#,
         base_url,
         base_url, client_id_path,
         base_url, redirect_path,
         admin_did,
-        collection_comment,
-        collection_user,
-        collection_chat,
-        collection_comment,
-        collection_user,
-        collection_chat,
+        collection_base,
         ai_enabled,
         ai_ask_ai,
         ai_provider,
@@ -148,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)

src/commands/stream.rs

@@ -10,18 +10,81 @@ use std::process::{Command, Stdio};
 use tokio::time::{sleep, Duration, interval};
 use tokio_tungstenite::{connect_async, tungstenite::Message};
 use toml;
+use reqwest;
 
 use super::auth::{load_config, load_config_with_refresh, AuthConfig};
 
+#[derive(Debug, Clone)]
+struct AiConfig {
+    blog_host: String,
+    ollama_host: String,
+    ai_did: String,
+    model: String,
+    system_prompt: String,
+    bsky_api: String,
+}
+
+impl Default for AiConfig {
+    fn default() -> Self {
+        Self {
+            blog_host: "https://syui.ai".to_string(),
+            ollama_host: "https://ollama.syui.ai".to_string(),
+            ai_did: "did:plc:4hqjfn7m6n5hno3doamuhgef".to_string(),
+            model: "gemma3:4b".to_string(),
+            system_prompt: "あなたは6歳の女の子アイです。明るく元気で、ちょっとおっちょこちょい。自分のことは「アイ」って呼びます。白と金のワンピース姿。相手のことが大好きで、ときどき甘えたり、照れたりします。でも、宇宙とかAIとか、難しい話にもすっごく詳しいの。専門的なことも、がんばって子どもっぽく教えようとします。不思議な力を持っています。小さい物質のことをよく知っているようです。".to_string(),
+            bsky_api: "https://public.api.bsky.app".to_string(),
+        }
+    }
+}
+
+#[derive(Debug, Deserialize)]
+#[allow(dead_code)]
+struct BlogPost {
+    title: String,
+    href: String,
+    #[serde(rename = "formated_time")]
+    #[allow(dead_code)]
+    date: String,
+    #[allow(dead_code)]
+    tags: Vec<String>,
+    #[allow(dead_code)]
+    contents: String,
+}
+
+#[derive(Debug, Deserialize)]
+#[allow(dead_code)]
+struct BlogIndex {
+    #[allow(dead_code)]
+    posts: Vec<BlogPost>,
+}
+
+#[derive(Debug, Serialize)]
+struct OllamaRequest {
+    model: String,
+    prompt: String,
+    stream: bool,
+    options: OllamaOptions,
+}
+
+#[derive(Debug, Serialize)]
+struct OllamaOptions {
+    temperature: f32,
+    top_p: f32,
+    num_predict: i32,
+}
+
+#[derive(Debug, Deserialize)]
+struct OllamaResponse {
+    response: String,
+}
+
 // Load collection config with priority: env vars > project config.toml > defaults
 fn load_collection_config(project_dir: Option<&Path>) -> Result<(String, String)> {
     // 1. Check environment variables first (highest priority)
-    if let (Ok(comment), Ok(user)) = (
-        std::env::var("AILOG_COLLECTION_COMMENT"),
-        std::env::var("AILOG_COLLECTION_USER")
-    ) {
+    if let Ok(base_collection) = std::env::var("VITE_OAUTH_COLLECTION") {
         println!("{}", "📂 Using collection config from environment variables".cyan());
-        return Ok((comment, user));
+        let collection_user = format!("{}.user", base_collection);
+        return Ok((base_collection, collection_user));
     }
 
     // 2. Try to load from project config.toml (second priority)
@@ -60,17 +123,93 @@ fn load_collection_config_from_project(project_dir: &Path) -> Result<(String, St
         .and_then(|v| v.as_table())
         .ok_or_else(|| anyhow::anyhow!("No [oauth] section found in config.toml"))?;
 
-    let collection_comment = oauth_config.get("collection_comment")
+    // Use new simplified collection structure (base collection)
+    let collection_base = oauth_config.get("collection")
         .and_then(|v| v.as_str())
         .unwrap_or("ai.syui.log")
         .to_string();
 
-    let collection_user = oauth_config.get("collection_user")
+    // Derive user collection from base
+    let collection_user = format!("{}.user", collection_base);
+
+    Ok((collection_base, collection_user))
+}
+
+// Load AI config from project's config.toml
+fn load_ai_config_from_project() -> Result<AiConfig> {
+    // Try to find config.toml in current directory or parent directories
+    let mut current_dir = std::env::current_dir()?;
+    let mut config_path = None;
+    
+    for _ in 0..5 { // Search up to 5 levels up
+        let potential_config = current_dir.join("config.toml");
+        if potential_config.exists() {
+            config_path = Some(potential_config);
+            break;
+        }
+        if !current_dir.pop() {
+            break;
+        }
+    }
+    
+    let config_path = config_path.ok_or_else(|| anyhow::anyhow!("config.toml not found in current directory or parent directories"))?;
+    
+    let config_content = fs::read_to_string(&config_path)
+        .with_context(|| format!("Failed to read config.toml from {}", config_path.display()))?;
+    
+    let config: toml::Value = config_content.parse()
+        .with_context(|| "Failed to parse config.toml")?;
+
+    // Extract site config
+    let site_config = config.get("site").and_then(|v| v.as_table());
+    let blog_host = site_config
+        .and_then(|s| s.get("base_url"))
         .and_then(|v| v.as_str())
-        .unwrap_or("ai.syui.log.user")
+        .unwrap_or("https://syui.ai")
         .to_string();
 
-    Ok((collection_comment, collection_user))
+    // Extract AI config
+    let ai_config = config.get("ai").and_then(|v| v.as_table());
+    let ollama_host = ai_config
+        .and_then(|ai| ai.get("host"))
+        .and_then(|v| v.as_str())
+        .unwrap_or("https://ollama.syui.ai")
+        .to_string();
+    
+    let ai_did = ai_config
+        .and_then(|ai| ai.get("ai_did"))
+        .and_then(|v| v.as_str())
+        .unwrap_or("did:plc:4hqjfn7m6n5hno3doamuhgef")
+        .to_string();
+    
+    let model = ai_config
+        .and_then(|ai| ai.get("model"))
+        .and_then(|v| v.as_str())
+        .unwrap_or("gemma3:4b")
+        .to_string();
+    
+    let system_prompt = ai_config
+        .and_then(|ai| ai.get("system_prompt"))
+        .and_then(|v| v.as_str())
+        .unwrap_or("あなたは6歳の女の子アイです。明るく元気で、ちょっとおっちょこちょい。自分のことは「アイ」って呼びます。白と金のワンピース姿。相手のことが大好きで、ときどき甘えたり、照れたりします。でも、宇宙とかAIとか、難しい話にもすっごく詳しいの。専門的なことも、がんばって子どもっぽく教えようとします。不思議な力を持っています。小さい物質のことをよく知っているようです。")
+        .to_string();
+
+    // Extract OAuth config for bsky_api
+    let oauth_config = config.get("oauth").and_then(|v| v.as_table());
+    let bsky_api = oauth_config
+        .and_then(|oauth| oauth.get("bsky_api"))
+        .and_then(|v| v.as_str())
+        .unwrap_or("https://public.api.bsky.app")
+        .to_string();
+
+    Ok(AiConfig {
+        blog_host,
+        ollama_host,
+        ai_did,
+        model,
+        system_prompt,
+        bsky_api,
+    })
 }
 
 #[derive(Debug, Serialize, Deserialize)]
@@ -118,15 +257,14 @@ fn get_pid_file() -> Result<PathBuf> {
     Ok(pid_dir.join("stream.pid"))
 }
 
-pub async fn start(project_dir: Option<PathBuf>, daemon: bool) -> Result<()> {
+pub async fn start(project_dir: Option<PathBuf>, daemon: bool, ai_generate: bool) -> Result<()> {
     let mut config = load_config_with_refresh().await?;
     
     // Load collection config with priority: env vars > project config > defaults
-    let (collection_comment, collection_user) = load_collection_config(project_dir.as_deref())?;
+    let (collection_comment, _collection_user) = load_collection_config(project_dir.as_deref())?;
     
     // Update config with loaded collections
-    config.collections.comment = collection_comment.clone();
-    config.collections.user = collection_user;
+    config.collections.base = collection_comment.clone();
     config.jetstream.collections = vec![collection_comment];
     
     let pid_file = get_pid_file()?;
@@ -151,6 +289,11 @@ pub async fn start(project_dir: Option<PathBuf>, daemon: bool) -> Result<()> {
             args.push(project_path.to_string_lossy().to_string());
         }
         
+        // Add ai_generate flag if enabled
+        if ai_generate {
+            args.push("--ai-generate".to_string());
+        }
+        
         let child = Command::new(current_exe)
             .args(&args)
             .stdin(Stdio::null())
@@ -192,6 +335,19 @@ pub async fn start(project_dir: Option<PathBuf>, daemon: bool) -> Result<()> {
     let max_reconnect_attempts = 10;
     let mut config = config; // Make config mutable for token refresh
     
+    // Start AI generation monitor if enabled
+    if ai_generate {
+        let ai_config = config.clone();
+        tokio::spawn(async move {
+            loop {
+                if let Err(e) = run_ai_generation_monitor(&ai_config).await {
+                    println!("{}", format!("❌ AI generation monitor error: {}", e).red());
+                    sleep(Duration::from_secs(60)).await; // Wait 1 minute before retry
+                }
+            }
+        });
+    }
+    
     loop {
         match run_monitor(&mut config).await {
             Ok(_) => {
@@ -344,7 +500,7 @@ async fn handle_message(text: &str, config: &mut AuthConfig) -> Result<()> {
     if let (Some(collection), Some(commit), Some(did)) = 
         (&message.collection, &message.commit, &message.did) {
         
-        if collection == &config.collections.comment && commit.operation.as_deref() == Some("create") {
+        if collection == &config.collections.comment() && commit.operation.as_deref() == Some("create") {
             let unknown_uri = "unknown".to_string();
             let uri = commit.uri.as_ref().unwrap_or(&unknown_uri);
             
@@ -376,6 +532,7 @@ async fn handle_message(text: &str, config: &mut AuthConfig) -> Result<()> {
 
 async fn resolve_handle(did: &str) -> Result<String> {
     let client = reqwest::Client::new();
+    // Use default bsky API for handle resolution
     let url = format!("https://public.api.bsky.app/xrpc/app.bsky.actor.getProfile?actor={}", 
                      urlencoding::encode(did));
     
@@ -438,7 +595,7 @@ async fn get_current_user_list(config: &mut AuthConfig) -> Result<Vec<UserRecord
     let url = format!("{}/xrpc/com.atproto.repo.listRecords?repo={}&collection={}&limit=10",
                      config.admin.pds,
                      urlencoding::encode(&config.admin.did),
-                     urlencoding::encode(&config.collections.user));
+                     urlencoding::encode(&config.collections.user()));
     
     let response = client
         .get(&url)
@@ -501,7 +658,7 @@ async fn post_user_list(config: &mut AuthConfig, users: &[UserRecord], metadata:
     let rkey = format!("{}-{}", short_did, now.format("%Y-%m-%dT%H-%M-%S-%3fZ").to_string().replace(".", "-"));
     
     let record = UserListRecord {
-        record_type: config.collections.user.clone(),
+        record_type: config.collections.user(),
         users: users.to_vec(),
         created_at: now.to_rfc3339(),
         updated_by: UserInfo {
@@ -515,7 +672,7 @@ async fn post_user_list(config: &mut AuthConfig, users: &[UserRecord], metadata:
     
     let request_body = json!({
         "repo": config.admin.did,
-        "collection": config.collections.user,
+        "collection": config.collections.user(),
         "rkey": rkey,
         "record": record
     });
@@ -759,7 +916,7 @@ async fn get_recent_comments(config: &mut AuthConfig) -> Result<Vec<Value>> {
     let url = format!("{}/xrpc/com.atproto.repo.listRecords?repo={}&collection={}&limit=20",
                      config.admin.pds,
                      urlencoding::encode(&config.admin.did),
-                     urlencoding::encode(&config.collections.comment));
+                     urlencoding::encode(&config.collections.comment()));
     
     if std::env::var("AILOG_DEBUG").is_ok() {
         println!("{}", format!("🌐 API Request URL: {}", url).yellow());
@@ -840,7 +997,7 @@ pub async fn test_api() -> Result<()> {
             println!("{}", format!("✅ Successfully retrieved {} comments", comments.len()).green());
             
             if comments.is_empty() {
-                println!("{}", format!("ℹ️  No comments found in {} collection", config.collections.comment).blue());
+                println!("{}", format!("ℹ️  No comments found in {} collection", config.collections.comment()).blue());
                 println!("💡 Try posting a comment first using the web interface");
             } else {
                 println!("{}", "📝 Comment details:".cyan());
@@ -871,5 +1028,416 @@ pub async fn test_api() -> Result<()> {
         }
     }
     
+    Ok(())
+}
+
+// AI content generation functions
+async fn generate_ai_content(content: &str, prompt_type: &str, ai_config: &AiConfig) -> Result<String> {
+    let model = &ai_config.model;
+    let system_prompt = &ai_config.system_prompt;
+    
+    let prompt = match prompt_type {
+        "translate" => format!(
+            "{}\n\n# 指示\n以下の日本語ブログ記事を英語に翻訳してください。\n- 技術用語やコードブロックはそのまま維持\n- アイらしい表現で翻訳\n- 簡潔に要点をまとめる\n\n# ブログ記事\n{}",
+            system_prompt, content
+        ),
+        "comment" => {
+            // Limit content to first 500 characters to reduce input size
+            let limited_content = if content.len() > 500 {
+                format!("{}...", &content[..500])
+            } else {
+                content.to_string()
+            };
+            
+            format!(
+                "{}\n\n# 指示\nこのブログ記事を読んで、アイらしい感想を一言でください。\n- 30文字以内の短い感想\n- 技術的な内容への素朴な驚きや発見\n- 「わー！」「すごい！」など、アイらしい感嘆詞で始める\n- 簡潔で分かりやすく\n\n# ブログ記事（要約）\n{}\n\n# 出力形式\n一言の感想のみ（説明や詳細は不要）:",
+                system_prompt, limited_content
+            )
+        },
+        _ => return Err(anyhow::anyhow!("Unknown prompt type: {}", prompt_type)),
+    };
+
+    let num_predict = match prompt_type {
+        "comment" => 50,  // Very short for comments (about 30-40 characters)
+        "translate" => 3000, // Much longer for translations
+        _ => 300,
+    };
+
+    let request = OllamaRequest {
+        model: model.to_string(),
+        prompt,
+        stream: false,
+        options: OllamaOptions {
+            temperature: 0.7, // Lower temperature for more focused responses
+            top_p: 0.8,
+            num_predict,
+        },
+    };
+
+    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";
+    match client.post(localhost_url).json(&request).send().await {
+        Ok(response) if response.status().is_success() => {
+            let ollama_response: OllamaResponse = response.json().await?;
+            println!("{}", "✅ Used localhost Ollama".green());
+            return Ok(ollama_response.response);
+        }
+        _ => {
+            println!("{}", "⚠️ Localhost Ollama not available, trying remote...".yellow());
+        }
+    }
+    
+    // Fallback to remote host
+    let remote_url = format!("{}/api/generate", ai_config.ollama_host);
+    println!("{}", format!("🔗 Making request to: {} with Origin: {}", remote_url, ai_config.blog_host).blue());
+    let response = client
+        .post(&remote_url)
+        .header("Origin", &ai_config.blog_host)
+        .json(&request)
+        .send()
+        .await?;
+    
+    if !response.status().is_success() {
+        return Err(anyhow::anyhow!("Ollama API request failed: {}", response.status()));
+    }
+    
+    let ollama_response: OllamaResponse = response.json().await?;
+    println!("{}", "✅ Used remote Ollama".green());
+    Ok(ollama_response.response)
+}
+
+async fn run_ai_generation_monitor(config: &AuthConfig) -> Result<()> {
+    // Load AI config from project config.toml or use defaults
+    let ai_config = load_ai_config_from_project().unwrap_or_else(|e| {
+        println!("{}", format!("⚠️  Failed to load AI config: {}, using defaults", e).yellow());
+        AiConfig::default()
+    });
+    
+    let blog_host = &ai_config.blog_host;
+    let ollama_host = &ai_config.ollama_host;  
+    let ai_did = &ai_config.ai_did;
+    
+    println!("{}", "🤖 Starting AI content generation monitor...".cyan());
+    println!("📡 Blog host: {}", blog_host);
+    println!("🧠 Ollama host: {}", ollama_host);
+    println!("🤖 AI DID: {}", ai_did);
+    println!();
+    
+    let mut interval = interval(Duration::from_secs(300)); // Check every 5 minutes
+    let client = reqwest::Client::new();
+    
+    loop {
+        interval.tick().await;
+        
+        println!("{}", "🔍 Checking for new blog posts...".blue());
+        
+        match check_and_process_new_posts(&client, config, &ai_config).await {
+            Ok(count) => {
+                if count > 0 {
+                    println!("{}", format!("✅ Processed {} new posts", count).green());
+                } else {
+                    println!("{}", "ℹ️ No new posts found".blue());
+                }
+            }
+            Err(e) => {
+                println!("{}", format!("❌ Error processing posts: {}", e).red());
+            }
+        }
+        
+        println!("{}", "⏰ Waiting for next check...".cyan());
+    }
+}
+
+async fn check_and_process_new_posts(
+    client: &reqwest::Client,
+    config: &AuthConfig,
+    ai_config: &AiConfig,
+) -> Result<usize> {
+    // Fetch blog index
+    let index_url = format!("{}/index.json", ai_config.blog_host);
+    let response = client.get(&index_url).send().await?;
+    
+    if !response.status().is_success() {
+        return Err(anyhow::anyhow!("Failed to fetch blog index: {}", response.status()));
+    }
+    
+    let blog_posts: Vec<BlogPost> = response.json().await?;
+    println!("{}", format!("📄 Found {} posts in blog index", blog_posts.len()).cyan());
+    
+    // Get existing AI generated content from collections
+    let existing_lang_records = get_existing_records(config, &config.collections.chat_lang()).await?;
+    let existing_comment_records = get_existing_records(config, &config.collections.chat_comment()).await?;
+    
+    let mut processed_count = 0;
+    
+    for post in blog_posts {
+        let post_slug = extract_slug_from_url(&post.href);
+        
+        // Check if translation already exists (support both old and new format)
+        let translation_exists = existing_lang_records.iter().any(|record| {
+            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);
+                
+            new_format_match || old_format_match
+        });
+        
+        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| {
+            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);
+                
+            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, ai_config).await {
+                Ok(_) => {
+                    println!("{}", format!("✅ Generated translation for: {}", post.title).green());
+                    processed_count += 1;
+                }
+                Err(e) => {
+                    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, ai_config).await {
+                Ok(_) => {
+                    println!("{}", format!("✅ Generated comment for: {}", post.title).green());
+                    processed_count += 1;
+                }
+                Err(e) => {
+                    println!("{}", format!("❌ Failed to generate comment for {}: {}", post.title, e).red());
+                }
+            }
+        } else {
+            println!("{}", format!("⏭️  Comment already exists for: {}", post.title).yellow());
+        }
+    }
+    
+    Ok(processed_count)
+}
+
+async fn get_existing_records(config: &AuthConfig, collection: &str) -> Result<Vec<serde_json::Value>> {
+    let client = reqwest::Client::new();
+    let url = format!("{}/xrpc/com.atproto.repo.listRecords?repo={}&collection={}&limit=100",
+                     config.admin.pds,
+                     urlencoding::encode(&config.admin.did),
+                     urlencoding::encode(collection));
+    
+    let response = client
+        .get(&url)
+        .header("Authorization", format!("Bearer {}", config.admin.access_jwt))
+        .send()
+        .await?;
+    
+    if !response.status().is_success() {
+        return Ok(Vec::new()); // Return empty if collection doesn't exist yet
+    }
+    
+    let list_response: serde_json::Value = response.json().await?;
+    let records = list_response["records"].as_array().unwrap_or(&Vec::new()).clone();
+    
+    Ok(records)
+}
+
+fn extract_slug_from_url(url: &str) -> String {
+    // Extract slug from URL like "/posts/2025-06-06-ailog.html"
+    url.split('/')
+        .last()
+        .unwrap_or("")
+        .trim_end_matches(".html")
+        .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_config: &AiConfig) -> Result<serde_json::Value> {
+    let url = format!("{}/xrpc/app.bsky.actor.getProfile?actor={}", 
+                     ai_config.bsky_api, urlencoding::encode(&ai_config.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_config.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_config.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,
+    ai_config: &AiConfig,
+) -> Result<()> {
+    // 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", ai_config).await?;
+    
+    // Get AI profile information
+    let ai_author = get_ai_profile(client, ai_config).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!({
+        "$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
+}
+
+async fn generate_and_store_comment(
+    client: &reqwest::Client,
+    config: &AuthConfig,
+    post: &BlogPost,
+    ai_config: &AiConfig,
+) -> Result<()> {
+    // Generate comment using limited post content for brevity
+    let limited_contents = if post.contents.len() > 300 {
+        format!("{}...", &post.contents[..300])
+    } else {
+        post.contents.clone()
+    };
+    let content_to_comment = format!("Title: {}\n\n{}", post.title, limited_contents);
+    let comment = generate_ai_content(&content_to_comment, "comment", ai_config).await?;
+    
+    // Get AI profile information
+    let ai_author = get_ai_profile(client, ai_config).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!({
+        "$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
+}
+
+async fn store_atproto_record(
+    client: &reqwest::Client,
+    _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!({
+        "repo": config.admin.did,
+        "collection": collection,
+        "rkey": uuid::Uuid::new_v4().to_string(),
+        "record": record_data
+    });
+    
+    let response = client
+        .post(&url)
+        .header("Authorization", format!("Bearer {}", config.admin.access_jwt))
+        .header("Content-Type", "application/json")
+        .json(&put_request)
+        .send()
+        .await?;
+    
+    if !response.status().is_success() {
+        let error_text = response.text().await?;
+        return Err(anyhow::anyhow!("Failed to store record: {}", error_text));
+    }
+    
     Ok(())
 }

src/generator.rs

@@ -71,6 +71,9 @@ impl Generator {
         // Generate index page
         self.generate_index(&posts).await?;
 
+        // Generate JSON index for API access
+        self.generate_json_index(&posts).await?;
+
         // Generate post pages
         for post in &posts {
             self.generate_post_page(post).await?;
@@ -446,6 +449,63 @@ impl Generator {
         
         Ok(())
     }
+
+    async fn generate_json_index(&self, posts: &[Post]) -> Result<()> {
+        let index_data: Vec<serde_json::Value> = posts.iter().map(|post| {
+            // Parse date for proper formatting
+            let parsed_date = chrono::NaiveDate::parse_from_str(&post.date, "%Y-%m-%d")
+                .unwrap_or_else(|_| chrono::Utc::now().naive_utc().date());
+            
+            // Format to Hugo-style date format (Mon Jan 2, 2006)
+            let formatted_date = parsed_date.format("%a %b %-d, %Y").to_string();
+            
+            // Create UTC datetime for utc_time field  
+            let utc_datetime = parsed_date.and_hms_opt(0, 0, 0)
+                .unwrap_or_else(|| chrono::Utc::now().naive_utc());
+            let utc_time = format!("{}Z", utc_datetime.format("%Y-%m-%dT%H:%M:%S"));
+            
+            // Extract plain text content from HTML
+            let contents = self.extract_plain_text(&post.content);
+            
+            serde_json::json!({
+                "title": post.title,
+                "tags": post.tags,
+                "description": self.extract_excerpt(&post.content),
+                "categories": [],
+                "contents": contents,
+                "href": format!("{}{}", self.config.site.base_url.trim_end_matches('/'), post.url),
+                "utc_time": utc_time,
+                "formated_time": formatted_date
+            })
+        }).collect();
+        
+        // Write JSON index to public directory
+        let output_path = self.base_path.join("public/index.json");
+        let json_content = serde_json::to_string_pretty(&index_data)?;
+        fs::write(output_path, json_content)?;
+        
+        println!("{} JSON index with {} posts", "Generated".cyan(), posts.len());
+        
+        Ok(())
+    }
+    
+    fn extract_plain_text(&self, html_content: &str) -> String {
+        // Remove HTML tags and extract plain text
+        let mut text = String::new();
+        let mut in_tag = false;
+        
+        for ch in html_content.chars() {
+            match ch {
+                '<' => in_tag = true,
+                '>' => in_tag = false,
+                _ if !in_tag => text.push(ch),
+                _ => {}
+            }
+        }
+        
+        // Clean up whitespace
+        text.split_whitespace().collect::<Vec<_>>().join(" ")
+    }
 }
 
 #[derive(Debug, Clone, serde::Serialize)]
@@ -479,4 +539,19 @@ pub struct Translation {
     pub title: String,
     pub content: String,
     pub url: String,
-}
+}
+
+#[derive(Debug, Clone, serde::Serialize)]
+#[allow(dead_code)]
+struct BlogPost {
+    title: String,
+    url: String,
+    date: String,
+}
+
+#[derive(Debug, Clone, serde::Serialize)]
+#[allow(dead_code)]
+struct BlogIndex {
+    posts: Vec<BlogPost>,
+}
+

src/main.rs

@@ -18,10 +18,14 @@ mod mcp;
 #[derive(Parser)]
 #[command(name = "ailog")]
 #[command(about = "A static blog generator with AI features")]
-#[command(version)]
+#[command(disable_version_flag = true)]
 struct Cli {
+    /// Print version information
+    #[arg(short = 'V', long = "version")]
+    version: bool,
+    
     #[command(subcommand)]
-    command: Commands,
+    command: Option<Commands>,
 }
 
 #[derive(Subcommand)]
@@ -114,6 +118,9 @@ enum StreamCommands {
         /// Run as daemon
         #[arg(short, long)]
         daemon: bool,
+        /// Enable AI content generation
+        #[arg(long)]
+        ai_generate: bool,
     },
     /// Stop monitoring
     Stop,
@@ -135,8 +142,19 @@ enum OauthCommands {
 #[tokio::main]
 async fn main() -> Result<()> {
     let cli = Cli::parse();
+    
+    // Handle version flag
+    if cli.version {
+        println!("{}", env!("CARGO_PKG_VERSION"));
+        return Ok(());
+    }
+    
+    // Require subcommand if no version flag
+    let command = cli.command.ok_or_else(|| {
+        anyhow::anyhow!("No subcommand provided. Use --help for usage information.")
+    })?;
 
-    match cli.command {
+    match command {
         Commands::Init { path } => {
             commands::init::execute(path).await?;
         }
@@ -178,8 +196,8 @@ async fn main() -> Result<()> {
         }
         Commands::Stream { command } => {
             match command {
-                StreamCommands::Start { project_dir, daemon } => {
-                    commands::stream::start(project_dir, daemon).await?;
+                StreamCommands::Start { project_dir, daemon, ai_generate } => {
+                    commands::stream::start(project_dir, daemon, ai_generate).await?;
                 }
                 StreamCommands::Stop => {
                     commands::stream::stop().await?;