feat: Stock Management

.gitignore

@@ -2,6 +2,7 @@
 
 # Environment Files
 .env
+.env.*
 
 # compiled output
 dist
@@ -45,4 +46,4 @@ Thumbs.db
 .nx/cache
 
 # Next.js
-.next
+.next

.nvmrc

@@ -1 +1 @@
-lts/iron
+20

libs/items/src/client.ts

@@ -1,5 +1,4 @@
 export {
-  type ItemDetailsResponse,
   type ItemVariantWithAttributes,
   type ItemVariantWithSize,
 } from './services';

libs/items/src/services/attributes/add-attribute/services.ts

@@ -1,8 +1,9 @@
 import { getPrismaClient } from '@vestido-ecommerce/models';
 
-import { CreateAttributeSchema, CreateAttributeSchemaType } from './zod';
+import { CreateAttributeArgs } from './types';
+import { CreateAttributeSchema } from './zod';
 
-export async function createAttribute(body: CreateAttributeSchemaType) {
+export async function createAttribute(body: CreateAttributeArgs) {
   const prisma = getPrismaClient();
 
   const validatedData = CreateAttributeSchema.parse(body);

libs/items/src/services/attributes/add-attribute/types.ts

@@ -1,11 +1,10 @@
-import { ItemAttribute, ItemAttributeValue } from '@prisma/client';
-
+import { createAttribute } from './services';
 import { CreateAttributeSchemaType } from './zod';
 
-export type CreateAttributeRequest = CreateAttributeSchemaType;
+export type CreateAttributeArgs = CreateAttributeSchemaType;
+
+export type CreateAttributeResult = Awaited<ReturnType<typeof createAttribute>>;
 
-export type CreateAttributeResponse = {
-  data: ItemAttribute & {
-    values: ItemAttributeValue[];
-  };
-};
+// export type CreateAttributeResult = ItemAttribute & {
+//   values: ItemAttributeValue[];
+// };

libs/items/src/services/attributes/list-attributes/service.ts

@@ -1,9 +1,9 @@
 import { getPrismaClient } from '@vestido-ecommerce/models';
 
-import { ListAttributesRequest } from './types';
+import { ListAttributesArgs } from './types';
 import { ListAttributeRequestSchema } from './zod';
 
-export async function listAttribute(_args: ListAttributesRequest) {
+export async function listAttribute(_args: ListAttributesArgs) {
   const prisma = getPrismaClient();
   const args = ListAttributeRequestSchema.parse(_args ?? {});
 

libs/items/src/services/attributes/list-attributes/types.ts

@@ -1,5 +1,5 @@
 import { type listAttribute } from './service';
 import { ListAttributeRequestSchemaType } from './zod';
 
-export type ListAttributesRequest = ListAttributeRequestSchemaType;
-export type ListAttributesResponse = Awaited<ReturnType<typeof listAttribute>>;
+export type ListAttributeArgs = ListAttributeRequestSchemaType;
+export type ListAttributesResult = Awaited<ReturnType<typeof listAttribute>>;

libs/items/src/services/attributes/update-attribute/types.ts

@@ -1,11 +1,6 @@
-import { ItemAttribute, ItemAttributeValue } from '@prisma/client';
-
+import { updateAttribute } from './services';
 import { UpdateAttributeSchemaType } from './zod';
 
-export type UpdateAttributeRequest = UpdateAttributeSchemaType;
+export type UpdateAttributeArgs = UpdateAttributeSchemaType;
 
-export type UpdateAttributeResponse = {
-  data: ItemAttribute & {
-    values: ItemAttributeValue[];
-  };
-};
+export type UpdateAttributeResult = Awaited<ReturnType<typeof updateAttribute>>;

libs/items/src/services/cart/add-to-cart/services.ts

@@ -1,8 +1,9 @@
 import { getPrismaClient } from '@vestido-ecommerce/models';
 
-import { AddToCartSchema, AddToCartSchemaType } from './zod';
+import { AddToCartArgs } from './types';
+import { AddToCartSchema } from './zod';
 
-export async function addToCart(body: AddToCartSchemaType) {
+export async function addToCart(body: AddToCartArgs) {
   const prisma = getPrismaClient();
 
   const validatedData = AddToCartSchema.parse(body);

libs/items/src/services/cart/add-to-cart/types.ts

@@ -1,9 +1,6 @@
-import { CartItem } from '@prisma/client';
-
+import { addToCart } from './services';
 import { AddToCartSchemaType } from './zod';
 
-export type AddToCartRequest = AddToCartSchemaType;
+export type AddToCartArgs = AddToCartSchemaType;
 
-export type AddToCartResponse = {
-  data: CartItem;
-};
+export type AddToCartResult = Awaited<ReturnType<typeof addToCart>>;

libs/items/src/services/cart/get-cart/index.ts

@@ -1,2 +1,2 @@
-export * from './services';
+export * from './service';
 export * from './types';

libs/items/src/services/cart/get-cart/types.ts

@@ -1,9 +1,3 @@
-import { CartItem, Item } from '@prisma/client';
+import { listCartItems } from './service';
 
-export type CartItemResponse = {
-  data: Array<
-    CartItem & {
-      item: Item;
-    }
-  >;
-};
+export type CartItemResult = Awaited<ReturnType<typeof listCartItems>>;

libs/items/src/services/cart/remove-from-cart/services.ts

@@ -1,8 +1,9 @@
 import { getPrismaClient } from '@vestido-ecommerce/models';
 
+import { RemoveFromCartArgs } from './types';
 import { RemoveFromCartSchema } from './zod';
 
-export async function removeFromCart(body: unknown) {
+export async function removeFromCart(body: RemoveFromCartArgs) {
   const prisma = getPrismaClient();
   const validatedData = RemoveFromCartSchema.parse(body);
 

libs/items/src/services/cart/remove-from-cart/types.ts

@@ -1,9 +1,6 @@
-import { CartItem } from '@prisma/client';
-
+import { removeFromCart } from './services';
 import { RemoveFromCartSchemaType } from './zod';
 
-export type RemoveFromCartRequest = RemoveFromCartSchemaType;
+export type RemoveFromCartArgs = RemoveFromCartSchemaType;
 
-export type RemoveFromCartResponse = {
-  data: CartItem;
-};
+export type RemoveFromCartResult = Awaited<ReturnType<typeof removeFromCart>>;

libs/items/src/services/categories/create-category/service.ts

@@ -4,9 +4,10 @@ import { getPrismaClient } from '@vestido-ecommerce/models';
 import { VestidoError } from '@vestido-ecommerce/utils';
 
 import { validateSlug } from '../../slug';
-import { CreateCategorySchema, CreateCategorySchemaType } from './zod';
+import { CreateCategoryArgs } from './types';
+import { CreateCategorySchema } from './zod';
 
-export async function createCategory(body: CreateCategorySchemaType) {
+export async function createCategory(body: CreateCategoryArgs) {
   const prisma = getPrismaClient();
 
   const validatedData = CreateCategorySchema.parse(body);

libs/items/src/services/categories/create-category/types.ts

@@ -1,11 +1,6 @@
-import { Category } from '@prisma/client';
-
+import { createCategory } from './service';
 import { CreateCategorySchemaType } from './zod';
 
-export type CreateCategoryRequest = {
-  data: CreateCategorySchemaType;
-};
+export type CreateCategoryArgs = CreateCategorySchemaType;
 
-export type CreateCategoryResponse = {
-  data: Category;
-};
+export type CreateCategoryResult = Awaited<ReturnType<typeof createCategory>>;

libs/items/src/services/categories/get-category/types.ts

@@ -1,5 +1,3 @@
-import { Category } from '@prisma/client';
+import { categoryDetails } from './service';
 
-export type CategoryDetailsResponse = {
-  data: Category;
-};
+export type CategoryDetailsResult = Awaited<ReturnType<typeof categoryDetails>>;

libs/items/src/services/categories/list-category/service.ts

@@ -1,9 +1,9 @@
 import { getPrismaClient } from '@vestido-ecommerce/models';
 
-import { ListCategoryRequest } from './types';
+import { ListCategoryArgs } from './types';
 import { ListCategoryRequestSchema } from './zod';
 
-export async function listCategories(_args: ListCategoryRequest) {
+export async function listCategories(_args: ListCategoryArgs) {
   const prisma = getPrismaClient();
   const args = ListCategoryRequestSchema.parse(_args);
 

libs/items/src/services/categories/list-category/types.ts

@@ -1,5 +1,5 @@
 import { type listCategories } from './service';
 import { ListCategoryRequestSchemaType } from './zod';
 
-export type ListCategoryRequest = ListCategoryRequestSchemaType;
-export type ListCategoriesResponse = Awaited<ReturnType<typeof listCategories>>;
+export type ListCategoryArgs = ListCategoryRequestSchemaType;
+export type ListCategoryResult = Awaited<ReturnType<typeof listCategories>>;

libs/items/src/services/categories/update-category/service.ts

@@ -4,12 +4,12 @@ import { getPrismaClient } from '@vestido-ecommerce/models';
 import { VestidoError } from '@vestido-ecommerce/utils';
 
 import { validateSlug } from '../../slug';
-import { UpdateCategoryRequest } from './types';
+import { UpdateCategoryArgs } from './types';
 import { UpdateCategorySchema } from './zod';
 
 export async function updateCategory(
   categoryId: string,
-  data: UpdateCategoryRequest,
+  data: UpdateCategoryArgs,
 ) {
   const prisma = getPrismaClient();
 

libs/items/src/services/categories/update-category/types.ts

@@ -1,11 +1,6 @@
-import { Category } from '@prisma/client';
-
+import { updateCategory } from './service';
 import { UpdateCategorySchemaType } from './zod';
 
-export type UpdateCategoryRequest = {
-  data: UpdateCategorySchemaType;
-};
+export type UpdateCategoryArgs = UpdateCategorySchemaType;
 
-export type UpdateCategoryResponse = {
-  data: Category;
-};
+export type UpdateCategoryResult = Awaited<ReturnType<typeof updateCategory>>;

libs/items/src/services/index.ts

@@ -9,6 +9,7 @@ export * from './cart/get-cart';
 export * from './cart/remove-from-cart';
 export * from './categories';
 export * from './items';
+export * from './stocks';
 export * from './variants';
 export * from './wishlist/add-to-wishlist';
 export * from './wishlist/get-wishlist';

libs/items/src/services/items/create-item/types.ts

@@ -1,10 +1,6 @@
-import { Item } from '@prisma/client';
-
 import { ItemUpsertSchemaType } from '../zod';
+import { createItem } from './service';
+
+export type CreateItemArgs = ItemUpsertSchemaType;
 
-export type CreateItemRequest = {
-  data: ItemUpsertSchemaType;
-};
-export type CreateItemResponse = {
-  data: Item;
-};
+export type CreateItemResult = Awaited<ReturnType<typeof createItem>>;

libs/items/src/services/items/get-item/types.ts

@@ -1,9 +1,5 @@
 import { getItemDetails } from './service';
 
-export type ItemDetails = NonNullable<
+export type ItemDetailsResult = NonNullable<
   Awaited<ReturnType<typeof getItemDetails>>
 >;
-
-export type ItemDetailsResponse = {
-  data: ItemDetails | null;
-};

libs/items/src/services/items/list-item/types.ts

@@ -1,4 +1,4 @@
 import { type listItem } from './service';
 import { ListItemRequestSchemaType } from './zod';
-export type ListItemRequest = ListItemRequestSchemaType;
-export type ListItemResponse = Awaited<ReturnType<typeof listItem>>;
+export type ListItemArgs = ListItemRequestSchemaType;
+export type ListItemResult = Awaited<ReturnType<typeof listItem>>;

libs/items/src/services/items/update-item/types.ts

@@ -1,10 +1,6 @@
-import { Item } from '@prisma/client';
-
 import { ItemUpsertSchemaType } from '../zod';
+import { updateItem } from './service';
+
+export type UpdateItemArgs = ItemUpsertSchemaType;
 
-export type UpdateItemRequest = {
-  data: ItemUpsertSchemaType;
-};
-export type UpdateItemResponse = {
-  data: Item;
-};
+export type UpdateItemResult = Awaited<ReturnType<typeof updateItem>>;

libs/items/src/services/items/zod.ts

@@ -11,6 +11,7 @@ export const ItemVariantWithSizeSchema = z.object({
   stockStatus: z
     .nativeEnum(StockStatus)
     .default('AVAILABLE' satisfies StockStatus),
+  stockBalance: z.number().nullish(),
 });
 
 export type ItemVariantWithSize = z.infer<typeof ItemVariantWithSizeSchema>;

libs/items/src/services/stocks/get-stock-balance/index.ts

@@ -0,0 +1,2 @@
+export * from './service';
+export * from './types';

libs/items/src/services/stocks/get-stock-balance/service.ts

@@ -0,0 +1,89 @@
+import type { PrismaTransactionalClient } from '@vestido-ecommerce/models';
+import { PrismaClient } from '@vestido-ecommerce/models';
+import { VestidoError } from '@vestido-ecommerce/utils';
+
+import { getStockStatus } from '../get-stock-status';
+import { StockBalanceRow } from './types';
+import { GetStockBalanceInputSchemaType } from './zod';
+
+type StockBalanceResult = {
+  itemId: string;
+  itemVariantId: string | null;
+  stockBalance: number;
+  stockStatus: 'OUT_OF_STOCK' | 'LIMITED_STOCK' | 'AVAILABLE';
+  _stockBalanceRow: StockBalanceRow;
+};
+
+export async function getStockBalances(
+  prisma: PrismaClient | PrismaTransactionalClient,
+  items: GetStockBalanceInputSchemaType[],
+): Promise<Record<string, StockBalanceResult>> {
+  const itemIdsOnly = items
+    .filter((i) => !i.itemVariantId)
+    .map((i) => i.itemId);
+  const variantIdsOnly = items
+    .filter((i) => !!i.itemVariantId)
+    .map((i) => i.itemVariantId!);
+
+  const rows: StockBalanceRow[] = [];
+  if (itemIdsOnly.length > 0) {
+    rows.push(
+      ...((await prisma.$queryRawUnsafe(
+        `
+      SELECT
+        "id" AS "itemId",
+        NULL AS "itemVariantId",
+        "stockBalance" AS balance,
+        "hasVariants"
+      FROM "Item"
+      WHERE "id" = ANY($1::uuid[])
+      FOR UPDATE
+      `,
+        itemIdsOnly,
+      )) as StockBalanceRow[]),
+    );
+
+    const templateRows = rows.filter((r) => r.hasVariants);
+    if (templateRows.length > 0) {
+      throw new VestidoError({
+        message: `Some items have variants. Please specify itemVariantId instead of itemId.`,
+        name: 'TemplateItemCannotHaveStockBalance',
+        httpStatus: 400,
+        context: {
+          itemIds: templateRows.map((r) => r.itemId),
+        },
+      });
+    }
+  }
+
+  if (variantIdsOnly.length > 0) {
+    rows.push(
+      ...((await prisma.$queryRawUnsafe(
+        `
+        SELECT "itemId",
+              "id" AS "itemVariantId",
+              "stockBalance" AS balance
+        FROM "ItemVariant"
+        WHERE "id" = ANY($1::uuid[])
+        FOR UPDATE
+        `,
+        variantIdsOnly,
+      )) as StockBalanceRow[]),
+    );
+  }
+
+  const result: Record<string, StockBalanceResult> = {};
+
+  for (const row of rows) {
+    const key = row.itemVariantId ?? row.itemId;
+    result[key] = {
+      itemId: row.itemId,
+      itemVariantId: row.itemVariantId,
+      stockBalance: row.balance,
+      stockStatus: getStockStatus(row.balance),
+      _stockBalanceRow: row,
+    };
+  }
+
+  return result;
+}