my-log-kafka-package v0.1.24
:pushpin: Validate Token
- Cách sử dụng + Wrapper
import { GrpcMetadataInterceptor } from "src/utils.common/utils.interceptor/grpc-metadata.interceptor";
@Controller("users")
@UseInterceptors(GrpcMetadataInterceptor)
...
@Get("/:id")
@UseGuards(UserGuard)
async findOneUser(
@Req() request: RequestWithUser,
@Param("id") id: number,
@Res() res: Response,
@AddGrpcMetadata() metadata: Metadata
) {
return res
.status(HttpStatus.OK)
.send(await this.userService.findOneUser(id, metadata));
}
+ Service
async findOneUser(
request: FindOneUserDTO,
metadata: Metadata,
call: ServerUnaryCall<any, any>
): Promise<any> {
console.log(new UtilsUser(call).getUser());
}
:pushpin: Enum
AccountType
AccountStatus
StoreProcedureStatusEnum
:bangbang: Exception
GrpcExceptionFilter
ExceptionStoreProcedure
ExceptionResponseDetail
:file_folder: Store
StoreProcedureResultOutput
StoreProcedureResult
StoreProcedureOutputResultInterface
StoreProcedureResultInterface
:zap: Utils
UtilsTime
Kafka Log Module
Introduction
This module provides functionality to log messages to Kafka.
Cách dùng
-Đổi tên
KafkaLogModule -> KafkaCofastModule
KafkaLogService -> KafkaCofastService
- Import vào module cần dùng
import { KafkaCofastModule } from 'nodejs-cofast-package/dist/v1';
KafkaCofastModule.register({
client_id: 'my-app-test-1', // có thể sửa
host: process.env.CONFIG_KAFKA_HOST,
port: process.env.CONFIG_KAFKA_PORT,
})
- Khai báo service
private readonly kafkaCofastService: KafkaCofastService
- Send log
export interface ILogActivity {
user_id: number;
log_type: LOG_TYPE_ENUM;
object_id: number;
action_type: ACTION_TYPE_ENUM;
action_detail: string;
json_data_before: string;
json_data_after: string;
platform_type: PLATFORM_TYPE_ENUM;
timestamp: number;
}
await this.kafkaCofastService.sendLogToKafka(message: ILogActivity);
- send notification
export interface INotification {
recipient_user_id: number;
avatar: string;
image_url: string;
title: string;
content: string;
object_id: number;
object_type: LOG_TYPE_ENUM;
timestamp: number;
}
await this.kafkaCofastService.sendNotificationToKafka(message: INotification);
- KeyRedisGenerate
KeyRedisGenerate.generateKey(REDIS_PREFIX_ENUM.AIR_FREIGHT, request)
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago
11 months ago