Commit 86e428e0 authored by Merzough Münker's avatar Merzough Münker
Browse files

fix: add support for method injection

parent 2ccdd6cc

libs/data-source/http/src/lib/http.data-source.ts

+2 −2
Original line number Diff line number Diff line
@@ -113,12 +113,12 @@ export class HttpDataSource<Data = any, PathParams = any, Body = any> extends Ba 
      tap(event => this.handelHttpEvent(event)),

      filter((event: any) => event instanceof HttpResponse),

      tap((response: HttpResponse<Data>) => {

        this.interceptors.forEach(interceptor => interceptor

        this.interceptors?.forEach(interceptor => interceptor

          .next({ response, options })

        );

      }),

      catchError((response: HttpErrorResponse) => {

        this.interceptors.forEach(interceptor => interceptor

        this.interceptors?.forEach(interceptor => interceptor

          .next({ response, options })

        );

        return throwError(response);

libs/definition/CHANGELOG.md

+6 −6
Original line number Diff line number Diff line 
# Change Log



All notable changes to this project will be documented in this file.

See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.



## [11.0.6](https://gitlab.com/rxap/packages/compare/@rxap/definition@11.0.5...@rxap/definition@11.0.6) (2021-03-19)

All notable changes to this project will be documented in this file. See [Conventional Commits](https://conventionalcommits.org) for commit guidelines.



## [11.0.7](https://gitlab.com/rxap/packages/compare/@rxap/definition@11.0.6...@rxap/definition@11.0.7) (2021-03-29)



### Bug Fixes



* update peer dependencies ([954fde4](https://gitlab.com/rxap/packages/commit/954fde47836ff0c1f25a77c33ff871ddc7685b6c))



* add support for method injection ([2ccdd6c](https://gitlab.com/rxap/packages/commit/2ccdd6ccaf73d164385e443ecdcc753dc1b54ffa))



## [11.0.6](https://gitlab.com/rxap/packages/compare/@rxap/definition@11.0.5...@rxap/definition@11.0.6) (2021-03-19)



### Bug Fixes



* update peer dependencies ([954fde4](https://gitlab.com/rxap/packages/commit/954fde47836ff0c1f25a77c33ff871ddc7685b6c))



## [11.0.5](https://gitlab.com/rxap/packages/compare/@rxap/definition@11.0.4...@rxap/definition@11.0.5) (2021-03-19)

libs/definition/package.json

+1 −1
Original line number Diff line number Diff line 
{

  "name": "@rxap/definition",

  "version": "11.0.6",

  "version": "11.0.7",

  "private": false,

  "author": "Merzough Münker",

  "homepage": "https://gitlab.com/rxap/packages",

libs/definition/src/lib/definition.ts

+3 −3
Original line number Diff line number Diff line
@@ -23,17 +23,17 @@ export abstract class BaseDefinition<Metadata extends BaseDefinitionMetadata = B 
  /**

   * A map of active Definition instances

   */

  public static readonly instances: Map<string, BaseDefinition> | undefined = new Map<string, BaseDefinition>();

  public static readonly instances: Map<string, BaseDefinition> = new Map<string, BaseDefinition>();



  /**

   * Emits when a new Definition instance is initialised

   */

  public static readonly initialised$: Subject<BaseDefinition> | undefined = new Subject<BaseDefinition>();

  public static readonly initialised$: Subject<BaseDefinition> = new Subject<BaseDefinition>();



  /**

   * Emits when a new Definition instance is initialised

   */

  public static readonly destroyed$: Subject<BaseDefinition> | undefined = new Subject<BaseDefinition>();

  public static readonly destroyed$: Subject<BaseDefinition> = new Subject<BaseDefinition>();



  /**

   * @param definition

libs/recorder/src/lib/recorder.service.ts

+2 −2
Original line number Diff line number Diff line
@@ -62,7 +62,7 @@ export class RecorderService { 
        switchMap(info => BaseDefinition.initialised$.pipe(

          mergeMap(definition => {

            const interceptor$ = new Subject<any>();

            definition.interceptors.add(interceptor$);

            definition.interceptors?.add(interceptor$);



            const interception: Interception = {

              definitionId: definition.id,
@@ -76,7 +76,7 @@ export class RecorderService { 
            console.debug('interception:', interception);



            return interceptor$.pipe(

              takeUntil(definition.destroyed$),

              takeUntil(definition.destroyed$ ?? new Subject()),

              tap(data => this.child.sendMessageToParent(JSON.stringify({

                ...interception,

                data