\n No locations added yet. Add a location to get started.\n

\n `;\n return;\n }\n \n elements.locationsList.innerHTML = state.locations.map(location => `\n

${location.name}

\n \n ${location.latitude.toFixed(6)}, ${location.longitude.toFixed(6)}\n

Added on ${new Date(location.created_at).toLocaleDateString()}

\n \n

\n `).join('');\n \n // Add event listeners to delete buttons\n document.querySelectorAll('.delete-location-btn').forEach(button => {\n button.addEventListener('click', () => deleteLocation(button.dataset.id));\n });\n}\n\n// Delete location\nasync function deleteLocation(locationId) {\n if (!confirm('Are you sure you want to delete this location?')) {\n return;\n }\n \n try {\n const response = await fetch(`${API_BASE_URL}/api/locations/${locationId}`, {\n method: 'DELETE',\n headers: {\n 'Authorization': `Bearer ${state.token}`\n }\n });\n \n const data = await response.json();\n \n if (!response.ok) {\n throw new Error(data.error || 'Failed to delete location');\n }\n \n // Reload locations\n loadLocations();\n } catch (error) {\n alert(error.message);\n }\n}\n\n// Load alerts\nasync function loadAlerts() {\n // This would be an API call to get alerts\n // For now, we'll just use a placeholder\n state.alerts = [];\n renderAlerts();\n}\n\n// Render alerts\nfunction renderAlerts() {\n if (state.alerts.length === 0) {\n elements.alertsList.innerHTML = `\n

\n No alerts at this time. We'll notify you if flooding is predicted.\n

\n `;\n return;\n }\n \n elements.alertsList.innerHTML = state.alerts.map(alert => `\n

\n \n

Alert for ${alert.location_name}

${alert.message}

\n \n ${formatDate(alert.alert_date)}\n

