Update from GitHub Actions

components.d.ts

@@ -11,6 +11,7 @@ declare module 'vue' {
     MonacoEditor: typeof import('./src/components/MonacoEditor.vue')['default']
     RouterLink: typeof import('vue-router')['RouterLink']
     RouterView: typeof import('vue-router')['RouterView']
+    TAlert: typeof import('tdesign-vue-next')['Alert']
     TAside: typeof import('tdesign-vue-next')['Aside']
     TButton: typeof import('tdesign-vue-next')['Button']
     TCard: typeof import('tdesign-vue-next')['Card']
@@ -36,6 +37,7 @@ declare module 'vue' {
     TMenuItem: typeof import('tdesign-vue-next')['MenuItem']
     TPagination: typeof import('tdesign-vue-next')['Pagination']
     TTable: typeof import('tdesign-vue-next')['Table']
+    TTag: typeof import('tdesign-vue-next')['Tag']
     TTbody: typeof import('tdesign-vue-next')['Tbody']
     TTd: typeof import('tdesign-vue-next')['Td']
     TTextarea: typeof import('tdesign-vue-next')['Textarea']

functions/api/debug/cleanup.ts

@@ -0,0 +1,43 @@
+import { CORS_HEADERS as corsHeaders } from '../../utils/cors.js';
+import { cleanupOldDebugFiles } from '../../utils/debugStorage.js';
+
+export async function onRequestPOST(context: any) {
+    const { request } = context;
+    const url = new URL(request.url);
+    const daysToKeep = parseInt(url.searchParams.get('days') || '7');
+
+    try {
+        const deletedCount = await cleanupOldDebugFiles(daysToKeep);
+
+        return new Response(JSON.stringify({
+            success: true,
+            message: `已清理 ${deletedCount} 条超过 ${daysToKeep} 天的调试数据`,
+            deletedCount
+        }), {
+            headers: {
+                'Content-Type': 'application/json',
+                ...corsHeaders
+            }
+        });
+
+    } catch (error) {
+        console.error('Error cleaning up debug data:', error);
+        return new Response(JSON.stringify({
+            error: 'Failed to cleanup debug data',
+            details: error instanceof Error ? error.message : String(error)
+        }), {
+            status: 500,
+            headers: {
+                'Content-Type': 'application/json',
+                ...corsHeaders
+            }
+        });
+    }
+}
+
+export async function onRequestOPTIONS() {
+    return new Response(null, {
+        status: 200,
+        headers: corsHeaders
+    });
+}

functions/api/debug/list.ts

@@ -0,0 +1,47 @@
+import { CORS_HEADERS as corsHeaders } from '../../utils/cors.js';
+import { getAllDebugInfo } from '../../utils/debugStorage.js';
+
+export async function onRequestGET(context: any) {
+    const { request } = context;
+    const url = new URL(request.url);
+    const limit = parseInt(url.searchParams.get('limit') || '50');
+
+    try {
+        // 获取所有调试信息
+        const debugItems = await getAllDebugInfo();
+
+        // 限制返回数量
+        const limitedItems = debugItems.slice(0, limit);
+
+        return new Response(JSON.stringify({
+            success: true,
+            data: limitedItems,
+            total: debugItems.length
+        }), {
+            headers: {
+                'Content-Type': 'application/json',
+                ...corsHeaders
+            }
+        });
+
+    } catch (error) {
+        console.error('Error retrieving debug list:', error);
+        return new Response(JSON.stringify({
+            error: 'Failed to retrieve debug list',
+            details: error instanceof Error ? error.message : String(error)
+        }), {
+            status: 500,
+            headers: {
+                'Content-Type': 'application/json',
+                ...corsHeaders
+            }
+        });
+    }
+}
+
+export async function onRequestOPTIONS() {
+    return new Response(null, {
+        status: 200,
+        headers: corsHeaders
+    });
+}

functions/api/debug/screenshot.ts

@@ -0,0 +1,61 @@
+import { CORS_HEADERS as corsHeaders } from '../../utils/cors.js';
+import { getScreenshot } from '../../utils/debugStorage.js';
+
+export async function onRequestGET(context: any) {
+    const { request } = context;
+    const url = new URL(request.url);
+    const debugId = url.searchParams.get('id');
+
+    if (!debugId) {
+        return new Response(JSON.stringify({ error: 'Missing debug ID' }), {
+            status: 400,
+            headers: {
+                'Content-Type': 'application/json',
+                ...corsHeaders
+            }
+        });
+    }
+
+    try {
+        // 获取截图数据
+        const screenshotBuffer = await getScreenshot(debugId);
+
+        if (!screenshotBuffer) {
+            return new Response(JSON.stringify({ error: 'Screenshot not found' }), {
+                status: 404,
+                headers: {
+                    'Content-Type': 'application/json',
+                    ...corsHeaders
+                }
+            });
+        }
+
+        return new Response(screenshotBuffer, {
+            headers: {
+                'Content-Type': 'image/png',
+                'Cache-Control': 'public, max-age=3600',
+                ...corsHeaders
+            }
+        });
+
+    } catch (error) {
+        console.error('Error retrieving screenshot:', error);
+        return new Response(JSON.stringify({
+            error: 'Failed to retrieve screenshot',
+            details: error instanceof Error ? error.message : String(error)
+        }), {
+            status: 500,
+            headers: {
+                'Content-Type': 'application/json',
+                ...corsHeaders
+            }
+        });
+    }
+}
+
+export async function onRequestOPTIONS() {
+    return new Response(null, {
+        status: 200,
+        headers: corsHeaders
+    });
+}

functions/types.d.ts

@@ -3,6 +3,7 @@ interface KVNamespace {
   put: (key: string, value: string, options?: { expiration?: number, expirationTtl?: number, metadata?: object }) => Promise<void>;
   get: (key: string) => Promise<string | null>;
   delete: (key: string) => Promise<void>;
+  list: (options?: { prefix?: string }) => Promise<{ keys: { name: string }[] }>
 }
 
 interface Env {

functions/utils/authService.ts

@@ -1,6 +1,7 @@
 import { Page } from 'playwright';
 import BrowserManager from './browser.js';
 import { getVerificationCode } from './emailVerification.js';
+import { saveScreenshot, saveDebugInfo, saveErrorInfo } from './debugStorage.js';
 
 interface Account {
     email: string;
@@ -39,18 +40,61 @@ export class AuthService {
         const redirectUri = this.env.AUTH_REDIRECT_URI;
         let browser;
         let context;
+        let page;
+        const debugId = `auth_${account.email}_${Date.now()}`;
 
         try {
             browser = await BrowserManager.getInstance();
             context = await browser.newContext();
-            const page = await context.newPage();
+            page = await context.newPage();
 
             const authUrl = this.buildAuthUrl(clientId, redirectUri, account.email);
             await this.handleLoginProcess(page, account, authUrl);
             await this.handleMultiFactorAuth(page, account);
             await this.confirmLogin(page, account);
             await this.handleConsent(page, redirectUri);
+        } catch (error) {
+            // 记录错误信息
+            const errorInfo = {
+                email: account.email,
+                error: error instanceof Error ? error.message : String(error),
+                timestamp: new Date().toISOString(),
+                debugId: debugId
+            };
+
+            try {
+                await saveErrorInfo(debugId, errorInfo);
+            } catch (saveError) {
+                console.error('Failed to save error info:', saveError);
+            }
+            throw error;
         } finally {
+            // 截取最后的页面截图
+            if (page) {
+                try {
+                    const screenshot = await page.screenshot({
+                        fullPage: true,
+                        type: 'png'
+                    });
+
+                    const screenshotInfo = {
+                        email: account.email,
+                        timestamp: new Date().toISOString(),
+                        debugId: debugId,
+                        url: page.url(),
+                        title: await page.title().catch(() => 'Unknown')
+                    };
+
+                    // 保存截图和调试信息到本地文件
+                    await saveScreenshot(debugId, screenshot);
+                    await saveDebugInfo(debugId, screenshotInfo);
+
+                    console.log(`Screenshot saved for debug: ${debugId}`);
+                } catch (screenshotError) {
+                    console.error('Failed to take screenshot:', screenshotError);
+                }
+            }
+
             if (context) await context.close();
         }
     }
@@ -67,6 +111,11 @@ export class AuthService {
     }
 
     public async loginMail(email: string): Promise<{ success: boolean; error?: string }> {
+        let browser;
+        let context;
+        let page;
+        const debugId = `login_${email}_${Date.now()}`;
+
         try {
             const accountsStr = await this.env.KV.get("accounts");
             const accounts: Account[] = accountsStr ? JSON.parse(accountsStr) : [];
@@ -75,19 +124,62 @@ export class AuthService {
             if (!account) {
                 throw new Error("Account not found");
             }
-            const browser = await BrowserManager.getInstance();
-            const context = await browser.newContext();
-            const page = await context.newPage();
+
+            browser = await BrowserManager.getInstance();
+            context = await browser.newContext();
+            page = await context.newPage();
             await this.handleLoginProcess(page, account, "https://outlook.live.com/mail/0/?prompt=select_account");
             await this.handleMultiFactorAuth(page, account);
             await this.confirmLogin(page, account);
             await page.waitForTimeout(5000);
             return { success: true };
         } catch (error: any) {
+            // 记录错误信息
+            const errorInfo = {
+                email: email,
+                error: error instanceof Error ? error.message : String(error),
+                timestamp: new Date().toISOString(),
+                debugId: debugId
+            };
+
+            try {
+                await saveErrorInfo(debugId, errorInfo);
+            } catch (saveError) {
+                console.error('Failed to save error info:', saveError);
+            }
+
             return {
                 success: false,
                 error: error.message
             };
+        } finally {
+            // 截取最后的页面截图
+            if (page) {
+                try {
+                    const screenshot = await page.screenshot({
+                        fullPage: true,
+                        type: 'png'
+                    });
+
+                    const screenshotInfo = {
+                        email: email,
+                        timestamp: new Date().toISOString(),
+                        debugId: debugId,
+                        url: page.url(),
+                        title: await page.title().catch(() => 'Unknown')
+                    };
+
+                    // 保存截图和调试信息到本地文件
+                    await saveScreenshot(debugId, screenshot);
+                    await saveDebugInfo(debugId, screenshotInfo);
+
+                    console.log(`Screenshot saved for debug: ${debugId}`);
+                } catch (screenshotError) {
+                    console.error('Failed to take screenshot:', screenshotError);
+                }
+            }
+
+            if (context) await context.close();
         }
     }
 
@@ -122,11 +214,17 @@ export class AuthService {
             console.log(account.email, `没有新版切换到密码登录，继续执行: ${error}`);
         }
 
-
-        await page.waitForURL("https://login.live.com/**");
-        await page.fill('input[type="password"]', account.password);
-        await page.fill('input[type="password"]', account.password);
-        await page.click('button[type="submit"]');
+        try {
+            await page.waitForURL("https://login.live.com/**", { timeout: 30000 });
+            // 填写密码 - 双重填写确保成功
+            await page.fill('input[type="password"]', account.password);
+            await page.waitForTimeout(500); // 等待页面稳定
+            await page.fill('input[type="password"]', account.password);
+            await page.click('button[type="submit"]');
+            await page.waitForTimeout(2000); // 等待提交处理
+        } catch (error) {
+            console.log(account.email, `填写密码失败: ${error}`);
+        }
 
 
         const proofEmail = account.proofEmail;
@@ -288,13 +386,13 @@ export class AuthService {
             }, { timeout: 3000 });
             await page.click('button[type="submit"]#acceptButton', { timeout: 3000 });
         } catch (error) {
-            console.log(account.email, `无其他登录确认，继续执行: ${error}`);
+            console.log(account.email, `无旧版的登录确认，继续执行: ${error}`);
         }
     }
 
     private async handleConsent(page: Page, redirectUri: string) {
         try {
-            await page.waitForURL("https://account.live.com/Consent/**", { timeout: 10000 });
+            await page.waitForURL("https://account.live.com/Consent/**", { timeout: 20000 });
             await page.click('button[type="submit"][data-testid="appConsentPrimaryButton"]');
         } catch (error) {
             console.log("Consent page not found or timeout, skipping...");

functions/utils/debugStorage.ts

@@ -0,0 +1,135 @@
+import fs from 'fs/promises';
+import path from 'path';
+
+const DEBUG_DIR = 'debug';
+
+// 确保调试目录存在
+async function ensureDebugDir() {
+    try {
+        await fs.access(DEBUG_DIR);
+    } catch {
+        await fs.mkdir(DEBUG_DIR, { recursive: true });
+    }
+}
+
+// 保存截图
+export async function saveScreenshot(debugId: string, screenshot: Buffer): Promise<void> {
+    await ensureDebugDir();
+    const screenshotPath = path.join(DEBUG_DIR, `${debugId}.png`);
+    await fs.writeFile(screenshotPath, screenshot);
+}
+
+// 保存调试信息
+export async function saveDebugInfo(debugId: string, info: any): Promise<void> {
+    await ensureDebugDir();
+    const infoPath = path.join(DEBUG_DIR, `${debugId}.json`);
+    await fs.writeFile(infoPath, JSON.stringify(info, null, 2));
+}
+
+// 保存错误信息
+export async function saveErrorInfo(debugId: string, error: any): Promise<void> {
+    await ensureDebugDir();
+    const errorPath = path.join(DEBUG_DIR, `${debugId}_error.json`);
+    await fs.writeFile(errorPath, JSON.stringify(error, null, 2));
+}
+
+// 获取所有调试信息
+export async function getAllDebugInfo(): Promise<any[]> {
+    try {
+        await ensureDebugDir();
+        const files = await fs.readdir(DEBUG_DIR);
+        const debugItems = [];
+
+        // 获取所有 .json 文件（排除 _error.json）
+        const infoFiles = files.filter(file => file.endsWith('.json') && !file.endsWith('_error.json'));
+
+        for (const file of infoFiles) {
+            try {
+                const debugId = file.replace('.json', '');
+                const infoPath = path.join(DEBUG_DIR, file);
+                const errorPath = path.join(DEBUG_DIR, `${debugId}_error.json`);
+                const screenshotPath = path.join(DEBUG_DIR, `${debugId}.png`);
+
+                // 读取基本信息
+                const infoData = await fs.readFile(infoPath, 'utf-8');
+                const info = JSON.parse(infoData);
+
+                // 检查是否有错误信息
+                let errorInfo = null;
+                try {
+                    const errorData = await fs.readFile(errorPath, 'utf-8');
+                    errorInfo = JSON.parse(errorData);
+                } catch {
+                    // 没有错误文件，忽略
+                }
+
+                // 检查是否有截图
+                let hasScreenshot = false;
+                try {
+                    await fs.access(screenshotPath);
+                    hasScreenshot = true;
+                } catch {
+                    // 没有截图文件，忽略
+                }
+
+                debugItems.push({
+                    debugId,
+                    ...info,
+                    hasError: !!errorInfo,
+                    errorMessage: errorInfo?.error || null,
+                    hasScreenshot,
+                    screenshotUrl: hasScreenshot ? `/api/debug/screenshot?id=${debugId}` : null
+                });
+            } catch (error) {
+                console.error(`Error reading debug file ${file}:`, error);
+            }
+        }
+
+        // 按时间戳排序（最新的在前）
+        debugItems.sort((a, b) => new Date(b.timestamp).getTime() - new Date(a.timestamp).getTime());
+
+        return debugItems;
+    } catch (error) {
+        console.error('Error reading debug directory:', error);
+        return [];
+    }
+}
+
+// 获取截图
+export async function getScreenshot(debugId: string): Promise<Buffer | null> {
+    try {
+        const screenshotPath = path.join(DEBUG_DIR, `${debugId}.png`);
+        return await fs.readFile(screenshotPath);
+    } catch {
+        return null;
+    }
+}
+
+// 清理旧的调试文件
+export async function cleanupOldDebugFiles(daysToKeep: number = 7): Promise<number> {
+    try {
+        await ensureDebugDir();
+        const files = await fs.readdir(DEBUG_DIR);
+        const cutoffTime = Date.now() - (daysToKeep * 24 * 60 * 60 * 1000);
+        let deletedCount = 0;
+
+        for (const file of files) {
+            try {
+                const filePath = path.join(DEBUG_DIR, file);
+                const stats = await fs.stat(filePath);
+                
+                if (stats.mtime.getTime() < cutoffTime) {
+                    await fs.unlink(filePath);
+                    deletedCount++;
+                }
+            } catch (error) {
+                console.error(`Error processing file ${file}:`, error);
+            }
+        }
+
+        return deletedCount;
+    } catch (error) {
+        console.error('Error cleaning up debug files:', error);
+        return 0;
+    }
+}

index.ts

@@ -30,6 +30,9 @@ import { onRequest as handleMailSend } from './functions/api/mail/send.js'
 import { onRequest as handleBatch } from './functions/api/mail/batch.js'
 import { onRequest as handleMailStatus } from './functions/api/mail/status.js'
 import { onRequest as handleMailActivate } from './functions/api/mail/activate.js'
+import { onRequestGET as handleDebugList } from './functions/api/debug/list.js'
+import { onRequestGET as handleDebugScreenshot } from './functions/api/debug/screenshot.js'
+import { onRequestPOST as handleDebugCleanup } from './functions/api/debug/cleanup.js'
 dotenv.config({ path: ['.env', '.env.local'], override: true });
 const isDev = process.env.NODE_ENV === 'development'
 
@@ -64,6 +67,13 @@ const kv: KVNamespace = {
     },
     delete: async (key: string) => {
         await storage.removeItem(key);
+    },
+    list: async (options?: { prefix?: string }) => {
+        const keys = await storage.getKeys(options?.prefix);
+        console.log(options?.prefix,keys)
+        return {
+            keys: keys.map(key => ({ name: key }))
+        };
     }
 };
 
@@ -169,7 +179,18 @@ app.all('/api/*', async (c) => {
             case '/api/mail/activate':
                 response = await handleMailActivate(context);
                 break;
+            case '/api/debug/list':
+                response = await handleDebugList(context);
+                break;
+            case '/api/debug/cleanup':
+                response = await handleDebugCleanup(context);
+                break;
             default:
+                // 处理带参数的路由
+                if (path.startsWith('/api/debug/screenshot')) {
+                    response = await handleDebugScreenshot(context);
+                    break;
+                }
                 return c.json({ error: 'Route not found' }, 404);
         }
         return response;

src/App.vue

@@ -24,6 +24,11 @@ const menu = [
     name: '设置',
     path: '/setting',
     icon: 'setting-1'
+  },
+  {
+    name: '调试',
+    path: '/debug',
+    icon: 'bug'
   }
 ];
 

src/router/index.ts

@@ -33,6 +33,12 @@ const router = createRouter({
             component: () => import('../views/AccountView.vue'),
             meta: { requiresAuth: true }
         },
+        {
+            path: '/debug',
+            name: 'Debug',
+            component: () => import('../views/DebugView.vue'),
+            meta: { requiresAuth: true }
+        },
     ],
 })
 // 添加路由守卫

src/views/DebugView.vue

@@ -0,0 +1,161 @@
+<template>
+  <div class="debug-view p-6">
+    <div class="mb-4">
+      <t-button theme="primary" @click="loadDebugData" :loading="loading">
+        <template #icon>
+          <t-icon name="refresh" />
+        </template>
+        刷新数据
+      </t-button>
+    </div>
+
+    <t-loading :loading="loading" text="正在加载调试数据...">
+      <div v-if="error" class="mb-4">
+        <t-alert theme="error" :message="error" />
+      </div>
+
+      <div v-if="!loading && debugList.length === 0" class="text-center py-12">
+        <t-icon name="inbox" size="48px" class="text-gray-400 mb-4" />
+        <p class="text-gray-500">暂无调试数据</p>
+      </div>
+
+      <div v-else class="space-y-4">
+        <t-card
+          v-for="item in debugList"
+          :key="item.debugId"
+          :class="{ 'border-red-200': item.hasError }"
+          class="cursor-pointer hover:shadow-md transition-shadow"
+          @click="toggleDebugContent(item.debugId)"
+        >
+          <template #header>
+            <div class="flex justify-between items-center">
+              <div class="flex items-center space-x-3">
+                <strong class="text-lg">{{ item.email }}</strong>
+                <t-tag
+                  :theme="item.hasError ? 'danger' : 'success'"
+                  variant="light"
+                >
+                  {{ item.hasError ? '失败' : '成功' }}
+                </t-tag>
+                <span class="text-gray-500 text-sm">
+                  {{ formatTime(item.timestamp) }}
+                </span>
+              </div>
+              <t-icon
+                :name="expandedItems.has(item.debugId) ? 'chevron-up' : 'chevron-down'"
+                class="text-gray-400"
+              />
+            </div>
+          </template>
+
+          <div v-if="expandedItems.has(item.debugId)" class="space-y-4">
+            <div v-if="item.hasError" class="mb-4">
+              <t-alert theme="error" :message="`错误信息: ${item.errorMessage}`" />
+            </div>
+
+            <div class="grid grid-cols-1 md:grid-cols-2 gap-4 text-sm">
+              <div>
+                <span class="font-medium text-gray-700">调试ID:</span>
+                <span class="ml-2 text-gray-600 font-mono">{{ item.debugId }}</span>
+              </div>
+              <div>
+                <span class="font-medium text-gray-700">邮箱:</span>
+                <span class="ml-2 text-gray-600">{{ item.email }}</span>
+              </div>
+              <div>
+                <span class="font-medium text-gray-700">时间:</span>
+                <span class="ml-2 text-gray-600">{{ formatTime(item.timestamp) }}</span>
+              </div>
+              <div>
+                <span class="font-medium text-gray-700">页面标题:</span>
+                <span class="ml-2 text-gray-600">{{ item.title }}</span>
+              </div>
+              <div class="md:col-span-2">
+                <span class="font-medium text-gray-700">页面URL:</span>
+                <span class="ml-2 text-gray-600 break-all">{{ item.url }}</span>
+              </div>
+            </div>
+
+            <div>
+              <h4 class="font-medium text-gray-700 mb-2">页面截图:</h4>
+              <div class="border rounded-lg overflow-hidden bg-gray-50">
+                <img
+                  :src="item.screenshotUrl"
+                  :alt="`${item.email} 的页面截图`"
+                  class="w-full h-auto max-h-96 object-contain"
+                  loading="lazy"
+                  @error="handleImageError"
+                />
+              </div>
+            </div>
+          </div>
+        </t-card>
+      </div>
+    </t-loading>
+  </div>
+</template>
+
+<script setup lang="ts">
+import { ref, onMounted } from 'vue'
+
+interface DebugItem {
+  debugId: string
+  email: string
+  timestamp: string
+  url: string
+  title: string
+  hasError: boolean
+  errorMessage?: string
+  screenshotUrl: string
+}
+
+const loading = ref(false)
+const error = ref('')
+const debugList = ref<DebugItem[]>([])
+const expandedItems = ref(new Set<string>())
+
+const loadDebugData = async () => {
+  loading.value = true
+  error.value = ''
+
+  try {
+    const response = await fetch('/api/debug/list')
+    const result = await response.json()
+
+    if (result.success) {
+      debugList.value = result.data
+    } else {
+      error.value = `加载失败: ${result.error}`
+    }
+  } catch (err) {
+    error.value = `网络错误: ${err instanceof Error ? err.message : String(err)}`
+  } finally {
+    loading.value = false
+  }
+}
+
+const toggleDebugContent = (debugId: string) => {
+  if (expandedItems.value.has(debugId)) {
+    expandedItems.value.delete(debugId)
+  } else {
+    expandedItems.value.add(debugId)
+  }
+}
+
+const formatTime = (timestamp: string) => {
+  return new Date(timestamp).toLocaleString('zh-CN')
+}
+
+const handleImageError = (event: Event) => {
+  const img = event.target as HTMLImageElement
+  img.style.display = 'none'
+  const parent = img.parentElement
+  if (parent) {
+    parent.innerHTML = '<div class="text-center py-8 text-gray-500">截图加载失败</div>'
+  }
+}
+
+onMounted(() => {
+  loadDebugData()
+})
+</script>