hotfix: api, integration 하기 위해 대응개발

Author: Nuung

src/controllers/tracking.controller.ts

@@ -4,14 +4,14 @@ import { TrackingService } from '@/services/tracking.service';
 import { EmptyResponseDto } from '@/types';
 
 export class TrackingController {
-  constructor(private trackingService: TrackingService) {}
+  constructor(private trackingService: TrackingService) { }
 
   event: RequestHandler = async (req: Request, res: Response<EmptyResponseDto>, next: NextFunction) => {
     try {
       const { eventType } = req.body;
       const { id } = req.user;
 
-      await this.trackingService.tracking(eventType, id);
+      await this.trackingService.tracking(eventType, id, req.headers);
 
       const response = new EmptyResponseDto(true, '이벤트 데이터 저장완료', {}, null);
 

src/repositories/tracking.repository.ts

@@ -4,17 +4,17 @@ import { DBError } from '@/exception';
 import { EventRequestDto } from '@/types';
 
 export class TrackingRepository {
-  constructor(private readonly pool: Pool) {}
+  constructor(private readonly pool: Pool) { }
 
-  async createEvent(type: EventRequestDto, id: number) {
+  async createEvent(type: EventRequestDto, id: number, req_headers: object) {
     try {
       const result = await this.pool.query(
         `
-        INSERT INTO tracking_usereventtracking (event_type, user_id, created_at)
-        VALUES ($1, $2, CURRENT_TIMESTAMP)
+        INSERT INTO tracking_usereventtracking (event_type, user_id, request_header, created_at)
+        VALUES ($1, $2, $3, CURRENT_TIMESTAMP)
         RETURNING *;
       `,
-        [type, id],
+        [type, id, req_headers],
       );
       return result.rows[0];
     } catch (error) {

src/services/tracking.service.ts

@@ -4,10 +4,10 @@ import logger from '@/configs/logger.config';
 import { BadRequestError } from '@/exception';
 
 export class TrackingService {
-  constructor(private trackingRepo: TrackingRepository) {}
+  constructor(private trackingRepo: TrackingRepository) { }
 
-  async tracking(eventType: EventRequestDto, id: number) {
-    return await this.trackingRepo.createEvent(eventType, id);
+  async tracking(eventType: EventRequestDto, id: number, req_headers: object) {
+    return await this.trackingRepo.createEvent(eventType, id, req_headers);
   }
 
   async stay(data: StayTimeRequestDto, userId: number) {