[{"_1":2,"_169":-5,"_170":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","ff0419d68e57d8cc3e37e5d3da688157c5dd37c6","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_166":167,"_168":-5},"handle","diegoivo","name","denoCrudTask","path","rankwatch.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":72,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"id","8c132fdc-8e92-11f0-8129-0224a6c84d84","createdAt",["D",1757542051489],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","add95710-0ddb-4dc2-90f2-bdcb16df89be","pinnedFileId","pinPreview","screenshotVersion","likeCount","39c8580e-ee92-40a4-b9a2-165f574b6ae2","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ycWNtOXpnaDJrU25hbkZMNW15WjN5MlhldEUifQ","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",26,"8c137596-8e92-11f0-8129-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":98,"_149":150,"_151":-5,"_152":136,"_153":154,"_155":156,"_103":157,"_134":158,"_159":160,"_161":162,"_163":20,"_164":-5,"_97":165},"030610bc-8efe-11f0-b6bd-0224a6c84d84","fileId","6210349e-8e9e-11f0-9dc8-0224a6c84d84","parentId","branchId","branchVersion",24,"latest",true,["D",1757588207192],3,"fileType","script","content","// rankwatch.ts - Complete RankWatch API in a single file for Val Town\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 { 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 { sqlite } from \"https://esm.town/v/std/sqlite?v=4\";\n\nconst app = new Hono();\n\n// =====================================================\n// CONFIGURATION\n// =====================================================\n\nconst config = {\n jwt: {\n secret: Deno.env.get(\"JWT_SECRET\") || \"rankwatch-secret-key-change-in-production\",\n expiresIn: \"7d\",\n },\n rateLimit: {\n freemium: { requests: 100, windowMs: 60 * 60 * 1000 },\n unlimited: { requests: 1000, windowMs: 60 * 60 * 1000 },\n },\n serper: {\n apiKey: Deno.env.get(\"SERPER_API_KEY\") || \"\",\n baseUrl: \"https://google.serper.dev\",\n },\n plans: {\n freemium: { maxKeywords: 10, maxProjects: 1 },\n unlimited: { maxKeywords: -1, maxProjects: -1 },\n },\n};\n\n// =====================================================\n// DATABASE SETUP\n// =====================================================\n\nlet db: any = null;\n\nfunction getDatabase() {\n if (!db) {\n // Use Val Town's SQLite without specific database name - it uses your account's DB\n db = sqlite();\n }\n return db;\n}\n\nasync 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,\n checked_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (keyword_id) REFERENCES keywords (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_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\n console.log(\"Database schema initialized successfully\");\n return database;\n}\n\n// =====================================================\n// UTILITY FUNCTIONS\n// =====================================================\n\nfunction createSuccessResponse(data: any, message?: string): Response {\n const response = {\n success: true,\n data,\n ...(message && { message }),\n };\n\n return new Response(JSON.stringify(response), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\nfunction createErrorResponse(error: string, status: number = 400): Response {\n const response = {\n success: false,\n error,\n };\n\n return new Response(JSON.stringify(response), {\n status,\n headers: { \"Content-Type\": \"application/json\" },\n });\n}\n\nfunction isValidEmail(email: string): boolean {\n const emailRegex = /^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/;\n return emailRegex.test(email);\n}\n\nfunction 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 return { valid: true };\n}\n\nasync 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\nfunction validateRequiredFields(obj: any, requiredFields: string[]): { 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// =====================================================\n// AUTHENTICATION FUNCTIONS\n// =====================================================\n\nasync 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\nasync function verifyPassword(password: string, hash: string): Promise {\n const hashedPassword = await hashPassword(password);\n return hashedPassword === hash;\n}\n\nfunction generateApiKey(): string {\n const array = new Uint8Array(32);\n crypto.getRandomValues(array);\n return encodeBase64(array);\n}\n\nasync function createJWT(userId: number, email: string, plan: string): 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\nasync 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\nasync 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);\n const payload = await verifyJWT(token);\n \n const db = getDatabase();\n const result = await db.execute({\n sql: \"SELECT id, email, plan, created_at FROM users WHERE id = ? AND deleted_at IS NULL\",\n args: [payload.user_id],\n });\n\n if (result.rows.length === 0) {\n throw new Error(\"User not found\");\n }\n\n const userData = result.rows[0];\n return {\n id: userData[0],\n email: userData[1],\n plan: userData[2],\n created_at: userData[3],\n };\n}\n\n// =====================================================\n// RATE LIMITING\n// =====================================================\n\nasync function checkRateLimit(userId: number, plan: string, endpoint: string): Promise<{ allowed: boolean; remaining: number }> {\n const db = getDatabase();\n const config_limit = config.rateLimit[plan as keyof typeof config.rateLimit];\n const now = new Date();\n const windowStart = new Date(now.getTime() - config_limit.windowMs);\n\n // Clean up old records\n await db.execute({\n sql: \"DELETE FROM rate_limits WHERE window_end < ?\",\n args: [new Date(Date.now() - 24 * 60 * 60 * 1000).toISOString()],\n });\n\n // Check current usage\n const existingLimit = await db.execute({\n sql: `SELECT requests_made FROM rate_limits \n WHERE user_id = ? AND endpoint = ? AND window_end > ?\n ORDER BY window_start DESC LIMIT 1`,\n args: [userId, endpoint, now.toISOString()],\n });\n\n let requestsMade = 0;\n if (existingLimit.rows.length > 0) {\n requestsMade = existingLimit.rows[0][0] as number;\n }\n\n if (requestsMade >= config_limit.requests) {\n return { allowed: false, remaining: 0 };\n }\n\n // Increment request count\n const newRequestCount = requestsMade + 1;\n const windowEnd = new Date(now.getTime() + config_limit.windowMs);\n\n await db.execute({\n sql: `INSERT OR REPLACE INTO rate_limits (user_id, endpoint, requests_made, window_start, window_end) \n VALUES (?, ?, ?, ?, ?)`,\n args: [userId, endpoint, newRequestCount, now.toISOString(), windowEnd.toISOString()],\n });\n\n return {\n allowed: true,\n remaining: config_limit.requests - newRequestCount,\n };\n}\n\n// =====================================================\n// SERPER CLIENT (Simplified)\n// =====================================================\n\ninterface RankingResult {\n keyword: string;\n position: number | null;\n url: string | null;\n title: string | null;\n found: boolean;\n checked_at: string;\n error?: string;\n}\n\nasync function checkKeywordRanking(keyword: string, domain: string): Promise {\n const checkedAt = new Date().toISOString();\n \n try {\n if (!config.serper.apiKey) {\n throw new Error(\"Serper API key not configured\");\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({\n q: keyword,\n gl: \"us\",\n hl: \"en\",\n num: 100,\n }),\n });\n\n if (!response.ok) {\n throw new Error(`Serper API error: ${response.status}`);\n }\n\n const data = await response.json();\n const organic = data.organic || [];\n\n // Find domain ranking\n const cleanDomain = domain.replace(/^https?:\\/\\//, \"\").replace(/^www\\./, \"\").toLowerCase();\n \n for (let i = 0; i < organic.length; i++) {\n const result = organic[i];\n const resultDomain = result.displayLink?.replace(/^www\\./, \"\").toLowerCase();\n \n if (resultDomain === cleanDomain) {\n return {\n keyword,\n position: i + 1,\n url: result.link,\n title: result.title,\n found: true,\n checked_at: checkedAt,\n };\n }\n }\n\n return {\n keyword,\n position: null,\n url: null,\n title: null,\n found: false,\n checked_at: checkedAt,\n };\n\n } catch (error) {\n return {\n keyword,\n position: null,\n url: null,\n title: null,\n found: false,\n checked_at: checkedAt,\n error: error.message,\n };\n }\n}\n\n// =====================================================\n// MIDDLEWARE SETUP\n// =====================================================\n\n// Global 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\napp.use(\"*\", async (c, next) => {\n await ensureDatabase();\n await next();\n});\n\n// Global error handler\napp.onError((err, c) => {\n console.error(\"Global error:\", err);\n return createErrorResponse(\"Internal server error\", 500);\n});\n\n// =====================================================\n// AUTHENTICATION ENDPOINTS\n// =====================================================\n\n// POST /auth/register\napp.post(\"/auth/register\", async (c) => {\n try {\n const body = await parseJsonBody(c.req.raw);\n \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 if (!isValidEmail(email)) {\n return createErrorResponse(\"Invalid email format\", 400);\n }\n\n const passwordValidation = isValidPassword(password);\n if (!passwordValidation.valid) {\n return createErrorResponse(passwordValidation.message!, 400);\n }\n\n const db = getDatabase();\n \n // Check if user 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 return createErrorResponse(\"User already exists\", 400);\n }\n\n // Create user\n const passwordHash = await hashPassword(password);\n const apiKey = generateApiKey();\n\n const result = await db.execute({\n sql: `INSERT INTO users (email, password_hash, plan, api_key) \n VALUES (?, ?, ?, ?) RETURNING id, email, plan, created_at`,\n args: [email, passwordHash, plan, apiKey],\n });\n\n const userData = result.rows[0];\n const user = {\n id: userData[0],\n email: userData[1],\n plan: userData[2],\n created_at: userData[3],\n };\n\n const token = await createJWT(user.id, user.email, user.plan);\n\n return createSuccessResponse({ user, token }, \"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\napp.post(\"/auth/login\", async (c) => {\n try {\n const body = await parseJsonBody(c.req.raw);\n \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 const db = getDatabase();\n const result = await db.execute({\n sql: \"SELECT id, email, password_hash, plan, created_at FROM users WHERE email = ? AND deleted_at IS NULL\",\n args: [email],\n });\n\n if (result.rows.length === 0) {\n return createErrorResponse(\"User not found\", 401);\n }\n\n const userData = result.rows[0];\n const passwordHash = userData[2] as string;\n\n const isValidPassword = await verifyPassword(password, passwordHash);\n if (!isValidPassword) {\n return createErrorResponse(\"Invalid password\", 401);\n }\n\n const user = {\n id: userData[0],\n email: userData[1],\n plan: userData[3],\n created_at: userData[4],\n };\n\n const token = await createJWT(user.id, user.email, user.plan);\n\n return createSuccessResponse({ user, token }, \"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\napp.get(\"/auth/me\", async (c) => {\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 const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/auth/me\");\n \n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n return createSuccessResponse(user, \"User info retrieved successfully\");\n\n } catch (error) {\n return createErrorResponse(error.message || \"Failed to get user info\", 401);\n }\n});\n\n// =====================================================\n// PROJECT ENDPOINTS\n// =====================================================\n\n// GET /projects\napp.get(\"/projects\", async (c) => {\n try {\n const user = await extractUserFromToken(c.req.header(\"authorization\") || \"\");\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects\");\n \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 user_id = ? AND deleted_at IS NULL \n ORDER BY created_at DESC`,\n args: [user.id],\n });\n\n const projects = result.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 return createSuccessResponse(projects, \"Projects retrieved successfully\");\n\n } catch (error) {\n return createErrorResponse(error.message || \"Failed to get projects\", 401);\n }\n});\n\n// POST /projects\napp.post(\"/projects\", async (c) => {\n try {\n const user = await extractUserFromToken(c.req.header(\"authorization\") || \"\");\n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects\");\n \n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Check project limits\n if (user.plan === \"freemium\") {\n const db = getDatabase();\n const projectCount = await db.execute({\n sql: \"SELECT COUNT(*) as count FROM projects WHERE user_id = ? AND deleted_at IS NULL\",\n args: [user.id],\n });\n \n if ((projectCount.rows[0][0] as number) >= config.plans.freemium.maxProjects) {\n return createErrorResponse(\"Project limit reached. Freemium plan allows 1 project only.\", 403);\n }\n }\n\n const body = await parseJsonBody(c.req.raw);\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 const cleanDomain = domain.replace(/^https?:\\/\\//, \"\").replace(/\\/$/, \"\");\n\n const db = getDatabase();\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, name.trim(), 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 return createSuccessResponse(project, \"Project created successfully\");\n\n } catch (error) {\n return createErrorResponse(error.message || \"Failed to create project\", 400);\n }\n});\n\n// =====================================================\n// KEYWORD ENDPOINTS\n// =====================================================\n\n// GET /projects/:id/keywords\napp.get(\"/projects/:id/keywords\", async (c) => {\n try {\n const user = await extractUserFromToken(c.req.header(\"authorization\") || \"\");\n const projectId = parseInt(c.req.param(\"id\"));\n \n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects/:id/keywords\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n const db = getDatabase();\n \n // Verify project ownership\n const projectCheck = 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 (projectCheck.rows.length === 0) {\n return createErrorResponse(\"Project not found\", 404);\n }\n\n const result = await db.execute({\n sql: `SELECT id, keyword, target_url, active, created_at, updated_at \n FROM keywords \n WHERE project_id = ? AND deleted_at IS NULL \n ORDER BY created_at DESC`,\n args: [projectId],\n });\n\n const keywords = result.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 return createSuccessResponse(keywords, \"Keywords retrieved successfully\");\n\n } catch (error) {\n return createErrorResponse(error.message || \"Failed to get keywords\", 401);\n }\n});\n\n// POST /projects/:id/keywords\napp.post(\"/projects/:id/keywords\", async (c) => {\n try {\n const user = await extractUserFromToken(c.req.header(\"authorization\") || \"\");\n const projectId = parseInt(c.req.param(\"id\"));\n \n const rateLimitResult = await checkRateLimit(user.id, user.plan, \"/projects/:id/keywords\");\n if (!rateLimitResult.allowed) {\n return createErrorResponse(\"Rate limit exceeded\", 429);\n }\n\n // Check keyword limits\n if (user.plan === \"freemium\") {\n const db = getDatabase();\n const keywordCount = 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: [user.id],\n });\n \n if ((keywordCount.rows[0][0] as number) >= config.plans.freemium.maxKeywords) {\n return createErrorResponse(\"Keyword limit reached. Freemium plan allows 10 keywords.\", 403);\n }\n }\n\n const body = await parseJsonBody(c.req.raw);\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 const db = getDatabase();\n \n // Verify project ownership\n const projectCheck = 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 (projectCheck.rows.length === 0) {\n return createErrorResponse(\"Project not found\", 404);\n }\n\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, keyword.trim(), 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 return createSuccessResponse(newKeyword, \"Keyword created successfully\");\n\n } catch (error) {\n return createErrorResponse(error.message || \"Failed to create keyword\", 400);\n }\n});\n\n// =====================================================\n// RANKING ENDPOINTS\n// =====================================================\n\n// GET /keywords/:id/rankings\napp.get(\"/keywords/:id/rankings\", async (c) => {\n try {\n const user = await extractUserFromToken(c.req.header(\"authorization\") || \"\");\n const keywordId = parseInt(c.req.param(\"id\"));\n \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 const db = getDatabase();\n \n // Verify keyword ownership\n const keywordCheck = await db.execute({\n sql: `SELECT k.keyword, p.domain \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 (keywordCheck.rows.length === 0) {\n return createErrorResponse(\"Keyword not found\", 404);\n }\n\n // Get latest ranking\n const rankingResult = await db.execute({\n sql: `SELECT position, url, title, 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 checked_at: row[3],\n };\n }\n\n return createSuccessResponse({\n keyword: keywordCheck.rows[0][0],\n domain: keywordCheck.rows[0][1],\n current_ranking: currentRanking,\n }, \"Current ranking retrieved successfully\");\n\n } catch (error) {\n return createErrorResponse(error.message || \"Failed to get ranking\", 401);\n }\n});\n\n// POST /keywords/:id/check-now\napp.post(\"/keywords/:id/check-now\", async (c) => {\n try {\n const user = await extractUserFromToken(c.req.header(\"authorization\") || \"\");\n const keywordId = parseInt(c.req.param(\"id\"));\n \n if (user.plan !== \"unlimited\") {\n return createErrorResponse(\"Immediate ranking checks are only available for unlimited plan users\", 403);\n }\n\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 const db = getDatabase();\n \n // Get keyword and project details\n const keywordResult = await db.execute({\n sql: `SELECT k.keyword, p.domain \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 (keywordResult.rows.length === 0) {\n return createErrorResponse(\"Keyword not found\", 404);\n }\n\n const keyword = keywordResult.rows[0][0] as string;\n const domain = keywordResult.rows[0][1] as string;\n\n // Check ranking using Serper\n const rankingResult = await checkKeywordRanking(keyword, domain);\n\n // Save result to database\n await db.execute({\n sql: `INSERT INTO rankings (keyword_id, position, url, title, checked_at) \n VALUES (?, ?, ?, ?, ?)`,\n args: [\n keywordId,\n rankingResult.position,\n rankingResult.url,\n rankingResult.title,\n rankingResult.checked_at,\n ],\n });\n\n return createSuccessResponse({\n keyword,\n domain,\n ranking_result: rankingResult,\n }, \"Ranking check completed successfully\");\n\n } catch (error) {\n return createErrorResponse(error.message || \"Failed to perform ranking check\", 400);\n }\n});\n\n// =====================================================\n// ROOT ENDPOINTS\n// =====================================================\n\n// Root endpoint\napp.get(\"/\", (c) => {\n return createSuccessResponse({\n service: \"RankWatch API\",\n version: \"1.0.0\",\n description: \"Keyword ranking monitoring API built with Val Town\",\n endpoints: {\n authentication: \"/auth/*\",\n projects: \"/projects/*\",\n keywords: \"/keywords/*\",\n rankings: \"/rankings/*\",\n },\n status: \"operational\",\n timestamp: new Date().toISOString(),\n }, \"Welcome to RankWatch API\");\n});\n\n// Health check endpoint\napp.get(\"/health\", async (c) => {\n try {\n await ensureDatabase();\n \n return createSuccessResponse({\n status: \"healthy\",\n service: \"RankWatch API\",\n version: \"1.0.0\",\n database: \"connected\",\n timestamp: new Date().toISOString(),\n }, \"Service is healthy\");\n \n } catch (error) {\n console.error(\"Health check failed:\", error);\n return createErrorResponse(\"Service unhealthy\", 503);\n }\n});\n\n// 404 handler\napp.notFound((c) => {\n return createErrorResponse(`Endpoint not found: ${c.req.method} ${c.req.path}`, 404);\n});\n\n// Export the main app\nexport default {\n fetch: app.fetch,\n};","deleted","label",[98],"permalink","https://www.val.town/x/diegoivo/denoCrudTask/code/rankwatch.ts","extension","actionData","errors"]