import { createContext, DomainError } from "@tailor-platform/erp-kit/app"; import { createResolver, t } from "@tailor-platform/sdk"; import { getDB } from "@/generated/kysely-tailordb"; import { purchaseModules } from "@/modules"; export default createResolver({ name: "createPurchaseItem", operation: "mutation", input: { itemId: t.string().description("Item to adopt for purchasing"), requiresPhysicalReceipt: t .bool() .description("Whether ordering this item is expected to produce a goods receipt"), }, body: async (context) => { const ctx = createContext(context); const db = getDB("main-db"); return db .transaction() .execute(async (trx) => { const result = await purchaseModules.commands.createPurchaseItem( trx, { itemId: context.input.itemId, requiresPhysicalReceipt: context.input.requiresPhysicalReceipt, }, ctx, ); if (!result.ok) { switch (result.error.code) { case "PURCHASE_ITEM_NOT_FOUND": throw new DomainError(`Item not found: ${context.input.itemId}`); case "PURCHASE_DUPLICATE_PURCHASE_ITEM": throw new DomainError( `Item already has a purchasing record: ${context.input.itemId}`, ); case "UNAUTHENTICATED": throw new DomainError("Authentication is required"); case "INSUFFICIENT_PERMISSION": throw new DomainError("You do not have permission to perform this action"); default: throw result.error satisfies never; } } return { id: result.value.purchaseItemId }; }) .catch((err: unknown) => { if (err instanceof DomainError) throw err; throw new Error("Failed to adopt the item for purchasing", { cause: err }); }); }, // Entity-typed so clients can select PurchaseItem fields off the result. output: t.object({ id: t.uuid() }).typeName(purchaseModules.db.purchaseItem.name), });