diff --git a/server/src/contexts/auth/application/authServices.ts b/server/src/contexts/auth/application/authServices.ts index be25c8e..941d1be 100644 --- a/server/src/contexts/auth/application/authServices.ts +++ b/server/src/contexts/auth/application/authServices.ts @@ -14,3 +14,26 @@ export const findUserByEmail = async ( repository({ transaction: t }).findUserByEmail(email), ); }; + +/*export class AuthService extends ApplicationService { + private _adapter: ISequelizeAdapter; + private _repository: IRepositoryManager; + private _authRepository: IAuthRepository; + + constructor(props: { + adapter: ISequelizeAdapter, + repository: IRepositoryManager, + }) { + super(); + this._adapter = props.adapter; + + this._repository = props.repository; + + this._repository.getRepository("auth") + + this._authRepository = ; + } + + +} +*/ diff --git a/server/src/contexts/common/application/services/index.ts b/server/src/contexts/common/application/services/index.ts index d0508d6..8975c2e 100644 --- a/server/src/contexts/common/application/services/index.ts +++ b/server/src/contexts/common/application/services/index.ts @@ -1 +1,2 @@ -export * from './QueryCriteriaService'; +export * from "./ApplicationService"; +export * from "./QueryCriteriaService"; diff --git a/server/src/contexts/common/infrastructure/sequelize/SequelizeRepository.ts b/server/src/contexts/common/infrastructure/sequelize/SequelizeRepository.ts index f6e550c..043d90f 100644 --- a/server/src/contexts/common/infrastructure/sequelize/SequelizeRepository.ts +++ b/server/src/contexts/common/infrastructure/sequelize/SequelizeRepository.ts @@ -4,19 +4,17 @@ import { ModelDefined, Transaction } from "sequelize"; import { IRepository } from "../../domain/repositories"; import { ISequelizeAdapter } from "./SequelizeAdapter"; -import { ISequelizeQueryBuilder } from "./queryBuilder/SequelizeQueryBuilder"; export abstract class SequelizeRepository implements IRepository { - protected queryBuilder: ISequelizeQueryBuilder; - protected transaction: Transaction; - protected adapter: ISequelizeAdapter; + protected _transaction: Transaction; + protected _adapter: ISequelizeAdapter; + public constructor(props: { adapter: ISequelizeAdapter; transaction: Transaction; }) { - this.adapter = props.adapter; - this.transaction = props.transaction; - this.queryBuilder = this.adapter.queryBuilder; + this._adapter = props.adapter; + this._transaction = props.transaction; } protected getById(id: UniqueID): Promise { @@ -53,14 +51,14 @@ export abstract class SequelizeRepository implements IRepository { value: any, params: any = {}, ): Promise { - const _model = this.adapter.getModel(modelName); + const _model = this._adapter.getModel(modelName); const where: { [key: string]: any } = {}; where[field] = value; return _model.findOne({ where, - transaction: this.transaction, + transaction: this._transaction, ...params, }); } @@ -70,7 +68,7 @@ export abstract class SequelizeRepository implements IRepository { id: UniqueID | string, params: any = {}, ): Promise { - const _model = this.adapter.getModel(modelName); + const _model = this._adapter.getModel(modelName); return _model.findByPk(id.toString(), params); } @@ -81,15 +79,15 @@ export abstract class SequelizeRepository implements IRepository { ): Promise<{ rows: any[]; count: number }> { console.time("_findAll"); - const { model: _model, query } = this.queryBuilder.generateQuery({ - model: this.adapter.getModel(modelName), + const { model: _model, query } = this._adapter.queryBuilder.generateQuery({ + model: this._adapter.getModel(modelName), queryCriteria, }); const args = { ...query, distinct: true, - transaction: this.transaction, + transaction: this._transaction, ...params, }; @@ -106,13 +104,13 @@ export abstract class SequelizeRepository implements IRepository { value: any, params: any = {}, ): Promise { - const _model = this.adapter.getModel(modelName) as ModelDefined; + const _model = this._adapter.getModel(modelName) as ModelDefined; const where = {}; where[field] = value; const count: number = await _model.count({ where, - transaction: this.transaction, + transaction: this._transaction, }); return Promise.resolve(Boolean(count !== 0)); @@ -124,7 +122,7 @@ export abstract class SequelizeRepository implements IRepository { data: any, params: any = {}, ): Promise { - const _model = this.adapter.getModel(modelName); + const _model = this._adapter.getModel(modelName); if (await this._exists(modelName, "id", id.toPrimitive())) { await _model.update( @@ -134,7 +132,7 @@ export abstract class SequelizeRepository implements IRepository { }, { where: { id: id.toPrimitive() }, - transaction: this.transaction, + transaction: this._transaction, ...params, }, ); @@ -146,7 +144,7 @@ export abstract class SequelizeRepository implements IRepository { }, { include: [{ all: true }], - transaction: this.transaction, + transaction: this._transaction, ...params, }, ); @@ -159,13 +157,13 @@ export abstract class SequelizeRepository implements IRepository { force: boolean = false, params: any = {}, ): Promise { - const model: ModelDefined = this.adapter.getModel(modelName); + const model: ModelDefined = this._adapter.getModel(modelName); await model.destroy({ where: { id: id.toPrimitive(), }, - transaction: this.transaction, + transaction: this._transaction, force, logging: console.log, });