update driver api

e2e/driver.test.ts

@@ -57,10 +57,20 @@ test('Set ticket checked', async ({ page }) => {
 	const ticketCode = 'a7d421840cf89e052d7c1aa74caf66d8';
 	await execSQL(sql`UPDATE "request" SET ticket_code = ${ticketCode} WHERE id = ${requestId}`);
 
-	const response = await page
+	const response1 = await page
 		.context()
-		.request.post(`/api/driver/ticket?requestId=${requestId}&ticketCode=${ticketCode}`);
-	expect(response.status()).toBe(200);
+		.request.put(`/api/driver/ticket?requestId=${requestId}&ticketCode=${ticketCode}`);
+	expect(response1.status()).toBe(204);
+
+	const response2 = await page
+		.context()
+		.request.put(`/api/driver/ticket?requestId="NaN"&ticketCode=${ticketCode}`);
+	expect(response2.status()).toBe(400);
+
+	const response3 = await page
+		.context()
+		.request.put(`/api/driver/ticket?requestId=${requestId}&ticketCode=invalidCode`);
+	expect(response3.status()).toBe(404);
 });
 
 test('Set tour fare', async ({ page }) => {
@@ -80,8 +90,14 @@ test('Set tour fare', async ({ page }) => {
 
 	const fare = 1234;
 
-	const response = await page
+	const response1 = await page
 		.context()
-		.request.post(`/api/driver/fare?tourId=${tourId}&fare=${fare}`);
-	expect(response.status()).toBe(200);
+		.request.put(`/api/driver/fare?tourId=${tourId}&fare=${fare}`);
+	expect(response1.status()).toBe(204);
+
+	const response2 = await page.context().request.put(`/api/driver/fare?tourId=NaN&fare=${fare}`);
+	expect(response2.status()).toBe(400);
+
+	const response3 = await page.context().request.put(`/api/driver/fare?tourId=${tourId}&fare=NaN`);
+	expect(response3.status()).toBe(400);
 });

src/routes/api/driver/fare/+server.ts

@@ -1,16 +1,24 @@
 import { db } from '$lib/server/db';
 import { readInt } from '$lib/server/util/readForm.js';
-import { json } from '@sveltejs/kit';
+import { error } from '@sveltejs/kit';
 
-export const POST = async ({ url }) => {
+export const PUT = async ({ url }) => {
 	const tourId = readInt(url.searchParams.get('tourId'));
 	const fare = readInt(url.searchParams.get('fare'));
 
 	if (isNaN(fare) || isNaN(tourId)) {
-		throw 'bad params';
+		throw error(400, 'Bad request');
 	}
 
-	await db.updateTable('tour').set({ fare: fare }).where('id', '=', tourId).execute();
+	const result = await db
+		.updateTable('tour')
+		.set({ fare: fare })
+		.where('id', '=', tourId)
+		.executeTakeFirst();
 
-	return json({ success: true });
+	if (result.numUpdatedRows === BigInt(0)) {
+		throw error(404, 'Not found');
+	}
+
+	return new Response(null, { status: 204 });
 };

src/routes/api/driver/ticket/+server.ts

@@ -1,21 +1,25 @@
 import { db } from '$lib/server/db';
 import { readInt } from '$lib/server/util/readForm.js';
-import { json } from '@sveltejs/kit';
+import { error } from '@sveltejs/kit';
 
-export const POST = async ({ url }) => {
+export const PUT = async ({ url }) => {
 	const requestId = readInt(url.searchParams.get('requestId'));
 	const ticketCode = url.searchParams.get('ticketCode');
 
 	if (typeof ticketCode !== 'string' || isNaN(requestId)) {
-		throw 'bad params';
+		throw error(400, 'Bad request');
 	}
 
-	await db
+	const result = await db
 		.updateTable('request')
 		.set({ ticketChecked: true })
 		.where('id', '=', requestId)
 		.where('ticketCode', '=', ticketCode)
-		.execute();
+		.executeTakeFirst();
 
-	return json({ success: true });
+	if (result.numUpdatedRows === BigInt(0)) {
+		throw error(404, 'Not found');
+	}
+
+	return new Response(null, { status: 204 });
 };

src/routes/api/driver/tour/+server.ts

@@ -1,10 +1,15 @@
 import { getTours } from '$lib/server/db/getTours';
 import { readInt } from '$lib/server/util/readForm.js';
-import { json } from '@sveltejs/kit';
+import { json, error } from '@sveltejs/kit';
 
 export const GET = async ({ locals, url }) => {
 	const companyId = locals.session!.companyId!;
 	const fromTime = readInt(url.searchParams.get('fromTime'));
 	const toTime = readInt(url.searchParams.get('toTime'));
+
+	if (isNaN(fromTime) || isNaN(toTime)) {
+		throw error(400, 'Bad request');
+	}
+
 	return json(await getTours(false, companyId, [fromTime, toTime]));
 };