2 files changed, 114 insertions, 0 deletions
diff --git a/app/api/tracking/page-duration/route.ts b/app/api/tracking/page-duration/route.ts
new file mode 100644
index 00000000..861a52cc
--- /dev/null
+++ b/app/api/tracking/page-duration/route.ts
@@ -0,0 +1,56 @@
+import { NextRequest, NextResponse } from 'next/server'
+import { getServerSession } from 'next-auth'
+import db from '@/db/db'
+import { pageVisits } from '@/db/schema'
+import { and, eq, desc, gte } from 'drizzle-orm'
+import { authOptions } from '../../auth/[...nextauth]/route'
+
+// 타입 변환 헬퍼
+function ensureNumber(value: string | number): number {
+    return typeof value === 'string' ? parseInt(value, 10) : value
+  }
+  
+  export async function POST(request: NextRequest) {
+    try {
+      const session = await getServerSession(authOptions)
+      const { route, duration, timestamp } = await request.json()
+  
+      // 세션이 있는 경우에만 체류 시간 업데이트
+      if (session?.user?.id) {
+        // string ID를 number로 변환
+        const numericUserId = ensureNumber(session.user.id)
+        
+        // 최근 5분 내의 해당 라우트 방문 기록을 찾아서 체류 시간 업데이트
+        const fiveMinutesAgo = new Date(Date.now() - 5 * 60 * 1000)
+        
+        // 방법 1: 서브쿼리를 사용해서 가장 최근 레코드의 ID를 찾아서 업데이트
+        const latestVisitSubquery = db
+          .select({ id: pageVisits.id })
+          .from(pageVisits)
+          .where(
+            and(
+              eq(pageVisits.userId, numericUserId),  // ✅ 이제 타입 매칭
+              eq(pageVisits.route, route),
+              gte(pageVisits.visitedAt, fiveMinutesAgo)
+            )
+          )
+          .orderBy(desc(pageVisits.visitedAt))
+          .limit(1)
+  
+        // 서브쿼리 결과를 사용해서 업데이트
+        const latestVisit = await latestVisitSubquery
+        
+        if (latestVisit.length > 0) {
+          await db
+            .update(pageVisits)
+            .set({ duration })
+            .where(eq(pageVisits.id, latestVisit[0].id))
+        }
+      }
+  
+      return NextResponse.json({ success: true })
+    } catch (error) {
+      console.error('Page duration tracking API error:', error)
+      return NextResponse.json({ success: false }, { status: 200 })
+    }
+  }
+\ No newline at end of file
diff --git a/app/api/tracking/page-visit/route.ts b/app/api/tracking/page-visit/route.ts
new file mode 100644
index 00000000..26263b04
--- /dev/null
+++ b/app/api/tracking/page-visit/route.ts
@@ -0,0 +1,58 @@
+import { NextRequest, NextResponse } from 'next/server'
+import { getServerSession } from 'next-auth'
+import { SessionRepository } from '@/lib/users/session/repository'
+import { authOptions } from '../../auth/[...nextauth]/route'
+
+function ensureNumber(value: string | number): number {
+    return typeof value === 'string' ? parseInt(value, 10) : value
+}
+export async function POST(request: NextRequest) {
+    try {
+        const session = await getServerSession(authOptions)
+        const trackingData = await request.json()
+
+        // IP 주소 추출
+        const getClientIP = (req: NextRequest): string => {
+            const forwarded = req.headers.get('x-forwarded-for')
+            const realIP = req.headers.get('x-real-ip')
+            const cfConnectingIP = req.headers.get('cf-connecting-ip')
+
+            if (cfConnectingIP) return cfConnectingIP
+            if (forwarded) return forwarded.split(',')[0].trim()
+            if (realIP) return realIP
+            return '127.0.0.1'
+        }
+
+        // 활성 세션 조회 및 업데이트
+        let sessionId = null
+        if (session?.user?.id && session?.user?.dbSessionId) {
+            sessionId = session.user.dbSessionId
+
+            // 세션 활동 시간 업데이트 (백그라운드)
+            SessionRepository.updateSessionActivity(sessionId).catch(error => {
+                console.error('Failed to update session activity:', error)
+            })
+        }
+
+        // 페이지 방문 기록
+        await SessionRepository.recordPageVisit({
+            userId: session?.user?.id ? ensureNumber(session.user.id) : undefined,  // ✅ 타입 변환
+            sessionId,
+            route: trackingData.route,
+            pageTitle: trackingData.pageTitle || undefined,
+            referrer: trackingData.referrer || undefined,
+            ipAddress: getClientIP(request),
+            userAgent: trackingData.userAgent,
+            queryParams: new URL(request.url).search || undefined,
+            deviceType: trackingData.deviceType || undefined,
+            browserName: trackingData.browserName || undefined,
+            osName: trackingData.osName || undefined,
+        })
+
+        return NextResponse.json({ success: true })
+    } catch (error) {
+        console.error('Page visit tracking API error:', error)
+        // 추적 실패가 클라이언트에 영향을 주지 않도록 성공 응답
+        return NextResponse.json({ success: false }, { status: 200 })
+    }
+}
+\ No newline at end of file