Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
7dac01acb7 |
@@ -1,5 +1,5 @@
|
|||||||
import { canCancelOrder, orderCancellationBlockedMessage } from "@orderops/shared/order-status";
|
|
||||||
import type { DatabaseContext } from "../db/database";
|
import type { DatabaseContext } from "../db/database";
|
||||||
|
import { canCancelOrder } from "./order-status";
|
||||||
import { appendAuditEvent, findOrderDetail, updateOrderStatus } from "./order-repository";
|
import { appendAuditEvent, findOrderDetail, updateOrderStatus } from "./order-repository";
|
||||||
|
|
||||||
export async function cancelOrder(
|
export async function cancelOrder(
|
||||||
@@ -17,7 +17,7 @@ export async function cancelOrder(
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (!canCancelOrder(order.status)) {
|
if (!canCancelOrder(order.status)) {
|
||||||
return { statusCode: 400, message: orderCancellationBlockedMessage } as const;
|
return { statusCode: 400, message: "Order cannot be cancelled for this order status." } as const;
|
||||||
}
|
}
|
||||||
|
|
||||||
const updatedAt = new Date().toISOString();
|
const updatedAt = new Date().toISOString();
|
||||||
|
|||||||
@@ -117,14 +117,7 @@ export async function findOrderItemRecord(context: DatabaseContext, orderId: str
|
|||||||
.leftJoin(inventory, eq(orderItems.productId, inventory.productId))
|
.leftJoin(inventory, eq(orderItems.productId, inventory.productId))
|
||||||
.where(and(eq(orderItems.id, itemId), eq(orderItems.orderId, orderId)));
|
.where(and(eq(orderItems.id, itemId), eq(orderItems.orderId, orderId)));
|
||||||
|
|
||||||
if (!row) {
|
return row ?? null;
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
return {
|
|
||||||
...row,
|
|
||||||
order: { ...row.order, status: row.order.status as OrderDetail["status"] }
|
|
||||||
};
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export async function updateOrderItemQuantity(context: DatabaseContext, itemId: string, quantity: number) {
|
export async function updateOrderItemQuantity(context: DatabaseContext, itemId: string, quantity: number) {
|
||||||
|
|||||||
@@ -1,108 +0,0 @@
|
|||||||
import { afterEach, beforeEach, describe, expect, test } from "bun:test";
|
|
||||||
import type { AppWithContext } from "../app";
|
|
||||||
import { buildApp } from "../app";
|
|
||||||
import { createUser } from "../users/user-repository";
|
|
||||||
|
|
||||||
let app: AppWithContext;
|
|
||||||
let employeeCookie = "";
|
|
||||||
|
|
||||||
function firstHeader(value: string | string[] | undefined) {
|
|
||||||
return Array.isArray(value) ? value[0] : value ?? "";
|
|
||||||
}
|
|
||||||
|
|
||||||
async function login(username: string) {
|
|
||||||
const response = await app.inject({ method: "POST", url: "/api/login", payload: { username } });
|
|
||||||
return firstHeader(response.headers["set-cookie"]);
|
|
||||||
}
|
|
||||||
|
|
||||||
beforeEach(async () => {
|
|
||||||
app = await buildApp(":memory:");
|
|
||||||
|
|
||||||
await createUser(app.dbContext, {
|
|
||||||
username: "dev-employee",
|
|
||||||
name: "Dev Employee",
|
|
||||||
email: "dev.employee@example.com",
|
|
||||||
role: "employee"
|
|
||||||
});
|
|
||||||
|
|
||||||
employeeCookie = await login("dev-employee");
|
|
||||||
});
|
|
||||||
|
|
||||||
afterEach(async () => {
|
|
||||||
await app.close();
|
|
||||||
});
|
|
||||||
|
|
||||||
describe("assignment 4 order lifecycle rules", () => {
|
|
||||||
test("keeps quantity editing blocked for processing orders", async () => {
|
|
||||||
const response = await app.inject({
|
|
||||||
method: "POST",
|
|
||||||
url: "/api/orders/order_2/items/item_3/quantity",
|
|
||||||
headers: { cookie: employeeCookie },
|
|
||||||
payload: { quantity: 2 }
|
|
||||||
});
|
|
||||||
|
|
||||||
expect(response.statusCode).toBe(400);
|
|
||||||
});
|
|
||||||
|
|
||||||
test("allows address editing for processing orders", async () => {
|
|
||||||
const response = await app.inject({
|
|
||||||
method: "POST",
|
|
||||||
url: "/api/orders/order_2/shipping-address",
|
|
||||||
headers: { cookie: employeeCookie },
|
|
||||||
payload: {
|
|
||||||
fullName: "Jane Doe",
|
|
||||||
line1: "50 New Street",
|
|
||||||
line2: null,
|
|
||||||
city: "Oakland",
|
|
||||||
state: "CA",
|
|
||||||
postalCode: "94607",
|
|
||||||
country: "US"
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
expect(response.statusCode).toBe(200);
|
|
||||||
expect(response.json().shippingAddress.city).toBe("Oakland");
|
|
||||||
});
|
|
||||||
|
|
||||||
test("allows cancellation for processing orders", async () => {
|
|
||||||
const response = await app.inject({
|
|
||||||
method: "POST",
|
|
||||||
url: "/api/orders/order_2/cancel",
|
|
||||||
headers: { cookie: employeeCookie },
|
|
||||||
payload: { reason: "Customer request" }
|
|
||||||
});
|
|
||||||
|
|
||||||
expect(response.statusCode).toBe(200);
|
|
||||||
expect(response.json().status).toBe("cancelled");
|
|
||||||
});
|
|
||||||
|
|
||||||
test("blocks address editing for shipped orders", async () => {
|
|
||||||
const response = await app.inject({
|
|
||||||
method: "POST",
|
|
||||||
url: "/api/orders/order_3/shipping-address",
|
|
||||||
headers: { cookie: employeeCookie },
|
|
||||||
payload: {
|
|
||||||
fullName: "John Smith",
|
|
||||||
line1: "77 Final Mile Road",
|
|
||||||
line2: null,
|
|
||||||
city: "Denver",
|
|
||||||
state: "CO",
|
|
||||||
postalCode: "80202",
|
|
||||||
country: "US"
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
expect(response.statusCode).toBe(400);
|
|
||||||
});
|
|
||||||
|
|
||||||
test("blocks cancellation for shipped orders", async () => {
|
|
||||||
const response = await app.inject({
|
|
||||||
method: "POST",
|
|
||||||
url: "/api/orders/order_3/cancel",
|
|
||||||
headers: { cookie: employeeCookie },
|
|
||||||
payload: { reason: "Late request" }
|
|
||||||
});
|
|
||||||
|
|
||||||
expect(response.statusCode).toBe(400);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
@@ -0,0 +1,13 @@
|
|||||||
|
import type { OrderStatus } from "@orderops/shared/order-status";
|
||||||
|
|
||||||
|
export function canEditOrderItems(status: OrderStatus) {
|
||||||
|
return status === "pending";
|
||||||
|
}
|
||||||
|
|
||||||
|
export function canEditShippingAddress(status: OrderStatus) {
|
||||||
|
return status === "pending" || status === "processing";
|
||||||
|
}
|
||||||
|
|
||||||
|
export function canCancelOrder(status: OrderStatus) {
|
||||||
|
return status === "pending" || status === "processing";
|
||||||
|
}
|
||||||
@@ -1,5 +1,5 @@
|
|||||||
import { canEditOrderItems, orderItemsLockedMessage } from "@orderops/shared/order-status";
|
|
||||||
import type { DatabaseContext } from "../db/database";
|
import type { DatabaseContext } from "../db/database";
|
||||||
|
import { canEditOrderItems } from "./order-status";
|
||||||
import { appendAuditEvent, findOrderDetail, findOrderItemRecord, updateOrderItemQuantity, updateOrderNotes as saveOrderNotes, updateOrderTimestamp } from "./order-repository";
|
import { appendAuditEvent, findOrderDetail, findOrderItemRecord, updateOrderItemQuantity, updateOrderNotes as saveOrderNotes, updateOrderTimestamp } from "./order-repository";
|
||||||
|
|
||||||
export async function changeOrderItemQuantity(
|
export async function changeOrderItemQuantity(
|
||||||
@@ -17,8 +17,8 @@ export async function changeOrderItemQuantity(
|
|||||||
return { statusCode: 404, message: "Order item not found." } as const;
|
return { statusCode: 404, message: "Order item not found." } as const;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!canEditOrderItems(row.order.status)) {
|
if (!canEditOrderItems(row.order.status as never)) {
|
||||||
return { statusCode: 400, message: orderItemsLockedMessage } as const;
|
return { statusCode: 400, message: "Order items cannot be changed for this order status." } as const;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (input.quantity < 1 || input.quantity > 10) {
|
if (input.quantity < 1 || input.quantity > 10) {
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
import type { Address } from "@orderops/shared/address";
|
import type { Address } from "@orderops/shared/address";
|
||||||
import { canEditShippingAddress, shippingAddressLockedMessage } from "@orderops/shared/order-status";
|
|
||||||
import type { DatabaseContext } from "../db/database";
|
import type { DatabaseContext } from "../db/database";
|
||||||
|
import { canEditShippingAddress } from "./order-status";
|
||||||
import { appendAuditEvent, findOrderDetail, updateOrderAddress, updateOrderTimestamp } from "./order-repository";
|
import { appendAuditEvent, findOrderDetail, updateOrderAddress, updateOrderTimestamp } from "./order-repository";
|
||||||
|
|
||||||
export async function changeShippingAddress(
|
export async function changeShippingAddress(
|
||||||
@@ -18,7 +18,7 @@ export async function changeShippingAddress(
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (!canEditShippingAddress(order.status)) {
|
if (!canEditShippingAddress(order.status)) {
|
||||||
return { statusCode: 400, message: shippingAddressLockedMessage } as const;
|
return { statusCode: 400, message: "Shipping address cannot be changed for this order status." } as const;
|
||||||
}
|
}
|
||||||
|
|
||||||
const updatedAt = new Date().toISOString();
|
const updatedAt = new Date().toISOString();
|
||||||
|
|||||||
@@ -51,7 +51,11 @@ export function OrderItemsPanel({ order, onUpdateQuantity }: OrderItemsPanelProp
|
|||||||
<div className="text-sm text-slate-600">{item.sku}</div>
|
<div className="text-sm text-slate-600">{item.sku}</div>
|
||||||
<div className="text-sm text-slate-500">Available: {item.availableQuantity}</div>
|
<div className="text-sm text-slate-500">Available: {item.availableQuantity}</div>
|
||||||
</div>
|
</div>
|
||||||
|
{order.status === "pending" ? (
|
||||||
<QuantityForm itemId={item.id} quantity={item.quantity} onSave={onUpdateQuantity} />
|
<QuantityForm itemId={item.id} quantity={item.quantity} onSave={onUpdateQuantity} />
|
||||||
|
) : (
|
||||||
|
<div className="text-sm text-slate-600">Quantity: {item.quantity}</div>
|
||||||
|
)}
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
))}
|
))}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
import { useEffect, useState } from "react";
|
import { useEffect, useState } from "react";
|
||||||
import { canEditOrderItems, orderItemsLockedMessage, type Address, type AuditEvent, type OrderDetail } from "@orderops/shared";
|
import type { Address, AuditEvent, OrderDetail } from "@orderops/shared";
|
||||||
import { Link, useParams } from "react-router-dom";
|
import { Link, useParams } from "react-router-dom";
|
||||||
import { Toast } from "../ui/toast";
|
import { Toast } from "../ui/toast";
|
||||||
import { cancelOrder, getOrder, listAuditEvents, updateOrderItemQuantity, updateOrderNotes, updateShippingAddress } from "./order-api";
|
import { cancelOrder, getOrder, listAuditEvents, updateOrderItemQuantity, updateOrderNotes, updateShippingAddress } from "./order-api";
|
||||||
@@ -72,19 +72,6 @@ export function OrderPage() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async function handleUpdateQuantity(itemId: string, quantity: number) {
|
|
||||||
if (!order) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!canEditOrderItems(order.status)) {
|
|
||||||
setToast({ message: orderItemsLockedMessage, variant: "error" });
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
await runAction(() => updateOrderItemQuantity(order.id, itemId, quantity), "Quantity saved.");
|
|
||||||
}
|
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<div className="space-y-4">
|
<div className="space-y-4">
|
||||||
<Link className="inline-flex text-sm font-medium text-blue-600 hover:text-blue-700" to="/orders">
|
<Link className="inline-flex text-sm font-medium text-blue-600 hover:text-blue-700" to="/orders">
|
||||||
@@ -97,7 +84,7 @@ export function OrderPage() {
|
|||||||
<OrderDetailPage
|
<OrderDetailPage
|
||||||
order={order}
|
order={order}
|
||||||
auditEvents={auditEvents}
|
auditEvents={auditEvents}
|
||||||
onUpdateQuantity={handleUpdateQuantity}
|
onUpdateQuantity={(itemId, quantity) => runAction(() => updateOrderItemQuantity(order.id, itemId, quantity), "Quantity saved.")}
|
||||||
onSaveAddress={(address: Address) => runAction(() => updateShippingAddress(order.id, address), "Shipping address saved.")}
|
onSaveAddress={(address: Address) => runAction(() => updateShippingAddress(order.id, address), "Shipping address saved.")}
|
||||||
onSaveNotes={(notes) => runAction(() => updateOrderNotes(order.id, notes), "Notes saved.")}
|
onSaveNotes={(notes) => runAction(() => updateOrderNotes(order.id, notes), "Notes saved.")}
|
||||||
onCancel={() => runAction(() => cancelOrder(order.id), "Order cancelled.")}
|
onCancel={() => runAction(() => cancelOrder(order.id), "Order cancelled.")}
|
||||||
|
|||||||
@@ -1,23 +1,3 @@
|
|||||||
export const orderStatuses = ["pending", "processing", "shipped", "cancelled", "refunded"] as const;
|
export const orderStatuses = ["pending", "processing", "shipped", "cancelled", "refunded"] as const;
|
||||||
|
|
||||||
export type OrderStatus = (typeof orderStatuses)[number];
|
export type OrderStatus = (typeof orderStatuses)[number];
|
||||||
|
|
||||||
const orderItemsEditableStatuses: readonly OrderStatus[] = ["pending"];
|
|
||||||
const shippingAddressEditableStatuses: readonly OrderStatus[] = ["pending", "processing"];
|
|
||||||
const orderCancellableStatuses: readonly OrderStatus[] = ["pending", "processing"];
|
|
||||||
|
|
||||||
export const orderItemsLockedMessage = "Order items cannot be changed for this order status.";
|
|
||||||
export const shippingAddressLockedMessage = "Shipping address cannot be changed for this order status.";
|
|
||||||
export const orderCancellationBlockedMessage = "Order cannot be cancelled for this order status.";
|
|
||||||
|
|
||||||
export function canEditOrderItems(status: OrderStatus) {
|
|
||||||
return orderItemsEditableStatuses.includes(status);
|
|
||||||
}
|
|
||||||
|
|
||||||
export function canEditShippingAddress(status: OrderStatus) {
|
|
||||||
return shippingAddressEditableStatuses.includes(status);
|
|
||||||
}
|
|
||||||
|
|
||||||
export function canCancelOrder(status: OrderStatus) {
|
|
||||||
return orderCancellableStatuses.includes(status);
|
|
||||||
}
|
|
||||||
|
|||||||
Reference in New Issue
Block a user