chore: Add productReadOneByIdRequest action

packages/core/state/src/lib/+state/product/product.actions.ts

@@ -26,6 +26,21 @@ export const productReadRequestFail = createAction(
   props<{ error: string }>()
 );
 
+export const productReadOneByIdRequest = createAction(
+  '[PRODUCT] Read one by id request',
+  props<{ payload: { id: string } }>()
+);
+
+export const productReadOneByIdRequestSuccess = createAction(
+  '[PRODUCT] Read one by id success',
+  props<{ payload: IProduct }>()
+);
+
+export const productReadOneByIdRequestFail = createAction(
+  '[PRODUCT] Read one by id fail',
+  props<{ error: string }>()
+);
+
 export const setSelectedId = createAction(
   '[PRODUCT] Set selected id',
   props<{ payload: string | null }>()

packages/core/state/src/lib/+state/product/product.effects.ts

@@ -2,9 +2,13 @@ import { Injectable } from '@angular/core';
 import { Router } from '@angular/router';
 import { Actions, createEffect, ofType } from '@ngrx/effects';
 import { of } from 'rxjs';
-import { catchError, map, switchMap, tap } from 'rxjs/operators';
+import { catchError, exhaustMap, map, switchMap, tap } from 'rxjs/operators';
 
 import { ROUTER } from '@console-core/config';
+import {
+  IoRestorecommerceResourcebaseFilterOperation,
+  IoRestorecommerceResourcebaseFilterValueType,
+} from '@console-core/graphql';
 import {
   ENotificationTypes,
   IProduct,
@@ -15,14 +19,15 @@ import { ErrorHandlingService, ProductService } from '../../services';
 import { AppFacade } from '../app';
 
 import * as productActions from './product.actions';
+import { productReadOneByIdRequest } from './product.actions';
 
 @Injectable()
 export class ProductEffects {
   productReadRequest$ = createEffect(() => {
     let isLoadMore = false;
     return this.actions$.pipe(
       ofType(productActions.productReadRequest),
-      switchMap(({ payload }) =>
+      exhaustMap(({ payload }) =>
         this.productService.read(payload).pipe(
           tap((result) => {
             if (payload.offset) {
@@ -53,6 +58,47 @@ export class ProductEffects {
     );
   });
 
+  productReadOneByIdRequest$ = createEffect(() => {
+    return this.actions$.pipe(
+      ofType(productReadOneByIdRequest),
+      exhaustMap(({ payload }) =>
+        this.productService
+          .read({
+            filters: [
+              {
+                filters: [
+                  {
+                    field: 'id',
+                    value: payload.id,
+                    type: IoRestorecommerceResourcebaseFilterValueType.String,
+                    operation: IoRestorecommerceResourcebaseFilterOperation.Eq,
+                  },
+                ],
+              },
+            ],
+            limit: 1,
+          })
+          .pipe(
+            map((result) => {
+              const payload =
+                result?.data?.catalog?.product?.Read?.details?.items?.pop()
+                  ?.payload as IProduct;
+              return productActions.productReadOneByIdRequestSuccess({
+                payload,
+              });
+            }),
+            catchError((error: Error) =>
+              of(
+                productActions.productReadOneByIdRequestFail({
+                  error: error.message,
+                })
+              )
+            )
+          )
+      )
+    );
+  });
+
   productCreateRequest$ = createEffect(() => {
     return this.actions$.pipe(
       ofType(productActions.productCreateRequest),
@@ -185,6 +231,7 @@ export class ProductEffects {
       return this.actions$.pipe(
         ofType(
           productActions.productReadRequestFail,
+          productActions.productReadOneByIdRequestFail,
           productActions.productCreateFail,
           productActions.productUpdateFail,
           productActions.productRemoveFail

packages/core/state/src/lib/+state/product/product.facade.ts

@@ -32,6 +32,8 @@ export class ProductFacade {
   // Actions
   read = (payload: IIoRestorecommerceResourcebaseReadRequest) =>
     this.store.dispatch(productActions.productReadRequest({ payload }));
+  readOneById = (payload: { id: string }) =>
+    this.store.dispatch(productActions.productReadOneByIdRequest({ payload }));
   setSelectedId = (payload: string | null) =>
     this.store.dispatch(productActions.setSelectedId({ payload }));
   create = (payload: IIoRestorecommerceProductProductList) =>

packages/core/state/src/lib/+state/product/product.reducer.ts

@@ -42,6 +42,29 @@ const reducer = createReducer<IProductState>(
       error,
     })
   ),
+  on(
+    productActions.productReadOneByIdRequest,
+    (state): IProductState => ({
+      ...state,
+      actionStatus: EActionStatus.Requesting,
+    })
+  ),
+  on(
+    productActions.productReadOneByIdRequestSuccess,
+    (state, { payload }): IProductState =>
+      adapter.addOne(payload, {
+        ...state,
+        actionStatus: EActionStatus.Succeeded,
+      })
+  ),
+  on(
+    productActions.productReadOneByIdRequestFail,
+    (state, { error }): IProductState => ({
+      ...state,
+      actionStatus: EActionStatus.Failed,
+      error,
+    })
+  ),
   on(
     productActions.setSelectedId,
     (state, { payload }): IProductState => ({