Merging Multi-Form Email Writer

netlify/functions/status.ts

@@ -0,0 +1,127 @@
+// SVELTEKIT SUBSTITUTE: Removed SvelteKit imports and replaced with Netlify Function structure
+// SVELTEKIT SUBSTITUTE: Changed from '@sveltejs/kit' to standard Response objects
+// SVELTEKIT SUBSTITUTE: Changed import paths to netlify/functions
+
+import { JobStorage } from './storage'
+import { prepareResponse } from './write'
+
+// SVELTEKIT SUBSTITUTE: Converted to Netlify Function handler
+export const handler = async (event: any, context: any) => {
+	// SVELTEKIT SUBSTITUTE: Handle CORS for browser requests
+	const headers = {
+		'Content-Type': 'application/json',
+		'Access-Control-Allow-Origin': '*',
+		'Access-Control-Allow-Headers': 'Content-Type',
+		'Access-Control-Allow-Methods': 'GET, POST, OPTIONS'
+	}
+
+	// Handle preflight requests
+	if (event.httpMethod === 'OPTIONS') {
+		return {
+			statusCode: 200,
+			headers,
+			body: ''
+		}
+	}
+
+	// Handle GET requests
+	if (event.httpMethod === 'GET') {
+		// SVELTEKIT SUBSTITUTE: Parse query parameters from event instead of url.searchParams
+		const jobId = event.queryStringParameters?.jobId
+
+		if (!jobId) {
+			return {
+				statusCode: 400,
+				headers,
+				body: JSON.stringify({ error: 'Job ID is required' })
+			}
+		}
+
+		try {
+			const jobData = await JobStorage.getJob(jobId)
+
+			if (!jobData) {
+				return {
+					statusCode: 404,
+					headers,
+					body: JSON.stringify({ error: 'Job not found' })
+				}
+			}
+
+			// Prepare response using your existing function
+			const response = prepareResponse(jobData.writeState)
+
+			return {
+				statusCode: 200,
+				headers,
+				body: JSON.stringify({
+					...response,
+					jobId,
+					status: jobData.status,
+					error: jobData.error,
+					createdAt: jobData.createdAt,
+					completedAt: jobData.completedAt
+				})
+			}
+		} catch (error) {
+			console.error('Error checking job status:', error)
+			return {
+				statusCode: 500,
+				headers,
+				body: JSON.stringify({ error: 'Internal server error' })
+			}
+		}
+	}
+
+	// Handle POST requests (for compatibility)
+	if (event.httpMethod === 'POST') {
+		try {
+			const { jobId } = JSON.parse(event.body || '{}')
+
+			if (!jobId) {
+				return {
+					statusCode: 400,
+					headers,
+					body: JSON.stringify({ error: 'Job ID is required' })
+				}
+			}
+
+			const jobData = await JobStorage.getJob(jobId)
+
+			if (!jobData) {
+				return {
+					statusCode: 404,
+					headers,
+					body: JSON.stringify({ error: 'Job not found' })
+				}
+			}
+
+			const response = prepareResponse(jobData.writeState)
+
+			return {
+				statusCode: 200,
+				headers,
+				body: JSON.stringify({
+					...response,
+					jobId,
+					status: jobData.status,
+					error: jobData.error
+				})
+			}
+		} catch (error) {
+			console.error('Error checking job status:', error)
+			return {
+				statusCode: 500,
+				headers,
+				body: JSON.stringify({ error: 'Internal server error' })
+			}
+		}
+	}
+
+	// Handle unsupported methods
+	return {
+		statusCode: 405,
+		headers,
+		body: JSON.stringify({ error: 'Method not allowed' })
+	}
+}

netlify/functions/storage.ts

@@ -0,0 +1,111 @@
+// SVELTEKIT SUBSTITUTE: This file already uses Netlify Blobs correctly, minimal changes needed
+// SVELTEKIT SUBSTITUTE: Fixed initialization to properly handle Netlify Functions environment
+
+let jobStore: any = null
+
+async function getJobStore() {
+	if (!jobStore) {
+		const { getStore } = await import('@netlify/blobs')
+		jobStore = getStore('email-jobs')
+	}
+	return jobStore
+}
+
+// Storage interface functions
+export const JobStorage = {
+	// Create new job entry
+	async createJob(jobId: string, initialWriteState: any) {
+		const store = await getJobStore() // SVELTEKIT SUBSTITUTE: Ensure store is initialized
+		const jobData = {
+			jobId,
+			status: 'pending',
+			writeState: initialWriteState,
+			createdAt: new Date().toISOString(),
+			error: null,
+			completedAt: null
+		}
+
+		await store.set(jobId, JSON.stringify(jobData))
+		return jobData
+	},
+
+	// Get job by ID
+	async getJob(jobId: string) {
+		try {
+			const store = await getJobStore() // SVELTEKIT SUBSTITUTE: Ensure store is initialized
+			const data = await store.get(jobId)
+			if (!data) return null
+			return JSON.parse(data)
+		} catch (error) {
+			console.error('Error retrieving job:', error)
+			return null
+		}
+	},
+
+	// Update job status
+	async updateJobStatus(jobId: string, status: string, error: string | null = null) {
+		const jobData = await this.getJob(jobId)
+		if (!jobData) throw new Error(`Job ${jobId} not found`)
+
+		jobData.status = status
+		jobData.error = error
+
+		if (status === 'completed' || status === 'failed') {
+			jobData.completedAt = new Date().toISOString()
+		}
+
+		const store = await getJobStore() // SVELTEKIT SUBSTITUTE: Ensure store is initialized
+		await store.set(jobId, JSON.stringify(jobData))
+		return jobData
+	},
+
+	// Update WriteState for job
+	async updateWriteState(jobId: string, newWriteState: any) {
+		const jobData = await this.getJob(jobId)
+		if (!jobData) throw new Error(`Job ${jobId} not found`)
+
+		jobData.writeState = newWriteState
+		jobData.status = 'processing'
+
+		const store = await getJobStore() // SVELTEKIT SUBSTITUTE: Ensure store is initialized
+		await store.set(jobId, JSON.stringify(jobData))
+		return jobData
+	},
+
+	// Complete job with final results
+	async completeJob(jobId: string, finalWriteState: any) {
+		const jobData = await this.getJob(jobId)
+		if (!jobData) throw new Error(`Job ${jobId} not found`)
+
+		jobData.writeState = finalWriteState
+		jobData.status = 'completed'
+		jobData.completedAt = new Date().toISOString()
+
+		const store = await getJobStore() // SVELTEKIT SUBSTITUTE: Ensure store is initialized
+		await store.set(jobId, JSON.stringify(jobData))
+		return jobData
+	},
+
+	// Mark job as failed
+	async failJob(jobId: string, errorMessage: string) {
+		return await this.updateJobStatus(jobId, 'failed', errorMessage)
+	},
+
+	// Delete job (cleanup)
+	async deleteJob(jobId: string) {
+		const store = await getJobStore() // SVELTEKIT SUBSTITUTE: Ensure store is initialized
+		await store.delete(jobId)
+	},
+
+	// List all jobs (for debugging/admin)
+	async listJobs() {
+		const store = await getJobStore() // SVELTEKIT SUBSTITUTE: Ensure store is initialized
+		const { blobs } = await store.list()
+		return blobs.map((blob: any) => blob.key)
+	}
+}
+
+// Utility function to generate unique job IDs
+export function generateJobId(): string {
+	return `job_${Date.now()}_${Math.random().toString(36).substr(2, 9)}`
+}