@berish/orm - npm Package Compare versions

Comparing version 0.5.1 to 0.6.0

build/entity/entity.d.ts

@@ -13,2 +13,3 @@ import type { Manager } from '../manager';
     }): TEntity;
+    static isEquals(entity1: Entity, entity2: Entity): boolean;
     constructor();
@@ -15,0 +16,0 @@ get attributes(): methods.IAttributes;

build/entity/entity.js

@@ -23,2 +23,5 @@ "use strict";
     }
+    static isEquals(entity1, entity2) {
+        return methods.isEquals(entity1, entity2);
+    }
     get attributes() {
@@ -25,0 +28,0 @@ return methods.getAttributes(this);

build/entity/fileEntity.d.ts

@@ -9,2 +9,3 @@ /// <reference types="node" />
     }): FileEntity;
+    static isEquals(entity1: FileEntity, entity2: FileEntity): boolean;
     constructor();
@@ -11,0 +12,0 @@ get attributes(): methods.IAttributes;

build/entity/fileEntity.js

@@ -23,2 +23,5 @@ "use strict";
     }
+    static isEquals(entity1, entity2) {
+        return methods.isEquals(entity1, entity2);
+    }
     get attributes() {
@@ -25,0 +28,0 @@ return methods.getAttributes(this);

build/entity/methods/index.d.ts

@@ -16,2 +16,3 @@ export * from './fetch';
 export * from './getUpdatedAt';
+export * from './isEquals';
 export * from './setFileName';
@@ -18,0 +19,0 @@ export * from './setIsFetched';

build/entity/methods/index.js

@@ -28,2 +28,3 @@ "use strict";
 __exportStar(require("./getUpdatedAt"), exports);
+__exportStar(require("./isEquals"), exports);
 __exportStar(require("./setFileName"), exports);
@@ -30,0 +31,0 @@ __exportStar(require("./setIsFetched"), exports);

build/manager/manager.d.ts

@@ -28,3 +28,3 @@ import EventEmitter from '@berish/emitter';
         find: (data: QueryData<QueryDataSchema>) => Promise<IBaseDBItem[]>;
-        subscribe: (data: QueryData<QueryDataSchema>, callback: (oldValue: IBaseDBItem, newValue: IBaseDBItem) => any, onError?: (reason: any) => any) => () => any;
+        subscribe: (data: QueryData<QueryDataSchema>, callback: (oldValue: IBaseDBItem, newValue: IBaseDBItem, newValueIndex?: number) => any, onError?: (reason: any) => any) => () => any;
     };
@@ -31,0 +31,0 @@ /**

build/manager/manager.js

@@ -61,3 +61,13 @@ "use strict";
             const eventHash = this.emitter.cacheSubscribe(eventName, (callback) => {
-                const onDisconnect = this._dbAdapter.subscribe(data, (oldValue, newValue) => callback({ oldValue, newValue }), (reason) => onError && onError(reason));
+                const onDisconnect = this._dbAdapter.subscribe(data, (oldValue, newValue) => __awaiter(this, void 0, void 0, function* () {
+                    if (!oldValue && newValue) {
+                        const items = yield this.db.find(query_1.Query.fromJSON(data).pluck('id').json);
+                        const valueIndex = (items || []).map((m) => m && m.id).indexOf(newValue.id);
+                        const newValueIndex = valueIndex === -1 ? undefined : valueIndex;
+                        callback({ oldValue, newValue, newValueIndex });
+                    }
+                    else {
+                        callback({ oldValue, newValue });
+                    }
+                }), (reason) => onError && onError(reason));
                 return () => __awaiter(this, void 0, void 0, function* () {
@@ -67,3 +77,3 @@ const disconnect = yield onDisconnect;
                 });
-            }, ({ oldValue, newValue }) => callback(oldValue, newValue));
+            }, ({ oldValue, newValue, newValueIndex }) => callback(oldValue, newValue, newValueIndex));
             return () => this.emitter.off(eventHash);
@@ -70,0 +80,0 @@ };

build/serber/abstract.d.ts

@@ -5,3 +5,4 @@ export declare enum RawTypeEnum {
     fullEntity = "fe",
-    fullFileEntity = "ffe"
+    fullFileEntity = "ffe",
+    fullQuery = "fq"
 }
@@ -8,0 +9,0 @@ /**

build/serber/abstract.js

@@ -10,2 +10,3 @@ "use strict";
     RawTypeEnum["fullFileEntity"] = "ffe";
+    RawTypeEnum["fullQuery"] = "fq";
 })(RawTypeEnum = exports.RawTypeEnum || (exports.RawTypeEnum = {}));
@@ -12,0 +13,0 @@ /**

build/serber/instances.js

@@ -12,2 +12,3 @@ "use strict";
 const fileEntityToFileEntityPointerPlugin_1 = require("./plugins/fileEntityToFileEntityPointerPlugin");
+const queryToFullQueryPlugin_1 = require("./plugins/queryToFullQueryPlugin");
 const undefinedDBPlugin_1 = require("./plugins/undefinedDBPlugin");
@@ -73,2 +74,3 @@ class SerberInstances {
             .addPlugin(fileEntitiyToFullFileEntityPlugin_1.fileEntityToFullFileEntityPlugin)
+            .addPlugin(queryToFullQueryPlugin_1.queryToFullQueryPlugin)
             .addPlugin(serber_1.plugins.loopObjectPlugin);
@@ -75,0 +77,0 @@ }

build/serber/plugins/index.d.ts

@@ -7,2 +7,3 @@ export * from './entityToBaseDBItemPlugin';
 export * from './fileEntityToFileEntityPointerPlugin';
+export * from './queryToFullQueryPlugin';
 export * from './undefinedDBPlugin';

build/serber/plugins/index.js

@@ -19,3 +19,4 @@ "use strict";
 __exportStar(require("./fileEntityToFileEntityPointerPlugin"), exports);
+__exportStar(require("./queryToFullQueryPlugin"), exports);
 __exportStar(require("./undefinedDBPlugin"), exports);
 //# sourceMappingURL=index.js.map

package.json

 {
   "name": "@berish/orm",
-  "version": "0.5.1",
+  "version": "0.6.0",
   "description": "ORM",
@@ -5,0 +5,0 @@ "main": "build/index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

227642

increased by2.46%

Number of package files

236

increased by2.61%

Lines of code

3156

increased by2.27%

No dependency changes