Merge branch 'hotfix/4266-Archivartikel'

(cherry picked from commit 1d865c47d7)

.vscode/launch.json

@@ -1,22 +1,15 @@
 {
-  // Use IntelliSense to learn about possible attributes.
-  // Hover to view descriptions of existing attributes.
-  // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
-  "version": "0.11.0",
-  "configurations": [
-    {
-      "type": "chrome",
-      "request": "launch",
-      "name": "Launch Chrome",
-      "url": "https://192.168.2.112:4200",
-      "webRoot": "${workspaceFolder}",
-      "sourceMaps": true,
-      "sourceMapPathOverrides": {
-        "/./*": "${webRoot}/*",
-        "/src/*": "${webRoot}/*",
-        "/*": "*",
-        "/./~/*": "${webRoot}/node_modules/*"
-      }
-    }
-  ]
-}
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "type": "chrome",
+            "request": "launch",
+            "name": "ISA-App Chrome",
+            "url": "https://localhost:4200",
+            "webRoot": "${workspaceFolder}",
+        }
+    ]
+}

Dockerfile

@@ -1,5 +1,5 @@
 #stage 1
-FROM node:14 as base
+FROM node:18 as base
 ARG IS_PRODUCTION=false
 ARG SEMVERSION=1.0.0
 ARG BuildUniqueID

apps/adapter/scan/karma.conf.js

@@ -1,41 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      jasmine: {
-        // you can add configuration options for Jasmine here
-        // the possible options are listed at https://jasmine.github.io/api/edge/Configuration.html
-        // for example, you can disable the random execution with `random: false`
-        // or set a specific seed with `seed: 4321`
-      },
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    jasmineHtmlReporter: {
-      suppressAll: true, // removes the duplicated traces
-    },
-    coverageReporter: {
-      dir: require('path').join(__dirname, '../../../coverage/adapter/scan'),
-      subdir: '.',
-      reporters: [{ type: 'html' }, { type: 'text-summary' }],
-    },
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/adapter/scan/src/lib/dev.scan-adapter.ts

@@ -1,4 +1,5 @@
 import { Injectable, isDevMode } from '@angular/core';
+import { EnvironmentService } from '@core/environment';
 import { PromptModalData, UiModalService, UiPromptModalComponent } from '@ui/modal';
 import { Observable } from 'rxjs';
 import { ScanAdapter } from './scan-adapter';
@@ -7,9 +8,9 @@ import { ScanAdapter } from './scan-adapter';
 export class DevScanAdapter implements ScanAdapter {
   readonly name = 'Dev';
 
-  constructor(private _modal: UiModalService) {}
+  constructor(private _modal: UiModalService, private _environmentService: EnvironmentService) {}
 
-  init(): Promise<boolean> {
+  async init(): Promise<boolean> {
     return new Promise((resolve, reject) => {
       resolve(isDevMode());
     });

apps/adapter/scan/src/lib/dummy.spec.ts

@@ -0,0 +1,5 @@
+describe('Dummy', () => {
+  it('should work', () => {
+    expect(true).toBeTruthy();
+  });
+});

apps/adapter/scan/src/lib/native.scan-adapter.ts

@@ -12,7 +12,7 @@ export class NativeScanAdapter implements ScanAdapter {
 
   init(): Promise<boolean> {
     return new Promise((resolve, reject) => {
-      resolve(this.nativeContainerService.isUiWebview().isNative);
+      resolve(this.nativeContainerService.isNative);
     });
   }
 

apps/adapter/scan/src/lib/scan.service.ts

@@ -14,7 +14,6 @@ export class ScanAdapterService {
   async init(): Promise<void> {
     for (const adapter of this.scanAdapters) {
       const isReady = await adapter.init();
-      console.log('ScanAdapterService.init', adapter.name, isReady);
       this._readyAdapters[adapter.name] = isReady;
     }
   }
@@ -24,42 +23,30 @@ export class ScanAdapterService {
   }
 
   getAdapter(name: string): ScanAdapter | undefined {
-    return this.scanAdapters.find((adapter) => adapter.name === name);
+    return this._readyAdapters[name] && this.scanAdapters.find((adapter) => adapter.name === name);
   }
 
-  // return true if at least one adapter is ready
   isReady(): boolean {
     return Object.values(this._readyAdapters).some((ready) => ready);
   }
 
-  scan(ops: { use?: string; include?: string[]; exclude?: string[] } = { exclude: ['Dev'] }): Observable<string> {
+  scan(): Observable<string> {
+    const adapterOrder = ['Native', 'Scandit', 'Dev'];
+
     let adapter: ScanAdapter;
 
-    if (ops.use == undefined) {
-      // get the first adapter that is ready to use
-      adapter = this.scanAdapters
-        .filter((adapter) => {
-          if (ops.include?.length) {
-            return ops.include.includes(adapter.name);
-          } else if (ops.exclude?.length) {
-            return !ops.exclude.includes(adapter.name);
-          } else {
-            return true;
-          }
-        })
-        .find((adapter) => this._readyAdapters[adapter.name]);
-    } else {
-      adapter = this.getAdapter(ops.use);
+    for (const name of adapterOrder) {
+      adapter = this.getAdapter(name);
+
+      if (adapter) {
+        break;
+      }
     }
 
     if (!adapter) {
       return throwError('No adapter found');
     }
 
-    if (this._readyAdapters[adapter.name] == false) {
-      return throwError('Adapter is not ready');
-    }
-
     return adapter.scan();
   }
 }

apps/adapter/scan/src/lib/scandit/scandit.scan-adapter.ts

@@ -8,19 +8,24 @@ import { configure } from 'scandit-sdk';
 import { Config } from '@core/config';
 import { ComponentPortal } from '@angular/cdk/portal';
 import { ScanditOverlayComponent } from './scandit-overlay.component';
+import { EnvironmentService } from '@core/environment';
 
 @Injectable()
 export class ScanditScanAdapter implements ScanAdapter {
   readonly name = 'Scandit';
 
-  constructor(private readonly _config: Config, private _overlay: Overlay) {}
+  constructor(private readonly _config: Config, private _overlay: Overlay, private _environmentService: EnvironmentService) {}
 
   async init(): Promise<boolean> {
-    await configure(this._config.get('licence.scandit'), {
-      engineLocation: '/scandit/',
-    });
+    if (this._environmentService.isTablet()) {
+      await configure(this._config.get('licence.scandit'), {
+        engineLocation: '/scandit/',
+      });
 
-    return true;
+      return true;
+    }
+
+    return false;
   }
 
   scan(): Observable<string> {

apps/adapter/scan/src/test.ts

@@ -1,9 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), { teardown: { destroyAfterEach: true } });

apps/adapter/scan/tsconfig.spec.json

@@ -7,11 +7,8 @@
       "jasmine"
     ]
   },
-  "files": [
-    "src/test.ts"
-  ],
   "include": [
     "**/*.spec.ts",
     "**/*.d.ts"
   ]
-}
+}

apps/cdn/product-image/karma.conf.js

@@ -1,32 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage-istanbul-reporter'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    coverageIstanbulReporter: {
-      dir: require('path').join(__dirname, '../../../coverage/cdn/product-image'),
-      reports: ['html', 'lcovonly', 'text-summary'],
-      fixWebpackSourcePaths: true,
-    },
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/cdn/product-image/src/lib/product-image.service.spec.ts

@@ -1,16 +1,20 @@
-import { TestBed } from '@angular/core/testing';
+import { Config } from '@core/config';
+import { createServiceFactory, SpectatorService } from '@ngneat/spectator';
 
 import { ProductImageService } from './product-image.service';
 
 describe('ProductImageService', () => {
-  let service: ProductImageService;
+  let spectator: SpectatorService<ProductImageService>;
+  const createService = createServiceFactory({
+    service: ProductImageService,
+    mocks: [Config],
+  });
 
   beforeEach(() => {
-    TestBed.configureTestingModule({});
-    service = TestBed.inject(ProductImageService);
+    spectator = createService();
   });
 
   it('should be created', () => {
-    expect(service).toBeTruthy();
+    expect(spectator.service).toBeTruthy();
   });
 });

apps/cdn/product-image/src/test.ts

@@ -1,11 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), {
-  teardown: { destroyAfterEach: false },
-});

apps/cdn/product-image/tsconfig.spec.json

@@ -7,11 +7,8 @@
       "jasmine"
     ]
   },
-  "files": [
-    "src/test.ts"
-  ],
   "include": [
     "**/*.spec.ts",
     "**/*.d.ts"
   ]
-}
+}

apps/core/README.md

@@ -1,24 +1,24 @@
-# Auth
+# Core
 
