feat(photo): enhance photo asset normalization and logging

- Updated photo asset service to correctly use regex in normalization functions, ensuring proper path formatting.
- Introduced builder log relay functionality in the data sync controller to improve logging during synchronization tasks.
- Added error handling improvements across various components, utilizing a centralized error message function for consistency.
- Enhanced photo page actions and library action bar with new select all functionality for better user experience.

Signed-off-by: Innei <tukon479@gmail.com>

Author: Innei

be/apps/core/src/modules/content/photo/assets/photo-asset.service.ts

@@ -814,7 +814,7 @@ export class PhotoAssetService {
       return null
     }
 
-    const normalized = trimmed.replaceAll('\\', '/').replaceAll(/^\/+|\/+$/, '')
+    const normalized = trimmed.replaceAll('\\', '/').replaceAll(/^\/+|\/+$/g, '')
     return normalized.length > 0 ? normalized : null
   }
 
@@ -824,7 +824,7 @@ export class PhotoAssetService {
       if (!segment) {
         continue
       }
-      filtered.push(segment.replaceAll(/^\/+|\/+$/, ''))
+      filtered.push(segment.replaceAll(/^\/+|\/+$/g, ''))
     }
 
     if (filtered.length === 0) {

be/apps/core/src/modules/infrastructure/data-sync/builder-log-relay.ts

@@ -0,0 +1,82 @@
+import { format as utilFormat } from 'node:util'
+
+import type { LogMessage } from '@afilmory/builder/logger/index.js'
+import { setLogListener } from '@afilmory/builder/logger/index.js'
+
+import type { DataSyncLogLevel, DataSyncProgressEmitter } from './data-sync.types'
+
+const LEVEL_MAP: Record<string, DataSyncLogLevel> = {
+  log: 'info',
+  info: 'info',
+  start: 'info',
+  success: 'success',
+  warn: 'warn',
+  error: 'error',
+  fatal: 'error',
+  debug: 'info',
+  trace: 'info',
+}
+
+export async function runWithBuilderLogRelay<T>(
+  emitter: DataSyncProgressEmitter | undefined,
+  task: () => Promise<T>,
+): Promise<T> {
+  if (!emitter) {
+    return await task()
+  }
+
+  const listener = (message: LogMessage): void => {
+    forwardBuilderLog(emitter, message)
+  }
+
+  setLogListener(listener, { forwardToConsole: true })
+
+  try {
+    return await task()
+  } finally {
+    setLogListener(null, { forwardToConsole: true })
+  }
+}
+
+function forwardBuilderLog(emitter: DataSyncProgressEmitter, message: LogMessage): void {
+  const formatted = formatBuilderMessage(message)
+  if (!formatted) {
+    return
+  }
+
+  const level = LEVEL_MAP[message.level] ?? 'info'
+
+  try {
+    void emitter({
+      type: 'log',
+      payload: {
+        level,
+        message: formatted,
+        timestamp: message.timestamp.toISOString(),
+        stage: null,
+        storageKey: undefined,
+        details: {
+          source: 'builder',
+          tag: message.tag,
+        },
+      },
+    })
+  } catch {
+    // Relay should never break builder logging
+  }
+}
+
+function formatBuilderMessage(message: LogMessage): string {
+  const prefix = message.tag ? `[${message.tag}] ` : ''
+
+  if (!message.args?.length) {
+    return prefix.trim()
+  }
+
+  try {
+    return `${prefix}${utilFormat(...message.args)}`.trim()
+  } catch {
+    const fallback = message.args[0] ? String(message.args[0]) : ''
+    return `${prefix}${fallback}`.trim()
+  }
+}

be/apps/core/src/modules/infrastructure/data-sync/data-sync.controller.ts

@@ -3,6 +3,7 @@ import { Body, ContextParam, Controller, createLogger, Get, Param, Post } from '
 import { Roles } from 'core/guards/roles.decorator'
 import type { Context } from 'hono'
 
+import { runWithBuilderLogRelay } from './builder-log-relay'
 import type { ResolveConflictInput, RunDataSyncInput } from './data-sync.dto'
 import { ResolveConflictDto, RunDataSyncDto } from './data-sync.dto'
 import { DataSyncService } from './data-sync.service'
@@ -97,13 +98,15 @@ export class DataSyncController {
 
         ;(async () => {
           try {
-            await this.dataSyncService.runSync(
-              {
-                builderConfig: payload.builderConfig as BuilderConfig | undefined,
-                storageConfig: payload.storageConfig as StorageConfig | undefined,
-                dryRun: payload.dryRun ?? false,
-              },
-              progressHandler,
+            await runWithBuilderLogRelay(progressHandler, () =>
+              this.dataSyncService.runSync(
+                {
+                  builderConfig: payload.builderConfig as BuilderConfig | undefined,
+                  storageConfig: payload.storageConfig as StorageConfig | undefined,
+                  dryRun: payload.dryRun ?? false,
+                },
+                progressHandler,
+              ),
             )
           } catch (error) {
             const message = error instanceof Error ? error.message : 'Unknown error'

be/apps/dashboard/src/components/navigation/PageTabs.tsx

@@ -22,7 +22,7 @@ export function PageTabs({ items, activeId, onSelect, className }: PageTabsProps
   const renderTabContent = (selected: boolean, label: ReactNode) => (
     <span
       className={clsxm(
-        'inline-flex items-center rounded-lg px-3 py-1.5 text-xs font-medium transition-all',
+        'inline-flex items-center shape-squircle px-3 py-1.5 text-xs font-medium transition-all',
         selected ? 'bg-accent/15 text-accent' : 'bg-fill/10 text-text-secondary hover:bg-fill/20 hover:text-text',
       )}
     >
@@ -59,7 +59,7 @@ export function PageTabs({ items, activeId, onSelect, className }: PageTabsProps
             type="button"
             onClick={handleClick}
             disabled={item.disabled}
-            className="focus-visible:outline-none"
+            className="focus-visible:outline-none shape-squircle"
           >
             {renderTabContent(selected, item.label)}
           </button>

be/apps/dashboard/src/lib/errors.ts

@@ -0,0 +1,72 @@
+import { FetchError } from 'ofetch'
+
+type FetchErrorWithPayload = FetchError<unknown> & {
+  response?: {
+    _data?: unknown
+  }
+}
+
+function toMessage(value: unknown): string | null {
+  if (value == null) {
+    return null
+  }
+
+  if (typeof value === 'string') {
+    const trimmed = value.trim()
+    return trimmed.length > 0 ? trimmed : null
+  }
+
+  if (typeof value === 'number' && Number.isFinite(value)) {
+    return String(value)
+  }
+
+  if (value instanceof Error) {
+    return toMessage(value.message)
+  }
+
+  if (Array.isArray(value)) {
+    for (const entry of value) {
+      const message = toMessage(entry)
+      if (message) {
+        return message
+      }
+    }
+    return null
+  }
+
+  if (typeof value === 'object') {
+    const record = value as Record<string, unknown>
+    const candidates: unknown[] = [record.message, record.error, record.detail, record.description, record.reason]
+
+    for (const candidate of candidates) {
+      const message = toMessage(candidate)
+      if (message) {
+        return message
+      }
+    }
+  }
+
+  return null
+}
+
+export function getRequestErrorMessage(error: unknown, fallback = '请求失败，请稍后重试。'): string {
+  if (error instanceof FetchError) {
+    const payload = (error as FetchErrorWithPayload).data ?? (error as FetchErrorWithPayload).response?._data
+    const payloadMessage = toMessage(payload)
+    if (payloadMessage) {
+      return payloadMessage
+    }
+
+    const errorMessage = toMessage(error.message)
+    if (errorMessage) {
+      return errorMessage
+    }
+  }
+
+  const genericMessage = toMessage(error)
+  if (genericMessage) {
+    return genericMessage
+  }
+
+  return fallback
+}

be/apps/dashboard/src/modules/auth/components/SocialConnectionSettings.tsx

@@ -4,6 +4,7 @@ import { useCallback, useMemo } from 'react'
 import { toast } from 'sonner'
 
 import { LinearBorderPanel } from '~/components/common/GlassPanel'
+import { getRequestErrorMessage } from '~/lib/errors'
 
 import type { SocialAccountRecord } from '../api/socialAccounts'
 import {
@@ -32,10 +33,10 @@ export function SocialConnectionSettings() {
   const hasError = providersQuery.isError || accountsQuery.isError
   const errorMessage = useMemo(() => {
     if (providersQuery.isError && providersQuery.error) {
-      return providersQuery.error instanceof Error ? providersQuery.error.message : '无法加载可用的 OAuth Provider'
+      return getRequestErrorMessage(providersQuery.error, '无法加载可用的 OAuth Provider')
     }
     if (accountsQuery.isError && accountsQuery.error) {
-      return accountsQuery.error instanceof Error ? accountsQuery.error.message : '无法查询绑定状态'
+      return getRequestErrorMessage(accountsQuery.error, '无法查询绑定状态')
     }
     return null
   }, [accountsQuery.error, accountsQuery.isError, providersQuery.error, providersQuery.isError])
@@ -68,7 +69,7 @@ export function SocialConnectionSettings() {
         }
       } catch (error) {
         toast.error(`无法开启 ${providerName} 绑定`, {
-          description: error instanceof Error ? error.message : '请稍后再试',
+          description: getRequestErrorMessage(error, '请稍后再试'),
         })
       }
     },
@@ -82,7 +83,7 @@ export function SocialConnectionSettings() {
         toast.success(`已解除与 ${providerName} 的绑定`)
       } catch (error) {
         toast.error('解绑失败', {
-          description: error instanceof Error ? error.message : '请稍后再试',
+          description: getRequestErrorMessage(error, '请稍后再试'),
         })
       }
     },