chore(release): 1.3.0

HISTORY.md

@@ -2,6 +2,36 @@
 
 All notable changes to this project will be documented in this file. See [standard-version](https://github.com/conventional-changelog/standard-version) for commit guidelines.
 
+## [1.3.0](https://git.archive.systems/Dezzpil/ivanovna.orm/compare/v1.2.0...v1.3.0) (2021-10-05)
+
+
+### Features
+
+* добавил управление трансформацией данных для репозитория ([017f735](https://git.archive.systems/Dezzpil/ivanovna.orm/commit/017f7356134c306c9ba46b19385c3e96444c613b))
+
+## [1.2.0](https://git.archive.systems/Dezzpil/ivanovna.orm/compare/v1.1.3...v1.2.0) (2021-10-04)
+
+
+### Features
+
+* добавил Entity Manager ([d0942e5](https://git.archive.systems/Dezzpil/ivanovna.orm/commit/d0942e59d97d861aa3368ee96a3a15f0418263e4))
+
+### [1.1.3](https://git.archive.systems/Dezzpil/ivanovna.orm/compare/v1.1.2...v1.1.3) (2021-10-04)
+
+
+### Bug Fixes
+
+* путь к файлу типов ([d923969](https://git.archive.systems/Dezzpil/ivanovna.orm/commit/d92396967a79b51fe63d6620eb8b2169260f4ec7))
+
+### [1.1.2](https://git.archive.systems/Dezzpil/ivanovna.orm/compare/v1.1.1...v1.1.2) (2021-09-30)
+
+
+### Bug Fixes
+
+* заменил все unknow на any ([20a969c](https://git.archive.systems/Dezzpil/ivanovna.orm/commit/20a969c829d5d4d9ec5b4f001f6d13be3570a97d))
+
+### [1.1.1](https://git.archive.systems/Dezzpil/ivanovna.orm/compare/v1.1.0...v1.1.1) (2021-09-29)
+
 ## [1.1.0](https://git.archive.systems/Dezzpil/ivanovna.orm/compare/v1.0.2...v1.1.0) (2021-09-29)
 
 

orm.d.ts

@@ -26,6 +26,20 @@ export declare abstract class Entity<T extends Data> {
 /** @public */
 export declare type EntityConstructor<T extends Data> = new (data?: T) => Entity<T>;
 
+/** @public */
+export declare class EntityManager {
+    private readonly _storage;
+    private _saveMap;
+    private _removeMap;
+    constructor(storage: Storage_2);
+    persist(entity: Entity<any>): this;
+    persistMany(entities: Entity<any>[]): this;
+    remove(entity: Entity<any>): this;
+    forget(): this;
+    flush(): Promise<this>;
+    refresh(entity: Entity<any>): Promise<Entity<any>>;
+}
+
 /** @public */
 export declare class ErrEntityHasNoUniqKeyValue extends Error {
 }
@@ -70,10 +84,10 @@ export declare abstract class Repo<T extends Entity<any>> {
      *
      * @protected
      */
-    _findByParams(parameters: Record<string, unknown>, limit?: number, order?: Record<string, unknown>): Promise<T[]>;
-    findMany(parameters: Record<string, unknown>, order?: Record<string, unknown>): Promise<T[]>;
+    _findByParams(parameters: Record<string, any>, limit?: number, order?: Record<string, any>): Promise<T[]>;
+    findMany(parameters: Record<string, any>, order?: Record<string, any>): Promise<T[]>;
     shift(limit?: number, offset?: number): this;
-    count(query?: Record<string, unknown>): Promise<number>;
+    count(query?: Record<string, any>): Promise<number>;
     remove(entity: T, silent?: boolean): Promise<this>;
 }
 
@@ -81,10 +95,10 @@ export declare abstract class Repo<T extends Entity<any>> {
 declare abstract class Storage_2 {
     protected _dsn: string;
     constructor(dsn: string);
-    abstract find(name: string, query: Record<string, unknown>): Promise<StorageCursor>;
-    abstract save(name: string, uniqKey: string, data: Record<string, unknown>): Promise<string>;
+    abstract find(name: string, query: Record<string, any>): Promise<StorageCursor>;
+    abstract save(name: string, uniqKey: string, data: Record<string, any>): Promise<string>;
     abstract createSession(): StorageSession;
-    abstract count(name: string, query?: Record<string, unknown>): Promise<number>;
+    abstract count(name: string, query?: Record<string, any>): Promise<number>;
     abstract remove(collectionName: string, uniqKeyName: string, uniqKey: string): Promise<boolean>;
 }
 export { Storage_2 as Storage }
@@ -99,8 +113,8 @@ export declare interface StorageCursor {
 
 /** @public */
 export declare abstract class StorageSession {
-    abstract start(options?: Record<string, unknown>): Promise<void>;
-    abstract commit(fn: () => any, options?: Record<string, unknown>): Promise<void>;
+    abstract start(options?: Record<string, any>): Promise<void>;
+    abstract commit(fn: () => any, options?: Record<string, any>): Promise<void>;
 }
 
 /** @public */

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "ivna-orm",
-  "version": "1.1.0",
+  "version": "1.3.0",
   "lockfileVersion": 2,
   "requires": true,
   "packages": {
     "": {
       "name": "ivna-orm",
-      "version": "1.1.0",
+      "version": "1.3.0",
       "license": "ISC",
       "devDependencies": {
         "@jest/test-sequencer": "^27.2.3",

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ivna-orm",
-  "version": "1.1.0",
+  "version": "1.3.0",
   "description": "Mini ORM for convenience",
   "main": "dist/index.js",
   "files": [
@@ -11,7 +11,7 @@
     "src/app/**/*",
     "orm.d.ts"
   ],
-  "types": "dist/index.d.ts",
+  "types": "orm.d.ts",
   "scripts": {
     "test": "node --no-warnings node_modules/.bin/jest --runInBand --forceExit",
     "build": "rimraf dist && tsc -b -v",

src/app/entity/manager.ts

@@ -0,0 +1,64 @@
+import { Entity } from '../entity'
+import { Storage } from '../storage'
+
+/** @public */
+export class EntityManager {
+    private readonly _storage: Storage
+    private _saveMap: Map<string, Entity<any>>
+    private _removeMap: Map<string, Entity<any>>
+
+    constructor(storage: Storage) {
+        this._storage = storage
+        this._saveMap = new Map()
+        this._removeMap = new Map()
+    }
+
+    persist(entity: Entity<any>): this {
+        const key = [entity.constructor.name, entity.getUniqKey()].join('&')
+        this._saveMap.set(key, entity)
+        return this
+    }
+
+    persistMany(entities: Entity<any>[]): this {
+        for (let entity of entities) {
+            this.persist(entity)
+        }
+        return this
+    }
+
+    remove(entity: Entity<any>): this {
+        const key = [entity.constructor.name, entity.getUniqKey()].join('&')
+        this._removeMap.set(key, entity)
+        return this
+    }
+
+    forget(): this {
+        this._saveMap = new Map()
+        return this
+    }
+
+    async flush() {
+        if (!this._saveMap.size && !this._removeMap.size) return this
+
+        const session = this._storage.createSession()
+        await session.start()
+        await session.commit(async () => {
+            for (let en of this._saveMap.values()) {
+                await en._getRepo(this._storage).save(en)
+            }
+            this._saveMap = new Map()
+
+            for (let en of this._removeMap.values()) {
+                await en._getRepo(this._storage).remove(en)
+            }
+            this._removeMap = new Map()
+        })
+
+        return this
+    }
+
+    async refresh(entity: Entity<any>) {
+        const repo = entity._getRepo(this._storage)
+        return repo.findById(entity.getUniqKey())
+    }
+}

src/app/repo.ts

@@ -15,6 +15,8 @@ export abstract class Repo<T extends Entity<any>> {
     protected _limit = 0
     protected _offset = 0
 
+    private _transformer: (obj: any) => any
+
     /**
      * Возвращает объект соотв. сущности, например new App()
      */
@@ -25,21 +27,24 @@ export abstract class Repo<T extends Entity<any>> {
      */
     abstract Name(): string
 
-    _transformer: (object: any) => any
-
-    constructor(storage: Storage) {
+    constructor(storage: Storage, transformer?: (obj: any) => any) {
         this._storage = storage
         this._entity = this.Entity()
-        this.resetTransformer()
+        this.setTransformer(transformer)
     }
 
-    resetTransformer() {
-        this._transformer = function (object: any): any {
-            const entity = this.Entity()
-            entity.data.fromObject(object)
-            entity._id = object._id
-            return entity
+    setTransformer(transformer?: (obj: any) => any): this {
+        if (transformer) {
+            this._transformer = transformer
+        } else {
+            this._transformer = function (object: any): any {
+                const entity = this.Entity()
+                entity.data.fromObject(object)
+                entity._id = object._id
+                return entity
+            }
         }
+        return this
     }
 
     get storage(): Storage {
@@ -74,9 +79,9 @@ export abstract class Repo<T extends Entity<any>> {
      * @protected
      */
     async _findByParams(
-        parameters: Record<string, unknown>,
+        parameters: Record<string, any>,
         limit?: number,
-        order?: Record<string, unknown>
+        order?: Record<string, any>
     ): Promise<T[]> {
         const cursor = await this._storage.find(this.Name(), parameters)
         if (limit && limit > 0) await cursor.limit(limit)
@@ -90,7 +95,7 @@ export abstract class Repo<T extends Entity<any>> {
         return list
     }
 
-    async findMany(parameters: Record<string, unknown>, order?: Record<string, unknown>): Promise<T[]> {
+    async findMany(parameters: Record<string, any>, order?: Record<string, any>): Promise<T[]> {
         const cursor = await this._storage.find(this.Name(), parameters)
         if (this._offset > 0) await cursor.skip(this._offset)
         if (this._limit > 0) await cursor.limit(this._limit)
@@ -110,7 +115,7 @@ export abstract class Repo<T extends Entity<any>> {
         return this
     }
 
-    async count(query?: Record<string, unknown>): Promise<number> {
+    async count(query?: Record<string, any>): Promise<number> {
         return this._storage.count(this.Name(), query)
     }
 

src/app/storage.ts

@@ -20,19 +20,19 @@ export abstract class Storage {
         this._dsn = dsn
     }
 
-    abstract find(name: string, query: Record<string, unknown>): Promise<StorageCursor>
+    abstract find(name: string, query: Record<string, any>): Promise<StorageCursor>
 
-    abstract save(name: string, uniqKey: string, data: Record<string, unknown>): Promise<string>
+    abstract save(name: string, uniqKey: string, data: Record<string, any>): Promise<string>
 
     abstract createSession(): StorageSession
 
-    abstract count(name: string, query?: Record<string, unknown>): Promise<number>
+    abstract count(name: string, query?: Record<string, any>): Promise<number>
 
     abstract remove(collectionName: string, uniqKeyName: string, uniqKey: string): Promise<boolean>
 }
 
 /** @public */
 export abstract class StorageSession {
-    abstract start(options?: Record<string, unknown>): Promise<void>
-    abstract commit(fn: () => any, options?: Record<string, unknown>): Promise<void>
+    abstract start(options?: Record<string, any>): Promise<void>
+    abstract commit(fn: () => any, options?: Record<string, any>): Promise<void>
 }

src/app/storage/mongo.ts

@@ -21,19 +21,19 @@ export class MongoStorage extends Storage {
         await this._client.connect()
     }
 
-    async find(collectionName: string, query: Record<string, unknown>): Promise<StorageCursor> {
+    async find(collectionName: string, query: Record<string, any>): Promise<StorageCursor> {
         await this._connect()
         const coll = await this._client.db().collection(collectionName)
         return coll.find(query)
     }
 
-    async count(collectionName: string, query: Record<string, unknown>): Promise<number> {
+    async count(collectionName: string, query: Record<string, any>): Promise<number> {
         await this._connect()
         const coll = await this._client.db().collection(collectionName)
         return coll.countDocuments(query)
     }
 
-    async save(collectionName: string, uniqKey: string, data: Record<string, unknown>): Promise<string> {
+    async save(collectionName: string, uniqKey: string, data: Record<string, any>): Promise<string> {
         await this._connect()
         const id = data[uniqKey]
         const coll = await this._client.db().collection(collectionName)

src/index.ts

@@ -6,3 +6,4 @@ export { Data, ValuesObject } from './app/data'
 export { Entity, EntityConstructor, ErrEntityHasNoUniqKeyValue } from './app/entity'
 export { Repo, ErrFoundNotUniqEntity, ErrEntityNotFound } from './app/repo'
 export { Storage, StorageCursor, ErrStorage, ErrNoSession, StorageSession } from './app/storage'
+export { EntityManager } from './app/entity/manager'