feat(SPG-448) REST API CUD Berita
parent
75663c4f99
commit
9056b60937
|
@ -64,6 +64,8 @@ import { TermConditionModel } from './modules/web-information/term-condition/dat
|
|||
import { FaqModel } from './modules/web-information/faq/data/models/faq.model';
|
||||
import { FaqModule } from './modules/web-information/faq/faq.module';
|
||||
import { UploadModule } from './modules/configuration/upload/upload.module';
|
||||
import { NewsModule } from './modules/web-information/news/news.module';
|
||||
import { NewsModel } from './modules/web-information/news/data/models/news.model';
|
||||
|
||||
@Module({
|
||||
imports: [
|
||||
|
@ -88,6 +90,7 @@ import { UploadModule } from './modules/configuration/upload/upload.module';
|
|||
ItemCategoryModel,
|
||||
ItemRateModel,
|
||||
LogModel,
|
||||
NewsModel,
|
||||
PaymentMethodModel,
|
||||
RefundModel,
|
||||
RefundItemModel,
|
||||
|
@ -148,6 +151,7 @@ import { UploadModule } from './modules/configuration/upload/upload.module';
|
|||
// web information
|
||||
FaqModule,
|
||||
GateModule,
|
||||
NewsModule,
|
||||
TermConditionModule,
|
||||
|
||||
// report
|
||||
|
|
|
@ -4,6 +4,7 @@ export enum MODULE_NAME {
|
|||
ITEM = 'items',
|
||||
ITEM_CATEGORY = 'item-categories',
|
||||
ITEM_RATE = 'item-rates',
|
||||
NEWS = 'news',
|
||||
PAYMENT_METHOD = 'payment-methods',
|
||||
RECONCILIATION = 'reconciliations',
|
||||
REFUND = 'refunds',
|
||||
|
|
|
@ -6,6 +6,7 @@ export enum TABLE_NAME {
|
|||
ITEM_RATE = 'item_rates',
|
||||
GATE = 'gates',
|
||||
LOG = 'logs',
|
||||
NEWS = 'news',
|
||||
PAYMENT_METHOD = 'payment_methods',
|
||||
PRICE_FORMULA = 'price_formulas',
|
||||
REFUND = 'refunds',
|
||||
|
|
|
@ -0,0 +1,19 @@
|
|||
import { MigrationInterface, QueryRunner } from 'typeorm';
|
||||
|
||||
export class News1721109817371 implements MigrationInterface {
|
||||
name = 'News1721109817371';
|
||||
|
||||
public async up(queryRunner: QueryRunner): Promise<void> {
|
||||
await queryRunner.query(
|
||||
`CREATE TYPE "public"."news_status_enum" AS ENUM('active', 'cancel', 'confirmed', 'draft', 'expired', 'inactive', 'partial refund', 'pending', 'proses refund', 'refunded', 'rejected', 'settled', 'waiting')`,
|
||||
);
|
||||
await queryRunner.query(
|
||||
`CREATE TABLE "news" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "creator_id" character varying(36), "creator_name" character varying(125), "editor_id" character varying(36), "editor_name" character varying(125), "created_at" bigint NOT NULL, "updated_at" bigint NOT NULL, "status" "public"."news_status_enum" NOT NULL DEFAULT 'draft', "image_url" character varying, "title" character varying, "teaser" character varying, "description" character varying, CONSTRAINT "PK_39a43dfcb6007180f04aff2357e" PRIMARY KEY ("id"))`,
|
||||
);
|
||||
}
|
||||
|
||||
public async down(queryRunner: QueryRunner): Promise<void> {
|
||||
await queryRunner.query(`DROP TABLE "news"`);
|
||||
await queryRunner.query(`DROP TYPE "public"."news_status_enum"`);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,22 @@
|
|||
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||
import { NewsEntity } from '../../domain/entities/news.entity';
|
||||
import { Column, Entity } from 'typeorm';
|
||||
import { BaseStatusModel } from 'src/core/modules/data/model/base-status.model';
|
||||
|
||||
@Entity(TABLE_NAME.NEWS)
|
||||
export class NewsModel
|
||||
extends BaseStatusModel<NewsEntity>
|
||||
implements NewsEntity
|
||||
{
|
||||
@Column('varchar', { name: 'image_url', nullable: true })
|
||||
image_url: string;
|
||||
|
||||
@Column('varchar', { name: 'title', nullable: true })
|
||||
title: string;
|
||||
|
||||
@Column('varchar', { name: 'teaser', nullable: true })
|
||||
teaser: string;
|
||||
|
||||
@Column('varchar', { name: 'description', nullable: true })
|
||||
description: string;
|
||||
}
|
|
@ -0,0 +1,17 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseDataService } from 'src/core/modules/data/service/base-data.service';
|
||||
import { NewsEntity } from '../../domain/entities/news.entity';
|
||||
import { InjectRepository } from '@nestjs/typeorm';
|
||||
import { NewsModel } from '../models/news.model';
|
||||
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
|
||||
import { Repository } from 'typeorm';
|
||||
|
||||
@Injectable()
|
||||
export class NewsDataService extends BaseDataService<NewsEntity> {
|
||||
constructor(
|
||||
@InjectRepository(NewsModel, CONNECTION_NAME.DEFAULT)
|
||||
private repo: Repository<NewsModel>,
|
||||
) {
|
||||
super(repo);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class NewsChangeStatusEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class NewsCreatedEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class NewsDeletedEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class NewsUpdatedEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,8 @@
|
|||
import { BaseStatusEntity } from 'src/core/modules/domain/entities/base-status.entity';
|
||||
|
||||
export interface NewsEntity extends BaseStatusEntity {
|
||||
image_url: string;
|
||||
title: string;
|
||||
teaser: string;
|
||||
description: string;
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
|
||||
@Injectable()
|
||||
export class ActiveNewsManager extends BaseUpdateStatusManager<NewsEntity> {
|
||||
getResult(): string {
|
||||
return `Success active data ${this.result.title}`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchActiveNewsManager extends BaseBatchUpdateStatusManager<NewsEntity> {
|
||||
validateData(data: NewsEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchConfirmNewsManager extends BaseBatchUpdateStatusManager<NewsEntity> {
|
||||
validateData(data: NewsEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchDeleteManager } from 'src/core/modules/domain/usecase/managers/base-batch-delete.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsDeletedEvent } from '../../entities/event/news-deleted.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchDeleteNewsManager extends BaseBatchDeleteManager<NewsEntity> {
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async validateData(data: NewsEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsDeletedEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchInactiveNewsManager extends BaseBatchUpdateStatusManager<NewsEntity> {
|
||||
validateData(data: NewsEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
|
||||
@Injectable()
|
||||
export class ConfirmNewsManager extends BaseUpdateStatusManager<NewsEntity> {
|
||||
getResult(): string {
|
||||
return `Success active data ${this.result.title}`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,42 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import {
|
||||
EventTopics,
|
||||
columnUniques,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { BaseCreateManager } from 'src/core/modules/domain/usecase/managers/base-create.manager';
|
||||
import { NewsCreatedEvent } from '../../entities/event/news-created.event';
|
||||
|
||||
@Injectable()
|
||||
export class CreateNewsManager extends BaseCreateManager<NewsEntity> {
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get uniqueColumns(): columnUniques[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsCreatedEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseDeleteManager } from 'src/core/modules/domain/usecase/managers/base-delete.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsDeletedEvent } from '../../entities/event/news-deleted.event';
|
||||
|
||||
@Injectable()
|
||||
export class DeleteNewsManager extends BaseDeleteManager<NewsEntity> {
|
||||
getResult(): string {
|
||||
return `Success`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsDeletedEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
|
||||
@Injectable()
|
||||
export class InactiveNewsManager extends BaseUpdateStatusManager<NewsEntity> {
|
||||
getResult(): string {
|
||||
return `Success inactive data ${this.result.title}`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,46 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateManager } from 'src/core/modules/domain/usecase/managers/base-update.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsUpdatedEvent } from '../../entities/event/news-updated.event';
|
||||
import {
|
||||
EventTopics,
|
||||
columnUniques,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
@Injectable()
|
||||
export class UpdateNewsManager extends BaseUpdateManager<NewsEntity> {
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get uniqueColumns(): columnUniques[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsUpdatedEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,106 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { CreateNewsManager } from './managers/create-news.manager';
|
||||
import { NewsDataService } from '../../data/services/news-data.service';
|
||||
import { NewsEntity } from '../entities/news.entity';
|
||||
import { DeleteNewsManager } from './managers/delete-news.manager';
|
||||
import { UpdateNewsManager } from './managers/update-news.manager';
|
||||
import { BaseDataTransactionOrchestrator } from 'src/core/modules/domain/usecase/orchestrators/base-data-transaction.orchestrator';
|
||||
import { ActiveNewsManager } from './managers/active-news.manager';
|
||||
import { InactiveNewsManager } from './managers/inactive-news.manager';
|
||||
import { ConfirmNewsManager } from './managers/confirm-news.manager';
|
||||
import { STATUS } from 'src/core/strings/constants/base.constants';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { BatchConfirmNewsManager } from './managers/batch-confirm-news.manager';
|
||||
import { BatchInactiveNewsManager } from './managers/batch-inactive-news.manager';
|
||||
import { BatchActiveNewsManager } from './managers/batch-active-news.manager';
|
||||
import { BatchDeleteNewsManager } from './managers/batch-delete-news.manager';
|
||||
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||
|
||||
@Injectable()
|
||||
export class NewsDataOrchestrator extends BaseDataTransactionOrchestrator<NewsEntity> {
|
||||
constructor(
|
||||
private createManager: CreateNewsManager,
|
||||
private updateManager: UpdateNewsManager,
|
||||
private deleteManager: DeleteNewsManager,
|
||||
private activeManager: ActiveNewsManager,
|
||||
private confirmManager: ConfirmNewsManager,
|
||||
private inactiveManager: InactiveNewsManager,
|
||||
private batchDeleteManager: BatchDeleteNewsManager,
|
||||
private batchActiveManager: BatchActiveNewsManager,
|
||||
private batchConfirmManager: BatchConfirmNewsManager,
|
||||
private batchInactiveManager: BatchInactiveNewsManager,
|
||||
private serviceData: NewsDataService,
|
||||
) {
|
||||
super();
|
||||
}
|
||||
|
||||
async create(data): Promise<NewsEntity> {
|
||||
this.createManager.setData(data);
|
||||
this.createManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.createManager.execute();
|
||||
return this.createManager.getResult();
|
||||
}
|
||||
|
||||
async update(dataId, data): Promise<NewsEntity> {
|
||||
this.updateManager.setData(dataId, data);
|
||||
this.updateManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.updateManager.execute();
|
||||
return this.updateManager.getResult();
|
||||
}
|
||||
|
||||
async delete(dataId): Promise<string> {
|
||||
this.deleteManager.setData(dataId);
|
||||
this.deleteManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.deleteManager.execute();
|
||||
return this.deleteManager.getResult();
|
||||
}
|
||||
|
||||
async batchDelete(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchDeleteManager.setData(dataIds);
|
||||
this.batchDeleteManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.batchDeleteManager.execute();
|
||||
return this.batchDeleteManager.getResult();
|
||||
}
|
||||
|
||||
async active(dataId): Promise<string> {
|
||||
this.activeManager.setData(dataId, STATUS.ACTIVE);
|
||||
this.activeManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.activeManager.execute();
|
||||
return this.activeManager.getResult();
|
||||
}
|
||||
|
||||
async batchActive(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchActiveManager.setData(dataIds, STATUS.ACTIVE);
|
||||
this.batchActiveManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.batchActiveManager.execute();
|
||||
return this.batchActiveManager.getResult();
|
||||
}
|
||||
|
||||
async confirm(dataId): Promise<string> {
|
||||
this.confirmManager.setData(dataId, STATUS.ACTIVE);
|
||||
this.confirmManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.confirmManager.execute();
|
||||
return this.confirmManager.getResult();
|
||||
}
|
||||
|
||||
async batchConfirm(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchConfirmManager.setData(dataIds, STATUS.ACTIVE);
|
||||
this.batchConfirmManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.batchConfirmManager.execute();
|
||||
return this.batchConfirmManager.getResult();
|
||||
}
|
||||
|
||||
async inactive(dataId): Promise<string> {
|
||||
this.inactiveManager.setData(dataId, STATUS.INACTIVE);
|
||||
this.inactiveManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.inactiveManager.execute();
|
||||
return this.inactiveManager.getResult();
|
||||
}
|
||||
|
||||
async batchInactive(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchInactiveManager.setData(dataIds, STATUS.INACTIVE);
|
||||
this.batchInactiveManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.batchInactiveManager.execute();
|
||||
return this.batchInactiveManager.getResult();
|
||||
}
|
||||
}
|
|
@ -0,0 +1,33 @@
|
|||
import { BaseStatusDto } from 'src/core/modules/infrastructure/dto/base-status.dto';
|
||||
import { NewsEntity } from '../../domain/entities/news.entity';
|
||||
import { ApiProperty } from '@nestjs/swagger';
|
||||
|
||||
export class NewsDto extends BaseStatusDto implements NewsEntity {
|
||||
@ApiProperty({
|
||||
type: String,
|
||||
required: false,
|
||||
example: 'https://...',
|
||||
})
|
||||
image_url: string;
|
||||
|
||||
@ApiProperty({
|
||||
type: String,
|
||||
required: true,
|
||||
example: 'The Flash Speed Force',
|
||||
})
|
||||
title: string;
|
||||
|
||||
@ApiProperty({
|
||||
type: String,
|
||||
required: false,
|
||||
example: 'Get ready to take on the first ride-within-a-ride experience',
|
||||
})
|
||||
teaser: string;
|
||||
|
||||
@ApiProperty({
|
||||
type: String,
|
||||
required: false,
|
||||
example: 'description',
|
||||
})
|
||||
description: string;
|
||||
}
|
|
@ -0,0 +1,78 @@
|
|||
import {
|
||||
Body,
|
||||
Controller,
|
||||
Delete,
|
||||
Param,
|
||||
Patch,
|
||||
Post,
|
||||
Put,
|
||||
} from '@nestjs/common';
|
||||
import { NewsDataOrchestrator } from '../domain/usecases/news-data.orchestrator';
|
||||
import { NewsDto } from './dto/news.dto';
|
||||
import { MODULE_NAME } from 'src/core/strings/constants/module.constants';
|
||||
import { ApiBearerAuth, ApiTags } from '@nestjs/swagger';
|
||||
import { NewsEntity } from '../domain/entities/news.entity';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { BatchIdsDto } from 'src/core/modules/infrastructure/dto/base-batch.dto';
|
||||
import { Public } from 'src/core/guards';
|
||||
|
||||
@ApiTags(`${MODULE_NAME.NEWS.split('-').join(' ')} - data`)
|
||||
@Controller(`v1/${MODULE_NAME.NEWS}`)
|
||||
@Public(false)
|
||||
@ApiBearerAuth('JWT')
|
||||
export class NewsDataController {
|
||||
constructor(private orchestrator: NewsDataOrchestrator) {}
|
||||
|
||||
@Post()
|
||||
async create(@Body() data: NewsDto): Promise<NewsEntity> {
|
||||
return await this.orchestrator.create(data);
|
||||
}
|
||||
|
||||
@Put('/batch-delete')
|
||||
async batchDeleted(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchDelete(body.ids);
|
||||
}
|
||||
|
||||
@Patch(':id/active')
|
||||
async active(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.active(dataId);
|
||||
}
|
||||
|
||||
@Put('/batch-active')
|
||||
async batchActive(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchActive(body.ids);
|
||||
}
|
||||
|
||||
@Patch(':id/confirm')
|
||||
async confirm(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.confirm(dataId);
|
||||
}
|
||||
|
||||
@Put('/batch-confirm')
|
||||
async batchConfirm(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchConfirm(body.ids);
|
||||
}
|
||||
|
||||
@Patch(':id/inactive')
|
||||
async inactive(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.inactive(dataId);
|
||||
}
|
||||
|
||||
@Put('/batch-inactive')
|
||||
async batchInactive(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchInactive(body.ids);
|
||||
}
|
||||
|
||||
@Put(':id')
|
||||
async update(
|
||||
@Param('id') dataId: string,
|
||||
@Body() data: NewsDto,
|
||||
): Promise<NewsEntity> {
|
||||
return await this.orchestrator.update(dataId, data);
|
||||
}
|
||||
|
||||
@Delete(':id')
|
||||
async delete(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.delete(dataId);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,54 @@
|
|||
import { Module } from '@nestjs/common';
|
||||
import { ConfigModule } from '@nestjs/config';
|
||||
import { TypeOrmModule } from '@nestjs/typeorm';
|
||||
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
|
||||
import { NewsDataService } from './data/services/news-data.service';
|
||||
import { NewsReadService } from './data/services/news-read.service';
|
||||
import { NewsReadController } from './infrastructure/news-read.controller';
|
||||
import { NewsReadOrchestrator } from './domain/usecases/news-read.orchestrator';
|
||||
import { NewsDataController } from './infrastructure/news-data.controller';
|
||||
import { NewsDataOrchestrator } from './domain/usecases/news-data.orchestrator';
|
||||
import { CreateNewsManager } from './domain/usecases/managers/create-news.manager';
|
||||
import { CqrsModule } from '@nestjs/cqrs';
|
||||
import { IndexNewsManager } from './domain/usecases/managers/index-news.manager';
|
||||
import { DeleteNewsManager } from './domain/usecases/managers/delete-news.manager';
|
||||
import { UpdateNewsManager } from './domain/usecases/managers/update-news.manager';
|
||||
import { ActiveNewsManager } from './domain/usecases/managers/active-news.manager';
|
||||
import { ConfirmNewsManager } from './domain/usecases/managers/confirm-news.manager';
|
||||
import { InactiveNewsManager } from './domain/usecases/managers/inactive-news.manager';
|
||||
import { DetailNewsManager } from './domain/usecases/managers/detail-news.manager';
|
||||
import { BatchDeleteNewsManager } from './domain/usecases/managers/batch-delete-news.manager';
|
||||
import { BatchActiveNewsManager } from './domain/usecases/managers/batch-active-news.manager';
|
||||
import { BatchConfirmNewsManager } from './domain/usecases/managers/batch-confirm-news.manager';
|
||||
import { BatchInactiveNewsManager } from './domain/usecases/managers/batch-inactive-news.manager';
|
||||
import { NewsModel } from './data/models/news.model';
|
||||
|
||||
@Module({
|
||||
imports: [
|
||||
ConfigModule.forRoot(),
|
||||
TypeOrmModule.forFeature([NewsModel], CONNECTION_NAME.DEFAULT),
|
||||
CqrsModule,
|
||||
],
|
||||
controllers: [NewsDataController, NewsReadController],
|
||||
providers: [
|
||||
IndexNewsManager,
|
||||
DetailNewsManager,
|
||||
CreateNewsManager,
|
||||
DeleteNewsManager,
|
||||
UpdateNewsManager,
|
||||
ActiveNewsManager,
|
||||
ConfirmNewsManager,
|
||||
InactiveNewsManager,
|
||||
BatchDeleteNewsManager,
|
||||
BatchActiveNewsManager,
|
||||
BatchConfirmNewsManager,
|
||||
BatchInactiveNewsManager,
|
||||
|
||||
NewsDataService,
|
||||
NewsReadService,
|
||||
|
||||
NewsDataOrchestrator,
|
||||
NewsReadOrchestrator,
|
||||
],
|
||||
})
|
||||
export class NewsModule {}
|
Loading…
Reference in New Issue