Skip to content

Commit

Permalink
fix singleton listfactory
Browse files Browse the repository at this point in the history
  • Loading branch information
bahram1249 committed May 27, 2024
1 parent f5aba7e commit 96c1810
Show file tree
Hide file tree
Showing 4 changed files with 23 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3,24 +3,20 @@ import { Job } from 'bullmq';
import { DBLogger } from '@rahino/logger';
import { PRODUCT_DISCOUNT_QUEUE } from './constansts';
import { ProductDiscountService } from './product-discount.service';
import { emptyListFilter } from '@rahino/query-filter/provider/constants';
import { Inject } from '@nestjs/common';
import { ListFilter } from '@rahino/query-filter';
import * as _ from 'lodash';
import { ListFilterV2Factory } from '@rahino/query-filter/provider/list-filter-v2.factory';

@Processor(PRODUCT_DISCOUNT_QUEUE)
export class ProductDiscountProcessor extends WorkerHost {
constructor(
private readonly productDiscountService: ProductDiscountService,
@Inject(emptyListFilter)
private emptyListFilter: ListFilter,
private listFilterFactory: ListFilterV2Factory,
private logger: DBLogger,
) {
super();
}

async process(job: Job<any, any, string>, token?: string): Promise<any> {
const listFilter = _.cloneDeep(this.emptyListFilter);
const listFilter = await this.listFilterFactory.create();
listFilter.limit = 10;
listFilter.offset = 0;
console.log('initial list filter', listFilter);
Expand Down
2 changes: 1 addition & 1 deletion apps/e-commerce/src/user/stock/stock.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -319,7 +319,7 @@ export class StockService {
throw new NotFoundException('the item with this given id not founded!');
}
const queryItem = await this.productRepositoryService.findById(
_.merge(this.emptyListFilter, { inventoryId: stock.inventoryId }),
_.extend(this.emptyListFilter, { inventoryId: stock.inventoryId }),
stock.productId,
);
stock.set('product', queryItem.result);
Expand Down
16 changes: 16 additions & 0 deletions libs/query-filter/src/provider/list-filter-v2.factory.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
import { Injectable } from '@nestjs/common';
import { ListFilter, SortOrder } from '../types';

@Injectable()
export class ListFilterV2Factory {
constructor() {}
async create() {
const listFilter = new ListFilter();
listFilter.search = '%%';
listFilter.offset = null;
listFilter.limit = null;
listFilter.sortOrder = SortOrder.DESC;
listFilter.orderBy = 'id';
return listFilter;
}
}
5 changes: 3 additions & 2 deletions libs/query-filter/src/query-filter.module.ts
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
import { Module } from '@nestjs/common';
import { listFilterFactory } from '@rahino/query-filter/provider';
import { ListFilterV2Factory } from './provider/list-filter-v2.factory';

@Module({
providers: [listFilterFactory],
exports: [listFilterFactory],
providers: [listFilterFactory, ListFilterV2Factory],
exports: [listFilterFactory, ListFilterV2Factory],
})
export class QueryFilterModule {}

0 comments on commit 96c1810

Please sign in to comment.