LogiChain - Secure Freight Subcontracting

Available Subcontract Loads

\n \n

\n\n\n\n`;\n}\n\n// --- API & APPLICATION LOGIC ---\nconst app = new Hono();\n\n// Middleware for database initialization and CORS\napp.use(\"*\", cors());\napp.use(\"*\", async (c, next) => {\n await initializeDatabase();\n await next();\n});\n\n// GET /api/loads - Fetches all loads currently available for subcontracting\napp.get(\"/api/loads\", async (c) => {\n const { results: loads } = await sqlite.execute(\n \"SELECT * FROM loads WHERE status = 'in_storage' ORDER BY posted_at DESC\",\n );\n return c.json(loads);\n});\n\n// GET /api/carriers - Fetches all carriers\napp.get(\"/api/carriers\", async (c) => {\n const { results: carriers } = await sqlite.execute(\"SELECT * FROM carriers\");\n return c.json(carriers);\n});\n\n// POST /api/claim - The core AI-driven workflow\napp.post(\"/api/claim\", async (c) => {\n const { loadId, subcontractorId } = await c.req.json();\n\n if (!loadId || !subcontractorId) {\n return c.json({ error: \"Load ID and Subcontractor ID are required.\" }, 400);\n }\n\n // Fetch data for AI analysis\n const load = await sqlite.get(\"SELECT * FROM loads WHERE id = ?\", [loadId]);\n const primaryCarrier = await sqlite.get(\"SELECT * FROM carriers WHERE id = ?\", [load.primary_carrier_id]);\n const subcontractor = await sqlite.get(\"SELECT * FROM carriers WHERE id = ?\", [subcontractorId]);\n\n if (!load || !primaryCarrier || !subcontractor) {\n return c.json({ error: \"Could not find all required records for assessment.\" }, 404);\n }\n if (load.status !== \"in_storage\") {\n return c.json({ error: \"This load is not available for claiming.\" }, 409);\n }\n\n // Construct the prompt for the AI\n const aiInput = {\n load: {\n origin: load.origin,\n destination: load.destination,\n cargo_description: load.cargo_description,\n },\n primaryCarrier: {\n rating: primaryCarrier.rating,\n completed_jobs: primaryCarrier.completed_jobs,\n },\n subcontractor: {\n rating: subcontractor.rating,\n completed_jobs: subcontractor.completed_jobs,\n vehicle_type: subcontractor.vehicle_type,\n },\n };\n\n const openai = new OpenAI();\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [\n { role: \"system\", content: RISK_ASSESSMENT_PROMPT },\n { role: \"user\", content: JSON.stringify(aiInput) },\n ],\n response_format: { type: \"json_object\" },\n });\n\n // Sanitize and parse the AI response\n let assessment;\n try {\n const rawContent = completion.choices[0].message.content;\n assessment = JSON.parse(rawContent);\n // Basic validation of the AI's output structure\n if (typeof assessment.risk_score !== \"number\" || typeof assessment.reason !== \"string\") {\n throw new Error(\"Invalid AI response structure.\");\n }\n } catch (error) {\n console.error(\"AI Response Parsing Error:\", error);\n return c.json({ error: \"Failed to get a valid risk assessment from AI.\" }, 500);\n }\n\n // If the AI rejects the claim, return the assessment without changing state\n if (assessment.decision === \"REJECT\") {\n return c.json({ assessment, updatedLoad: null });\n }\n\n // If approved, update the database\n const updateResult = await sqlite.execute({\n sql: \"UPDATE loads SET subcontractor_id = ?, status = 'claimed', claimed_at = CURRENT_TIMESTAMP WHERE id = ?\",\n args: [subcontractorId, loadId],\n });\n\n if (updateResult.rowsAffected === 0) {\n return c.json({ error: \"Failed to claim the load, another carrier may have claimed it first.\" }, 409);\n }\n\n const updatedLoad = await sqlite.execute({ sql: \"SELECT * FROM loads WHERE id = ?\", args: [loadId] });\n\n return c.json({ assessment, updatedLoad });\n});\n\n// GET /* - Serves the main HTML page\napp.get(\"*\", async (c) => {\n const sourceUrl = c.req.url;\n return c.html(generateHtml(sourceUrl));\n});\n\nexport default app.fetch;","deleted","label",[98],"permalink","https://www.val.town/x/join/loadboard/code/main.tsx","extension","actionData","errors"]