internal/parsers/mandarake/handleTasks.go

@@ -10,39 +10,8 @@ import (
 	"task-processor/internal/shared"
 )
 
-func (s *Parser) setupBrowser(ctx context.Context) (string, error) {
-	allocCtx, allocCancel := chromedp.NewRemoteAllocator(ctx, s.externalBrowser)
-	defer allocCancel()
-
-	pageCtx, pageCancel := chromedp.NewContext(allocCtx, chromedp.WithLogf(func(string, ...any) {}))
-	defer pageCancel()
-
-	copyright := "No copyright div found."
-
-	if err := chromedp.Run(pageCtx,
-		chromedp.Navigate("https://www.mandarake.co.jp/"),
-		chromedp.WaitReady("body", chromedp.ByQuery),
-		chromedp.Text(`div.copyright`, &copyright, chromedp.ByQuery, chromedp.AtLeast(0)),
-		chromedp.Navigate("https://www.mandarake.co.jp/index2.html"),
-		chromedp.WaitReady("body", chromedp.ByQuery),
-	); err != nil {
-		log.WithError(err).Error(logHeader + logGetPrice + "failed to get single price tag")
-		return copyright, err
-	}
-
-	return copyright, nil
-}
-
 func (s *Parser) HandleTasks(ctx context.Context, tasks []shared.Task, sender chan shared.TaskResult, state *appState.State) {
-	log.Infof("%v Start handling tasks", logHeader)
+	log.Infof("%v %v handling tasks", logHeader, logWorker)
-	log.Infof("%v Setting up browser", logHeader)
-	cr, err := s.setupBrowser(ctx)
-	if err != nil {
-		log.WithError(err).Error(logHeader + logGetPrice + "failed to setup browser")
-	}
-	log.WithField("Copyright message", cr).Infof("%v Finished setting up browser.", logHeader)
-
-	log.Infof("%v %v processing tasks...", logHeader, logWorker)
 
 	allocCtx, allocCancel := chromedp.NewRemoteAllocator(ctx, s.externalBrowser)
 	defer allocCancel()

pkg/router/handler.go

@@ -21,7 +21,7 @@ type Deps struct {
 const pkgLogHeader string = "Router |"
 
 func NewHandler(deps Deps) *Handler {
-	engine := gin.New()
+	engine := gin.Default()
 
 	if deps.GinMode == "release" {
 		gin.SetMode(gin.ReleaseMode)
@@ -32,12 +32,17 @@ func NewHandler(deps Deps) *Handler {
 		}
 	}
 
-	logGroup := engine.Group("")
+	engine.GET("/", func(c *gin.Context) { c.JSON(200, gin.H{"msg": "v2"}) })
-	logGroup.GET("/", func(c *gin.Context) { c.JSON(200, gin.H{"msg": "v2"}) })
 
 	p := ginprometheus.NewPrometheus("gin")
 	p.Use(engine)
 
+	engine.Use(gin.LoggerWithConfig(gin.LoggerConfig{
+		Skip: func(c *gin.Context) bool {
+			return c.Request.URL.Path == "/metrics"
+		},
+	}))
+
 	srv := http.Server{
 		Addr:    deps.Addr,
 		Handler: engine,