Using deepEqual in observables.

contribute/VERSION

@@ -1 +1 @@
-1.0.18
+1.0.21

lib/dispatcher/InstanceManager/InstanceManager.ts

@@ -31,12 +31,12 @@ import {
   INopeRpcManager,
   INopeStatusInfo,
   TValidAsssignmentChecker,
-  ValidSelectorFunction
+  ValidSelectorFunction,
 } from "../../types/nope";
 import {
   INopeInstanceManager,
   TConstructorCallback,
-  TGenerateWrapperCallback
+  TGenerateWrapperCallback,
 } from "../../types/nope/nopeInstanceManager.interface";
 import { NopeConnectivityManager } from "../ConnectivityManager";
 import { NopeRpcManager } from "../RpcManager/NopeRpcManager";

lib/helpers/getSubject.ts

@@ -1,9 +1,6 @@
 /**
  * @author Martin Karkowski
  * @email m.karkowski@zema.de
- * @create date 2021-11-13 14:13:06
- * @modify date 2021-11-13 14:13:06
- * @desc [description]
  */
 
 import { BehaviorSubject, ReplaySubject, Subject } from "rxjs";

lib/helpers/index.browser.ts

@@ -5,6 +5,7 @@
 
 import * as arrays from "./arrayMethods";
 import * as async from "./async";
+import * as subject from "./getSubject";
 import * as ids from "./idMethods";
 import * as json from "./jsonMethods";
 import * as schema from "./jsonSchemaMethods";
@@ -18,6 +19,7 @@ import * as strings from "./stringMethods";
 
 export * from "./arrayMethods";
 export * from "./async";
+export * from "./getSubject";
 export * from "./idMethods";
 export * from "./jsonMethods";
 export * from "./jsonSchemaMethods";
@@ -41,4 +43,5 @@ export {
   strings,
   pathes,
   runtime,
+  subject,
 };

lib/helpers/objectMethods.ts

@@ -7,6 +7,7 @@
  */
 
 export const SPLITCHAR = "/";
+import { deepEqual as _deepEqual } from "assert";
 
 const _sentinel = new Object();
 
@@ -510,7 +511,20 @@ export function deepClone<T>(obj: T): T {
   }
 }
 
-// export const deepEqual: (a: any, b: any) => boolean = require('deep-equal');
+/**
+ * Compares deep a and b (using assert)
+ * @param a Object A
+ * @param b Object B
+ * @returns The Result
+ */
+export function deepEqual<T>(a: T, b: T): boolean {
+  try {
+    _deepEqual(a, b);
+    return true;
+  } catch (e) {
+    return false;
+  }
+}
 
 /**
  * Function to adapt the Object and only return a specific amount of elements.

lib/module/BaseModule.ts

@@ -10,7 +10,7 @@ import {
   getPropertyPath,
   isEmitterPathCorrect,
   isMethodPathCorrect,
-  isPropertyPathCorrect
+  isPropertyPathCorrect,
 } from "../helpers/dispatcherPathes";
 import { deepClone } from "../helpers/objectMethods";
 import { getNopeLogger } from "../logger/getLogger";
@@ -21,7 +21,7 @@ import {
   IFunctionOptions,
   INopeModule,
   INopeModuleDescription,
-  IVersion
+  IVersion,
 } from "../types/nope/nopeModule.interface";
 import { INopeObservable } from "../types/nope/nopeObservable.interface";
 

lib/module/GenericWrapper.injectable.ts

@@ -7,7 +7,7 @@ import { inject, injectable } from "inversify";
 import { INopeCore } from "../index.browser";
 import {
   DISPATCHER_INSTANCE,
-  OBSERVABLE_FACTORY
+  OBSERVABLE_FACTORY,
 } from "../symbols/identifiers";
 import { INopeObservable } from "../types/nope/nopeObservable.interface";
 import { NopeGenericWrapper } from "./GenericWrapper";

lib/module/GenericWrapper.ts

@@ -11,7 +11,7 @@ import { INopeDispatcher } from "../types/nope/nopeDispatcher.interface";
 import {
   IEventOptions,
   IFunctionOptions,
-  INopeModuleDescription
+  INopeModuleDescription,
 } from "../types/nope/nopeModule.interface";
 import { INopeObservable } from "../types/nope/nopeObservable.interface";
 import { INopePromise } from "../types/nope/nopePromise.interface";

lib/module/index.ts

@@ -8,4 +8,3 @@ export { NopeBaseModule } from "./BaseModule";
 export { InjectableNopeBaseModule } from "./BaseModule.injectable";
 export { NopeGenericWrapper } from "./GenericWrapper";
 export { InjectableNopeGenericWrapper } from "./GenericWrapper.injectable";
-

lib/observables/nopeObservable.ts

@@ -7,6 +7,7 @@ import { BehaviorSubject } from "rxjs";
 import { NopeEventEmitter } from "../eventEmitter/nopeEventEmitter";
 import { TSubjectOptions } from "../helpers/getSubject";
 import { generateId } from "../helpers/idMethods";
+import { deepEqual } from "../helpers/objectMethods";
 import { getNopeLogger } from "../logger/getLogger";
 import {
   IEventAdditionalData,
@@ -15,7 +16,7 @@ import {
   INopeObserver,
   INopePartialObserver,
   INopeSubscriptionOptions,
-  IObservableType
+  IObservableType,
 } from "../types/nope/index";
 
 const logger = getNopeLogger("obervable");
@@ -79,10 +80,10 @@ export class NopeObservable<
 
     const valueToPublish = this.getContent();
 
-    /** Publish the Data */
+    // Publish the Data, but only if they are different (deeply)
     if (
       !this.disablePublishing &&
-      (options.forced || this._emitter.value?.value !== valueToPublish)
+      (options.forced || !deepEqual(this._emitter.value?.value, valueToPublish))
     ) {
       return this._publish(valueToPublish, options);
     }

lib/types/nope/nopeInstanceManager.interface.ts

@@ -9,13 +9,13 @@
 import { INopeCore, INopeModule } from ".";
 import {
   IAvailableInstancesMsg,
-  IInstanceCreationMsg
+  IInstanceCreationMsg,
 } from "./nopeCommunication.interface";
 import { INopeStatusInfo } from "./nopeConnectivityManager.interface";
 import { IMapBasedMergeData } from "./nopeHelpers.interface";
 import {
   IGenericNopeModule,
-  INopeModuleDescription
+  INopeModuleDescription,
 } from "./nopeModule.interface";
 import { INopeObservable } from "./nopeObservable.interface";
 import { ValidSelectorFunction } from "./nopeRpcManager.interface";

package.json

@@ -1,6 +1,6 @@
 {
   "name": "nope",
-  "version": "1.0.18",
+  "version": "1.0.21",
   "description": "NoPE Runtime for Nodejs. For Browser-Support please use nope-browser",
   "files": [
     "dist-nodejs/**/*",