[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_252":253,"_254":255},"routes/_app.x.$handle.$name",{"_103":102,"_32":51,"_111":93,"_27":112,"_13":14,"_113":-5,"_11":114,"_115":116,"_117":118,"_119":120,"_121":122,"_21":-5,"_123":-5,"_124":-5,"_125":25,"_126":127,"_128":25,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_49":50,"_32":51,"_37":52,"_53":-5,"_54":25,"_55":56,"_57":56,"_58":59,"_60":-5,"_18":61,"_62":63,"_64":65,"_66":65,"_67":-5,"_68":69,"_70":71,"_72":-5,"_73":-5,"_74":-5,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":25},"version",7,"changes",[19,20],"aiChatInfo","userId",{"_21":42,"_23":-7,"_24":25,"_26":25,"_27":43,"_29":43},{"_21":22,"_23":-7,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":35,"_36":-5,"_37":38,"_39":14,"_40":41,"_24":25},"previous","deleted",false,"deletedHere","path","backend/services","latestPath","fileId","3ef83286-fd0a-473e-894e-c0b0e8b7b867","name","services","fileType","directory","content","createdAt",["D",1747614484710],"branchVersion","branchId","719b260a-3447-11f0-ae6c-9e149126039e",{"_30":44,"_32":45,"_34":46,"_36":47,"_37":48,"_39":14,"_40":41,"_24":25},"backend/services/floodPredictor.ts","2129a01a-3448-11f0-8dad-9e149126039e","floodPredictor.ts","script","import { Location, createAlert, getLocationsByUserId, getUserById } from \"../database/queries.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\n\n// Threshold for rainfall that might cause flooding (in mm)\nconst RAINFALL_THRESHOLD = 50; // Adjust based on local conditions\n\n// Open-Meteo API for weather forecasts\nconst WEATHER_API_URL = \"https://api.open-meteo.com/v1/forecast\";\n\ninterface WeatherForecast {\n daily: {\n time: string[];\n precipitation_sum: number[];\n };\n}\n\n// Get weather forecast for a location\nasync function getWeatherForecast(latitude: number, longitude: number): Promise {\n const url = new URL(WEATHER_API_URL);\n url.searchParams.append(\"latitude\", latitude.toString());\n url.searchParams.append(\"longitude\", longitude.toString());\n url.searchParams.append(\"daily\", \"precipitation_sum\");\n url.searchParams.append(\"timezone\", \"Africa/Lagos\");\n url.searchParams.append(\"forecast_days\", \"14\"); // 2 weeks forecast\n\n const response = await fetch(url.toString());\n \n if (!response.ok) {\n throw new Error(`Weather API error: ${response.statusText}`);\n }\n \n return await response.json();\n}\n\n// Check if flooding is likely based on rainfall\nfunction isFloodingLikely(precipitationSum: number): boolean {\n return precipitationSum > RAINFALL_THRESHOLD;\n}\n\n// Predict flooding for a location\nasync function predictFloodingForLocation(location: Location): Promise<{ date: string, rainfall: number } | null> {\n try {\n const forecast = await getWeatherForecast(location.latitude, location.longitude);\n \n // Check each day in the forecast\n for (let i = 0; i < forecast.daily.time.length; i++) {\n const date = forecast.daily.time[i];\n const rainfall = forecast.daily.precipitation_sum[i];\n \n if (isFloodingLikely(rainfall)) {\n return { date, rainfall };\n }\n }\n \n return null; // No flooding predicted\n } catch (error) {\n console.error(`Error predicting flooding for location ${location.id}:`, error);\n return null;\n }\n}\n\n// Create flood alerts for a user's locations\nexport async function createFloodAlertsForUser(userId: number): Promise {\n try {\n const locations = await getLocationsByUserId(userId);\n let alertsCreated = 0;\n \n for (const location of locations) {\n const floodPrediction = await predictFloodingForLocation(location);\n \n if (floodPrediction) {\n const message = `Potential flooding predicted on ${floodPrediction.date} with expected rainfall of ${floodPrediction.rainfall}mm.`;\n \n await createAlert(userId, location.id, floodPrediction.date, message);\n alertsCreated++;\n }\n }\n \n return alertsCreated;\n } catch (error) {\n console.error(`Error creating flood alerts for user ${userId}:`, error);\n return 0;\n }\n}\n\n// Send email notification for a flood alert\nexport async function sendFloodAlertEmail(userEmail: string, userName: string, locationName: string, alertDate: string, message: string): Promise {\n try {\n await email({\n to: userEmail,\n subject: `⚠️ Flood Alert for ${locationName}`,\n text: `Hello ${userName},\\n\\nWe are sending this alert to inform you of potential flooding in ${locationName} on ${alertDate}.\\n\\n${message}\\n\\nPlease take necessary precautions.\\n\\nStay safe,\\nOsun State Flood Alert System`,\n html: `\n