-This library was generated with [Angular CLI](https://github.com/angular/angular-cli) version 12.2.0.
+This library was generated with [Angular CLI](https://github.com/angular/angular-cli) version 15.0.0.
 
 ## Code scaffolding
 
-Run `ng generate component component-name --project auth` to generate a new component. You can also use `ng generate directive|pipe|service|class|guard|interface|enum|module --project auth`.
+Run `ng generate component component-name --project core` to generate a new component. You can also use `ng generate directive|pipe|service|class|guard|interface|enum|module --project core`.
 
-> Note: Don't forget to add `--project auth` or else it will be added to the default project in your `angular.json` file.
+> Note: Don't forget to add `--project core` or else it will be added to the default project in your `angular.json` file.
 
 ## Build
 
-Run `ng build auth` to build the project. The build artifacts will be stored in the `dist/` directory.
+Run `ng build core` to build the project. The build artifacts will be stored in the `dist/` directory.
 
 ## Publishing
 
-After building your library with `ng build auth`, go to the dist folder `cd dist/auth` and run `npm publish`.
+After building your library with `ng build core`, go to the dist folder `cd dist/core` and run `npm publish`.
 
 ## Running unit tests
 
-Run `ng test auth` to execute the unit tests via [Karma](https://karma-runner.github.io).
+Run `ng test core` to execute the unit tests via [Karma](https://karma-runner.github.io).
 
 ## Further help
 

apps/core/application/README.md

@@ -1,25 +0,0 @@
-# Application
-
-This library was generated with [Angular CLI](https://github.com/angular/angular-cli) version 10.1.2.
-
-## Code scaffolding
-
-Run `ng generate component component-name --project application` to generate a new component. You can also use `ng generate directive|pipe|service|class|guard|interface|enum|module --project application`.
-
-> Note: Don't forget to add `--project application` or else it will be added to the default project in your `angular.json` file.
-
-## Build
-
-Run `ng build application` to build the project. The build artifacts will be stored in the `dist/` directory.
-
-## Publishing
-
-After building your library with `ng build application`, go to the dist folder `cd dist/application` and run `npm publish`.
-
-## Running unit tests
-
-Run `ng test application` to execute the unit tests via [Karma](https://karma-runner.github.io).
-
-## Further help
-
-To get more help on the Angular CLI use `ng help` or go check out the [Angular CLI README](https://github.com/angular/angular-cli/blob/master/README.md).

apps/core/application/karma.conf.js

@@ -1,43 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-const customLaunchers = require('../../../karma/custom-launchers');
-const junitReporter = require('../../../karma/junit-reporter')('core-application');
-const coverageReporter = require('../../../karma/coverage-reporter')('core-application');
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage'),
-      require('karma-junit-reporter'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      jasmine: {
-        // you can add configuration options for Jasmine here
-        // the possible options are listed at https://jasmine.github.io/api/edge/Configuration.html
-        // for example, you can disable the random execution with `random: false`
-        // or set a specific seed with `seed: 4321`
-      },
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    jasmineHtmlReporter: {
-      suppressAll: true, // removes the duplicated traces
-    },
-    coverageReporter,
-    junitReporter,
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    customLaunchers,
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/core/application/package.json

@@ -1,11 +0,0 @@
-{
-  "name": "@core/application",
-  "version": "0.0.1",
-  "peerDependencies": {
-    "@angular/common": "^10.1.2",
-    "@angular/core": "^10.1.2"
-  },
-  "dependencies": {
-    "tslib": "^2.0.0"
-  }
-}

apps/core/application/src/lib/application.service.spec.ts

@@ -1,233 +1,233 @@
-import { createServiceFactory, SpectatorService, SpyObject } from '@ngneat/spectator';
-import { Store } from '@ngrx/store';
-import { Observable, of } from 'rxjs';
-import { first } from 'rxjs/operators';
-import { ApplicationProcess } from './defs';
+// import { createServiceFactory, SpectatorService, SpyObject } from '@ngneat/spectator';
+// import { Store } from '@ngrx/store';
+// import { Observable, of } from 'rxjs';
+// import { first } from 'rxjs/operators';
+// import { ApplicationProcess } from './defs';
 
-import { ApplicationService } from './application.service';
-import * as actions from './store/application.actions';
+// import { ApplicationService } from './application.service';
+// import * as actions from './store/application.actions';
 
-describe('ApplicationService', () => {
-  let spectator: SpectatorService<ApplicationService>;
-  let store: SpyObject<Store>;
-  const createService = createServiceFactory({
-    service: ApplicationService,
-    mocks: [Store],
-  });
+// describe('ApplicationService', () => {
+//   let spectator: SpectatorService<ApplicationService>;
+//   let store: SpyObject<Store>;
+//   const createService = createServiceFactory({
+//     service: ApplicationService,
+//     mocks: [Store],
+//   });
 
-  beforeEach(() => {
-    spectator = createService({});
-    store = spectator.inject(Store);
-  });
+//   beforeEach(() => {
+//     spectator = createService({});
+//     store = spectator.inject(Store);
+//   });
 
-  it('should be created', () => {
-    expect(spectator.service).toBeTruthy();
-  });
+//   it('should be created', () => {
+//     expect(spectator.service).toBeTruthy();
+//   });
 
-  describe('activatedProcessId$', () => {
-    it('should return an observable', () => {
-      expect(spectator.service.activatedProcessId$).toBeInstanceOf(Observable);
-    });
-  });
+//   describe('activatedProcessId$', () => {
+//     it('should return an observable', () => {
+//       expect(spectator.service.activatedProcessId$).toBeInstanceOf(Observable);
+//     });
+//   });
 
-  describe('activatedProcessId', () => {
-    it('should return the process id as a number', () => {
-      spyOnProperty(spectator.service['activatedProcessIdSubject'] as any, 'value').and.returnValue(2);
-      expect(spectator.service.activatedProcessId).toBe(2);
-    });
-  });
+//   describe('activatedProcessId', () => {
+//     it('should return the process id as a number', () => {
+//       spyOnProperty(spectator.service['activatedProcessIdSubject'] as any, 'value').and.returnValue(2);
+//       expect(spectator.service.activatedProcessId).toBe(2);
+//     });
+//   });
 
-  describe('getProcesses$()', () => {
-    it('should call select on store and return all selected processes', async () => {
-      const processes: ApplicationProcess[] = [
-        { id: 1, name: 'Vorgang', type: 'cart', section: 'customer', data: { count: 1 } },
-        { id: 2, name: 'Vorgang', type: 'task-calendar', section: 'branch' },
-      ];
-      store.select.and.returnValue(of(processes));
-      const result = await spectator.service.getProcesses$().pipe(first()).toPromise();
-      expect(result).toEqual(processes);
-      expect(store.select).toHaveBeenCalled();
-    });
+//   describe('getProcesses$()', () => {
+//     it('should call select on store and return all selected processes', async () => {
+//       const processes: ApplicationProcess[] = [
+//         { id: 1, name: 'Vorgang', type: 'cart', section: 'customer', data: { count: 1 } },
+//         { id: 2, name: 'Vorgang', type: 'task-calendar', section: 'branch' },
+//       ];
+//       store.select.and.returnValue(of(processes));
+//       const result = await spectator.service.getProcesses$().pipe(first()).toPromise();
+//       expect(result).toEqual(processes);
+//       expect(store.select).toHaveBeenCalled();
+//     });
 
-    it('should call select on store and return all section customer processes', async () => {
-      const processes: ApplicationProcess[] = [
-        { id: 1, name: 'Vorgang', type: 'cart', section: 'customer', data: { count: 1 } },
-        { id: 2, name: 'Vorgang', type: 'task-calendar', section: 'branch' },
-      ];
-      store.select.and.returnValue(of(processes));
-      const result = await spectator.service.getProcesses$('customer').pipe(first()).toPromise();
-      expect(result).toEqual([processes[0]]);
-      expect(store.select).toHaveBeenCalled();
-    });
+//     it('should call select on store and return all section customer processes', async () => {
+//       const processes: ApplicationProcess[] = [
+//         { id: 1, name: 'Vorgang', type: 'cart', section: 'customer', data: { count: 1 } },
+//         { id: 2, name: 'Vorgang', type: 'task-calendar', section: 'branch' },
+//       ];
+//       store.select.and.returnValue(of(processes));
+//       const result = await spectator.service.getProcesses$('customer').pipe(first()).toPromise();
+//       expect(result).toEqual([processes[0]]);
+//       expect(store.select).toHaveBeenCalled();
+//     });
 
-    it('should call select on store and return all section branch processes', async () => {
-      const processes: ApplicationProcess[] = [
-        { id: 1, name: 'Vorgang', type: 'cart', section: 'customer', data: { count: 1 } },
-        { id: 2, name: 'Vorgang', type: 'task-calendar', section: 'branch' },
-      ];
-      store.select.and.returnValue(of(processes));
-      const result = await spectator.service.getProcesses$('branch').pipe(first()).toPromise();
-      expect(result).toEqual([processes[1]]);
-      expect(store.select).toHaveBeenCalled();
-    });
-  });
+//     it('should call select on store and return all section branch processes', async () => {
+//       const processes: ApplicationProcess[] = [
+//         { id: 1, name: 'Vorgang', type: 'cart', section: 'customer', data: { count: 1 } },
+//         { id: 2, name: 'Vorgang', type: 'task-calendar', section: 'branch' },
+//       ];
+//       store.select.and.returnValue(of(processes));
+//       const result = await spectator.service.getProcesses$('branch').pipe(first()).toPromise();
+//       expect(result).toEqual([processes[1]]);
+//       expect(store.select).toHaveBeenCalled();
+//     });
+//   });
 
-  describe('getProcessById$()', () => {
-    it('should return the process by id', async () => {
-      const processes: ApplicationProcess[] = [
-        { id: 1, name: 'Vorgang 1', section: 'customer' },
-        { id: 2, name: 'Vorgang 2', section: 'customer' },
-      ];
-      spyOn(spectator.service, 'getProcesses$').and.returnValue(of(processes));
+//   describe('getProcessById$()', () => {
+//     it('should return the process by id', async () => {
+//       const processes: ApplicationProcess[] = [
+//         { id: 1, name: 'Vorgang 1', section: 'customer' },
+//         { id: 2, name: 'Vorgang 2', section: 'customer' },
+//       ];
+//       spyOn(spectator.service, 'getProcesses$').and.returnValue(of(processes));
 
-      const process = await spectator.service.getProcessById$(1).toPromise();
-      expect(process.id).toBe(1);
-    });
-  });
+//       const process = await spectator.service.getProcessById$(1).toPromise();
+//       expect(process.id).toBe(1);
+//     });
+//   });
 
-  describe('getSection$()', () => {
-    it('should return the selected section branch', async () => {
-      const section = 'branch';
-      store.select.and.returnValue(of(section));
-      const result = await spectator.service.getSection$().pipe(first()).toPromise();
-      expect(result).toEqual(section);
-      expect(store.select).toHaveBeenCalled();
-    });
-  });
+//   describe('getSection$()', () => {
+//     it('should return the selected section branch', async () => {
+//       const section = 'branch';
+//       store.select.and.returnValue(of(section));
+//       const result = await spectator.service.getSection$().pipe(first()).toPromise();
+//       expect(result).toEqual(section);
+//       expect(store.select).toHaveBeenCalled();
+//     });
+//   });
 
-  describe('getActivatedProcessId$', () => {
-    it('should return the current selected activated process id', async () => {
-      const activatedProcessId = 2;
-      store.select.and.returnValue(of({ id: activatedProcessId }));
-      const result = await spectator.service.getActivatedProcessId$().pipe(first()).toPromise();
-      expect(result).toEqual(activatedProcessId);
-      expect(store.select).toHaveBeenCalled();
-    });
-  });
+//   describe('getActivatedProcessId$', () => {
+//     it('should return the current selected activated process id', async () => {
+//       const activatedProcessId = 2;
+//       store.select.and.returnValue(of({ id: activatedProcessId }));
+//       const result = await spectator.service.getActivatedProcessId$().pipe(first()).toPromise();
+//       expect(result).toEqual(activatedProcessId);
+//       expect(store.select).toHaveBeenCalled();
+//     });
+//   });
 
-  describe('activateProcess()', () => {
-    it('should dispatch action setActivatedProcess with argument activatedProcessId and action type', () => {
-      const activatedProcessId = 2;
-      spectator.service.activateProcess(activatedProcessId);
-      expect(store.dispatch).toHaveBeenCalledWith({ activatedProcessId, type: actions.setActivatedProcess.type });
-    });
-  });
+//   describe('activateProcess()', () => {
+//     it('should dispatch action setActivatedProcess with argument activatedProcessId and action type', () => {
+//       const activatedProcessId = 2;
+//       spectator.service.activateProcess(activatedProcessId);
+//       expect(store.dispatch).toHaveBeenCalledWith({ activatedProcessId, type: actions.setActivatedProcess.type });
+//     });
+//   });
 
-  describe('removeProcess()', () => {
-    it('should dispatch action removeProcess with argument processId and action type', () => {
-      const processId = 2;
-      spectator.service.removeProcess(processId);
-      expect(store.dispatch).toHaveBeenCalledWith({ processId, type: actions.removeProcess.type });
-    });
-  });
+//   describe('removeProcess()', () => {
+//     it('should dispatch action removeProcess with argument processId and action type', () => {
+//       const processId = 2;
+//       spectator.service.removeProcess(processId);
+//       expect(store.dispatch).toHaveBeenCalledWith({ processId, type: actions.removeProcess.type });
+//     });
+//   });
 
-  describe('createProcess()', () => {
-    it('should dispatch action addProcess with process', async () => {
-      const process: ApplicationProcess = {
-        id: 1,
-        name: 'Vorgang 1',
-        section: 'customer',
-        type: 'cart',
-      };
+//   describe('createProcess()', () => {
+//     it('should dispatch action addProcess with process', async () => {
+//       const process: ApplicationProcess = {
+//         id: 1,
+//         name: 'Vorgang 1',
+//         section: 'customer',
+//         type: 'cart',
+//       };
 
-      const timestamp = 100;
-      spyOn(spectator.service as any, '_createTimestamp').and.returnValue(timestamp);
-      spyOn(spectator.service, 'getProcessById$').and.returnValue(of(undefined));
-      await spectator.service.createProcess(process);
+//       const timestamp = 100;
+//       spyOn(spectator.service as any, '_createTimestamp').and.returnValue(timestamp);
+//       spyOn(spectator.service, 'getProcessById$').and.returnValue(of(undefined));
+//       await spectator.service.createProcess(process);
 
-      expect(store.dispatch).toHaveBeenCalledWith({
-        type: actions.addProcess.type,
-        process: {
-          ...process,
-          activated: 0,
-          created: timestamp,
-        },
-      });
-    });
+//       expect(store.dispatch).toHaveBeenCalledWith({
+//         type: actions.addProcess.type,
+//         process: {
+//           ...process,
+//           activated: 0,
+//           created: timestamp,
+//         },
+//       });
+//     });
 
-    it('should throw an error if the process id is already existing', async () => {
-      const process: ApplicationProcess = {
-        id: 1,
-        name: 'Vorgang 1',
-        section: 'customer',
-        type: 'cart',
-      };
-      spyOn(spectator.service, 'getProcessById$').and.returnValue(of(process));
-      await expectAsync(spectator.service.createProcess(process)).toBeRejectedWithError('Process Id existiert bereits');
-    });
+//     it('should throw an error if the process id is already existing', async () => {
+//       const process: ApplicationProcess = {
+//         id: 1,
+//         name: 'Vorgang 1',
+//         section: 'customer',
+//         type: 'cart',
+//       };
+//       spyOn(spectator.service, 'getProcessById$').and.returnValue(of(process));
+//       await expectAsync(spectator.service.createProcess(process)).toBeRejectedWithError('Process Id existiert bereits');
+//     });
 
-    it('should throw an error if the process id is not a number', async () => {
-      const process: ApplicationProcess = {
-        id: undefined,
-        name: 'Vorgang 1',
-        section: 'customer',
-        type: 'cart',
-      };
-      spyOn(spectator.service, 'getProcessById$').and.returnValue(of({ id: 5, name: 'Vorgang 2', section: 'customer' }));
-      await expectAsync(spectator.service.createProcess(process)).toBeRejectedWithError('Process Id nicht gesetzt');
-    });
-  });
+//     it('should throw an error if the process id is not a number', async () => {
+//       const process: ApplicationProcess = {
+//         id: undefined,
+//         name: 'Vorgang 1',
+//         section: 'customer',
+//         type: 'cart',
+//       };
+//       spyOn(spectator.service, 'getProcessById$').and.returnValue(of({ id: 5, name: 'Vorgang 2', section: 'customer' }));
+//       await expectAsync(spectator.service.createProcess(process)).toBeRejectedWithError('Process Id nicht gesetzt');
+//     });
+//   });
 
-  describe('patchProcess', () => {
-    it('should dispatch action patchProcess with changes', async () => {
-      const process: ApplicationProcess = {
-        id: 1,
-        name: 'Vorgang 1',
-        section: 'customer',
-        type: 'cart',
-      };
+//   describe('patchProcess', () => {
+//     it('should dispatch action patchProcess with changes', async () => {
+//       const process: ApplicationProcess = {
+//         id: 1,
+//         name: 'Vorgang 1',
+//         section: 'customer',
+//         type: 'cart',
+//       };
 
-      await spectator.service.patchProcess(process.id, process);
+//       await spectator.service.patchProcess(process.id, process);
 
-      expect(store.dispatch).toHaveBeenCalledWith({
-        type: actions.patchProcess.type,
-        processId: process.id,
-        changes: {
-          ...process,
-        },
-      });
-    });
-  });
+//       expect(store.dispatch).toHaveBeenCalledWith({
+//         type: actions.patchProcess.type,
+//         processId: process.id,
+//         changes: {
+//           ...process,
+//         },
+//       });
+//     });
+//   });
 
-  describe('setSection()', () => {
-    it('should dispatch action setSection with argument section and action type', () => {
-      const section = 'customer';
-      spectator.service.setSection(section);
-      expect(store.dispatch).toHaveBeenCalledWith({ section, type: actions.setSection.type });
-    });
-  });
+//   describe('setSection()', () => {
+//     it('should dispatch action setSection with argument section and action type', () => {
+//       const section = 'customer';
+//       spectator.service.setSection(section);
+//       expect(store.dispatch).toHaveBeenCalledWith({ section, type: actions.setSection.type });
+//     });
+//   });
 
-  describe('getLastActivatedProcessWithSectionAndType()', () => {
-    it('should return the last activated process by section and type', async () => {
-      const processes: ApplicationProcess[] = [
-        { id: 1, name: 'Vorgang 1', section: 'customer', type: 'cart', activated: 100 },
-        { id: 2, name: 'Vorgang 2', section: 'customer', type: 'cart', activated: 200 },
-        { id: 3, name: 'Vorgang 3', section: 'customer', type: 'goodsOut', activated: 300 },
-      ];
-      spyOn(spectator.service, 'getProcesses$').and.returnValue(of(processes));
+//   describe('getLastActivatedProcessWithSectionAndType()', () => {
+//     it('should return the last activated process by section and type', async () => {
+//       const processes: ApplicationProcess[] = [
+//         { id: 1, name: 'Vorgang 1', section: 'customer', type: 'cart', activated: 100 },
+//         { id: 2, name: 'Vorgang 2', section: 'customer', type: 'cart', activated: 200 },
+//         { id: 3, name: 'Vorgang 3', section: 'customer', type: 'goodsOut', activated: 300 },
+//       ];
+//       spyOn(spectator.service, 'getProcesses$').and.returnValue(of(processes));
 
-      expect(await spectator.service.getLastActivatedProcessWithSectionAndType$('customer', 'cart').pipe(first()).toPromise()).toBe(
-        processes[1]
-      );
-    });
-  });
+//       expect(await spectator.service.getLastActivatedProcessWithSectionAndType$('customer', 'cart').pipe(first()).toPromise()).toBe(
+//         processes[1]
+//       );
+//     });
+//   });
 
-  describe('getLastActivatedProcessWithSection()', () => {
-    it('should return the last activated process by section', async () => {
-      const processes: ApplicationProcess[] = [
-        { id: 1, name: 'Vorgang 1', section: 'customer', activated: 100 },
-        { id: 2, name: 'Vorgang 2', section: 'customer', activated: 200 },
-        { id: 3, name: 'Vorgang 3', section: 'customer', activated: 300 },
-      ];
-      spyOn(spectator.service, 'getProcesses$').and.returnValue(of(processes));
+//   describe('getLastActivatedProcessWithSection()', () => {
+//     it('should return the last activated process by section', async () => {
+//       const processes: ApplicationProcess[] = [
+//         { id: 1, name: 'Vorgang 1', section: 'customer', activated: 100 },
+//         { id: 2, name: 'Vorgang 2', section: 'customer', activated: 200 },
+//         { id: 3, name: 'Vorgang 3', section: 'customer', activated: 300 },
+//       ];
+//       spyOn(spectator.service, 'getProcesses$').and.returnValue(of(processes));
 
-      expect(await spectator.service.getLastActivatedProcessWithSection$('customer').pipe(first()).toPromise()).toBe(processes[2]);
-    });
-  });
+//       expect(await spectator.service.getLastActivatedProcessWithSection$('customer').pipe(first()).toPromise()).toBe(processes[2]);
+//     });
+//   });
 
-  describe('_createTimestamp', () => {
-    it('should return the current timestamp in ms', () => {
-      expect(spectator.service['_createTimestamp']()).toBeCloseTo(Date.now());
-    });
-  });
-});
+//   describe('_createTimestamp', () => {
+//     it('should return the current timestamp in ms', () => {
+//       expect(spectator.service['_createTimestamp']()).toBeCloseTo(Date.now());
+//     });
+//   });
+// });

apps/core/application/src/lib/application.service.ts

@@ -1,5 +1,7 @@
 import { Injectable } from '@angular/core';
+import { DomainAvailabilityService } from '@domain/availability';
 import { Store } from '@ngrx/store';
+import { BranchDTO } from '@swagger/checkout';
 import { isBoolean, isNumber } from '@utils/common';
 import { BehaviorSubject, Observable } from 'rxjs';
 import { first, map, switchMap } from 'rxjs/operators';
@@ -68,6 +70,16 @@ export class ApplicationService {
     this.store.dispatch(patchProcessData({ processId, data }));
   }
 
+  getSelectedBranch$(processId?: number): Observable<BranchDTO> {
+    if (!processId) {
+      return this.activatedProcessId$.pipe(
+        switchMap((processId) => this.getProcessById$(processId).pipe(map((process) => process?.data?.selectedBranch)))
+      );
+    }
+
+    return this.getProcessById$(processId).pipe(map((process) => process?.data?.selectedBranch));
+  }
+
   async createProcess(process: ApplicationProcess) {
     const existingProcess = await this.getProcessById$(process?.id).pipe(first()).toPromise();
     if (existingProcess?.id === process?.id) {

apps/core/application/src/lib/store/application.selectors.spec.ts

@@ -5,14 +5,16 @@ import * as selectors from './application.selectors';
 describe('applicationSelectors', () => {
   it('should select the processes', () => {
     const processes: ApplicationProcess[] = [{ id: 1, name: 'Vorgang 1', section: 'customer' }];
-    const state: Partial<ApplicationState> = {
+    const state: ApplicationState = {
       processes,
+      section: 'customer',
     };
     expect(selectors.selectProcesses.projector(state)).toEqual(processes);
   });
 
   it('should select the section', () => {
-    const state: Partial<ApplicationState> = {
+    const state: ApplicationState = {
+      processes: [],
       section: 'customer',
     };
     expect(selectors.selectSection.projector(state)).toEqual('customer');
@@ -24,8 +26,9 @@ describe('applicationSelectors', () => {
       { id: 2, name: 'Vorgang 2', section: 'customer', activated: 300 },
       { id: 3, name: 'Vorgang 3', section: 'customer', activated: 200 },
     ];
-    const state: Partial<ApplicationState> = {
+    const state: ApplicationState = {
       processes,
+      section: 'customer',
     };
     expect(selectors.selectActivatedProcess.projector(state)).toEqual(processes[1]);
   });

apps/core/application/src/test.ts

@@ -1,11 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), {
-  teardown: { destroyAfterEach: false },
-});

apps/core/application/tsconfig.lib.json

@@ -1,24 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/lib",
-    "declaration": true,
-    "declarationMap": true,
-    "inlineSources": true,
-    "types": [],
-    "lib": [
-      "dom",
-      "es2018"
-    ]
-  },
-  "angularCompilerOptions": {
-    "skipTemplateCodegen": true,
-    "strictMetadataEmit": true,
-    "enableResourceInlining": true
-  },
-  "exclude": [
-    "src/test.ts",
-    "**/*.spec.ts"
-  ]
-}

apps/core/application/tslint.json

@@ -1,17 +0,0 @@
-{
-  "extends": "../../../tslint.json",
-  "rules": {
-    "directive-selector": [
-      true,
-      "attribute",
-      "lib",
-      "camelCase"
-    ],
-    "component-selector": [
-      true,
-      "element",
-      "lib",
-      "kebab-case"
-    ]
-  }
-}

apps/core/auth/karma.conf.js

@@ -1,43 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-const customLaunchers = require('../../../karma/custom-launchers');
-const junitReporter = require('../../../karma/junit-reporter')('core-auth');
-const coverageReporter = require('../../../karma/coverage-reporter')('core-auth');
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage'),
-      require('karma-junit-reporter'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      jasmine: {
-        // you can add configuration options for Jasmine here
-        // the possible options are listed at https://jasmine.github.io/api/edge/Configuration.html
-        // for example, you can disable the random execution with `random: false`
-        // or set a specific seed with `seed: 4321`
-      },
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    jasmineHtmlReporter: {
-      suppressAll: true, // removes the duplicated traces
-    },
-    coverageReporter,
-    junitReporter,
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    customLaunchers,
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/core/auth/src/lib/auth.module.ts

@@ -1,7 +1,11 @@
 import { ModuleWithProviders, NgModule } from '@angular/core';
 import { AuthService } from './auth.service';
 import { OAuthModule } from 'angular-oauth2-oidc';
-@NgModule({})
+import { IfRoleDirective } from './if-role.directive';
+@NgModule({
+  declarations: [IfRoleDirective],
+  exports: [IfRoleDirective],
+})
 export class AuthModule {
   static forRoot(): ModuleWithProviders<AuthModule> {
     return {

apps/core/auth/src/lib/auth.service.ts

@@ -1,9 +1,10 @@
+import { coerceArray, coerceStringArray } from '@angular/cdk/coercion';
 import { Injectable } from '@angular/core';
 import { Config } from '@core/config';
 import { isNullOrUndefined } from '@utils/common';
 import { AuthConfig, OAuthService } from 'angular-oauth2-oidc';
 import { JwksValidationHandler } from 'angular-oauth2-oidc-jwks';
-import { BehaviorSubject } from 'rxjs';
+import { asapScheduler, BehaviorSubject } from 'rxjs';
 
 @Injectable({
   providedIn: 'root',
@@ -14,20 +15,29 @@ export class AuthService {
     return this._initialized.asObservable();
   }
 
-  constructor(private _config: Config, private readonly _oAuthService: OAuthService) {}
+  private _authConfig: AuthConfig;
+
+  constructor(private _config: Config, private readonly _oAuthService: OAuthService) {
+    this._oAuthService.events?.subscribe((event) => {
+      if (event.type === 'token_received') {
+        console.log('SSO Token Expiration:', new Date(this._oAuthService.getAccessTokenExpiration()));
+      }
+    });
+  }
 
   async init() {
     if (this._initialized.getValue()) {
       throw new Error('AuthService is already initialized');
     }
 
-    const authConfig: AuthConfig = this._config.get('@core/auth');
+    this._authConfig = this._config.get('@core/auth');
 
-    authConfig.redirectUri = window.location.origin;
-    authConfig.silentRefreshRedirectUri = window.location.origin + '/silent-refresh.html';
-    authConfig.useSilentRefresh = true;
+    this._authConfig.redirectUri = window.location.origin;
 
-    this._oAuthService.configure(authConfig);
+    this._authConfig.silentRefreshRedirectUri = window.location.origin + '/silent-refresh.html';
+    this._authConfig.useSilentRefresh = true;
+
+    this._oAuthService.configure(this._authConfig);
     this._oAuthService.tokenValidationHandler = new JwksValidationHandler();
 
     this._oAuthService.setupAutomaticSilentRefresh();
@@ -84,5 +94,32 @@ export class AuthService {
 
   async logout() {
     await this._oAuthService.revokeTokenAndLogout();
+    // asapScheduler.schedule(() => {
+    //   window.location.reload();
+    // }, 250);
+  }
+
+  hasRole(role: string | string[]) {
+    const roles = coerceArray(role);
+
+    const userRoles = this.getClaimByKey('role');
+
+    if (isNullOrUndefined(userRoles)) {
+      return false;
+    }
+
+    return roles.every((r) => userRoles.includes(r));
+  }
+
+  async refresh() {
+    try {
+      if (this._authConfig.responseType.includes('code') && this._authConfig.scope.includes('offline_access')) {
+        await this._oAuthService.refreshToken();
+      } else {
+        await this._oAuthService.silentRefresh();
+      }
+    } catch (error) {
+      console.error(error);
+    }
   }
 }

apps/core/auth/src/lib/if-role.directive.spec.ts

@@ -0,0 +1,65 @@
+// import { SpectatorDirective, createDirectiveFactory } from '@ngneat/spectator';
+// import { IfRoleDirective } from './if-role.directive';
+// import { AuthService } from './auth.service';
+// import { TemplateRef, ViewContainerRef } from '@angular/core';
+
+// describe('IfRoleDirective', () => {
+//   let spectator: SpectatorDirective<IfRoleDirective>;
+//   const createDirective = createDirectiveFactory({
+//     directive: IfRoleDirective,
+//     mocks: [AuthService],
+//   });
+
+//   it('should create an instance', () => {
+//     spectator = createDirective(`<div *ifRole="'admin'"></div>`);
+//     expect(spectator.directive).toBeTruthy();
+//   });
+
+//   it('should render template when user has the role', () => {
+//     spectator = createDirective(`<div *ifRole="'admin'"></div>`);
+//     const authService = spectator.inject(AuthService);
+//     const viewContainerRef = spectator.inject(ViewContainerRef);
+//     const templateRef = spectator.inject(TemplateRef);
+//     authService.hasRole.and.returnValue(true);
+//     spectator.directive.ngOnChanges();
+//     expect(viewContainerRef.createEmbeddedView).toHaveBeenCalledWith(templateRef, spectator.directive.getContext());
+//   });
+
+//   it('should render else template when user does not have the role', () => {
+//     authService.hasRole.and.returnValue(false);
+//     const elseTemplateRef = {} as TemplateRef<any>;
+//     spectator = createDirective(`<ng-template #elseTemplateRef></ng-template><div *ifRole="'admin'; else elseTemplateRef"></div>`, {
+//       hostProps: {
+//         elseTemplateRef,
+//       },
+//     });
+//     spectator.directive.ngOnChanges();
+//     expect(viewContainerRef.createEmbeddedView).toHaveBeenCalledWith(elseTemplateRef, spectator.directive.getContext());
+//   });
+
+//   it('should render else template when user does not have the role using ifNotRole input', () => {
+//     authService.hasRole.and.returnValue(false);
+//     const elseTemplateRef = {} as TemplateRef<any>;
+//     spectator = createDirective(`<ng-template #elseTemplateRef></ng-template><div *ifNotRole="'admin'; else elseTemplateRef"></div>`, {
+//       hostProps: {
+//         elseTemplateRef,
+//       },
+//     });
+//     spectator.directive.ngOnChanges();
+//     expect(viewContainerRef.createEmbeddedView).toHaveBeenCalledWith(elseTemplateRef, spectator.directive.getContext());
+//   });
+
+//   it('should clear view when user does not have the role and elseTemplateRef is not defined', () => {
+//     authService.hasRole.and.returnValue(false);
+//     spectator = createDirective(`<div *ifRole="'admin'"></div>`);
+//     spectator.directive.ngOnChanges();
+//     expect(viewContainerRef.clear).toHaveBeenCalled();
+//   });
+
+//   it('should set $implicit to ifRole or ifNotRole input', () => {
+//     spectator = createDirective(`<div *ifRole="'admin'"></div>`);
+//     expect(spectator.directive.getContext().$implicit).toEqual('admin');
+//     spectator.setInput('ifNotRole', 'user');
+//     expect(spectator.directive.getContext().$implicit).toEqual('user');
+//   });
+// });

apps/core/auth/src/lib/if-role.directive.ts

@@ -0,0 +1,59 @@
+import { Directive, Input, OnChanges, TemplateRef, ViewContainerRef } from '@angular/core';
+import { AuthService } from './auth.service';
+
+@Directive({
+  selector: '[ifRole],[ifRoleElse],[ifNotRole],[ifNotRoleElse]',
+})
+export class IfRoleDirective implements OnChanges {
+  @Input()
+  ifRole: string | string[];
+
+  @Input()
+  ifRoleElse: TemplateRef<any>;
+
+  @Input()
+  ifNotRole: string | string[];
+
+  @Input()
+  ifNotRoleElse: TemplateRef<any>;
+
+  get renderTemplateRef() {
+    if (this.ifRole) {
+      return this._authService.hasRole(this.ifRole);
+    }
+    if (this.ifNotRole) {
+      return !this._authService.hasRole(this.ifNotRole);
+    }
+    return false;
+  }
+
+  get elseTemplateRef() {
+    return this.ifRoleElse || this.ifNotRoleElse;
+  }
+
+  constructor(private _templateRef: TemplateRef<any>, private _viewContainer: ViewContainerRef, private _authService: AuthService) {}
+
+  ngOnChanges() {
+    this.render();
+  }
+
+  render() {
+    if (this.renderTemplateRef) {
+      this._viewContainer.createEmbeddedView(this._templateRef, this.getContext());
+      return;
+    }
+
+    if (this.elseTemplateRef) {
+      this._viewContainer.createEmbeddedView(this.elseTemplateRef, this.getContext());
+      return;
+    }
+
+    this._viewContainer.clear();
+  }
+
+  getContext(): { $implicit: string | string[] } {
+    return {
+      $implicit: this.ifRole || this.ifNotRole,
+    };
+  }
+}

apps/core/auth/src/test.ts

@@ -1,9 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), { teardown: { destroyAfterEach: true } });

apps/core/breadcrumb/README.md

@@ -1,25 +0,0 @@
-# Breadcrumb
-
-This library was generated with [Angular CLI](https://github.com/angular/angular-cli) version 10.1.2.
-
-## Code scaffolding
-
-Run `ng generate component component-name --project breadcrumb` to generate a new component. You can also use `ng generate directive|pipe|service|class|guard|interface|enum|module --project breadcrumb`.
-
-> Note: Don't forget to add `--project breadcrumb` or else it will be added to the default project in your `angular.json` file.
-
-## Build
-
-Run `ng build breadcrumb` to build the project. The build artifacts will be stored in the `dist/` directory.
-
-## Publishing
-
-After building your library with `ng build breadcrumb`, go to the dist folder `cd dist/breadcrumb` and run `npm publish`.
-
-## Running unit tests
-
-Run `ng test breadcrumb` to execute the unit tests via [Karma](https://karma-runner.github.io).
-
-## Further help
-
-To get more help on the Angular CLI use `ng help` or go check out the [Angular CLI README](https://github.com/angular/angular-cli/blob/master/README.md).

apps/core/breadcrumb/karma.conf.js

@@ -1,32 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage-istanbul-reporter'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    coverageIstanbulReporter: {
-      dir: require('path').join(__dirname, '../../../coverage/core/breadcrumb'),
-      reports: ['html', 'lcovonly', 'text-summary'],
-      fixWebpackSourcePaths: true,
-    },
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/core/breadcrumb/package.json

@@ -1,11 +0,0 @@
-{
-  "name": "@core/breadcrumb",
-  "version": "0.0.1",
-  "peerDependencies": {
-    "@angular/common": "^10.1.2",
-    "@angular/core": "^10.1.2"
-  },
-  "dependencies": {
-    "tslib": "^2.0.0"
-  }
-}

apps/core/breadcrumb/src/lib/breadcrumb.service.spec.ts

@@ -22,17 +22,9 @@ describe('Breadcrumb Service', () => {
     service = TestBed.inject(BreadcrumbService);
   });
 
-  describe('getByKey$', () => {
-    it('should call store.select with the selectBreadcrumbsByKey selector', () => {
-      store.select.and.returnValue(of([]));
-      service.getByKey$('unit-test');
-      expect(store.select).toHaveBeenCalledWith(selectors.selectBreadcrumbsByKey, 'unit-test');
-    });
-  });
-
   describe('addBreadcrumb', () => {
     it('should call store.dispatch with the addBreadecrumb action and retuns a breadcrumb with an id', () => {
-      let breadcrumb: Breadcrumb = { name: 'unit-test', key: 'hello-key', path: 'Run The Test' };
+      let breadcrumb: Breadcrumb = { name: 'unit-test', key: 'hello-key', path: 'Run The Test', section: 'customer' };
       breadcrumb = service.addBreadcrumb(breadcrumb);
       expect(store.dispatch).toHaveBeenCalledWith(actions.addBreadcrumb({ breadcrumb }));
       expect(isNumber(breadcrumb.id)).toBeTruthy();

apps/core/breadcrumb/src/lib/store/breadcrumb.reducer.spec.ts

@@ -17,6 +17,7 @@ describe('Breadcrumb Reducer', () => {
         key: 'unit-test',
         name: 'Test Name',
         path: 'Test Patch',
+        section: 'customer',
       };
 
       const fixture = breadcrumbReducer(INIT, action.addBreadcrumb({ breadcrumb }));
@@ -32,6 +33,7 @@ describe('Breadcrumb Reducer', () => {
         key: 'unit-test',
         name: 'Test Name',
         path: 'Test Patch',
+        section: 'customer',
       };
 
       const expected = {
@@ -54,6 +56,7 @@ describe('Breadcrumb Reducer', () => {
         key: 'unit-test',
         name: 'Test Name',
         path: 'Test Patch',
+        section: 'customer',
       };
 
       const state = breadcrumbReducer(INIT, action.addBreadcrumb({ breadcrumb }));
@@ -71,6 +74,7 @@ describe('Breadcrumb Reducer', () => {
         key: 'unit-test',
         name: 'Test Name',
         path: 'Test Patch',
+        section: 'customer',
       };
       const breadcrumb2 = { ...breadcrumb1, id: 2 };
       const breadcrumb3 = { ...breadcrumb1, id: 3 };

apps/core/breadcrumb/src/lib/store/breadcrumb.selectors.spec.ts

@@ -8,16 +8,29 @@ describe('Breadcrumb Selectors', () => {
   let state: BreadcrumbState;
 
   beforeEach(() => {
-    state = breadcrumbReducer(INIT, action.addBreadcrumb({ breadcrumb: { id: 1, key: 'unit-test-1', path: '', name: 'Unit Test 1' } }));
     state = breadcrumbReducer(
-      state,
-      action.addBreadcrumb({ breadcrumb: { id: 2, key: 'unit-test-1', path: '', name: 'Unit Test 1', tags: ['details'] } })
+      INIT,
+      action.addBreadcrumb({ breadcrumb: { id: 1, key: 'unit-test-1', path: '', name: 'Unit Test 1', section: 'customer' } })
     );
-    state = breadcrumbReducer(state, action.addBreadcrumb({ breadcrumb: { id: 3, key: 'unit-test-2', path: '', name: 'Unit Test 1' } }));
-    state = breadcrumbReducer(state, action.addBreadcrumb({ breadcrumb: { id: 4, key: 'unit-test-3', path: '', name: 'Unit Test 1' } }));
     state = breadcrumbReducer(
       state,
-      action.addBreadcrumb({ breadcrumb: { id: 5, key: 'unit-test-3', path: '', name: 'Unit Test 1', tags: ['details'] } })
+      action.addBreadcrumb({
+        breadcrumb: { id: 2, key: 'unit-test-1', path: '', name: 'Unit Test 1', tags: ['details'], section: 'customer' },
+      })
+    );
+    state = breadcrumbReducer(
+      state,
+      action.addBreadcrumb({ breadcrumb: { id: 3, key: 'unit-test-2', path: '', name: 'Unit Test 1', section: 'customer' } })
+    );
+    state = breadcrumbReducer(
+      state,
+      action.addBreadcrumb({ breadcrumb: { id: 4, key: 'unit-test-3', path: '', name: 'Unit Test 1', section: 'customer' } })
+    );
+    state = breadcrumbReducer(
+      state,
+      action.addBreadcrumb({
+        breadcrumb: { id: 5, key: 'unit-test-3', path: '', name: 'Unit Test 1', tags: ['details'], section: 'customer' },
+      })
     );
   });
 

apps/core/breadcrumb/src/test.ts

@@ -1,11 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), {
-  teardown: { destroyAfterEach: false },
-});

apps/core/breadcrumb/tsconfig.lib.json

@@ -1,24 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/lib",
-    "declaration": true,
-    "declarationMap": true,
-    "inlineSources": true,
-    "types": [],
-    "lib": [
-      "dom",
-      "es2018"
-    ]
-  },
-  "angularCompilerOptions": {
-    "skipTemplateCodegen": true,
-    "strictMetadataEmit": true,
-    "enableResourceInlining": true
-  },
-  "exclude": [
-    "src/test.ts",
-    "**/*.spec.ts"
-  ]
-}

apps/core/breadcrumb/tslint.json

@@ -1,17 +0,0 @@
-{
-  "extends": "../../../tslint.json",
-  "rules": {
-    "directive-selector": [
-      true,
-      "attribute",
-      "lib",
-      "camelCase"
-    ],
-    "component-selector": [
-      true,
-      "element",
-      "lib",
-      "kebab-case"
-    ]
-  }
-}

apps/core/cache/README.md

@@ -1,25 +0,0 @@
-# Cache
-
-This library was generated with [Angular CLI](https://github.com/angular/angular-cli) version 10.1.2.
-
-## Code scaffolding
-
-Run `ng generate component component-name --project cache` to generate a new component. You can also use `ng generate directive|pipe|service|class|guard|interface|enum|module --project cache`.
-
-> Note: Don't forget to add `--project cache` or else it will be added to the default project in your `angular.json` file.
-
-## Build
-
-Run `ng build cache` to build the project. The build artifacts will be stored in the `dist/` directory.
-
-## Publishing
-
-After building your library with `ng build cache`, go to the dist folder `cd dist/cache` and run `npm publish`.
-
-## Running unit tests
-
-Run `ng test cache` to execute the unit tests via [Karma](https://karma-runner.github.io).
-
-## Further help
-
-To get more help on the Angular CLI use `ng help` or go check out the [Angular CLI README](https://github.com/angular/angular-cli/blob/master/README.md).

apps/core/cache/karma.conf.js

@@ -1,32 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage-istanbul-reporter'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    coverageIstanbulReporter: {
-      dir: require('path').join(__dirname, '../../../coverage/core/cache'),
-      reports: ['html', 'lcovonly', 'text-summary'],
-      fixWebpackSourcePaths: true,
-    },
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/core/cache/package.json

@@ -1,11 +0,0 @@
-{
-  "name": "@core/cache",
-  "version": "0.0.1",
-  "peerDependencies": {
-    "@angular/common": "^10.1.2",
-    "@angular/core": "^10.1.2"
-  },
-  "dependencies": {
-    "tslib": "^2.0.0"
-  }
-}

apps/core/cache/src/test.ts

@@ -1,11 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), {
-  teardown: { destroyAfterEach: false },
-});

apps/core/cache/tsconfig.lib.json

@@ -1,24 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/lib",
-    "declaration": true,
-    "declarationMap": true,
-    "inlineSources": true,
-    "types": [],
-    "lib": [
-      "dom",
-      "es2018"
-    ]
-  },
-  "angularCompilerOptions": {
-    "skipTemplateCodegen": true,
-    "strictMetadataEmit": true,
-    "enableResourceInlining": true
-  },
-  "exclude": [
-    "src/test.ts",
-    "**/*.spec.ts"
-  ]
-}

apps/core/cache/tslint.json

@@ -1,17 +0,0 @@
-{
-  "extends": "../../../tslint.json",
-  "rules": {
-    "directive-selector": [
-      true,
-      "attribute",
-      "lib",
-      "camelCase"
-    ],
-    "component-selector": [
-      true,
-      "element",
-      "lib",
-      "kebab-case"
-    ]
-  }
-}

apps/core/command/README.md

@@ -1,25 +0,0 @@
-# Command
-
-This library was generated with [Angular CLI](https://github.com/angular/angular-cli) version 10.1.2.
-
-## Code scaffolding
-
-Run `ng generate component component-name --project command` to generate a new component. You can also use `ng generate directive|pipe|service|class|guard|interface|enum|module --project command`.
-
-> Note: Don't forget to add `--project command` or else it will be added to the default project in your `angular.json` file.
-
-## Build
-
-Run `ng build command` to build the project. The build artifacts will be stored in the `dist/` directory.
-
-## Publishing
-
-After building your library with `ng build command`, go to the dist folder `cd dist/command` and run `npm publish`.
-
-## Running unit tests
-
-Run `ng test command` to execute the unit tests via [Karma](https://karma-runner.github.io).
-
-## Further help
-
-To get more help on the Angular CLI use `ng help` or go check out the [Angular CLI README](https://github.com/angular/angular-cli/blob/master/README.md).

apps/core/command/karma.conf.js

@@ -1,32 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage-istanbul-reporter'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    coverageIstanbulReporter: {
-      dir: require('path').join(__dirname, '../../../coverage/core/command'),
-      reports: ['html', 'lcovonly', 'text-summary'],
-      fixWebpackSourcePaths: true,
-    },
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/core/command/package.json

@@ -1,11 +0,0 @@
-{
-  "name": "@core/command",
-  "version": "0.0.1",
-  "peerDependencies": {
-    "@angular/common": "^10.1.2",
-    "@angular/core": "^10.1.2"
-  },
-  "dependencies": {
-    "tslib": "^2.0.0"
-  }
-}

apps/core/command/src/lib/action-handler.interface.ts

@@ -1,4 +1,6 @@
+import { CommandService } from './command.service';
+
 export abstract class ActionHandler<T = any> {
   constructor(readonly action: string) {}
-  abstract handler(data: T): Promise<T>;
+  abstract handler(data: T, service?: CommandService): Promise<T>;
 }

apps/core/command/src/lib/command.module.ts

@@ -1,8 +1,12 @@
-import { ModuleWithProviders, NgModule, Type } from '@angular/core';
+import { ModuleWithProviders, NgModule, Provider, Type } from '@angular/core';
 import { ActionHandler } from './action-handler.interface';
 import { CommandService } from './command.service';
 import { FEATURE_ACTION_HANDLERS, ROOT_ACTION_HANDLERS } from './tokens';
 
+export function provideActionHandlers(actionHandlers: Type<ActionHandler>[]): Provider[] {
+  return [CommandService, actionHandlers.map((handler) => ({ provide: FEATURE_ACTION_HANDLERS, useClass: handler, multi: true }))];
+}
+
 @NgModule({})
 export class CoreCommandModule {
   static forRoot(actionHandlers: Type<ActionHandler>[]): ModuleWithProviders<CoreCommandModule> {

apps/core/command/src/lib/command.service.spec.ts

@@ -1,16 +1,16 @@
-import { TestBed } from '@angular/core/testing';
+// import { TestBed } from '@angular/core/testing';
 
-import { CommandService } from './command.service';
+// import { CommandService } from './command.service';
 
-describe('CommandService', () => {
-  let service: CommandService;
+// describe('CommandService', () => {
+//   let service: CommandService;
 
-  beforeEach(() => {
-    TestBed.configureTestingModule({});
-    service = TestBed.inject(CommandService);
-  });
+//   beforeEach(() => {
+//     TestBed.configureTestingModule({});
+//     service = TestBed.inject(CommandService);
+//   });
 
-  it('should be created', () => {
-    expect(service).toBeTruthy();
-  });
-});
+//   it('should be created', () => {
+//     expect(service).toBeTruthy();
+//   });
+// });

apps/core/command/src/lib/command.service.ts

@@ -16,7 +16,7 @@ export class CommandService {
         throw new Error('Action Handler does not exist');
       }
 
-      data = await handler.handler(data);
+      data = await handler.handler(data, this);
     }
     return data;
   }

apps/core/command/src/test.ts

@@ -1,11 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), {
-  teardown: { destroyAfterEach: false },
-});

apps/core/command/tsconfig.lib.json

@@ -1,24 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/lib",
-    "declaration": true,
-    "declarationMap": true,
-    "inlineSources": true,
-    "types": [],
-    "lib": [
-      "dom",
-      "es2018"
-    ]
-  },
-  "angularCompilerOptions": {
-    "skipTemplateCodegen": true,
-    "strictMetadataEmit": true,
-    "enableResourceInlining": true
-  },
-  "exclude": [
-    "src/test.ts",
-    "**/*.spec.ts"
-  ]
-}

apps/core/command/tsconfig.spec.json

@@ -1,17 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/spec",
-    "types": [
-      "jasmine"
-    ]
-  },
-  "files": [
-    "src/test.ts"
-  ],
-  "include": [
-    "**/*.spec.ts",
-    "**/*.d.ts"
-  ]
-}

apps/core/command/tslint.json

@@ -1,17 +0,0 @@
-{
-  "extends": "../../../tslint.json",
-  "rules": {
-    "directive-selector": [
-      true,
-      "attribute",
-      "lib",
-      "camelCase"
-    ],
-    "component-selector": [
-      true,
-      "element",
-      "lib",
-      "kebab-case"
-    ]
-  }
-}

apps/core/config/README.md

@@ -1,25 +0,0 @@
-# Config
-
-This library was generated with [Angular CLI](https://github.com/angular/angular-cli) version 12.2.0.
-
-## Code scaffolding
-
-Run `ng generate component component-name --project config` to generate a new component. You can also use `ng generate directive|pipe|service|class|guard|interface|enum|module --project config`.
-
-> Note: Don't forget to add `--project config` or else it will be added to the default project in your `angular.json` file.
-
-## Build
-
-Run `ng build config` to build the project. The build artifacts will be stored in the `dist/` directory.
-
-## Publishing
-
-After building your library with `ng build config`, go to the dist folder `cd dist/config` and run `npm publish`.
-
-## Running unit tests
-
-Run `ng test config` to execute the unit tests via [Karma](https://karma-runner.github.io).
-
-## Further help
-
-To get more help on the Angular CLI use `ng help` or go check out the [Angular CLI Overview and Command Reference](https://angular.io/cli) page.

apps/core/config/karma.conf.js

@@ -1,43 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-const customLaunchers = require('../../../karma/custom-launchers');
-const junitReporter = require('../../../karma/junit-reporter')('core-config');
-const coverageReporter = require('../../../karma/coverage-reporter')('core-config');
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage'),
-      require('karma-junit-reporter'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      jasmine: {
-        // you can add configuration options for Jasmine here
-        // the possible options are listed at https://jasmine.github.io/api/edge/Configuration.html
-        // for example, you can disable the random execution with `random: false`
-        // or set a specific seed with `seed: 4321`
-      },
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    jasmineHtmlReporter: {
-      suppressAll: true, // removes the duplicated traces
-    },
-    coverageReporter,
-    junitReporter,
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    customLaunchers,
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/core/config/src/test.ts

@@ -1,9 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), { teardown: { destroyAfterEach: true } });

apps/core/config/tsconfig.spec.json

@@ -1,17 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/spec",
-    "types": [
-      "jasmine"
-    ]
-  },
-  "files": [
-    "src/test.ts"
-  ],
-  "include": [
-    "**/*.spec.ts",
-    "**/*.d.ts"
-  ]
-}

apps/core/environment/README.md

@@ -1,25 +0,0 @@
-# Environment
-
-This library was generated with [Angular CLI](https://github.com/angular/angular-cli) version 10.1.2.
-
-## Code scaffolding
-
-Run `ng generate component component-name --project environment` to generate a new component. You can also use `ng generate directive|pipe|service|class|guard|interface|enum|module --project environment`.
-
-> Note: Don't forget to add `--project environment` or else it will be added to the default project in your `angular.json` file.
-
-## Build
-
-Run `ng build environment` to build the project. The build artifacts will be stored in the `dist/` directory.
-
-## Publishing
-
-After building your library with `ng build environment`, go to the dist folder `cd dist/environment` and run `npm publish`.
-
-## Running unit tests
-
-Run `ng test environment` to execute the unit tests via [Karma](https://karma-runner.github.io).
-
-## Further help
-
-To get more help on the Angular CLI use `ng help` or go check out the [Angular CLI README](https://github.com/angular/angular-cli/blob/master/README.md).

apps/core/environment/karma.conf.js

@@ -1,32 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage-istanbul-reporter'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    coverageIstanbulReporter: {
-      dir: require('path').join(__dirname, '../../../coverage/core/environment'),
-      reports: ['html', 'lcovonly', 'text-summary'],
-      fixWebpackSourcePaths: true,
-    },
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/core/environment/package.json

@@ -1,11 +0,0 @@
-{
-  "name": "@core/environment",
-  "version": "0.0.1",
-  "peerDependencies": {
-    "@angular/common": "^10.1.2",
-    "@angular/core": "^10.1.2"
-  },
-  "dependencies": {
-    "tslib": "^2.0.0"
-  }
-}

apps/core/environment/src/lib/environment.service.ts

@@ -1,32 +1,26 @@
 import { Injectable } from '@angular/core';
-import { fromEvent } from 'rxjs';
-import { map, take, tap } from 'rxjs/operators';
+import { Platform } from '@angular/cdk/platform';
+import { NativeContainerService } from 'native-container';
 
 @Injectable({
   providedIn: 'root',
 })
 export class EnvironmentService {
-  constructor() {}
+  constructor(private _platform: Platform, private _nativeContainer: NativeContainerService) {}
 
-  // /** Returns whether app is used within native container*/
-  // isNative(): Promise<boolean> {
-  //   return fromEvent(window, 'message')
-  //     .pipe(
-  //       map((evt: MessageEvent) => evt.data),
-  //       tap(console.log.bind(window)),
-  //       map((data) => data.status === 'INIT'),
-  //       take(1)
-  //     )
-  //     .toPromise();
-  // }
-
-  /** Returns whether current device is mobile phone or tablet */
-  async isMobile(): Promise<boolean> {
-    return 'orientation' in window;
+  isDesktop(): boolean {
+    return !this.isTablet();
   }
 
-  /** Returns whether current device is desktop */
-  async isDesktop(): Promise<boolean> {
-    return !(await this.isMobile());
+  isTablet(): boolean {
+    return this.isNative() || this.isSafari();
+  }
+
+  isNative(): boolean {
+    return this._nativeContainer.isNative;
+  }
+
+  isSafari(): boolean {
+    return (this._platform.ANDROID || this._platform.IOS) && this._platform.SAFARI;
   }
 }

apps/core/environment/src/test.ts

@@ -1,11 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), {
-  teardown: { destroyAfterEach: false },
-});

apps/core/environment/tsconfig.lib.json

@@ -1,24 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/lib",
-    "declaration": true,
-    "declarationMap": true,
-    "inlineSources": true,
-    "types": [],
-    "lib": [
-      "dom",
-      "es2018"
-    ]
-  },
-  "angularCompilerOptions": {
-    "skipTemplateCodegen": true,
-    "strictMetadataEmit": true,
-    "enableResourceInlining": true
-  },
-  "exclude": [
-    "src/test.ts",
-    "**/*.spec.ts"
-  ]
-}

apps/core/environment/tsconfig.spec.json

@@ -1,17 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/spec",
-    "types": [
-      "jasmine"
-    ]
-  },
-  "files": [
-    "src/test.ts"
-  ],
-  "include": [
-    "**/*.spec.ts",
-    "**/*.d.ts"
-  ]
-}

apps/core/environment/tslint.json

@@ -1,17 +0,0 @@
-{
-  "extends": "../../../tslint.json",
-  "rules": {
-    "directive-selector": [
-      true,
-      "attribute",
-      "lib",
-      "camelCase"
-    ],
-    "component-selector": [
-      true,
-      "element",
-      "lib",
-      "kebab-case"
-    ]
-  }
-}

apps/core/logger/karma.conf.js

@@ -1,43 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-const customLaunchers = require('../../../karma/custom-launchers');
-const junitReporter = require('../../../karma/junit-reporter')('core-logger');
-const coverageReporter = require('../../../karma/coverage-reporter')('core-logger');
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage'),
-      require('karma-junit-reporter'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      jasmine: {
-        // you can add configuration options for Jasmine here
-        // the possible options are listed at https://jasmine.github.io/api/edge/Configuration.html
-        // for example, you can disable the random execution with `random: false`
-        // or set a specific seed with `seed: 4321`
-      },
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    jasmineHtmlReporter: {
-      suppressAll: true, // removes the duplicated traces
-    },
-    junitReporter,
-    coverageReporter,
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    customLaunchers,
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/core/logger/src/test.ts

@@ -1,9 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), { teardown: { destroyAfterEach: true } });

apps/core/logger/tsconfig.spec.json

@@ -1,17 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/spec",
-    "types": [
-      "jasmine"
-    ]
-  },
-  "files": [
-    "src/test.ts"
-  ],
-  "include": [
-    "**/*.spec.ts",
-    "**/*.d.ts"
-  ]
-}

apps/core/ng-package.json

@@ -0,0 +1,7 @@
+{
+  "$schema": "../../node_modules/ng-packagr/ng-package.schema.json",
+  "dest": "../../dist/core",
+  "lib": {
+    "entryFile": "src/public-api.ts"
+  }
+}

apps/core/package.json

@@ -1,5 +1,5 @@
 {
-  "name": "@shared/history",
+  "name": "core",
   "version": "0.0.1",
   "peerDependencies": {
     "@angular/common": "^15.0.0",

apps/core/signalr/README.md

@@ -1,25 +0,0 @@
-# Signalr
-
-This library was generated with [Angular CLI](https://github.com/angular/angular-cli) version 10.2.4.
-
-## Code scaffolding
-
-Run `ng generate component component-name --project signalr` to generate a new component. You can also use `ng generate directive|pipe|service|class|guard|interface|enum|module --project signalr`.
-
-> Note: Don't forget to add `--project signalr` or else it will be added to the default project in your `angular.json` file.
-
-## Build
-
-Run `ng build signalr` to build the project. The build artifacts will be stored in the `dist/` directory.
-
-## Publishing
-
-After building your library with `ng build signalr`, go to the dist folder `cd dist/signalr` and run `npm publish`.
-
-## Running unit tests
-
-Run `ng test signalr` to execute the unit tests via [Karma](https://karma-runner.github.io).
-
-## Further help
-
-To get more help on the Angular CLI use `ng help` or go check out the [Angular CLI Overview and Command Reference](https://angular.io/cli) page.

apps/core/signalr/karma.conf.js

@@ -1,32 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage-istanbul-reporter'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    coverageIstanbulReporter: {
-      dir: require('path').join(__dirname, '../../../coverage/core/signalr'),
-      reports: ['html', 'lcovonly', 'text-summary'],
-      fixWebpackSourcePaths: true,
-    },
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/core/signalr/package.json

@@ -1,11 +0,0 @@
-{
-  "name": "@core/signalr",
-  "version": "0.0.1",
-  "peerDependencies": {
-    "@angular/common": "^10.2.4",
-    "@angular/core": "^10.2.4"
-  },
-  "dependencies": {
-    "tslib": "^2.0.0"
-  }
-}

apps/core/signalr/src/test.ts

@@ -1,11 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), {
-  teardown: { destroyAfterEach: false },
-});

apps/core/signalr/tsconfig.lib.json

@@ -1,24 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/lib",
-    "declaration": true,
-    "declarationMap": true,
-    "inlineSources": true,
-    "types": [],
-    "lib": [
-      "dom",
-      "es2018"
-    ]
-  },
-  "angularCompilerOptions": {
-    "skipTemplateCodegen": true,
-    "strictMetadataEmit": true,
-    "enableResourceInlining": true
-  },
-  "exclude": [
-    "src/test.ts",
-    "**/*.spec.ts"
-  ]
-}

apps/core/signalr/tsconfig.lib.prod.json

@@ -1,10 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "./tsconfig.lib.json",
-  "compilerOptions": {
-    "declarationMap": false
-  },
-  "angularCompilerOptions": {
-    "compilationMode": "partial"
-  }
-}

apps/core/signalr/tsconfig.spec.json

@@ -1,17 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/spec",
-    "types": [
-      "jasmine"
-    ]
-  },
-  "files": [
-    "src/test.ts"
-  ],
-  "include": [
-    "**/*.spec.ts",
-    "**/*.d.ts"
-  ]
-}

apps/core/signalr/tslint.json

@@ -1,17 +0,0 @@
-{
-  "extends": "../../../tslint.json",
-  "rules": {
-    "directive-selector": [
-      true,
-      "attribute",
-      "lib",
-      "camelCase"
-    ],
-    "component-selector": [
-      true,
-      "element",
-      "lib",
-      "kebab-case"
-    ]
-  }
-}

apps/core/src/lib/core.component.spec.ts

@@ -1,19 +1,17 @@
 import { ComponentFixture, TestBed } from '@angular/core/testing';
 
-import { ToastComponent } from './toast.component';
+import { CoreComponent } from './core.component';
 
-describe('ToastComponent', () => {
-  let component: ToastComponent;
-  let fixture: ComponentFixture<ToastComponent>;
+describe('CoreComponent', () => {
+  let component: CoreComponent;
+  let fixture: ComponentFixture<CoreComponent>;
 
   beforeEach(async () => {
     await TestBed.configureTestingModule({
-      declarations: [ToastComponent],
+      declarations: [CoreComponent],
     }).compileComponents();
-  });
 
-  beforeEach(() => {
-    fixture = TestBed.createComponent(ToastComponent);
+    fixture = TestBed.createComponent(CoreComponent);
     component = fixture.componentInstance;
     fixture.detectChanges();
   });

apps/core/src/lib/core.component.ts

@@ -0,0 +1,12 @@
+import { Component } from '@angular/core';
+
+@Component({
+  selector: 'lib-core',
+  template: `
+    <p>
+      core works!
+    </p>
+  `,
+  styles: [],
+})
+export class CoreComponent {}

apps/core/src/lib/core.module.ts

@@ -0,0 +1,9 @@
+import { NgModule } from '@angular/core';
+import { CoreComponent } from './core.component';
+
+@NgModule({
+  declarations: [CoreComponent],
+  imports: [],
+  exports: [CoreComponent],
+})
+export class CoreModule {}

apps/core/src/lib/core.service.spec.ts

@@ -0,0 +1,16 @@
+import { TestBed } from '@angular/core/testing';
+
+import { CoreService } from './core.service';
+
+describe('CoreService', () => {
+  let service: CoreService;
+
+  beforeEach(() => {
+    TestBed.configureTestingModule({});
+    service = TestBed.inject(CoreService);
+  });
+
+  it('should be created', () => {
+    expect(service).toBeTruthy();
+  });
+});

apps/core/src/lib/core.service.ts

@@ -0,0 +1,8 @@
+import { Injectable } from '@angular/core';
+
+@Injectable({
+  providedIn: 'root',
+})
+export class CoreService {
+  constructor() {}
+}

apps/core/src/public-api.ts

@@ -0,0 +1,7 @@
+/*
+ * Public API Surface of core
+ */
+
+export * from './lib/core.service';
+export * from './lib/core.component';
+export * from './lib/core.module';

apps/core/toast/karma.conf.js

@@ -1,41 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      jasmine: {
-        // you can add configuration options for Jasmine here
-        // the possible options are listed at https://jasmine.github.io/api/edge/Configuration.html
-        // for example, you can disable the random execution with `random: false`
-        // or set a specific seed with `seed: 4321`
-      },
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    jasmineHtmlReporter: {
-      suppressAll: true, // removes the duplicated traces
-    },
-    coverageReporter: {
-      dir: require('path').join(__dirname, '../../../coverage/core/toast'),
-      subdir: '.',
-      reporters: [{ type: 'html' }, { type: 'text-summary' }],
-    },
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/core/toast/src/test.ts

@@ -1,9 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), { teardown: { destroyAfterEach: true } });

apps/core/toast/tsconfig.lib.prod.json

@@ -1,10 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "./tsconfig.lib.json",
-  "compilerOptions": {
-    "declarationMap": false
-  },
-  "angularCompilerOptions": {
-    "compilationMode": "partial"
-  }
-}

apps/core/toast/tsconfig.spec.json

@@ -1,17 +0,0 @@
-/* To learn more about this file see: https://angular.io/config/tsconfig. */
-{
-  "extends": "../../../tsconfig.json",
-  "compilerOptions": {
-    "outDir": "../../../out-tsc/spec",
-    "types": [
-      "jasmine"
-    ]
-  },
-  "files": [
-    "src/test.ts"
-  ],
-  "include": [
-    "**/*.spec.ts",
-    "**/*.d.ts"
-  ]
-}

apps/core/tsconfig.lib.json

@@ -1,19 +1,14 @@
 /* To learn more about this file see: https://angular.io/config/tsconfig. */
 {
-  "extends": "../../../tsconfig.json",
+  "extends": "../../tsconfig.json",
   "compilerOptions": {
-    "outDir": "../../../out-tsc/lib",
+    "outDir": "../../out-tsc/lib",
     "declaration": true,
     "declarationMap": true,
     "inlineSources": true,
-    "types": [],
-    "lib": [
-      "dom",
-      "es2018"
-    ]
+    "types": []
   },
   "exclude": [
-    "src/test.ts",
     "**/*.spec.ts"
   ]
 }

apps/core/tsconfig.spec.json

@@ -1,15 +1,12 @@
 /* To learn more about this file see: https://angular.io/config/tsconfig. */
 {
-  "extends": "../../../tsconfig.json",
+  "extends": "../../tsconfig.json",
   "compilerOptions": {
-    "outDir": "../../../out-tsc/spec",
+    "outDir": "../../out-tsc/spec",
     "types": [
       "jasmine"
     ]
   },
-  "files": [
-    "src/test.ts"
-  ],
   "include": [
     "**/*.spec.ts",
     "**/*.d.ts"

apps/domain/availability/karma.conf.js

@@ -1,32 +0,0 @@
-// Karma configuration file, see link for more information
-// https://karma-runner.github.io/1.0/config/configuration-file.html
-
-module.exports = function (config) {
-  config.set({
-    basePath: '',
-    frameworks: ['jasmine', '@angular-devkit/build-angular'],
-    plugins: [
-      require('karma-jasmine'),
-      require('karma-chrome-launcher'),
-      require('karma-jasmine-html-reporter'),
-      require('karma-coverage-istanbul-reporter'),
-      require('@angular-devkit/build-angular/plugins/karma'),
-    ],
-    client: {
-      clearContext: false, // leave Jasmine Spec Runner output visible in browser
-    },
-    coverageIstanbulReporter: {
-      dir: require('path').join(__dirname, '../../../coverage/domain/availability'),
-      reports: ['html', 'lcovonly', 'text-summary'],
-      fixWebpackSourcePaths: true,
-    },
-    reporters: ['progress', 'kjhtml'],
-    port: 9876,
-    colors: true,
-    logLevel: config.LOG_INFO,
-    autoWatch: true,
-    browsers: ['Chrome'],
-    singleRun: false,
-    restartOnFileChange: true,
-  });
-};

apps/domain/availability/src/lib/availability.service.ts

@@ -16,7 +16,7 @@ import {
   AvailabilityType,
 } from '@swagger/availability';
 import { AvailabilityDTO as CatAvailabilityDTO } from '@swagger/cat';
-import { map, shareReplay, switchMap, withLatestFrom, mergeMap, timeout } from 'rxjs/operators';
+import { map, shareReplay, switchMap, withLatestFrom, mergeMap, timeout, first } from 'rxjs/operators';
 import { isArray, memorize } from '@utils/common';
 import { LogisticianDTO, LogisticianService } from '@swagger/oms';
 import { ResponseArgsOfIEnumerableOfStockInfoDTO, StockDTO, StockInfoDTO, StockService } from '@swagger/remi';
@@ -34,11 +34,16 @@ export class DomainAvailabilityService {
     private _branchService: StoreCheckoutBranchService
   ) {}
 
+  @memorize({ ttl: 10000 })
+  memorizedAvailabilityShippingAvailability(request: Array<AvailabilityRequestDTO>) {
+    return this._availabilityService.AvailabilityShippingAvailability(request).pipe(shareReplay(1));
+  }
+
   @memorize()
   getSuppliers(): Observable<SupplierDTO[]> {
     return this._supplierService.StoreCheckoutSupplierGetSuppliers({}).pipe(
       map((response) => response.result),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
@@ -46,7 +51,7 @@ export class DomainAvailabilityService {
   getTakeAwaySupplier(): Observable<SupplierDTO> {
     return this._supplierService.StoreCheckoutSupplierGetSuppliers({}).pipe(
       map(({ result }) => result?.find((supplier) => supplier?.supplierNumber === 'F')),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
@@ -54,20 +59,29 @@ export class DomainAvailabilityService {
   getBranches(): Observable<BranchDTO[]> {
     return this._branchService.StoreCheckoutBranchGetBranches({}).pipe(
       map((response) => response.result),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
   @memorize()
-  getCurrentStock(): Observable<StockDTO> {
+  getStockByBranch(branchId: number): Observable<StockDTO> {
+    return this._stockService.StockGetStocksByBranch({ branchId }).pipe(
+      map((response) => response.result),
+      map((result) => result?.find((_) => true)),
+      shareReplay(1)
+    );
+  }
+
+  @memorize()
+  getDefaultStock(): Observable<StockDTO> {
     return this._stockService.StockCurrentStock().pipe(
       map((response) => response.result),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
   @memorize()
-  getCurrentBranch(): Observable<BranchDTO> {
+  getDefaultBranch(): Observable<BranchDTO> {
     return this._stockService.StockCurrentBranch().pipe(
       map((response) => ({
         id: response.result.id,
@@ -86,7 +100,7 @@ export class DomainAvailabilityService {
         status: response.result.status,
         version: response.result.version,
       })),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
@@ -94,7 +108,7 @@ export class DomainAvailabilityService {
   getLogisticians(): Observable<LogisticianDTO> {
     return this._logisticanService.LogisticianGetLogisticians({}).pipe(
       map((response) => response.result?.find((l) => l.logisticianNumber === '2470')),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
@@ -127,24 +141,35 @@ export class DomainAvailabilityService {
         });
         return availabilities;
       }),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
-  getTakeAwayAvailability({ item, quantity }: { item: ItemData; quantity: number }): Observable<AvailabilityDTO> {
-    return this.getCurrentStock().pipe(
+  @memorize({ ttl: 10000 })
+  getTakeAwayAvailability({
+    item,
+    quantity,
+    branch,
+  }: {
+    item: ItemData;
+    quantity: number;
+    branch?: BranchDTO;
+  }): Observable<AvailabilityDTO> {
+    console.log('getTakeAwayAvailability', item, quantity, branch);
+    const request = !!branch ? this.getStockByBranch(branch.id) : this.getDefaultStock();
+    return request.pipe(
       switchMap((s) =>
         combineLatest([
           this._stockService.StockInStock({ articleIds: [item.itemId], stockId: s.id }),
           this.getTakeAwaySupplier(),
-          this.getCurrentBranch(),
+          this.getDefaultBranch(),
         ])
       ),
-      map(([response, supplier, branch]) => {
+      map(([response, supplier, defaultBranch]) => {
         const price = item?.price;
-        return this._mapToTakeAwayAvailability({ response, supplier, branch, quantity, price });
+        return this._mapToTakeAwayAvailability({ response, supplier, branchId: branch?.id ?? defaultBranch?.id, quantity, price });
       }),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
@@ -165,9 +190,9 @@ export class DomainAvailabilityService {
       this.getTakeAwaySupplier(),
     ]).pipe(
       map(([response, supplier]) => {
-        return this._mapToTakeAwayAvailability({ response, supplier, branch, quantity, price });
+        return this._mapToTakeAwayAvailability({ response, supplier, branchId: branch.id, quantity, price });
       }),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
@@ -175,28 +200,31 @@ export class DomainAvailabilityService {
     eans,
     price,
     quantity,
+    branchId,
   }: {
     eans: string[];
     price: PriceDTO;
     quantity: number;
+    branchId?: number;
   }): Observable<AvailabilityDTO> {
-    return this.getCurrentStock().pipe(
+    const request = !!branchId ? this.getStockByBranch(branchId) : this.getDefaultStock();
+    return request.pipe(
       switchMap((s) => this._stockService.StockInStockByEAN({ eans, stockId: s.id })),
-      withLatestFrom(this.getTakeAwaySupplier(), this.getCurrentBranch()),
-      map(([response, supplier, branch]) => {
-        return this._mapToTakeAwayAvailability({ response, supplier, branch, quantity, price });
+      withLatestFrom(this.getTakeAwaySupplier(), this.getDefaultBranch()),
+      map(([response, supplier, defaultBranch]) => {
+        return this._mapToTakeAwayAvailability({ response, supplier, branchId: branchId ?? defaultBranch.id, quantity, price });
       }),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
   getTakeAwayAvailabilitiesByEans({ eans }: { eans: string[] }): Observable<StockInfoDTO[]> {
     const eansFiltered = Array.from(new Set(eans));
-    return this.getCurrentStock().pipe(
+    return this.getDefaultStock().pipe(
       switchMap((s) => this._stockService.StockInStockByEAN({ eans: eansFiltered, stockId: s.id })),
-      withLatestFrom(this.getTakeAwaySupplier(), this.getCurrentBranch()),
+      withLatestFrom(this.getTakeAwaySupplier(), this.getDefaultBranch()),
       map((response) => response[0].result),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
@@ -222,81 +250,85 @@ export class DomainAvailabilityService {
       ])
       .pipe(
         map((r) => this._mapToPickUpAvailability(r.result)?.find((_) => true)),
-        shareReplay()
+        shareReplay(1)
       );
   }
 
   @memorize({ ttl: 10000 })
   getDeliveryAvailability({ item, quantity }: { item: ItemData; quantity: number }): Observable<AvailabilityDTO> {
-    return this._availabilityService
-      .AvailabilityShippingAvailability([
-        {
-          ean: item?.ean,
-          itemId: item?.itemId ? String(item?.itemId) : null,
-          price: item?.price,
-          qty: quantity,
-        },
-      ])
-      .pipe(
-        timeout(5000),
-        map((r) => this._mapToShippingAvailability(r.result)?.find((_) => true)),
-        shareReplay()
-      );
+    return this.memorizedAvailabilityShippingAvailability([
+      {
+        ean: item?.ean,
+        itemId: item?.itemId ? String(item?.itemId) : null,
+        price: item?.price,
+        qty: quantity,
+      },
+    ]).pipe(
+      timeout(5000),
+      map((r) => this._mapToShippingAvailability(r.result)?.find((_) => true)),
+      shareReplay(1)
+    );
   }
 
   @memorize({ ttl: 10000 })
   getDigDeliveryAvailability({ item, quantity }: { item: ItemData; quantity: number }): Observable<AvailabilityDTO> {
-    return this._availabilityService
-      .AvailabilityShippingAvailability([
-        {
-          qty: quantity,
-          ean: item?.ean,
-          itemId: item?.itemId ? String(item?.itemId) : null,
-          price: item?.price,
-        },
-      ])
-      .pipe(
-        timeout(5000),
-        map((r) => {
-          const availabilities = r.result;
-          const preferred = availabilities?.find((f) => f.preferred === 1);
+    return this.memorizedAvailabilityShippingAvailability([
+      {
+        qty: quantity,
+        ean: item?.ean,
+        itemId: item?.itemId ? String(item?.itemId) : null,
+        price: item?.price,
+      },
+    ]).pipe(
+      timeout(5000),
+      map((r) => {
+        const availabilities = r.result;
+        const preferred = availabilities?.find((f) => f.preferred === 1);
 
-          const availability: AvailabilityDTO = {
-            availabilityType: preferred?.status,
-            ssc: preferred?.ssc,
-            sscText: preferred?.sscText,
-            supplier: { id: preferred?.supplierId },
-            isPrebooked: preferred?.isPrebooked,
-            estimatedShippingDate: preferred?.requestStatusCode === '32' ? preferred?.altAt : preferred?.at,
-            estimatedDelivery: preferred?.estimatedDelivery,
-            price: preferred?.price,
-            logistician: { id: preferred?.logisticianId },
-            supplierProductNumber: preferred?.supplierProductNumber,
-            supplierInfo: preferred?.requestStatusCode,
-            lastRequest: preferred?.requested,
-          };
-          return availability;
-        }),
-        shareReplay()
-      );
+        const availability: AvailabilityDTO = {
+          availabilityType: preferred?.status,
+          ssc: preferred?.ssc,
+          sscText: preferred?.sscText,
+          supplier: { id: preferred?.supplierId },
+          isPrebooked: preferred?.isPrebooked,
+          estimatedShippingDate: preferred?.requestStatusCode === '32' ? preferred?.altAt : preferred?.at,
+          estimatedDelivery: preferred?.estimatedDelivery,
+          price: preferred?.price,
+          logistician: { id: preferred?.logisticianId },
+          supplierProductNumber: preferred?.supplierProductNumber,
+          supplierInfo: preferred?.requestStatusCode,
+          lastRequest: preferred?.requested,
+        };
+        return availability;
+      }),
+      shareReplay(1)
+    );
   }
 
   @memorize({ ttl: 10000 })
-  getB2bDeliveryAvailability({ item, quantity }: { item: ItemData; quantity: number }): Observable<AvailabilityDTO> {
+  getB2bDeliveryAvailability({
+    item,
+    quantity,
+    branch,
+  }: {
+    item: ItemData;
+    quantity: number;
+    branch?: BranchDTO;
+  }): Observable<AvailabilityDTO> {
     const logistician$ = this.getLogisticians();
 
-    const currentBranch$ = this.getCurrentBranch();
+    const currentBranch$ = this.getDefaultBranch();
 
     return currentBranch$.pipe(
       timeout(5000),
-      mergeMap((branch) =>
-        this.getPickUpAvailability({ item, quantity, branch }).pipe(
+      mergeMap((defaultBranch) =>
+        this.getPickUpAvailability({ item, quantity, branch: branch ?? defaultBranch }).pipe(
           mergeMap((availability) =>
             logistician$.pipe(
               map((logistician) => ({ ...(availability?.length > 0 ? availability[0] : []), logistician: { id: logistician.id } }))
             )
           ),
-          shareReplay()
+          shareReplay(1)
         )
       )
     );
@@ -304,37 +336,35 @@ export class DomainAvailabilityService {
 
   @memorize({ ttl: 10000 })
   getDownloadAvailability({ item }: { item: ItemData }): Observable<AvailabilityDTO> {
-    return this._availabilityService
-      .AvailabilityShippingAvailability([
-        {
-          ean: item?.ean,
-          itemId: item?.itemId ? String(item?.itemId) : null,
-          price: item?.price,
-          qty: 1,
-        },
-      ])
-      .pipe(
-        map((r) => {
-          const availabilities = r.result;
-          const preferred = availabilities?.find((f) => f.preferred === 1);
+    return this.memorizedAvailabilityShippingAvailability([
+      {
+        ean: item?.ean,
+        itemId: item?.itemId ? String(item?.itemId) : null,
+        price: item?.price,
+        qty: 1,
+      },
+    ]).pipe(
+      map((r) => {
+        const availabilities = r.result;
+        const preferred = availabilities?.find((f) => f.preferred === 1);
 
-          const availability: AvailabilityDTO = {
-            availabilityType: preferred?.status,
-            ssc: preferred?.ssc,
-            sscText: preferred?.sscText,
-            supplier: { id: preferred?.supplierId },
-            isPrebooked: preferred?.isPrebooked,
-            estimatedShippingDate: preferred?.requestStatusCode === '32' ? preferred?.altAt : preferred?.at,
-            price: preferred?.price,
-            supplierProductNumber: preferred?.supplierProductNumber,
-            logistician: { id: preferred?.logisticianId },
-            supplierInfo: preferred?.requestStatusCode,
-            lastRequest: preferred?.requested,
-          };
-          return availability;
-        }),
-        shareReplay()
-      );
+        const availability: AvailabilityDTO = {
+          availabilityType: preferred?.status,
+          ssc: preferred?.ssc,
+          sscText: preferred?.sscText,
+          supplier: { id: preferred?.supplierId },
+          isPrebooked: preferred?.isPrebooked,
+          estimatedShippingDate: preferred?.requestStatusCode === '32' ? preferred?.altAt : preferred?.at,
+          price: preferred?.price,
+          supplierProductNumber: preferred?.supplierProductNumber,
+          logistician: { id: preferred?.logisticianId },
+          supplierInfo: preferred?.requestStatusCode,
+          lastRequest: preferred?.requested,
+        };
+        return availability;
+      }),
+      shareReplay(1)
+    );
   }
 
   @memorize({ ttl: 10000 })
@@ -358,7 +388,7 @@ export class DomainAvailabilityService {
           })
         );
       }),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
@@ -372,7 +402,7 @@ export class DomainAvailabilityService {
 
   @memorize({ ttl: 10000 })
   getDeliveryAvailabilities(payload: AvailabilityRequestDTO[]) {
-    return this._availabilityService.AvailabilityShippingAvailability(payload).pipe(
+    return this.memorizedAvailabilityShippingAvailability(payload).pipe(
       timeout(20000),
       map((response) => this._mapToShippingAvailability(response.result))
     );
@@ -380,7 +410,7 @@ export class DomainAvailabilityService {
 
   @memorize({ ttl: 10000 })
   getDigDeliveryAvailabilities(payload: AvailabilityRequestDTO[]) {
-    return this._availabilityService.AvailabilityShippingAvailability(payload).pipe(
+    return this.memorizedAvailabilityShippingAvailability(payload).pipe(
       timeout(20000),
       map((response) => this._mapToShippingAvailability(response.result))
     );
@@ -395,7 +425,7 @@ export class DomainAvailabilityService {
       switchMap((availability) =>
         logistician$.pipe(map((logistician) => ({ availability: [...availability], logistician: { id: logistician.id } })))
       ),
-      shareReplay()
+      shareReplay(1)
     );
   }
 
@@ -418,6 +448,9 @@ export class DomainAvailabilityService {
   }
 
   isAvailable({ availability }: { availability: AvailabilityDTO }) {
+    if (availability?.supplier?.id === 16 && availability?.inStock == 0) {
+      return false;
+    }
     return [2, 32, 256, 1024, 2048, 4096].some((code) => availability?.availabilityType === code);
   }
 
@@ -450,17 +483,17 @@ export class DomainAvailabilityService {
   private _mapToTakeAwayAvailability({
     response,
     supplier,
-    branch,
+    branchId,
     quantity,
     price,
   }: {
     response: ResponseArgsOfIEnumerableOfStockInfoDTO;
     supplier: SupplierDTO;
-    branch: BranchDTO;
+    branchId: number;
     quantity: number;
     price: PriceDTO;
   }): AvailabilityDTO {
-    const stockInfo = response.result?.find((si) => si.branchId === branch.id);
+    const stockInfo = response.result?.find((si) => si.branchId === branchId);
     const inStock = stockInfo?.inStock ?? 0;
     const availability: AvailabilityDTO = {
       availabilityType: quantity <= inStock ? 1024 : 1, // 1024 (=Available)
@@ -509,6 +542,7 @@ export class DomainAvailabilityService {
       return preferred.map((p) => {
         return [
           {
+            orderDeadline: p?.orderDeadline,
             availabilityType: p?.status,
             ssc: p?.ssc,
             sscText: p?.sscText,
@@ -530,7 +564,6 @@ export class DomainAvailabilityService {
 
   private _mapToShippingAvailability(availabilities: SwaggerAvailabilityDTO[]) {
     const preferred = availabilities.filter((f) => f.preferred === 1);
-
     return preferred.map((p) => {
       return {
         availabilityType: p?.status,
@@ -544,7 +577,50 @@ export class DomainAvailabilityService {
         supplierInfo: p?.requestStatusCode,
         lastRequest: p?.requested,
         itemId: p.itemId,
+        priceMaintained: p.priceMaintained,
       };
     });
   }
+
+  getInStockByEan(params: { eans: string[]; branchId?: number }): Observable<Record<string, StockInfoDTO>> {
+    let branchId$ = of(params.branchId);
+
+    if (!params.branchId) {
+      branchId$ = this.getDefaultBranch().pipe(
+        first(),
+        map((b) => b.id)
+      );
+    }
+
+    const stock$ = branchId$.pipe(
+      mergeMap((branchId) => this._stockService.StockGetStocksByBranch({ branchId }).pipe(map((response) => response.result?.[0])))
+    );
+
+    return stock$.pipe(
+      mergeMap((stock) =>
+        this._stockService.StockInStockByEAN({ eans: params.eans, stockId: stock.id }).pipe(
+          map((response) => {
+            const result = response.result ?? [];
+
+            for (const stockInfo of result) {
+              stockInfo.ean = stockInfo.ean;
+            }
+
+            return result.reduce<Record<string, StockInfoDTO>>((acc, stockInfo) => {
+              acc[stockInfo.ean] = stockInfo;
+              return acc;
+            }, {});
+          })
+        )
+      )
+    );
+  }
+
+  getInStock({ itemIds, branchId }: { itemIds: number[]; branchId: number }): Observable<StockInfoDTO[]> {
+    return this.getStockByBranch(branchId).pipe(
+      mergeMap((stock) =>
+        this._stockService.StockInStock({ articleIds: itemIds, stockId: stock.id }).pipe(map((response) => response.result))
+      )
+    );
+  }
 }

apps/domain/availability/src/lib/in-stock.service.ts

@@ -0,0 +1,121 @@
+import { Injectable } from '@angular/core';
+import { StockInfoDTO } from '@swagger/remi';
+import { groupBy, isEqual, uniqWith } from 'lodash';
+import { BehaviorSubject, combineLatest, Observable, Subject } from 'rxjs';
+import { buffer, debounceTime, distinctUntilChanged } from 'rxjs/operators';
+import { DomainAvailabilityService } from './availability.service';
+
+export type ItemBranch = { itemId: number; branchId: number };
+export type InStock = ItemBranch & { inStock: number; fetching: boolean };
+
+@Injectable({ providedIn: 'root' })
+export class DomainInStockService {
+  private _inStockQueue = new Subject<ItemBranch>();
+  private _inStockMap = new BehaviorSubject<Record<string, number>>({});
+  private _inStockFetchingMap = new BehaviorSubject<Record<string, boolean>>({});
+
+  constructor(private _availability: DomainAvailabilityService) {
+    const queueBufferTrigger = this._createQueueBufferTrigger();
+
+    this._inStockQueue.pipe(buffer(queueBufferTrigger)).subscribe(this._handleStockDataToFetch);
+  }
+
+  private _createQueueBufferTrigger() {
+    return this._inStockQueue.pipe(debounceTime(1000));
+  }
+
+  private _handleStockDataToFetch = (itemBranchData: ItemBranch[]) => {
+    const unique = uniqWith(itemBranchData, isEqual);
+    if (unique?.length > 0) {
+      this._fetchStockData(unique);
+    }
+  };
+
+  getKey({ itemId, branchId }: ItemBranch) {
+    return `${itemId}_${branchId}`;
+  }
+
+  getInStock$({ itemId, branchId }: ItemBranch): Observable<InStock> {
+    return new Observable<InStock>((obs) => {
+      if (!(itemId && branchId)) {
+        obs.error(new Error(`ItemId: ${itemId} or BranchId: ${branchId} missing`));
+        return;
+      }
+
+      const key = this.getKey({ itemId, branchId });
+      this._addToInStockQueue({ itemId, branchId });
+
+      let _previousValue: InStock;
+
+      const sub = combineLatest([this._inStockMap, this._inStockFetchingMap])
+        .pipe(distinctUntilChanged(isEqual))
+        .subscribe(([inStockMap, inStockFetchingMap]) => {
+          const inStock: InStock = {
+            itemId,
+            branchId,
+            inStock: inStockMap[key],
+            fetching: inStockFetchingMap[key] ?? false,
+          };
+
+          if (!isEqual(inStock, _previousValue)) {
+            obs.next(inStock);
+          }
+
+          _previousValue = inStock;
+        });
+      return () => {
+        sub.unsubscribe();
+      };
+    });
+  }
+
+  private _addToInStockQueue({ itemId, branchId }: ItemBranch): void {
+    this._inStockQueue.next({ itemId, branchId });
+    this._setInStockFetching({ itemId, branchId }, true);
+  }
+
+  private _setInStockFetching({ itemId, branchId }: ItemBranch, value: boolean) {
+    const key = this.getKey({ itemId, branchId });
+    const current = this._inStockFetchingMap.getValue();
+    this._inStockFetchingMap.next({ ...current, [key]: value });
+  }
+
+  private _setInStock({ itemId, branchId }: ItemBranch, inStock: number) {
+    const key = this.getKey({ itemId, branchId });
+    const current = this._inStockMap.getValue();
+    this._inStockMap.next({ ...current, [key]: inStock });
+  }
+
+  private _fetchStockData(itemBranchData: ItemBranch[]) {
+    const grouped = groupBy(itemBranchData, 'branchId');
+    Object.keys(grouped).forEach((key) => {
+      const branchId = Number(key);
+      const itemIds = itemBranchData.filter((itemBranch) => itemBranch.branchId === branchId).map((item) => item.itemId);
+      this._availability
+        .getInStock({ itemIds, branchId })
+        .subscribe(this._fetchStockDataResponse({ itemIds, branchId }), this._fetchStockDataError({ itemIds, branchId }));
+    });
+  }
+
+  private _fetchStockDataResponse = ({ itemIds, branchId }: { itemIds: number[]; branchId: number }) => (stockInfos: StockInfoDTO[]) => {
+    itemIds.forEach((itemId) => {
+      const stockInfo = stockInfos.find((stockInfo) => stockInfo.itemId === itemId && stockInfo.branchId === branchId);
+      let inStock = 0;
+
+      if (stockInfo?.inStock) {
+        inStock = stockInfo.inStock;
+      }
+
+      this._setInStockFetching({ itemId, branchId }, false);
+      this._setInStock({ itemId, branchId }, inStock);
+    });
+  };
+
+  private _fetchStockDataError = ({ itemIds, branchId }: { itemIds: number[]; branchId: number }) => (error: Error) => {
+    itemIds.forEach((itemId) => {
+      this._setInStockFetching({ itemId, branchId }, false);
+      this._setInStock({ itemId, branchId }, 0);
+    });
+    console.error('DomainInStockService._fetchStockData()', error);
+  };
+}

apps/domain/availability/src/public-api.ts

@@ -3,5 +3,6 @@
  */
 
 export * from './lib/availability.service';
+export * from './lib/in-stock.service';
 export * from './lib/availability.module';
 export * from './lib/defs';

apps/domain/availability/src/test.ts

@@ -1,11 +0,0 @@
-// This file is required by karma.conf.js and loads recursively all the .spec and framework files
-
-import 'zone.js';
-import 'zone.js/testing';
-import { getTestBed } from '@angular/core/testing';
-import { BrowserDynamicTestingModule, platformBrowserDynamicTesting } from '@angular/platform-browser-dynamic/testing';
-
-// First, initialize the Angular testing environment.
-getTestBed().initTestEnvironment(BrowserDynamicTestingModule, platformBrowserDynamicTesting(), {
-  teardown: { destroyAfterEach: false },
-});