\n `).join('');\n}\n\n// Show location modal\nfunction showLocationModal() {\n elements.locationModal.classList.remove('hidden');\n elements.locationError.classList.add('hidden');\n elements.addLocationForm.reset();\n \n // Initialize map if not already initialized\n if (!state.map) {\n initMap();\n }\n}\n\n// Hide location modal\nfunction hideLocationModal() {\n elements.locationModal.classList.add('hidden');\n}\n\n// Initialize map\nfunction initMap() {\n // Center of Osun State\n const osunCenter = [7.5, 4.5];\n \n // Create map\n state.map = L.map('map').setView(osunCenter, 9);\n \n // Add tile layer\n L.tileLayer('https://{s}.tile.openstreetmap.org/{z}/{x}/{y}.png', {\n attribution: '© OpenStreetMap contributors'\n }).addTo(state.map);\n \n // Add Osun State boundary (approximate)\n const osunBounds = [\n [OSUN_STATE_BOUNDS.south, OSUN_STATE_BOUNDS.west],\n [OSUN_STATE_BOUNDS.north, OSUN_STATE_BOUNDS.east]\n ];\n \n L.rectangle(osunBounds, {\n color: '#3B82F6',\n weight: 2,\n fillOpacity: 0.1\n }).addTo(state.map);\n \n // Add click event to map\n state.map.on('click', function(e) {\n const lat = e.latlng.lat;\n const lng = e.latlng.lng;\n \n // Update form fields\n elements.latitude.value = lat.toFixed(6);\n elements.longitude.value = lng.toFixed(6);\n \n // Check if location is in Osun State\n if (isInOsunState(lat, lng)) {\n elements.locationError.classList.add('hidden');\n } else {\n elements.locationError.classList.remove('hidden');\n }\n \n // Add or move marker\n if (state.marker) {\n state.marker.setLatLng(e.latlng);\n } else {\n state.marker = L.marker(e.latlng).addTo(state.map);\n }\n });\n \n // Invalidate size to ensure map renders correctly\n setTimeout(() => {\n state.map.invalidateSize();\n }, 100);\n}\n\n// Handle add location\nasync function handleAddLocation(e) {\n e.preventDefault();\n \n const name = elements.locationName.value;\n const latitude = parseFloat(elements.latitude.value);\n const longitude = parseFloat(elements.longitude.value);\n \n // Validate inputs\n if (!name || isNaN(latitude) || isNaN(longitude)) {\n alert('Please fill in all fields and select a location on the map.');\n return;\n }\n \n // Check if location is in Osun State\n if (!isInOsunState(latitude, longitude)) {\n elements.locationError.classList.remove('hidden');\n return;\n }\n \n try {\n const response = await fetch(`${API_BASE_URL}/api/locations`, {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json',\n 'Authorization': `Bearer ${state.token}`\n },\n body: JSON.stringify({ name, latitude, longitude })\n });\n \n const data = await response.json();\n \n if (!response.ok) {\n throw new Error(data.error || 'Failed to add location');\n }\n \n // Hide modal\n hideLocationModal();\n \n // Reload locations\n loadLocations();\n \n // Reset form\n elements.addLocationForm.reset();\n \n // Remove marker\n if (state.marker) {\n state.map.removeLayer(state.marker);\n state.marker = null;\n }\n } catch (error) {\n alert(error.message);\n }\n}\n\n// Check for floods\nasync function checkForFloods() {\n if (state.locations.length === 0) {\n alert('Please add at least one location to check for floods.');\n return;\n }\n \n try {\n elements.checkFloodsBtn.disabled = true;\n elements.checkFloodsBtn.innerHTML = ' Checking...';\n \n const response = await fetch(`${API_BASE_URL}/api/check-floods`, {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json',\n 'Authorization': `Bearer ${state.token}`\n },\n body: JSON.stringify({ userId: state.user.id })\n });\n \n const data = await response.json();\n \n if (!response.ok) {\n throw new Error(data.error || 'Failed to check for floods');\n }\n \n // Show message\n alert(data.message);\n \n // Reload alerts\n loadAlerts();\n } catch (error) {\n alert(error.message);\n } finally {\n elements.checkFloodsBtn.disabled = false;\n elements.checkFloodsBtn.innerHTML = ' Check for Floods';\n }\n}\n\n// Initialize the application\ninit();",[],[135,198],"568094f8-3448-11f0-a39d-9e149126039e","index.html","568095ca-3448-11f0-a39d-9e149126039e",["D",1747614574199],"\n\n\n \n \n Osun State Flood Alert System\n \n \n \n \n\n\n \n

\n \n Osun State Flood Alert\n

\n \n \n

\n\n \n

\n \n

\n \n\n

Create Account

\n \n

\n\n \n

Your Locations

Add locations in Osun State to receive flood alerts.

\n \n \n \n

\n \n

\n No locations added yet. Add a location to get started.\n

\n\n

Flood Alerts

Recent flood alerts for your locations.

\n \n \n \n

\n \n

\n No alerts at this time. We'll notify you if flooding is predicted.\n

\n\n \n \n

\n\n \n \n\n \n \n \n \n \n \n\n",[],[135,206],"85928c92-3448-11f0-b155-9e149126039e","85928e40-3448-11f0-b155-9e149126039e",15,["D",1747614653171],"# Frontend\n\nThis directory contains the client-side code for the Osun State Flood Alert System.\n\n## Structure\n\n- `index.html` - Main HTML template\n- `index.js` - JavaScript for the application\n\n## Features\n\n- User authentication (signup and login)\n- Location management with map interface\n- Flood alerts display\n- Manual flood checking\n\n## Technologies\n\n- HTML, JavaScript\n- Tailwind CSS for styling\n- Leaflet.js for maps\n- Font Awesome for icons\n\n## User Flow\n\n1. User signs up or logs in\n2. User adds locations within Osun State using the map\n3. User can check for potential floods manually\n4. Alerts are displayed if flooding is predicted",[],[135,112],["D",1747614574199],[169,170,171],[135],"3afef828-3448-11f0-9cc9-9e149126039e","index.ts",11,["D",1747614528050],"http","import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { cors } from \"https://esm.sh/hono@3.11.7/middleware\";\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { runMigrations } from \"./database/migrations.ts\";\nimport auth from \"./routes/auth.ts\";\nimport locations from \"./routes/locations.ts\";\nimport { createFloodAlertsForUser } from \"./services/floodPredictor.ts\";\n\n// Initialize app\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n console.error(\"Error:\", err);\n throw err;\n});\n\n// Apply CORS middleware\napp.use(\"*\", cors());\n\n// Initialize database\napp.use(\"*\", async (c, next) => {\n try {\n await runMigrations();\n } catch (error) {\n console.error(\"Database migration error:\", error);\n }\n await next();\n});\n\n// API routes\napp.route(\"/api/auth\", auth);\napp.route(\"/api/locations\", locations);\n\n// Check for floods for a specific user\napp.post(\"/api/check-floods\", async (c) => {\n try {\n const { userId } = await c.req.json();\n \n if (!userId) {\n return c.json({ error: \"User ID is required\" }, 400);\n }\n \n const alertsCreated = await createFloodAlertsForUser(userId);\n \n return c.json({ \n success: true, \n alertsCreated,\n message: alertsCreated > 0 \n ? `Created ${alertsCreated} flood alerts` \n : \"No flooding predicted in the next 2 weeks\" \n });\n } catch (error) {\n console.error(\"Check floods error:\", error);\n return c.json({ error: \"Failed to check for floods\" }, 500);\n }\n});\n\n// Serve static files\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n\n// Serve index.html for root path\napp.get(\"/\", async c => {\n try {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Add project info for view source link\n const viewSourceUrl = import.meta.url.replace(\"esm.sh\", \"val.town\");\n const dataScript = ``;\n \n html = html.replace(\"\", `${dataScript}`);\n \n return c.html(html);\n } catch (error) {\n console.error(\"Error serving index.html:\", error);\n return c.text(\"Error loading application\", 500);\n }\n});\n\n// This is the entry point for HTTP vals\nexport default app.fetch;",[],[141,223],"2cf54700-3448-11f0-86af-9e149126039e","cron.ts","2a2b9ce0-3448-11f0-8422-9e149126039e",9,["D",1747614504499],"interval","import { runMigrations } from \"./database/migrations.ts\";\nimport { getUserById, getPendingAlerts, markAlertAsSent } from \"./database/queries.ts\";\nimport { sendFloodAlertEmail } from \"./services/floodPredictor.ts\";\nimport { formatDate } from \"../shared/utils.ts\";\n\n// Run daily to check for floods and send alerts\nexport default async function() {\n console.log(\"Running flood alert cron job...\");\n \n try {\n // Ensure database tables exist\n await runMigrations();\n \n // Get all pending alerts\n const pendingAlerts = await getPendingAlerts();\n console.log(`Found ${pendingAlerts.length} pending alerts`);\n \n // Send email for each alert\n for (const alert of pendingAlerts) {\n const user = await getUserById(alert.user_id);\n \n if (!user) {\n console.error(`User not found for alert ${alert.id}`);\n continue;\n }\n \n const formattedDate = formatDate(alert.alert_date);\n \n const sent = await sendFloodAlertEmail(\n user.email,\n user.name,\n alert.location_name,\n formattedDate,\n alert.message\n );\n \n if (sent) {\n await markAlertAsSent(alert.id);\n console.log(`Sent alert ${alert.id} to ${user.email}`);\n }\n }\n \n console.log(\"Flood alert cron job completed\");\n } catch (error) {\n console.error(\"Error in flood alert cron job:\", error);\n }\n}",[],[141,231],"7f43d206-3448-11f0-874a-9e149126039e","7f43d2d8-3448-11f0-874a-9e149126039e",14,["D",1747614642589],"# Backend\n\nThis directory contains the server-side code for the Osun State Flood Alert System.\n\n## Structure\n\n- `index.ts` - Main entry point for the HTTP API\n- `cron.ts` - Scheduled job to check for floods and send alerts\n- `database/` - Database schema and queries\n- `routes/` - API route handlers\n- `services/` - Business logic services\n\n## API Endpoints\n\n### Authentication\n\n- `POST /api/auth/signup` - Create a new user account\n- `POST /api/auth/login` - Log in to an existing account\n- `GET /api/auth/me` - Get current user information\n\n### Locations\n\n- `GET /api/locations` - Get all locations for the current user\n- `POST /api/locations` - Add a new location\n- `GET /api/locations/:id` - Get a specific location\n- `DELETE /api/locations/:id` - Delete a location\n\n### Flood Checking\n\n- `POST /api/check-floods` - Check for potential floods for a user's locations\n\n## Cron Job\n\nThe `cron.ts` file contains a scheduled job that runs daily to:\n\n1. Check for pending flood alerts\n2. Send email notifications to users\n3. Mark alerts as sent\n\n## Environment Variables\n\n- `JWT_SECRET` - Secret key for JWT token generation (optional, has default)",[],[141,112],"21299f16-3448-11f0-8dad-9e149126039e","floodPredictor.ts","2129a01a-3448-11f0-8dad-9e149126039e","3ef83286-fd0a-473e-894e-c0b0e8b7b867",7,["D",1747614484710],"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}",[],[141,255,247],"services","2129c428-3448-11f0-8dad-9e149126039e",["D",1747614484710],[164],[141,255],"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;",[],[141,269,261],"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;",[],[141,269,271],"0c44befa-3448-11f0-aa2a-9e149126039e",["D",1747614449649],[161,162],[141,269],"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}",[],[141,291,283],"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}",[],[141,291,293],"e9a4d52e-3447-11f0-ac65-9e149126039e",["D",1747614391564],[158,159],[141,291],["D",1747614391564],[157,160,163,165,166,167],[141],["D",1747614190177],{"_16":17,"_83":79},{"_16":17,"_77":-5,"_78":79,"_33":34,"_80":81,"_82":26},{"_65":66,"_20":67,"_18":68,"_69":19,"_70":-5,"_71":-5,"_72":-5,"_73":-5,"_74":-5,"_75":21,"_76":17},"ctx",{"_58":-5,"_104":343,"_344":345,"_346":347,"_348":26,"_349":26,"_350":26,"_351":38,"_352":-5,"_353":-7,"_354":-7,"_355":42,"_356":26,"_357":26,"_358":-5,"_359":26,"_360":26,"_361":26,"_362":-5},"ENV",{"_314":315,"_316":317,"_318":67,"_319":320,"_321":322,"_323":324,"_325":326,"_327":328,"_329":330,"_331":332,"_333":334,"_335":336,"_337":338,"_339":340,"_341":342},"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"]

${location.name}

Alert for ${alert.location_name}

Login

Create Account

Your Locations

Flood Alerts

Add Location

⚠️ Flood Alert

Search