⚠️ Flood Alert

Hello ${userName},

We are sending this alert to inform you of potential flooding in ${locationName} on ${alertDate}.

${message}

Please take necessary precautions.

Stay safe,
Osun State Flood Alert System

\n `\n });\n \n return true;\n } catch (error) {\n console.error(`Error sending flood alert email to ${userEmail}:`, error);\n return false;\n }\n}",["D",1747614484710],"id","719af482-3447-11f0-ae6c-9e149126039e","FloodApp",["D",1747614190177],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","A flood app that notify subscriber ahead of flooding","imageUrl","dcf86e80-3442-11f0-b519-ff88f6bc2fe6","pinnedFileId","36a9b060-3448-11f0-ae10-9e149126039e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","d12e9468-0713-4b2e-926d-7ccecb147081","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_103":102,"_110":106},"org",{"_103":102,"_104":-5,"_105":106,"_18":61,"_107":108,"_109":25},"branch",{"_13":92,"_32":93,"_49":41,"_94":50,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":51,"_101":102},"isOwned",16,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","excel","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yeEk0TXdTZ1pDYmt1Y0FqSmFkNWwxMUx6UkMifQ","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_49":50,"_32":51,"_37":248,"_53":-5,"_54":25,"_55":56,"_57":56,"_58":59,"_60":-5,"_18":61,"_62":63,"_64":65,"_66":65,"_67":-5,"_68":69,"_70":71,"_72":-5,"_73":-5,"_74":-5,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":249,"_87":250,"_89":251,"_91":25},"tree",[168,177,179],"files",[168,169,170,171,172,173,174,175,176,177,178,179],"counts",{"_158":69,"_159":140,"_160":69,"_161":162,"_163":164},"contents",[133,134,135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":152,"_32":153,"_30":154,"_139":-5,"_40":41,"_39":155,"_141":65,"_37":156,"_13":69,"_34":35,"_36":-5,"_24":25,"_144":-5,"_27":157},{"_49":146,"_32":147,"_30":148,"_139":-5,"_40":41,"_39":149,"_141":65,"_37":150,"_13":69,"_34":35,"_36":-5,"_24":25,"_144":-5,"_27":151},{"_49":136,"_32":137,"_30":138,"_139":-5,"_40":41,"_39":140,"_141":65,"_37":142,"_13":69,"_34":21,"_36":143,"_24":25,"_144":-5,"_27":145},"e29c60d0-3447-11f0-941a-9e149126039e","README.md","e29c618e-3447-11f0-941a-9e149126039e","parentId",1,"latest",["D",1747614379766],"# Osun State Flood Alert System\n\nA web application that allows residents of Osun State, Nigeria to receive early flood warnings based on weather forecasts.\n\n## Features\n\n- User authentication (signup and login)\n- Location management for Osun State areas\n- Flood prediction system (2 weeks in advance)\n- Email notifications for flood alerts\n\n## Project Structure\n\n- `/backend` - Server-side code and API endpoints\n- `/frontend` - User interface and client-side code\n- `/shared` - Shared types and utilities\n\n## Technologies\n\n- Backend: Hono (TypeScript)\n- Database: SQLite\n- Frontend: HTML, JavaScript, Tailwind CSS\n- Weather Data: Open-Meteo API\n- Notifications: Email\n\n## How It Works\n\n1. Users sign up with their email and basic details\n2. After login, users can add their location within Osun State\n3. The system checks weather forecasts daily for potential flooding\n4. If flooding is predicted in the next 2 weeks, users receive email notifications","label",[137],"fc9d2a5a-3447-11f0-b18f-9e149126039e","shared","f0761535-fa4a-4070-b884-3f75c73e7beb",4,["D",1747614423388],[147],"e9a4d380-3447-11f0-ac65-9e149126039e","backend","494901c2-9114-474e-8493-8fd4d96b25e0",2,["D",1747614391564],[153],"pulls","branches","forks","envVars",{"_165":69,"_167":69},"connections",{"_165":69,"_166":69},"count","unfilledCount","emptyCount",{"_49":152,"_32":153,"_30":154,"_139":-5,"_40":41,"_39":155,"_141":65,"_37":245,"_13":69,"_34":35,"_36":-5,"_24":25,"_144":-5,"_181":246,"_27":247},{"_49":241,"_32":233,"_30":227,"_139":154,"_40":41,"_39":155,"_141":65,"_37":242,"_13":69,"_34":35,"_36":-5,"_24":25,"_144":-5,"_181":243,"_27":244},{"_49":234,"_32":235,"_30":236,"_139":227,"_40":41,"_39":155,"_141":65,"_37":237,"_13":69,"_34":46,"_36":238,"_24":25,"_144":-5,"_181":239,"_27":240},{"_49":224,"_32":225,"_30":226,"_139":227,"_40":41,"_39":228,"_141":65,"_37":229,"_13":69,"_34":46,"_36":230,"_24":25,"_144":-5,"_181":231,"_27":232},{"_49":220,"_32":211,"_30":205,"_139":154,"_40":41,"_39":215,"_141":65,"_37":221,"_13":69,"_34":35,"_36":-5,"_24":25,"_144":-5,"_181":222,"_27":223},{"_49":212,"_32":213,"_30":214,"_139":205,"_40":41,"_39":215,"_141":65,"_37":216,"_13":69,"_34":46,"_36":217,"_24":25,"_144":-5,"_181":218,"_27":219},{"_49":202,"_32":203,"_30":204,"_139":205,"_40":41,"_39":206,"_141":65,"_37":207,"_13":69,"_34":46,"_36":208,"_24":25,"_144":-5,"_181":209,"_27":210},{"_49":198,"_32":33,"_30":31,"_139":154,"_40":41,"_39":14,"_141":65,"_37":199,"_13":69,"_34":35,"_36":-5,"_24":25,"_144":-5,"_181":200,"_27":201},{"_49":194,"_32":45,"_30":44,"_139":31,"_40":41,"_39":14,"_141":65,"_37":195,"_13":69,"_34":46,"_36":47,"_24":25,"_144":-5,"_181":196,"_27":197},{"_49":146,"_32":147,"_30":148,"_139":-5,"_40":41,"_39":149,"_141":65,"_37":191,"_13":69,"_34":35,"_36":-5,"_24":25,"_144":-5,"_181":192,"_27":193},{"_49":184,"_32":185,"_30":186,"_139":148,"_40":41,"_39":149,"_141":65,"_37":187,"_13":69,"_34":46,"_36":188,"_24":25,"_144":-5,"_181":189,"_27":190},{"_49":136,"_32":137,"_30":138,"_139":-5,"_40":41,"_39":140,"_141":65,"_37":180,"_13":69,"_34":21,"_36":143,"_24":25,"_144":-5,"_181":182,"_27":183},["D",1747614379766],"children",[],[137],"fc9d0764-3447-11f0-b18f-9e149126039e","utils.ts","fc9d0836-3447-11f0-b18f-9e149126039e",["D",1747614423388],"// Shared types and utilities for both frontend and backend\n\n// User types (without sensitive data)\nexport interface UserInfo {\n id: number;\n email: string;\n name: string;\n}\n\n// Location types\nexport interface LocationInfo {\n id: number;\n name: string;\n latitude: number;\n longitude: number;\n created_at: string;\n}\n\n// Alert types\nexport interface AlertInfo {\n id: number;\n location_id: number;\n location_name: string;\n alert_date: string;\n message: string;\n created_at: string;\n}\n\n// Auth types\nexport interface SignupRequest {\n email: string;\n password: string;\n name: string;\n}\n\nexport interface LoginRequest {\n email: string;\n password: string;\n}\n\nexport interface AuthResponse {\n user: UserInfo;\n token: string;\n}\n\n// Location types\nexport interface AddLocationRequest {\n name: string;\n latitude: number;\n longitude: number;\n}\n\n// Osun State boundaries (approximate)\nexport const OSUN_STATE_BOUNDS = {\n north: 8.1, // Northern latitude boundary\n south: 7.0, // Southern latitude boundary\n east: 5.1, // Eastern longitude boundary\n west: 4.0 // Western longitude boundary\n};\n\n// Check if coordinates are within Osun State\nexport function isInOsunState(latitude: number, longitude: number): boolean {\n return (\n latitude >= OSUN_STATE_BOUNDS.south &&\n latitude <= OSUN_STATE_BOUNDS.north &&\n longitude >= OSUN_STATE_BOUNDS.west &&\n longitude <= OSUN_STATE_BOUNDS.east\n );\n}\n\n// Format date for display\nexport function formatDate(dateString: string): string {\n const date = new Date(dateString);\n return date.toLocaleDateString('en-NG', {\n weekday: 'long',\n year: 'numeric',\n month: 'long',\n day: 'numeric'\n });\n}",[],[147,185],["D",1747614423388],[178],[147],"21299f16-3448-11f0-8dad-9e149126039e",["D",1747614484710],[],[153,33,45],"2129c428-3448-11f0-8dad-9e149126039e",["D",1747614484710],[176],[153,33],"1635e74a-3448-11f0-affd-9e149126039e","locations.ts","1635e808-3448-11f0-affd-9e149126039e","5ac05d44-0472-428d-add2-8df9f4c509aa",6,["D",1747614466333],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { \n createLocation, \n getLocationsByUserId, \n getLocationById, \n deleteLocation \n} from \"../database/queries.ts\";\nimport { authMiddleware } from \"./auth.ts\";\nimport { AddLocationRequest, isInOsunState } from \"../../shared/utils.ts\";\n\nconst locations = new Hono();\n\n// Apply auth middleware to all routes\nlocations.use(\"*\", authMiddleware);\n\n// Get all locations for the current user\nlocations.get(\"/\", async (c) => {\n try {\n const userId = c.get(\"userId\");\n const userLocations = await getLocationsByUserId(userId);\n \n return c.json({ locations: userLocations });\n } catch (error) {\n console.error(\"Get locations error:\", error);\n return c.json({ error: \"Failed to fetch locations\" }, 500);\n }\n});\n\n// Add a new location\nlocations.post(\"/\", async (c) => {\n try {\n const userId = c.get(\"userId\");\n const data = await c.req.json();\n \n // Validate input\n if (!data.name || data.latitude === undefined || data.longitude === undefined) {\n return c.json({ error: \"Name, latitude, and longitude are required\" }, 400);\n }\n \n // Check if location is within Osun State\n if (!isInOsunState(data.latitude, data.longitude)) {\n return c.json({ error: \"Location must be within Osun State, Nigeria\" }, 400);\n }\n \n // Create location\n const locationId = await createLocation(userId, data.name, data.latitude, data.longitude);\n \n // Get the created location\n const location = await getLocationById(locationId);\n \n return c.json({ location }, 201);\n } catch (error) {\n console.error(\"Add location error:\", error);\n return c.json({ error: \"Failed to add location\" }, 500);\n }\n});\n\n// Get a specific location\nlocations.get(\"/:id\", async (c) => {\n try {\n const userId = c.get(\"userId\");\n const locationId = parseInt(c.req.param(\"id\"));\n \n if (isNaN(locationId)) {\n return c.json({ error: \"Invalid location ID\" }, 400);\n }\n \n const location = await getLocationById(locationId);\n \n if (!location) {\n return c.json({ error: \"Location not found\" }, 404);\n }\n \n // Check if the location belongs to the user\n if (location.user_id !== userId) {\n return c.json({ error: \"Unauthorized\" }, 403);\n }\n \n return c.json({ location });\n } catch (error) {\n console.error(\"Get location error:\", error);\n return c.json({ error: \"Failed to fetch location\" }, 500);\n }\n});\n\n// Delete a location\nlocations.delete(\"/:id\", async (c) => {\n try {\n const userId = c.get(\"userId\");\n const locationId = parseInt(c.req.param(\"id\"));\n \n if (isNaN(locationId)) {\n return c.json({ error: \"Invalid location ID\" }, 400);\n }\n \n const location = await getLocationById(locationId);\n \n if (!location) {\n return c.json({ error: \"Location not found\" }, 404);\n }\n \n // Check if the location belongs to the user\n if (location.user_id !== userId) {\n return c.json({ error: \"Unauthorized\" }, 403);\n }\n \n const deleted = await deleteLocation(locationId, userId);\n \n if (!deleted) {\n return c.json({ error: \"Failed to delete location\" }, 500);\n }\n \n return c.json({ success: true });\n } catch (error) {\n console.error(\"Delete location error:\", error);\n return c.json({ error: \"Failed to delete location\" }, 500);\n }\n});\n\nexport default locations;",[],[153,211,203],"routes","0c449218-3448-11f0-aa2a-9e149126039e","auth.ts","0c44931c-3448-11f0-aa2a-9e149126039e",5,["D",1747614449649],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { createUser, getUserByEmail } from \"../database/queries.ts\";\nimport { SignupRequest, LoginRequest, AuthResponse } from \"../../shared/utils.ts\";\nimport * as bcrypt from \"https://deno.land/x/bcrypt@v0.4.1/mod.ts\";\nimport { create, verify } from \"https://deno.land/x/djwt@v2.8/mod.ts\";\n\nconst auth = new Hono();\n\n// Secret key for JWT\nconst JWT_SECRET = new TextEncoder().encode(\n Deno.env.get(\"JWT_SECRET\") || \"flood-app-secret-key-change-in-production\"\n);\n\n// Generate JWT token\nasync function generateToken(userId: number): Promise {\n return await create(\n { alg: \"HS256\", typ: \"JWT\" },\n { sub: userId.toString(), exp: Date.now() / 1000 + 60 * 60 * 24 * 7 }, // 7 days\n JWT_SECRET\n );\n}\n\n// Verify JWT token\nexport async function verifyToken(token: string): Promise {\n try {\n const payload = await verify(token, JWT_SECRET);\n return parseInt(payload.sub as string);\n } catch (error) {\n return null;\n }\n}\n\n// Middleware to check authentication\nexport async function authMiddleware(c: any, next: any) {\n const authHeader = c.req.header(\"Authorization\");\n \n if (!authHeader || !authHeader.startsWith(\"Bearer \")) {\n return c.json({ error: \"Unauthorized\" }, 401);\n }\n \n const token = authHeader.split(\" \")[1];\n const userId = await verifyToken(token);\n \n if (!userId) {\n return c.json({ error: \"Invalid token\" }, 401);\n }\n \n c.set(\"userId\", userId);\n await next();\n}\n\n// Signup route\nauth.post(\"/signup\", async (c) => {\n try {\n const data = await c.req.json();\n \n // Validate input\n if (!data.email || !data.password || !data.name) {\n return c.json({ error: \"Email, password, and name are required\" }, 400);\n }\n \n // Check if user already exists\n const existingUser = await getUserByEmail(data.email);\n if (existingUser) {\n return c.json({ error: \"Email already registered\" }, 409);\n }\n \n // Hash password\n const passwordHash = await bcrypt.hash(data.password);\n \n // Create user\n const userId = await createUser(data.email, passwordHash, data.name);\n \n // Generate token\n const token = await generateToken(userId);\n \n // Return user info and token\n const response: AuthResponse = {\n user: {\n id: userId,\n email: data.email,\n name: data.name\n },\n token\n };\n \n return c.json(response, 201);\n } catch (error) {\n console.error(\"Signup error:\", error);\n return c.json({ error: \"Failed to create user\" }, 500);\n }\n});\n\n// Login route\nauth.post(\"/login\", async (c) => {\n try {\n const data = await c.req.json();\n \n // Validate input\n if (!data.email || !data.password) {\n return c.json({ error: \"Email and password are required\" }, 400);\n }\n \n // Get user\n const user = await getUserByEmail(data.email);\n if (!user) {\n return c.json({ error: \"Invalid email or password\" }, 401);\n }\n \n // Verify password\n const passwordMatch = await bcrypt.compare(data.password, user.password_hash);\n if (!passwordMatch) {\n return c.json({ error: \"Invalid email or password\" }, 401);\n }\n \n // Generate token\n const token = await generateToken(user.id);\n \n // Return user info and token\n const response: AuthResponse = {\n user: {\n id: user.id,\n email: user.email,\n name: user.name\n },\n token\n };\n \n return c.json(response);\n } catch (error) {\n console.error(\"Login error:\", error);\n return c.json({ error: \"Failed to login\" }, 500);\n }\n});\n\n// Get current user\nauth.get(\"/me\", authMiddleware, async (c) => {\n const userId = c.get(\"userId\");\n \n return c.json({\n user: {\n id: userId,\n // Other user data would be fetched from the database here\n }\n });\n});\n\nexport default auth;",[],[153,211,213],"0c44befa-3448-11f0-aa2a-9e149126039e",["D",1747614449649],[173,174],[153,211],"f4cd9bc0-3447-11f0-93a7-9e149126039e","queries.ts","f4cd9c88-3447-11f0-93a7-9e149126039e","9cf75c7d-cd49-45df-8942-278f9ddd13bf",3,["D",1747614410288],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { USERS_TABLE, LOCATIONS_TABLE, ALERTS_TABLE } from \"./migrations.ts\";\n\n// User types\nexport interface User {\n id: number;\n email: string;\n name: string;\n created_at: string;\n}\n\nexport interface UserWithPassword extends User {\n password_hash: string;\n}\n\n// Location types\nexport interface Location {\n id: number;\n user_id: number;\n name: string;\n latitude: number;\n longitude: number;\n created_at: string;\n}\n\n// Alert types\nexport interface Alert {\n id: number;\n user_id: number;\n location_id: number;\n alert_date: string;\n message: string;\n is_sent: boolean;\n created_at: string;\n}\n\n// User queries\nexport async function createUser(email: string, passwordHash: string, name: string): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${USERS_TABLE} (email, password_hash, name) VALUES (?, ?, ?) RETURNING id`,\n [email, passwordHash, name]\n );\n return result.rows[0].id;\n}\n\nexport async function getUserByEmail(email: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${USERS_TABLE} WHERE email = ?`,\n [email]\n );\n return result.rows[0] || null;\n}\n\nexport async function getUserById(id: number): Promise {\n const result = await sqlite.execute(\n `SELECT id, email, name, created_at FROM ${USERS_TABLE} WHERE id = ?`,\n [id]\n );\n return result.rows[0] || null;\n}\n\n// Location queries\nexport async function createLocation(userId: number, name: string, latitude: number, longitude: number): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${LOCATIONS_TABLE} (user_id, name, latitude, longitude) VALUES (?, ?, ?, ?) RETURNING id`,\n [userId, name, latitude, longitude]\n );\n return result.rows[0].id;\n}\n\nexport async function getLocationsByUserId(userId: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${LOCATIONS_TABLE} WHERE user_id = ?`,\n [userId]\n );\n return result.rows;\n}\n\nexport async function getLocationById(id: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${LOCATIONS_TABLE} WHERE id = ?`,\n [id]\n );\n return result.rows[0] || null;\n}\n\nexport async function deleteLocation(id: number, userId: number): Promise {\n const result = await sqlite.execute(\n `DELETE FROM ${LOCATIONS_TABLE} WHERE id = ? AND user_id = ?`,\n [id, userId]\n );\n return result.rowsAffected > 0;\n}\n\n// Alert queries\nexport async function createAlert(userId: number, locationId: number, alertDate: string, message: string): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${ALERTS_TABLE} (user_id, location_id, alert_date, message) VALUES (?, ?, ?, ?) RETURNING id`,\n [userId, locationId, alertDate, message]\n );\n return result.rows[0].id;\n}\n\nexport async function getAlertsByUserId(userId: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${ALERTS_TABLE} WHERE user_id = ? ORDER BY alert_date DESC`,\n [userId]\n );\n return result.rows;\n}\n\nexport async function markAlertAsSent(id: number): Promise {\n const result = await sqlite.execute(\n `UPDATE ${ALERTS_TABLE} SET is_sent = 1 WHERE id = ?`,\n [id]\n );\n return result.rowsAffected > 0;\n}\n\nexport async function getPendingAlerts(): Promise<(Alert & { user_email: string, location_name: string })[]> {\n const result = await sqlite.execute(`\n SELECT a.*, u.email as user_email, l.name as location_name\n FROM ${ALERTS_TABLE} a\n JOIN ${USERS_TABLE} u ON a.user_id = u.id\n JOIN ${LOCATIONS_TABLE} l ON a.location_id = l.id\n WHERE a.is_sent = 0\n `);\n return result.rows;\n}",[],[153,233,225],"database","e9a4afea-3447-11f0-ac65-9e149126039e","migrations.ts","e9a4b094-3447-11f0-ac65-9e149126039e",["D",1747614391564],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\n// Table names - change these when modifying schema\nexport const USERS_TABLE = \"flood_app_users\";\nexport const LOCATIONS_TABLE = \"flood_app_locations\";\nexport const ALERTS_TABLE = \"flood_app_alerts\";\n\nexport async function runMigrations() {\n // Create users table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${USERS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email TEXT UNIQUE NOT NULL,\n password_hash TEXT NOT NULL,\n name TEXT NOT NULL,\n created_at TEXT DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n // Create locations table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${LOCATIONS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n name TEXT NOT NULL,\n latitude REAL NOT NULL,\n longitude REAL NOT NULL,\n created_at TEXT DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES ${USERS_TABLE}(id) ON DELETE CASCADE\n )\n `);\n\n // Create alerts table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${ALERTS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n location_id INTEGER NOT NULL,\n alert_date TEXT NOT NULL,\n message TEXT NOT NULL,\n is_sent BOOLEAN DEFAULT 0,\n created_at TEXT DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES ${USERS_TABLE}(id) ON DELETE CASCADE,\n FOREIGN KEY (location_id) REFERENCES ${LOCATIONS_TABLE}(id) ON DELETE CASCADE\n )\n `);\n}",[],[153,233,235],"e9a4d52e-3447-11f0-ac65-9e149126039e",["D",1747614391564],[170,171],[153,233],["D",1747614391564],[169,172,175],[153],["D",1747614190177],{"_103":102,"_110":106},{"_103":102,"_104":-5,"_105":106,"_18":61,"_107":108,"_109":25},{"_13":92,"_32":93,"_49":41,"_94":50,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":51,"_101":102},"ctx",{"_85":-5,"_130":285,"_286":287,"_288":289,"_290":25,"_291":25,"_292":25,"_293":65,"_294":-5,"_295":-7,"_296":-7,"_297":69,"_298":25,"_299":25,"_300":-5,"_301":25,"_302":25,"_303":25,"_304":-5},"ENV",{"_256":257,"_258":259,"_260":93,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280,"_281":282,"_283":284},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","RENDER_GIT_BRANCH","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v7