[NO-ISSUE] Change references

Merge branch 'feature/NO-ISSUE-v2' into develop
[NO-ISSUE] Remove reader, processor, writer
2024-05-09 09:32:39 +09:00 · 2024-05-09 08:50:05 +09:00 · 2024-05-09 08:49:11 +09:00 · 2024-05-09 08:48:36 +09:00 · 2024-04-30 22:34:49 +09:00 · 2022-01-02 12:50:21 +09:00
155 changed files with 2712 additions and 1617 deletions
--- a/.gitignore
+++ b/.gitignore
@ -37,3 +37,6 @@ out/
 .vscode/

 temppassword.yml
+data.sql
+**/src/main/resources/slack
+**/src/main/resources/datasource
--- a/build.gradle
+++ b/build.gradle
@ -1,13 +1,13 @@
 plugins {
-    id 'org.springframework.boot' version '2.5.4'
-    id 'io.spring.dependency-management' version '1.0.11.RELEASE'
    id 'java'
    id 'idea'
+    id 'org.springframework.boot' version '2.5.4'
+    id 'io.spring.dependency-management' version '1.0.11.RELEASE'
 }

-group = 'com.myoa.engineering.crawl.ppomppu'
+group = 'com.myoa.engineering.crawl.shopping'
 version = '1.1.1'
