Hi

\"\n});\n```\n\n## Val Town Utility Functions\n\nVal Town provides several utility functions to help with common project tasks.\n\n### Importing Utilities\n\nAlways import utilities with version pins to avoid breaking changes:\n\n```ts\nimport { parseProject, readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n```\n\n### Available Utilities\n\n\n#### **serveFile** - Serve project files with proper content types\n\nFor example, in Hono:\n\n```ts\n// serve all files in frontend/ and shared/\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n```\n\n#### **readFile** - Read files from within the project:\n\n```ts\n// Read a file from the project\nconst fileContent = await readFile(\"/frontend/index.html\", import.meta.url);\n```\n\n#### **listFiles** - List all files in the project\n\n```ts\nconst files = await listFiles(import.meta.url);\n```\n\n#### **parseProject** - Extract information about the current project from import.meta.url\n\nThis is useful for including info for linking back to a val, ie in \"view source\" urls:\n\n```ts\nconst projectVal = parseProject(import.meta.url);\nconsole.log(projectVal.username); // Owner of the project\nconsole.log(projectVal.name); // Project name\nconsole.log(projectVal.version); // Version number\nconsole.log(projectVal.branch); // Branch name\nconsole.log(projectVal.links.self.project); // URL to the project page\n```\n\nHowever, it's *extremely importing* to note that `parseProject` and other Standard Library utilities ONLY RUN ON THE SERVER.\nIf you need access to this data on the client, run it in the server and pass it to the client by splicing it into the HTML page\nor by making an API request for it.\n\n## Val Town Platform Specifics\n\n- **Redirects:** Use `return new Response(null, { status: 302, headers: { Location: \"/place/to/redirect\" }})` instead of `Response.redirect` which is broken\n- **Images:** Avoid external images or base64 images. Use emojis, unicode symbols, or icon fonts/libraries instead\n- **AI Image:** To inline generate an AI image use: `

