\s*<\/div>/gi, '')
+ .trim()
+}
+
+/**
+ * Convert HTML AST nodes to Lexical nodes
+ */
+function convertNodes(nodes: any[]): LexicalElementNode[] {
+ const result: LexicalElementNode[] = []
+ let currentList: LexicalElementNode | null = null
+ let listItems: LexicalElementNode[] = []
+
+ for (const node of nodes) {
+ // Handle text nodes
+ if (node.type === 'text') {
+ const text = node.value?.trim()
+ if (text) {
+ result.push({
+ type: 'paragraph',
+ version: 1,
+ children: [createTextNode(text)],
+ })
+ }
+ continue
+ }
+
+ if (!node.name) continue
+
+ const tag = node.name.toLowerCase()
+
+ // Handle headings
+ if (['h1', 'h2', 'h3', 'h4', 'h5', 'h6'].includes(tag)) {
+ flushList(result, currentList, listItems)
+ currentList = null
+ listItems = []
+ result.push(createHeading(tag, node.children || []))
+ continue
+ }
+
+ // Handle paragraphs
+ if (tag === 'p') {
+ flushList(result, currentList, listItems)
+ currentList = null
+ listItems = []
+ const content = convertInlineNodes(node.children || [])
+ if (content.length > 0) {
+ result.push({
+ type: 'paragraph',
+ version: 1,
+ children: content,
+ })
+ }
+ continue
+ }
+
+ // Handle lists
+ if (tag === 'ul' || tag === 'ol') {
+ flushList(result, currentList, listItems)
+ currentList = {
+ type: 'list',
+ version: 1,
+ listType: tag === 'ol' ? 'number' : 'bullet',
+ children: [],
+ }
+ listItems = convertListItems(node.children || [])
+ continue
+ }
+
+ // Handle blockquotes
+ if (tag === 'blockquote') {
+ flushList(result, currentList, listItems)
+ currentList = null
+ listItems = []
+ const content = convertInlineNodes(node.children || [])
+ result.push({
+ type: 'quote',
+ version: 1,
+ children: content,
+ })
+ continue
+ }
+
+ // Handle divs (treat as paragraphs)
+ if (tag === 'div') {
+ flushList(result, currentList, listItems)
+ currentList = null
+ listItems = []
+ const content = convertInlineNodes(node.children || [])
+ if (content.length > 0) {
+ result.push({
+ type: 'paragraph',
+ version: 1,
+ children: content,
+ })
+ }
+ continue
+ }
+
+ // Handle line breaks and horizontal rules
+ if (tag === 'br') {
+ result.push({
+ type: 'paragraph',
+ version: 1,
+ children: [{ type: 'linebreak', version: 1 } as any],
+ })
+ continue
+ }
+
+ if (tag === 'hr') {
+ result.push({
+ type: 'paragraph',
+ version: 1,
+ children: [createTextNode('---')],
+ })
+ continue
+ }
+
+ // Handle images
+ if (tag === 'img') {
+ flushList(result, currentList, listItems)
+ currentList = null
+ listItems = []
+ const src = node.attributes?.src || ''
+ const alt = node.attributes?.alt || ''
+ result.push(createImageNode(src, alt))
+ continue
+ }
+ }
+
+ // Flush any remaining list
+ flushList(result, currentList, listItems)
+
+ return result.length > 0 ? result : [createEmptyParagraph()]
+}
+
+/**
+ * Flush pending list items to result
+ */
+function flushList(
+ result: LexicalElementNode[],
+ list: LexicalElementNode | null,
+ items: LexicalElementNode[],
+): void {
+ if (list && items.length > 0) {
+ list.children = items
+ result.push(list)
+ }
+}
+
+/**
+ * Convert list items (li) to Lexical format
+ */
+function convertListItems(items: any[]): LexicalElementNode[] {
+ return items
+ .filter((item) => item.name?.toLowerCase() === 'li')
+ .map((item) => ({
+ type: 'listitem',
+ version: 1,
+ children: convertInlineNodes(item.children || []),
+ }))
+}
+
+/**
+ * Create a standard text node with all required Lexical properties
+ */
+function createTextNode(text: string, format?: number): LexicalTextContent {
+ return {
+ type: 'text',
+ version: 1,
+ text,
+ detail: 0,
+ format: format ?? 0,
+ mode: 'normal',
+ style: '',
+ }
+}
+
+/**
+ * Convert inline nodes (text, links, formatting)
+ */
+function convertInlineNodes(nodes: any[]): LexicalContent[] {
+ const result: LexicalContent[] = []
+
+ for (const node of nodes) {
+ // Handle text nodes (html-parse-stringify uses type for text)
+ if (node.type === 'text') {
+ const text = (node.value || node.content || '') as string
+ if (text) {
+ result.push(createTextNode(text))
+ }
+ continue
+ }
+
+ // Skip if no element name (not an element)
+ if (!node.name && !node.type) continue
+
+ const tag = node.name.toLowerCase()
+
+ // Handle links
+ // NOTE: Payload's Lexical link validation is very strict. For now, convert links to text
+ // TODO: Implement proper link format after investigating Payload's link node requirements
+ if (tag === 'a') {
+ // Convert links to text with URL in parentheses
+ const text = extractText(node.children || [])
+ const href = node.attrs?.href || node.attributes?.href || ''
+ if (text) {
+ // Include URL as text for now
+ const linkText = href && href !== '#' ? `${text} (${href})` : text
+ result.push(createTextNode(linkText))
+ }
+ continue
+ }
+
+ // Handle bold (strong, b)
+ if (tag === 'strong' || tag === 'b') {
+ const text = extractText(node.children || [])
+ result.push(createTextNode(text, 1)) // Bold format
+ continue
+ }
+
+ // Handle italic (em, i)
+ if (tag === 'em' || tag === 'i') {
+ const text = extractText(node.children || [])
+ result.push(createTextNode(text, 2)) // Italic format
+ continue
+ }
+
+ // Handle underline (u)
+ if (tag === 'u') {
+ const text = extractText(node.children || [])
+ result.push(createTextNode(text, 4)) // Underline format
+ continue
+ }
+
+ // Handle images inline
+ if (tag === 'img') {
+ const src = node.attrs?.src || node.attributes?.src || ''
+ const alt = node.attrs?.alt || node.attributes?.alt || ''
+ result.push(createImageNode(src, alt))
+ continue
+ }
+
+ // Handle spans (treat as text)
+ if (tag === 'span') {
+ const text = extractText(node.children || [])
+ if (text) {
+ result.push(createTextNode(text))
+ }
+ continue
+ }
+
+ // Handle code
+ if (tag === 'code') {
+ const text = extractText(node.children || [])
+ result.push({
+ ...createTextNode(text),
+ style: 'font-family: monospace;',
+ })
+ continue
+ }
+
+ // Recursively handle other inline elements
+ const children = convertInlineNodes(node.children || [])
+ result.push(...children)
+ }
+
+ return result.length > 0 ? result : [createTextNode('')]
+}
+
+/**
+ * Create a heading node
+ */
+function createHeading(tag: string, children: any[]): LexicalElementNode {
+ const tagNum = parseInt(tag.substring(1), 10)
+ const inlineNodes = convertInlineNodes(children)
+ return {
+ type: 'heading',
+ version: 1,
+ tag: `h${tagNum}`,
+ children: inlineNodes.length > 0 ? inlineNodes : [createTextNode('')],
+ }
+}
+
+/**
+ * Create an image node
+ */
+function createImageNode(src: string, alt: string): LexicalElementNode {
+ return {
+ type: 'paragraph',
+ version: 1,
+ children: [
+ {
+ ...createTextNode(`[Image: ${alt || src}]`),
+ style: 'font-style: italic;',
+ },
+ ],
+ }
+}
+
+/**
+ * Extract plain text from nodes
+ */
+function extractText(nodes: any[]): string {
+ let text = ''
+ for (const node of nodes) {
+ if (node.type === 'text') {
+ text += node.value || node.content || ''
+ } else if (node.children) {
+ text += extractText(node.children)
+ } else if (node.content) {
+ text += node.content
+ }
+ }
+ return text
+}
+
+// ============================================================
+// UTILITY FUNCTIONS
+// ============================================================
+
+/**
+ * Check if a string is valid Lexical JSON
+ */
+export function isValidLexical(json: string): boolean {
+ try {
+ const parsed = JSON.parse(json)
+ return parsed?.type === 'root' && Array.isArray(parsed?.children)
+ } catch {
+ return false
+ }
+}
+
+/**
+ * Convert multiple HTML contents to Lexical format
+ */
+export function batchHtmlToLexical(htmlArray: string[]): string[] {
+ return htmlArray.map((html) => htmlToLexical(html))
+}
diff --git a/apps/backend/scripts/migration/mediaHandler.ts b/apps/backend/scripts/migration/mediaHandler.ts
new file mode 100644
index 0000000..ae5ee76
--- /dev/null
+++ b/apps/backend/scripts/migration/mediaHandler.ts
@@ -0,0 +1,286 @@
+/**
+ * Media Handler Module
+ * Story 1.3: Content Migration Script
+ *
+ * Downloads images from URLs and uploads to Payload CMS
+ */
+
+import type { Payload, File } from 'payload'
+import type { MediaDownloadResult } from './types'
+import { getFilenameFromUrl, getFileExtension } from './utils'
+
+// ============================================================
+// DOWNLOAD MEDIA
+// ============================================================
+
+/**
+ * Download an image from URL
+ */
+export async function downloadImage(
+ url: string,
+ retries: number = 3,
+): Promise
{
+ let lastError: Error | undefined
+
+ for (let i = 0; i < retries; i++) {
+ try {
+ const response = await fetch(url, {
+ method: 'GET',
+ headers: {
+ 'User-Agent':
+ 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36',
+ },
+ signal: AbortSignal.timeout(30000), // 30 second timeout
+ })
+
+ if (!response.ok) {
+ throw new Error(`HTTP ${response.status}: ${response.statusText}`)
+ }
+
+ const buffer = Buffer.from(await response.arrayBuffer())
+ const filename = getFilenameFromUrl(url)
+
+ return {
+ success: true,
+ url,
+ buffer,
+ filename,
+ }
+ } catch (error) {
+ lastError = error as Error
+ // Wait before retry (exponential backoff)
+ if (i < retries - 1) {
+ await new Promise((resolve) => setTimeout(resolve, Math.pow(2, i) * 1000))
+ }
+ }
+ }
+
+ return {
+ success: false,
+ url,
+ error: lastError?.message || 'Unknown error',
+ }
+}
+
+/**
+ * Download multiple images in parallel batches
+ */
+export async function downloadImages(
+ urls: string[],
+ batchSize: number = 5,
+): Promise {
+ const results: MediaDownloadResult[] = []
+
+ for (let i = 0; i < urls.length; i += batchSize) {
+ const batch = urls.slice(i, i + batchSize)
+ const batchResults = await Promise.all(batch.map((url) => downloadImage(url)))
+ results.push(...batchResults)
+ }
+
+ return results
+}
+
+// ============================================================
+// UPLOAD TO PAYLOAD CMS
+// ============================================================
+
+/**
+ * Upload a single image to Payload CMS Media collection
+ */
+export async function uploadToMedia(
+ payload: Payload,
+ downloadResult: MediaDownloadResult,
+): Promise<{ success: boolean; id?: string; error?: string }> {
+ if (!downloadResult.success || !downloadResult.buffer || !downloadResult.filename) {
+ return {
+ success: false,
+ error: downloadResult.error || 'Invalid download result',
+ }
+ }
+
+ try {
+ const file: File = {
+ name: downloadResult.filename,
+ data: downloadResult.buffer,
+ mimetype: `image/${getFileExtension(downloadResult.filename)}`,
+ size: downloadResult.buffer.length,
+ }
+
+ const result = await payload.create({
+ collection: 'media',
+ file,
+ data: {
+ alt: downloadResult.filename,
+ },
+ })
+
+ return {
+ success: true,
+ id: result.id,
+ }
+ } catch (error) {
+ return {
+ success: false,
+ error: error instanceof Error ? error.message : 'Unknown error',
+ }
+ }
+}
+
+/**
+ * Check if media already exists by filename
+ */
+export async function findMediaByFilename(
+ payload: Payload,
+ filename: string,
+): Promise {
+ try {
+ const result = await payload.find({
+ collection: 'media',
+ where: {
+ filename: { equals: filename },
+ },
+ limit: 1,
+ depth: 0,
+ })
+
+ if (result.docs && result.docs.length > 0) {
+ return result.docs[0].id
+ }
+
+ return null
+ } catch {
+ return null
+ }
+}
+
+// ============================================================
+// BATCH PROCESSING
+// ============================================================
+
+/**
+ * Process all media URLs: download and upload to Payload CMS
+ * Returns a map of original URL to Media ID
+ */
+export async function processMediaUrls(
+ payload: Payload,
+ urls: string[],
+ options: {
+ batchSize?: number
+ retries?: number
+ onProgress?: (current: number, total: number) => void
+ } = {},
+): Promise> {
+ const { batchSize = 5, onProgress } = options
+ const urlToIdMap = new Map()
+
+ // Filter out empty URLs
+ const validUrls = urls.filter((url) => url && isValidImageUrl(url))
+
+ for (let i = 0; i < validUrls.length; i += batchSize) {
+ const batch = validUrls.slice(i, i + batchSize)
+
+ // Download batch
+ const downloadResults = await Promise.all(
+ batch.map((url) => downloadImage(url, options.retries || 3)),
+ )
+
+ // Upload each downloaded image
+ for (const result of downloadResults) {
+ if (result.success && result.buffer && result.filename) {
+ // Check if already exists
+ const existingId = await findMediaByFilename(payload, result.filename)
+
+ if (existingId) {
+ urlToIdMap.set(result.url, existingId)
+ } else {
+ // Upload new
+ const uploadResult = await uploadToMedia(payload, result)
+ if (uploadResult.success && uploadResult.id) {
+ urlToIdMap.set(result.url, uploadResult.id)
+ }
+ }
+ }
+
+ // Report progress
+ if (onProgress) {
+ onProgress(urlToIdMap.size, validUrls.length)
+ }
+ }
+ }
+
+ return urlToIdMap
+}
+
+/**
+ * Process a single media URL with caching
+ */
+const mediaCache = new Map()
+
+export async function getOrCreateMedia(
+ payload: Payload,
+ url: string,
+): Promise {
+ // Check cache first
+ if (mediaCache.has(url)) {
+ return mediaCache.get(url)
+ }
+
+ if (!url || !isValidImageUrl(url)) {
+ return undefined
+ }
+
+ const downloadResult = await downloadImage(url)
+ if (!downloadResult.success || !downloadResult.buffer || !downloadResult.filename) {
+ return undefined
+ }
+
+ // Check if already exists
+ const existingId = await findMediaByFilename(payload, downloadResult.filename)
+ if (existingId) {
+ mediaCache.set(url, existingId)
+ return existingId
+ }
+
+ // Upload new
+ const uploadResult = await uploadToMedia(payload, downloadResult)
+ if (uploadResult.success && uploadResult.id) {
+ mediaCache.set(url, uploadResult.id)
+ return uploadResult.id
+ }
+
+ return undefined
+}
+
+// ============================================================
+// UTILITIES
+// ============================================================
+
+/**
+ * Check if URL is a valid image
+ */
+function isValidImageUrl(url: string): boolean {
+ if (!url) {
+ return false
+ }
+ try {
+ const urlObj = new URL(url)
+ const pathname = urlObj.pathname.toLowerCase()
+ return (
+ pathname.endsWith('.jpg') ||
+ pathname.endsWith('.jpeg') ||
+ pathname.endsWith('.png') ||
+ pathname.endsWith('.gif') ||
+ pathname.endsWith('.webp') ||
+ pathname.endsWith('.svg')
+ )
+ } catch {
+ return false
+ }
+}
+
+/**
+ * Clear media cache (useful for testing)
+ */
+export function clearMediaCache(): void {
+ mediaCache.clear()
+}
diff --git a/apps/backend/scripts/migration/migrate-wrapper.sh b/apps/backend/scripts/migration/migrate-wrapper.sh
new file mode 100644
index 0000000..c34070e
--- /dev/null
+++ b/apps/backend/scripts/migration/migrate-wrapper.sh
@@ -0,0 +1,13 @@
+#!/bin/bash
+# Migration wrapper script - loads .env before running tsx
+
+cd "$(dirname "$0")"
+
+# Load .env file
+if [ -f .env ]; then
+ export $(grep -v '^#' .env | xargs)
+ echo "✓ .env loaded"
+fi
+
+# Run the migration script
+tsx migrate.ts "$@"
diff --git a/apps/backend/scripts/migration/migrate.ts b/apps/backend/scripts/migration/migrate.ts
new file mode 100644
index 0000000..1dcec8b
--- /dev/null
+++ b/apps/backend/scripts/migration/migrate.ts
@@ -0,0 +1,436 @@
+#!/usr/bin/env tsx
+/**
+ * Webflow to Payload CMS Migration Script
+ * Story 1.3: Content Migration Script
+ *
+ * Usage:
+ * pnpm tsx scripts/migration/migrate.ts [options]
+ *
+ * Options:
+ * --dry-run, -n Run without making changes
+ * --verbose, -v Show detailed logging
+ * --force, -f Overwrite existing items
+ * --collection, -c Specific collection (categories|posts|portfolio|all)
+ * --source, -s Path to export file
+ * --batch-size Batch size for processing (default: 5)
+ * --help, -h Show help message
+ */
+
+import { config as dotenvConfig } from 'dotenv'
+// Load .env before any other imports
+dotenvConfig({ path: '.env' })
+
+// Ensure R2_BUCKET_NAME is set (from R2_BUCKET)
+if (!process.env.R2_BUCKET_NAME && process.env.R2_BUCKET) {
+ process.env.R2_BUCKET_NAME = process.env.R2_BUCKET
+}
+
+import { getPayload } from 'payload'
+import config from '../../src/payload.config'
+import { parseCliArgs, Logger, colors } from './utils'
+import { createReport, updateReport, saveReport, printReportSummary } from './reporter'
+import {
+ findBySlug,
+ findBySlugAndDate,
+ getAllSlugs,
+ getExistingPostIdentifiers,
+} from './deduplicator'
+import { transformCategories, transformPosts, transformPortfolios } from './transformers'
+import { processMediaUrls, getOrCreateMedia } from './mediaHandler'
+import { parseWebflowHTML, parseHTMLFile, extractMediaUrls } from './htmlParser'
+import { parseWebflowCSV } from './csvParser'
+import type { MigrationConfig, WebflowExportData, PayloadCategory } from './types'
+import { readFileSync, existsSync } from 'fs'
+import { extname } from 'path'
+
+// ============================================================
+// MAIN MIGRATION FUNCTION
+// ============================================================
+
+async function main() {
+ // Parse CLI arguments
+ const args = process.argv.slice(2)
+ const config_options = parseCliArgs(args)
+
+ const logger = new Logger(config_options.verbose)
+ const report = createReport(config_options.dryRun)
+
+ logger.header('🚀 Webflow to Payload CMS Migration')
+ logger.info(`Mode: ${config_options.dryRun ? colors.yellow + 'DRY RUN' + colors.reset : colors.green + 'LIVE' + colors.reset}`)
+ logger.info(`Source: ${config_options.sourcePath}`)
+ logger.info(`Collections: ${config_options.collections.join(', ')}`)
+
+ // Initialize Payload
+ logger.info('\n📦 Initializing Payload CMS...')
+ const payload = await getPayload({ config })
+
+ // Load source data
+ logger.info('\n📂 Loading source data...')
+ const sourceData = await loadSourceData(config_options.sourcePath, logger)
+
+ if (!sourceData) {
+ logger.error('Failed to load source data')
+ process.exit(1)
+ }
+
+ // Process based on collections
+ const collectionsToProcess = determineCollections(config_options.collections)
+
+ // Migration order: Categories first, then Posts/Portfolio
+ let categoryMap = new Map() // slug -> id
+
+ if (collectionsToProcess.includes('categories')) {
+ categoryMap = await migrateCategories(payload, sourceData, config_options, logger, report)
+ }
+
+ if (collectionsToProcess.includes('posts')) {
+ await migratePosts(payload, sourceData, config_options, logger, report, categoryMap)
+ }
+
+ if (collectionsToProcess.includes('portfolio')) {
+ await migratePortfolio(payload, sourceData, config_options, logger, report)
+ }
+
+ // Generate and save report
+ printReportSummary(report)
+
+ if (!config_options.dryRun) {
+ await saveReport(report, './apps/backend/reports')
+ }
+}
+
+// ============================================================
+// DATA LOADING
+// ============================================================
+
+async function loadSourceData(
+ sourcePath: string,
+ logger: Logger,
+): Promise {
+ // Check if file exists
+ if (!existsSync(sourcePath)) {
+ logger.error(`Source file not found: ${sourcePath}`)
+ logger.info('\nCreating sample data structure for manual entry...')
+ return {
+ posts: [],
+ categories: [
+ { name: 'Google小學堂', slug: 'google-workshop', colorHex: '#4285f4' },
+ { name: 'Meta小學堂', slug: 'meta-workshop', colorHex: '#0668e1' },
+ { name: '行銷時事最前線', slug: 'marketing-news', colorHex: '#34a853' },
+ { name: '恩群數位最新公告', slug: 'enchun-announcements', colorHex: '#ea4335' },
+ ],
+ portfolio: [],
+ }
+ }
+
+ const ext = extname(sourcePath).toLowerCase()
+
+ try {
+ if (ext === '.csv') {
+ // Parse CSV export (Webflow format)
+ logger.info('Parsing CSV file (Webflow format)...')
+ return await parseWebflowCSV(sourcePath)
+ } else if (ext === '.json') {
+ // Parse JSON export
+ const content = readFileSync(sourcePath, 'utf-8')
+ return JSON.parse(content) as WebflowExportData
+ } else if (ext === '.html' || ext === '.htm') {
+ // Parse HTML file
+ logger.info('Parsing HTML file (this may not capture all data)...')
+ return await parseHTMLFile(sourcePath)
+ } else {
+ // Auto-detect: try CSV first, then JSON, then HTML
+ logger.info('Auto-detecting file format...')
+ try {
+ return await parseWebflowCSV(sourcePath)
+ } catch {
+ try {
+ const content = readFileSync(sourcePath, 'utf-8')
+ return JSON.parse(content) as WebflowExportData
+ } catch {
+ const content = readFileSync(sourcePath, 'utf-8')
+ return parseWebflowHTML(content)
+ }
+ }
+ }
+ } catch (error) {
+ logger.error(`Error loading source data: ${error}`)
+ return null
+ }
+}
+
+// ============================================================
+// COLLECTION MIGRATION
+// ============================================================
+
+async function migrateCategories(
+ payload: any,
+ sourceData: WebflowExportData,
+ config: MigrationConfig,
+ logger: Logger,
+ report: any,
+): Promise> {
+ logger.header('\n🏷️ Migrating Categories')
+
+ const categories = sourceData.categories || []
+ if (categories.length === 0) {
+ logger.warn('No categories found in source data')
+ return new Map()
+ }
+
+ logger.info(`Found ${categories.length} categories`)
+
+ const categoryMap = new Map()
+ const results: any[] = []
+ let created = 0,
+ skipped = 0,
+ failed = 0
+
+ // Get existing slugs for deduplication
+ const existingSlugs = config.force ? new Set() : await getAllSlugs(payload, 'categories')
+
+ for (const category of categories) {
+ const transformed = transformCategories([category])[0]
+
+ if (!config.force && existingSlugs.has(transformed.slug)) {
+ logger.debug(`⏭️ Skipping existing category: ${transformed.title}`)
+ skipped++
+ results.push({ slug: transformed.slug, success: true, skipped: true })
+ continue
+ }
+
+ if (config.dryRun) {
+ logger.debug(`✓ Would create category: ${transformed.title}`)
+ created++
+ results.push({ slug: transformed.slug, success: true })
+ categoryMap.set(transformed.slug, `dry-run-id-${created}`)
+ continue
+ }
+
+ try {
+ const result = await payload.create({
+ collection: 'categories',
+ data: transformed,
+ })
+
+ logger.success(`Created category: ${transformed.title}`)
+ created++
+ results.push({ slug: transformed.slug, success: true, id: result.id })
+ categoryMap.set(transformed.slug, result.id)
+ } catch (error) {
+ logger.error(`Failed to create category "${transformed.title}": ${error}`)
+ failed++
+ results.push({ slug: transformed.slug, success: false, error: String(error) })
+ }
+ }
+
+ updateReport(report, {
+ collection: 'categories',
+ created,
+ skipped,
+ failed,
+ results,
+ })
+
+ logger.info(`Categories: ${created} created, ${skipped} skipped, ${failed} failed`)
+
+ return categoryMap
+}
+
+async function migratePosts(
+ payload: any,
+ sourceData: WebflowExportData,
+ config: MigrationConfig,
+ logger: Logger,
+ report: any,
+ categoryMap: Map,
+): Promise {
+ logger.header('\n📝 Migrating Posts')
+
+ const posts = sourceData.posts || []
+ if (posts.length === 0) {
+ logger.warn('No posts found in source data')
+ return
+ }
+
+ logger.info(`Found ${posts.length} posts`)
+
+ const results: any[] = []
+ let created = 0,
+ skipped = 0,
+ failed = 0
+
+ // Get existing identifiers for deduplication
+ const existingIds = config.force ? new Map() : await getExistingPostIdentifiers(payload)
+
+ // Extract media URLs for batch processing
+ const mediaUrls = new Set()
+ for (const post of posts) {
+ if (post.featuredImage) mediaUrls.add(post.featuredImage)
+ }
+
+ // Process media
+ if (mediaUrls.size > 0 && !config.dryRun) {
+ logger.info(`Processing ${mediaUrls.size} media files...`)
+ const mediaMap = await processMediaUrls(payload, Array.from(mediaUrls), {
+ batchSize: config.batchSize,
+ onProgress: (current, total) => logger.progress(current, total, 'media'),
+ })
+ logger.success(`Media processing complete`)
+ }
+
+ for (const post of posts) {
+ const transformed = transformPosts([post])[0]
+
+ // Resolve category IDs
+ if (post.postCategory && categoryMap.has(post.postCategory)) {
+ transformed.categories = [categoryMap.get(post.postCategory)!]
+ }
+
+ // Check for duplicates
+ const postKey = `${transformed.slug}-${transformed.publishedAt.toISOString()}`
+ if (!config.force && existingIds.has(postKey)) {
+ logger.debug(`⏭️ Skipping existing post: ${transformed.title}`)
+ skipped++
+ results.push({ slug: transformed.slug, success: true, skipped: true })
+ continue
+ }
+
+ if (config.dryRun) {
+ logger.debug(`✓ Would create post: ${transformed.title}`)
+ created++
+ results.push({ slug: transformed.slug, success: true })
+ continue
+ }
+
+ try {
+ const result = await payload.create({
+ collection: 'posts',
+ data: transformed,
+ })
+
+ logger.success(`Created post: ${transformed.title}`)
+ created++
+ results.push({ slug: transformed.slug, success: true, id: result.id })
+ } catch (error) {
+ logger.error(`Failed to create post "${transformed.title}": ${error}`)
+ failed++
+ results.push({ slug: transformed.slug, success: false, error: String(error) })
+ }
+ }
+
+ updateReport(report, {
+ collection: 'posts',
+ created,
+ skipped,
+ failed,
+ results,
+ })
+
+ logger.info(`Posts: ${created} created, ${skipped} skipped, ${failed} failed`)
+}
+
+async function migratePortfolio(
+ payload: any,
+ sourceData: WebflowExportData,
+ config: MigrationConfig,
+ logger: Logger,
+ report: any,
+): Promise {
+ logger.header('\n💼 Migrating Portfolio')
+
+ const portfolio = sourceData.portfolio || []
+ if (portfolio.length === 0) {
+ logger.warn('No portfolio items found in source data')
+ return
+ }
+
+ logger.info(`Found ${portfolio.length} portfolio items`)
+
+ const results: any[] = []
+ let created = 0,
+ skipped = 0,
+ failed = 0
+
+ // Get existing slugs
+ const existingSlugs = config.force ? new Set() : await getAllSlugs(payload, 'portfolio')
+
+ // Extract media URLs
+ const mediaUrls = new Set()
+ for (const item of portfolio) {
+ if (item.previewImage) mediaUrls.add(item.previewImage)
+ }
+
+ // Process media
+ if (mediaUrls.size > 0 && !config.dryRun) {
+ logger.info(`Processing ${mediaUrls.size} media files...`)
+ await processMediaUrls(payload, Array.from(mediaUrls), {
+ batchSize: config.batchSize,
+ onProgress: (current, total) => logger.progress(current, total, 'media'),
+ })
+ logger.success(`Media processing complete`)
+ }
+
+ for (const item of portfolio) {
+ const transformed = transformPortfolios([item])[0]
+
+ if (!config.force && existingSlugs.has(transformed.slug)) {
+ logger.debug(`⏭️ Skipping existing portfolio: ${transformed.title}`)
+ skipped++
+ results.push({ slug: transformed.slug, success: true, skipped: true })
+ continue
+ }
+
+ if (config.dryRun) {
+ logger.debug(`✓ Would create portfolio: ${transformed.title}`)
+ created++
+ results.push({ slug: transformed.slug, success: true })
+ continue
+ }
+
+ try {
+ const result = await payload.create({
+ collection: 'portfolio',
+ data: transformed,
+ })
+
+ logger.success(`Created portfolio: ${transformed.title}`)
+ created++
+ results.push({ slug: transformed.slug, success: true, id: result.id })
+ } catch (error) {
+ logger.error(`Failed to create portfolio "${transformed.title}": ${error}`)
+ failed++
+ results.push({ slug: transformed.slug, success: false, error: String(error) })
+ }
+ }
+
+ updateReport(report, {
+ collection: 'portfolio',
+ created,
+ skipped,
+ failed,
+ results,
+ })
+
+ logger.info(`Portfolio: ${created} created, ${skipped} skipped, ${failed} failed`)
+}
+
+// ============================================================
+// HELPER FUNCTIONS
+// ============================================================
+
+function determineCollections(collections: string[]): Array<'categories' | 'posts' | 'portfolio'> {
+ if (collections.includes('all')) {
+ return ['categories', 'posts', 'portfolio']
+ }
+ return collections as Array<'categories' | 'posts' | 'portfolio'>
+}
+
+// ============================================================
+// ENTRY POINT
+// ============================================================
+
+main().catch((error) => {
+ console.error(`${colors.red}Fatal error:${colors.reset}`, error)
+ process.exit(1)
+})
diff --git a/apps/backend/scripts/migration/reporter.ts b/apps/backend/scripts/migration/reporter.ts
new file mode 100644
index 0000000..d9927fb
--- /dev/null
+++ b/apps/backend/scripts/migration/reporter.ts
@@ -0,0 +1,188 @@
+/**
+ * Migration Reporter
+ * Story 1.3: Content Migration Script
+ *
+ * Generates migration reports in JSON and Markdown formats
+ */
+
+import type { MigrationReport, CollectionMigrationResult } from './types'
+import { writeFile, mkdir } from 'fs/promises'
+import { join } from 'path'
+import { existsSync } from 'fs'
+
+// ============================================================
+// REPORT GENERATION
+// ============================================================
+
+/**
+ * Create a new empty report
+ */
+export function createReport(dryRun: boolean = false): MigrationReport {
+ return {
+ timestamp: new Date().toISOString(),
+ dryRun,
+ summary: {
+ total: 0,
+ created: 0,
+ skipped: 0,
+ failed: 0,
+ },
+ byCollection: {},
+ details: {},
+ }
+}
+
+/**
+ * Update report with collection results
+ */
+export function updateReport(
+ report: MigrationReport,
+ collectionResult: CollectionMigrationResult,
+): MigrationReport {
+ const { collection, created, skipped, failed } = collectionResult
+
+ // Update byCollection stats
+ report.byCollection[collection] = { created, skipped, failed }
+
+ // Store details
+ report.details[collection] = collectionResult
+
+ // Update summary
+ report.summary.total += created + skipped + failed
+ report.summary.created += created
+ report.summary.skipped += skipped
+ report.summary.failed += failed
+
+ return report
+}
+
+/**
+ * Generate markdown report
+ */
+export function generateMarkdownReport(report: MigrationReport): string {
+ const lines: string[] = []
+
+ lines.push(`# Migration Report`)
+ lines.push(``)
+ lines.push(`**Generated:** ${new Date(report.timestamp).toLocaleString('zh-TW')}`)
+ lines.push(`**Mode:** ${report.dryRun ? '🧪 Dry Run (no changes made)' : '✅ Live Migration'}`)
+ lines.push(``)
+ lines.push(`---`)
+ lines.push(``)
+
+ // Summary section
+ lines.push(`## Summary`)
+ lines.push(``)
+ lines.push(`| Metric | Count |`)
+ lines.push(`|--------|-------|`)
+ lines.push(`| Total Items | ${report.summary.total} |`)
+ lines.push(`| ✅ Created | ${report.summary.created} |`)
+ lines.push(`| ⏭️ Skipped | ${report.summary.skipped} |`)
+ lines.push(`| ❌ Failed | ${report.summary.failed} |`)
+ lines.push(``)
+
+ // By collection section
+ lines.push(`## By Collection`)
+ lines.push(``)
+
+ for (const [collection, stats] of Object.entries(report.byCollection)) {
+ lines.push(`### ${collection.charAt(0).toUpperCase() + collection.slice(1)}`)
+ lines.push(``)
+ lines.push(`| Metric | Count |`)
+ lines.push(`|--------|-------|`)
+ lines.push(`| Created | ${stats.created} |`)
+ lines.push(`| Skipped | ${stats.skipped} |`)
+ lines.push(`| Failed | ${stats.failed} |`)
+ lines.push(``)
+ }
+
+ // Details section
+ if (report.details) {
+ lines.push(`## Details`)
+ lines.push(``)
+
+ for (const [collection, result] of Object.entries(report.details)) {
+ lines.push(`### ${collection.charAt(0).toUpperCase() + collection.slice(1)}`)
+ lines.push(``)
+
+ // Created items
+ if (result.results.some((r) => r.success)) {
+ lines.push(`#### ✅ Created (${result.results.filter((r) => r.success).length})`)
+ lines.push(``)
+ for (const item of result.results.filter((r) => r.success)) {
+ lines.push(`- \`${item.slug}\` (ID: ${item.id})`)
+ }
+ lines.push(``)
+ }
+
+ // Failed items
+ if (result.results.some((r) => !r.success)) {
+ lines.push(`#### ❌ Failed (${result.results.filter((r) => !r.success).length})`)
+ lines.push(``)
+ for (const item of result.results.filter((r) => !r.success)) {
+ lines.push(`- \`${item.slug}\`: ${item.error}`)
+ }
+ lines.push(``)
+ }
+ }
+ }
+
+ return lines.join('\n')
+}
+
+/**
+ * Save report to files
+ */
+export async function saveReport(
+ report: MigrationReport,
+ outputDir: string = './reports',
+): Promise {
+ // Ensure directory exists
+ if (!existsSync(outputDir)) {
+ await mkdir(outputDir, { recursive: true })
+ }
+
+ const timestamp = new Date().toISOString().replace(/[:.]/g, '-').split('T')[0]
+ const baseName = `migration-${timestamp}`
+
+ // Save JSON report
+ const jsonPath = join(outputDir, `${baseName}.json`)
+ await writeFile(jsonPath, JSON.stringify(report, null, 2), 'utf-8')
+
+ // Save Markdown report
+ const mdPath = join(outputDir, `${baseName}.md`)
+ await writeFile(mdPath, generateMarkdownReport(report), 'utf-8')
+
+ console.log(`\n📄 Reports saved:`)
+ console.log(` - JSON: ${jsonPath}`)
+ console.log(` - Markdown: ${mdPath}`)
+}
+
+/**
+ * Print report summary to console
+ */
+export function printReportSummary(report: MigrationReport): void {
+ console.log(`\n${'='.repeat(60)}`)
+ console.log(`📊 MIGRATION REPORT`)
+ console.log(`${'='.repeat(60)}`)
+ console.log(``)
+ console.log(`Mode: ${report.dryRun ? '🧪 Dry Run' : '✅ Live'}`)
+ console.log(``)
+ console.log(`Summary:`)
+ console.log(` Total: ${report.summary.total}`)
+ console.log(` Created: ${report.summary.created} ✅`)
+ console.log(` Skipped: ${report.summary.skipped} ⏭️`)
+ console.log(` Failed: ${report.summary.failed} ❌`)
+ console.log(``)
+
+ if (report.byCollection) {
+ console.log(`By Collection:`)
+ for (const [collection, stats] of Object.entries(report.byCollection)) {
+ console.log(
+ ` ${collection}: ${stats.created} created, ${stats.skipped} skipped, ${stats.failed} failed`,
+ )
+ }
+ }
+
+ console.log(`${'='.repeat(60)}`)
+}
diff --git a/apps/backend/scripts/migration/test-connection.ts b/apps/backend/scripts/migration/test-connection.ts
new file mode 100644
index 0000000..ebe112f
--- /dev/null
+++ b/apps/backend/scripts/migration/test-connection.ts
@@ -0,0 +1,93 @@
+#!/usr/bin/env tsx
+/**
+ * Test MongoDB and Payload CMS Connection
+ */
+
+import { config as dotenvConfig } from 'dotenv'
+import { resolve, dirname } from 'path'
+import { fileURLToPath } from 'url'
+
+// Resolve .env path from script location
+const __filename = fileURLToPath(import.meta.url)
+const __dirname = dirname(__filename)
+const envPath = resolve(__dirname, '../../../.env')
+
+console.log(`Loading .env from: ${envPath}`)
+dotenvConfig({ path: envPath })
+
+import { getPayload } from 'payload'
+import config from '../../src/payload.config'
+
+async function testMongoDirect() {
+ console.log('\n🔍 Testing Environment Variables...\n')
+
+ const uri = process.env.DATABASE_URI
+ console.log(`DATABASE_URI: ${uri?.replace(/:[^:@]+@/, ':****@')}`)
+
+ if (!uri) {
+ console.log('❌ DATABASE_URI not set')
+ return false
+ }
+
+ console.log('✅ DATABASE_URI is set')
+ return true
+}
+
+async function testPayloadAPI() {
+ console.log('\n🔍 Testing Payload CMS API Connection...\n')
+
+ try {
+ const payload = await getPayload({ config })
+ console.log('✅ Payload CMS initialized')
+
+ // Find posts
+ const posts = await payload.find({
+ collection: 'posts',
+ limit: 3,
+ depth: 0,
+ })
+
+ console.log(`📝 Found ${posts.totalDocs} posts`)
+
+ if (posts.docs.length > 0) {
+ const post = posts.docs[0]
+ console.log(`\n📋 First post:`)
+ console.log(` Title: ${post.title}`)
+ console.log(` Slug: ${post.slug}`)
+ console.log(` Content Type: ${typeof post.content}`)
+
+ if (typeof post.content === 'string') {
+ try {
+ const parsed = JSON.parse(post.content)
+ console.log(` Lexical Type: ${parsed?.type}`)
+ console.log(` Lexical Version: ${parsed?.version}`)
+ console.log(` Children Count: ${parsed?.children?.length}`)
+ } catch {
+ console.log(` Content (first 200 chars): ${post.content.substring(0, 200)}...`)
+ }
+ }
+ }
+
+ return true
+ } catch (error) {
+ console.log('❌ Payload CMS connection failed:', error)
+ return false
+ }
+}
+
+async function main() {
+ console.log('═══════════════════════════════════════════════════════════')
+ console.log('Connection Test')
+ console.log('═══════════════════════════════════════════════════════════')
+
+ const mongoOk = await testMongoDirect()
+ const payloadOk = await testPayloadAPI()
+
+ console.log('\n═══════════════════════════════════════════════════════════')
+ console.log('Summary:')
+ console.log(` DATABASE_URI: ${mongoOk ? '✅ OK' : '❌ FAILED'}`)
+ console.log(` Payload CMS: ${payloadOk ? '✅ OK' : '❌ FAILED'}`)
+ console.log('═══════════════════════════════════════════════════════════\n')
+}
+
+main().catch(console.error)
diff --git a/apps/backend/scripts/migration/test-create-post.ts b/apps/backend/scripts/migration/test-create-post.ts
new file mode 100644
index 0000000..0e8b720
--- /dev/null
+++ b/apps/backend/scripts/migration/test-create-post.ts
@@ -0,0 +1,49 @@
+#!/usr/bin/env tsx
+import { config as dotenvConfig } from 'dotenv'
+import { resolve, dirname } from 'path'
+import { fileURLToPath } from 'url'
+
+const __filename = fileURLToPath(import.meta.url)
+const __dirname = dirname(__filename)
+// Script is at: apps/backend/scripts/migration/test-create-post.ts
+// .env is at: apps/backend/.env
+const envPath = resolve(__dirname, '../../.env')
+
+dotenvConfig({ path: envPath })
+
+// Verify env is loaded
+console.log('PAYLOAD_SECRET loaded:', !!process.env.PAYLOAD_SECRET)
+console.log('PAYLOAD_SECRET value:', process.env.PAYLOAD_SECRET?.substring(0, 10))
+
+// Dynamic import after dotenv to ensure env is loaded before config
+const { getPayload } = await import('payload')
+const config = await import('../../src/payload.config.ts')
+const { parseWebflowCSV } = await import('./csvParser.ts')
+const { transformPosts } = await import('./transformers.ts')
+
+async function main() {
+ const payload = await getPayload({ config })
+
+ const data = await parseWebflowCSV('/Users/pukpuk/Dev/website-enchun-mgr/恩群數位行銷 - 行銷放大鏡集.csv')
+ const failPost = data.posts.find((p: any) => p.title.includes('一點都不難'))
+ const transformed = transformPosts([failPost])[0]
+
+ console.log('Attempting to create:', transformed.title)
+ console.log('Slug:', transformed.slug)
+
+ try {
+ const result = await payload.create({
+ collection: 'posts',
+ data: transformed,
+ })
+ console.log('Success! Created:', result.id)
+ } catch (error: any) {
+ console.log('Failed!')
+ console.log('Error message:', error.message)
+ if (error.data) {
+ console.log('Error data:', JSON.stringify(error.data, null, 2))
+ }
+ }
+}
+
+main().catch(console.error)
diff --git a/apps/backend/scripts/migration/test-csv.ts b/apps/backend/scripts/migration/test-csv.ts
new file mode 100644
index 0000000..4efccae
--- /dev/null
+++ b/apps/backend/scripts/migration/test-csv.ts
@@ -0,0 +1,46 @@
+#!/usr/bin/env tsx
+/**
+ * Test CSV Parser (No MongoDB required)
+ */
+
+import { parseWebflowCSV } from './csvParser'
+import { Logger } from './utils'
+
+const logger = new Logger(true)
+
+async function main() {
+ const csvPath = process.argv[2] || '../../恩群數位行銷 - 行銷放大鏡集 - 61f24aa108528b279f942ca9.csv'
+
+ logger.header('🧪 Testing CSV Parser')
+ logger.info(`File: ${csvPath}`)
+
+ try {
+ const data = await parseWebflowCSV(csvPath)
+
+ logger.success(`✓ CSV parsed successfully!`)
+ logger.info(`Posts: ${data.posts?.length || 0}`)
+ logger.info(`Categories: ${data.categories?.length || 0}`)
+ logger.info(`Portfolio: ${data.portfolio?.length || 0}`)
+
+ if (data.categories && data.categories.length > 0) {
+ logger.info('\n📋 Categories found:')
+ for (const cat of data.categories) {
+ logger.info(` - ${cat.name} (${cat.slug}) - ${cat.colorHex}`)
+ }
+ }
+
+ if (data.posts && data.posts.length > 0) {
+ logger.info('\n📝 First 5 posts:')
+ for (const post of data.posts.slice(0, 5)) {
+ logger.info(` - [${post.postCategory || 'uncategorized'}] ${post.title}`)
+ logger.debug(` Slug: ${post.slug}`)
+ logger.debug(` Date: ${post.publishedDate}`)
+ }
+ }
+
+ } catch (error) {
+ logger.error(`Error: ${error}`)
+ }
+}
+
+main()
diff --git a/apps/backend/scripts/migration/test-env.ts b/apps/backend/scripts/migration/test-env.ts
new file mode 100644
index 0000000..267afae
--- /dev/null
+++ b/apps/backend/scripts/migration/test-env.ts
@@ -0,0 +1,15 @@
+#!/usr/bin/env tsx
+import { config as dotenvConfig } from 'dotenv'
+import { resolve, dirname } from 'path'
+import { fileURLToPath } from 'url'
+
+const __filename = fileURLToPath(import.meta.url)
+const __dirname = dirname(__filename)
+const envPath = resolve(__dirname, '../../.env')
+
+console.log('Loading .env from:', envPath)
+const result = dotenvConfig({ path: envPath })
+
+console.log('dotenv result:', result.error ? result.error.message : 'success')
+console.log('PAYLOAD_SECRET:', process.env.PAYLOAD_SECRET ? 'SET' : 'NOT SET')
+console.log('DATABASE_URI:', process.env.DATABASE_URI ? 'SET' : 'NOT SET')
diff --git a/apps/backend/scripts/migration/test-payload-post.ts b/apps/backend/scripts/migration/test-payload-post.ts
new file mode 100644
index 0000000..2a7d269
--- /dev/null
+++ b/apps/backend/scripts/migration/test-payload-post.ts
@@ -0,0 +1,111 @@
+#!/usr/bin/env tsx
+/**
+ * Test Payload Post Creation with Lexical Content
+ */
+
+import { getPayload } from 'payload'
+import config from '@payload-config'
+
+async function testPostCreation() {
+ const payload = await getPayload({ config })
+
+ // Test 1: Simple string content
+ console.log('\n🧪 Test 1: String content')
+ try {
+ const result1 = await payload.create({
+ collection: 'posts',
+ data: {
+ title: 'Test String Content',
+ slug: 'test-string-' + Date.now(),
+ content: 'Simple HTML content
',
+ publishedAt: new Date(),
+ status: 'draft',
+ },
+ })
+ console.log('✓ String content worked:', result1.id)
+ await payload.delete({
+ collection: 'posts',
+ id: result1.id,
+ })
+ } catch (error: any) {
+ console.log('✗ String content failed:', error.message)
+ }
+
+ // Test 2: JSON string content
+ console.log('\n🧪 Test 2: JSON string content')
+ try {
+ const result2 = await payload.create({
+ collection: 'posts',
+ data: {
+ title: 'Test JSON Content',
+ slug: 'test-json-' + Date.now(),
+ content: JSON.stringify({
+ type: 'root',
+ version: 1,
+ children: [{
+ type: 'paragraph',
+ version: 1,
+ children: [{
+ type: 'text',
+ version: 1,
+ text: 'This is a test paragraph.'
+ }]
+ }],
+ direction: null
+ }),
+ publishedAt: new Date(),
+ status: 'draft',
+ },
+ })
+ console.log('✓ JSON string content worked:', result2.id)
+ await payload.delete({
+ collection: 'posts',
+ id: result2.id,
+ })
+ } catch (error: any) {
+ console.log('✗ JSON string content failed:', error.message)
+ if (error.data) {
+ console.error(' Validation errors:', JSON.stringify(error.data, null, 2))
+ }
+ }
+
+ // Test 3: Object content
+ console.log('\n🧪 Test 3: Object content')
+ try {
+ const result3 = await payload.create({
+ collection: 'posts',
+ data: {
+ title: 'Test Object Content',
+ slug: 'test-object-' + Date.now(),
+ content: {
+ type: 'root',
+ version: 1,
+ children: [{
+ type: 'paragraph',
+ version: 1,
+ children: [{
+ type: 'text',
+ version: 1,
+ text: 'This is a test paragraph.'
+ }]
+ }],
+ direction: null
+ },
+ publishedAt: new Date(),
+ status: 'draft',
+ },
+ })
+ console.log('✓ Object content worked:', result3.id)
+ await payload.delete({
+ collection: 'posts',
+ id: result3.id,
+ })
+ } catch (error: any) {
+ console.log('✗ Object content failed:', error.message)
+ if (error.data) {
+ console.error(' Validation errors:', JSON.stringify(error.data, null, 2))
+ }
+ }
+}
+
+testPostCreation().catch(console.error)
diff --git a/apps/backend/scripts/migration/test-payload-post2.ts b/apps/backend/scripts/migration/test-payload-post2.ts
new file mode 100644
index 0000000..1b7439a
--- /dev/null
+++ b/apps/backend/scripts/migration/test-payload-post2.ts
@@ -0,0 +1,107 @@
+#!/usr/bin/env tsx
+/**
+ * Test Payload Post Creation - Two Step Approach
+ */
+
+import { getPayload } from 'payload'
+import config from '@payload-config'
+
+async function testTwoStepPost() {
+ const payload = await getPayload({ config })
+
+ const testSlug = 'test-two-step-' + Date.now()
+ let postId = ''
+
+ // Step 1: Create post without content
+ console.log('\n🧪 Step 1: Create post without content')
+ try {
+ const result = await payload.create({
+ collection: 'posts',
+ data: {
+ title: 'Test Two Step Post',
+ slug: testSlug,
+ publishedAt: new Date(),
+ status: 'draft',
+ // No content field
+ },
+ })
+ console.log('✓ Post created without content:', result.id)
+ postId = result.id
+ } catch (error: any) {
+ console.log('✗ Failed:', error.message)
+ if (error.data) {
+ console.error(' Errors:', JSON.stringify(error.data, null, 2))
+ }
+ return
+ }
+
+ // Step 2: Update with content
+ console.log('\n🧪 Step 2: Update post with content (object)')
+ try {
+ const updated = await payload.update({
+ collection: 'posts',
+ id: postId,
+ data: {
+ content: {
+ type: 'root',
+ version: 1,
+ children: [{
+ type: 'paragraph',
+ version: 1,
+ children: [{
+ type: 'text',
+ version: 1,
+ text: 'This is a test paragraph.'
+ }]
+ }],
+ direction: null
+ },
+ },
+ })
+ console.log('✓ Post updated with object content:', updated.id)
+ } catch (error: any) {
+ console.log('✗ Object content failed:', error.message)
+ }
+
+ // Step 3: Try JSON string content
+ console.log('\n🧪 Step 3: Update with JSON string content')
+ try {
+ const updated = await payload.update({
+ collection: 'posts',
+ id: postId,
+ data: {
+ content: JSON.stringify({
+ type: 'root',
+ version: 1,
+ children: [{
+ type: 'paragraph',
+ version: 1,
+ children: [{
+ type: 'text',
+ version: 1,
+ text: 'This is a test paragraph from JSON string.'
+ }]
+ }],
+ direction: null
+ }),
+ },
+ })
+ console.log('✓ Post updated with JSON string content:', updated.id)
+ } catch (error: any) {
+ console.log('✗ JSON string content failed:', error.message)
+ }
+
+ // Cleanup
+ console.log('\n🧪 Cleanup: Delete test post')
+ try {
+ await payload.delete({
+ collection: 'posts',
+ id: postId,
+ })
+ console.log('✓ Test post deleted')
+ } catch (error: any) {
+ console.log('✗ Delete failed:', error.message)
+ }
+}
+
+testTwoStepPost().catch(console.error)
diff --git a/apps/backend/scripts/migration/transformers.ts b/apps/backend/scripts/migration/transformers.ts
new file mode 100644
index 0000000..6799b24
--- /dev/null
+++ b/apps/backend/scripts/migration/transformers.ts
@@ -0,0 +1,207 @@
+/**
+ * Data Transformers
+ * Story 1.3: Content Migration Script
+ *
+ * Transforms Webflow data to Payload CMS format
+ */
+
+import type {
+ PayloadCategory,
+ PayloadPostData,
+ PayloadPortfolioData,
+ WebflowCategory,
+ WebflowPost,
+ WebflowPortfolioItem,
+} from './types'
+import { toSlug, splitColorToTextBackground, truncate, htmlToPlainText, parseDate } from './utils'
+import { htmlToLexical } from './lexicalConverter'
+
+// ============================================================
+// CATEGORY TRANSFORMER
+// ============================================================
+
+/**
+ * Transform Webflow category to Payload CMS format
+ */
+export function transformCategory(
+ webflowCategory: WebflowCategory,
+ order: number = 0,
+): PayloadCategory {
+ const { textColor, backgroundColor } = splitColorToTextBackground(
+ webflowCategory.colorHex || '#ffffff',
+ )
+
+ return {
+ title: webflowCategory.name,
+ nameEn: '', // Can be manually set later
+ order,
+ textColor,
+ backgroundColor,
+ slug: webflowCategory.slug || toSlug(webflowCategory.name),
+ }
+}
+
+/**
+ * Transform multiple categories
+ */
+export function transformCategories(
+ webflowCategories: WebflowCategory[],
+): PayloadCategory[] {
+ return webflowCategories.map((cat, index) => transformCategory(cat, index))
+}
+
+// ============================================================
+// POST TRANSFORMER
+// ============================================================
+
+/**
+ * Transform Webflow post to Payload CMS format
+ */
+export function transformPost(webflowPost: WebflowPost): PayloadPostData {
+ // Generate excerpt from content if not provided
+ const excerpt = webflowPost.excerpt || htmlToPlainText(webflowPost.content, 200)
+
+ // Convert HTML to Lexical JSON string format (for richText field storage)
+ const lexicalContent = htmlToLexical(webflowPost.content || '')
+
+ return {
+ title: webflowPost.title,
+ slug: webflowPost.slug || toSlug(webflowPost.title),
+ heroImage: undefined, // Will be set by media handler
+ ogImage: undefined, // Will be set by media handler
+ content: lexicalContent as any, // Lexical JSON string for richText field
+ excerpt: truncate(excerpt, 200),
+ publishedAt: parseDate(webflowPost.publishedDate),
+ status: 'published',
+ categories: [], // Will be resolved after categories are migrated
+ meta: {
+ title: webflowPost.seoTitle || webflowPost.title,
+ description: webflowPost.seoDescription || excerpt,
+ image: undefined, // Will be set by media handler
+ },
+ }
+}
+
+/**
+ * Transform multiple posts
+ */
+export function transformPosts(webflowPosts: WebflowPost[]): PayloadPostData[] {
+ return webflowPosts.map((post) => transformPost(post))
+}
+
+// ============================================================
+// PORTFOLIO TRANSFORMER
+// ============================================================
+
+/**
+ * Transform Webflow portfolio item to Payload CMS format
+ */
+export function transformPortfolio(
+ webflowPortfolio: WebflowPortfolioItem,
+): PayloadPortfolioData {
+ return {
+ title: webflowPortfolio.name,
+ slug: webflowPortfolio.slug || toSlug(webflowPortfolio.name),
+ url: webflowPortfolio.websiteLink,
+ image: undefined, // Will be set by media handler
+ description: webflowPortfolio.description,
+ websiteType: webflowPortfolio.websiteType || 'other',
+ tags: parseTagsString(webflowPortfolio.tags),
+ }
+}
+
+/**
+ * Transform multiple portfolio items
+ */
+export function transformPortfolios(
+ webflowPortfolios: WebflowPortfolioItem[],
+): PayloadPortfolioData[] {
+ return webflowPortfolios.map((item) => transformPortfolio(item))
+}
+
+// ============================================================
+// HELPER FUNCTIONS
+// ============================================================
+
+/**
+ * Parse comma-separated tags into array
+ */
+function parseTagsString(tagsString: string): Array<{ tag: string }> {
+ if (!tagsString || typeof tagsString !== 'string') {
+ return []
+ }
+ return tagsString
+ .split(',')
+ .map((tag) => tag.trim())
+ .filter(Boolean)
+ .map((tag) => ({ tag }))
+}
+
+// ============================================================
+// VALIDATION FUNCTIONS
+// ============================================================
+
+/**
+ * Validate transformed category
+ */
+export function validateCategory(category: PayloadCategory): { valid: boolean; errors: string[] } {
+ const errors: string[] = []
+
+ if (!category.title) {
+ errors.push('Category title is required')
+ }
+ if (!category.slug) {
+ errors.push('Category slug is required')
+ }
+ if (!category.textColor || !category.backgroundColor) {
+ errors.push('Category colors are required')
+ }
+
+ return { valid: errors.length === 0, errors }
+}
+
+/**
+ * Validate transformed post
+ */
+export function validatePost(post: PayloadPostData): { valid: boolean; errors: string[] } {
+ const errors: string[] = []
+
+ if (!post.title) {
+ errors.push('Post title is required')
+ }
+ if (!post.slug) {
+ errors.push('Post slug is required')
+ }
+ if (!post.content) {
+ errors.push('Post content is required')
+ }
+ if (!post.publishedAt) {
+ errors.push('Post published date is required')
+ }
+
+ return { valid: errors.length === 0, errors }
+}
+
+/**
+ * Validate transformed portfolio item
+ */
+export function validatePortfolio(
+ portfolio: PayloadPortfolioData,
+): { valid: boolean; errors: string[] } {
+ const errors: string[] = []
+
+ if (!portfolio.title) {
+ errors.push('Portfolio title is required')
+ }
+ if (!portfolio.slug) {
+ errors.push('Portfolio slug is required')
+ }
+ if (!portfolio.url) {
+ errors.push('Portfolio URL is required')
+ }
+ if (!portfolio.websiteType) {
+ errors.push('Portfolio website type is required')
+ }
+
+ return { valid: errors.length === 0, errors }
+}
diff --git a/apps/backend/scripts/migration/types.ts b/apps/backend/scripts/migration/types.ts
new file mode 100644
index 0000000..6ee0079
--- /dev/null
+++ b/apps/backend/scripts/migration/types.ts
@@ -0,0 +1,159 @@
+/**
+ * Migration Script Types
+ * Story 1.3: Content Migration Script
+ */
+
+import { File } from 'payload'
+
+// Lexical content type (simplified)
+export interface LexicalRoot {
+ type: 'root'
+ version: 1
+ children: Array
+ direction: string | null
+}
+
+// ============================================================
+// WEBFLOW DATA TYPES (from HTML/JSON export)
+// ============================================================
+
+export interface WebflowPost {
+ title: string
+ slug: string
+ content: string // HTML content
+ publishedDate: string | Date
+ postCategory?: string // Category name or slug
+ featuredImage?: string // Image URL
+ seoTitle?: string
+ seoDescription?: string
+ excerpt?: string
+}
+
+export interface WebflowCategory {
+ name: string // Chinese name
+ slug: string
+ colorHex?: string // Single color to split into text + background
+}
+
+export interface WebflowPortfolioItem {
+ name: string
+ slug: string
+ websiteLink: string
+ previewImage: string // Image URL
+ description: string
+ websiteType: 'corporate' | 'ecommerce' | 'landing' | 'brand' | 'other'
+ tags: string // Comma-separated string
+}
+
+export interface WebflowExportData {
+ posts?: WebflowPost[]
+ categories?: WebflowCategory[]
+ portfolio?: WebflowPortfolioItem[]
+}
+
+// ============================================================
+// PAYLOAD CMS DATA TYPES
+// ============================================================
+
+export interface PayloadCategory {
+ title: string
+ nameEn?: string
+ order: number
+ textColor: string
+ backgroundColor: string
+ slug: string
+}
+
+export interface PayloadPostData {
+ title: string
+ slug: string
+ heroImage?: string // Media ID
+ ogImage?: string // Media ID
+ content: string // Lexical JSON string for richText field
+ excerpt?: string
+ publishedAt: Date
+ status: 'draft' | 'review' | 'published'
+ categories?: string[] // Category IDs
+ meta?: {
+ title?: string
+ description?: string
+ image?: string // Media ID
+ }
+}
+
+export interface PayloadPortfolioData {
+ title: string
+ slug: string
+ url: string
+ image?: string // Media ID
+ description?: string
+ websiteType: 'corporate' | 'ecommerce' | 'landing' | 'brand' | 'other'
+ tags?: Array<{ tag: string }>
+}
+
+// ============================================================
+// MIGRATION RESULT TYPES
+// ============================================================
+
+export interface MigrationResult {
+ success: boolean
+ id?: string
+ slug?: string
+ error?: string
+ skipped?: boolean
+}
+
+export interface CollectionMigrationResult {
+ collection: string
+ created: number
+ skipped: number
+ failed: number
+ results: Array<{
+ slug: string
+ success: boolean
+ id?: string
+ error?: string
+ }>
+}
+
+export interface MigrationReport {
+ timestamp: string
+ dryRun: boolean
+ summary: {
+ total: number
+ created: number
+ skipped: number
+ failed: number
+ }
+ byCollection: {
+ categories?: { created: number; skipped: number; failed: number }
+ posts?: { created: number; skipped: number; failed: number }
+ portfolio?: { created: number; skipped: number; failed: number }
+ }
+ details: {
+ categories?: CollectionMigrationResult
+ posts?: CollectionMigrationResult
+ portfolio?: CollectionMigrationResult
+ }
+}
+
+// ============================================================
+// MIGRATION CONFIG TYPES
+// ============================================================
+
+export interface MigrationConfig {
+ dryRun: boolean
+ verbose: boolean
+ collections: Array<'categories' | 'posts' | 'portfolio' | 'all'>
+ force: boolean // Overwrite existing items
+ batchSize: number // For batch processing
+ sourcePath: string // Path to HTML or JSON file
+}
+
+export interface MediaDownloadResult {
+ success: boolean
+ url: string
+ buffer?: Buffer
+ filename?: string
+ error?: string
+}
diff --git a/apps/backend/scripts/migration/update-hero-images-inline.ts b/apps/backend/scripts/migration/update-hero-images-inline.ts
new file mode 100644
index 0000000..6bd09e1
--- /dev/null
+++ b/apps/backend/scripts/migration/update-hero-images-inline.ts
@@ -0,0 +1,78 @@
+#!/usr/bin/env tsx
+import('dotenv/config')
+import('payload').then(async ({getPayload})=>{
+ const cfg = await import('../../src/payload.config.ts')
+ const p = await getPayload({config: cfg.default})
+
+ console.log('Loading media...')
+ const media = await p.find({collection:'media', limit:100, depth:0})
+
+ const filenameToId = new Map()
+ media.docs.forEach((m: any) => {
+ filenameToId.set(m.filename, m.id)
+ })
+
+ console.log(`Found ${filenameToId.size} media files`)
+
+ const { parseWebflowCSV } = await import('./csvParser.ts')
+ const { transformPosts } = await import('./transformers.ts')
+ const data = await parseWebflowCSV('/Users/pukpuk/Dev/website-enchun-mgr/恩群數位行銷 - 行銷放大鏡集.csv')
+
+ const posts = await p.find({collection:'posts', limit:100, depth:0})
+ const postsBySlug = new Map()
+ posts.docs.forEach((post: any) => {
+ postsBySlug.set(post.slug, post)
+ })
+
+ console.log('\nMatching hero images...\n')
+
+ let matched = 0
+ let updated = 0
+ let notFound = 0
+
+ for (const webflowPost of data.posts) {
+ const featuredImage = webflowPost.featuredImage
+ if (!featuredImage) continue
+
+ const urlParts = featuredImage.split('/')
+ const webflowFilename = urlParts[urlParts.length - 1]
+
+ let mediaId: string | null = null
+
+ for (const [filename, id] of filenameToId.entries()) {
+ // Match by checking if both contain the same hash (first 15 chars)
+ const webflowHash = webflowFilename.split('.')[0].substring(0, 15)
+ const payloadHash = filename.split('.')[0].substring(0, 15)
+ if (filename.includes(webflowHash) || webflowFilename.includes(payloadHash)) {
+ mediaId = id
+ matched++
+ break
+ }
+ }
+
+ if (!mediaId) {
+ notFound++
+ console.log(`No match: ${webflowPost.title?.substring(0, 40)}`)
+ console.log(` URL: ${webflowFilename.substring(0, 80)}`)
+ continue
+ }
+
+ const transformed = transformPosts([webflowPost])[0]
+ const post = postsBySlug.get(transformed.slug)
+
+ if (post && !post.heroImage) {
+ await p.update({
+ collection:'posts',
+ id: post.id,
+ data:{ heroImage: mediaId }
+ })
+ updated++
+ console.log(`Updated: ${webflowPost.title?.substring(0, 40)}`)
+ }
+ }
+
+ console.log('\n=== SUMMARY ===')
+ console.log(`Matched: ${matched}`)
+ console.log(`Updated: ${updated}`)
+ console.log(`Not found: ${notFound}`)
+}).catch(e=>console.error('Error:', e))
diff --git a/apps/backend/scripts/migration/update-hero-images.ts b/apps/backend/scripts/migration/update-hero-images.ts
new file mode 100644
index 0000000..a48cfd8
--- /dev/null
+++ b/apps/backend/scripts/migration/update-hero-images.ts
@@ -0,0 +1,105 @@
+#!/usr/bin/env tsx
+/**
+ * Update posts with heroImage by matching Webflow URLs to uploaded Media
+ */
+
+import { config as dotenvConfig } from 'dotenv'
+import { resolve, dirname } from 'path'
+import { fileURLToPath } from 'url'
+
+const __filename = fileURLToPath(import.meta.url)
+const __dirname = dirname(__filename)
+const envPath = resolve(__dirname, '../../.env')
+
+dotenvConfig({ path: envPath })
+
+// Debug
+console.log('Loading .env from:', envPath)
+console.log('PAYLOAD_SECRET loaded:', !!process.env.PAYLOAD_SECRET)
+
+import { getPayload } from 'payload'
+import config from '../../src/payload.config'
+import { parseWebflowCSV } from './csvParser'
+import { transformPosts } from './transformers'
+
+async function main() {
+ const payload = await getPayload({ config })
+
+ console.log('🔍 Loading media files...')
+ const media = await payload.find({ collection: 'media', limit: 100, depth: 0 })
+
+ // Create filename to ID mapping
+ const filenameToId = new Map()
+ media.docs.forEach((m: any) => {
+ filenameToId.set(m.filename, m.id)
+ })
+
+ console.log(`📁 Found ${filenameToId.size} media files`)
+
+ console.log('📂 Loading CSV data...')
+ const data = await parseWebflowCSV('/Users/pukpuk/Dev/website-enchun-mgr/恩群數位行銷 - 行銷放大鏡集.csv')
+
+ console.log('📝 Loading posts...')
+ const posts = await payload.find({ collection: 'posts', limit: 100, depth: 0 })
+ const postsBySlug = new Map()
+ posts.docs.forEach((post: any) => {
+ postsBySlug.set(post.slug, post)
+ })
+
+ console.log('\n🔗 Matching hero images...\n')
+
+ let matched = 0
+ let updated = 0
+ let notFound = 0
+
+ for (const webflowPost of data.posts) {
+ const featuredImage = webflowPost.featuredImage
+ if (!featuredImage) continue
+
+ // Extract filename from Webflow URL
+ const urlParts = featuredImage.split('/')
+ const webflowFilename = urlParts[urlParts.length - 1]
+
+ // Find matching media by comparing filename patterns
+ let mediaId: string | null = null
+
+ for (const [filename, id] of filenameToId.entries()) {
+ // Check if Webflow filename is contained in Payload filename or vice versa
+ // They may have different prefixes but the hash should match
+ if (filename.includes(webflowFilename.split('.')[0].substring(0, 15)) ||
+ webflowFilename.includes(filename.split('.')[0].substring(0, 15))) {
+ mediaId = id
+ matched++
+ break
+ }
+ }
+
+ if (!mediaId) {
+ notFound++
+ console.log(`❌ No match: ${webflowPost.title?.substring(0, 40)}`)
+ console.log(` URL: ${webflowFilename}`)
+ continue
+ }
+
+ // Find and update the post
+ const transformed = transformPosts([webflowPost])[0]
+ const post = postsBySlug.get(transformed.slug)
+
+ if (post && !post.heroImage) {
+ await payload.update({
+ collection: 'posts',
+ id: post.id,
+ data: { heroImage: mediaId },
+ })
+ updated++
+ console.log(`✓ Updated: ${webflowPost.title?.substring(0, 40)}`)
+ }
+ }
+
+ console.log('\n=== SUMMARY ===')
+ console.log(`Matched: ${matched}`)
+ console.log(`Updated: ${updated}`)
+ console.log(`Not found: ${notFound}`)
+}
+
+main().catch(console.error)
diff --git a/apps/backend/scripts/migration/utils.ts b/apps/backend/scripts/migration/utils.ts
new file mode 100644
index 0000000..f1113d4
--- /dev/null
+++ b/apps/backend/scripts/migration/utils.ts
@@ -0,0 +1,377 @@
+/**
+ * Migration Utilities
+ * Story 1.3: Content Migration Script
+ */
+
+import { MigrationConfig } from './types'
+
+// ============================================================
+// LOGGING UTILITIES
+// ============================================================
+
+export const colors = {
+ reset: '\x1b[0m',
+ bright: '\x1b[1m',
+ dim: '\x1b[2m',
+ red: '\x1b[31m',
+ green: '\x1b[32m',
+ yellow: '\x1b[33m',
+ blue: '\x1b[34m',
+ cyan: '\x1b[36m',
+ white: '\x1b[37m',
+}
+
+export class Logger {
+ private verbose: boolean
+
+ constructor(verbose: boolean = false) {
+ this.verbose = verbose
+ }
+
+ info(message: string): void {
+ console.log(`${colors.blue}ℹ${colors.reset} ${message}`)
+ }
+
+ success(message: string): void {
+ console.log(`${colors.green}✓${colors.reset} ${message}`)
+ }
+
+ error(message: string): void {
+ console.log(`${colors.red}✗${colors.reset} ${message}`)
+ }
+
+ warn(message: string): void {
+ console.log(`${colors.yellow}⚠${colors.reset} ${message}`)
+ }
+
+ debug(message: string): void {
+ if (this.verbose) {
+ console.log(`${colors.dim} →${colors.reset} ${message}`)
+ }
+ }
+
+ header(message: string): void {
+ console.log(`\n${colors.bright}${colors.cyan}${message}${colors.reset}`)
+ }
+
+ progress(current: number, total: number, message: string = ''): void {
+ const percent = Math.round((current / total) * 100)
+ const bar = '█'.repeat(Math.floor(percent / 2)) + '░'.repeat(50 - Math.floor(percent / 2))
+ process.stdout.write(
+ `\r${colors.cyan}[${bar}]${colors.reset} ${percent}% ${message}`.padEnd(100),
+ )
+ if (current === total) {
+ process.stdout.write('\n')
+ }
+ }
+}
+
+// ============================================================
+// STRING UTILITIES
+// ============================================================
+
+/**
+ * Convert any string to a URL-friendly slug
+ */
+export function toSlug(value: string): string {
+ return value
+ .toString()
+ .toLowerCase()
+ .trim()
+ .normalize('NFD') // Separate accented characters
+ .replace(/[\u0300-\u036f]/g, '') // Remove diacritics
+ .replace(/[^a-z0-9\u4e00-\u9fa5/-]/g, '-') // Replace non-alphanumeric with hyphen (keep Chinese)
+ .replace(/-+/g, '-') // Replace multiple hyphens with single
+ .replace(/^-+|-+$/g, '') // Trim hyphens from start/end
+}
+
+/**
+ * Extract filename from URL
+ */
+export function getFilenameFromUrl(url: string): string {
+ try {
+ const urlObj = new URL(url)
+ const pathname = urlObj.pathname
+ const filename = pathname.split('/').pop()
+ return filename || `file-${Date.now()}`
+ } catch {
+ return `file-${Date.now()}`
+ }
+}
+
+/**
+ * Get file extension from filename or URL
+ */
+export function getFileExtension(filename: string): string {
+ const match = filename.match(/\.([^.]+)$/)
+ return match ? match[1].toLowerCase() : 'jpg'
+}
+
+/**
+ * Parse comma-separated tags into array
+ */
+export function parseTagsString(tagsString: string): Array<{ tag: string }> {
+ if (!tagsString || typeof tagsString !== 'string') {
+ return []
+ }
+ return tagsString
+ .split(',')
+ .map((tag) => tag.trim())
+ .filter(Boolean)
+ .map((tag) => ({ tag }))
+}
+
+/**
+ * Convert hex color to text/background pair
+ * Uses luminance to determine if text should be black or white
+ */
+export function splitColorToTextBackground(
+ hexColor: string,
+): { textColor: string; backgroundColor: string } {
+ // Default to black text on white background
+ const defaultResult = {
+ textColor: '#000000',
+ backgroundColor: '#ffffff',
+ }
+
+ if (!hexColor) {
+ return defaultResult
+ }
+
+ // Ensure hex format
+ let hex = hexColor.replace('#', '')
+ if (hex.length === 3) {
+ hex = hex.split('').map((c) => c + c).join('')
+ }
+ if (hex.length !== 6) {
+ return defaultResult
+ }
+
+ // Calculate luminance
+ const r = parseInt(hex.substr(0, 2), 16) / 255
+ const g = parseInt(hex.substr(2, 2), 16) / 255
+ const b = parseInt(hex.substr(4, 2), 16) / 255
+
+ const luminance = 0.299 * r + 0.587 * g + 0.114 * b
+
+ // Use original color as background, choose contrasting text
+ return {
+ textColor: luminance > 0.5 ? '#000000' : '#ffffff',
+ backgroundColor: `#${hex}`,
+ }
+}
+
+/**
+ * Truncate text to max length
+ */
+export function truncate(text: string, maxLength: number): string {
+ if (!text || text.length <= maxLength) {
+ return text || ''
+ }
+ return text.substring(0, maxLength - 3) + '...'
+}
+
+// ============================================================
+// DATE UTILITIES
+// ============================================================
+
+/**
+ * Parse various date formats
+ */
+export function parseDate(dateValue: string | Date): Date {
+ if (dateValue instanceof Date) {
+ return dateValue
+ }
+ const parsed = new Date(dateValue)
+ if (isNaN(parsed.getTime())) {
+ return new Date() // Fallback to now
+ }
+ return parsed
+}
+
+/**
+ * Format date for display
+ */
+export function formatDate(date: Date): string {
+ return date.toISOString().split('T')[0]
+}
+
+// ============================================================
+// HTML CLEANING UTILITIES
+// ============================================================
+
+/**
+ * Clean HTML content by removing Webflow-specific classes and attributes
+ */
+export function cleanHTML(html: string): string {
+ if (!html) {
+ return ''
+ }
+
+ return html
+ // Remove Webflow-specific classes
+ .replace(/\sclass="[^"]*w-[^"]*"/g, '')
+ .replace(/\sclass="[^"]*wf-[^"]*"/g, '')
+ // Remove data attributes used by Webflow
+ .replace(/\sdata-[a-z-]+="[^"]*"/gi, '')
+ // Remove empty style attributes
+ .replace(/\sstyle=""/g, '')
+ // Clean up multiple spaces
+ .replace(/\s+/g, ' ')
+ .trim()
+}
+
+/**
+ * Extract plain text from HTML (for excerpts)
+ */
+export function htmlToPlainText(html: string, maxLength: number = 200): string {
+ if (!html) {
+ return ''
+ }
+
+ // Remove script and style tags
+ let text = html.replace(/]*>[\s\S]*?<\/script>/gi, '')
+ text = text.replace(/]*>[\s\S]*?<\/style>/gi, '')
+
+ // Replace block elements with newlines
+ text = text.replace(/<\/(div|p|h[1-6]|li|tr)>/gi, '\n')
+ text = text.replace(/<(br|hr)\s*\/?>/gi, '\n')
+
+ // Remove all other tags
+ text = text.replace(/<[^>]+>/g, '')
+
+ // Decode HTML entities
+ text = text.replace(/ /g, ' ')
+ text = text.replace(/&/g, '&')
+ text = text.replace(/</g, '<')
+ text = text.replace(/>/g, '>')
+ text = text.replace(/"/g, '"')
+ text = text.replace(/'/g, "'")
+
+ // Clean up whitespace
+ text = text.replace(/\n\s*\n/g, '\n\n').trim()
+
+ return truncate(text, maxLength)
+}
+
+// ============================================================
+// VALIDATION UTILITIES
+// ============================================================
+
+/**
+ * Check if a value is a valid URL
+ */
+export function isValidUrl(value: string): boolean {
+ try {
+ new URL(value)
+ return true
+ } catch {
+ return false
+ }
+}
+
+/**
+ * Check if a value is a valid image URL
+ */
+export function isValidImageUrl(value: string): boolean {
+ if (!isValidUrl(value)) {
+ return false
+ }
+ const ext = getFileExtension(value)
+ return ['jpg', 'jpeg', 'png', 'gif', 'webp', 'svg'].includes(ext)
+}
+
+// ============================================================
+// CONFIG UTILITIES
+// ============================================================
+
+/**
+ * Parse CLI arguments into MigrationConfig
+ */
+export function parseCliArgs(args: string[]): MigrationConfig {
+ const config: MigrationConfig = {
+ dryRun: false,
+ verbose: false,
+ collections: ['all'],
+ force: false,
+ batchSize: 5,
+ sourcePath: './data/webflow-export.json',
+ }
+
+ for (let i = 0; i < args.length; i++) {
+ const arg = args[i]
+ switch (arg) {
+ case '--dry-run':
+ case '-n':
+ config.dryRun = true
+ break
+ case '--verbose':
+ case '-v':
+ config.verbose = true
+ break
+ case '--force':
+ case '-f':
+ config.force = true
+ break
+ case '--collection':
+ case '-c':
+ if (args[i + 1]) {
+ const collection = args[++i]
+ if (collection === 'all') {
+ config.collections = ['all']
+ } else if (['categories', 'posts', 'portfolio'].includes(collection)) {
+ config.collections = [collection as any]
+ }
+ }
+ break
+ case '--source':
+ case '-s':
+ if (args[i + 1]) {
+ config.sourcePath = args[++i]
+ }
+ break
+ case '--batch-size':
+ if (args[i + 1]) {
+ config.batchSize = parseInt(args[++i], 10) || 5
+ }
+ break
+ case '--help':
+ case '-h':
+ printHelp()
+ process.exit(0)
+ }
+ }
+
+ return config
+}
+
+/**
+ * Print help message
+ */
+export function printHelp(): void {
+ console.log(`
+${colors.bright}Webflow to Payload CMS Migration Script${colors.reset}
+
+${colors.cyan}Usage:${colors.reset}
+ pnpm tsx scripts/migration/migrate.ts [options]
+
+${colors.cyan}Options:${colors.reset}
+ -n, --dry-run Run without making changes (preview mode)
+ -v, --verbose Show detailed logging output
+ -f, --force Overwrite existing items (skip deduplication)
+ -c, --collection Specific collection to migrate (categories|posts|portfolio|all)
+ -s, --source Path to HTML/JSON export file
+ --batch-size Number of items to process in parallel (default: 5)
+ -h, --help Show this help message
+
+${colors.cyan}Examples:${colors.reset}
+ pnpm tsx scripts/migration/migrate.ts --dry-run --verbose
+ pnpm tsx scripts/migration/migrate.ts --collection posts
+ pnpm tsx scripts/migration/migrate.ts --source ./data/export.json
+
+${colors.cyan}Environment Variables:${colors.reset}
+ PAYLOAD_CMS_URL Payload CMS URL (default: http://localhost:3000)
+ MIGRATION_ADMIN_EMAIL Admin user email for authentication
+ MIGRATION_ADMIN_PASSWORD Admin user password
+`)
+}
diff --git a/apps/backend/src/Home/config.ts b/apps/backend/src/Home/config.ts
new file mode 100644
index 0000000..b01799f
--- /dev/null
+++ b/apps/backend/src/Home/config.ts
@@ -0,0 +1,178 @@
+import type { GlobalConfig } from 'payload'
+
+import { adminOnly } from '../access/adminOnly'
+import { auditGlobalChange } from '../collections/Audit/hooks/auditHooks'
+import { revalidateHome } from './hooks/revalidateHome'
+
+export const Home: GlobalConfig = {
+ slug: 'home',
+ access: {
+ read: () => true,
+ update: adminOnly,
+ },
+ fields: [
+ // Hero Section
+ {
+ name: 'heroHeadline',
+ type: 'text',
+ required: true,
+ defaultValue: '創造企業更多發展的可能性\n是我們的使命',
+ admin: {
+ description: '首頁 Hero 主標題（支援換行）',
+ },
+ },
+ {
+ name: 'heroSubheadline',
+ type: 'text',
+ required: true,
+ defaultValue: "It's our destiny to create possibilities for your business.",
+ admin: {
+ description: '首頁 Hero 副標題（英文）',
+ },
+ },
+ {
+ name: 'heroDesktopVideo',
+ type: 'upload',
+ relationTo: 'media',
+ required: false,
+ admin: {
+ description: '桌面版 Hero 背景影片',
+ },
+ },
+ {
+ name: 'heroMobileVideo',
+ type: 'upload',
+ relationTo: 'media',
+ required: false,
+ admin: {
+ description: '手機版 Hero 背景影片（建議較小檔案以節省流量）',
+ },
+ },
+ {
+ name: 'heroFallbackImage',
+ type: 'upload',
+ relationTo: 'media',
+ required: false,
+ admin: {
+ description: '影片載入失敗時的備用圖片',
+ },
+ },
+ {
+ name: 'heroLogo',
+ type: 'upload',
+ relationTo: 'media',
+ required: false,
+ admin: {
+ description: 'Hero 區域顯示的 Logo（可選）',
+ },
+ },
+
+ // Service Features Section
+ {
+ name: 'serviceFeatures',
+ type: 'array',
+ fields: [
+ {
+ name: 'icon',
+ type: 'text',
+ required: true,
+ admin: {
+ description: '圖示（支援 SVG 或 Emoji，例如：🎯 或 ）',
+ },
+ },
+ {
+ name: 'title',
+ type: 'text',
+ required: true,
+ },
+ {
+ name: 'description',
+ type: 'textarea',
+ required: true,
+ },
+ {
+ name: 'link',
+ type: 'group',
+ fields: [
+ {
+ name: 'url',
+ type: 'text',
+ admin: {
+ description: '連結 URL（可選）',
+ },
+ },
+ ],
+ },
+ ],
+ maxRows: 4,
+ admin: {
+ initCollapsed: true,
+ },
+ },
+
+ // Portfolio Preview Section
+ {
+ name: 'portfolioSection',
+ type: 'group',
+ fields: [
+ {
+ name: 'headline',
+ type: 'text',
+ defaultValue: '精選案例',
+ required: true,
+ },
+ {
+ name: 'subheadline',
+ type: 'text',
+ defaultValue: '探索我們為客戶打造的優質網站',
+ required: false,
+ },
+ {
+ name: 'itemsToShow',
+ type: 'number',
+ defaultValue: 3,
+ min: 1,
+ max: 6,
+ admin: {
+ description: '顯示多少個作品項目',
+ },
+ },
+ ],
+ },
+
+ // CTA Section
+ {
+ name: 'ctaSection',
+ type: 'group',
+ fields: [
+ {
+ name: 'headline',
+ type: 'text',
+ defaultValue: '準備好開始新的旅程了嗎',
+ required: true,
+ },
+ {
+ name: 'description',
+ type: 'textarea',
+ defaultValue: '讓我們一起打造您的數位成功故事',
+ required: false,
+ },
+ {
+ name: 'buttonText',
+ type: 'text',
+ defaultValue: '聯絡我們',
+ required: true,
+ },
+ {
+ name: 'buttonLink',
+ type: 'text',
+ defaultValue: '/contact-us',
+ required: true,
+ },
+ ],
+ },
+ ],
+ hooks: {
+ afterChange: [revalidateHome, auditGlobalChange('home')],
+ },
+}
diff --git a/apps/backend/src/Home/hooks/revalidateHome.ts b/apps/backend/src/Home/hooks/revalidateHome.ts
new file mode 100644
index 0000000..89ea6c8
--- /dev/null
+++ b/apps/backend/src/Home/hooks/revalidateHome.ts
@@ -0,0 +1,14 @@
+import type { GlobalAfterChangeHook } from 'payload'
+
+import { revalidateTag } from 'next/cache'
+
+export const revalidateHome: GlobalAfterChangeHook = async ({ doc, req }) => {
+ const { payload, context } = req
+ if (!context.disableRevalidate) {
+ payload.logger.info(`Revalidating home`)
+
+ revalidateTag('global_home')
+ }
+
+ return doc
+}
diff --git a/apps/backend/src/collections/Audit/hooks/auditHooks.ts b/apps/backend/src/collections/Audit/hooks/auditHooks.ts
index ad47bee..68302c4 100644
--- a/apps/backend/src/collections/Audit/hooks/auditHooks.ts
+++ b/apps/backend/src/collections/Audit/hooks/auditHooks.ts
@@ -8,13 +8,16 @@ import { logDocumentChange } from '@/utilities/auditLogger'
*/
export const auditChange =
(collection: string): AfterChangeHook =>
- async ({ doc, req }) => {
+ async ({ doc, req, context }) => {
// 跳過 audit 集合本身以避免無限循環
if (collection === 'audit') return doc
+ // Determine operation from context or default to 'update'
+ const operation = (context?.operation as 'create' | 'update' | 'delete') || 'update'
+
await logDocumentChange(
req,
- operation as 'create' | 'update' | 'delete',
+ operation,
collection,
doc.id as string,
(doc.title || doc.name || String(doc.id)) as string,
diff --git a/apps/backend/src/collections/Posts/index.ts b/apps/backend/src/collections/Posts/index.ts
index c37fca0..fe6f8ab 100644
--- a/apps/backend/src/collections/Posts/index.ts
+++ b/apps/backend/src/collections/Posts/index.ts
@@ -111,7 +111,7 @@ export const Posts: CollectionConfig<'posts'> = {
},
}),
label: false,
- required: true,
+ required: false, // Temporarily disabled for migration
},
{
name: 'excerpt',
diff --git a/apps/backend/src/payload-types.ts b/apps/backend/src/payload-types.ts
index 9f79c21..bc187aa 100644
--- a/apps/backend/src/payload-types.ts
+++ b/apps/backend/src/payload-types.ts
@@ -103,10 +103,12 @@ export interface Config {
globals: {
header: Header;
footer: Footer;
+ home: Home;
};
globalsSelect: {
header: HeaderSelect | HeaderSelect;
footer: FooterSelect | FooterSelect;
+ home: HomeSelect | HomeSelect;
};
locale: null;
user: User & {
@@ -220,7 +222,7 @@ export interface Post {
* Facebook/LINE 分享時顯示的預覽圖，建議 1200x630px
*/
ogImage?: (string | null) | Media;
- content: {
+ content?: {
root: {
type: string;
children: {
@@ -234,7 +236,7 @@ export interface Post {
version: number;
};
[k: string]: unknown;
- };
+ } | null;
/**
* 顯示在文章列表頁，建議 150-200 字
*/
@@ -1410,6 +1412,70 @@ export interface Footer {
updatedAt?: string | null;
createdAt?: string | null;
}
+/**
+ * This interface was referenced by `Config`'s JSON-Schema
+ * via the `definition` "home".
+ */
+export interface Home {
+ id: string;
+ /**
+ * 首頁 Hero 主標題（支援換行）
+ */
+ heroHeadline: string;
+ /**
+ * 首頁 Hero 副標題（英文）
+ */
+ heroSubheadline: string;
+ /**
+ * 桌面版 Hero 背景影片
+ */
+ heroDesktopVideo?: (string | null) | Media;
+ /**
+ * 手機版 Hero 背景影片（建議較小檔案以節省流量）
+ */
+ heroMobileVideo?: (string | null) | Media;
+ /**
+ * 影片載入失敗時的備用圖片
+ */
+ heroFallbackImage?: (string | null) | Media;
+ /**
+ * Hero 區域顯示的 Logo（可選）
+ */
+ heroLogo?: (string | null) | Media;
+ serviceFeatures?:
+ | {
+ /**
+ * 圖示（支援 SVG 或 Emoji，例如：🎯 或 ）
+ */
+ icon: string;
+ title: string;
+ description: string;
+ link?: {
+ /**
+ * 連結 URL（可選）
+ */
+ url?: string | null;
+ };
+ id?: string | null;
+ }[]
+ | null;
+ portfolioSection: {
+ headline: string;
+ subheadline?: string | null;
+ /**
+ * 顯示多少個作品項目
+ */
+ itemsToShow?: number | null;
+ };
+ ctaSection: {
+ headline: string;
+ description?: string | null;
+ buttonText: string;
+ buttonLink: string;
+ };
+ updatedAt?: string | null;
+ createdAt?: string | null;
+}
/**
* This interface was referenced by `Config`'s JSON-Schema
* via the `definition` "header_select".
@@ -1470,6 +1536,49 @@ export interface FooterSelect {
createdAt?: T;
globalType?: T;
}
+/**
+ * This interface was referenced by `Config`'s JSON-Schema
+ * via the `definition` "home_select".
+ */
+export interface HomeSelect {
+ heroHeadline?: T;
+ heroSubheadline?: T;
+ heroDesktopVideo?: T;
+ heroMobileVideo?: T;
+ heroFallbackImage?: T;
+ heroLogo?: T;
+ serviceFeatures?:
+ | T
+ | {
+ icon?: T;
+ title?: T;
+ description?: T;
+ link?:
+ | T
+ | {
+ url?: T;
+ };
+ id?: T;
+ };
+ portfolioSection?:
+ | T
+ | {
+ headline?: T;
+ subheadline?: T;
+ itemsToShow?: T;
+ };
+ ctaSection?:
+ | T
+ | {
+ headline?: T;
+ description?: T;
+ buttonText?: T;
+ buttonLink?: T;
+ };
+ updatedAt?: T;
+ createdAt?: T;
+ globalType?: T;
+}
/**
* This interface was referenced by `Config`'s JSON-Schema
* via the `definition` "TaskCleanup-audit-logs".
diff --git a/apps/backend/src/payload.config.ts b/apps/backend/src/payload.config.ts
index 26ed353..1b94f78 100644
--- a/apps/backend/src/payload.config.ts
+++ b/apps/backend/src/payload.config.ts
@@ -14,6 +14,7 @@ import { Portfolio } from './collections/Portfolio'
import { Posts } from './collections/Posts'
import { Users } from './collections/Users'
import { Footer } from './Footer/config'
+import { Home } from './Home/config'
import { Header } from './Header/config'
import { plugins } from './plugins'
import { defaultLexical } from '@/fields/defaultLexical'
@@ -71,7 +72,7 @@ export default buildConfig({
'http://localhost:4321', // Astro dev server
'http://localhost:8788', // Wrangler Pages dev server
].filter(Boolean),
- globals: [Header, Footer],
+ globals: [Header, Footer, Home],
email: resendAdapter({
defaultFromAddress: 'dev@resend.com',
defaultFromName: '恩群數位行銷',