76 lines
1.8 KiB
TypeScript
76 lines
1.8 KiB
TypeScript
import { neon } from "@neondatabase/serverless";
|
|
|
|
export async function POST(request: Request) {
|
|
try {
|
|
const body = await request.json();
|
|
const {
|
|
origin_address,
|
|
destination_address,
|
|
origin_latitude,
|
|
origin_longitude,
|
|
destination_latitude,
|
|
destination_longitude,
|
|
ride_time,
|
|
fare_price,
|
|
payment_status,
|
|
driver_id,
|
|
user_id,
|
|
} = body;
|
|
|
|
if (
|
|
!origin_address ||
|
|
!destination_address ||
|
|
!origin_latitude ||
|
|
!origin_longitude ||
|
|
!destination_latitude ||
|
|
!destination_longitude ||
|
|
!ride_time ||
|
|
!fare_price ||
|
|
!payment_status ||
|
|
!driver_id ||
|
|
!user_id
|
|
) {
|
|
return Response.json(
|
|
{ error: "Missing required fields" },
|
|
{ status: 400 },
|
|
);
|
|
}
|
|
|
|
const sql = neon(`${process.env.DATABASE_URL}`);
|
|
|
|
const response = await sql`
|
|
INSERT INTO rides (
|
|
origin_address,
|
|
destination_address,
|
|
origin_latitude,
|
|
origin_longitude,
|
|
destination_latitude,
|
|
destination_longitude,
|
|
ride_time,
|
|
fare_price,
|
|
payment_status,
|
|
driver_id,
|
|
user_id
|
|
) VALUES (
|
|
${origin_address},
|
|
${destination_address},
|
|
${origin_latitude},
|
|
${origin_longitude},
|
|
${destination_latitude},
|
|
${destination_longitude},
|
|
${ride_time},
|
|
${fare_price},
|
|
${payment_status},
|
|
${driver_id},
|
|
${user_id}
|
|
)
|
|
RETURNING *;
|
|
`;
|
|
|
|
return Response.json({ data: response[0] }, { status: 201 });
|
|
} catch (error) {
|
|
console.error("[CREATE_RIDES]: ", error);
|
|
return Response.json({ error: "Internal Server Error" }, { status: 500 });
|
|
}
|
|
}
|