chore: wip

Author: glennmichael123

storage/framework/core/commerce/src/coupons/fetch.ts

@@ -1,6 +1,6 @@
 import type { CouponJsonResponse, CouponsTable } from '../../../../orm/src/models/Coupon'
-import { db } from '@stacksjs/database'
 import type { CouponStats } from '../../types'
+import { db } from '@stacksjs/database'
 
 export interface FetchCouponsOptions {
   page?: number

storage/framework/core/commerce/src/coupons/store.ts

@@ -0,0 +1,66 @@
+import type { CouponRequestType } from '@stacksjs/orm'
+import type { CouponsTable, NewCoupon } from '../../../../orm/src/models/Coupon'
+import { db } from '@stacksjs/database'
+
+/**
+ * Create a new coupon
+ *
+ * @param request The coupon data to store
+ * @returns The newly created coupon record
+ */
+export async function store(request: CouponRequestType): Promise<CouponsTable | undefined> {
+  await request.validate()
+
+  const couponData: NewCoupon = {
+    code: request.get<string>('code'),
+    description: request.get('description'),
+    discount_type: request.get<string>('discount_type'),
+    discount_value: request.get<number>('discount_value'),
+    min_order_amount: request.get<number | undefined>('min_order_amount'),
+    max_discount_amount: request.get<number | undefined>('max_discount_amount'),
+    free_product_id: request.get('free_product_id'),
+    is_active: request.get<boolean>('is_active'),
+    usage_limit: request.get<number | undefined>('usage_limit'),
+    usage_count: request.get<number>('usage_count'),
+    start_date: request.get<string>('start_date'),
+    end_date: request.get<string>('end_date'),
+    applicable_products: request.get<string[] | undefined>('applicable_products')
+      ? JSON.stringify(request.get<string[]>('applicable_products'))
+      : JSON.stringify([]),
+    applicable_categories: request.get<string[] | undefined>('applicable_categories')
+      ? JSON.stringify(request.get<string[]>('applicable_categories'))
+      : JSON.stringify([]),
+  }
+
+  try {
+    // Insert the coupon record
+    const createdCoupon = await db
+      .insertInto('coupons')
+      .values(couponData)
+      .executeTakeFirst()
+
+    // If insert was successful, retrieve the newly created coupon
+    if (createdCoupon.insertId) {
+      const coupon = await db
+        .selectFrom('coupons')
+        .where('id', '=', Number(createdCoupon.insertId))
+        .selectAll()
+        .executeTakeFirst()
+
+      return coupon
+    }
+
+    return undefined
+  }
+  catch (error) {
+    if (error instanceof Error) {
+      if (error.message.includes('Duplicate entry') && error.message.includes('code')) {
+        throw new Error('A coupon with this code already exists')
+      }
+
+      throw new Error(`Failed to create coupon: ${error.message}`)
+    }
+
+    throw error
+  }
+}

storage/framework/core/commerce/src/customers/store.ts

@@ -9,6 +9,8 @@ import { db } from '@stacksjs/database'
  * @returns The newly created customer record
  */
 export async function store(request: CustomerRequestType): Promise<CustomersTable | undefined> {
+  await request.validate()
+
   const customerData: NewCustomer = {
     name: request.get('name'),
     email: request.get('email'),

storage/framework/core/commerce/src/orders/store.ts

@@ -11,7 +11,7 @@ import { db } from '@stacksjs/database'
  */
 export async function store(request: OrderRequestType): Promise<OrderType | undefined> {
   // Validate the request data
-  request.validate()
+  await request.validate()
 
   try {
     // Prepare order data