GET http://localhost:33003/
# Trả về: {"message": "Hello, World API!"}

{
  "ads": [
    { "url": "https://...", "rank": 1, "type": "company", "confirm_status": true, "label": "", "title": "...", "description": "..." }
  ],
  "search": [
    { "url": "https://...", "rank": 1, "type": "competitors", "confirm_status": false, "label": "", "title": "...", "description": "..." }
  ]
}

+------------------------------------------------------------------+
|                        CLIENTS                                    |
|  Admin Frontend (Vue 3)  |  Tool Search (Node.js/Bun)            |
+-------------+------------+--------------+------------------------+
              |  JWT Auth                  |  API Key / Webhook Key
              v                           v
+------------------------------------------------------------------+
|                  SEARCH TOOL API (Go + Fiber)                    |
|                        Port: 33003                               |
|                                                                  |
|  Middleware: CORS | Helmet | Logger | JWT | API Key | WH Key     |
|                                                                  |
|  Route Groups:                                                   |
|  /api/*         (JWT Auth)   - User, Proxy, Server, Keyword      |
|  /search/*      (API Key)    - KeywordPoolTask CRUD              |
|  /anchor-text/* (API Key)    - AnchorText CRUD                   |
|  /webhook/*     (WH Key)     - Proxy & Search result callbacks    |
|  /ws            (Socket.IO)  - Real-time updates                 |
|                                                                  |
|  Scheduler (gocron):                                             |
|  - Reset proxy errors | Send search tasks | Keyword search cron  |
+---+------------------+------+-----+-----------------------------+
    |                  |            |
+---v---+     +--------v-------+  +-v---------+
| MySQL |     |    MongoDB     |  |   Redis   |
| GORM  |     | (Mongo Driver) |  |  (Cache)  |
|       |     |                |  |           |
|users  |     |keywords        |  |task cache |
|servers|     |keyword_results |  |locks      |
|act_   |     |proxies         |  |           |
|logs   |     |anchor_texts    |  +-----------+
+-------+     |keyword_pool_   |
              |  tasks         |
              +----------------+

[Cron SCHEDULE_SEARCH_KEYWORD - gocron]
  -> keyword.service.SearchKeyword()
  -> Lấy tất cả keyword status=Enable từ MongoDB (keywords)
  -> Tạo SearchKeywordRequest cho từng tổ hợp (keyword x engine x device)
  -> Lưu vào MongoDB: keyword_pool_tasks   <-- buffer/queue

[Cron keyword_pool_task - goroutine, loop mỗi 60s]
  -> Lấy tất cả task từ keyword_pool_tasks
  -> Kiểm tra Redis cache (key: keyword_engine_device_os):
       - Nếu có cache -> gọi hook_url trả kết quả luôn -> xóa task
       - Nếu chưa có -> đưa vào filteredTasks
  -> Đánh dấu filteredTasks: Status = PROCESSING
  -> Phân phối task đến Tool Servers (servers table) theo weighted:
       IsPriority=true: trọng số 5 | thường: trọng số 2
  -> POST http://{server.IP}/api/searches  (gửi batch đến Tool)
  -> Nhận response IDs -> xóa task khỏi keyword_pool_tasks
  -> Nếu lỗi: reset Status = NEW để retry vòng sau

  -> Lưu vào collection searches (MongoDB của Tools)
  -> Cron (every 1s): pick PENDING -> Chrome launch -> search Google/CocCoc
  -> Lưu kết quả vào searches.search_data
  -> POST {webhook_url} = /webhook/update-search-result/:id
  -> API cập nhật kết quả vào keyword_results

[Caller] POST /anchor-text/search
  -> Lưu vào MongoDB: anchor_texts  <-- buffer

[Cron anchor_text - goroutine, loop mỗi 60s]
  -> Lấy tất cả anchor text tasks
  -> Kiểm tra Redis cache (key: domain_anchor_text):
       - Nếu có cache -> gọi hook_url -> xóa task
       - Nếu chưa -> phân phối đến Tool servers (weighted)
  -> POST http://{server.IP}/api/search-anchor-texts
  -> Tool crawl anchor text -> POST /webhook/update-search-anchor-text/:id

[Tool cần proxy]
  -> POST /webhook/proxy/get-proxy  {task_id, proxy_url}
  -> API tìm proxy khả dụng (is_active, in_use < max, không lỗi)
  -> Đánh dấu in_use++, ghi task_id vào proxy.proxy_used
  -> Trả về {host, port, username, password}

[Tool sau khi rotate xong]
  -> POST /webhook/proxy-rotation-result/:id
  -> API cập nhật ip_public, region, reset is_rotating=false

api/
├── cmd/
│   └── main.go                    # Entry point
│
├── bootstrap/
│   ├── routes.go                  # Đăng ký toàn bộ routes + cron
│   ├── cron/                      # Cron job configs (gocron)
│   ├── injection/                 # Dependency Injection (Uber Dig)
│   └── socket/                    # Socket.IO server setup
│
├── internal/                      # Core business logic
│   ├── activity_log/
│   │   ├── activity_log.go        # Model (MySQL)
│   │   ├── dto/
│   │   ├── handler/               # GET /activity-log (pagination)
│   │   ├── repository/
│   │   └── service/
│   │
│   ├── anchor_text/
│   │   ├── anchor_text.go         # Model (MongoDB)
│   │   ├── cron/
│   │   ├── dto/
│   │   ├── handler/               # POST /search, GET /get-all, GET /reset-all-status
│   │   ├── repository/
│   │   └── service/
│   │
│   ├── keyword/
│   │   ├── keyword.go             # Model (MongoDB) + Device/Engine/Status enums
│   │   ├── cron/
│   │   ├── dto/
│   │   ├── handler/               # CRUD + reset
│   │   ├── repository/
│   │   └── service/
│   │
│   ├── keyword_pool_task/
│   │   ├── handler/               # POST /, GET /get-all, GET /reset-all-status
│   │   ├── repository/
│   │   └── service/
│   │
│   ├── keyword_result/
│   │   ├── keyword_result.go      # Model (MongoDB) + SearchData, SearchResult
│   │   ├── cron/
│   │   ├── dto/
│   │   ├── handler/               # POST (create), PUT /update-search-data/:id
│   │   ├── repository/
│   │   └── service/
│   │
│   ├── proxy/
│   │   ├── proxy.go               # Model (MongoDB) + ProxyArea enum
│   │   ├── cron/
│   │   ├── dto/
│   │   ├── handler/               # CRUD + import Excel + change_status
│   │   ├── repository/
│   │   └── service/
│   │
│   ├── server/
│   │   ├── server.go              # Model (MySQL)
│   │   ├── handler/               # CRUD
│   │   ├── repository/
│   │   └── service/
│   │
│   ├── user/
│   │   ├── user.go                # Model (MySQL) + RoleType enum
│   │   ├── dto/
│   │   ├── handler/               # Login, Register, CRUD
│   │   ├── repository/
│   │   └── service/
│   │
│   └── webhook/
│       ├── dto/
│       ├── handler/               # get_proxy, proxy_rotation_result,
│       │                          # update_search_result, update_search_anchor_text
│       └── service/
│
├── pkg/                           # Shared utilities
│   ├── env.go                     # EnvStruct + LoadEnv()
│   ├── api/                       # HTTP clients gọi external APIs
│   ├── apperror/                  # Custom error types
│   ├── cache/                     # Redis wrapper
│   ├── database/                  # DB connections (MySQL + MongoDB)
│   ├── excel/                     # Excel reader (import proxy)
│   ├── jwt/                       # JWT create & parse
│   ├── logger/                    # Zap logger + lumberjack rotation
│   ├── messages/                  # Standard response format
│   ├── middleware/                 # JWT, Webhook, Error middlewares
│   ├── scheduler/                 # gocron wrapper
│   ├── telegram/                  # Telegram notifications
│   └── validate/                  # Request validation
│
├── common/
│   ├── const.go
│   └── paging.go                  # Pagination struct
│
├── go.mod                         # Go module
├── .env.example
└── docker-compose.yaml