`\n- **Storage:** DO NOT use the Deno KV module for storage\n- **Browser APIs:** DO NOT use the `alert()`, `prompt()`, or `confirm()` methods\n- **Weather Data:** Use open-meteo for weather data (doesn't require API keys) unless otherwise specified\n- **View Source:** Add a view source link by importing & using `import.meta.url.replace(\"ems.sh\", \"val.town)\"` (or passing this data to the client) and include `target=\"_top\"` attribute\n- **Error Debugging:** Add `` to HTML to capture client-side errors\n- **Error Handling:** Only use try...catch when there's a clear local resolution; Avoid catches that merely log or return 500s. Let errors bubble up with full context\n- **Environment Variables:** Use `Deno.env.get('keyname')` when you need to, but generally prefer APIs that don't require keys\n- **Imports:** Use `https://esm.sh` for npm and Deno dependencies to ensure compatibility on server and browser\n- **Storage Strategy:** Only use backend storage if explicitly required; prefer simple static client-side sites\n- **React Configuration:** When using React libraries, pin versions with `?deps=react@18.2.0,react-dom@18.2.0` and start the file with `/** @jsxImportSource https://esm.sh/react@18.2.0 */`\n- Ensure all React dependencies and sub-dependencies are pinned to the same version\n- **Styling:** Default to using TailwindCSS via `` unless otherwise specified\n\n## Project Structure and Design Patterns\n\n### Recommended Directory Structure\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Schema definitions\n│ │ ├── queries.ts # DB query functions\n│ │ └── README.md\n│ └── routes/ # Route modules\n│ ├── [route].ts\n│ └── static.ts # Static file serving\n│ ├── index.ts # Main entry point\n│ └── README.md\n├── frontend/\n│ ├── components/\n│ │ ├── App.tsx\n│ │ └── [Component].tsx\n│ ├── favicon.svg\n│ ├── index.html # Main HTML template\n│ ├── index.tsx # Frontend JS entry point\n│ ├── README.md\n│ └── style.css\n├── README.md\n└── shared/\n ├── README.md\n └── utils.ts # Shared types and functions\n```\n\n### Backend (Hono) Best Practices\n\n- Hono is the recommended API framework\n- Main entry point should be `backend/index.ts`\n- **Static asset serving:** Use the utility functions to read and serve project files:\n ```ts\n import { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\n \n // serve all files in frontend/ and shared/\n app.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\n app.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n \n // For index.html, often you'll want to bootstrap with initial data\n app.get(\"/\", async c => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Inject data to avoid extra round-trips\n const initialData = await fetchInitialData();\n const dataScript = ``;\n \n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n });\n ```\n- Create RESTful API routes for CRUD operations\n- Always include this snippet at the top-level Hono app to re-throwing errors to see full stack traces:\n ```ts\n // Unwrap Hono errors to see original error details\n app.onError((err, c) => {\n throw err;\n });\n ```\n\n### Database Patterns\n- Run migrations on startup or comment out for performance\n- Change table names when modifying schemas rather than altering\n- Export clear query functions with proper TypeScript typing\n\n## Common Gotchas and Solutions\n\n1. **Environment Limitations:** \n - Val Town runs on Deno in a serverless context, not Node.js\n - Code in `shared/` must work in both frontend and backend environments\n - Cannot use `Deno` keyword in shared code\n - Use `https://esm.sh` for imports that work in both environments\n\n2. **SQLite Peculiarities:**\n - Limited support for ALTER TABLE operations\n - Create new tables with updated schemas and copy data when needed\n - Always run table creation before querying\n\n3. **React Configuration:**\n - All React dependencies must be pinned to 18.2.0\n - Always include `@jsxImportSource https://esm.sh/react@18.2.0` at the top of React files\n - Rendering issues often come from mismatched React versions\n\n4. **File Handling:**\n - Val Town only supports text files, not binary\n - Use the provided utilities to read files across branches and forks\n - For files in the project, use `readFile` helpers\n\n5. **API Design:**\n - `fetch` handler is the entry point for HTTP vals\n - Run the Hono app with `export default app.fetch // This is the entry point for HTTP vals`\n\n",[],[173],{"_104":181,"_95":99,"_153":182,"_155":-5,"_156":138,"_157":183,"_159":160,"_106":184,"_100":32,"_162":185,"_164":186,"_166":22,"_167":-5,"_168":187,"_98":188},"7c2de338-8e96-11f0-88eb-0224a6c84d84","7c2de414-8e96-11f0-88eb-0224a6c84d84",6,["D",1757543742803],"script","// auth.ts - JWT Authentication system for RankWatch\n\nimport { create, getNumericDate, verify } from \"https://deno.land/x/djwt@v3.0.1/mod.ts\";\nimport { encodeBase64 } from \"https://deno.land/std@0.208.0/encoding/base64.ts\";\nimport { config, type UserPlan } from \"./config.ts\";\nimport { getDatabase } from \"./database.ts\";\n\n// Hash password using Web Crypto API\nexport async function hashPassword(password: string): Promise {\n const encoder = new TextEncoder();\n const data = encoder.encode(password);\n const hashBuffer = await crypto.subtle.digest(\"SHA-256\", data);\n return encodeBase64(new Uint8Array(hashBuffer));\n}\n\n// Verify password\nexport async function verifyPassword(password: string, hash: string): Promise {\n const hashedPassword = await hashPassword(password);\n return hashedPassword === hash;\n}\n\n// Generate API key\nexport function generateApiKey(): string {\n const array = new Uint8Array(32);\n crypto.getRandomValues(array);\n return encodeBase64(array);\n}\n\n// JWT token creation\nexport async function createJWT(userId: number, email: string, plan: UserPlan): Promise {\n const payload = {\n user_id: userId,\n email,\n plan,\n exp: getNumericDate(new Date(Date.now() + 7 * 24 * 60 * 60 * 1000)), // 7 days\n iat: getNumericDate(new Date()),\n };\n\n const key = await crypto.subtle.importKey(\n \"raw\",\n new TextEncoder().encode(config.jwt.secret),\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\", \"verify\"]\n );\n\n return await create({ alg: \"HS256\", typ: \"JWT\" }, payload, key);\n}\n\n// Verify JWT token\nexport async function verifyJWT(token: string): Promise {\n try {\n const key = await crypto.subtle.importKey(\n \"raw\",\n new TextEncoder().encode(config.jwt.secret),\n { name: \"HMAC\", hash: \"SHA-256\" },\n false,\n [\"sign\", \"verify\"]\n );\n\n const payload = await verify(token, key);\n return payload;\n } catch (error) {\n throw new Error(\"Invalid token\");\n }\n}\n\n// User interface\nexport interface User {\n id: number;\n email: string;\n plan: UserPlan;\n api_key?: string;\n created_at: string;\n}\n\n// Register new user\nexport async function registerUser(email: string, password: string, plan: UserPlan = \"freemium\"): Promise<{ user: User; token: string }> {\n const db = getDatabase();\n \n // Check if user already exists\n const existingUser = await db.execute({\n sql: \"SELECT id FROM users WHERE email = ? AND deleted_at IS NULL\",\n args: [email],\n });\n\n if (existingUser.rows.length > 0) {\n throw new Error(\"User already exists\");\n }\n\n // Hash password and generate API key\n const passwordHash = await hashPassword(password);\n const apiKey = generateApiKey();\n\n // Insert user\n const result = await db.execute({\n sql: `INSERT INTO users (email, password_hash, plan, api_key) \n VALUES (?, ?, ?, ?) RETURNING id, email, plan, api_key, created_at`,\n args: [email, passwordHash, plan, apiKey],\n });\n\n const userData = result.rows[0];\n const user: User = {\n id: userData[0] as number,\n email: userData[1] as string,\n plan: userData[2] as UserPlan,\n api_key: userData[3] as string,\n created_at: userData[4] as string,\n };\n\n // Create JWT token\n const token = await createJWT(user.id, user.email, user.plan);\n\n return { user, token };\n}\n\n// Login user\nexport async function loginUser(email: string, password: string): Promise<{ user: User; token: string }> {\n const db = getDatabase();\n \n // Get user\n const result = await db.execute({\n sql: \"SELECT id, email, password_hash, plan, api_key, created_at FROM users WHERE email = ? AND deleted_at IS NULL\",\n args: [email],\n });\n\n if (result.rows.length === 0) {\n throw new Error(\"User not found\");\n }\n\n const userData = result.rows[0];\n const passwordHash = userData[2] as string;\n\n // Verify password\n const isValidPassword = await verifyPassword(password, passwordHash);\n if (!isValidPassword) {\n throw new Error(\"Invalid password\");\n }\n\n const user: User = {\n id: userData[0] as number,\n email: userData[1] as string,\n plan: userData[3] as UserPlan,\n api_key: userData[4] as string,\n created_at: userData[5] as string,\n };\n\n // Create JWT token\n const token = await createJWT(user.id, user.email, user.plan);\n\n return { user, token };\n}\n\n// Get user by ID\nexport async function getUserById(userId: number): Promise {\n const db = getDatabase();\n \n const result = await db.execute({\n sql: \"SELECT id, email, plan, api_key, created_at FROM users WHERE id = ? AND deleted_at IS NULL\",\n args: [userId],\n });\n\n if (result.rows.length === 0) {\n return null;\n }\n\n const userData = result.rows[0];\n return {\n id: userData[0] as number,\n email: userData[1] as string,\n plan: userData[2] as UserPlan,\n api_key: userData[3] as string,\n created_at: userData[4] as string,\n };\n}\n\n// Middleware to extract user from Authorization header\nexport async function extractUserFromToken(authHeader: string): Promise {\n if (!authHeader || !authHeader.startsWith(\"Bearer \")) {\n throw new Error(\"Missing or invalid authorization header\");\n }\n\n const token = authHeader.substring(7); // Remove \"Bearer \" prefix\n const payload = await verifyJWT(token);\n \n const user = await getUserById(payload.user_id);\n if (!user) {\n throw new Error(\"User not found\");\n }\n\n return user;\n}",[],[99],{"_104":190,"_95":191,"_153":192,"_155":-5,"_156":138,"_157":193,"_159":160,"_106":194,"_100":32,"_162":185,"_164":195,"_166":22,"_167":-5,"_168":196,"_98":197},"b0df238a-8e96-11f0-bee6-0224a6c84d84","authApi.ts","b0df2420-8e96-11f0-bee6-0224a6c84d84",9,["D",1757543831197],"// authApi.ts - Authentication API endpoints for RankWatch\n\nimport { Hono } from \"https://deno.land/x/hono@v3.12.6/mod.ts\";\nimport { cors } from \"https://deno.land/x/hono@v3.12.6/middleware.ts\";\nimport { registerUser, loginUser, getUserById, extractUserFromToken } from \"./auth.ts\";\nimport { createSuccessResponse, createErrorResponse, parseJsonBody, validateRequiredFields, isValidEmail, isValidPassword, logRequest } from \"./utils.ts\";\nimport { rateLimitMiddleware, checkRateLimit, getRateLimitHeaders } from \"./rateLimit.ts\";\nimport { initializeDatabase } from \"./database.ts\";\n\nconst app = new Hono();\n\n// CORS middleware\napp.use(\"*\", cors({\n origin: \"*\",\n allowMethods: [\"GET\", \"POST\", \"PUT\", \"DELETE\", \"OPTIONS\"],\n allowHeaders: [\"Content-Type\", \"Authorization\"],\n}));\n\n// Initialize database on startup\nlet dbInitialized = false;\nasync function ensureDatabase() {\n if (!dbInitialized) {\n await initializeDatabase();\n dbInitialized = true;\n }\n}\n\n// POST /auth/register - Create new user account\napp.post(\"/auth/register\", async (c) => {\n await ensureDatabase();\n logRequest(c.req.raw);\n\n try {\n const body = await parseJsonBody(c.req.raw);\n \n // Validate required fields\n const validation = validateRequiredFields(body, [\"email\", \"password\"]);\n if (!validation.valid) {\n return createErrorResponse(`Missing required fields: ${validation.missing?.join(\", \")}`, 400);\n }\n\n const { email, password, plan = \"freemium\" } = body;\n\n // Validate email format\n if (!isValidEmail(email)) {\n return createErrorResponse(\"Invalid email format\", 400);\n }\n\n // Validate password strength\n const passwordValidation = isValidPassword(password);\n if (!passwordValidation.valid) {\n return createErrorResponse(passwordValidation.message!, 400);\n }\n\n // Validate plan\n if (plan !== \"freemium\" && plan !== \"unlimited\") {\n return createErrorResponse(\"Invalid plan. Must be 'freemium' or 'unlimited'\", 400);\n }\n\n // Register user\n const result = await registerUser(email, password, plan);\n \n return createSuccessResponse({\n user: {\n id: result.user.id,\n email: result.user.email,\n plan: result.user.plan,\n created_at: result.user.created_at,\n },\n token: result.token,\n }, \"User registered successfully\");\n\n } catch (error) {\n console.error(\"Registration error:\", error);\n return createErrorResponse(error.message || \"Registration failed\", 400);\n }\n});\n\n// POST /auth/login - Authenticate user\napp.post(\"/auth/login\", async (c) => {\n await ensureDatabase();\n logRequest(c.req.raw);\n\n try {\n const body = await parseJsonBody(c.req.raw);\n \n // Validate required fields\n const validation = validateRequiredFields(body, [\"email\", \"password\"]);\n if (!validation.valid) {\n return createErrorResponse(`Missing required fields: ${validation.missing?.join(\", \")}`, 400);\n }\n\n const { email, password } = body;\n\n // Validate email format\n if (!isValidEmail(email)) {\n return createErrorResponse(\"Invalid email format\", 400);\n }\n\n // Login user\n const result = await loginUser(email, password);\n \n return createSuccessResponse({\n user: {\n id: result.user.id,\n email: result.user.email,\n plan: result.user.plan,\n created_at: result.user.created_at,\n },\n token: result.token,\n }, \"Login successful\");\n\n } catch (error) {\n console.error(\"Login error:\", error);\n return createErrorResponse(error.message || \"Login failed\", 401);\n }\n});\n\n// GET /auth/me - Get current user info\napp.get(\"/auth/me\", async (c) => {\n await ensureDatabase();\n \n try {\n const authHeader = c.req.header(\"authorization\");\n if (!authHeader) {\n return createErrorResponse(\"Authorization header required\", 401);\n }\n\n const user = await extractUserFromToken(authHeader);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/auth/me\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n \n const response = createSuccessResponse({\n id: user.id,\n email: user.email,\n plan: user.plan,\n created_at: user.created_at,\n }, \"User info retrieved successfully\");\n\n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Get user error:\", error);\n return createErrorResponse(error.message || \"Failed to get user info\", 401);\n }\n});\n\n// POST /auth/refresh - Refresh JWT token\napp.post(\"/auth/refresh\", async (c) => {\n await ensureDatabase();\n \n try {\n const authHeader = c.req.header(\"authorization\");\n if (!authHeader) {\n return createErrorResponse(\"Authorization header required\", 401);\n }\n\n const user = await extractUserFromToken(authHeader);\n logRequest(c.req.raw, user.id);\n\n // Create new token\n const { createJWT } = await import(\"./auth.ts\");\n const newToken = await createJWT(user.id, user.email, user.plan);\n \n return createSuccessResponse({\n token: newToken,\n user: {\n id: user.id,\n email: user.email,\n plan: user.plan,\n created_at: user.created_at,\n },\n }, \"Token refreshed successfully\");\n\n } catch (error) {\n console.error(\"Token refresh error:\", error);\n return createErrorResponse(error.message || \"Failed to refresh token\", 401);\n }\n});\n\n// POST /auth/logout - Logout user (for completeness, stateless JWT)\napp.post(\"/auth/logout\", async (c) => {\n logRequest(c.req.raw);\n \n // Since we're using stateless JWT, logout is handled client-side\n // In a production app, you might want to maintain a blacklist of tokens\n return createSuccessResponse(null, \"Logout successful. Please remove the token from your client.\");\n});\n\n// Health check endpoint\napp.get(\"/auth/health\", async (c) => {\n await ensureDatabase();\n \n return createSuccessResponse({\n status: \"healthy\",\n timestamp: new Date().toISOString(),\n service: \"RankWatch Auth API\",\n });\n});\n\n// Export the Hono app\nexport default {\n fetch: app.fetch,\n};",[],[191],{"_104":199,"_95":200,"_153":201,"_155":-5,"_156":138,"_157":202,"_159":160,"_106":203,"_100":32,"_162":185,"_164":204,"_166":22,"_167":-5,"_168":205,"_98":206},"e9556bc6-8e95-11f0-95f6-0224a6c84d84","config.ts","e9556c84-8e95-11f0-95f6-0224a6c84d84",4,["D",1757543496435],"// config.ts - Configurações centralizadas do RankWatch API\n\nexport const config = {\n // Database\n database: {\n type: \"sqlite\" as const,\n // Preparado para migração futura para Turso\n url: Deno.env.get(\"DATABASE_URL\") || \":memory:\",\n },\n\n // JWT Configuration\n jwt: {\n secret: Deno.env.get(\"JWT_SECRET\") || \"rankwatch-secret-key-change-in-production\",\n expiresIn: \"7d\",\n algorithm: \"HS256\" as const,\n },\n\n // Rate Limiting\n rateLimit: {\n freemium: {\n requests: 100,\n windowMs: 60 * 60 * 1000, // 1 hour\n },\n unlimited: {\n requests: 1000,\n windowMs: 60 * 60 * 1000, // 1 hour\n },\n },\n\n // External APIs\n serper: {\n apiKey: Deno.env.get(\"SERPER_API_KEY\") || \"\",\n baseUrl: \"https://google.serper.dev\",\n timeout: 30000,\n },\n\n // Email (Resend)\n resend: {\n apiKey: Deno.env.get(\"RESEND_API_KEY\") || \"\",\n fromEmail: \"noreply@rankwatch.dev\",\n },\n\n // Plans\n plans: {\n freemium: {\n maxKeywords: 10,\n maxProjects: 1,\n updateFrequency: \"weekly\",\n historyDays: 30,\n },\n unlimited: {\n maxKeywords: -1, // unlimited\n maxProjects: -1, // unlimited\n updateFrequency: \"daily\",\n historyDays: -1, // unlimited\n },\n },\n\n // Server\n server: {\n port: parseInt(Deno.env.get(\"PORT\") || \"8000\"),\n baseUrl: Deno.env.get(\"BASE_URL\") || \"https://your-val.val.town\",\n },\n} as const;\n\nexport type Plan = keyof typeof config.plans;\nexport type UserPlan = \"freemium\" | \"unlimited\";",[],[200],{"_104":208,"_95":209,"_153":210,"_155":-5,"_156":138,"_157":211,"_159":160,"_106":212,"_100":32,"_162":185,"_164":213,"_166":22,"_167":-5,"_168":214,"_98":215},"70086a38-8e96-11f0-b661-0224a6c84d84","database.ts","70086af6-8e96-11f0-b661-0224a6c84d84",5,["D",1757543722416],"// database.ts - Database setup and schema for RankWatch\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite?v=4\";\n\n// Database connection singleton\nlet db: any = null;\n\nexport function getDatabase() {\n if (!db) {\n db = sqlite(\"rankwatch\");\n }\n return db;\n}\n\n// Initialize database schema\nexport async function initializeDatabase() {\n const database = getDatabase();\n\n // Users table\n await database.execute(`\n CREATE TABLE IF NOT EXISTS users (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email TEXT UNIQUE NOT NULL,\n password_hash TEXT NOT NULL,\n plan TEXT NOT NULL DEFAULT 'freemium' CHECK (plan IN ('freemium', 'unlimited')),\n api_key TEXT UNIQUE,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n deleted_at DATETIME NULL\n )\n `);\n\n // Rate limiting table\n await database.execute(`\n CREATE TABLE IF NOT EXISTS rate_limits (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n endpoint TEXT NOT NULL,\n requests_made INTEGER NOT NULL DEFAULT 0,\n window_start DATETIME NOT NULL,\n window_end DATETIME NOT NULL,\n FOREIGN KEY (user_id) REFERENCES users (id),\n UNIQUE(user_id, endpoint, window_start)\n )\n `);\n\n // Projects table\n await database.execute(`\n CREATE TABLE IF NOT EXISTS projects (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n name TEXT NOT NULL,\n domain TEXT NOT NULL,\n location TEXT DEFAULT 'us',\n device TEXT DEFAULT 'desktop' CHECK (device IN ('desktop', 'mobile')),\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n deleted_at DATETIME NULL,\n FOREIGN KEY (user_id) REFERENCES users (id)\n )\n `);\n\n // Keywords table\n await database.execute(`\n CREATE TABLE IF NOT EXISTS keywords (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n project_id INTEGER NOT NULL,\n keyword TEXT NOT NULL,\n target_url TEXT,\n active BOOLEAN DEFAULT TRUE,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n deleted_at DATETIME NULL,\n FOREIGN KEY (project_id) REFERENCES projects (id)\n )\n `);\n\n // Rankings table\n await database.execute(`\n CREATE TABLE IF NOT EXISTS rankings (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n keyword_id INTEGER NOT NULL,\n position INTEGER,\n url TEXT,\n title TEXT,\n serp_features TEXT, -- JSON string\n checked_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (keyword_id) REFERENCES keywords (id)\n )\n `);\n\n // Rank history table\n await database.execute(`\n CREATE TABLE IF NOT EXISTS rank_history (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n keyword_id INTEGER NOT NULL,\n position INTEGER,\n change_value INTEGER, -- positive = up, negative = down\n checked_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (keyword_id) REFERENCES keywords (id)\n )\n `);\n\n // Alerts table\n await database.execute(`\n CREATE TABLE IF NOT EXISTS alerts (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n keyword_id INTEGER NOT NULL,\n trigger_type TEXT NOT NULL CHECK (trigger_type IN ('position_up', 'position_down', 'top_10_entry', 'page_1_lost')),\n threshold INTEGER NOT NULL,\n email TEXT NOT NULL,\n active BOOLEAN DEFAULT TRUE,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n deleted_at DATETIME NULL,\n FOREIGN KEY (keyword_id) REFERENCES keywords (id)\n )\n `);\n\n // Usage limits table\n await database.execute(`\n CREATE TABLE IF NOT EXISTS usage_limits (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n searches_used INTEGER DEFAULT 0,\n period_start DATETIME NOT NULL,\n period_end DATETIME NOT NULL,\n FOREIGN KEY (user_id) REFERENCES users (id)\n )\n `);\n\n // Create indexes for performance\n await database.execute(`CREATE INDEX IF NOT EXISTS idx_users_email ON users (email)`);\n await database.execute(`CREATE INDEX IF NOT EXISTS idx_users_api_key ON users (api_key)`);\n await database.execute(`CREATE INDEX IF NOT EXISTS idx_projects_user_id ON projects (user_id)`);\n await database.execute(`CREATE INDEX IF NOT EXISTS idx_keywords_project_id ON keywords (project_id)`);\n await database.execute(`CREATE INDEX IF NOT EXISTS idx_rankings_keyword_id ON rankings (keyword_id)`);\n await database.execute(`CREATE INDEX IF NOT EXISTS idx_rankings_checked_at ON rankings (checked_at)`);\n await database.execute(`CREATE INDEX IF NOT EXISTS idx_rank_history_keyword_id ON rank_history (keyword_id)`);\n await database.execute(`CREATE INDEX IF NOT EXISTS idx_alerts_keyword_id ON alerts (keyword_id)`);\n await database.execute(`CREATE INDEX IF NOT EXISTS idx_rate_limits_user_endpoint ON rate_limits (user_id, endpoint)`);\n\n console.log(\"Database schema initialized successfully\");\n return database;\n}\n\n// Helper function to run migrations\nexport async function runMigrations() {\n // Future migrations can be added here\n console.log(\"Running database migrations...\");\n await initializeDatabase();\n console.log(\"Migrations completed\");\n}",[],[209],{"_104":217,"_95":218,"_153":219,"_155":-5,"_156":138,"_157":220,"_159":160,"_106":221,"_100":32,"_162":163,"_164":222,"_166":22,"_167":-5,"_168":223,"_98":224},"d469e2ee-8e92-11f0-8874-0224a6c84d84","deno.json","d469e460-8e92-11f0-8874-0224a6c84d84",1,["D",1757542172847],"{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/348900b8b79f4a434cab4c74b3bc8d4d2fa8ee74/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": false,\n \"types\": [\n \"https://www.val.town/types/valtown.d.ts\"\n ],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"files\": {\n \"include\": [\n \"deno:/https/esm.town/**/*\"\n ]\n },\n \"rules\": {\n \"exclude\": [\n \"no-explicit-any\"\n ]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n }\n}",[],[218],{"_104":226,"_95":227,"_153":228,"_155":-5,"_156":138,"_157":101,"_159":160,"_106":229,"_100":32,"_162":185,"_164":230,"_166":22,"_167":-5,"_168":231,"_98":232},"b3117d6e-8e97-11f0-b3fc-0224a6c84d84","exportApi.ts","b3117e0e-8e97-11f0-b3fc-0224a6c84d84",["D",1757544264387],"// exportApi.ts - CSV export API endpoints for RankWatch\n\nimport { Hono } from \"https://deno.land/x/hono@v3.12.6/mod.ts\";\nimport { cors } from \"https://deno.land/x/hono@v3.12.6/middleware.ts\";\nimport { extractUserFromToken } from \"./auth.ts\";\nimport { getDatabase } from \"./database.ts\";\nimport { \n createSuccessResponse, \n createErrorResponse, \n logRequest,\n arrayToCSV,\n formatDate\n} from \"./utils.ts\";\nimport { checkRateLimit, getRateLimitHeaders } from \"./rateLimit.ts\";\n\nconst app = new Hono();\n\n// CORS middleware\napp.use(\"*\", cors({\n origin: \"*\",\n allowMethods: [\"GET\", \"POST\", \"PUT\", \"DELETE\", \"OPTIONS\"],\n allowHeaders: [\"Content-Type\", \"Authorization\"],\n}));\n\n// Middleware to extract and validate user\nasync function authenticateUser(c: any) {\n const authHeader = c.req.header(\"authorization\");\n if (!authHeader) {\n throw new Error(\"Authorization header required\");\n }\n return await extractUserFromToken(authHeader);\n}\n\n// Check if project belongs to user\nasync function verifyProjectOwnership(projectId: number, userId: number): Promise {\n const db = getDatabase();\n const result = await db.execute({\n sql: \"SELECT id FROM projects WHERE id = ? AND user_id = ? AND deleted_at IS NULL\",\n args: [projectId, userId],\n });\n return result.rows.length > 0;\n}\n\n// Check if keyword belongs to user\nasync function verifyKeywordOwnership(keywordId: number, userId: number): Promise {\n const db = getDatabase();\n const result = await db.execute({\n sql: `SELECT k.id \n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n WHERE k.id = ? AND p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL`,\n args: [keywordId, userId],\n });\n return result.rows.length > 0;\n}\n\n// GET /projects/:projectId/export - Export project summary as CSV\napp.get(\"/projects/:projectId/export\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const projectId = parseInt(c.req.param(\"projectId\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(projectId)) {\n return createErrorResponse(\"Invalid project ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects/:projectId/export\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Verify project ownership\n const hasAccess = await verifyProjectOwnership(projectId, user.id);\n if (!hasAccess) {\n return createErrorResponse(\"Project not found or access denied\", 404);\n }\n\n const db = getDatabase();\n \n // Get project details\n const projectResult = await db.execute({\n sql: \"SELECT name, domain, location, device, created_at FROM projects WHERE id = ?\",\n args: [projectId],\n });\n\n if (projectResult.rows.length === 0) {\n return createErrorResponse(\"Project not found\", 404);\n }\n\n const project = projectResult.rows[0];\n\n // Get all keywords with their latest rankings\n const keywordsWithRankings = await db.execute({\n sql: `SELECT \n k.keyword,\n k.target_url,\n k.active,\n k.created_at as keyword_created,\n r.position,\n r.url as ranking_url,\n r.title as ranking_title,\n r.checked_at as last_check,\n rh.change_value as last_change\n FROM keywords k\n LEFT JOIN rankings r ON k.id = r.keyword_id \n AND r.id = (SELECT id FROM rankings WHERE keyword_id = k.id ORDER BY checked_at DESC LIMIT 1)\n LEFT JOIN rank_history rh ON k.id = rh.keyword_id\n AND rh.id = (SELECT id FROM rank_history WHERE keyword_id = k.id ORDER BY checked_at DESC LIMIT 1)\n WHERE k.project_id = ? AND k.deleted_at IS NULL\n ORDER BY k.keyword`,\n args: [projectId],\n });\n\n // Format data for CSV\n const csvData = keywordsWithRankings.rows.map(row => ({\n project_name: project[0],\n project_domain: project[1],\n keyword: row[0],\n target_url: row[1] || '',\n active: row[2] ? 'Yes' : 'No',\n current_position: row[4] || 'Not ranking',\n ranking_url: row[5] || '',\n ranking_title: row[6] || '',\n last_change: row[8] ? (row[8] > 0 ? `+${row[8]}` : row[8].toString()) : 'No change',\n last_checked: row[7] || 'Never',\n keyword_created: row[3],\n }));\n\n // Generate CSV\n const csvHeaders = [\n 'project_name',\n 'project_domain', \n 'keyword',\n 'target_url',\n 'active',\n 'current_position',\n 'ranking_url',\n 'ranking_title',\n 'last_change',\n 'last_checked',\n 'keyword_created'\n ];\n\n const csvContent = arrayToCSV(csvData, csvHeaders);\n const filename = `rankwatch_project_${projectId}_${formatDate(new Date()).split('T')[0]}.csv`;\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n \n // Return CSV file\n const response = new Response(csvContent, {\n status: 200,\n headers: {\n \"Content-Type\": \"text/csv\",\n \"Content-Disposition\": `attachment; filename=\"${filename}\"`,\n \"Cache-Control\": \"no-cache\",\n ...headers,\n },\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Project export error:\", error);\n return createErrorResponse(error.message || \"Failed to export project\", 401);\n }\n});\n\n// GET /keywords/:id/export - Export keyword ranking history as CSV\napp.get(\"/keywords/:id/export\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const keywordId = parseInt(c.req.param(\"id\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(keywordId)) {\n return createErrorResponse(\"Invalid keyword ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/keywords/:id/export\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Verify keyword ownership\n const hasAccess = await verifyKeywordOwnership(keywordId, user.id);\n if (!hasAccess) {\n return createErrorResponse(\"Keyword not found or access denied\", 404);\n }\n\n const url = new URL(c.req.url);\n const fromDate = url.searchParams.get(\"from\");\n const toDate = url.searchParams.get(\"to\");\n\n const db = getDatabase();\n \n // Get keyword and project details\n const keywordResult = await db.execute({\n sql: `SELECT k.keyword, k.target_url, p.name as project_name, p.domain as project_domain\n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n WHERE k.id = ?`,\n args: [keywordId],\n });\n\n if (keywordResult.rows.length === 0) {\n return createErrorResponse(\"Keyword not found\", 404);\n }\n\n const keyword = keywordResult.rows[0];\n\n // Build query with optional date filters\n let whereClause = \"WHERE keyword_id = ?\";\n const args: any[] = [keywordId];\n \n if (fromDate) {\n whereClause += \" AND checked_at >= ?\";\n args.push(fromDate);\n }\n \n if (toDate) {\n whereClause += \" AND checked_at <= ?\";\n args.push(toDate);\n }\n\n // Get ranking history\n const historyResult = await db.execute({\n sql: `SELECT position, change_value, checked_at \n FROM rank_history ${whereClause} \n ORDER BY checked_at DESC`,\n args,\n });\n\n // Format data for CSV\n const csvData = historyResult.rows.map(row => ({\n project_name: keyword[2],\n project_domain: keyword[3],\n keyword: keyword[0],\n target_url: keyword[1] || '',\n date: row[2] ? row[2].split('T')[0] : '', // Date only\n time: row[2] ? row[2].split('T')[1]?.replace('Z', '') : '', // Time only\n position: row[0],\n change: row[1] ? (row[1] > 0 ? `+${row[1]}` : row[1].toString()) : '0',\n full_datetime: row[2],\n }));\n\n // Generate CSV\n const csvHeaders = [\n 'project_name',\n 'project_domain',\n 'keyword',\n 'target_url',\n 'date',\n 'time',\n 'position',\n 'change',\n 'full_datetime'\n ];\n\n const csvContent = arrayToCSV(csvData, csvHeaders);\n const dateRange = fromDate && toDate ? `_${fromDate}_to_${toDate}` : '';\n const filename = `rankwatch_keyword_${keywordId}_history${dateRange}_${formatDate(new Date()).split('T')[0]}.csv`;\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n \n // Return CSV file\n const response = new Response(csvContent, {\n status: 200,\n headers: {\n \"Content-Type\": \"text/csv\",\n \"Content-Disposition\": `attachment; filename=\"${filename}\"`,\n \"Cache-Control\": \"no-cache\",\n ...headers,\n },\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Keyword export error:\", error);\n return createErrorResponse(error.message || \"Failed to export keyword history\", 401);\n }\n});\n\n// GET /reports/usage - Export user usage statistics as CSV\napp.get(\"/reports/usage\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/reports/usage\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const db = getDatabase();\n \n // Get user stats\n const [projectCount, keywordCount, rankingCount, alertCount] = await Promise.all([\n db.execute({\n sql: \"SELECT COUNT(*) FROM projects WHERE user_id = ? AND deleted_at IS NULL\",\n args: [user.id],\n }),\n db.execute({\n sql: `SELECT COUNT(*) \n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n WHERE p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL`,\n args: [user.id],\n }),\n db.execute({\n sql: `SELECT COUNT(*) \n FROM rankings r \n JOIN keywords k ON r.keyword_id = k.id \n JOIN projects p ON k.project_id = p.id \n WHERE p.user_id = ?`,\n args: [user.id],\n }),\n db.execute({\n sql: `SELECT COUNT(*) \n FROM alerts a \n JOIN keywords k ON a.keyword_id = k.id \n JOIN projects p ON k.project_id = p.id \n WHERE p.user_id = ? AND a.deleted_at IS NULL`,\n args: [user.id],\n }),\n ]);\n\n // Get recent activity (last 30 days)\n const recentActivity = await db.execute({\n sql: `SELECT \n DATE(r.checked_at) as date,\n COUNT(*) as rankings_checked\n FROM rankings r \n JOIN keywords k ON r.keyword_id = k.id \n JOIN projects p ON k.project_id = p.id \n WHERE p.user_id = ? \n AND r.checked_at >= datetime('now', '-30 days')\n GROUP BY DATE(r.checked_at)\n ORDER BY date DESC`,\n args: [user.id],\n });\n\n // Format usage data\n const usageData = [\n {\n user_email: user.email,\n user_plan: user.plan,\n account_created: user.created_at,\n total_projects: projectCount.rows[0][0],\n total_keywords: keywordCount.rows[0][0],\n total_ranking_checks: rankingCount.rows[0][0],\n total_alerts: alertCount.rows[0][0],\n report_generated: formatDate(new Date()),\n }\n ];\n\n // Format activity data\n const activityData = recentActivity.rows.map(row => ({\n user_email: user.email,\n date: row[0],\n rankings_checked: row[1],\n report_generated: formatDate(new Date()),\n }));\n\n // Combine both datasets\n const combinedData = [\n ...usageData.map(item => ({ ...item, type: 'usage_summary' })),\n ...activityData.map(item => ({ ...item, type: 'daily_activity' })),\n ];\n\n // Generate CSV\n const csvContent = arrayToCSV(combinedData);\n const filename = `rankwatch_usage_report_${formatDate(new Date()).split('T')[0]}.csv`;\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n \n // Return CSV file\n const response = new Response(csvContent, {\n status: 200,\n headers: {\n \"Content-Type\": \"text/csv\",\n \"Content-Disposition\": `attachment; filename=\"${filename}\"`,\n \"Cache-Control\": \"no-cache\",\n ...headers,\n },\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Usage report export error:\", error);\n return createErrorResponse(error.message || \"Failed to export usage report\", 401);\n }\n});\n\n// GET /export/all-keywords - Export all user keywords across all projects\napp.get(\"/export/all-keywords\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/export/all-keywords\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const db = getDatabase();\n \n // Get all keywords with their latest rankings across all projects\n const allKeywords = await db.execute({\n sql: `SELECT \n p.name as project_name,\n p.domain as project_domain,\n p.location,\n p.device,\n k.keyword,\n k.target_url,\n k.active,\n k.created_at as keyword_created,\n r.position,\n r.url as ranking_url,\n r.title as ranking_title,\n r.checked_at as last_check,\n rh.change_value as last_change\n FROM projects p\n JOIN keywords k ON p.id = k.project_id\n LEFT JOIN rankings r ON k.id = r.keyword_id \n AND r.id = (SELECT id FROM rankings WHERE keyword_id = k.id ORDER BY checked_at DESC LIMIT 1)\n LEFT JOIN rank_history rh ON k.id = rh.keyword_id\n AND rh.id = (SELECT id FROM rank_history WHERE keyword_id = k.id ORDER BY checked_at DESC LIMIT 1)\n WHERE p.user_id = ? AND p.deleted_at IS NULL AND k.deleted_at IS NULL\n ORDER BY p.name, k.keyword`,\n args: [user.id],\n });\n\n if (allKeywords.rows.length === 0) {\n return createErrorResponse(\"No keywords found\", 404);\n }\n\n // Format data for CSV\n const csvData = allKeywords.rows.map(row => ({\n project_name: row[0],\n project_domain: row[1],\n location: row[2],\n device: row[3],\n keyword: row[4],\n target_url: row[5] || '',\n active: row[6] ? 'Yes' : 'No',\n current_position: row[8] || 'Not ranking',\n ranking_url: row[9] || '',\n ranking_title: row[10] || '',\n last_change: row[12] ? (row[12] > 0 ? `+${row[12]}` : row[12].toString()) : 'No change',\n last_checked: row[11] || 'Never',\n keyword_created: row[7],\n }));\n\n // Generate CSV\n const csvHeaders = [\n 'project_name',\n 'project_domain',\n 'location',\n 'device',\n 'keyword',\n 'target_url',\n 'active',\n 'current_position',\n 'ranking_url',\n 'ranking_title',\n 'last_change',\n 'last_checked',\n 'keyword_created'\n ];\n\n const csvContent = arrayToCSV(csvData, csvHeaders);\n const filename = `rankwatch_all_keywords_${formatDate(new Date()).split('T')[0]}.csv`;\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n \n // Return CSV file\n const response = new Response(csvContent, {\n status: 200,\n headers: {\n \"Content-Type\": \"text/csv\",\n \"Content-Disposition\": `attachment; filename=\"${filename}\"`,\n \"Cache-Control\": \"no-cache\",\n ...headers,\n },\n });\n\n return response;\n\n } catch (error) {\n console.error(\"All keywords export error:\", error);\n return createErrorResponse(error.message || \"Failed to export all keywords\", 401);\n }\n});\n\n// GET /export/format-info - Get information about available export formats\napp.get(\"/export/format-info\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit (lightweight check)\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/export/format-info\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const formatInfo = {\n available_exports: [\n {\n endpoint: \"/projects/{id}/export\",\n description: \"Export project summary with all keywords and current rankings\",\n format: \"CSV\",\n parameters: [\"project_id\"],\n filename_pattern: \"rankwatch_project_{id}_{date}.csv\"\n },\n {\n endpoint: \"/keywords/{id}/export\",\n description: \"Export keyword ranking history\",\n format: \"CSV\",\n parameters: [\"keyword_id\", \"from (optional)\", \"to (optional)\"],\n filename_pattern: \"rankwatch_keyword_{id}_history_{date}.csv\"\n },\n {\n endpoint: \"/reports/usage\",\n description: \"Export user usage statistics and activity\",\n format: \"CSV\",\n parameters: [],\n filename_pattern: \"rankwatch_usage_report_{date}.csv\"\n },\n {\n endpoint: \"/export/all-keywords\",\n description: \"Export all keywords across all projects\",\n format: \"CSV\",\n parameters: [],\n filename_pattern: \"rankwatch_all_keywords_{date}.csv\"\n }\n ],\n csv_features: {\n encoding: \"UTF-8\",\n delimiter: \",\",\n quote_character: \"\\\"\",\n headers_included: true,\n date_format: \"ISO 8601 (YYYY-MM-DDTHH:mm:ss.sssZ)\"\n },\n notes: [\n \"All exports include rate limiting headers\",\n \"Files are generated on-demand and not stored server-side\",\n \"Date ranges use ISO 8601 format (YYYY-MM-DD)\",\n \"Export availability depends on user plan limits\"\n ]\n };\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse(formatInfo, \"Export format information retrieved successfully\");\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Export format info error:\", error);\n return createErrorResponse(error.message || \"Failed to get export format info\", 401);\n }\n});\n\n// Export the Hono app\nexport default {\n fetch: app.fetch,\n};",[],[227],{"_104":234,"_95":235,"_153":236,"_155":-5,"_156":138,"_157":237,"_159":160,"_106":238,"_100":32,"_162":185,"_164":239,"_166":22,"_167":-5,"_168":240,"_98":241},"0735f7ae-8e97-11f0-bcfc-0224a6c84d84","keywordsApi.ts","0735fb78-8e97-11f0-bcfc-0224a6c84d84",11,["D",1757543976057],"// keywordsApi.ts - Keywords CRUD API endpoints with soft delete for RankWatch\n\nimport { Hono } from \"https://deno.land/x/hono@v3.12.6/mod.ts\";\nimport { cors } from \"https://deno.land/x/hono@v3.12.6/middleware.ts\";\nimport { extractUserFromToken } from \"./auth.ts\";\nimport { getDatabase } from \"./database.ts\";\nimport { config } from \"./config.ts\";\nimport { \n createSuccessResponse, \n createErrorResponse, \n parseJsonBody, \n validateRequiredFields, \n isValidUrl,\n sanitizeString,\n logRequest,\n parsePaginationParams,\n createPaginationMeta,\n parseSearchQuery,\n getSoftDeleteTimestamp,\n isValidKeyword\n} from \"./utils.ts\";\nimport { checkRateLimit, getRateLimitHeaders } from \"./rateLimit.ts\";\n\nconst app = new Hono();\n\n// CORS middleware\napp.use(\"*\", cors({\n origin: \"*\",\n allowMethods: [\"GET\", \"POST\", \"PUT\", \"DELETE\", \"OPTIONS\"],\n allowHeaders: [\"Content-Type\", \"Authorization\"],\n}));\n\n// Interface for Keyword\ninterface Keyword {\n id: number;\n project_id: number;\n keyword: string;\n target_url?: string;\n active: boolean;\n created_at: string;\n updated_at: string;\n}\n\n// Middleware to extract and validate user\nasync function authenticateUser(c: any) {\n const authHeader = c.req.header(\"authorization\");\n if (!authHeader) {\n throw new Error(\"Authorization header required\");\n }\n return await extractUserFromToken(authHeader);\n}\n\n// Check if project belongs to user\nasync function verifyProjectOwnership(projectId: number, userId: number): Promise {\n const db = getDatabase();\n const result = await db.execute({\n sql: \"SELECT id FROM projects WHERE id = ? AND user_id = ? AND deleted_at IS NULL\",\n args: [projectId, userId],\n });\n return result.rows.length > 0;\n}\n\n// Check user plan limits for keywords\nasync function checkKeywordLimits(userId: number, plan: string): Promise<{ allowed: boolean; current: number; max: number }> {\n const db = getDatabase();\n const result = await db.execute({\n sql: `SELECT COUNT(*) as count \n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n WHERE p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL`,\n args: [userId],\n });\n \n const currentCount = result.rows[0][0] as number;\n const maxKeywords = plan === \"unlimited\" ? -1 : config.plans.freemium.maxKeywords;\n \n return {\n allowed: maxKeywords === -1 || currentCount < maxKeywords,\n current: currentCount,\n max: maxKeywords,\n };\n}\n\n// GET /projects/:projectId/keywords - List keywords for a project\napp.get(\"/projects/:projectId/keywords\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const projectId = parseInt(c.req.param(\"projectId\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(projectId)) {\n return createErrorResponse(\"Invalid project ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects/:projectId/keywords\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Verify project ownership\n const hasAccess = await verifyProjectOwnership(projectId, user.id);\n if (!hasAccess) {\n return createErrorResponse(\"Project not found or access denied\", 404);\n }\n\n const url = new URL(c.req.url);\n const { page, limit } = parsePaginationParams(url);\n const searchQuery = parseSearchQuery(url);\n const offset = (page - 1) * limit;\n\n const db = getDatabase();\n \n // Build query with search\n let whereClause = \"WHERE project_id = ? AND deleted_at IS NULL\";\n const args: any[] = [projectId];\n \n if (searchQuery) {\n whereClause += \" AND (keyword LIKE ? OR target_url LIKE ?)\";\n args.push(`%${searchQuery}%`, `%${searchQuery}%`);\n }\n\n // Get total count\n const countResult = await db.execute({\n sql: `SELECT COUNT(*) as total FROM keywords ${whereClause}`,\n args,\n });\n const total = countResult.rows[0][0] as number;\n\n // Get keywords with pagination\n const keywordsResult = await db.execute({\n sql: `SELECT id, keyword, target_url, active, created_at, updated_at \n FROM keywords ${whereClause} \n ORDER BY created_at DESC \n LIMIT ? OFFSET ?`,\n args: [...args, limit, offset],\n });\n\n const keywords = keywordsResult.rows.map(row => ({\n id: row[0],\n project_id: projectId,\n keyword: row[1],\n target_url: row[2],\n active: row[3],\n created_at: row[4],\n updated_at: row[5],\n }));\n\n const meta = createPaginationMeta(page, limit, total);\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n \n const response = createSuccessResponse(keywords, \"Keywords retrieved successfully\", meta);\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Get keywords error:\", error);\n return createErrorResponse(error.message || \"Failed to get keywords\", 401);\n }\n});\n\n// POST /projects/:projectId/keywords - Add keyword to project\napp.post(\"/projects/:projectId/keywords\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const projectId = parseInt(c.req.param(\"projectId\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(projectId)) {\n return createErrorResponse(\"Invalid project ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects/:projectId/keywords\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Verify project ownership\n const hasAccess = await verifyProjectOwnership(projectId, user.id);\n if (!hasAccess) {\n return createErrorResponse(\"Project not found or access denied\", 404);\n }\n\n // Check keyword limits\n const limits = await checkKeywordLimits(user.id, user.plan);\n if (!limits.allowed) {\n return createErrorResponse(\n `Keyword limit reached. ${user.plan} plan allows ${limits.max} keywords. Current: ${limits.current}`, \n 403\n );\n }\n\n const body = await parseJsonBody(c.req.raw);\n \n // Validate required fields\n const validation = validateRequiredFields(body, [\"keyword\"]);\n if (!validation.valid) {\n return createErrorResponse(`Missing required fields: ${validation.missing?.join(\", \")}`, 400);\n }\n\n const { keyword, target_url, active = true } = body;\n\n // Validate keyword\n const keywordValidation = isValidKeyword(keyword);\n if (!keywordValidation.valid) {\n return createErrorResponse(keywordValidation.message!, 400);\n }\n\n const sanitizedKeyword = sanitizeString(keyword);\n\n // Validate target URL if provided\n if (target_url && !isValidUrl(target_url)) {\n return createErrorResponse(\"Invalid target URL format\", 400);\n }\n\n const db = getDatabase();\n \n // Check if keyword already exists in this project\n const existingKeyword = await db.execute({\n sql: \"SELECT id FROM keywords WHERE project_id = ? AND keyword = ? AND deleted_at IS NULL\",\n args: [projectId, sanitizedKeyword],\n });\n\n if (existingKeyword.rows.length > 0) {\n return createErrorResponse(\"Keyword already exists in this project\", 409);\n }\n\n // Create keyword\n const result = await db.execute({\n sql: `INSERT INTO keywords (project_id, keyword, target_url, active) \n VALUES (?, ?, ?, ?) \n RETURNING id, keyword, target_url, active, created_at, updated_at`,\n args: [projectId, sanitizedKeyword, target_url || null, active],\n });\n\n const keywordData = result.rows[0];\n const newKeyword = {\n id: keywordData[0],\n project_id: projectId,\n keyword: keywordData[1],\n target_url: keywordData[2],\n active: keywordData[3],\n created_at: keywordData[4],\n updated_at: keywordData[5],\n };\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse(newKeyword, \"Keyword created successfully\");\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Create keyword error:\", error);\n return createErrorResponse(error.message || \"Failed to create keyword\", 400);\n }\n});\n\n// PUT /keywords/:id - Update keyword\napp.put(\"/keywords/:id\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const keywordId = parseInt(c.req.param(\"id\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(keywordId)) {\n return createErrorResponse(\"Invalid keyword ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/keywords/:id\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const body = await parseJsonBody(c.req.raw);\n const { keyword, target_url, active } = body;\n\n // Validate at least one field is provided\n if (keyword === undefined && target_url === undefined && active === undefined) {\n return createErrorResponse(\"At least one field must be provided for update\", 400);\n }\n\n const db = getDatabase();\n \n // Check if keyword exists and user has access (through project ownership)\n const existingKeyword = await db.execute({\n sql: `SELECT k.id, k.project_id \n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n WHERE k.id = ? AND p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL`,\n args: [keywordId, user.id],\n });\n\n if (existingKeyword.rows.length === 0) {\n return createErrorResponse(\"Keyword not found or access denied\", 404);\n }\n\n const projectId = existingKeyword.rows[0][1] as number;\n\n // Build update query dynamically\n const updateFields: string[] = [];\n const updateValues: any[] = [];\n\n if (keyword !== undefined) {\n const keywordValidation = isValidKeyword(keyword);\n if (!keywordValidation.valid) {\n return createErrorResponse(keywordValidation.message!, 400);\n }\n \n const sanitizedKeyword = sanitizeString(keyword);\n \n // Check if updated keyword already exists in this project (excluding current keyword)\n const duplicateCheck = await db.execute({\n sql: \"SELECT id FROM keywords WHERE project_id = ? AND keyword = ? AND id != ? AND deleted_at IS NULL\",\n args: [projectId, sanitizedKeyword, keywordId],\n });\n\n if (duplicateCheck.rows.length > 0) {\n return createErrorResponse(\"Keyword already exists in this project\", 409);\n }\n\n updateFields.push(\"keyword = ?\");\n updateValues.push(sanitizedKeyword);\n }\n\n if (target_url !== undefined) {\n if (target_url && !isValidUrl(target_url)) {\n return createErrorResponse(\"Invalid target URL format\", 400);\n }\n updateFields.push(\"target_url = ?\");\n updateValues.push(target_url || null);\n }\n\n if (active !== undefined) {\n updateFields.push(\"active = ?\");\n updateValues.push(active);\n }\n\n updateFields.push(\"updated_at = CURRENT_TIMESTAMP\");\n updateValues.push(keywordId);\n\n // Update keyword\n await db.execute({\n sql: `UPDATE keywords SET ${updateFields.join(\", \")} WHERE id = ?`,\n args: updateValues,\n });\n\n // Get updated keyword\n const result = await db.execute({\n sql: `SELECT id, project_id, keyword, target_url, active, created_at, updated_at \n FROM keywords \n WHERE id = ? AND deleted_at IS NULL`,\n args: [keywordId],\n });\n\n const keywordData = result.rows[0];\n const updatedKeyword = {\n id: keywordData[0],\n project_id: keywordData[1],\n keyword: keywordData[2],\n target_url: keywordData[3],\n active: keywordData[4],\n created_at: keywordData[5],\n updated_at: keywordData[6],\n };\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse(updatedKeyword, \"Keyword updated successfully\");\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Update keyword error:\", error);\n return createErrorResponse(error.message || \"Failed to update keyword\", 400);\n }\n});\n\n// DELETE /keywords/:id - Soft delete keyword\napp.delete(\"/keywords/:id\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const keywordId = parseInt(c.req.param(\"id\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(keywordId)) {\n return createErrorResponse(\"Invalid keyword ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/keywords/:id\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const db = getDatabase();\n \n // Check if keyword exists and user has access\n const existingKeyword = await db.execute({\n sql: `SELECT k.id \n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n WHERE k.id = ? AND p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL`,\n args: [keywordId, user.id],\n });\n\n if (existingKeyword.rows.length === 0) {\n return createErrorResponse(\"Keyword not found or access denied\", 404);\n }\n\n // Soft delete keyword\n const deletedAt = getSoftDeleteTimestamp();\n \n await db.execute({\n sql: \"UPDATE keywords SET deleted_at = ?, updated_at = CURRENT_TIMESTAMP WHERE id = ?\",\n args: [deletedAt, keywordId],\n });\n\n // Also soft delete related alerts\n await db.execute({\n sql: \"UPDATE alerts SET deleted_at = ? WHERE keyword_id = ?\",\n args: [deletedAt, keywordId],\n });\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse(\n { deleted: true, deleted_at: deletedAt }, \n \"Keyword deleted successfully\"\n );\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Delete keyword error:\", error);\n return createErrorResponse(error.message || \"Failed to delete keyword\", 400);\n }\n});\n\n// POST /keywords/bulk-create - Bulk create keywords\napp.post(\"/keywords/bulk-create\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/keywords/bulk-create\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const body = await parseJsonBody(c.req.raw);\n \n // Validate required fields\n const validation = validateRequiredFields(body, [\"project_id\", \"keywords\"]);\n if (!validation.valid) {\n return createErrorResponse(`Missing required fields: ${validation.missing?.join(\", \")}`, 400);\n }\n\n const { project_id, keywords } = body;\n\n if (!Array.isArray(keywords) || keywords.length === 0) {\n return createErrorResponse(\"Keywords must be a non-empty array\", 400);\n }\n\n if (keywords.length > 100) {\n return createErrorResponse(\"Maximum 100 keywords allowed per bulk operation\", 400);\n }\n\n // Verify project ownership\n const hasAccess = await verifyProjectOwnership(project_id, user.id);\n if (!hasAccess) {\n return createErrorResponse(\"Project not found or access denied\", 404);\n }\n\n // Check keyword limits\n const limits = await checkKeywordLimits(user.id, user.plan);\n if (!limits.allowed || (limits.max !== -1 && limits.current + keywords.length > limits.max)) {\n return createErrorResponse(\n `Keyword limit would be exceeded. ${user.plan} plan allows ${limits.max} keywords. Current: ${limits.current}, Trying to add: ${keywords.length}`, \n 403\n );\n }\n\n const db = getDatabase();\n const createdKeywords: any[] = [];\n const errors: string[] = [];\n\n // Process each keyword\n for (let i = 0; i < keywords.length; i++) {\n const keywordData = keywords[i];\n \n try {\n // Validate keyword structure\n if (typeof keywordData === \"string\") {\n // Simple string format\n const keywordValidation = isValidKeyword(keywordData);\n if (!keywordValidation.valid) {\n errors.push(`Keyword ${i + 1}: ${keywordValidation.message}`);\n continue;\n }\n\n const sanitizedKeyword = sanitizeString(keywordData);\n\n // Check for duplicates\n const duplicate = await db.execute({\n sql: \"SELECT id FROM keywords WHERE project_id = ? AND keyword = ? AND deleted_at IS NULL\",\n args: [project_id, sanitizedKeyword],\n });\n\n if (duplicate.rows.length > 0) {\n errors.push(`Keyword ${i + 1}: \"${sanitizedKeyword}\" already exists`);\n continue;\n }\n\n // Create keyword\n const result = await db.execute({\n sql: `INSERT INTO keywords (project_id, keyword, active) \n VALUES (?, ?, ?) \n RETURNING id, keyword, target_url, active, created_at, updated_at`,\n args: [project_id, sanitizedKeyword, true],\n });\n\n const newKeywordData = result.rows[0];\n createdKeywords.push({\n id: newKeywordData[0],\n project_id: project_id,\n keyword: newKeywordData[1],\n target_url: newKeywordData[2],\n active: newKeywordData[3],\n created_at: newKeywordData[4],\n updated_at: newKeywordData[5],\n });\n\n } else if (typeof keywordData === \"object\") {\n // Object format with additional fields\n const keywordValidation = isValidKeyword(keywordData.keyword);\n if (!keywordValidation.valid) {\n errors.push(`Keyword ${i + 1}: ${keywordValidation.message}`);\n continue;\n }\n\n const sanitizedKeyword = sanitizeString(keywordData.keyword);\n\n if (keywordData.target_url && !isValidUrl(keywordData.target_url)) {\n errors.push(`Keyword ${i + 1}: Invalid target URL`);\n continue;\n }\n\n // Check for duplicates\n const duplicate = await db.execute({\n sql: \"SELECT id FROM keywords WHERE project_id = ? AND keyword = ? AND deleted_at IS NULL\",\n args: [project_id, sanitizedKeyword],\n });\n\n if (duplicate.rows.length > 0) {\n errors.push(`Keyword ${i + 1}: \"${sanitizedKeyword}\" already exists`);\n continue;\n }\n\n // Create keyword\n const result = await db.execute({\n sql: `INSERT INTO keywords (project_id, keyword, target_url, active) \n VALUES (?, ?, ?, ?) \n RETURNING id, keyword, target_url, active, created_at, updated_at`,\n args: [project_id, sanitizedKeyword, keywordData.target_url || null, keywordData.active !== false],\n });\n\n const newKeywordData = result.rows[0];\n createdKeywords.push({\n id: newKeywordData[0],\n project_id: project_id,\n keyword: newKeywordData[1],\n target_url: newKeywordData[2],\n active: newKeywordData[3],\n created_at: newKeywordData[4],\n updated_at: newKeywordData[5],\n });\n\n } else {\n errors.push(`Keyword ${i + 1}: Invalid format`);\n }\n\n } catch (error) {\n errors.push(`Keyword ${i + 1}: ${error.message}`);\n }\n }\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse(\n {\n created: createdKeywords,\n created_count: createdKeywords.length,\n error_count: errors.length,\n errors: errors.length > 0 ? errors : undefined,\n }, \n `Bulk operation completed. Created: ${createdKeywords.length}, Errors: ${errors.length}`\n );\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Bulk create keywords error:\", error);\n return createErrorResponse(error.message || \"Failed to bulk create keywords\", 400);\n }\n});\n\n// DELETE /keywords/bulk-delete - Bulk soft delete keywords\napp.delete(\"/keywords/bulk-delete\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/keywords/bulk-delete\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const body = await parseJsonBody(c.req.raw);\n \n // Validate required fields\n const validation = validateRequiredFields(body, [\"keyword_ids\"]);\n if (!validation.valid) {\n return createErrorResponse(`Missing required fields: ${validation.missing?.join(\", \")}`, 400);\n }\n\n const { keyword_ids } = body;\n\n if (!Array.isArray(keyword_ids) || keyword_ids.length === 0) {\n return createErrorResponse(\"keyword_ids must be a non-empty array\", 400);\n }\n\n if (keyword_ids.length > 100) {\n return createErrorResponse(\"Maximum 100 keywords allowed per bulk operation\", 400);\n }\n\n // Validate all IDs are numbers\n const invalidIds = keyword_ids.filter(id => !Number.isInteger(id) || id <= 0);\n if (invalidIds.length > 0) {\n return createErrorResponse(\"All keyword IDs must be positive integers\", 400);\n }\n\n const db = getDatabase();\n \n // Check which keywords exist and user has access to\n const placeholders = keyword_ids.map(() => \"?\").join(\",\");\n const existingKeywords = await db.execute({\n sql: `SELECT k.id \n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n WHERE k.id IN (${placeholders}) AND p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL`,\n args: [...keyword_ids, user.id],\n });\n\n const existingIds = existingKeywords.rows.map(row => row[0] as number);\n const notFoundIds = keyword_ids.filter(id => !existingIds.includes(id));\n\n if (existingIds.length === 0) {\n return createErrorResponse(\"No valid keywords found for deletion\", 404);\n }\n\n // Soft delete keywords\n const deletedAt = getSoftDeleteTimestamp();\n const deletePlaceholders = existingIds.map(() => \"?\").join(\",\");\n \n await db.execute({\n sql: `UPDATE keywords SET deleted_at = ?, updated_at = CURRENT_TIMESTAMP WHERE id IN (${deletePlaceholders})`,\n args: [deletedAt, ...existingIds],\n });\n\n // Also soft delete related alerts\n await db.execute({\n sql: `UPDATE alerts SET deleted_at = ? WHERE keyword_id IN (${deletePlaceholders})`,\n args: [deletedAt, ...existingIds],\n });\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse(\n {\n deleted_count: existingIds.length,\n deleted_ids: existingIds,\n not_found_count: notFoundIds.length,\n not_found_ids: notFoundIds.length > 0 ? notFoundIds : undefined,\n deleted_at: deletedAt,\n }, \n `Bulk delete completed. Deleted: ${existingIds.length} keywords`\n );\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Bulk delete keywords error:\", error);\n return createErrorResponse(error.message || \"Failed to bulk delete keywords\", 400);\n }\n});\n\n// GET /keywords/search - Search keywords across all user projects\napp.get(\"/keywords/search\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/keywords/search\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const url = new URL(c.req.url);\n const searchQuery = parseSearchQuery(url);\n \n if (!searchQuery) {\n return createErrorResponse(\"Search query 'q' parameter is required\", 400);\n }\n\n const { page, limit } = parsePaginationParams(url);\n const offset = (page - 1) * limit;\n\n const db = getDatabase();\n \n // Search in keywords and target URLs across all user projects\n const whereClause = `WHERE p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL \n AND (k.keyword LIKE ? OR k.target_url LIKE ?)`;\n const args = [user.id, `%${searchQuery}%`, `%${searchQuery}%`];\n\n // Get total count\n const countResult = await db.execute({\n sql: `SELECT COUNT(*) as total \n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n ${whereClause}`,\n args,\n });\n const total = countResult.rows[0][0] as number;\n\n // Get keywords with project info\n const keywordsResult = await db.execute({\n sql: `SELECT k.id, k.project_id, k.keyword, k.target_url, k.active, k.created_at, k.updated_at,\n p.name as project_name, p.domain as project_domain\n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n ${whereClause}\n ORDER BY \n CASE \n WHEN k.keyword LIKE ? THEN 1 \n WHEN k.target_url LIKE ? THEN 2 \n ELSE 3 \n END,\n k.created_at DESC \n LIMIT ? OFFSET ?`,\n args: [...args, `%${searchQuery}%`, `%${searchQuery}%`, limit, offset],\n });\n\n const keywords = keywordsResult.rows.map(row => ({\n id: row[0],\n project_id: row[1],\n keyword: row[2],\n target_url: row[3],\n active: row[4],\n created_at: row[5],\n updated_at: row[6],\n project: {\n name: row[7],\n domain: row[8],\n },\n }));\n\n const meta = createPaginationMeta(page, limit, total);\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n \n const response = createSuccessResponse(\n keywords, \n `Found ${total} keywords matching \"${searchQuery}\"`, \n { ...meta, query: searchQuery }\n );\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Search keywords error:\", error);\n return createErrorResponse(error.message || \"Failed to search keywords\", 401);\n }\n});\n\n// Export the Hono app\nexport default {\n fetch: app.fetch,\n};",[],[235],{"_104":243,"_95":244,"_153":245,"_155":-5,"_156":138,"_157":246,"_159":160,"_106":247,"_100":32,"_162":185,"_164":248,"_166":22,"_167":-5,"_168":249,"_98":250},"d02d9410-8e96-11f0-be01-0224a6c84d84","projectsApi.ts","d02d94ec-8e96-11f0-be01-0224a6c84d84",10,["D",1757543883720],"// projectsApi.ts - Projects CRUD API endpoints for RankWatch\n\nimport { Hono } from \"https://deno.land/x/hono@v3.12.6/mod.ts\";\nimport { cors } from \"https://deno.land/x/hono@v3.12.6/middleware.ts\";\nimport { extractUserFromToken } from \"./auth.ts\";\nimport { getDatabase } from \"./database.ts\";\nimport { config } from \"./config.ts\";\nimport { \n createSuccessResponse, \n createErrorResponse, \n parseJsonBody, \n validateRequiredFields, \n isValidUrl,\n sanitizeString,\n logRequest,\n parsePaginationParams,\n createPaginationMeta,\n parseSearchQuery,\n getSoftDeleteTimestamp\n} from \"./utils.ts\";\nimport { checkRateLimit, getRateLimitHeaders } from \"./rateLimit.ts\";\n\nconst app = new Hono();\n\n// CORS middleware\napp.use(\"*\", cors({\n origin: \"*\",\n allowMethods: [\"GET\", \"POST\", \"PUT\", \"DELETE\", \"OPTIONS\"],\n allowHeaders: [\"Content-Type\", \"Authorization\"],\n}));\n\n// Interface for Project\ninterface Project {\n id: number;\n user_id: number;\n name: string;\n domain: string;\n location: string;\n device: string;\n created_at: string;\n updated_at: string;\n}\n\n// Middleware to extract and validate user\nasync function authenticateUser(c: any) {\n const authHeader = c.req.header(\"authorization\");\n if (!authHeader) {\n throw new Error(\"Authorization header required\");\n }\n return await extractUserFromToken(authHeader);\n}\n\n// Check user plan limits for projects\nasync function checkProjectLimits(userId: number, plan: string): Promise {\n if (plan === \"unlimited\") return true;\n \n const db = getDatabase();\n const result = await db.execute({\n sql: \"SELECT COUNT(*) as count FROM projects WHERE user_id = ? AND deleted_at IS NULL\",\n args: [userId],\n });\n \n const currentCount = result.rows[0][0] as number;\n const maxProjects = config.plans.freemium.maxProjects;\n \n return currentCount < maxProjects;\n}\n\n// GET /projects - List user projects with pagination and search\napp.get(\"/projects\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const url = new URL(c.req.url);\n const { page, limit } = parsePaginationParams(url);\n const searchQuery = parseSearchQuery(url);\n const offset = (page - 1) * limit;\n\n const db = getDatabase();\n \n // Build query with search\n let whereClause = \"WHERE user_id = ? AND deleted_at IS NULL\";\n const args: any[] = [user.id];\n \n if (searchQuery) {\n whereClause += \" AND (name LIKE ? OR domain LIKE ?)\";\n args.push(`%${searchQuery}%`, `%${searchQuery}%`);\n }\n\n // Get total count\n const countResult = await db.execute({\n sql: `SELECT COUNT(*) as total FROM projects ${whereClause}`,\n args,\n });\n const total = countResult.rows[0][0] as number;\n\n // Get projects with pagination\n const projectsResult = await db.execute({\n sql: `SELECT id, name, domain, location, device, created_at, updated_at \n FROM projects ${whereClause} \n ORDER BY created_at DESC \n LIMIT ? OFFSET ?`,\n args: [...args, limit, offset],\n });\n\n const projects = projectsResult.rows.map(row => ({\n id: row[0],\n name: row[1],\n domain: row[2],\n location: row[3],\n device: row[4],\n created_at: row[5],\n updated_at: row[6],\n }));\n\n const meta = createPaginationMeta(page, limit, total);\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n \n const response = createSuccessResponse(projects, \"Projects retrieved successfully\", meta);\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Get projects error:\", error);\n return createErrorResponse(error.message || \"Failed to get projects\", 401);\n }\n});\n\n// POST /projects - Create new project\napp.post(\"/projects\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Check project limits\n const canCreateProject = await checkProjectLimits(user.id, user.plan);\n if (!canCreateProject) {\n return createErrorResponse(\n `Project limit reached. Freemium plan allows ${config.plans.freemium.maxProjects} project only.`, \n 403\n );\n }\n\n const body = await parseJsonBody(c.req.raw);\n \n // Validate required fields\n const validation = validateRequiredFields(body, [\"name\", \"domain\"]);\n if (!validation.valid) {\n return createErrorResponse(`Missing required fields: ${validation.missing?.join(\", \")}`, 400);\n }\n\n const { name, domain, location = \"us\", device = \"desktop\" } = body;\n\n // Validate and sanitize inputs\n const sanitizedName = sanitizeString(name);\n if (!sanitizedName || sanitizedName.length < 1) {\n return createErrorResponse(\"Project name is required\", 400);\n }\n\n if (!isValidUrl(domain) && !domain.includes(\".\")) {\n return createErrorResponse(\"Invalid domain format\", 400);\n }\n\n if (![\"desktop\", \"mobile\"].includes(device)) {\n return createErrorResponse(\"Device must be 'desktop' or 'mobile'\", 400);\n }\n\n // Clean domain (remove protocol if present)\n const cleanDomain = domain.replace(/^https?:\\/\\//, \"\").replace(/\\/$/, \"\");\n\n const db = getDatabase();\n \n // Check if project with same domain already exists for user\n const existingProject = await db.execute({\n sql: \"SELECT id FROM projects WHERE user_id = ? AND domain = ? AND deleted_at IS NULL\",\n args: [user.id, cleanDomain],\n });\n\n if (existingProject.rows.length > 0) {\n return createErrorResponse(\"Project with this domain already exists\", 409);\n }\n\n // Create project\n const result = await db.execute({\n sql: `INSERT INTO projects (user_id, name, domain, location, device) \n VALUES (?, ?, ?, ?, ?) \n RETURNING id, name, domain, location, device, created_at, updated_at`,\n args: [user.id, sanitizedName, cleanDomain, location, device],\n });\n\n const projectData = result.rows[0];\n const project = {\n id: projectData[0],\n name: projectData[1],\n domain: projectData[2],\n location: projectData[3],\n device: projectData[4],\n created_at: projectData[5],\n updated_at: projectData[6],\n };\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse(project, \"Project created successfully\");\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Create project error:\", error);\n return createErrorResponse(error.message || \"Failed to create project\", 400);\n }\n});\n\n// GET /projects/:id - Get specific project\napp.get(\"/projects/:id\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const projectId = parseInt(c.req.param(\"id\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(projectId)) {\n return createErrorResponse(\"Invalid project ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects/:id\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const db = getDatabase();\n const result = await db.execute({\n sql: `SELECT id, name, domain, location, device, created_at, updated_at \n FROM projects \n WHERE id = ? AND user_id = ? AND deleted_at IS NULL`,\n args: [projectId, user.id],\n });\n\n if (result.rows.length === 0) {\n return createErrorResponse(\"Project not found\", 404);\n }\n\n const projectData = result.rows[0];\n const project = {\n id: projectData[0],\n name: projectData[1],\n domain: projectData[2],\n location: projectData[3],\n device: projectData[4],\n created_at: projectData[5],\n updated_at: projectData[6],\n };\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse(project, \"Project retrieved successfully\");\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Get project error:\", error);\n return createErrorResponse(error.message || \"Failed to get project\", 401);\n }\n});\n\n// PUT /projects/:id - Update project\napp.put(\"/projects/:id\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const projectId = parseInt(c.req.param(\"id\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(projectId)) {\n return createErrorResponse(\"Invalid project ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects/:id\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const body = await parseJsonBody(c.req.raw);\n const { name, domain, location, device } = body;\n\n // Validate at least one field is provided\n if (!name && !domain && !location && !device) {\n return createErrorResponse(\"At least one field must be provided for update\", 400);\n }\n\n const db = getDatabase();\n \n // Check if project exists and belongs to user\n const existingProject = await db.execute({\n sql: \"SELECT id FROM projects WHERE id = ? AND user_id = ? AND deleted_at IS NULL\",\n args: [projectId, user.id],\n });\n\n if (existingProject.rows.length === 0) {\n return createErrorResponse(\"Project not found\", 404);\n }\n\n // Build update query dynamically\n const updateFields: string[] = [];\n const updateValues: any[] = [];\n\n if (name) {\n const sanitizedName = sanitizeString(name);\n if (!sanitizedName) {\n return createErrorResponse(\"Invalid project name\", 400);\n }\n updateFields.push(\"name = ?\");\n updateValues.push(sanitizedName);\n }\n\n if (domain) {\n if (!isValidUrl(domain) && !domain.includes(\".\")) {\n return createErrorResponse(\"Invalid domain format\", 400);\n }\n const cleanDomain = domain.replace(/^https?:\\/\\//, \"\").replace(/\\/$/, \"\");\n updateFields.push(\"domain = ?\");\n updateValues.push(cleanDomain);\n }\n\n if (location) {\n updateFields.push(\"location = ?\");\n updateValues.push(location);\n }\n\n if (device) {\n if (![\"desktop\", \"mobile\"].includes(device)) {\n return createErrorResponse(\"Device must be 'desktop' or 'mobile'\", 400);\n }\n updateFields.push(\"device = ?\");\n updateValues.push(device);\n }\n\n updateFields.push(\"updated_at = CURRENT_TIMESTAMP\");\n updateValues.push(projectId, user.id);\n\n // Update project\n await db.execute({\n sql: `UPDATE projects SET ${updateFields.join(\", \")} WHERE id = ? AND user_id = ?`,\n args: updateValues,\n });\n\n // Get updated project\n const result = await db.execute({\n sql: `SELECT id, name, domain, location, device, created_at, updated_at \n FROM projects \n WHERE id = ? AND user_id = ? AND deleted_at IS NULL`,\n args: [projectId, user.id],\n });\n\n const projectData = result.rows[0];\n const project = {\n id: projectData[0],\n name: projectData[1],\n domain: projectData[2],\n location: projectData[3],\n device: projectData[4],\n created_at: projectData[5],\n updated_at: projectData[6],\n };\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse(project, \"Project updated successfully\");\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Update project error:\", error);\n return createErrorResponse(error.message || \"Failed to update project\", 400);\n }\n});\n\n// DELETE /projects/:id - Soft delete project\napp.delete(\"/projects/:id\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const projectId = parseInt(c.req.param(\"id\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(projectId)) {\n return createErrorResponse(\"Invalid project ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects/:id\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const db = getDatabase();\n \n // Check if project exists and belongs to user\n const existingProject = await db.execute({\n sql: \"SELECT id FROM projects WHERE id = ? AND user_id = ? AND deleted_at IS NULL\",\n args: [projectId, user.id],\n });\n\n if (existingProject.rows.length === 0) {\n return createErrorResponse(\"Project not found\", 404);\n }\n\n // Soft delete project and all related keywords\n const deletedAt = getSoftDeleteTimestamp();\n \n await db.execute({\n sql: \"UPDATE projects SET deleted_at = ?, updated_at = CURRENT_TIMESTAMP WHERE id = ? AND user_id = ?\",\n args: [deletedAt, projectId, user.id],\n });\n\n // Also soft delete all keywords in this project\n await db.execute({\n sql: \"UPDATE keywords SET deleted_at = ?, updated_at = CURRENT_TIMESTAMP WHERE project_id = ?\",\n args: [deletedAt, projectId],\n });\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse(\n { deleted: true, deleted_at: deletedAt }, \n \"Project deleted successfully\"\n );\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Delete project error:\", error);\n return createErrorResponse(error.message || \"Failed to delete project\", 400);\n }\n});\n\n// GET /projects/search - Search projects\napp.get(\"/projects/search\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects/search\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const url = new URL(c.req.url);\n const searchQuery = parseSearchQuery(url);\n \n if (!searchQuery) {\n return createErrorResponse(\"Search query 'q' parameter is required\", 400);\n }\n\n const { page, limit } = parsePaginationParams(url);\n const offset = (page - 1) * limit;\n\n const db = getDatabase();\n \n // Search in name and domain\n const whereClause = \"WHERE user_id = ? AND deleted_at IS NULL AND (name LIKE ? OR domain LIKE ?)\";\n const args = [user.id, `%${searchQuery}%`, `%${searchQuery}%`];\n\n // Get total count\n const countResult = await db.execute({\n sql: `SELECT COUNT(*) as total FROM projects ${whereClause}`,\n args,\n });\n const total = countResult.rows[0][0] as number;\n\n // Get projects with pagination\n const projectsResult = await db.execute({\n sql: `SELECT id, name, domain, location, device, created_at, updated_at \n FROM projects ${whereClause} \n ORDER BY \n CASE \n WHEN name LIKE ? THEN 1 \n WHEN domain LIKE ? THEN 2 \n ELSE 3 \n END,\n created_at DESC \n LIMIT ? OFFSET ?`,\n args: [...args, `%${searchQuery}%`, `%${searchQuery}%`, limit, offset],\n });\n\n const projects = projectsResult.rows.map(row => ({\n id: row[0],\n name: row[1],\n domain: row[2],\n location: row[3],\n device: row[4],\n created_at: row[5],\n updated_at: row[6],\n }));\n\n const meta = createPaginationMeta(page, limit, total);\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n \n const response = createSuccessResponse(\n projects, \n `Found ${total} projects matching \"${searchQuery}\"`, \n { ...meta, query: searchQuery }\n );\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Search projects error:\", error);\n return createErrorResponse(error.message || \"Failed to search projects\", 401);\n }\n});\n\n// Export the Hono app\nexport default {\n fetch: app.fetch,\n};",[],[244],{"_104":252,"_95":253,"_153":254,"_155":-5,"_156":138,"_157":255,"_159":160,"_106":256,"_100":32,"_162":185,"_164":257,"_166":22,"_167":-5,"_168":258,"_98":259},"6287202e-8e97-11f0-ad40-0224a6c84d84","rankingsApi.ts","628720f6-8e97-11f0-ad40-0224a6c84d84",13,["D",1757544129250],"// rankingsApi.ts - Rankings and ranking history API endpoints for RankWatch\n\nimport { Hono } from \"https://deno.land/x/hono@v3.12.6/mod.ts\";\nimport { cors } from \"https://deno.land/x/hono@v3.12.6/middleware.ts\";\nimport { extractUserFromToken } from \"./auth.ts\";\nimport { getDatabase } from \"./database.ts\";\nimport { config } from \"./config.ts\";\nimport { \n createSuccessResponse, \n createErrorResponse, \n logRequest,\n parsePaginationParams,\n createPaginationMeta,\n formatDate\n} from \"./utils.ts\";\nimport { checkRateLimit, getRateLimitHeaders } from \"./rateLimit.ts\";\nimport { \n checkKeywordRanking, \n getCompetitorAnalysis, \n type RankingResult \n} from \"./serperClient.ts\";\n\nconst app = new Hono();\n\n// CORS middleware\napp.use(\"*\", cors({\n origin: \"*\",\n allowMethods: [\"GET\", \"POST\", \"PUT\", \"DELETE\", \"OPTIONS\"],\n allowHeaders: [\"Content-Type\", \"Authorization\"],\n}));\n\n// Middleware to extract and validate user\nasync function authenticateUser(c: any) {\n const authHeader = c.req.header(\"authorization\");\n if (!authHeader) {\n throw new Error(\"Authorization header required\");\n }\n return await extractUserFromToken(authHeader);\n}\n\n// Check if keyword belongs to user\nasync function verifyKeywordOwnership(keywordId: number, userId: number): Promise<{\n hasAccess: boolean;\n keyword?: any;\n project?: any;\n}> {\n const db = getDatabase();\n const result = await db.execute({\n sql: `SELECT k.id, k.keyword, k.target_url, p.id as project_id, p.name as project_name, \n p.domain, p.location, p.device\n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n WHERE k.id = ? AND p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL`,\n args: [keywordId, userId],\n });\n \n if (result.rows.length === 0) {\n return { hasAccess: false };\n }\n\n const row = result.rows[0];\n return {\n hasAccess: true,\n keyword: {\n id: row[0],\n keyword: row[1],\n target_url: row[2],\n },\n project: {\n id: row[3],\n name: row[4],\n domain: row[5],\n location: row[6],\n device: row[7],\n },\n };\n}\n\n// Save ranking result to database\nasync function saveRankingResult(keywordId: number, result: RankingResult): Promise {\n const db = getDatabase();\n \n // Insert ranking record\n await db.execute({\n sql: `INSERT INTO rankings (keyword_id, position, url, title, serp_features, checked_at) \n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [\n keywordId,\n result.position,\n result.url,\n result.title,\n JSON.stringify(result.serp_features),\n result.checked_at,\n ],\n });\n\n // Get previous ranking for change calculation\n const previousRanking = await db.execute({\n sql: `SELECT position FROM rankings \n WHERE keyword_id = ? AND checked_at < ? \n ORDER BY checked_at DESC \n LIMIT 1`,\n args: [keywordId, result.checked_at],\n });\n\n let changeValue = 0;\n if (previousRanking.rows.length > 0 && result.position) {\n const previousPosition = previousRanking.rows[0][0] as number | null;\n if (previousPosition) {\n changeValue = previousPosition - result.position; // Positive = moved up, Negative = moved down\n }\n }\n\n // Insert ranking history record\n if (result.position) {\n await db.execute({\n sql: `INSERT INTO rank_history (keyword_id, position, change_value, checked_at) \n VALUES (?, ?, ?, ?)`,\n args: [keywordId, result.position, changeValue, result.checked_at],\n });\n }\n}\n\n// GET /keywords/:id/rankings - Get current ranking for keyword\napp.get(\"/keywords/:id/rankings\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const keywordId = parseInt(c.req.param(\"id\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(keywordId)) {\n return createErrorResponse(\"Invalid keyword ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/keywords/:id/rankings\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Verify keyword ownership\n const ownership = await verifyKeywordOwnership(keywordId, user.id);\n if (!ownership.hasAccess) {\n return createErrorResponse(\"Keyword not found or access denied\", 404);\n }\n\n const db = getDatabase();\n \n // Get latest ranking\n const rankingResult = await db.execute({\n sql: `SELECT position, url, title, serp_features, checked_at \n FROM rankings \n WHERE keyword_id = ? \n ORDER BY checked_at DESC \n LIMIT 1`,\n args: [keywordId],\n });\n\n let currentRanking = null;\n if (rankingResult.rows.length > 0) {\n const row = rankingResult.rows[0];\n currentRanking = {\n position: row[0],\n url: row[1],\n title: row[2],\n serp_features: row[3] ? JSON.parse(row[3] as string) : null,\n checked_at: row[4],\n };\n }\n\n // Get ranking change from history\n let change = null;\n if (currentRanking) {\n const historyResult = await db.execute({\n sql: `SELECT change_value \n FROM rank_history \n WHERE keyword_id = ? \n ORDER BY checked_at DESC \n LIMIT 1`,\n args: [keywordId],\n });\n\n if (historyResult.rows.length > 0) {\n change = historyResult.rows[0][0] as number;\n }\n }\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse({\n keyword: ownership.keyword,\n project: ownership.project,\n current_ranking: currentRanking,\n change: change,\n last_updated: currentRanking?.checked_at || null,\n }, \"Current ranking retrieved successfully\");\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Get current ranking error:\", error);\n return createErrorResponse(error.message || \"Failed to get current ranking\", 401);\n }\n});\n\n// GET /keywords/:id/history - Get ranking history for keyword\napp.get(\"/keywords/:id/history\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const keywordId = parseInt(c.req.param(\"id\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(keywordId)) {\n return createErrorResponse(\"Invalid keyword ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/keywords/:id/history\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Verify keyword ownership\n const ownership = await verifyKeywordOwnership(keywordId, user.id);\n if (!ownership.hasAccess) {\n return createErrorResponse(\"Keyword not found or access denied\", 404);\n }\n\n const url = new URL(c.req.url);\n const { page, limit } = parsePaginationParams(url);\n const offset = (page - 1) * limit;\n\n // Optional date range filters\n const fromDate = url.searchParams.get(\"from\");\n const toDate = url.searchParams.get(\"to\");\n\n const db = getDatabase();\n \n // Build query with optional date filters\n let whereClause = \"WHERE keyword_id = ?\";\n const args: any[] = [keywordId];\n \n if (fromDate) {\n whereClause += \" AND checked_at >= ?\";\n args.push(fromDate);\n }\n \n if (toDate) {\n whereClause += \" AND checked_at <= ?\";\n args.push(toDate);\n }\n\n // Get total count\n const countResult = await db.execute({\n sql: `SELECT COUNT(*) as total FROM rank_history ${whereClause}`,\n args,\n });\n const total = countResult.rows[0][0] as number;\n\n // Get ranking history with pagination\n const historyResult = await db.execute({\n sql: `SELECT position, change_value, checked_at \n FROM rank_history ${whereClause} \n ORDER BY checked_at DESC \n LIMIT ? OFFSET ?`,\n args: [...args, limit, offset],\n });\n\n const history = historyResult.rows.map(row => ({\n position: row[0],\n change: row[1],\n checked_at: row[2],\n }));\n\n const meta = createPaginationMeta(page, limit, total);\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n \n const response = createSuccessResponse({\n keyword: ownership.keyword,\n project: ownership.project,\n history,\n date_range: {\n from: fromDate || null,\n to: toDate || null,\n },\n }, \"Ranking history retrieved successfully\", meta);\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Get ranking history error:\", error);\n return createErrorResponse(error.message || \"Failed to get ranking history\", 401);\n }\n});\n\n// GET /keywords/:id/competitors - Get competitor analysis for keyword\napp.get(\"/keywords/:id/competitors\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const keywordId = parseInt(c.req.param(\"id\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(keywordId)) {\n return createErrorResponse(\"Invalid keyword ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/keywords/:id/competitors\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Verify keyword ownership\n const ownership = await verifyKeywordOwnership(keywordId, user.id);\n if (!ownership.hasAccess) {\n return createErrorResponse(\"Keyword not found or access denied\", 404);\n }\n\n const url = new URL(c.req.url);\n const topN = Math.min(20, Math.max(5, parseInt(url.searchParams.get(\"limit\") || \"10\")));\n\n // Get competitor analysis using Serper\n const competitorAnalysis = await getCompetitorAnalysis(\n ownership.keyword!.keyword,\n ownership.project!.location,\n ownership.project!.device,\n topN\n );\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse({\n keyword: ownership.keyword,\n project: ownership.project,\n competitors: competitorAnalysis.competitors,\n checked_at: competitorAnalysis.checked_at,\n top_n: topN,\n }, \"Competitor analysis retrieved successfully\");\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Get competitor analysis error:\", error);\n return createErrorResponse(error.message || \"Failed to get competitor analysis\", 400);\n }\n});\n\n// POST /keywords/:id/check-now - Force immediate ranking check (unlimited plan only)\napp.post(\"/keywords/:id/check-now\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const keywordId = parseInt(c.req.param(\"id\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(keywordId)) {\n return createErrorResponse(\"Invalid keyword ID\", 400);\n }\n\n // Check if user has unlimited plan\n if (user.plan !== \"unlimited\") {\n return createErrorResponse(\"Immediate ranking checks are only available for unlimited plan users\", 403);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/keywords/:id/check-now\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Verify keyword ownership\n const ownership = await verifyKeywordOwnership(keywordId, user.id);\n if (!ownership.hasAccess) {\n return createErrorResponse(\"Keyword not found or access denied\", 404);\n }\n\n // Perform ranking check\n const rankingResult = await checkKeywordRanking(\n ownership.keyword!.keyword,\n ownership.project!.domain,\n ownership.keyword!.target_url,\n ownership.project!.location,\n ownership.project!.device\n );\n\n // Save result to database\n await saveRankingResult(keywordId, rankingResult);\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse({\n keyword: ownership.keyword,\n project: ownership.project,\n ranking_result: {\n position: rankingResult.position,\n url: rankingResult.url,\n title: rankingResult.title,\n found: rankingResult.found,\n serp_features: rankingResult.serp_features,\n checked_at: rankingResult.checked_at,\n error: rankingResult.error,\n },\n }, \"Ranking check completed successfully\");\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Manual ranking check error:\", error);\n return createErrorResponse(error.message || \"Failed to perform ranking check\", 400);\n }\n});\n\n// GET /projects/:projectId/summary - Get project summary with ranking stats\napp.get(\"/projects/:projectId/summary\", async (c) => {\n try {\n const user = await authenticateUser(c);\n const projectId = parseInt(c.req.param(\"projectId\"));\n logRequest(c.req.raw, user.id);\n\n if (isNaN(projectId)) {\n return createErrorResponse(\"Invalid project ID\", 400);\n }\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects/:projectId/summary\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const db = getDatabase();\n \n // Verify project ownership\n const projectResult = await db.execute({\n sql: \"SELECT id, name, domain FROM projects WHERE id = ? AND user_id = ? AND deleted_at IS NULL\",\n args: [projectId, user.id],\n });\n\n if (projectResult.rows.length === 0) {\n return createErrorResponse(\"Project not found or access denied\", 404);\n }\n\n const project = {\n id: projectResult.rows[0][0],\n name: projectResult.rows[0][1],\n domain: projectResult.rows[0][2],\n };\n\n // Get summary statistics\n const [keywordCount, topRankings, improvements, declines] = await Promise.all([\n // Total keywords count\n db.execute({\n sql: \"SELECT COUNT(*) FROM keywords WHERE project_id = ? AND deleted_at IS NULL\",\n args: [projectId],\n }),\n \n // Top 10 rankings count\n db.execute({\n sql: `SELECT COUNT(DISTINCT k.id) \n FROM keywords k \n LEFT JOIN rankings r ON k.id = r.keyword_id \n WHERE k.project_id = ? AND k.deleted_at IS NULL \n AND r.id = (SELECT id FROM rankings WHERE keyword_id = k.id ORDER BY checked_at DESC LIMIT 1)\n AND r.position <= 10 AND r.position IS NOT NULL`,\n args: [projectId],\n }),\n\n // Recent improvements (moved up in last 7 days)\n db.execute({\n sql: `SELECT COUNT(*) \n FROM rank_history rh \n JOIN keywords k ON rh.keyword_id = k.id \n WHERE k.project_id = ? AND k.deleted_at IS NULL \n AND rh.change_value > 0 \n AND rh.checked_at >= datetime('now', '-7 days')`,\n args: [projectId],\n }),\n\n // Recent declines (moved down in last 7 days)\n db.execute({\n sql: `SELECT COUNT(*) \n FROM rank_history rh \n JOIN keywords k ON rh.keyword_id = k.id \n WHERE k.project_id = ? AND k.deleted_at IS NULL \n AND rh.change_value < 0 \n AND rh.checked_at >= datetime('now', '-7 days')`,\n args: [projectId],\n }),\n ]);\n\n // Get recent ranking changes (top movers)\n const recentChanges = await db.execute({\n sql: `SELECT k.keyword, rh.position, rh.change_value, rh.checked_at \n FROM rank_history rh \n JOIN keywords k ON rh.keyword_id = k.id \n WHERE k.project_id = ? AND k.deleted_at IS NULL \n AND rh.checked_at >= datetime('now', '-7 days')\n AND rh.change_value != 0\n ORDER BY ABS(rh.change_value) DESC \n LIMIT 10`,\n args: [projectId],\n });\n\n const topMovers = recentChanges.rows.map(row => ({\n keyword: row[0],\n position: row[1],\n change: row[2],\n checked_at: row[3],\n }));\n\n const summary = {\n project,\n stats: {\n total_keywords: keywordCount.rows[0][0],\n top_10_rankings: topRankings.rows[0][0],\n recent_improvements: improvements.rows[0][0],\n recent_declines: declines.rows[0][0],\n },\n top_movers: topMovers,\n summary_date: formatDate(new Date()),\n };\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse(summary, \"Project summary retrieved successfully\");\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Get project summary error:\", error);\n return createErrorResponse(error.message || \"Failed to get project summary\", 401);\n }\n});\n\n// Export the Hono app\nexport default {\n fetch: app.fetch,\n};",[],[253],{"_104":261,"_95":262,"_153":263,"_155":-5,"_156":138,"_157":264,"_159":160,"_106":265,"_100":32,"_162":185,"_164":266,"_166":22,"_167":-5,"_168":267,"_98":268},"8edcebd2-8e96-11f0-a1ac-0224a6c84d84","rateLimit.ts","8edcec90-8e96-11f0-a1ac-0224a6c84d84",7,["D",1757543774152],"// rateLimit.ts - SQLite-based rate limiting system for RankWatch\n\nimport { config, type UserPlan } from \"./config.ts\";\nimport { getDatabase } from \"./database.ts\";\n\nexport interface RateLimitResult {\n allowed: boolean;\n remaining: number;\n resetTime: Date;\n message?: string;\n}\n\n// Get rate limit configuration for user plan\nfunction getRateLimitConfig(plan: UserPlan) {\n return config.rateLimit[plan];\n}\n\n// Clean up old rate limit records\nexport async function cleanupRateLimits(): Promise {\n const db = getDatabase();\n const oneDayAgo = new Date(Date.now() - 24 * 60 * 60 * 1000);\n \n await db.execute({\n sql: \"DELETE FROM rate_limits WHERE window_end < ?\",\n args: [oneDayAgo.toISOString()],\n });\n}\n\n// Check and update rate limit for user and endpoint\nexport async function checkRateLimit(\n userId: number, \n plan: UserPlan, \n endpoint: string\n): Promise {\n const db = getDatabase();\n const config = getRateLimitConfig(plan);\n const now = new Date();\n const windowStart = new Date(now.getTime() - config.windowMs);\n const windowEnd = new Date(now.getTime());\n\n // First, cleanup old records\n await cleanupRateLimits();\n\n // Check current usage in this window\n const existingLimit = await db.execute({\n sql: `SELECT id, requests_made, window_start, window_end \n FROM rate_limits \n WHERE user_id = ? AND endpoint = ? AND window_end > ?\n ORDER BY window_start DESC \n LIMIT 1`,\n args: [userId, endpoint, now.toISOString()],\n });\n\n let requestsMade = 0;\n let rateLimitId = null;\n let currentWindowStart = windowStart;\n let currentWindowEnd = windowEnd;\n\n if (existingLimit.rows.length > 0) {\n const limitData = existingLimit.rows[0];\n rateLimitId = limitData[0] as number;\n requestsMade = limitData[1] as number;\n currentWindowStart = new Date(limitData[2] as string);\n currentWindowEnd = new Date(limitData[3] as string);\n\n // If window has expired, create new window\n if (currentWindowEnd <= now) {\n currentWindowStart = windowStart;\n currentWindowEnd = windowEnd;\n requestsMade = 0;\n rateLimitId = null;\n }\n }\n\n // Check if limit exceeded\n if (requestsMade >= config.requests) {\n return {\n allowed: false,\n remaining: 0,\n resetTime: currentWindowEnd,\n message: `Rate limit exceeded. Maximum ${config.requests} requests per hour allowed for ${plan} plan.`,\n };\n }\n\n // Increment request count\n const newRequestCount = requestsMade + 1;\n\n if (rateLimitId) {\n // Update existing record\n await db.execute({\n sql: \"UPDATE rate_limits SET requests_made = ? WHERE id = ?\",\n args: [newRequestCount, rateLimitId],\n });\n } else {\n // Create new record\n await db.execute({\n sql: `INSERT INTO rate_limits (user_id, endpoint, requests_made, window_start, window_end) \n VALUES (?, ?, ?, ?, ?)`,\n args: [userId, endpoint, newRequestCount, currentWindowStart.toISOString(), currentWindowEnd.toISOString()],\n });\n }\n\n return {\n allowed: true,\n remaining: config.requests - newRequestCount,\n resetTime: currentWindowEnd,\n };\n}\n\n// Middleware function to check rate limits\nexport async function rateLimitMiddleware(\n userId: number,\n plan: UserPlan,\n endpoint: string\n): Promise {\n const result = await checkRateLimit(userId, plan, endpoint);\n\n if (!result.allowed) {\n return new Response(\n JSON.stringify({\n error: \"Rate limit exceeded\",\n message: result.message,\n resetTime: result.resetTime.toISOString(),\n }),\n {\n status: 429,\n headers: {\n \"Content-Type\": \"application/json\",\n \"X-RateLimit-Limit\": getRateLimitConfig(plan).requests.toString(),\n \"X-RateLimit-Remaining\": \"0\",\n \"X-RateLimit-Reset\": Math.ceil(result.resetTime.getTime() / 1000).toString(),\n \"Retry-After\": Math.ceil((result.resetTime.getTime() - Date.now()) / 1000).toString(),\n },\n }\n );\n }\n\n // Add rate limit headers to successful responses\n return null; // No error, continue with request\n}\n\n// Get rate limit headers for successful responses\nexport function getRateLimitHeaders(result: RateLimitResult, plan: UserPlan): HeadersInit {\n const config = getRateLimitConfig(plan);\n \n return {\n \"X-RateLimit-Limit\": config.requests.toString(),\n \"X-RateLimit-Remaining\": result.remaining.toString(),\n \"X-RateLimit-Reset\": Math.ceil(result.resetTime.getTime() / 1000).toString(),\n };\n}\n\n// Get current rate limit status for a user\nexport async function getRateLimitStatus(\n userId: number,\n plan: UserPlan,\n endpoint?: string\n): Promise<{ [endpoint: string]: RateLimitResult }> {\n const db = getDatabase();\n const now = new Date();\n\n let query = `SELECT endpoint, requests_made, window_start, window_end \n FROM rate_limits \n WHERE user_id = ? AND window_end > ?`;\n const args: any[] = [userId, now.toISOString()];\n\n if (endpoint) {\n query += \" AND endpoint = ?\";\n args.push(endpoint);\n }\n\n const result = await db.execute({ sql: query, args });\n const config = getRateLimitConfig(plan);\n const status: { [endpoint: string]: RateLimitResult } = {};\n\n for (const row of result.rows) {\n const endpointName = row[0] as string;\n const requestsMade = row[1] as number;\n const windowEnd = new Date(row[3] as string);\n\n status[endpointName] = {\n allowed: requestsMade < config.requests,\n remaining: Math.max(0, config.requests - requestsMade),\n resetTime: windowEnd,\n };\n }\n\n return status;\n}\n\n// Reset rate limits for a user (admin function)\nexport async function resetUserRateLimits(userId: number): Promise {\n const db = getDatabase();\n \n await db.execute({\n sql: \"DELETE FROM rate_limits WHERE user_id = ?\",\n args: [userId],\n });\n}",[],[262],{"_104":270,"_95":271,"_153":272,"_155":-5,"_156":138,"_157":273,"_159":160,"_106":274,"_100":32,"_162":185,"_164":275,"_166":22,"_167":-5,"_168":276,"_98":277},"8e60e52c-8e97-11f0-98a6-0224a6c84d84","searchApi.ts","8e60e5ea-8e97-11f0-98a6-0224a6c84d84",14,["D",1757544202835],"// searchApi.ts - Global search API endpoints for RankWatch\n\nimport { Hono } from \"https://deno.land/x/hono@v3.12.6/mod.ts\";\nimport { cors } from \"https://deno.land/x/hono@v3.12.6/middleware.ts\";\nimport { extractUserFromToken } from \"./auth.ts\";\nimport { getDatabase } from \"./database.ts\";\nimport { \n createSuccessResponse, \n createErrorResponse, \n logRequest,\n parsePaginationParams,\n createPaginationMeta,\n parseSearchQuery\n} from \"./utils.ts\";\nimport { checkRateLimit, getRateLimitHeaders } from \"./rateLimit.ts\";\n\nconst app = new Hono();\n\n// CORS middleware\napp.use(\"*\", cors({\n origin: \"*\",\n allowMethods: [\"GET\", \"POST\", \"PUT\", \"DELETE\", \"OPTIONS\"],\n allowHeaders: [\"Content-Type\", \"Authorization\"],\n}));\n\n// Middleware to extract and validate user\nasync function authenticateUser(c: any) {\n const authHeader = c.req.header(\"authorization\");\n if (!authHeader) {\n throw new Error(\"Authorization header required\");\n }\n return await extractUserFromToken(authHeader);\n}\n\n// Search projects\nasync function searchProjects(userId: number, query: string, limit: number): Promise {\n const db = getDatabase();\n \n const result = await db.execute({\n sql: `SELECT id, name, domain, location, device, created_at, updated_at \n FROM projects \n WHERE user_id = ? AND deleted_at IS NULL \n AND (name LIKE ? OR domain LIKE ?) \n ORDER BY \n CASE \n WHEN name LIKE ? THEN 1 \n WHEN domain LIKE ? THEN 2 \n ELSE 3 \n END,\n created_at DESC \n LIMIT ?`,\n args: [userId, `%${query}%`, `%${query}%`, `%${query}%`, `%${query}%`, limit],\n });\n\n return result.rows.map(row => ({\n type: \"project\",\n id: row[0],\n name: row[1],\n domain: row[2],\n location: row[3],\n device: row[4],\n created_at: row[5],\n updated_at: row[6],\n }));\n}\n\n// Search keywords\nasync function searchKeywords(userId: number, query: string, limit: number): Promise {\n const db = getDatabase();\n \n const result = await db.execute({\n sql: `SELECT k.id, k.keyword, k.target_url, k.active, k.created_at, k.updated_at,\n p.id as project_id, p.name as project_name, p.domain as project_domain\n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n WHERE p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL \n AND (k.keyword LIKE ? OR k.target_url LIKE ?) \n ORDER BY \n CASE \n WHEN k.keyword LIKE ? THEN 1 \n WHEN k.target_url LIKE ? THEN 2 \n ELSE 3 \n END,\n k.created_at DESC \n LIMIT ?`,\n args: [userId, `%${query}%`, `%${query}%`, `%${query}%`, `%${query}%`, limit],\n });\n\n return result.rows.map(row => ({\n type: \"keyword\",\n id: row[0],\n keyword: row[1],\n target_url: row[2],\n active: row[3],\n created_at: row[4],\n updated_at: row[5],\n project: {\n id: row[6],\n name: row[7],\n domain: row[8],\n },\n }));\n}\n\n// Search ranking results\nasync function searchRankings(userId: number, query: string, limit: number): Promise {\n const db = getDatabase();\n \n const result = await db.execute({\n sql: `SELECT DISTINCT r.id, r.position, r.url, r.title, r.checked_at,\n k.id as keyword_id, k.keyword,\n p.id as project_id, p.name as project_name, p.domain as project_domain\n FROM rankings r \n JOIN keywords k ON r.keyword_id = k.id \n JOIN projects p ON k.project_id = p.id \n WHERE p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL \n AND (r.title LIKE ? OR r.url LIKE ? OR k.keyword LIKE ?) \n ORDER BY r.checked_at DESC \n LIMIT ?`,\n args: [userId, `%${query}%`, `%${query}%`, `%${query}%`, limit],\n });\n\n return result.rows.map(row => ({\n type: \"ranking\",\n id: row[0],\n position: row[1],\n url: row[2],\n title: row[3],\n checked_at: row[4],\n keyword: {\n id: row[5],\n keyword: row[6],\n },\n project: {\n id: row[7],\n name: row[8],\n domain: row[9],\n },\n }));\n}\n\n// GET /search - Global search across all user data\napp.get(\"/search\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/search\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const url = new URL(c.req.url);\n const searchQuery = parseSearchQuery(url);\n \n if (!searchQuery) {\n return createErrorResponse(\"Search query 'q' parameter is required\", 400);\n }\n\n if (searchQuery.length < 2) {\n return createErrorResponse(\"Search query must be at least 2 characters long\", 400);\n }\n\n // Get search type filter\n const type = url.searchParams.get(\"type\") || \"all\";\n const validTypes = [\"all\", \"projects\", \"keywords\", \"rankings\"];\n \n if (!validTypes.includes(type)) {\n return createErrorResponse(`Invalid type. Must be one of: ${validTypes.join(\", \")}`, 400);\n }\n\n const { page, limit } = parsePaginationParams(url);\n const maxResultsPerType = Math.ceil(limit / 3); // Distribute results across types\n\n let results: any[] = [];\n let totalFound = 0;\n\n // Search based on type filter\n if (type === \"all\" || type === \"projects\") {\n const projects = await searchProjects(user.id, searchQuery, maxResultsPerType);\n results.push(...projects);\n totalFound += projects.length;\n }\n\n if (type === \"all\" || type === \"keywords\") {\n const keywords = await searchKeywords(user.id, searchQuery, maxResultsPerType);\n results.push(...keywords);\n totalFound += keywords.length;\n }\n\n if (type === \"all\" || type === \"rankings\") {\n const rankings = await searchRankings(user.id, searchQuery, maxResultsPerType);\n results.push(...rankings);\n totalFound += rankings.length;\n }\n\n // Sort results by relevance (exact matches first)\n results.sort((a, b) => {\n const aExact = (\n a.name?.toLowerCase().includes(searchQuery.toLowerCase()) ||\n a.keyword?.toLowerCase().includes(searchQuery.toLowerCase()) ||\n a.title?.toLowerCase().includes(searchQuery.toLowerCase())\n ) ? 1 : 0;\n \n const bExact = (\n b.name?.toLowerCase().includes(searchQuery.toLowerCase()) ||\n b.keyword?.toLowerCase().includes(searchQuery.toLowerCase()) ||\n b.title?.toLowerCase().includes(searchQuery.toLowerCase())\n ) ? 1 : 0;\n \n return bExact - aExact;\n });\n\n // Apply pagination to sorted results\n const offset = (page - 1) * limit;\n const paginatedResults = results.slice(offset, offset + limit);\n\n // Group results by type for better presentation\n const groupedResults = {\n projects: paginatedResults.filter(r => r.type === \"project\"),\n keywords: paginatedResults.filter(r => r.type === \"keyword\"),\n rankings: paginatedResults.filter(r => r.type === \"ranking\"),\n };\n\n const meta = {\n query: searchQuery,\n type: type,\n total_found: totalFound,\n page: page,\n limit: limit,\n results_breakdown: {\n projects: groupedResults.projects.length,\n keywords: groupedResults.keywords.length,\n rankings: groupedResults.rankings.length,\n },\n };\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse({\n results: type === \"all\" ? groupedResults : paginatedResults,\n summary: {\n total_found: totalFound,\n showing: paginatedResults.length,\n query: searchQuery,\n type: type,\n },\n }, `Found ${totalFound} results for \"${searchQuery}\"`, meta);\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Global search error:\", error);\n return createErrorResponse(error.message || \"Failed to perform search\", 401);\n }\n});\n\n// GET /search/suggestions - Get search suggestions/autocomplete\napp.get(\"/search/suggestions\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/search/suggestions\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const url = new URL(c.req.url);\n const searchQuery = parseSearchQuery(url);\n \n if (!searchQuery) {\n return createErrorResponse(\"Search query 'q' parameter is required\", 400);\n }\n\n if (searchQuery.length < 1) {\n return createErrorResponse(\"Search query must be at least 1 character long\", 400);\n }\n\n const maxSuggestions = Math.min(20, parseInt(url.searchParams.get(\"limit\") || \"10\"));\n const db = getDatabase();\n\n // Get suggestions from projects\n const projectSuggestions = await db.execute({\n sql: `SELECT DISTINCT name as suggestion, 'project' as type, name as display\n FROM projects \n WHERE user_id = ? AND deleted_at IS NULL \n AND name LIKE ? \n ORDER BY name \n LIMIT ?`,\n args: [user.id, `${searchQuery}%`, Math.ceil(maxSuggestions / 3)],\n });\n\n // Get suggestions from keywords\n const keywordSuggestions = await db.execute({\n sql: `SELECT DISTINCT k.keyword as suggestion, 'keyword' as type, k.keyword as display\n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n WHERE p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL \n AND k.keyword LIKE ? \n ORDER BY k.keyword \n LIMIT ?`,\n args: [user.id, `${searchQuery}%`, Math.ceil(maxSuggestions / 3)],\n });\n\n // Get suggestions from domains\n const domainSuggestions = await db.execute({\n sql: `SELECT DISTINCT domain as suggestion, 'domain' as type, domain as display\n FROM projects \n WHERE user_id = ? AND deleted_at IS NULL \n AND domain LIKE ? \n ORDER BY domain \n LIMIT ?`,\n args: [user.id, `${searchQuery}%`, Math.ceil(maxSuggestions / 3)],\n });\n\n // Combine and format suggestions\n const suggestions = [\n ...projectSuggestions.rows.map(row => ({ suggestion: row[0], type: row[1], display: row[2] })),\n ...keywordSuggestions.rows.map(row => ({ suggestion: row[0], type: row[1], display: row[2] })),\n ...domainSuggestions.rows.map(row => ({ suggestion: row[0], type: row[1], display: row[2] })),\n ];\n\n // Remove duplicates and limit results\n const uniqueSuggestions = suggestions\n .filter((suggestion, index, self) => \n index === self.findIndex(s => s.suggestion === suggestion.suggestion)\n )\n .slice(0, maxSuggestions);\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse({\n query: searchQuery,\n suggestions: uniqueSuggestions,\n count: uniqueSuggestions.length,\n }, `Found ${uniqueSuggestions.length} suggestions for \"${searchQuery}\"`);\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Search suggestions error:\", error);\n return createErrorResponse(error.message || \"Failed to get search suggestions\", 401);\n }\n});\n\n// GET /search/recent - Get recent search history (client-side implementation recommended)\napp.get(\"/search/recent\", async (c) => {\n try {\n const user = await authenticateUser(c);\n logRequest(c.req.raw, user.id);\n\n // Check rate limit\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/search/recent\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Since we don't store search history in the database for privacy,\n // this endpoint returns commonly accessed items instead\n const db = getDatabase();\n \n // Get recently created/updated items\n const recentItems = await db.execute({\n sql: `\n SELECT 'project' as type, id, name as title, domain as subtitle, updated_at \n FROM projects \n WHERE user_id = ? AND deleted_at IS NULL \n UNION ALL\n SELECT 'keyword' as type, k.id, k.keyword as title, p.name as subtitle, k.updated_at\n FROM keywords k \n JOIN projects p ON k.project_id = p.id \n WHERE p.user_id = ? AND k.deleted_at IS NULL AND p.deleted_at IS NULL \n ORDER BY updated_at DESC \n LIMIT 10`,\n args: [user.id, user.id],\n });\n\n const recent = recentItems.rows.map(row => ({\n type: row[0],\n id: row[1],\n title: row[2],\n subtitle: row[3],\n updated_at: row[4],\n }));\n\n const headers = getRateLimitHeaders(rateLimitResult, user.plan);\n const response = createSuccessResponse({\n recent_items: recent,\n count: recent.length,\n note: \"This shows recently updated items. For search history, implement client-side storage.\",\n }, \"Recent items retrieved successfully\");\n \n // Add rate limit headers\n Object.entries(headers).forEach(([key, value]) => {\n response.headers.set(key, value);\n });\n\n return response;\n\n } catch (error) {\n console.error(\"Recent search error:\", error);\n return createErrorResponse(error.message || \"Failed to get recent items\", 401);\n }\n});\n\n// Export the Hono app\nexport default {\n fetch: app.fetch,\n};",[],[271],{"_104":279,"_95":280,"_153":281,"_155":-5,"_156":138,"_157":282,"_159":160,"_106":283,"_100":32,"_162":185,"_164":284,"_166":22,"_167":-5,"_168":285,"_98":286},"235980cc-8e97-11f0-9aab-0224a6c84d84","serperClient.ts","2359818a-8e97-11f0-9aab-0224a6c84d84",12,["D",1757544023268],"// serperClient.ts - Serper.dev API client for Google search ranking\n\nimport { config } from \"./config.ts\";\nimport { retryWithBackoff, sleep } from \"./utils.ts\";\n\n// Serper API response interfaces\nexport interface SerperResult {\n position: number;\n title: string;\n link: string;\n displayLink: string;\n snippet: string;\n date?: string;\n sitelinks?: {\n title: string;\n link: string;\n }[];\n}\n\nexport interface SerperSearchResponse {\n searchParameters: {\n q: string;\n type: string;\n engine: string;\n gl?: string;\n hl?: string;\n device?: string;\n num?: number;\n };\n organic: SerperResult[];\n answerBox?: any;\n peopleAlsoAsk?: any[];\n relatedSearches?: any[];\n knowledgeGraph?: any;\n pagination?: {\n current: number;\n next?: string;\n other: any[];\n };\n searchInformation: {\n totalResults: string;\n timeTaken: number;\n formattedTotalResults: string;\n formattedTimeTaken: string;\n };\n}\n\nexport interface RankingResult {\n keyword: string;\n position: number | null;\n url: string | null;\n title: string | null;\n snippet: string | null;\n found: boolean;\n serp_features: {\n answer_box: boolean;\n knowledge_graph: boolean;\n featured_snippet: boolean;\n local_pack: boolean;\n related_questions: boolean;\n sitelinks: boolean;\n };\n total_results: string;\n search_time: number;\n checked_at: string;\n error?: string;\n}\n\n// Rate limiting for Serper API calls\nconst serperRateLimit = {\n requests: 0,\n windowStart: Date.now(),\n maxRequests: 100, // Conservative limit\n windowMs: 60 * 1000, // 1 minute\n};\n\nfunction checkSerperRateLimit(): boolean {\n const now = Date.now();\n \n // Reset window if expired\n if (now - serperRateLimit.windowStart >= serperRateLimit.windowMs) {\n serperRateLimit.requests = 0;\n serperRateLimit.windowStart = now;\n }\n \n return serperRateLimit.requests < serperRateLimit.maxRequests;\n}\n\nfunction incrementSerperRateLimit(): void {\n serperRateLimit.requests++;\n}\n\n// Make request to Serper API\nasync function makeSerperRequest(\n keyword: string,\n location: string = \"us\",\n device: string = \"desktop\",\n num: number = 100\n): Promise {\n if (!config.serper.apiKey) {\n throw new Error(\"Serper API key not configured\");\n }\n\n // Check rate limit\n if (!checkSerperRateLimit()) {\n throw new Error(\"Serper API rate limit exceeded\");\n }\n\n const params = {\n q: keyword,\n gl: location, // Geographic location\n hl: \"en\", // Language\n device: device === \"mobile\" ? \"mobile\" : \"desktop\",\n num: num, // Number of results (max 100)\n type: \"search\",\n };\n\n const response = await fetch(\"https://google.serper.dev/search\", {\n method: \"POST\",\n headers: {\n \"X-API-KEY\": config.serper.apiKey,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(params),\n });\n\n incrementSerperRateLimit();\n\n if (!response.ok) {\n const errorText = await response.text();\n throw new Error(`Serper API error: ${response.status} - ${errorText}`);\n }\n\n const data = await response.json();\n return data as SerperSearchResponse;\n}\n\n// Find ranking position for a specific domain\nexport function findDomainRanking(\n results: SerperResult[],\n targetDomain: string,\n targetUrl?: string\n): { position: number; result: SerperResult } | null {\n // Clean domain for comparison\n const cleanTargetDomain = targetDomain.replace(/^https?:\\/\\//, \"\").replace(/^www\\./, \"\").toLowerCase();\n \n for (let i = 0; i < results.length; i++) {\n const result = results[i];\n const resultDomain = result.displayLink.replace(/^www\\./, \"\").toLowerCase();\n \n // Check domain match\n if (resultDomain === cleanTargetDomain || resultDomain.endsWith(`.${cleanTargetDomain}`)) {\n // If specific URL provided, check for URL match\n if (targetUrl) {\n const cleanTargetUrl = targetUrl.replace(/^https?:\\/\\//, \"\").replace(/\\/$/, \"\").toLowerCase();\n const cleanResultUrl = result.link.replace(/^https?:\\/\\//, \"\").replace(/\\/$/, \"\").toLowerCase();\n \n // Check if URLs match (exact or path contains)\n if (cleanResultUrl === cleanTargetUrl || cleanResultUrl.includes(cleanTargetUrl)) {\n return { position: result.position || i + 1, result };\n }\n } else {\n // Domain match is sufficient\n return { position: result.position || i + 1, result };\n }\n }\n }\n \n return null;\n}\n\n// Detect SERP features\nfunction detectSerpFeatures(data: SerperSearchResponse): RankingResult['serp_features'] {\n return {\n answer_box: !!data.answerBox,\n knowledge_graph: !!data.knowledgeGraph,\n featured_snippet: !!data.organic?.some((result: any) => result.snippet?.includes(\"...\")),\n local_pack: !!data.organic?.some((result: any) => result.type === \"local\"),\n related_questions: !!(data.peopleAlsoAsk && data.peopleAlsoAsk.length > 0),\n sitelinks: !!data.organic?.some((result: any) => result.sitelinks && result.sitelinks.length > 0),\n };\n}\n\n// Check keyword ranking\nexport async function checkKeywordRanking(\n keyword: string,\n domain: string,\n targetUrl?: string,\n location: string = \"us\",\n device: string = \"desktop\"\n): Promise {\n const checkedAt = new Date().toISOString();\n \n try {\n // Make request with retry logic\n const data = await retryWithBackoff(\n () => makeSerperRequest(keyword, location, device),\n 3, // max retries\n 1000 // base delay\n );\n\n // Find domain ranking\n const ranking = findDomainRanking(data.organic || [], domain, targetUrl);\n \n // Detect SERP features\n const serpFeatures = detectSerpFeatures(data);\n\n const result: RankingResult = {\n keyword,\n position: ranking?.position || null,\n url: ranking?.result.link || null,\n title: ranking?.result.title || null,\n snippet: ranking?.result.snippet || null,\n found: !!ranking,\n serp_features: serpFeatures,\n total_results: data.searchInformation?.totalResults || \"0\",\n search_time: data.searchInformation?.timeTaken || 0,\n checked_at: checkedAt,\n };\n\n return result;\n\n } catch (error) {\n console.error(`Error checking ranking for \"${keyword}\":`, error);\n \n return {\n keyword,\n position: null,\n url: null,\n title: null,\n snippet: null,\n found: false,\n serp_features: {\n answer_box: false,\n knowledge_graph: false,\n featured_snippet: false,\n local_pack: false,\n related_questions: false,\n sitelinks: false,\n },\n total_results: \"0\",\n search_time: 0,\n checked_at: checkedAt,\n error: error.message,\n };\n }\n}\n\n// Batch check multiple keywords with delay between requests\nexport async function batchCheckKeywords(\n keywords: Array<{\n keyword: string;\n domain: string;\n target_url?: string;\n location?: string;\n device?: string;\n }>,\n delayMs: number = 1000\n): Promise {\n const results: RankingResult[] = [];\n \n for (let i = 0; i < keywords.length; i++) {\n const keywordData = keywords[i];\n \n try {\n const result = await checkKeywordRanking(\n keywordData.keyword,\n keywordData.domain,\n keywordData.target_url,\n keywordData.location || \"us\",\n keywordData.device || \"desktop\"\n );\n \n results.push(result);\n \n // Add delay between requests to be respectful\n if (i < keywords.length - 1) {\n await sleep(delayMs);\n }\n \n } catch (error) {\n console.error(`Batch check error for keyword \"${keywordData.keyword}\":`, error);\n \n results.push({\n keyword: keywordData.keyword,\n position: null,\n url: null,\n title: null,\n snippet: null,\n found: false,\n serp_features: {\n answer_box: false,\n knowledge_graph: false,\n featured_snippet: false,\n local_pack: false,\n related_questions: false,\n sitelinks: false,\n },\n total_results: \"0\",\n search_time: 0,\n checked_at: new Date().toISOString(),\n error: error.message,\n });\n }\n }\n \n return results;\n}\n\n// Get competitor analysis for a keyword\nexport async function getCompetitorAnalysis(\n keyword: string,\n location: string = \"us\",\n device: string = \"desktop\",\n topN: number = 10\n): Promise<{\n keyword: string;\n competitors: Array<{\n position: number;\n domain: string;\n url: string;\n title: string;\n snippet: string;\n }>;\n checked_at: string;\n}> {\n const data = await makeSerperRequest(keyword, location, device, Math.min(topN, 20));\n \n const competitors = (data.organic || [])\n .slice(0, topN)\n .map((result, index) => ({\n position: result.position || index + 1,\n domain: result.displayLink,\n url: result.link,\n title: result.title,\n snippet: result.snippet,\n }));\n\n return {\n keyword,\n competitors,\n checked_at: new Date().toISOString(),\n };\n}\n\n// Validate Serper API configuration\nexport function validateSerperConfig(): { valid: boolean; error?: string } {\n if (!config.serper.apiKey) {\n return { valid: false, error: \"Serper API key not configured\" };\n }\n \n if (!config.serper.baseUrl) {\n return { valid: false, error: \"Serper base URL not configured\" };\n }\n \n return { valid: true };\n}\n\n// Get current rate limit status\nexport function getSerperRateLimitStatus(): {\n requests: number;\n maxRequests: number;\n remaining: number;\n resetTime: Date;\n} {\n const now = Date.now();\n const resetTime = new Date(serperRateLimit.windowStart + serperRateLimit.windowMs);\n \n return {\n requests: serperRateLimit.requests,\n maxRequests: serperRateLimit.maxRequests,\n remaining: Math.max(0, serperRateLimit.maxRequests - serperRateLimit.requests),\n resetTime,\n };\n}",[],[280],{"_104":288,"_95":289,"_153":290,"_155":-5,"_156":138,"_157":291,"_159":160,"_106":292,"_100":32,"_162":185,"_164":293,"_166":22,"_167":-5,"_168":294,"_98":295},"9cf8c51a-8e96-11f0-b551-0224a6c84d84","utils.ts","9cf8c5e2-8e96-11f0-b551-0224a6c84d84",8,["D",1757543797816],"// utils.ts - Utility functions and helpers for RankWatch\n\n// Standard API response interface\nexport interface ApiResponse {\n success: boolean;\n data?: T;\n error?: string;\n message?: string;\n meta?: {\n page?: number;\n limit?: number;\n total?: number;\n [key: string]: any;\n };\n}\n\n// Create standardized success response\nexport function createSuccessResponse(\n data: T,\n message?: string,\n meta?: any\n): Response {\n const response: ApiResponse = {\n success: true,\n data,\n ...(message && { message }),\n ...(meta && { meta }),\n };\n\n return new Response(JSON.stringify(response), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\n// Create standardized error response\nexport function createErrorResponse(\n error: string,\n status: number = 400,\n details?: any\n): Response {\n const response: ApiResponse = {\n success: false,\n error,\n ...(details && { details }),\n };\n\n return new Response(JSON.stringify(response), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\n// Validate email format\nexport function isValidEmail(email: string): boolean {\n const emailRegex = /^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/;\n return emailRegex.test(email);\n}\n\n// Validate password strength\nexport function isValidPassword(password: string): { valid: boolean; message?: string } {\n if (password.length < 8) {\n return { valid: false, message: \"Password must be at least 8 characters long\" };\n }\n \n if (!/(?=.*[a-z])(?=.*[A-Z])(?=.*\\d)/.test(password)) {\n return { \n valid: false, \n message: \"Password must contain at least one uppercase letter, one lowercase letter, and one number\" \n };\n }\n\n return { valid: true };\n}\n\n// Validate URL format\nexport function isValidUrl(url: string): boolean {\n try {\n new URL(url);\n return true;\n } catch {\n return false;\n }\n}\n\n// Validate keyword (basic validation)\nexport function isValidKeyword(keyword: string): { valid: boolean; message?: string } {\n if (!keyword || keyword.trim().length === 0) {\n return { valid: false, message: \"Keyword cannot be empty\" };\n }\n\n if (keyword.length > 255) {\n return { valid: false, message: \"Keyword must be less than 255 characters\" };\n }\n\n return { valid: true };\n}\n\n// Sanitize input string\nexport function sanitizeString(input: string): string {\n return input.trim().replace(/[<>]/g, \"\");\n}\n\n// Generate pagination metadata\nexport function createPaginationMeta(\n page: number,\n limit: number,\n total: number\n): { page: number; limit: number; total: number; totalPages: number; hasNext: boolean; hasPrev: boolean } {\n const totalPages = Math.ceil(total / limit);\n \n return {\n page,\n limit,\n total,\n totalPages,\n hasNext: page < totalPages,\n hasPrev: page > 1,\n };\n}\n\n// Parse query parameters for pagination\nexport function parsePaginationParams(url: URL): { page: number; limit: number } {\n const page = Math.max(1, parseInt(url.searchParams.get(\"page\") || \"1\"));\n const limit = Math.min(100, Math.max(1, parseInt(url.searchParams.get(\"limit\") || \"10\")));\n \n return { page, limit };\n}\n\n// Parse search query parameter\nexport function parseSearchQuery(url: URL): string {\n return url.searchParams.get(\"q\")?.trim() || \"\";\n}\n\n// Format date for API responses\nexport function formatDate(date: Date): string {\n return date.toISOString();\n}\n\n// Parse JSON body safely\nexport async function parseJsonBody(request: Request): Promise {\n try {\n const text = await request.text();\n if (!text) {\n throw new Error(\"Request body is empty\");\n }\n return JSON.parse(text);\n } catch (error) {\n throw new Error(\"Invalid JSON in request body\");\n }\n}\n\n// Validate required fields in object\nexport function validateRequiredFields(\n obj: any,\n requiredFields: string[]\n): { valid: boolean; missing?: string[] } {\n const missing: string[] = [];\n \n for (const field of requiredFields) {\n if (obj[field] === undefined || obj[field] === null || obj[field] === \"\") {\n missing.push(field);\n }\n }\n\n return {\n valid: missing.length === 0,\n ...(missing.length > 0 && { missing }),\n };\n}\n\n// Generate CSV from array of objects\nexport function arrayToCSV(data: any[], headers?: string[]): string {\n if (!data || data.length === 0) {\n return \"\";\n }\n\n const csvHeaders = headers || Object.keys(data[0]);\n const csvRows = [];\n\n // Add headers\n csvRows.push(csvHeaders.map(header => `\"${header}\"`).join(\",\"));\n\n // Add data rows\n for (const row of data) {\n const values = csvHeaders.map(header => {\n const value = row[header];\n if (value === null || value === undefined) {\n return '\"\"';\n }\n return `\"${String(value).replace(/\"/g, '\"\"')}\"`;\n });\n csvRows.push(values.join(\",\"));\n }\n\n return csvRows.join(\"\\n\");\n}\n\n// Sleep utility for delays\nexport function sleep(ms: number): Promise {\n return new Promise(resolve => setTimeout(resolve, ms));\n}\n\n// Retry function with exponential backoff\nexport async function retryWithBackoff(\n fn: () => Promise,\n maxRetries: number = 3,\n baseDelay: number = 1000\n): Promise {\n let lastError: Error;\n\n for (let attempt = 0; attempt <= maxRetries; attempt++) {\n try {\n return await fn();\n } catch (error) {\n lastError = error as Error;\n \n if (attempt === maxRetries) {\n break;\n }\n\n const delay = baseDelay * Math.pow(2, attempt);\n await sleep(delay);\n }\n }\n\n throw lastError!;\n}\n\n// Log request for debugging\nexport function logRequest(request: Request, userId?: number): void {\n const method = request.method;\n const url = new URL(request.url);\n const path = url.pathname;\n const timestamp = new Date().toISOString();\n \n console.log(`[${timestamp}] ${method} ${path} - User: ${userId || 'anonymous'}`);\n}\n\n// Soft delete timestamp\nexport function getSoftDeleteTimestamp(): string {\n return new Date().toISOString();\n}\n\n// Check if record is soft deleted\nexport function isSoftDeleted(deletedAt: string | null): boolean {\n return deletedAt !== null;\n}",[],[289],"files",[150,171,180,189,198,207,216,225,233,242,251,260,269,278,287],"counts",{"_300":32,"_301":220,"_302":32,"_303":175},"pulls","branches","forks","envVars","contents",[],{"_104":181,"_95":99,"_153":182,"_155":-5,"_156":138,"_157":183,"_159":160,"_106":307,"_100":32,"_162":185,"_164":186,"_166":22,"_167":-5,"_98":308},["D",1757543742803],[99],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_100":101,"_98":99,"_102":317,"_148":322,"_296":368,"_163":369,"_304":371,"_372":-5,"_373":22,"_374":-5,"_375":-5,"_376":-5,"_377":378},{"_104":105,"_95":96,"_106":318,"_108":-5,"_109":22,"_110":111,"_112":72,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":32,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":319,"_132":320,"_135":321,"_147":22},["D",1757542051489],{"_93":94,"_130":131},{"_93":94,"_134":131},{"_100":137,"_95":43,"_104":138,"_139":105,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":96,"_146":94},[323,326,329,332,335,338,341,344,347,350,353,356,359,362,365],{"_104":151,"_95":152,"_153":154,"_155":-5,"_156":138,"_157":158,"_159":160,"_106":161,"_100":32,"_162":163,"_164":165,"_166":22,"_167":-5,"_168":324,"_98":325},[],[152],{"_104":172,"_95":173,"_153":174,"_155":-5,"_156":138,"_157":175,"_159":160,"_106":176,"_100":32,"_162":163,"_164":177,"_166":22,"_167":-5,"_168":327,"_98":328},[],[173],{"_104":181,"_95":99,"_153":182,"_155":-5,"_156":138,"_157":183,"_159":160,"_106":184,"_100":32,"_162":185,"_164":186,"_166":22,"_167":-5,"_168":330,"_98":331},[],[99],{"_104":190,"_95":191,"_153":192,"_155":-5,"_156":138,"_157":193,"_159":160,"_106":194,"_100":32,"_162":185,"_164":195,"_166":22,"_167":-5,"_168":333,"_98":334},[],[191],{"_104":199,"_95":200,"_153":201,"_155":-5,"_156":138,"_157":202,"_159":160,"_106":203,"_100":32,"_162":185,"_164":204,"_166":22,"_167":-5,"_168":336,"_98":337},[],[200],{"_104":208,"_95":209,"_153":210,"_155":-5,"_156":138,"_157":211,"_159":160,"_106":212,"_100":32,"_162":185,"_164":213,"_166":22,"_167":-5,"_168":339,"_98":340},[],[209],{"_104":217,"_95":218,"_153":219,"_155":-5,"_156":138,"_157":220,"_159":160,"_106":221,"_100":32,"_162":163,"_164":222,"_166":22,"_167":-5,"_168":342,"_98":343},[],[218],{"_104":226,"_95":227,"_153":228,"_155":-5,"_156":138,"_157":101,"_159":160,"_106":229,"_100":32,"_162":185,"_164":230,"_166":22,"_167":-5,"_168":345,"_98":346},[],[227],{"_104":234,"_95":235,"_153":236,"_155":-5,"_156":138,"_157":237,"_159":160,"_106":238,"_100":32,"_162":185,"_164":239,"_166":22,"_167":-5,"_168":348,"_98":349},[],[235],{"_104":243,"_95":244,"_153":245,"_155":-5,"_156":138,"_157":246,"_159":160,"_106":247,"_100":32,"_162":185,"_164":248,"_166":22,"_167":-5,"_168":351,"_98":352},[],[244],{"_104":252,"_95":253,"_153":254,"_155":-5,"_156":138,"_157":255,"_159":160,"_106":256,"_100":32,"_162":185,"_164":257,"_166":22,"_167":-5,"_168":354,"_98":355},[],[253],{"_104":261,"_95":262,"_153":263,"_155":-5,"_156":138,"_157":264,"_159":160,"_106":265,"_100":32,"_162":185,"_164":266,"_166":22,"_167":-5,"_168":357,"_98":358},[],[262],{"_104":270,"_95":271,"_153":272,"_155":-5,"_156":138,"_157":273,"_159":160,"_106":274,"_100":32,"_162":185,"_164":275,"_166":22,"_167":-5,"_168":360,"_98":361},[],[271],{"_104":279,"_95":280,"_153":281,"_155":-5,"_156":138,"_157":282,"_159":160,"_106":283,"_100":32,"_162":185,"_164":284,"_166":22,"_167":-5,"_168":363,"_98":364},[],[280],{"_104":288,"_95":289,"_153":290,"_155":-5,"_156":138,"_157":291,"_159":160,"_106":292,"_100":32,"_162":185,"_164":293,"_166":22,"_167":-5,"_168":366,"_98":367},[],[289],[323,326,329,332,335,338,341,344,347,350,353,356,359,362,365],{"_104":181,"_95":99,"_153":182,"_155":-5,"_156":138,"_157":183,"_159":160,"_106":307,"_100":32,"_162":185,"_164":186,"_166":22,"_167":-5,"_98":370},[99],[],"upstream","showCompareCallout","pull","ahead","behind","templates",[],"actionData","errors"]

diegoivo

denoCrudTask