-sourceCompatibility = '11'
+sourceCompatibility = JavaVersion.VERSION_17

 configurations {
    compileOnly {
@ -20,7 +20,7 @@ repositories {
 }

 allprojects {
-    group = 'com.myoa.engineering.crawl.ppomppu'
+    group = 'com.myoa.engineering.crawl.shopping'
    version = '1.1.1'

    apply plugin: 'java'
--- a/gradle/wrapper/gradle-wrapper.properties
+++ b/gradle/wrapper/gradle-wrapper.properties
@ -1,5 +1,6 @@
+#Sun Apr 28 23:47:38 KST 2024
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-7.1.1-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-8.5-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists
--- a/0
+++ b/0
--- a/processor/build.gradle
+++ b/processor/build.gradle
@ -1,30 +0,0 @@
-
-dependencies {
-    developmentOnly 'org.springframework.boot:spring-boot-devtools'
-    runtimeOnly 'com.h2database:h2'
-    runtimeOnly 'mysql:mysql-connector-java'
-    compileOnly 'org.projectlombok:lombok'
-
-    implementation project(':support')
-    // https://projectreactor.io/docs/core/release/reference/#debug-activate
-    implementation 'org.springframework.boot:spring-boot-starter-webflux'
-    implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
-    implementation 'org.springframework.boot:spring-boot-starter-jdbc'
-    implementation 'org.springframework.cloud:spring-cloud-starter-config'
-    implementation 'org.springframework.boot:spring-boot-starter-actuator'
-    implementation 'com.rometools:rome:1.16.0'
-    implementation 'org.jsoup:jsoup:1.14.2'
-    implementation 'com.h2database:h2:1.4.200'
-
-    annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
-    annotationProcessor 'org.projectlombok:lombok'
-
-    testImplementation 'org.springframework.boot:spring-boot-starter-test'
-}
-
-test {
-    useJUnitPlatform()
-    testLogging {
-        events "passed", "skipped", "failed"
-    }
-}
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/ProcessorApplication.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/ProcessorApplication.java
@ -1,23 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.processor;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.context.annotation.Import;
-
-import com.myoa.engineering.crawl.ppomppu.support.webclient.PpomppuNotifierWebClientConfiguration;
-
-/**
- * ProcessorApplication
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-08-20
- *
- */
-@Import({ PpomppuNotifierWebClientConfiguration.class })
-@SpringBootApplication
-public class ProcessorApplication {
-
-    public static void main(String[] args) {
-        SpringApplication.run(ProcessorApplication.class, args);
-    }
-
-}
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/controller/CrawlAPIController.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/controller/CrawlAPIController.java
@ -1,4 +1,4 @@
-package com.myoa.engineering.crawl.ppomppu.processor.controller;
+package com.myoa.engineering.crawl.shopping.controller;

 import java.util.List;

@ -7,13 +7,13 @@ import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;

-import com.myoa.engineering.crawl.ppomppu.processor.domain.PpomppuArticle;
-import com.myoa.engineering.crawl.ppomppu.processor.dto.FeedParsedResult;
-import com.myoa.engineering.crawl.ppomppu.processor.service.MessageSenderService;
-import com.myoa.engineering.crawl.ppomppu.processor.service.PpomppuArticleService;
-import com.myoa.engineering.crawl.ppomppu.processor.service.PpomppuFeedService;
-import com.myoa.engineering.crawl.ppomppu.support.dto.APIResponse;
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
+import com.myoa.engineering.crawl.shopping.processor.domain.PpomppuArticle;
+import com.myoa.engineering.crawl.shopping.processor.dto.FeedParsedResult;
+import com.myoa.engineering.crawl.shopping.processor.service.MessageSenderService;
+import com.myoa.engineering.crawl.shopping.processor.service.PpomppuArticleService;
+import com.myoa.engineering.crawl.shopping.processor.service.PpomppuFeedService;
+import com.myoa.engineering.crawl.shopping.support.dto.APIResponse;
+import com.myoa.engineering.crawl.shopping.support.dto.code.PpomppuBoardName;

 import lombok.extern.slf4j.Slf4j;
 import reactor.core.publisher.Mono;
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/domain/SubscribedBoard.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/domain/SubscribedBoard.java
@ -1,32 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.processor.domain;
-
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.EnumType;
-import javax.persistence.Enumerated;
-import javax.persistence.GeneratedValue;
-import javax.persistence.GenerationType;
-import javax.persistence.Id;
-import javax.persistence.Table;
-import lombok.Getter;
-import lombok.NoArgsConstructor;
-
-@Getter
-@NoArgsConstructor
-@Entity
-@Table(name = "subscribed_board")
-public class SubscribedBoard extends Auditable {
-
-    @Id
-    @GeneratedValue(strategy = GenerationType.IDENTITY)
-    private Long id;
-
-    @Column
-    private Long userId;
-
-    @Column
-    @Enumerated(EnumType.STRING)
-    private PpomppuBoardName boardName;
-
-}
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/dto/PpomppuArticleParser.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/dto/PpomppuArticleParser.java
@ -1,10 +1,10 @@
-package com.myoa.engineering.crawl.ppomppu.processor.dto;
+package com.myoa.engineering.crawl.shopping.dto;

 import org.jsoup.nodes.Element;
 import org.jsoup.select.Elements;

-import com.myoa.engineering.crawl.ppomppu.processor.domain.PpomppuArticle;
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
+import com.myoa.engineering.crawl.shopping.processor.domain.PpomppuArticle;
+import com.myoa.engineering.crawl.shopping.support.dto.code.PpomppuBoardName;

 /**
 * PpomppuArticleTransformer
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/infrastructure/client/MessageSenderAPIClient.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/infrastructure/client/MessageSenderAPIClient.java
@ -1,70 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.processor.infrastructure.client;
-
-import org.springframework.core.ParameterizedTypeReference;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.MediaType;
-import org.springframework.stereotype.Component;
-import org.springframework.web.reactive.function.client.WebClient;
-import org.springframework.web.reactive.function.client.WebClientRequestException;
-
-import com.myoa.engineering.crawl.ppomppu.processor.dto.constant.WebClientPropertiesUnitName;
-import com.myoa.engineering.crawl.ppomppu.support.dto.BlockMessageDTO;
-import com.myoa.engineering.crawl.ppomppu.support.dto.SimpleMessageDTO;
-import com.myoa.engineering.crawl.ppomppu.support.webclient.factory.WebClientFilterFactory;
-import com.myoa.engineering.crawl.ppomppu.support.webclient.factory.WebFluxExchangeStragiesFactory;
-import com.myoa.engineering.crawl.ppomppu.support.webclient.properties.WebClientProperties;
-import com.myoa.engineering.crawl.ppomppu.support.webclient.properties.WebClientProperties.WebClientPropertiesUnit;
-
-import lombok.extern.slf4j.Slf4j;
-import reactor.core.publisher.Mono;
-import reactor.core.scheduler.Schedulers;
-
-/**
- * PpomppuNotifierSenderAPIClient
- *
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-11-17
- */
-@Slf4j
-@Component
-public class MessageSenderAPIClient {
-
-    private final WebClient webClient;
-
-    public MessageSenderAPIClient(WebClientProperties webClientProperties) {
-        WebClientPropertiesUnit webClientPropertiesUnit =
-            webClientProperties.find(WebClientPropertiesUnitName.PPOMPPU_NOTIFIER_SENDER_API.getUnitName());
-        this.webClient = WebClient.builder()
-                                  .baseUrl(webClientPropertiesUnit.getBaseUrl())
-                                  .exchangeStrategies(WebFluxExchangeStragiesFactory.ofDefault())
-                                  .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)
-//                                  .filter(WebClientFilterFactory.logRequest())
-//                                  .filter(WebClientFilterFactory.logResponse())
-                                  .build();
-    }
-
-    public Mono<String> sendSimpleMessageToSlack(SimpleMessageDTO dto) {
-        return webClient.post()
-                        .uri("/api/v1/messages/sendSimpleMessage/messengers/slack")
-                        .bodyValue(dto)
-                        .exchangeToMono(e -> e.bodyToMono(new ParameterizedTypeReference<String>() {}))
-                        .publishOn(Schedulers.boundedElastic())
-                        .onErrorResume(WebClientRequestException.class, t -> {
-                            log.info("Exception occured, ignoring. : {}", t.getClass().getSimpleName());
-                            return Mono.empty();
-                        });
-    }
-
-
-    public Mono<String> sendBlockMessageToSlack(BlockMessageDTO dto) {
-        return webClient.post()
-                        .uri("/api/v1/messages/sendBlockMessage/messengers/slack")
-                        .bodyValue(dto)
-                        .exchangeToMono(e -> e.bodyToMono(new ParameterizedTypeReference<String>() {}))
-                        .publishOn(Schedulers.boundedElastic())
-                        .onErrorResume(WebClientRequestException.class, t -> {
-                            log.info("Exception occured, ignoring. : {}", t.getClass().getSimpleName());
-                            return Mono.empty();
-                        });
-    }
-}
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/infrastructure/repository/BaseScanRepository.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/infrastructure/repository/BaseScanRepository.java
@ -1,4 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.processor.infrastructure.repository;
-
-public interface BaseScanRepository {
-}
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/service/MessageSenderService.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/service/MessageSenderService.java
@ -1,44 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.processor.service;
-
-import java.util.List;
-
-import org.springframework.stereotype.Service;
-
-import com.myoa.engineering.crawl.ppomppu.processor.domain.PpomppuArticle;
-import com.myoa.engineering.crawl.ppomppu.processor.dto.PpomppuArticleTransformer;
-import com.myoa.engineering.crawl.ppomppu.processor.infrastructure.client.MessageSenderAPIClient;
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
-
-import lombok.extern.slf4j.Slf4j;
-import reactor.core.publisher.Mono;
-
-/**
- * MessageSenderService
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-11-21
- *
- */
-@Slf4j
-@Service
-public class MessageSenderService {
-
-    private final MessageSenderAPIClient messageSenderAPIClient;
-
-    public MessageSenderService(MessageSenderAPIClient messageSenderAPIClient) {
-        this.messageSenderAPIClient = messageSenderAPIClient;
-    }
-
-    public Mono<String> sendSimpleMessageToSlack(PpomppuArticle article) {
-        return messageSenderAPIClient.sendSimpleMessageToSlack(PpomppuArticleTransformer.TRANSFORM_TO_MESSAGE_DTO.apply(article));
-    }
-
-    public Mono<String> sendSimpleMessageToSlack(List<PpomppuArticle> articles) {
-        return messageSenderAPIClient.sendSimpleMessageToSlack(PpomppuArticleTransformer.transformToSimpleMessage(articles));
-    }
-
-    public Mono<String> sendBlockMessageToSlack(PpomppuBoardName boardName, List<PpomppuArticle> articles) {
-        return messageSenderAPIClient.sendBlockMessageToSlack(
-            PpomppuArticleTransformer.transformToBlockMessage(boardName, articles));
-    }
-
-}
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/service/PpomppuFeedService.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/service/PpomppuFeedService.java
@ -1,66 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.processor.service;
-
-import java.util.Comparator;
-import java.util.List;
-
-import org.jsoup.Jsoup;
-import org.jsoup.nodes.Element;
-import org.springframework.stereotype.Component;
-
-import com.myoa.engineering.crawl.ppomppu.processor.domain.PpomppuArticle;
-import com.myoa.engineering.crawl.ppomppu.processor.dto.PpomppuArticleParser;
-import com.myoa.engineering.crawl.ppomppu.processor.infrastructure.client.PpomppuBoardFeedRetriever;
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
-
-import lombok.extern.slf4j.Slf4j;
-import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
-
-/**
- * PpomppuFeedService
- *
- * @author Shin Woo-jin (woozu.shin@kakaoent.com)
- * @since 2021-09-08
- */
-@Slf4j
-@Component
-public class PpomppuFeedService {
-
-    private final PpomppuBoardFeedRetriever ppomppuBoardFeedRetriever;
-
-    public PpomppuFeedService(PpomppuBoardFeedRetriever ppomppuBoardFeedRetriever) {
-        this.ppomppuBoardFeedRetriever = ppomppuBoardFeedRetriever;
-    }
-
-    public Mono<List<PpomppuArticle>> getArticles(PpomppuBoardName boardName) {
-        final Mono<String> html = ppomppuBoardFeedRetriever.getHtml(boardName.getResourcePath());
-        final Mono<Element> tbody = extractTbodyFromHtml(html);
-        // .doOnNext(e -> log.info("pre tbody - {}", e.html()));
-        return extractArticlesFromTbody(tbody).map(this::convertFromElement)
-                                              .onErrorContinue((t, e) -> log.error("Error occured : {}, value: {}",
-                                                                                   e, t.getLocalizedMessage()))
-                                              .map(e -> e.updateBoardName(boardName))
-                                              .sort(Comparator.comparing(PpomppuArticle::getArticleId))
-                                              // .doOnNext(e -> log.info("parsed Result: {}", e))
-                                              .collectList();
-    }
-
-    private Mono<Element> extractTbodyFromHtml(Mono<String> html) {
-        return html.map(Jsoup::parse)
-                   .mapNotNull(e -> e.getElementById("revolution_main_table"))
-                   .map(e -> e.getElementsByTag("tbody"))
-                   // .doOnNext(e -> log.info("tbody - {}", e.html()))
-                   .map(e -> e.stream()
-                              .findFirst()
-                              .orElseThrow(() -> new IndexOutOfBoundsException("no tbody")));
-    }
-
-    private Flux<Element> extractArticlesFromTbody(Mono<Element> tbody) {
-        return Flux.concat(tbody.flatMapMany(e -> Flux.fromArray(e.select("tr.list0").toArray(Element[]::new))),
-                           tbody.flatMapMany(e -> Flux.fromArray(e.select("tr.list1").toArray(Element[]::new))));
-    }
-
-    private PpomppuArticle convertFromElement(Element element) {
-        return PpomppuArticleParser.toArticle(element.getElementsByTag("td"));
-    }
-}
--- a/processor/src/main/resources/application-local.yml
+++ b/processor/src/main/resources/application-local.yml
@ -1,11 +0,0 @@
-spring:
-  config:
-    activate:
-      on-profile: local
-    import:
-      - "configserver:http://localhost:20085"
-
-server:
-  port: 20081
-
-    # import: optional:configserver:http://localhost:11080 # can be start up even config server was not found.
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/ReceiverApplication.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/ReceiverApplication.java
@ -1,25 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
-import org.springframework.context.annotation.Import;
-
-import com.myoa.engineering.crawl.ppomppu.receiver.configuration.properties.TelegramBotProperties;
-import com.myoa.engineering.crawl.ppomppu.support.webclient.PpomppuNotifierWebClientConfiguration;
-
-/**
- * ReceiverApplication
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-08-20
- *
- */
-@Import({ PpomppuNotifierWebClientConfiguration.class})
-@SpringBootApplication
-// @EnableConfigurationProperties({ TelegramBotProperties.class })
-public class ReceiverApplication {
-
-    public static void main(String[] args) {
-        SpringApplication.run(ReceiverApplication.class, args);
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/configuration/TelegramBotConfiguration.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/configuration/TelegramBotConfiguration.java
@ -1,39 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.configuration;
-
-import java.util.List;
-
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.telegram.telegrambots.meta.TelegramBotsApi;
-import org.telegram.telegrambots.meta.exceptions.TelegramApiException;
-import org.telegram.telegrambots.updatesreceivers.DefaultBotSession;
-
-import com.myoa.engineering.crawl.ppomppu.receiver.configuration.properties.TelegramBotProperties;
-import com.myoa.engineering.crawl.ppomppu.receiver.configuration.properties.TelegramBotProperties.TelegramBotPropertiesUnit;
-import com.myoa.engineering.crawl.ppomppu.receiver.dispatch.MessageDispatcher;
-import com.myoa.engineering.crawl.ppomppu.receiver.handler.message.MessageHandler;
-
-/**
- * TelegramBotConfiguration
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-08-21
- *
- */
-@Configuration
-public class TelegramBotConfiguration {
-
-    private static final String BOT_PROPERTIES_UNIT_NAME = "ppomppu_notify_bot";
-    @Bean
-    public TelegramBotsApi telegramBotsApi(MessageDispatcher messageDispatcher) throws TelegramApiException {
-        TelegramBotsApi api = new TelegramBotsApi(DefaultBotSession.class);
-        api.registerBot(messageDispatcher);
-        return api;
-    }
-
-    @Bean
-    public MessageDispatcher messageDispatcher(List<MessageHandler> messageHandlers,
-                                               TelegramBotProperties telegramBotProperties) {
-        TelegramBotPropertiesUnit propertiesUnit = telegramBotProperties.find(BOT_PROPERTIES_UNIT_NAME);
-        return new MessageDispatcher(messageHandlers, propertiesUnit.getName(), propertiesUnit.getToken());
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/configuration/properties/TelegramBotProperties.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/configuration/properties/TelegramBotProperties.java
@ -1,44 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.configuration.properties;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.springframework.boot.context.properties.ConfigurationProperties;
-import org.springframework.boot.context.properties.ConstructorBinding;
-import org.springframework.stereotype.Component;
-
-import lombok.AllArgsConstructor;
-import lombok.Data;
-import lombok.Getter;
-import lombok.NoArgsConstructor;
-import lombok.Setter;
-
-/**
- * TelegramBotProperties
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-09-05
- *
- */
-@Component
-@Setter
-@Getter
-@ConfigurationProperties(prefix = "infra.telegram.bot")
-public class TelegramBotProperties {
-
-    private List<TelegramBotPropertiesUnit> units = new ArrayList<>();
-
-    @Data
-    public static class TelegramBotPropertiesUnit {
-        private String unitName;
-        private String name;
-        private String token;
-    }
-
-    public TelegramBotPropertiesUnit find(String unitName) {
-        return units.stream()
-                    .filter(e -> e.getUnitName().equals(unitName))
-                    .findFirst()
-                    .orElseThrow(
-                        () -> new IllegalArgumentException(this.getClass().getName() + ": unitName Not found. " + unitName));
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/controller/v1/EventAPIController.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/controller/v1/EventAPIController.java
@ -1,33 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.controller.v1;
-
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import com.myoa.engineering.crawl.ppomppu.receiver.service.ProcessorAPIService;
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
-
-import reactor.core.publisher.Mono;
-
-/**
- * EventAPIController
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-09-05
- *
- */
-@RestController
-@RequestMapping("/api/v1/")
-public class EventAPIController {
-
-    private final ProcessorAPIService processorAPIService;
-
-    public EventAPIController(ProcessorAPIService processorAPIService) {
-        this.processorAPIService = processorAPIService;
-    }
-
-    @PostMapping("/exploit/parsePpomppuRSS/{boardName}")
-    public Mono<String> parsePpomppuRSS(@PathVariable("boardName") PpomppuBoardName boardName) {
-        return processorAPIService.emitParseEvent(boardName);
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/dispatch/MessageDispatcher.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/dispatch/MessageDispatcher.java
@ -1,50 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.dispatch;
-
-import java.util.List;
-
-import org.telegram.telegrambots.bots.TelegramLongPollingBot;
-import org.telegram.telegrambots.meta.api.objects.Message;
-import org.telegram.telegrambots.meta.api.objects.Update;
-
-import com.myoa.engineering.crawl.ppomppu.receiver.handler.message.MessageHandler;
-
-import lombok.extern.slf4j.Slf4j;
-
-@Slf4j
-public class MessageDispatcher extends TelegramLongPollingBot {
-
-    private final List<MessageHandler> messageHandlers;
-    private final String botName;
-    private final String botToken;
-
-    public MessageDispatcher(List<MessageHandler> messageHandlers, String botName, String botToken) {
-        this.messageHandlers = messageHandlers;
-        this.botName = botName;
-        this.botToken = botToken;
-    }
-
-    @Override
-    public String getBotToken() {
-        return botToken;
-    }
-
-    @Override
-    public void onUpdateReceived(Update update) {
-
-        Message message = update.getMessage();
-        MessageHandler handler = getMessageHandler(message);
-        handler.handle(message);
-    }
-
-    private MessageHandler getMessageHandler(Message message) {
-        return messageHandlers.stream()
-                              .filter(e -> e.isApplicable(message))
-                              .findFirst()
-                              .orElseThrow(() -> new IllegalArgumentException("Can not found applicable handler"));
-    }
-
-    @Override
-    public String getBotUsername() {
-        return botName;
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/dto/FeedParsedResult.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/dto/FeedParsedResult.java
@ -1,25 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.dto;
-
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
-import java.io.Serializable;
-import java.time.Instant;
-import lombok.Getter;
-import lombok.NoArgsConstructor;
-
-/**
- * FeedParsedResult
- *
- * @author Shin Woo-jin (woozu.shin@kakaoent.com)
- * @since 2021-09-08
- */
-@Getter
-@NoArgsConstructor
-public class FeedParsedResult implements Serializable {
-
-    private static final long serialVersionUID = -3771310078623481348L;
-
-    private PpomppuBoardName boardName;
-    private Instant requestedAt;
-    private Instant processedAt;
-
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/dto/constant/WebClientPropertiesUnitName.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/dto/constant/WebClientPropertiesUnitName.java
@ -1,19 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.dto.constant;
-
-import lombok.AllArgsConstructor;
-import lombok.Getter;
-
-/**
- * WebClientPropertiesUnitName
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-11-18
- *
- */
-@Getter
-@AllArgsConstructor
-public enum WebClientPropertiesUnitName {
-    PPOMPPU_NOTIFIER_PROCESSOR_API("ppn-processor-api"),
-    ;
-
-    private String unitName;
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/HelloWorldMessageHandler.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/HelloWorldMessageHandler.java
@ -1,21 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.handler.message;
-
-import com.myoa.engineering.crawl.ppomppu.support.util.ObjectUtil;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-import org.telegram.telegrambots.meta.api.objects.Message;
-
-@Slf4j
-@Component
-public class HelloWorldMessageHandler implements MessageHandler {
-
-    @Override
-    public boolean isApplicable(Message message) {
-        return ObjectUtil.isEmpty(message);
-    }
-
-    @Override
-    public void handle(Message message) {
-        // skip empty event message.
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/ImageMessageHandler.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/ImageMessageHandler.java
@ -1,12 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.handler.message;
-
-/**
- * ImageHandler
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-08-21
- *
- */
-public interface ImageMessageHandler extends MessageHandler {
-
-
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/MessageHandler.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/MessageHandler.java
@ -1,17 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.handler.message;
-
-import org.telegram.telegrambots.meta.api.objects.Message;
-
-/**
- * MessageHandler
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-08-21
- *
- */
-public interface MessageHandler {
-
-    boolean isApplicable(Message message);
-
-    void handle(Message message);
-
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/TextMessageHandler.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/TextMessageHandler.java
@ -1,18 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.handler.message;
-
-import com.myoa.engineering.crawl.ppomppu.support.util.ObjectUtil;
-import org.telegram.telegrambots.meta.api.objects.Message;
-
-/**
- * TextMessageHandler
- *
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-08-21
- */
-public interface TextMessageHandler extends MessageHandler {
-
-    @Override
-    default boolean isApplicable(Message message) {
-        return ObjectUtil.isNotEmpty(message) && message.isUserMessage() && message.hasText();
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/CommandHandler.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/CommandHandler.java
@ -1,48 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.handler.message.text;
-
-import java.util.List;
-
-import org.springframework.stereotype.Component;
-import org.telegram.telegrambots.meta.api.objects.Message;
-
-import com.myoa.engineering.crawl.ppomppu.receiver.handler.message.TextMessageHandler;
-
-import lombok.extern.slf4j.Slf4j;
-
-/**
- * CommandHandler
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-08-21
- *
- */
-@Slf4j
-@Component
-public class CommandHandler implements TextMessageHandler {
-
-    private final List<TextCommandProcessor> processors;
-
-    public CommandHandler(List<TextCommandProcessor> processors) {
-        this.processors = processors;
-    }
-
-    @Override
-    public boolean isApplicable(Message message) {
-        return TextMessageHandler.super.isApplicable(message)
-               && message.isCommand(); // && message.getText().startsWith("/");
-    }
-
-    @Override
-    public void handle(Message message) {
-        log.info("CommandHandler : {}", message.getText());
-        TextCommandCode commandCode = TextCommandCode.find(message.getText());
-        TextCommandProcessor applicableProcessor = getApplicableProcessor(commandCode);
-        applicableProcessor.process(message);
-    }
-
-    private TextCommandProcessor getApplicableProcessor(TextCommandCode commandCode) {
-        return processors.stream()
-                         .filter(e -> e.isApplicable(commandCode))
-                         .findFirst()
-                         .orElseThrow(() -> new IllegalArgumentException("Can not found"));
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/CommonTextHandler.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/CommonTextHandler.java
@ -1,30 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.handler.message.text;
-
-import org.springframework.stereotype.Component;
-import org.telegram.telegrambots.meta.api.objects.Message;
-
-import com.myoa.engineering.crawl.ppomppu.receiver.handler.message.TextMessageHandler;
-
-import lombok.extern.slf4j.Slf4j;
-
-/**
- * NormalTextHandler
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-08-21
- *
- */
-@Slf4j
-@Component
-public class CommonTextHandler implements TextMessageHandler {
-
-    @Override
-    public boolean isApplicable(Message message) {
-        return TextMessageHandler.super.isApplicable(message) && message.isCommand() == false;
-    }
-
-    @Override
-    public void handle(Message message) {
-        log.info("CommonTextHandler : {}", message.getText());
-    }
-
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/EmptyTextCommandProcessor.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/EmptyTextCommandProcessor.java
@ -1,24 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.handler.message.text;
-
-import org.springframework.stereotype.Component;
-import org.telegram.telegrambots.meta.api.objects.Message;
-
-/**
- * EmptyTextCommandProcessor
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-09-05
- *
- */
-@Component
-public class EmptyTextCommandProcessor implements TextCommandProcessor {
-
-    @Override
-    public boolean isApplicable(TextCommandCode commandCode) {
-        return commandCode == TextCommandCode.EMPTY;
-    }
-
-    @Override
-    public void process(Message message) {
-
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/StartTextCommandProcessor.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/StartTextCommandProcessor.java
@ -1,27 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.handler.message.text;
-
-import org.springframework.stereotype.Component;
-import org.telegram.telegrambots.meta.api.objects.Message;
-
-import lombok.extern.slf4j.Slf4j;
-
-/**
- * StartCommandProcessor
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-09-05
- *
- */
-@Slf4j
-@Component
-public class StartTextCommandProcessor implements TextCommandProcessor {
-
-    @Override
-    public boolean isApplicable(TextCommandCode commandCode) {
-        return TextCommandCode.START == commandCode;
-    }
-
-    @Override
-    public void process(Message message) {
-        log.info("[process] user: {}, command: {}", message.getChatId(), message.getText());
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/TextCommandCode.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/TextCommandCode.java
@ -1,33 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.handler.message.text;
-
-import java.util.Arrays;
-
-import lombok.Getter;
-import lombok.NoArgsConstructor;
-
-/**
- * CommandTextCode
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-09-05
- *
- */
-@Getter
-@NoArgsConstructor
-public enum TextCommandCode {
-    EMPTY(null),
-    START("/start"),
-    ;
-    private String value;
-
-    TextCommandCode(String value) {
-        this.value = value;
-    }
-
-    public static TextCommandCode find(String value) {
-        return Arrays.stream(TextCommandCode.values())
-                     .filter(e -> e != EMPTY)
-                     .filter(e -> value.startsWith(e.getValue()))
-                     .findFirst()
-                     .orElse(TextCommandCode.EMPTY);
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/TextCommandProcessor.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/handler/message/text/TextCommandProcessor.java
@ -1,17 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.handler.message.text;
-
-import org.telegram.telegrambots.meta.api.objects.Message;
-
-/**
- * TextCommandProcessor
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-09-05
- *
- */
-public interface TextCommandProcessor {
-
-    boolean isApplicable(TextCommandCode commandCode);
-
-    void process(Message message);
-
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/infrastructure/client/ProcessorAPIWebClient.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/infrastructure/client/ProcessorAPIWebClient.java
@ -1,44 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.infrastructure.client;
-
-import org.springframework.core.ParameterizedTypeReference;
-import org.springframework.stereotype.Component;
-import org.springframework.web.reactive.function.client.WebClient;
-import org.springframework.web.reactive.function.client.WebClientRequestException;
-
-import com.myoa.engineering.crawl.ppomppu.receiver.dto.constant.WebClientPropertiesUnitName;
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
-import com.myoa.engineering.crawl.ppomppu.support.webclient.factory.WebClientFilterFactory;
-import com.myoa.engineering.crawl.ppomppu.support.webclient.properties.WebClientProperties;
-import com.myoa.engineering.crawl.ppomppu.support.webclient.properties.WebClientProperties.WebClientPropertiesUnit;
-
-import lombok.extern.slf4j.Slf4j;
-import reactor.core.publisher.Mono;
-import reactor.core.scheduler.Schedulers;
-
-@Slf4j
-@Component
-public class ProcessorAPIWebClient {
-
-    private final WebClient webClient;
-
-    public ProcessorAPIWebClient(WebClientProperties webClientProperties) {
-        WebClientPropertiesUnit webClientPropertiesUnit =
-            webClientProperties.find(WebClientPropertiesUnitName.PPOMPPU_NOTIFIER_PROCESSOR_API.getUnitName());
-        this.webClient = WebClient.builder()
-                                  .baseUrl(webClientPropertiesUnit.getBaseUrl())
-                                  .filter(WebClientFilterFactory.logRequest())
-                                  .filter(WebClientFilterFactory.logResponse())
-                                  .build();
-    }
-
-    public Mono<String> emitParseEvent(PpomppuBoardName boardName) {
-        return webClient.post()
-                        .uri("/api/v1/crawl/boards/{boardName}", boardName)
-                        .exchangeToMono(e -> e.bodyToMono(new ParameterizedTypeReference<String>() {}))
-                        .publishOn(Schedulers.boundedElastic())
-                        .onErrorResume(WebClientRequestException.class, t -> {
-                            log.info("Exception occured, ignoring. : {}", t.getClass().getSimpleName());
-                            return Mono.empty();
-                        });
-    }
-}
--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/scheduler/ParseEventEmitter.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/scheduler/ParseEventEmitter.java
@ -1,4 +1,4 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.scheduler;
+package com.myoa.engineering.crawl.shopping.receiver.scheduler;

 import java.util.Arrays;

@ -6,8 +6,8 @@ import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;

-import com.myoa.engineering.crawl.ppomppu.receiver.service.ProcessorAPIService;
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
+import com.myoa.engineering.crawl.shopping.receiver.service.ProcessorAPIService;
+import com.myoa.engineering.crawl.shopping.support.dto.code.PpomppuBoardName;

 import lombok.extern.slf4j.Slf4j;

--- a/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/service/ProcessorAPIService.java
+++ b/receiver/src/main/java/com/myoa/engineering/crawl/ppomppu/receiver/service/ProcessorAPIService.java
@ -1,30 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.receiver.service;
-
-import org.springframework.stereotype.Service;
-
-import com.myoa.engineering.crawl.ppomppu.receiver.infrastructure.client.ProcessorAPIWebClient;
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
-
-import lombok.extern.slf4j.Slf4j;
-import reactor.core.publisher.Mono;
-
-/**
- * ProcessorAPIService
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-09-05
- *
- */
-@Slf4j
-@Service
-public class ProcessorAPIService {
-
-    private final ProcessorAPIWebClient processorAPIWebClient;
-
-    public ProcessorAPIService(ProcessorAPIWebClient processorAPIWebClient) {
-        this.processorAPIWebClient = processorAPIWebClient;
-    }
-
-    public Mono<String> emitParseEvent(PpomppuBoardName boardName) {
-        return processorAPIWebClient.emitParseEvent(boardName);
-    }
-}
--- a/receiver/src/main/resources/application-development.yml
+++ b/receiver/src/main/resources/application-development.yml
@ -1,6 +0,0 @@
-spring:
-  config:
-    activate:
-      on-profile: development
-    import:
-      - "configserver:http://192.168.0.100:11080"
--- a/receiver/src/main/resources/application-local.yml
+++ b/receiver/src/main/resources/application-local.yml
@ -1,6 +0,0 @@
-spring:
-  config:
-    activate:
-      on-profile: local
-    import:
-      - "configserver:http://localhost:20085"
--- a/receiver/src/main/resources/logback-spring.xml
+++ b/receiver/src/main/resources/logback-spring.xml
@ -1,15 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<configuration>
-  <springProperty name="DEFAULT_LEVEL_CONFIG" source="log.defaultLevel" />
-  <springProfile name="local">
-    <include resource="logback/logback-development.xml" />
-    <logger name="org.apache.kafka" level="INFO" />
-  </springProfile>
-  <springProfile name="development">
-    <include resource="logback/logback-development.xml" />
-    <logger name="org.apache.kafka" level="INFO" />
-  </springProfile>
-  <springProfile name="production">
-    <include resource="logback/logback-production.xml" />
-  </springProfile>
-</configuration>
--- a/receiver/src/main/resources/logback/component/logback-file.xml
+++ b/receiver/src/main/resources/logback/component/logback-file.xml
@ -1,23 +0,0 @@
-<included>
-  <property name="FILE_LOG_PATTERN"
-            value="%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{45}:%L - %msg%n" />
-  <property name="LOG_FILE_BASE" value="lcp-benefit-benefit-api" />
-  <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
-    <file>${DIRECTORY}/${LOG_FILE_BASE}_log</file>
-    <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
-      <fileNamePattern>${DIRECTORY}/${LOG_FILE_BASE}_log.%d{yyyyMMdd}.%i</fileNamePattern>
-      <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
-        <maxFileSize>1000MB</maxFileSize>
-      </timeBasedFileNamingAndTriggeringPolicy>
-      <maxHistory>60</maxHistory>
-    </rollingPolicy>
-    <encoder>
-      <pattern>${FILE_LOG_PATTERN}</pattern>
-      <immediateFlush>${IMMEDIATE_FLUSH}</immediateFlush>
-    </encoder>
-  </appender>
-  <appender name="ASYNC_FILE" class="ch.qos.logback.classic.AsyncAppender">
-    <queueSize>1024</queueSize>
-    <appender-ref ref="FILE" />
-  </appender>
-</included>
--- a/receiver/src/main/resources/logback/logback-development.xml
+++ b/receiver/src/main/resources/logback/logback-development.xml
@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<included>
-  <!-- =========== property BETA ========= -->
-  <property name="DEFAULT_LEVEL" value="${DEFAULT_LEVEL_CONFIG:-INFO}"/>
-  <!--file-->
-  <property name="DIRECTORY" value="/home1/www/logs/supervisor"/>
-  <property name="IMMEDIATE_FLUSH" value="true"/>
-  <!--nelo2-->
-  <property name="NELO2_LEVEL" value="WARN"/>
-  <!-- =========== include appender =========== -->
-  <include resource="org/springframework/boot/logging/logback/defaults.xml"/>
-  <include resource="org/springframework/boot/logging/logback/console-appender.xml"/>
-  <include resource="logback/component/logback-nelo2.xml"/>
-  <include resource="logback/component/logback-datachain.xml"/>
-  <!-- =========== root logger ============== -->
-  <root level="${DEFAULT_LEVEL}">
-    <appender-ref ref="CONSOLE"/>
-  </root>
-</included>
--- a/receiver/src/main/resources/logback/logback-production.xml
+++ b/receiver/src/main/resources/logback/logback-production.xml
@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<included>
-  <!-- =========== property RELEASE ========= -->
-  <property name="DEFAULT_LEVEL" value="${DEFAULT_LEVEL_CONFIG:-INFO}"/>
-  <!--file-->
-  <property name="DIRECTORY" value="/home1/www/logs/supervisor"/>
-  <property name="IMMEDIATE_FLUSH" value="true"/>
-  <!--nelo2-->
-  <property name="NELO2_LEVEL" value="WARN"/>
-  <!-- =========== include appender =========== -->
-  <include resource="org/springframework/boot/logging/logback/defaults.xml"/>
-  <include resource="org/springframework/boot/logging/logback/console-appender.xml"/>
-  <include resource="logback/component/logback-nelo2.xml"/>
-  <include resource="logback/component/logback-datachain.xml"/>
-  <!-- =========== root logger ============== -->
-  <root level="${DEFAULT_LEVEL}">
-    <appender-ref ref="CONSOLE"/>
-  </root>
-</included>
--- a/sender/build.gradle
+++ b/sender/build.gradle
@ -1,23 +0,0 @@
-dependencies {
-    developmentOnly 'org.springframework.boot:spring-boot-devtools'
-    runtimeOnly 'mysql:mysql-connector-java'
-    compileOnly 'org.projectlombok:lombok'
-
-    implementation project(':support')
-    // https://projectreactor.io/docs/core/release/reference/#debug-activate
-    implementation 'org.springframework.boot:spring-boot-starter-webflux'
-    implementation 'org.springframework.boot:spring-boot-starter-actuator'
-    implementation 'org.springframework.cloud:spring-cloud-starter-config'
-
-    annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
-    annotationProcessor 'org.projectlombok:lombok'
-
-    testImplementation 'org.springframework.boot:spring-boot-starter-test'
-}
-
-test {
-    useJUnitPlatform()
-    testLogging {
-        events "passed", "skipped", "failed"
-    }
-}
--- a/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/SenderApplication.java
+++ b/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/SenderApplication.java
@ -1,22 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.sender;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.context.annotation.Import;
-
-import com.myoa.engineering.crawl.ppomppu.support.webclient.PpomppuNotifierWebClientConfiguration;
-
-/**
- * SenderApplication
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-08-20
- *
- */
-@Import({ PpomppuNotifierWebClientConfiguration.class })
-@SpringBootApplication
-public class SenderApplication {
-
-    public static void main(String[] args) {
-        SpringApplication.run(SenderApplication.class, args);
-    }
-}
--- a/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/controller/MessageSenderAPIController.java
+++ b/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/controller/MessageSenderAPIController.java
@ -1,17 +1,17 @@
-package com.myoa.engineering.crawl.ppomppu.sender.controller;
+package com.myoa.engineering.crawl.shopping.controller;

 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;

-import com.myoa.engineering.crawl.ppomppu.sender.dto.SlackBaseMessageBlock;
-import com.myoa.engineering.crawl.ppomppu.sender.dto.SlackMessageDTO;
-import com.myoa.engineering.crawl.ppomppu.sender.infrastructure.client.MongeShoppingBotSlackMessageSender;
-import com.myoa.engineering.crawl.ppomppu.support.dto.APIResponse;
-import com.myoa.engineering.crawl.ppomppu.support.dto.BlockMessageDTO;
-import com.myoa.engineering.crawl.ppomppu.support.dto.SimpleMessageDTO;
-import com.myoa.engineering.crawl.ppomppu.support.util.ObjectMapperFactory;
+import com.myoa.engineering.crawl.shopping.sender.dto.SlackBaseMessageBlock;
+import com.myoa.engineering.crawl.shopping.sender.dto.SlackMessageDTO;
+import com.myoa.engineering.crawl.shopping.sender.infrastructure.client.MongeShoppingBotSlackMessageSender;
+import com.myoa.engineering.crawl.shopping.support.dto.APIResponse;
+import com.myoa.engineering.crawl.shopping.support.dto.BlockMessageDTO;
+import com.myoa.engineering.crawl.shopping.support.dto.SimpleMessageDTO;
+import com.myoa.engineering.crawl.shopping.support.util.ObjectMapperFactory;

 import lombok.extern.slf4j.Slf4j;
 import reactor.core.publisher.Mono;
--- a/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/controller/TestAPIController.java
+++ b/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/controller/TestAPIController.java
@ -1,33 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.sender.controller;
-
-import com.myoa.engineering.crawl.ppomppu.sender.infrastructure.client.MongeShoppingBotSlackMessageSender;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import lombok.extern.slf4j.Slf4j;
-import reactor.core.publisher.Mono;
-
-/**
- * TestAPIController
- *
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-11-15
- */
-@Slf4j
-@RestController
-@RequestMapping("/api/v1")
-public class TestAPIController {
-
-    private final MongeShoppingBotSlackMessageSender sender;
-
-    public TestAPIController(MongeShoppingBotSlackMessageSender sender) {
-        this.sender = sender;
-    }
-
-    @GetMapping("/test")
-    public Mono<String> test() {
-        log.info("received!!!");
-        return sender.sendMessage(sender.ofMessage("testtesttest!!!"));
-    }
-}
--- a/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/infrastructure/client/MessageSender.java
+++ b/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/infrastructure/client/MessageSender.java
@ -1,17 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.sender.infrastructure.client;
-
-import com.myoa.engineering.crawl.ppomppu.sender.dto.MessageDTO;
-
-import reactor.core.publisher.Mono;
-
-/**
- * MessageSender
- * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
- * @since 2021-11-14
- *
- */
-public interface MessageSender<T extends MessageDTO> {
-
-    Mono<String> sendMessage(T message);
-
-}
--- a/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/infrastructure/client/MongeShoppingBotSlackMessageSender.java
+++ b/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/infrastructure/client/MongeShoppingBotSlackMessageSender.java
@ -1,52 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.sender.infrastructure.client;
-
-import java.util.ArrayList;
-
-import org.springframework.stereotype.Component;
-
-import com.myoa.engineering.crawl.ppomppu.sender.configuration.properties.SlackSecretProperties;
-import com.myoa.engineering.crawl.ppomppu.sender.configuration.properties.SlackSecretProperties.SlackSecretPropertiesUnit;
-import com.myoa.engineering.crawl.ppomppu.sender.dto.SlackMessageDTO;
-
-import lombok.extern.slf4j.Slf4j;
-
-@Slf4j
-@Component
-public class MongeShoppingBotSlackMessageSender extends SlackMessageSender {
-
-    private static final String SLACK_SECRET_UNIT_NAME = "monge_shopping_bot";
-
-    private final SlackSecretPropertiesUnit slackProperties;
-
-    public MongeShoppingBotSlackMessageSender(SlackSecretProperties slackSecretProperties) {
-        super(slackSecretProperties.find(SLACK_SECRET_UNIT_NAME).getToken());
-        this.slackProperties = slackSecretProperties.find(SLACK_SECRET_UNIT_NAME);
-    }
-
-    public SlackMessageDTO ofMessageTemplate() {
-        return SlackMessageDTO.builder()
-                              .channel(slackProperties.getChannel())
-                              .iconEmoji(slackProperties.getIconEmoji())
-                              .username(slackProperties.getUsername())
-                              .build();
-    }
-
-    public SlackMessageDTO ofMessage(String text) {
-        return SlackMessageDTO.builder()
-                              .channel(slackProperties.getChannel())
-                              .iconEmoji(slackProperties.getIconEmoji())
-                              .username(slackProperties.getUsername())
-                              .text(text)
-                              .build();
-    }
-
-    public SlackMessageDTO ofBlockMessageBased() {
-        return SlackMessageDTO.builder()
-                              .channel(slackProperties.getChannel())
-                              .iconEmoji(slackProperties.getIconEmoji())
-                              .username(slackProperties.getUsername())
-                              .blocks(new ArrayList<>())
-                              .build();
-    }
-
-}
--- a/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/infrastructure/client/SlackMessageSender.java
+++ b/sender/src/main/java/com/myoa/engineering/crawl/ppomppu/sender/infrastructure/client/SlackMessageSender.java
@ -1,55 +0,0 @@
-package com.myoa.engineering.crawl.ppomppu.sender.infrastructure.client;
-
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.MediaType;
-import org.springframework.web.reactive.function.client.WebClient;
-import org.springframework.web.reactive.function.client.WebClientRequestException;
-
-import com.myoa.engineering.crawl.ppomppu.sender.dto.SlackMessageDTO;
-import com.myoa.engineering.crawl.ppomppu.support.webclient.factory.WebClientFilterFactory;
-import com.myoa.engineering.crawl.ppomppu.support.webclient.factory.WebFluxExchangeStragiesFactory;
-
-import lombok.extern.slf4j.Slf4j;
-import reactor.core.publisher.Mono;
-import reactor.core.scheduler.Schedulers;
-
-/**
- * SlackMessageSender
- *
- * @author Shin Woo-jin (woozu.shin@kakaoent.com)
- * @since 2021-09-08
- */
-@Slf4j
-public class SlackMessageSender implements MessageSender<SlackMessageDTO> {
-
-    private static final String SLACK_API_URL = "https://slack.com/api";
-
-    private final WebClient webClient;
-
-    public SlackMessageSender(String apiSecret) {
-        this.webClient = WebClient.builder()
-                                  .baseUrl(SLACK_API_URL)
-                                  .defaultHeader(HttpHeaders.AUTHORIZATION, "Bearer " + apiSecret)
-                                  .exchangeStrategies(WebFluxExchangeStragiesFactory.ofDefault())
-                                  .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_UTF8_VALUE)
-                                  .defaultHeader(HttpHeaders.ACCEPT_CHARSET, "UTF-8")
-                                  .filter(WebClientFilterFactory.logRequest())
-                                  .filter(WebClientFilterFactory.logResponse())
-                                  .build();
-    }
-
-    @Override
-    public Mono<String> sendMessage(SlackMessageDTO message) {
-        return webClient.post()
-                        .uri("/chat.postMessage")
-                        .bodyValue(message)
-                        .exchangeToMono(e -> e.bodyToMono(String.class))
-                        .publishOn(Schedulers.boundedElastic())
-                        .onErrorResume(WebClientRequestException.class, t -> {
-                            log.info("Exception occured, ignoring. : {}", t.getClass().getSimpleName());
-                            return Mono.empty();
-                        })
-                        .doOnNext(e -> log.info("[sendMessage] {}", e));
-    }
-
-}
--- a/sender/src/main/resources/application-development.yml
+++ b/sender/src/main/resources/application-development.yml
@ -1,10 +0,0 @@
-spring:
-  config:
-    activate:
-      on-profile: development
-    import:
-      - "configserver:http://192.168.0.100:11080"
-    # import: optional:configserver:http://localhost:11080 # can be start up even config server was not found.
-
-server:
-  port: 20082
--- a/sender/src/main/resources/application-production.yml
+++ b/sender/src/main/resources/application-production.yml
@ -1,6 +0,0 @@
-spring:
-  config:
-    activate:
-      on-profile: production
-    import:
-      - "configserver:http://ppn-config-server:20080"
--- a/sender/src/main/resources/logback-spring.xml
+++ b/sender/src/main/resources/logback-spring.xml
@ -1,15 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<configuration>
-  <springProfile name="local">
-    <include resource="logback/logback-development.xml" />
-    <logger name="org.apache.kafka" level="INFO" />
-  </springProfile>
-  <springProperty name="DEFAULT_LEVEL_CONFIG" source="log.defaultLevel" />
-  <springProfile name="development">
-    <include resource="logback/logback-development.xml" />
-    <logger name="org.apache.kafka" level="INFO" />
-  </springProfile>
-  <springProfile name="production">
-    <include resource="logback/logback-production.xml" />
-  </springProfile>
-</configuration>
--- a/sender/src/main/resources/logback/component/logback-file.xml
+++ b/sender/src/main/resources/logback/component/logback-file.xml
@ -1,23 +0,0 @@
-<included>
-  <property name="FILE_LOG_PATTERN"
-            value="%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{45}:%L - %msg%n" />
-  <property name="LOG_FILE_BASE" value="lcp-benefit-benefit-api" />
-  <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
-    <file>${DIRECTORY}/${LOG_FILE_BASE}_log</file>
-    <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
-      <fileNamePattern>${DIRECTORY}/${LOG_FILE_BASE}_log.%d{yyyyMMdd}.%i</fileNamePattern>
-      <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
-        <maxFileSize>1000MB</maxFileSize>
-      </timeBasedFileNamingAndTriggeringPolicy>
-      <maxHistory>60</maxHistory>
-    </rollingPolicy>
-    <encoder>
-      <pattern>${FILE_LOG_PATTERN}</pattern>
-      <immediateFlush>${IMMEDIATE_FLUSH}</immediateFlush>
-    </encoder>
-  </appender>
-  <appender name="ASYNC_FILE" class="ch.qos.logback.classic.AsyncAppender">
-    <queueSize>1024</queueSize>
-    <appender-ref ref="FILE" />
-  </appender>
-</included>
--- a/sender/src/main/resources/logback/logback-development.xml
+++ b/sender/src/main/resources/logback/logback-development.xml
@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<included>
-  <!-- =========== property BETA ========= -->
-  <property name="DEFAULT_LEVEL" value="${DEFAULT_LEVEL_CONFIG:-INFO}"/>
-  <!--file-->
-  <property name="DIRECTORY" value="/home1/www/logs/supervisor"/>
-  <property name="IMMEDIATE_FLUSH" value="true"/>
-  <!--nelo2-->
-  <property name="NELO2_LEVEL" value="WARN"/>
-  <!-- =========== include appender =========== -->
-  <include resource="org/springframework/boot/logging/logback/defaults.xml"/>
-  <include resource="org/springframework/boot/logging/logback/console-appender.xml"/>
-  <include resource="logback/component/logback-nelo2.xml"/>
-  <include resource="logback/component/logback-datachain.xml"/>
-  <!-- =========== root logger ============== -->
-  <root level="${DEFAULT_LEVEL}">
-    <appender-ref ref="CONSOLE"/>
-  </root>
-</included>
--- a/sender/src/main/resources/logback/logback-production.xml
+++ b/sender/src/main/resources/logback/logback-production.xml
@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<included>
-  <!-- =========== property RELEASE ========= -->
-  <property name="DEFAULT_LEVEL" value="${DEFAULT_LEVEL_CONFIG:-INFO}"/>
-  <!--file-->
-  <property name="DIRECTORY" value="/home1/www/logs/supervisor"/>
-  <property name="IMMEDIATE_FLUSH" value="true"/>
-  <!--nelo2-->
-  <property name="NELO2_LEVEL" value="WARN"/>
-  <!-- =========== include appender =========== -->
-  <include resource="org/springframework/boot/logging/logback/defaults.xml"/>
-  <include resource="org/springframework/boot/logging/logback/console-appender.xml"/>
-  <include resource="logback/component/logback-nelo2.xml"/>
-  <include resource="logback/component/logback-datachain.xml"/>
-  <!-- =========== root logger ============== -->
-  <root level="${DEFAULT_LEVEL}">
-    <appender-ref ref="CONSOLE"/>
-  </root>
-</included>
--- a/settings.gradle
+++ b/settings.gradle
@ -1,14 +1,14 @@
 rootProject.name = 'PpomppuNotifier'

-include 'receiver'
-project(':receiver').projectDir = "$rootDir/receiver" as File
-
-include 'processor'
-project(':processor').projectDir = "$rootDir/processor" as File
-
-include 'sender'
-project(':sender').projectDir = "$rootDir/sender" as File
+//include 'reader'
+//project(':reader').projectDir = "$rootDir/reader" as File
+//include 'processor'
+//project(':processor').projectDir = "$rootDir/processor" as File
+//include 'writer'
+//project(':writer').projectDir = "$rootDir/writer" as File

+include 'shopping-crawler'
+project(':shopping-crawler').projectDir = "$rootDir/shopping-crawler" as File

 include 'support'
 project(':support').projectDir = "$rootDir/support" as File
--- a/shopping-crawler/.jqwik-database
+++ b/shopping-crawler/.jqwik-database
--- a/shopping-crawler/build.gradle
+++ b/shopping-crawler/build.gradle
@ -1,21 +1,36 @@
 dependencies {
    developmentOnly 'org.springframework.boot:spring-boot-devtools'
    runtimeOnly 'com.h2database:h2'
-    runtimeOnly 'mysql:mysql-connector-java'
+    runtimeOnly 'com.mysql:mysql-connector-j:8.4.0'
    compileOnly 'org.projectlombok:lombok'

    implementation project(':support')
    // https://projectreactor.io/docs/core/release/reference/#debug-activate
-    implementation 'org.springframework.boot:spring-boot-starter-webflux'
+    implementation("org.springframework.boot:spring-boot-starter-web") {
+        exclude group: "org.springframework.boot", module: "spring-boot-starter-tomcat"
+    }
+
+    implementation("org.springframework.boot:spring-boot-starter-undertow") {
+        exclude group: "io.undertow", module: "undertow-websockets-jsr"
+    }
+    implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
    implementation 'org.springframework.boot:spring-boot-configuration-processor'
    implementation 'org.springframework.cloud:spring-cloud-starter-config'
    implementation 'org.springframework.boot:spring-boot-starter-actuator'
-    implementation 'org.telegram:telegrambots:5.3.0'
+    implementation 'org.jsoup:jsoup:1.17.2'
+    implementation 'com.h2database:h2:2.2.224'
+    implementation "org.springframework.cloud:spring-cloud-starter-openfeign"
+    implementation "io.github.openfeign:feign-hc5"
+    implementation 'org.ahocorasick:ahocorasick:0.6.3'

    annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
    annotationProcessor 'org.projectlombok:lombok'

    testImplementation 'org.springframework.boot:spring-boot-starter-test'
+    testImplementation('org.assertj:assertj-core:3.25.3')
+    testImplementation("org.jeasy:easy-random-core:5.0.0")
+    testCompileOnly 'org.projectlombok:lombok'
+    testAnnotationProcessor('org.projectlombok:lombok')
 }

 test {
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/ShoppingCrawlerApplication.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/ShoppingCrawlerApplication.java
@ -0,0 +1,19 @@
+package com.myoa.engineering.crawl.shopping;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@EnableScheduling
+@EnableFeignClients
+@EnableConfigurationProperties
+@SpringBootApplication
+public class ShoppingCrawlerApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ShoppingCrawlerApplication.class, args);
+    }
+
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/FeignDefaultConfig.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/FeignDefaultConfig.java
@ -0,0 +1,30 @@
+package com.myoa.engineering.crawl.shopping.configuration;
+
+import feign.Logger;
+import feign.RequestInterceptor;
+import feign.codec.ErrorDecoder;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+
+@Slf4j
+@Configuration
+public class FeignDefaultConfig {
+
+    @Bean
+    Logger.Level feignLoggerLevel() {
+        return Logger.Level.FULL;
+    }
+
+
+    public static final String MIME_TYPE =
+            MediaType.APPLICATION_JSON_VALUE + ";charset=utf-8";
+
+    @Bean
+    public RequestInterceptor requestInterceptor() {
+        return requestTemplate -> requestTemplate.header(HttpHeaders.CONTENT_TYPE, MIME_TYPE);
+    }
+
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/datasource/H2ConsoleConfiguration.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/datasource/H2ConsoleConfiguration.java
@ -1,6 +1,5 @@
-package com.myoa.engineering.crawl.ppomppu.processor.configuration;
+package com.myoa.engineering.crawl.shopping.configuration.datasource;

-import java.sql.SQLException;
 import lombok.extern.slf4j.Slf4j;
 import org.h2.tools.Server;
 import org.springframework.beans.factory.annotation.Value;
@ -10,6 +9,8 @@ import org.springframework.context.event.ContextClosedEvent;
 import org.springframework.context.event.ContextRefreshedEvent;
 import org.springframework.context.event.EventListener;

+import java.sql.SQLException;
+
@Slf4j
@Profile({"datasource-local", "datasource-development"})
@Configuration
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/datasource/ShoppingCrawlerDatasourceConfiguration.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/datasource/ShoppingCrawlerDatasourceConfiguration.java
@ -1,54 +1,58 @@
-package com.myoa.engineering.crawl.ppomppu.processor.configuration;
+package com.myoa.engineering.crawl.shopping.configuration.datasource;

-import com.myoa.engineering.crawl.ppomppu.processor.configuration.properties.DatasourceProperties;
-import com.myoa.engineering.crawl.ppomppu.processor.configuration.properties.DatasourceProperties.DataSourcePropertiesUnit;
-import com.myoa.engineering.crawl.ppomppu.processor.configuration.properties.HibernateProperties;
-import com.myoa.engineering.crawl.ppomppu.processor.configuration.properties.HikariProperties;
-import com.myoa.engineering.crawl.ppomppu.processor.domain.BaseScanDomain;
-import com.myoa.engineering.crawl.ppomppu.processor.infrastructure.repository.BaseScanRepository;
+import com.myoa.engineering.crawl.shopping.configuration.datasource.properties.DatasourceProperties;
+import com.myoa.engineering.crawl.shopping.configuration.datasource.properties.HibernateProperties;
+import com.myoa.engineering.crawl.shopping.configuration.datasource.properties.HikariProperties;
+import com.myoa.engineering.crawl.shopping.domain.entity.BaseScanDomain;
+import com.myoa.engineering.crawl.shopping.infra.repository.BaseScanRepository;
 import com.zaxxer.hikari.HikariConfig;
 import com.zaxxer.hikari.HikariDataSource;
-import java.util.Enumeration;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Properties;
-import javax.persistence.EntityManagerFactory;
-import javax.sql.DataSource;
 import lombok.NonNull;
 import org.hibernate.cfg.AvailableSettings;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
+import org.springframework.boot.orm.jpa.hibernate.SpringImplicitNamingStrategy;
+import org.springframework.boot.orm.jpa.hibernate.SpringPhysicalNamingStrategy;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
 import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
 import org.springframework.orm.jpa.JpaTransactionManager;
 import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
 import org.springframework.transaction.PlatformTransactionManager;

-@Configuration
-@EnableJpaRepositories(basePackageClasses = BaseScanRepository.class,
-    entityManagerFactoryRef = "ppomppuNotifierProcessorEntityManagerFactory",
-    transactionManagerRef = "ppomppuNotifierProcessorTransactionManager"
-)
-public class PpomppuDatasourceConfiguration {
+import javax.persistence.EntityManagerFactory;
+import javax.sql.DataSource;
+import java.util.Enumeration;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Properties;

-    private static final String DATA_SOURCE_UNIT_NAME = "ppn_mysql";
+@Configuration
+@EnableJpaAuditing
+@EnableJpaRepositories(basePackageClasses = BaseScanRepository.class,
+        entityManagerFactoryRef = "shoppingCrawlerEntityManagerFactory",
+        transactionManagerRef = "shoppingCrawlerTransactionManager"
+)
+public class ShoppingCrawlerDatasourceConfiguration {
+
+    private static final String DATA_SOURCE_UNIT_NAME = "crawler-shopping";

    private final DatasourceProperties dataSourceProeprties;
    private final HikariProperties hikariProperties;
    private final HibernateProperties hibernateProperties;

-    public PpomppuDatasourceConfiguration(DatasourceProperties dataSourceProeprties,
-                                          HikariProperties hikariProperties,
-                                          HibernateProperties hibernateProperties) {
+    public ShoppingCrawlerDatasourceConfiguration(DatasourceProperties dataSourceProeprties,
+                                                  HikariProperties hikariProperties,
+                                                  HibernateProperties hibernateProperties) {
        this.dataSourceProeprties = dataSourceProeprties;
        this.hikariProperties = hikariProperties;
        this.hibernateProperties = hibernateProperties;
    }

-    @Bean(name = "ppomppuNotifierProcessorDataSource")
+    @Bean(name = "shoppingCrawlerDataSource")
    public DataSource dataSource() {
-        DataSourcePropertiesUnit dataSourcePropertiesUnit = dataSourceProeprties.find(DATA_SOURCE_UNIT_NAME);
+        DatasourceProperties.DataSourcePropertiesUnit dataSourcePropertiesUnit = dataSourceProeprties.find(DATA_SOURCE_UNIT_NAME);

        final HikariConfig hikariConfig = new HikariConfig();
        hikariConfig.setJdbcUrl(dataSourcePropertiesUnit.toCompletedJdbcUrl());
@ -69,19 +73,19 @@ public class PpomppuDatasourceConfiguration {
        return dataSource;
    }

-    @Bean("ppomppuNotifierProcessorEntityManagerFactory")
+    @Bean("shoppingCrawlerEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean entityManagerFactory(
-        EntityManagerFactoryBuilder builder,
-        @Qualifier("ppomppuNotifierProcessorDataSource") DataSource dataSource) {
+            EntityManagerFactoryBuilder builder,
+            @Qualifier("shoppingCrawlerDataSource") DataSource dataSource) {
        return builder.dataSource(dataSource)
                      .packages(BaseScanDomain.class)
                      .properties(getPropsMap(DATA_SOURCE_UNIT_NAME))
                      .build();
    }

-    @Bean("ppomppuNotifierProcessorTransactionManager")
+    @Bean("shoppingCrawlerTransactionManager")
    public PlatformTransactionManager transactionManager(
-        @Qualifier("ppomppuNotifierProcessorEntityManagerFactory") EntityManagerFactory entityManagerFactory) {
+            @Qualifier("shoppingCrawlerEntityManagerFactory") EntityManagerFactory entityManagerFactory) {
        return new JpaTransactionManager(entityManagerFactory);
    }

@ -91,20 +95,17 @@ public class PpomppuDatasourceConfiguration {
        properties.put(AvailableSettings.FORMAT_SQL, hibernateProperties.getFormatSql());
        properties.put(AvailableSettings.SHOW_SQL, hibernateProperties.getShowSql());
        properties.put(AvailableSettings.HBM2DDL_AUTO, hibernateProperties.getHbm2ddlAuto());
-        properties.put(AvailableSettings.CONNECTION_PROVIDER_DISABLES_AUTOCOMMIT,
-                       hibernateProperties.getDisableAutoCommit());
-        properties.put(AvailableSettings.IMPLICIT_NAMING_STRATEGY,
-                       "org.springframework.boot.orm.jpa.hibernate.SpringImplicitNamingStrategy");
-        properties.put(AvailableSettings.PHYSICAL_NAMING_STRATEGY,
-                       "org.springframework.boot.orm.jpa.hibernate.SpringPhysicalNamingStrategy");
+        properties.put(AvailableSettings.CONNECTION_PROVIDER_DISABLES_AUTOCOMMIT, hibernateProperties.getDisableAutoCommit());
+        properties.put(AvailableSettings.IMPLICIT_NAMING_STRATEGY, SpringImplicitNamingStrategy.class.getName());
+        properties.put(AvailableSettings.PHYSICAL_NAMING_STRATEGY, SpringPhysicalNamingStrategy.class.getName());
        properties.put(AvailableSettings.GENERATE_STATISTICS, "false");
-        properties.put(AvailableSettings.GLOBALLY_QUOTED_IDENTIFIERS, "true");
-        properties.put(AvailableSettings.GLOBALLY_QUOTED_IDENTIFIERS_SKIP_COLUMN_DEFINITIONS, "true");
+//        properties.put(AvailableSettings.GLOBALLY_QUOTED_IDENTIFIERS, "true");
+//        properties.put(AvailableSettings.GLOBALLY_QUOTED_IDENTIFIERS_SKIP_COLUMN_DEFINITIONS, "true");
        properties.put(AvailableSettings.STATEMENT_BATCH_SIZE, "20");
        properties.put(AvailableSettings.ORDER_INSERTS, "true");
        properties.put(AvailableSettings.ORDER_UPDATES, "true");
        properties.put(AvailableSettings.BATCH_VERSIONED_DATA, "true");
-        properties.put(AvailableSettings.USE_NEW_ID_GENERATOR_MAPPINGS, "false");
+//        properties.put(AvailableSettings.JPA_ID_GENERATOR_GLOBAL_SCOPE_COMPLIANCE, "false");
        return properties;
    }

--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/datasource/properties/DatasourceProperties.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/datasource/properties/DatasourceProperties.java
@ -1,29 +1,26 @@
-package com.myoa.engineering.crawl.ppomppu.processor.configuration.properties;
+package com.myoa.engineering.crawl.shopping.configuration.datasource.properties;

-import com.myoa.engineering.crawl.ppomppu.support.util.ObjectUtil;
-import java.util.List;
-
-import lombok.Getter;
-import lombok.Setter;
+import com.myoa.engineering.crawl.shopping.support.util.ObjectUtil;
+import lombok.Data;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.stereotype.Component;

+import java.util.List;
+
@Component
-@Setter
-@Getter
-@ConfigurationProperties(prefix = "infra.database")
+@Data
+@ConfigurationProperties(prefix = "datasource")
 public class DatasourceProperties {

    private List<DataSourcePropertiesUnit> units;

-    @Getter
-    @Setter
+    @Data
    public static class DataSourcePropertiesUnit {

        private String unitName;
        private String schemaName;
        private String connectionParameters;
-        private String datasourceUrl;
+        private String dbConnectionUrl;
        private Boolean isSimpleConnectionUrl;
        private String username;
        private String password;
@ -31,9 +28,9 @@ public class DatasourceProperties {

        public String toCompletedJdbcUrl() {
            if (ObjectUtil.isEmpty(isSimpleConnectionUrl) || isSimpleConnectionUrl == false) {
-                return String.format("%s/%s?%s", datasourceUrl, schemaName, connectionParameters);
+                return String.format("%s/%s?%s", dbConnectionUrl, schemaName, connectionParameters);
            }
-            return datasourceUrl;
+            return dbConnectionUrl;
        }
    }

@ -42,7 +39,7 @@ public class DatasourceProperties {
                    .filter(e -> e.getUnitName().equals(unitName))
                    .findFirst()
                    .orElseThrow(
-                        () -> new IllegalArgumentException(this.getClass().getName() + ": unitName Not found. " + unitName));
+                            () -> new IllegalArgumentException(this.getClass().getName() + ": unitName Not found. " + unitName));
    }

 }
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/datasource/properties/HibernateProperties.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/datasource/properties/HibernateProperties.java
@ -1,14 +1,12 @@
-package com.myoa.engineering.crawl.ppomppu.processor.configuration.properties;
+package com.myoa.engineering.crawl.shopping.configuration.datasource.properties;

-import java.util.List;
 import lombok.Getter;
 import lombok.Setter;
-
-import org.hibernate.dialect.MySQL8Dialect;
-import org.hibernate.dialect.MySQLDialect;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.stereotype.Component;

+import java.util.List;
+
@Component
@Setter
@Getter
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/datasource/properties/HikariProperties.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/datasource/properties/HikariProperties.java
@ -1,4 +1,4 @@
-package com.myoa.engineering.crawl.ppomppu.processor.configuration.properties;
+package com.myoa.engineering.crawl.shopping.configuration.datasource.properties;

 import lombok.Getter;
 import lombok.Setter;
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/slack/properties/SlackSecretProperties.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/configuration/slack/properties/SlackSecretProperties.java
@ -1,4 +1,4 @@
-package com.myoa.engineering.crawl.ppomppu.sender.configuration.properties;
+package com.myoa.engineering.crawl.shopping.configuration.slack.properties;

 import java.util.List;
 import lombok.Data;
@ -7,18 +7,16 @@ import lombok.Setter;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.stereotype.Component;

-@Getter
-@Setter
+@Data
@Component
-@ConfigurationProperties("infra.slack.bot")
+@ConfigurationProperties(prefix = "slack.bot")
 public class SlackSecretProperties {

    private List<SlackSecretPropertiesUnit> units;

    @Data
    public static class SlackSecretPropertiesUnit {
-
-        private String botName;
+        private String botUnitName;
        private String username;
        private String iconEmoji;
        private String channel;
@ -27,7 +25,7 @@ public class SlackSecretProperties {

    public SlackSecretPropertiesUnit find(String botUnitName) {
        return units.stream()
-                    .filter(e -> e.getBotName().equals(botUnitName))
+                    .filter(e -> e.getBotUnitName().equals(botUnitName))
                    .findFirst()
                    .orElseThrow(() -> new IllegalArgumentException("not found bot unit name : " + botUnitName));
    }
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/controller/TestAPIController.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/controller/TestAPIController.java
@ -0,0 +1,22 @@
+package com.myoa.engineering.crawl.shopping.controller;
+
+import com.myoa.engineering.crawl.shopping.crawlhandler.PpomppuCrawlDomesticHandler;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/api/v1/exploit")
+public class TestAPIController {
+
+    private final PpomppuCrawlDomesticHandler ppomppuCrawlDomesticHandler;
+
+    public TestAPIController(PpomppuCrawlDomesticHandler ppomppuCrawlDomesticHandler) {
+        this.ppomppuCrawlDomesticHandler = ppomppuCrawlDomesticHandler;
+    }
+
+    @GetMapping("/triggers")
+    public void triggerExploit() {
+        ppomppuCrawlDomesticHandler.handle();
+    }
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/crawlhandler/CrawlHandler.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/crawlhandler/CrawlHandler.java
@ -0,0 +1,10 @@
+package com.myoa.engineering.crawl.shopping.crawlhandler;
+
+import com.myoa.engineering.crawl.shopping.support.dto.constant.CrawlTarget;
+
+public interface CrawlHandler {
+
+    CrawlTarget getCrawlTarget();
+
+    void handle();
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/crawlhandler/FmkoreaCrawlHandler.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/crawlhandler/FmkoreaCrawlHandler.java
@ -0,0 +1,18 @@
+package com.myoa.engineering.crawl.shopping.crawlhandler;
+
+import com.myoa.engineering.crawl.shopping.support.dto.constant.CrawlTarget;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class FmkoreaCrawlHandler implements CrawlHandler {
+    @Override
+    public CrawlTarget getCrawlTarget() {
+        return CrawlTarget.FMKOREA;
+    }
+
+    @Override
+    public void handle() {
+    }
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/crawlhandler/PpomppuCrawlDomesticHandler.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/crawlhandler/PpomppuCrawlDomesticHandler.java
@ -0,0 +1,58 @@
+package com.myoa.engineering.crawl.shopping.crawlhandler;
+
+import com.myoa.engineering.crawl.shopping.crawlhandler.parser.PpomppuArticleParserV2;
+import com.myoa.engineering.crawl.shopping.domain.entity.v2.Article;
+import com.myoa.engineering.crawl.shopping.infra.client.ppomppu.PpomppuBoardClientV2;
+import com.myoa.engineering.crawl.shopping.service.ArticleCommandService;
+import com.myoa.engineering.crawl.shopping.support.dto.constant.CrawlTarget;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Stream;
+
+@Component
+public class PpomppuCrawlDomesticHandler implements CrawlHandler {
+
+    private final PpomppuBoardClientV2 ppomppuBoardClient;
+    private final PpomppuArticleParserV2 ppomppuArticleParserV2;
+    private final ArticleCommandService articleCommandService;
+
+    public PpomppuCrawlDomesticHandler(PpomppuBoardClientV2 ppomppuBoardClient,
+                                       PpomppuArticleParserV2 ppomppuArticleParserV2,
+                                       ArticleCommandService articleCommandService) {
+        this.ppomppuBoardClient = ppomppuBoardClient;
+        this.ppomppuArticleParserV2 = ppomppuArticleParserV2;
+        this.articleCommandService = articleCommandService;
+    }
+
+    @Override
+    public CrawlTarget getCrawlTarget() {
+        return CrawlTarget.PPOMPPU_DOMESTIC;
+    }
+
+    @Override
+    public void handle() {
+
+        String boardHtmlPage1 = ppomppuBoardClient.getBoardHtml("/zboard/zboard.php", generateRequestParams(1));
+        List<Article> parsedPage1 = ppomppuArticleParserV2.parse(boardHtmlPage1);
+
+        String boardHtmlPage2 = ppomppuBoardClient.getBoardHtml("/zboard/zboard.php", generateRequestParams(2));
+        List<Article> parsedPage2 = ppomppuArticleParserV2.parse(boardHtmlPage2);
+
+        List<Article> merged = Stream.of(parsedPage1, parsedPage2)
+                                     .flatMap(List::stream)
+                                     .map(e -> e.updateCrawlTarget(getCrawlTarget()))
+                                     .toList();
+
+        articleCommandService.upsert(merged);
+    }
+
+    private Map<String, String> generateRequestParams(int pageId) {
+        Map<String, String> params = new HashMap<>();
+        params.put("id", "ppomppu");
+        params.put("page", String.valueOf(pageId));
+        return params;
+    }
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/crawlhandler/parser/PpomppuArticleParserV2.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/crawlhandler/parser/PpomppuArticleParserV2.java
@ -0,0 +1,115 @@
+package com.myoa.engineering.crawl.shopping.crawlhandler.parser;
+
+import com.myoa.engineering.crawl.shopping.domain.entity.v2.Article;
+import com.myoa.engineering.crawl.shopping.support.dto.constant.PpomppuBoardName;
+import com.myoa.engineering.crawl.shopping.util.DateTimeUtils;
+import com.myoa.engineering.crawl.shopping.util.NumberUtils;
+import io.micrometer.core.instrument.util.StringUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.jsoup.Jsoup;
+import org.jsoup.nodes.Document;
+import org.jsoup.nodes.Element;
+import org.jsoup.select.Elements;
+import org.springframework.stereotype.Component;
+
+import java.time.ZoneId;
+import java.time.ZonedDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.List;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+@Slf4j
+@Component
+public final class PpomppuArticleParserV2 {
+
+    private static final DateTimeFormatter DATE_TIME_FORMATTER = DateTimeFormatter.ofPattern("yy.MM.dd HH:mm:ss")
+                                                                                  .withZone(ZoneId.of("Asia/Seoul"));
+
+    private PpomppuArticleParserV2() {
+    }
+
+    public List<Article> parse(String html) {
+        Elements trElements = converHtmlToTrElements(html);
+        return trElements.stream()
+                         .filter(this::isRealArticle)
+                         .map(this::parse)
+                         .toList();
+
+    }
+
+    private Elements converHtmlToTrElements(String data) {
+        Document document = Jsoup.parse(data);
+        Elements trList = document.getElementById("revolution_main_table").getElementsByTag("tr");
+        return trList;
+    }
+
+    private boolean isRealArticle(Element tr) {
+        Elements tdList = tr.getElementsByTag("td");
+        if (tdList.size() != 6) {
+            return false;
+        }
+
+        if (!hasOnlyNumeric(tdList.get(0))) {
+            return false;
+        }
+
+        return true;
+    }
+
+    private Pattern pattern_numeric = Pattern.compile("\\d+");
+
+    private boolean hasOnlyNumeric(Element td) {
+        return pattern_numeric.matcher(td.text()).matches();
+    }
+
+    private Article parse(Element tr) {
+        Elements tdList = tr.getElementsByTag("td");
+        Long articleId = Long.parseLong(tdList.get(0).text());
+
+        String title = tdList.get(2).text();
+        String articleUrl = parseArticleUrl(tdList.get(2).getElementsByTag("a").attr("href"));
+        String boardName = parseBoardName(title);
+        Integer recommended = parseRecommended(tdList.get(4));
+        Integer hit = NumberUtils.parseInt(tdList.get(5).text(), 0);
+        ZonedDateTime registeredAt = DateTimeUtils.parse(tdList.get(3).text());
+
+        return Article.builder()
+                      .articleId(articleId)
+                      .title(title)
+                      .boardName(boardName)
+                      .articleUrl(articleUrl)
+                      .recommended(recommended)
+                      .hit(hit)
+                      .registeredAt(registeredAt)
+                      .build();
+    }
+
+    public Integer parseRecommended(Element td) {
+        final String voteString = td.text();
+        if (StringUtils.isEmpty(voteString)) {
+            return null;
+        }
+
+        final int voteUp = Integer.parseInt(td.text().split(" - ")[0]);
+        final int voteDown = Integer.parseInt(td.text().split(" - ")[1]);
+        int recommended = voteUp - voteDown;
+        return recommended;
+    }
+
+    public static String parseArticleUrl(String data) {
+        return PpomppuBoardName.ofViewPageUrl(data);
+    }
+
+    Pattern patternBoardName = Pattern.compile("\\[(.+?)\\]");
+
+    public String parseBoardName(String fullTitle) {
+        Matcher matcher = patternBoardName.matcher(fullTitle);
+        String lastMatched = null;
+        while (matcher.find()) {
+            lastMatched = matcher.group(1);
+        }
+        return lastMatched;
+    }
+
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/Auditable.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/Auditable.java
@ -1,17 +1,19 @@
-package com.myoa.engineering.crawl.ppomppu.processor.domain;
+package com.myoa.engineering.crawl.shopping.domain.entity;

-import java.io.Serializable;
-import java.time.Instant;
-import javax.persistence.Column;
+import lombok.Getter;
 import org.springframework.data.annotation.CreatedDate;
 import org.springframework.data.annotation.LastModifiedDate;
+import org.springframework.data.jpa.domain.support.AuditingEntityListener;

-/**
- * Auditable
- *
- * @author Shin Woo-jin (woozu.shin@kakaoent.com)
- * @since 2021-09-08
- */
+import javax.persistence.Column;
+import javax.persistence.EntityListeners;
+import javax.persistence.MappedSuperclass;
+import java.io.Serializable;
+import java.time.Instant;
+
+@Getter
+@MappedSuperclass
+@EntityListeners(AuditingEntityListener.class)
 public abstract class Auditable implements Serializable {
    private static final long serialVersionUID = -7105030870015828551L;

--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/BaseScanDomain.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/BaseScanDomain.java
@ -1,4 +1,4 @@
-package com.myoa.engineering.crawl.ppomppu.processor.domain;
+package com.myoa.engineering.crawl.shopping.domain.entity;

 /**
 * BaseScanDomain
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v1/PpomppuArticle.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v1/PpomppuArticle.java
@ -1,19 +1,14 @@
-package com.myoa.engineering.crawl.ppomppu.processor.domain;
+package com.myoa.engineering.crawl.shopping.domain.entity.v1;

-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
-import java.time.Instant;
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.EnumType;
-import javax.persistence.Enumerated;
-import javax.persistence.GeneratedValue;
-import javax.persistence.GenerationType;
-import javax.persistence.Id;
-import javax.persistence.Table;
+import com.myoa.engineering.crawl.shopping.domain.entity.Auditable;
+import com.myoa.engineering.crawl.shopping.support.dto.constant.PpomppuBoardName;
 import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;

+import javax.persistence.*;
+import java.time.Instant;
+
@Getter
@NoArgsConstructor
@Entity
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v1/PpomppuBoardFeedStatus.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v1/PpomppuBoardFeedStatus.java
@ -1,19 +1,14 @@
-package com.myoa.engineering.crawl.ppomppu.processor.domain;
+package com.myoa.engineering.crawl.shopping.domain.entity.v1;

-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
-import java.time.Instant;
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.EnumType;
-import javax.persistence.Enumerated;
-import javax.persistence.GeneratedValue;
-import javax.persistence.GenerationType;
-import javax.persistence.Id;
-import javax.persistence.Table;
+import com.myoa.engineering.crawl.shopping.domain.entity.Auditable;
+import com.myoa.engineering.crawl.shopping.support.dto.constant.PpomppuBoardName;
 import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;

+import javax.persistence.*;
+import java.time.Instant;
+
@Getter
@NoArgsConstructor
@Entity
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v1/PublishedHistory.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v1/PublishedHistory.java
@ -1,15 +1,12 @@
-package com.myoa.engineering.crawl.ppomppu.processor.domain;
+package com.myoa.engineering.crawl.shopping.domain.entity.v1;

-import java.time.Instant;
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.GeneratedValue;
-import javax.persistence.GenerationType;
-import javax.persistence.Id;
-import javax.persistence.Table;
+import com.myoa.engineering.crawl.shopping.domain.entity.Auditable;
 import lombok.Getter;
 import lombok.NoArgsConstructor;

+import javax.persistence.*;
+import java.time.Instant;
+
@Getter
@NoArgsConstructor
@Entity
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v1/SubscribedBoard.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v1/SubscribedBoard.java
@ -0,0 +1,27 @@
+package com.myoa.engineering.crawl.shopping.domain.entity.v1;
+
+import com.myoa.engineering.crawl.shopping.domain.entity.Auditable;
+import com.myoa.engineering.crawl.shopping.support.dto.constant.PpomppuBoardName;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import javax.persistence.*;
+
+@Getter
+@NoArgsConstructor
+@Entity
+@Table(name = "subscribed_board")
+public class SubscribedBoard extends Auditable {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column
+    private Long userId;
+
+    @Column
+    @Enumerated(EnumType.STRING)
+    private PpomppuBoardName boardName;
+
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v1/SubscribedUser.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v1/SubscribedUser.java
@ -1,20 +1,17 @@
-package com.myoa.engineering.crawl.ppomppu.processor.domain;
+package com.myoa.engineering.crawl.shopping.domain.entity.v1;

-import java.time.Instant;
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.GeneratedValue;
-import javax.persistence.GenerationType;
-import javax.persistence.Id;
-import javax.persistence.Table;
+import com.myoa.engineering.crawl.shopping.domain.entity.Auditable;
 import lombok.Getter;
 import lombok.NoArgsConstructor;

+import javax.persistence.*;
+import java.time.Instant;
+
@Getter
@NoArgsConstructor
@Entity
@Table(name = "subscribed_user")
-public class SubscribedUser extends Auditable{
+public class SubscribedUser extends Auditable {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v2/AppUser.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v2/AppUser.java
@ -0,0 +1,29 @@
+package com.myoa.engineering.crawl.shopping.domain.entity.v2;
+
+import com.myoa.engineering.crawl.shopping.domain.entity.Auditable;
+import javax.persistence.*;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+@Entity
+@Table
+public class AppUser extends Auditable {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column
+    private String name;
+
+    @Column
+    private String slackId;
+
+    @Column
+    private Boolean enabled;
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v2/Article.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v2/Article.java
@ -0,0 +1,63 @@
+package com.myoa.engineering.crawl.shopping.domain.entity.v2;
+
+import com.myoa.engineering.crawl.shopping.domain.entity.Auditable;
+import com.myoa.engineering.crawl.shopping.support.dto.constant.CrawlTarget;
+import javax.persistence.*;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.time.ZonedDateTime;
+
+@Getter
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+@Entity
+@Table
+public class Article extends Auditable {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column
+    private Long articleId;
+
+    @Column
+    @Enumerated(EnumType.STRING)
+    private CrawlTarget crawlTarget;
+
+    @Column
+    private String boardName;
+
+    @Column
+    private String articleUrl;
+
+    @Column
+    private String title;
+
+    @Column
+    private Integer hit;
+
+    @Column
+    private Integer recommended;
+
+    @Column
+    private ZonedDateTime registeredAt;
+
+    public Article update(Article article) {
+        this.boardName = article.getBoardName();
+        this.articleUrl = article.getArticleUrl();
+        this.title = article.getTitle();
+        this.hit = article.getHit();
+        this.recommended = article.getRecommended();
+        return this;
+    }
+
+    public Article updateCrawlTarget(CrawlTarget crawlTarget) {
+        this.crawlTarget = crawlTarget;
+        return this;
+    }
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v2/SubscribedKeyword.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/entity/v2/SubscribedKeyword.java
@ -0,0 +1,33 @@
+package com.myoa.engineering.crawl.shopping.domain.entity.v2;
+
+import com.myoa.engineering.crawl.shopping.domain.entity.Auditable;
+import com.myoa.engineering.crawl.shopping.support.dto.constant.CrawlTarget;
+import javax.persistence.*;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+@Entity
+@Table
+public class SubscribedKeyword extends Auditable {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column
+    private String keyword;
+
+    @Column
+    @Enumerated(EnumType.STRING)
+    private CrawlTarget crawlTarget;
+
+    @Column
+    private String userId;
+
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/model/UserNotifyModel.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/model/UserNotifyModel.java
@ -0,0 +1,24 @@
+package com.myoa.engineering.crawl.shopping.domain.model;
+
+import com.myoa.engineering.crawl.shopping.domain.model.v2.ArticleModel;
+import lombok.*;
+
+import java.util.List;
+
+
+@ToString
+@Getter
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class UserNotifyModel {
+    private String userId;
+    private List<ArticleModel> articles;
+
+    public static UserNotifyModel of(String userId, List<ArticleModel> articles) {
+        return UserNotifyModel.builder()
+                              .userId(userId)
+                              .articles(articles)
+                              .build();
+    }
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/model/v2/AppUserModel.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/model/v2/AppUserModel.java
@ -0,0 +1,26 @@
+package com.myoa.engineering.crawl.shopping.domain.model.v2;
+
+import com.myoa.engineering.crawl.shopping.domain.entity.v2.AppUser;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+
+@Getter
+@Builder
+@AllArgsConstructor
+public class AppUserModel {
+
+    private Long id;
+    private String name;
+    private String slackId;
+    private Boolean enabled;
+
+    public static AppUserModel from(AppUser entity) {
+        return AppUserModel.builder()
+                           .id(entity.getId())
+                           .name(entity.getName())
+                           .slackId(entity.getSlackId())
+                           .enabled(entity.getEnabled())
+                           .build();
+    }
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/model/v2/ArticleModel.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/model/v2/ArticleModel.java
@ -0,0 +1,25 @@
+package com.myoa.engineering.crawl.shopping.domain.model.v2;
+
+import com.myoa.engineering.crawl.shopping.support.dto.constant.CrawlTarget;
+import lombok.*;
+
+import java.time.ZonedDateTime;
+
+@ToString
+@Getter
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class ArticleModel {
+
+    private Long id;
+    private Long articleId;
+    private CrawlTarget crawlTarget;
+    private String boardName;
+    private String articleUrl;
+    private String title;
+    private Integer hit;
+    private Integer recommended;
+    private ZonedDateTime registeredAt;
+
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/model/v2/SubscribedKeywordAggregatedModel.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/domain/model/v2/SubscribedKeywordAggregatedModel.java
@ -0,0 +1,27 @@
+package com.myoa.engineering.crawl.shopping.domain.model.v2;
+
+import com.myoa.engineering.crawl.shopping.support.dto.constant.CrawlTarget;
+import com.myoa.engineering.crawl.shopping.util.AhoCorasickUtils;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import org.ahocorasick.trie.Trie;
+
+import java.util.List;
+
+@Getter
+@Builder
+@AllArgsConstructor
+public class SubscribedKeywordAggregatedModel {
+    private final Trie ahoCorasickTrie;
+    private final String userId;
+    private final CrawlTarget crawlTarget;
+
+    public static SubscribedKeywordAggregatedModel of(String userId, CrawlTarget crawlTarget, List<String> keywords) {
+        return SubscribedKeywordAggregatedModel.builder()
+                                               .userId(userId)
+                                               .crawlTarget(crawlTarget)
+                                               .ahoCorasickTrie(AhoCorasickUtils.generateTrie(keywords))
+                                               .build();
+    }
+}
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/dto/FeedParsedResult.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/dto/FeedParsedResult.java
@ -1,12 +1,13 @@
-package com.myoa.engineering.crawl.ppomppu.processor.dto;
+package com.myoa.engineering.crawl.shopping.dto;

-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
-import java.io.Serializable;
-import java.time.Instant;
+import com.myoa.engineering.crawl.shopping.support.dto.constant.PpomppuBoardName;
 import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;

+import java.io.Serializable;
+import java.time.Instant;
+
 /**
 * FeedParsedResult
 *
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/dto/PpomppuArticleParseDTO.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/dto/PpomppuArticleParseDTO.java
@ -1,14 +1,13 @@
-package com.myoa.engineering.crawl.ppomppu.processor.dto;
-
-import java.time.Instant;
-
-import com.myoa.engineering.crawl.ppomppu.processor.domain.PpomppuArticle;
-import com.myoa.engineering.crawl.ppomppu.support.util.DateUtil;
+package com.myoa.engineering.crawl.shopping.dto;

+import com.myoa.engineering.crawl.shopping.domain.entity.v1.PpomppuArticle;
+import com.myoa.engineering.crawl.shopping.support.util.DateUtil;
 import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;

+import java.time.Instant;
+
 /**
 * PpomppuArticleParseDTO
 *
@ -46,7 +45,7 @@ public class PpomppuArticleParseDTO {

    public boolean isInValidated() {
        return articleId == null || articleId.isEmpty()
-               || hit == null || hit.isEmpty();
+                || hit == null || hit.isEmpty();
    }

    public PpomppuArticle convert() {
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/dto/PpomppuArticleTransformer.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/dto/PpomppuArticleTransformer.java
@ -1,39 +1,40 @@
-package com.myoa.engineering.crawl.ppomppu.processor.dto;
+package com.myoa.engineering.crawl.shopping.dto;
+
+import com.myoa.engineering.crawl.shopping.domain.entity.v1.PpomppuArticle;
+import com.myoa.engineering.crawl.shopping.support.dto.BlockMessageDTO;
+import com.myoa.engineering.crawl.shopping.support.dto.SimpleMessageDTO;
+import com.myoa.engineering.crawl.shopping.support.dto.constant.PpomppuBoardName;
+import com.myoa.engineering.crawl.shopping.support.util.DateUtil;

 import java.time.Instant;
 import java.util.List;
 import java.util.function.Function;
 import java.util.stream.Collectors;

-import com.myoa.engineering.crawl.ppomppu.processor.domain.PpomppuArticle;
-import com.myoa.engineering.crawl.ppomppu.support.dto.BlockMessageDTO;
-import com.myoa.engineering.crawl.ppomppu.support.dto.SimpleMessageDTO;
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
-import com.myoa.engineering.crawl.ppomppu.support.util.DateUtil;
-
 /**
 * PpomppuArticleTransformer
+ *
 * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
 * @since 2021-11-21
- *
 */
 public final class PpomppuArticleTransformer {

-    private PpomppuArticleTransformer() {}
+    private PpomppuArticleTransformer() {
+    }

    private static final String MESSAGE_FORMAT_V1 = "%s)) <%s|LINK> `%s` ";
    private static final String MESSAGE_FORMAT_V2 = "%s *<%s|LINK>*\n%s";
    private static final String TITLE_FORMAT_V1 = "_*:hearts: %s | %s*_";

    public static final Function<PpomppuArticle, SimpleMessageDTO> TRANSFORM_TO_MESSAGE_DTO = article ->
-        SimpleMessageDTO.builder()
-                        .requestedAt(Instant.now())
-                        .publishedAt(article.getRegisteredAt())
-                        .title(String.format(MESSAGE_FORMAT_V1,
-                                             article.getBoardName().getMenuName(), article.getArticleUrl(),
-                                             article.getTitle()))
-                        .body(article.getArticleUrl())
-                        .build();
+            SimpleMessageDTO.builder()
+                            .requestedAt(Instant.now())
+                            .publishedAt(article.getRegisteredAt())
+                            .title(String.format(MESSAGE_FORMAT_V1,
+                                                 article.getBoardName().getMenuName(), article.getArticleUrl(),
+                                                 article.getTitle()))
+                            .body(article.getArticleUrl())
+                            .build();

    // https://stackoverflow.com/questions/24882927/using-streams-to-convert-a-list-of-objects-into-a-string-obtained-from-the-tostr
    public static SimpleMessageDTO transformToSimpleMessage(List<PpomppuArticle> articles) {
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/dto/constant/WebClientPropertiesUnitName.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/dto/constant/WebClientPropertiesUnitName.java
@ -1,4 +1,4 @@
-package com.myoa.engineering.crawl.ppomppu.processor.dto.constant;
+package com.myoa.engineering.crawl.shopping.dto.constant;

 import lombok.AllArgsConstructor;
 import lombok.Getter;
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/MessageDTO.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/MessageDTO.java
@ -1,4 +1,4 @@
-package com.myoa.engineering.crawl.ppomppu.sender.dto;
+package com.myoa.engineering.crawl.shopping.dto.slack;

 import java.io.Serializable;

--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackBaseMessageBlock.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackBaseMessageBlock.java
@ -1,4 +1,4 @@
-package com.myoa.engineering.crawl.ppomppu.sender.dto;
+package com.myoa.engineering.crawl.shopping.dto.slack;

 import com.fasterxml.jackson.annotation.JsonInclude;

--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackImageMessageBlock.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackImageMessageBlock.java
@ -1,4 +1,4 @@
-package com.myoa.engineering.crawl.ppomppu.sender.dto;
+package com.myoa.engineering.crawl.shopping.dto.slack;

 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.annotation.JsonProperty;
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackMessageBlock.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackMessageBlock.java
@ -1,4 +1,4 @@
-package com.myoa.engineering.crawl.ppomppu.sender.dto;
+package com.myoa.engineering.crawl.shopping.dto.slack;

 import java.io.Serializable;

--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackMessageBlockType.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackMessageBlockType.java
@ -1,4 +1,4 @@
-package com.myoa.engineering.crawl.ppomppu.sender.dto;
+package com.myoa.engineering.crawl.shopping.dto.slack;

 import lombok.AllArgsConstructor;
 import lombok.Getter;
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackMessageDTO.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackMessageDTO.java
@ -1,21 +1,19 @@
-package com.myoa.engineering.crawl.ppomppu.sender.dto;
-
-import java.util.List;
+package com.myoa.engineering.crawl.shopping.dto.slack;

 import com.fasterxml.jackson.annotation.JsonInclude;
 import com.fasterxml.jackson.annotation.JsonProperty;
-import com.myoa.engineering.crawl.ppomppu.support.dto.BlockMessageDTO;
-import com.myoa.engineering.crawl.ppomppu.support.dto.BlockMessageDTO.Block;
-
+import com.myoa.engineering.crawl.shopping.support.dto.BlockMessageDTO;
 import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;

+import java.util.List;
+
 /**
 * SlackMessageDTO
+ *
 * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
 * @since 2021-11-14
- *
 */
@Getter
@NoArgsConstructor
@ -51,6 +49,7 @@ public class SlackMessageDTO implements MessageDTO {
        slackSectionMessageBlock.applyImageaccessory(block.getImageUrl(), block.getAltText());
        addBlock(slackSectionMessageBlock);
    }
+
    public void addSectionBlock(String rawBlockMessage) {
        addBlock(SlackSectionMessageBlock.ofMarkDown(rawBlockMessage));
    }
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackSectionMessageBlock.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/dto/slack/SlackSectionMessageBlock.java
@ -1,16 +1,15 @@
-package com.myoa.engineering.crawl.ppomppu.sender.dto;
+package com.myoa.engineering.crawl.shopping.dto.slack;

 import com.fasterxml.jackson.annotation.JsonInclude;
-
 import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;

 /**
 * SectionBlock
+ *
 * @author Shin Woo-jin (woo-jin.shin@linecorp.com)
 * @since 2021-11-30
- *
 */
@Getter
@NoArgsConstructor
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/event/ArticleUpsertEvent.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/event/ArticleUpsertEvent.java
@ -0,0 +1,13 @@
+package com.myoa.engineering.crawl.shopping.event;
+
+import com.myoa.engineering.crawl.shopping.domain.model.v2.ArticleModel;
+import org.springframework.context.ApplicationEvent;
+
+import java.util.List;
+
+public class ArticleUpsertEvent extends ApplicationEvent {
+
+    public ArticleUpsertEvent(List<ArticleModel> source) {
+        super(source);
+    }
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/event/ArticleUpsertEventPayload.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/event/ArticleUpsertEventPayload.java
@ -0,0 +1,15 @@
+package com.myoa.engineering.crawl.shopping.event;
+
+import com.myoa.engineering.crawl.shopping.domain.model.v2.ArticleModel;
+import com.myoa.engineering.crawl.shopping.support.dto.constant.CrawlTarget;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.util.List;
+
+@Getter
+@AllArgsConstructor
+public class ArticleUpsertEventPayload {
+    private final List<ArticleModel> articles;
+    private final CrawlTarget crawlTarget;
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/event/handler/ArticleUpsertEventListener.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/event/handler/ArticleUpsertEventListener.java
@ -0,0 +1,86 @@
+package com.myoa.engineering.crawl.shopping.event.handler;
+
+import com.myoa.engineering.crawl.shopping.domain.model.UserNotifyModel;
+import com.myoa.engineering.crawl.shopping.domain.model.v2.AppUserModel;
+import com.myoa.engineering.crawl.shopping.domain.model.v2.ArticleModel;
+import com.myoa.engineering.crawl.shopping.domain.model.v2.SubscribedKeywordAggregatedModel;
+import com.myoa.engineering.crawl.shopping.event.ArticleUpsertEvent;
+import com.myoa.engineering.crawl.shopping.service.AppUserQueryService;
+import com.myoa.engineering.crawl.shopping.service.SubscribedKeywordCacheService;
+import com.myoa.engineering.crawl.shopping.service.UserNotifyService;
+import com.myoa.engineering.crawl.shopping.support.dto.constant.CrawlTarget;
+import org.springframework.context.event.EventListener;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+@Component
+public class ArticleUpsertEventListener {
+
+    private final SubscribedKeywordCacheService subscribedKeywordCacheService;
+    private final AppUserQueryService appUserQueryService;
+    private final UserNotifyService userNotifyService;
+
+
+    public ArticleUpsertEventListener(SubscribedKeywordCacheService subscribedKeywordCacheService,
+                                      AppUserQueryService appUserQueryService, UserNotifyService userNotifyService) {
+        this.subscribedKeywordCacheService = subscribedKeywordCacheService;
+        this.appUserQueryService = appUserQueryService;
+        this.userNotifyService = userNotifyService;
+    }
+
+
+    @EventListener
+    public void handleArticleUpsertEvent(ArticleUpsertEvent event) {
+        Map<CrawlTarget, List<ArticleModel>> articleMap =
+                ((List<ArticleModel>) event.getSource()).stream()
+                                                        .collect(Collectors.groupingBy(ArticleModel::getCrawlTarget));
+        List<AppUserModel> appUsers = appUserQueryService.findAll();
+
+        appUsers.stream()
+                .filter(AppUserModel::getEnabled)
+                .map(user -> {
+                    List<ArticleModel> filteredArticles = handleAhoCorasick(articleMap)
+                            .apply(subscribedKeywordCacheService.getSubscribedKeywordsCached(user.getName()));
+                    return UserNotifyModel.of(user.getName(), filteredArticles);
+                })
+                .forEach(this::notifyMessage);
+
+    }
+
+    private Function<Map<CrawlTarget, SubscribedKeywordAggregatedModel>, List<ArticleModel>> handleAhoCorasick(
+            Map<CrawlTarget, List<ArticleModel>> articleMap) {
+        return userTrieModel -> {
+            return userTrieModel
+                    .entrySet()
+                    .stream().filter(e -> articleMap.containsKey(e.getKey()))
+                    .map((entry) -> filterAhocorasick(articleMap.get(entry.getKey()), entry.getValue()))
+                    .flatMap(List::stream)
+                    .toList();
+//            return UserNotifyModel.of(userTrieModel.values().stream().findFirst().get().getUserId(),
+//                                      filteredArticle);
+        };
+    }
+
+    private List<ArticleModel> filterAhocorasick(List<ArticleModel> articles,
+                                                 SubscribedKeywordAggregatedModel trieModel) {
+        return articles.stream()
+                       .filter(article -> !trieModel.getAhoCorasickTrie()
+                                                    .parseText(article.getTitle())
+                                                    .isEmpty())
+                       .toList();
+        //ArticleUpsertEventListener::printArticle
+    }
+
+    private void notifyMessage(UserNotifyModel article) {
+        System.out.println("article = " + article);
+        if (article.getArticles().isEmpty()){
+            return;
+        }
+        userNotifyService.notify("안녕 " + article.getUserId() + "\n" + article.getArticles());
+    }
+
+}
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/infra/client/fmkorea/FmkoreaBoardClient.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/infra/client/fmkorea/FmkoreaBoardClient.java
@ -0,0 +1,12 @@
+package com.myoa.engineering.crawl.shopping.infra.client.fmkorea;
+
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+
+@FeignClient(value = "fmkorea-board-client", url = "https://fmkorea.com")
+public interface FmkoreaBoardClient {
+
+    @GetMapping("{boardLink}")
+    String getBoardHtml(@PathVariable("boardLink") String boardLink);
+}
--- a/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/infrastructure/client/PpomppuBoardFeedRetriever.java
+++ b/processor/src/main/java/com/myoa/engineering/crawl/ppomppu/processor/infrastructure/client/PpomppuBoardFeedRetriever.java
@ -1,16 +1,7 @@
-package com.myoa.engineering.crawl.ppomppu.processor.infrastructure.client;
+package com.myoa.engineering.crawl.shopping.infra.client.ppomppu;

-import com.myoa.engineering.crawl.ppomppu.support.webclient.factory.WebClientFilterFactory;
-import com.myoa.engineering.crawl.ppomppu.support.webclient.factory.WebFluxExchangeStragiesFactory;
-import com.myoa.engineering.crawl.ppomppu.support.dto.code.PpomppuBoardName;
 import lombok.extern.slf4j.Slf4j;
-
-import org.springframework.core.ParameterizedTypeReference;
 import org.springframework.stereotype.Component;
-import org.springframework.web.reactive.function.client.WebClient;
-import org.springframework.web.reactive.function.client.WebClientRequestException;
-import reactor.core.publisher.Mono;
-import reactor.core.scheduler.Schedulers;

 /**
 * PpomppuBoardFeedRetriever
@ -20,11 +11,11 @@ import reactor.core.scheduler.Schedulers;
 */
@Slf4j
@Component
-public class PpomppuBoardFeedRetriever {
-
+public class PpomppuBoardClient {
+/*
    private final WebClient webClient;

-    public PpomppuBoardFeedRetriever(WebClient.Builder webClientBuilder) {
+    public PpomppuBoardClient(WebClient.Builder webClientBuilder) {
        this.webClient = webClientBuilder.baseUrl(PpomppuBoardName.PPOMPPU_URL)
                                         .exchangeStrategies(WebFluxExchangeStragiesFactory.ofTextHtml())
                                         .filter(WebClientFilterFactory.logRequest())
@ -43,5 +34,5 @@ public class PpomppuBoardFeedRetriever {
                        });
                        // .doOnNext(e -> log.info("[getHtml] {}", e));
    }
-
+*/
 }
--- a/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/infra/client/ppomppu/PpomppuBoardClientV2.java
+++ b/shopping-crawler/src/main/java/com/myoa/engineering/crawl/shopping/infra/client/ppomppu/PpomppuBoardClientV2.java
@ -0,0 +1,17 @@
+package com.myoa.engineering.crawl.shopping.infra.client.ppomppu;
+
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.cloud.openfeign.SpringQueryMap;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.Map;
+
+@FeignClient(value = "ppomppu-board-client", url = "https://www.ppomppu.co.kr")
+public interface PpomppuBoardClientV2 {
+
+    @GetMapping("{boardLink}")
+    String getBoardHtml(@PathVariable("boardLink") String boardLink,
+                        @SpringQueryMap Map<String, String> params);
+}
--- a/Show More
+++ b/Show More
Author	SHA1	Message	Date
woozu-shin	378e6ef68e	[NO-ISSUE] Change references	2024-05-09 09:32:39 +09:00
woozu-shin	08737664f4	Merge branch 'feature/NO-ISSUE-v2' into develop	2024-05-09 08:50:05 +09:00
woozu-shin	7b015e8093	[NO-ISSUE] Remove reader, processor, writer	2024-05-09 08:49:11 +09:00
woozu-shin	b4accbc2c0	[NO-ISSUE] Initialize v2	2024-05-09 08:48:36 +09:00
woozu-shin	0c4be3cc05	[NO-ISSUE] Implement v2	2024-04-30 22:34:49 +09:00
nthfuncx	4738b930df	Merge pull request '[PPN-13] Deal with new page board structure' (#14 ) from feature/PPN-13 into develop Reviewed-on: OutworldDestroyer/PpomppuNotifier#14	2022-01-02 12:50:21 +09:00