IT Jobs Board & Chat

\n \n\n",[],[147,201],["D",1748871650978],[177,178],[147],"2c8c917c-3fb7-11f0-9480-76b3cceeab13","index.ts",7,["D",1748871640740],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { runMigrations } from \"./database/migrations.ts\";\nimport jobs from \"./routes/jobs.ts\";\nimport chat from \"./routes/chat.ts\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n throw err;\n});\n\n// Initialize database\nawait runMigrations();\n\n// API routes\napp.route(\"/api/jobs\", jobs);\napp.route(\"/api/chat\", chat);\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 main application\napp.get(\"/\", async c => {\n try {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Inject initial data to avoid extra round-trips\n const initialDataScript = ``;\n\n html = html.replace(\"\", `${initialDataScript}`);\n return c.html(html);\n } catch (error) {\n console.error(\"Error serving index:\", error);\n return c.text(\"Error loading application\", 500);\n }\n});\n\n// Health check endpoint\napp.get(\"/health\", c => c.json({ status: \"ok\", timestamp: new Date().toISOString() }));\n\nexport default app;",[],[153,211],"1dc6222a-3fb7-11f0-929c-76b3cceeab13","jobs.ts","1dc62310-3fb7-11f0-929c-76b3cceeab13","123c9573-b30c-47b2-8dc6-0d24cbd38c7f",5,["D",1748871615948],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { getAllJobs, getJobById, createJob } from \"../database/queries.ts\";\nimport type { CreateJobRequest, JobFilters } from \"../../shared/types.ts\";\n\nconst jobs = new Hono();\n\n// Get all jobs with optional filters\njobs.get(\"/\", async (c) => {\n try {\n const filters: JobFilters = {\n type: c.req.query(\"type\"),\n location: c.req.query(\"location\"),\n search: c.req.query(\"search\")\n };\n\n // Remove undefined values\n Object.keys(filters).forEach(key => {\n if (filters[key as keyof JobFilters] === undefined) {\n delete filters[key as keyof JobFilters];\n }\n });\n\n const jobsList = await getAllJobs(Object.keys(filters).length > 0 ? filters : undefined);\n return c.json(jobsList);\n } catch (error) {\n console.error(\"Error fetching jobs:\", error);\n return c.json({ error: \"Failed to fetch jobs\" }, 500);\n }\n});\n\n// Get specific job by ID\njobs.get(\"/:id\", async (c) => {\n try {\n const id = parseInt(c.req.param(\"id\"));\n if (isNaN(id)) {\n return c.json({ error: \"Invalid job ID\" }, 400);\n }\n\n const job = await getJobById(id);\n if (!job) {\n return c.json({ error: \"Job not found\" }, 404);\n }\n\n return c.json(job);\n } catch (error) {\n console.error(\"Error fetching job:\", error);\n return c.json({ error: \"Failed to fetch job\" }, 500);\n }\n});\n\n// Create new job posting\njobs.post(\"/\", async (c) => {\n try {\n const body = await c.req.json() as CreateJobRequest;\n\n // Validate required fields\n const requiredFields = ['title', 'company', 'location', 'type', 'description', 'requirements', 'contact_email'];\n for (const field of requiredFields) {\n if (!body[field as keyof CreateJobRequest]) {\n return c.json({ error: `Missing required field: ${field}` }, 400);\n }\n }\n\n // Validate job type\n const validTypes = ['full-time', 'part-time', 'contract', 'remote'];\n if (!validTypes.includes(body.type)) {\n return c.json({ error: \"Invalid job type\" }, 400);\n }\n\n // Validate email format\n const emailRegex = /^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/;\n if (!emailRegex.test(body.contact_email)) {\n return c.json({ error: \"Invalid email format\" }, 400);\n }\n\n const newJob = await createJob(body);\n return c.json(newJob, 201);\n } catch (error) {\n console.error(\"Error creating job:\", error);\n return c.json({ error: \"Failed to create job\" }, 500);\n }\n});\n\nexport default jobs;",[],[153,226,218],"routes","264c0aea-3fb7-11f0-9279-76b3cceeab13","chat.ts","264c0ba8-3fb7-11f0-9279-76b3cceeab13",6,["D",1748871630247],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { getChatMessages, createChatMessage, getRecentChatMessages } from \"../database/queries.ts\";\nimport type { CreateMessageRequest } from \"../../shared/types.ts\";\n\nconst chat = new Hono();\n\n// Get chat messages\nchat.get(\"/messages\", async (c) => {\n try {\n const limit = parseInt(c.req.query(\"limit\") || \"50\");\n const messages = await getChatMessages(limit);\n return c.json(messages);\n } catch (error) {\n console.error(\"Error fetching messages:\", error);\n return c.json({ error: \"Failed to fetch messages\" }, 500);\n }\n});\n\n// Send new chat message\nchat.post(\"/messages\", async (c) => {\n try {\n const body = await c.req.json() as CreateMessageRequest;\n\n // Validate required fields\n if (!body.username || !body.message) {\n return c.json({ error: \"Username and message are required\" }, 400);\n }\n\n // Validate message length\n if (body.message.length > 500) {\n return c.json({ error: \"Message too long (max 500 characters)\" }, 400);\n }\n\n // Validate username length\n if (body.username.length > 50) {\n return c.json({ error: \"Username too long (max 50 characters)\" }, 400);\n }\n\n // Basic content filtering\n const message = body.message.trim();\n if (message.length === 0) {\n return c.json({ error: \"Message cannot be empty\" }, 400);\n }\n\n const newMessage = await createChatMessage({\n username: body.username.trim(),\n message: message\n });\n\n return c.json(newMessage, 201);\n } catch (error) {\n console.error(\"Error creating message:\", error);\n return c.json({ error: \"Failed to send message\" }, 500);\n }\n});\n\n// Server-sent events for real-time chat updates\nchat.get(\"/stream\", async (c) => {\n const lastMessageTime = c.req.query(\"since\") || new Date(0).toISOString();\n \n // Set up SSE headers\n c.header(\"Content-Type\", \"text/event-stream\");\n c.header(\"Cache-Control\", \"no-cache\");\n c.header(\"Connection\", \"keep-alive\");\n\n const stream = new ReadableStream({\n start(controller) {\n // Send initial connection message\n controller.enqueue(`data: ${JSON.stringify({ type: \"connected\" })}\\n\\n`);\n\n // Poll for new messages every 2 seconds\n const interval = setInterval(async () => {\n try {\n const recentMessages = await getRecentChatMessages(lastMessageTime);\n if (recentMessages.length > 0) {\n for (const message of recentMessages) {\n controller.enqueue(`data: ${JSON.stringify({ type: \"message\", data: message })}\\n\\n`);\n }\n }\n } catch (error) {\n console.error(\"Error in SSE stream:\", error);\n controller.enqueue(`data: ${JSON.stringify({ type: \"error\", message: \"Stream error\" })}\\n\\n`);\n }\n }, 2000);\n\n // Clean up on close\n setTimeout(() => {\n clearInterval(interval);\n controller.close();\n }, 300000); // Close after 5 minutes\n }\n });\n\n return new Response(stream);\n});\n\nexport default chat;",[],[153,226,228],"1dc62e3c-3fb7-11f0-929c-76b3cceeab13",["D",1748871615948],[173,174],[153,226],"15bd4b58-3fb7-11f0-861e-76b3cceeab13","queries.ts","15bd4c16-3fb7-11f0-861e-76b3cceeab13","203de2c1-d941-457c-81d0-2d47e5a30a07",4,["D",1748871602471],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { JOBS_TABLE, CHAT_TABLE } from \"./migrations.ts\";\nimport type { JobPosting, ChatMessage, CreateJobRequest, CreateMessageRequest, JobFilters } from \"../../shared/types.ts\";\n\n// Job queries\nexport async function getAllJobs(filters?: JobFilters): Promise {\n let query = `SELECT * FROM ${JOBS_TABLE} WHERE 1=1`;\n const params: any[] = [];\n\n if (filters?.type) {\n query += ` AND type = ?`;\n params.push(filters.type);\n }\n\n if (filters?.location) {\n query += ` AND location LIKE ?`;\n params.push(`%${filters.location}%`);\n }\n\n if (filters?.search) {\n query += ` AND (title LIKE ? OR company LIKE ? OR description LIKE ?)`;\n const searchTerm = `%${filters.search}%`;\n params.push(searchTerm, searchTerm, searchTerm);\n }\n\n // Only show non-expired jobs\n query += ` AND (expires_at IS NULL OR expires_at > datetime('now'))`;\n query += ` ORDER BY posted_at DESC`;\n\n const result = await sqlite.execute(query, params);\n return result.rows as JobPosting[];\n}\n\nexport async function getJobById(id: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${JOBS_TABLE} WHERE id = ?`,\n [id]\n );\n return result.rows[0] as JobPosting || null;\n}\n\nexport async function createJob(job: CreateJobRequest): Promise {\n const result = await sqlite.execute(`\n INSERT INTO ${JOBS_TABLE} \n (title, company, location, type, salary_range, description, requirements, contact_email, expires_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)\n `, [\n job.title,\n job.company,\n job.location,\n job.type,\n job.salary_range || null,\n job.description,\n job.requirements,\n job.contact_email,\n job.expires_at || null\n ]);\n\n const newJob = await getJobById(result.lastInsertRowId!);\n if (!newJob) {\n throw new Error('Failed to create job');\n }\n return newJob;\n}\n\n// Chat queries\nexport async function getChatMessages(limit: number = 50): Promise {\n const result = await sqlite.execute(`\n SELECT * FROM ${CHAT_TABLE} \n ORDER BY timestamp DESC \n LIMIT ?\n `, [limit]);\n \n // Reverse to show oldest first\n return (result.rows as ChatMessage[]).reverse();\n}\n\nexport async function createChatMessage(message: CreateMessageRequest): Promise {\n const result = await sqlite.execute(`\n INSERT INTO ${CHAT_TABLE} (username, message)\n VALUES (?, ?)\n `, [message.username, message.message]);\n\n const newMessage = await sqlite.execute(`\n SELECT * FROM ${CHAT_TABLE} WHERE id = ?\n `, [result.lastInsertRowId!]);\n\n return newMessage.rows[0] as ChatMessage;\n}\n\nexport async function getRecentChatMessages(since: string): Promise {\n const result = await sqlite.execute(`\n SELECT * FROM ${CHAT_TABLE} \n WHERE timestamp > ?\n ORDER BY timestamp ASC\n `, [since]);\n \n return result.rows as ChatMessage[];\n}",[],[153,248,240],"database","0c09b90c-3fb7-11f0-9d66-76b3cceeab13","migrations.ts","0c09b9d4-3fb7-11f0-9d66-76b3cceeab13",["D",1748871586191],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nconst JOBS_TABLE = 'it_jobs_board_jobs_v1';\nconst CHAT_TABLE = 'it_jobs_board_chat_v1';\n\nexport async function runMigrations() {\n // Create jobs table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${JOBS_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n title TEXT NOT NULL,\n company TEXT NOT NULL,\n location TEXT NOT NULL,\n type TEXT NOT NULL CHECK (type IN ('full-time', 'part-time', 'contract', 'remote')),\n salary_range TEXT,\n description TEXT NOT NULL,\n requirements TEXT NOT NULL,\n contact_email TEXT NOT NULL,\n posted_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n expires_at DATETIME\n )\n `);\n\n // Create chat messages table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${CHAT_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n username TEXT NOT NULL,\n message TEXT NOT NULL,\n timestamp DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n console.log('Database migrations completed');\n}\n\nexport { JOBS_TABLE, CHAT_TABLE };",[],[153,248,250],"0c09c1d6-3fb7-11f0-9d66-76b3cceeab13",["D",1748871586191],[170,171],[153,248],["D",1748871586191],[169,172,175],[153],["D",1748871539335],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":53,"_99":100,"_101":24},{"_13":84,"_31":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"ctx",{"_77":-5,"_122":300,"_301":302,"_303":304,"_305":24,"_306":24,"_307":24,"_308":57,"_309":-5,"_310":-7,"_311":-7,"_312":61,"_313":24,"_314":24,"_315":-5,"_316":24,"_317":24,"_318":24,"_319":-5},"ENV",{"_271":272,"_273":274,"_275":85,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299},"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 · v9