v0.3.5: update proguard-rules.pro

app/build.gradle.kts

@@ -24,8 +24,8 @@ android {
  applicationId = "com.hotdeal.alarm"
  minSdk = 31
  targetSdk = 35
-        versionCode = 34
-        versionName = "0.3.4"
+        versionCode = 35
+        versionName = "0.3.5"
 
  testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
  vectorDrawables {

app/src/main/java/com/hotdeal/alarm/domain/usecase/HotDealScraperManager.kt

@@ -0,0 +1,175 @@
+package com.hotdeal.alarm.domain.usecase
+
+import android.content.Context
+import android.util.Log
+import com.hotdeal.alarm.data.local.db.dao.HotDealDao
+import com.hotdeal.alarm.data.local.db.dao.KeywordDao
+import com.hotdeal.alarm.data.local.db.dao.SiteConfigDao
+import com.hotdeal.alarm.data.local.db.entity.HotDealEntity
+import com.hotdeal.alarm.data.local.db.entity.KeywordEntity
+import com.hotdeal.alarm.data.local.db.entity.SiteConfigEntity
+import com.hotdeal.alarm.data.remote.scraper.ScraperFactory
+import com.hotdeal.alarm.domain.model.HotDeal
+import com.hotdeal.alarm.service.NotificationService
+import dagger.hilt.android.qualifiers.ApplicationContext
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.async
+import kotlinx.coroutines.awaitAll
+import kotlinx.coroutines.sync.Mutex
+import kotlinx.coroutines.sync.withLock
+import kotlinx.coroutines.withContext
+import javax.inject.Inject
+import javax.inject.Singleton
+
+/**
+ * 핫딜 스크래핑, DB 저장, 키워드 매칭, 알림 발송을 총괄하는 핵심 매니저
+ * 
+ * 포그라운드(앱 진입/새로고침), 백그라운드(AlarmReceiver), WorkManager 모두에서
+ * 공통으로 직접 호출하여 지연 없이 즉시 수집 및 알림을 발송합니다.
+ */
+@Singleton
+class HotDealScraperManager @Inject constructor(
+    @ApplicationContext private val context: Context,
+    private val scraperFactory: ScraperFactory,
+    private val notificationService: NotificationService,
+    private val dealDao: HotDealDao,
+    private val siteConfigDao: SiteConfigDao,
+    private val keywordDao: KeywordDao
+) {
+    companion object {
+        private const val TAG = "HotDealScraperManager"
+    }
+
+    // 중복 동시 실행 방지 뮤텍스
+    private val mutex = Mutex()
+
+    /**
+     * 핫딜 수집 및 키워드 알림 발송 전체 프로세스 실행
+     * @return 수집된 새로운 핫딜 목록
+     */
+    suspend fun fetchAndProcessDeals(): List<HotDeal> = withContext(Dispatchers.IO) {
+        mutex.withLock {
+            try {
+                Log.d(TAG, "===== 🚀 핫딜 수집 프로세스 시작 =====")
+
+                // 1. 활성화된 사이트 설정 조회
+                val enabledConfigs = siteConfigDao.getEnabledConfigs()
+                Log.d(TAG, "활성화된 사이트 설정: ${enabledConfigs.size}개")
+
+                if (enabledConfigs.isEmpty()) {
+                    Log.w(TAG, "활성화된 사이트 설정이 없습니다.")
+                    return@withContext emptyList()
+                }
+
+                // 2. 활성화된 키워드 조회
+                val keywords = keywordDao.getEnabledKeywords()
+                Log.d(TAG, "활성화된 키워드: ${keywords.size}개 (${keywords.map { it.keyword }})")
+
+                // 3. 각 사이트/게시판 병렬 스크래핑
+                val allDeals = enabledConfigs.map { config ->
+                    async { scrapeSite(config) }
+                }.awaitAll().flatten()
+
+                Log.d(TAG, "스크래핑 완료: 총 ${allDeals.size}개 핫딜 수집됨")
+                if (allDeals.isEmpty()) {
+                    return@withContext emptyList()
+                }
+
+                // 4. 새로운 핫딜 필터링 (기존 DB에 없는 것)
+                val newDeals = filterNewDeals(allDeals)
+                Log.d(TAG, "새로운 핫딜: ${newDeals.size}개")
+
+                // 5. 인기글 상태 일괄 업데이트 (기존 + 신규 모두)
+                val popularDealIds = allDeals.filter { it.isPopular }.map { it.id }
+                if (popularDealIds.isNotEmpty()) {
+                    dealDao.markAsPopular(popularDealIds)
+                    Log.d(TAG, "🔥 인기글 마킹: ${popularDealIds.size}개")
+                }
+
+                if (newDeals.isNotEmpty()) {
+                    // 6. 키워드 매칭
+                    val keywordMatchedDeals = if (keywords.isNotEmpty()) {
+                        filterByKeywords(newDeals, keywords).also {
+                            Log.d(TAG, "⭐ 키워드 매칭 핫딜: ${it.size}개 -> ${it.map { d -> d.title }}")
+                        }
+                    } else {
+                        emptyList()
+                    }
+
+                    // 7. DB에 새 핫딜 저장
+                    var insertedCount = 0
+                    newDeals.forEach { deal ->
+                        try {
+                            val entity = HotDealEntity.fromDomain(deal)
+                            dealDao.insertDeal(entity)
+                            insertedCount++
+                        } catch (e: Exception) {
+                            Log.w(TAG, "핫딜 저장 실패: ${deal.id}")
+                        }
+                    }
+                    Log.d(TAG, "DB 저장 완료: $insertedCount 개")
+
+                    // 8. 키워드 매칭 알림 즉시 발송! (시스템바 노티피케이션)
+                    if (keywordMatchedDeals.isNotEmpty()) {
+                        Log.d(TAG, "🔔 키워드 매칭 알림 발송: ${keywordMatchedDeals.size}개")
+                        notificationService.showKeywordMatchNotification(keywordMatchedDeals)
+                        dealDao.markAsKeywordMatch(keywordMatchedDeals.map { it.id })
+                    }
+
+                    // 9. 알림 발송 상태 업데이트
+                    dealDao.markAsNotified(newDeals.map { it.id })
+                }
+
+                // 10. 오래된 데이터 정리 (3일 이상)
+                val threshold = System.currentTimeMillis() - (3 * 24 * 60 * 60 * 1000L)
+                dealDao.deleteOldDeals(threshold)
+
+                Log.d(TAG, "===== ✅ 핫딜 수집 프로세스 종료 =====")
+                newDeals
+            } catch (e: Exception) {
+                Log.e(TAG, "핫딜 수집 오류: ${e.message}", e)
+                emptyList()
+            }
+        }
+    }
+
+    private suspend fun scrapeSite(config: SiteConfigEntity): List<HotDeal> {
+        val scraper = scraperFactory.getScraper(config.siteName) ?: return emptyList()
+        val result = scraper.scrape(config.boardName)
+
+        result.fold(
+            onSuccess = { deals ->
+                try {
+                    siteConfigDao.updateLastScrapedAt(config.siteBoardKey, System.currentTimeMillis())
+                } catch (e: Exception) {
+                    // 무시
+                }
+            },
+            onFailure = { error ->
+                Log.e(TAG, "${config.siteName}/${config.boardName} 실패: ${error.message}")
+            }
+        )
+
+        return result.getOrElse { emptyList() }
+    }
+
+    private suspend fun filterNewDeals(deals: List<HotDeal>): List<HotDeal> {
+        return deals.filter { deal ->
+            val existingByUrl = dealDao.getDealByUrl(deal.url)
+            if (existingByUrl != null) return@filter false
+
+            val existingById = dealDao.getDealById(deal.id)
+            if (existingById != null) return@filter false
+
+            true
+        }
+    }
+
+    private fun filterByKeywords(deals: List<HotDeal>, keywords: List<KeywordEntity>): List<HotDeal> {
+        return deals.filter { deal ->
+            keywords.any { keyword ->
+                deal.title.contains(keyword.keyword, ignoreCase = true)
+            }
+        }
+    }
+}

app/src/main/java/com/hotdeal/alarm/presentation/deallist/DealListScreen.kt

@@ -62,7 +62,7 @@ fun DealListScreen(
 
     // Pull to Refresh
     val pullToRefreshState = rememberPullToRefreshState(positionalThreshold = 40.dp)
-    var isRefreshing by remember { mutableStateOf(false) }
+    val isRefreshingByVm by viewModel.isRefreshing.collectAsStateWithLifecycle()
 
     val listState = rememberLazyListState()
     val scope = rememberCoroutineScope()
@@ -70,9 +70,8 @@ fun DealListScreen(
         derivedStateOf { listState.firstVisibleItemIndex > 3 }
     }
 
-    LaunchedEffect(uiState) {
-        if (uiState !is MainUiState.Loading) {
-            isRefreshing = false
+    LaunchedEffect(isRefreshingByVm) {
+        if (!isRefreshingByVm) {
             pullToRefreshState.endRefresh()
         }
     }
@@ -421,7 +420,6 @@ fun DealListScreen(
 
             LaunchedEffect(pullToRefreshState.isRefreshing) {
                 if (pullToRefreshState.isRefreshing) {
-                    isRefreshing = true
                     viewModel.refresh()
                 }
             }

app/src/main/java/com/hotdeal/alarm/presentation/main/MainActivity.kt

@@ -40,6 +40,9 @@ class MainActivity : ComponentActivity() {
     @Inject
     lateinit var workerScheduler: WorkerScheduler
 
+    @Inject
+    lateinit var scraperManager: com.hotdeal.alarm.domain.usecase.HotDealScraperManager
+
     private var downloadReceiver: BroadcastReceiver? = null
 
     override fun onCreate(savedInstanceState: Bundle?) {
@@ -216,7 +219,13 @@ class MainActivity : ComponentActivity() {
     override fun onResume() {
         super.onResume()
         if (isInBackground) {
-            workerScheduler.executeOnce()
+            lifecycleScope.launch {
+                try {
+                    scraperManager.fetchAndProcessDeals()
+                } catch (e: Exception) {
+                    // 무시
+                }
+            }
         }
         isInBackground = false
     }

app/src/main/java/com/hotdeal/alarm/presentation/main/MainViewModel.kt

@@ -10,6 +10,7 @@ import com.hotdeal.alarm.data.local.db.entity.SiteConfigEntity
 import com.hotdeal.alarm.data.local.preferences.AppSettings
 import com.hotdeal.alarm.domain.model.Keyword
 import com.hotdeal.alarm.domain.model.SiteType
+import com.hotdeal.alarm.domain.usecase.HotDealScraperManager
 import com.hotdeal.alarm.worker.WorkerScheduler
 import dagger.hilt.android.lifecycle.HiltViewModel
 import kotlinx.coroutines.flow.*
@@ -21,6 +22,7 @@ class MainViewModel @Inject constructor(
     private val hotDealDao: HotDealDao,
     private val siteConfigDao: SiteConfigDao,
     private val keywordDao: KeywordDao,
+    private val scraperManager: HotDealScraperManager,
     private val workerScheduler: WorkerScheduler,
     private val appSettings: AppSettings
 ) : ViewModel() {
@@ -28,6 +30,10 @@ class MainViewModel @Inject constructor(
     private val _uiState = MutableStateFlow<MainUiState>(MainUiState.Loading)
     val uiState: StateFlow<MainUiState> = _uiState.asStateFlow()
 
+    // 새로고침 진행 상태
+    private val _isRefreshing = MutableStateFlow(false)
+    val isRefreshing: StateFlow<Boolean> = _isRefreshing.asStateFlow()
+
     // 폴링 주기
     val pollingInterval: StateFlow<Int> = appSettings.pollingInterval
         .stateIn(viewModelScope, SharingStarted.Eagerly, 2)
@@ -44,18 +50,19 @@ class MainViewModel @Inject constructor(
     }
 
     private fun initializeApp() {
-        // 1. 사이트 설정 초기화 후 DB Flow 구독 (별도 코루틴 — collect는 영원히 suspend)
+        // 1. 사이트 설정 초기화 후 DB Flow 구독 (별도 코루틴 — collect는 지속 실행)
         viewModelScope.launch {
             initializeDefaultSiteConfigs()
-            loadState()  // combine().collect — 이 코루틴은 영원히 살아있음
+            loadState()
         }
 
-        // 2. 백그라운드 폴링 등록 + 즉시 1회 스크래핑 (별도 코루틴)
+        // 2. 백그라운드 폴링 등록 + 앱 진입 즉시 직접 1회 스크래핑 실행
         viewModelScope.launch {
             val savedInterval = appSettings.pollingInterval.first()
             workerScheduler.schedulePeriodicPolling(savedInterval.toLong())
-            // 앱 시작 시 즉시 1회 실행하여 최신 데이터 갱신
-            workerScheduler.executeOnce()
+            
+            // 지연 없는 직접 스크래핑 실행 -> Room Flow를 통해 메인화면에 즉시 반영됨!
+            refresh()
         }
     }
 
@@ -70,7 +77,7 @@ class MainViewModel @Inject constructor(
                     siteName = site.name,
                     boardName = board.id,
                     displayName = "${site.displayName} - ${board.displayName}",
-                    isEnabled = true // 기본값: 활성화 (설치 즉시 수집 작동)
+                    isEnabled = true // 기본 활성화 (설치 즉시 수집 가동)
                 )
             }
         }
@@ -88,7 +95,6 @@ class MainViewModel @Inject constructor(
             keywordDao.observeAllKeywords(),
             appSettings.keywordOrder
         ) { deals, configs, keywords, keywordOrder ->
-            // 사용자가 설정한 키워드 순서에 따라 정렬
             val domainKeywords = keywords.map { it.toDomain() }
             val sortedKeywords = if (keywordOrder.isEmpty()) {
                 domainKeywords
@@ -112,12 +118,14 @@ class MainViewModel @Inject constructor(
     fun toggleSiteConfig(siteBoardKey: String, enabled: Boolean) {
         viewModelScope.launch {
             siteConfigDao.updateEnabled(siteBoardKey, enabled)
+            // 사이트 활성화 변경 시 즉시 새 핫딜 갱신
+            if (enabled) {
+                refresh()
+            }
         }
     }
 
     fun reorderSites(fromIndex: Int, toIndex: Int) {
-        // siteOrder는 appSettings.siteOrder에서 stateIn으로 가져오므로
-        // appSettings를 즉시 저장하고 Flow가 업데이트되도록 함
         val current = siteOrder.value.toMutableList()
         if (fromIndex in current.indices && toIndex in current.indices) {
             val item = current.removeAt(fromIndex)
@@ -140,6 +148,8 @@ class MainViewModel @Inject constructor(
             val currentOrder = appSettings.keywordOrder.first().toMutableList()
             currentOrder.add(0, newId)
             appSettings.setKeywordOrder(currentOrder)
+            // 키워드 등록 후 매칭 검사를 위해 즉시 갱신
+            refresh()
         }
     }
 
@@ -155,19 +165,19 @@ class MainViewModel @Inject constructor(
     fun toggleKeyword(id: Long, enabled: Boolean) {
         viewModelScope.launch {
             keywordDao.updateEnabled(id, enabled)
+            if (enabled) {
+                refresh()
+            }
         }
     }
 
     fun reorderKeywords(fromIndex: Int, toIndex: Int) {
-        // uiState를 동기적으로 즉시 업데이트하여 빠른 드래그 시 stale 데이터 방지
         val state = _uiState.value as? MainUiState.Success ?: return
         val current = state.keywords.toMutableList()
         if (fromIndex in current.indices && toIndex in current.indices) {
             val item = current.removeAt(fromIndex)
             current.add(toIndex, item)
-            // UI 즉시 갱신
             _uiState.value = state.copy(keywords = current)
-            // DataStore 비동기 영속화
             viewModelScope.launch {
                 appSettings.setKeywordOrder(current.map { it.id })
             }
@@ -186,8 +196,20 @@ class MainViewModel @Inject constructor(
         }
     }
 
+    /**
+     * 직접 즉시 스크래핑 실행 (WorkManager 큐 대기 지연 없이 UI 및 DB 즉시 갱신)
+     */
     fun refresh() {
-        workerScheduler.executeOnce()
+        viewModelScope.launch {
+            _isRefreshing.value = true
+            try {
+                scraperManager.fetchAndProcessDeals()
+            } catch (e: Exception) {
+                // 에러 발생 시 무시 (UI는 DB Flow로 유지)
+            } finally {
+                _isRefreshing.value = false
+            }
+        }
     }
 
     fun startPolling(intervalMinutes: Long = WorkerScheduler.DEFAULT_INTERVAL_MINUTES) {

app/src/main/java/com/hotdeal/alarm/presentation/settings/SettingsScreen.kt

@@ -140,8 +140,17 @@ fun SettingsScreen(viewModel: MainViewModel) {
                     permissionStatus = permissionStatus,
                     currentPollingInterval = currentPollingInterval,
                     onRequestPermission = {
-                        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.TIRAMISU) {
-                            notificationPermissionLauncher.launch(Manifest.permission.POST_NOTIFICATIONS)
+                        if (!permissionStatus.hasNotificationPermission) {
+                            if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.TIRAMISU) {
+                                notificationPermissionLauncher.launch(Manifest.permission.POST_NOTIFICATIONS)
+                            } else {
+                                PermissionHelper.openNotificationSettings(context)
+                            }
+                        } else if (!permissionStatus.hasExactAlarmPermission) {
+                            permissionDialogTitle = "알람 및 리마인더 권한 필요"
+                            permissionDialogMessage = "화면이 꺼져있을 때도 실시간 핫딜 알림을 받으려면 '알람 및 리마인더' 권한 허용이 필요합니다."
+                            permissionDialogAction = { PermissionHelper.openExactAlarmSettings(context) }
+                            showPermissionDialog = true
                         }
                     }
                 )
@@ -216,13 +225,19 @@ private fun NotificationTab(
                         Text("실시간 모니터링 요약", style = MaterialTheme.typography.titleSmall, fontWeight = FontWeight.Bold)
                     }
                     Spacer(modifier = Modifier.height(10.dp))
+                    val isPermissionOk = permissionStatus.hasNotificationPermission && permissionStatus.hasExactAlarmPermission
+                    val permText = when {
+                        !permissionStatus.hasNotificationPermission -> "알림권한 필요"
+                        !permissionStatus.hasExactAlarmPermission -> "알람권한 필요"
+                        else -> "실시간 가동"
+                    }
                     Row(modifier = Modifier.fillMaxWidth(), horizontalArrangement = Arrangement.spacedBy(8.dp)) {
                         BentoMiniTile(
                             title = "알림 상태",
-                            value = if (permissionStatus.hasNotificationPermission) "정상 가동" else "권한 필요",
-                            isHighlight = !permissionStatus.hasNotificationPermission,
+                            value = permText,
+                            isHighlight = !isPermissionOk,
                             modifier = Modifier.weight(1f),
-                            onClick = if (!permissionStatus.hasNotificationPermission) onRequestPermission else null
+                            onClick = if (!isPermissionOk) onRequestPermission else null
                         )
                         BentoMiniTile(title = "감시 주기", value = "${currentPollingInterval}분 간격", modifier = Modifier.weight(1f))
                     }

app/src/main/java/com/hotdeal/alarm/receiver/PollingAlarmReceiver.kt

@@ -5,6 +5,7 @@ import android.content.Context
 import android.content.Intent
 import android.util.Log
 import com.hotdeal.alarm.data.local.preferences.AppSettings
+import com.hotdeal.alarm.domain.usecase.HotDealScraperManager
 import com.hotdeal.alarm.worker.AlarmScheduler
 import com.hotdeal.alarm.worker.WorkerScheduler
 import dagger.hilt.android.AndroidEntryPoint
@@ -16,7 +17,9 @@ import kotlinx.coroutines.launch
 import javax.inject.Inject
 
 /**
- * 주기적 알람 수신 시 백그라운드 스크래핑을 실행하고 다음 알람을 예약하는 리시버
+ * 주기적 알람 수신 시 백그라운드 스크래핑을 즉시 실행하고 다음 알람을 예약하는 리시버
+ * 
+ * goAsync()를 사용하여 WorkManager의 Doze 지연 없이 백그라운드에서 즉시 핫딜을 수집하고 알림을 발송합니다.
  */
 @AndroidEntryPoint
 class PollingAlarmReceiver : BroadcastReceiver() {
@@ -26,7 +29,7 @@ class PollingAlarmReceiver : BroadcastReceiver() {
     }
 
     @Inject
-    lateinit var workerScheduler: WorkerScheduler
+    lateinit var scraperManager: HotDealScraperManager
 
     @Inject
     lateinit var alarmScheduler: AlarmScheduler
@@ -34,24 +37,33 @@ class PollingAlarmReceiver : BroadcastReceiver() {
     @Inject
     lateinit var appSettings: AppSettings
 
-    private val scope = CoroutineScope(SupervisorJob() + Dispatchers.IO)
+    private val receiverScope = CoroutineScope(SupervisorJob() + Dispatchers.IO)
 
     override fun onReceive(context: Context, intent: Intent) {
         if (intent.action == AlarmScheduler.ACTION_POLL_ALARM) {
-            Log.d(TAG, "⏰ 폴링 알람 수신 -> 핫딜 스크래핑 1회 즉시 실행 및 다음 알람 예약")
-            
-            // 1. 핫딜 스크래핑 실행
-            workerScheduler.executeOnce()
+            Log.d(TAG, "⏰ [실시간 알람 수신] 백그라운드 스크래핑 즉시 시작 및 다음 알람 예약")
 
-            // 2. 다음 주기 알람 예약 (Self-rescheduling)
-            scope.launch {
+            val pendingResult = goAsync()
+
+            receiverScope.launch {
                 try {
-                    val interval = appSettings.pollingInterval.first().toLong()
-                    alarmScheduler.scheduleAlarm(interval)
-                    Log.d(TAG, "다음 폴링 알람 예약 완료: ${interval}분 후")
+                    // 1. 백그라운드에서 직접 스크래핑, DB 저장, 키워드 알림 즉시 발송!
+                    val newDeals = scraperManager.fetchAndProcessDeals()
+                    Log.d(TAG, "⏰ [스크래핑 완료] 신규 핫딜 ${newDeals.size}개 처리됨")
                 } catch (e: Exception) {
-                    Log.e(TAG, "다음 알람 예약 실패: ${e.message}")
-                    alarmScheduler.scheduleAlarm(WorkerScheduler.DEFAULT_INTERVAL_MINUTES)
+                    Log.e(TAG, "알람 처리 중 오류: ${e.message}", e)
+                } finally {
+                    // 2. 다음 주기 알람 예약 (Self-rescheduling)
+                    try {
+                        val interval = appSettings.pollingInterval.first().toLong()
+                        alarmScheduler.scheduleAlarm(interval)
+                        Log.d(TAG, "⏰ 다음 폴링 알람 예약 완료: ${interval}분 후")
+                    } catch (e: Exception) {
+                        Log.e(TAG, "다음 알람 예약 실패: ${e.message}")
+                        alarmScheduler.scheduleAlarm(WorkerScheduler.DEFAULT_INTERVAL_MINUTES)
+                    }
+
+                    pendingResult.finish()
                 }
             }
         }

app/src/main/java/com/hotdeal/alarm/worker/HotDealPollingWorker.kt

@@ -6,33 +6,20 @@ import androidx.hilt.work.HiltWorker
 import androidx.work.CoroutineWorker
 import androidx.work.ForegroundInfo
 import androidx.work.WorkerParameters
-import com.hotdeal.alarm.data.local.db.entity.HotDealEntity
-import com.hotdeal.alarm.data.local.db.entity.KeywordEntity
-import com.hotdeal.alarm.data.local.db.entity.SiteConfigEntity
-import com.hotdeal.alarm.data.remote.scraper.ScraperFactory
-import com.hotdeal.alarm.domain.model.HotDeal
+import com.hotdeal.alarm.domain.usecase.HotDealScraperManager
 import com.hotdeal.alarm.service.NotificationService
 import dagger.assisted.Assisted
 import dagger.assisted.AssistedInject
-import kotlinx.coroutines.Dispatchers
-import kotlinx.coroutines.async
-import kotlinx.coroutines.awaitAll
-import kotlinx.coroutines.withContext
 
 /**
- * 핫딜 폴� Worker
- * 
- * 키워드 매칭된 핫딜만 알림 발송
+ * 핫딜 폴링 Worker (WorkManager 전용)
  */
 @HiltWorker
 class HotDealPollingWorker @AssistedInject constructor(
     @Assisted private val context: Context,
     @Assisted workerParams: WorkerParameters,
-    private val scraperFactory: ScraperFactory,
-    private val notificationService: NotificationService,
-    private val dealDao: com.hotdeal.alarm.data.local.db.dao.HotDealDao,
-    private val siteConfigDao: com.hotdeal.alarm.data.local.db.dao.SiteConfigDao,
-    private val keywordDao: com.hotdeal.alarm.data.local.db.dao.KeywordDao
+    private val scraperManager: HotDealScraperManager,
+    private val notificationService: NotificationService
 ) : CoroutineWorker(context, workerParams) {
     
     companion object {
@@ -40,153 +27,18 @@ class HotDealPollingWorker @AssistedInject constructor(
         const val TAG = "HotDealPolling"
     }
     
-    override suspend fun doWork(): Result = withContext(Dispatchers.IO) {
-        try {
-            Log.d(TAG, "===== 핫딜 폴� 시작 =====")
-            
-            // 1. 활성화된 사이트 설정 조회
-            val enabledConfigs = siteConfigDao.getEnabledConfigs()
-            Log.d(TAG, "활성화된 사이트 설정: ${enabledConfigs.size}개")
-            
-            if (enabledConfigs.isEmpty()) {
-                Log.w(TAG, "활성화된 사이트 설정이 없습니다.")
-                return@withContext Result.success()
-            }
-
-            // 2. 활성화된 키워드 조회
-            val keywords = keywordDao.getEnabledKeywords()
-            Log.d(TAG, "활성화된 키워드: ${keywords.size}개")
-
-            // 3. 각 사이트/게시판 스크래핑 (병렬)
-            Log.d(TAG, "스크래핑 시작...")
-            val allDeals = enabledConfigs.map { config ->
-                async {
-                    scrapeSite(config)
-                }
-            }.awaitAll().flatten()
-
-            Log.d(TAG, "스크래핑 완료: 총 ${allDeals.size}개 핫딜")
-            
-            if (allDeals.isEmpty()) {
-                Log.w(TAG, "스크래핑된 핫딜이 없습니다.")
-                return@withContext Result.success()
-            }
-
-            // 4. 새로운 핫딜 필터링
-            val newDeals = filterNewDeals(allDeals)
-            Log.d(TAG, "새로운 핫딜: ${newDeals.size}개")
-
-            if (newDeals.isEmpty()) {
-                Log.d(TAG, "새로운 핫딜이 없습니다.")
-                return@withContext Result.success()
-            }
-
-            // 5. 키워드 매칭 (키워드가 있을 때만)
-            val keywordMatchedDeals = if (keywords.isNotEmpty()) {
-                filterByKeywords(newDeals, keywords).also {
-                    Log.d(TAG, "키워드 매칭 핫딜: ${it.size}개")
-                }
-            } else {
-                Log.d(TAG, "키워드가 없어 매칭 체크를 건�뜁니다.")
-                emptyList()
-            }
-
-            // 6. DB 저장
-            var insertedCount = 0
-            newDeals.forEach { deal ->
-                try {
-                    val entity = HotDealEntity.fromDomain(deal)
-                    dealDao.insertDeal(entity)
-                    insertedCount++
-                } catch (e: Exception) {
-                    Log.w(TAG, "핫딜 저장 실패 (무시됨): ${deal.id}")
-                }
-            }
-            Log.d(TAG, "DB 저장 완료: $insertedCount/${newDeals.size}개 저장됨")
-
-            // 7. 키워드 매칭 알림 발송 (키워드 매칭된 것만!)
-            if (keywordMatchedDeals.isNotEmpty()) {
-                Log.d(TAG, "키워드 매칭 알림 발송: ${keywordMatchedDeals.size}개")
-                notificationService.showKeywordMatchNotification(keywordMatchedDeals)
-                dealDao.markAsKeywordMatch(keywordMatchedDeals.map { it.id })
-            } else {
-                Log.d(TAG, "키워드 매칭된 핫딜이 없어 알림을 발송하지 않습니다.")
-            }
-
-            // 8. 알림 발송 상태 업데이트
-            dealDao.markAsNotified(newDeals.map { it.id })
-
-            // 9. 인기글 상태 업데이트 (신규+기존 딜 모두 HOT 마킹)
-            val popularDealIds = allDeals.filter { it.isPopular }.map { it.id }
-            if (popularDealIds.isNotEmpty()) {
-                dealDao.markAsPopular(popularDealIds)
-                Log.d(TAG, "인기글 마킹: ${popularDealIds.size}개")
-            }
-
- // 10. 오래된 데이터 정리 (3일 이상 - 배터리/데이터 절약)
- val threshold = System.currentTimeMillis() - (3 * 24 * 60 * 60 * 1000L)
- dealDao.deleteOldDeals(threshold)
-
-            Log.d(TAG, "===== 핫딜 폴 완료 =====")
+    override suspend fun doWork(): Result {
+        Log.d(TAG, "WorkManager HotDealPollingWorker 실행됨")
+        return try {
+            scraperManager.fetchAndProcessDeals()
             Result.success()
         } catch (e: Exception) {
-            Log.e(TAG, "폴� 오류: ${e.message}", e)
-            if (runAttemptCount < 3) {
-                Result.retry()
-            } else {
-                Result.failure()
-            }
+            Log.e(TAG, "Worker 실행 실패: ${e.message}", e)
+            if (runAttemptCount < 3) Result.retry() else Result.failure()
         }
     }
     
     override suspend fun getForegroundInfo(): ForegroundInfo {
         return notificationService.createForegroundInfo()
     }
-    
-    private suspend fun scrapeSite(config: SiteConfigEntity): List<HotDeal> {
-        val scraper = scraperFactory.getScraper(config.siteName)
-        if (scraper == null) {
-            Log.w(TAG, "스크래퍼를 찾을 수 없음: ${config.siteName}")
-            return emptyList()
-        }
-
-        Log.d(TAG, "스크래핑: ${config.siteName}/${config.boardName}")
-        val result = scraper.scrape(config.boardName)
-        
-        result.fold(
-            onSuccess = { deals ->
-                Log.d(TAG, " ${config.siteName}: ${deals.size}개 핫딜 파싱됨")
-                try {
-                    siteConfigDao.updateLastScrapedAt(config.siteBoardKey, System.currentTimeMillis())
-                } catch (e: Exception) {
-                    Log.w(TAG, "lastScrapedAt 업데이트 실패: ${config.siteBoardKey}")
-                }
-            },
-            onFailure = { error ->
-                Log.e(TAG, " ${config.siteName} 스크래핑 실패: ${error.message}")
-            }
-        )
-
-        return result.getOrElse { emptyList() }
-    }
-    
-    private suspend fun filterNewDeals(deals: List<HotDeal>): List<HotDeal> {
-        return deals.filter { deal ->
-            val existingByUrl = dealDao.getDealByUrl(deal.url)
-            if (existingByUrl != null) return@filter false
-            
-            val existingById = dealDao.getDealById(deal.id)
-            if (existingById != null) return@filter false
-            
-            true
-        }
-    }
-    
-    private fun filterByKeywords(deals: List<HotDeal>, keywords: List<KeywordEntity>): List<HotDeal> {
-        return deals.filter { deal ->
-            keywords.any { keyword ->
-                deal.title.contains(keyword.keyword, ignoreCase = true)
-            }
-        }
-    }
 }

version.json

@@ -1,7 +1,7 @@
 {
-  "version": "0.3.4",
-  "versionCode": 34,
-  "updateUrl": "https://git.webpluss.net/sanjeok77/hotdeal_alarm/releases/download/v0.3.4/app-release.apk",
+  "version": "0.3.5",
+  "versionCode": 35,
+  "updateUrl": "https://git.webpluss.net/sanjeok77/hotdeal_alarm/releases/download/v0.3.5/app-release.apk",
   "changelog": [
     "사이트 및 키워드 순서 조절을 터치 드래그 앤 드롭(Drag & Drop) 방식으로 전면 업그레이드",
     "앱 내 업데이트 시 다운로드 완료 후 설치 화면으로 안 넘어가는 버그 수정",