feat(frontend): exibe histórico de candidatura (#237)

.env.example

@@ -31,6 +31,8 @@ SEARCH_KEYWORDS=UX Designer,UI Designer,Product Manager,Product Owner
 
 # Scraping behavior
 SCRAPER_MAX_CONCURRENCY=12
+SCRAPER_PROVIDER_MAX_CONCURRENCY=2
+SCRAPER_PROVIDER_CONCURRENCY_OVERRIDES=
 SCRAPER_RUN_LOCK_TTL=120s
 SCRAPER_RUN_LOCK_RENEW_INTERVAL=30s
 GOMAXPROCS=2
@@ -87,7 +89,6 @@ INHIRE_ENABLED=true
 INHIRE_TENANTS_FILE=./internal/interfaces/inhireTenants.json
 INHIRE_ENRICH_DETAILS=false
 INHIRE_DETAILS_MODE=ambiguous
-INHIRE_DETAILS_CONCURRENCY=8
 INHIRE_DETAILS_TIMEOUT_MS=10000
 GREENHOUSE_ENABLED=true
 GREENHOUSE_COMPANIES_FILE=./internal/interfaces/greenhouseCompanies.json

SCRAPER.md

@@ -197,16 +197,19 @@ No Compose da raiz, a porta `8081` fica exposta apenas na rede interna `vagas-ne
 
 ### Limites globais de execução
 
-O scraper possui um orçamento global de concorrência por execução controlado por `SCRAPER_MAX_CONCURRENCY`.
-
-- Padrão interno: `12`, usado quando a variável não está definida.
-- Valor válido: inteiro positivo.
-- Valores inválidos explícitos (`""`, `0`, negativo ou não numérico) fazem a aplicação falhar no startup, sem fallback silencioso.
+O scraper possui um orçamento global e limites por provider controlados pelo scheduler do pipeline:
+
+- `SCRAPER_MAX_CONCURRENCY`: teto global. Padrão interno `12`.
+- `SCRAPER_PROVIDER_MAX_CONCURRENCY`: limite padrão por provider. Padrão interno `2`.
+- `SCRAPER_PROVIDER_CONCURRENCY_OVERRIDES`: overrides separados por vírgula no formato `provider=limite`, por exemplo `linkedin=1,gupy=3`.
+- IDs aceitos nos overrides: `linkedin`, `adzuna`, `themuse`, `gupy`, `inhire`, `jooble`, `greenhouse` e `lever`.
+- Limites devem ser inteiros positivos e não podem superar o teto global. Provider desconhecido, entrada malformada ou duplicada impede o startup.
+- Valores inválidos explícitos nas variáveis numéricas (`""`, `0`, negativo ou não numérico) fazem a aplicação falhar no startup, sem fallback silencioso; overrides vazios significam que nenhum provider foi sobrescrito.
 - Cron e `POST /admin/scrape` usam o limite global configurado.
 - `POST /scrape` preserva o contrato atual: quando `maxConcurrency` não é informado, ou vem como `0`/negativo, usa o limite global; quando vem positivo abaixo do teto, usa o valor solicitado; quando vem acima do teto, usa o teto global.
-- A concorrência efetiva é calculada antes da chave de cache e é o mesmo valor usado pelo pipeline, logs e semáforo.
-
-O semáforo global atual é criado uma vez por chamada do pipeline. O lock distribuído abaixo impede que duas execuções mantenham semáforos independentes ao mesmo tempo; limites específicos por provider permanecem para uma sub-issue posterior.
+- A concorrência global efetiva continua fazendo parte da chave de cache. Limites por provider são parâmetros operacionais e não alteram a chave.
+- Cada tarefa adquire primeiro o permit do provider e depois o permit global; o limite efetivo do provider é sempre o menor entre seu limite configurado e o global da requisição.
+- O lock distribuído abaixo impede que duas execuções mantenham orçamentos independentes ao mesmo tempo.
 
 ### Lock distribuído de execução
 
@@ -302,7 +305,9 @@ Fluxo principal:
 2. Verifica cache (`internal/cache`). Se encontrado, retorna resultado cacheado.
 3. Caso contrário, executa `pipeline.ScrapeAllSources` que:
    - Recebe a lista de fontes já montada pelo servidor/registry.
-   - Cria uma tarefa por fonte batch (`SearchBatch`) ou uma tarefa por keyword para fontes sem batch, sempre respeitando `MaxConcurrency`.
+   - Valida o ID, o modo de descoberta e a interface declarada por cada fonte antes de iniciar workers.
+   - Produz tarefas sob demanda em round-robin para uma fila limitada, consumida por um conjunto fixo de workers.
+   - Cria uma tarefa por keyword no modo `keyword`, uma tarefa com o conjunto controlado no modo `batch` e uma tarefa por catálogo/instância no modo `catalog`.
    - Cada adaptador realiza requisições HTTP específicas, parseia HTML/JSON quando necessário e retorna `domain.Job`.
    - Agrega resultados e aplica deduplicação (`dedup.DedupeJobs`).
    - Classifica vagas por família, tecnologias e senioridade antes da indexação.
@@ -311,15 +316,17 @@ Fluxo principal:
 
 Concorrência e resiliência:
 
-- Semáforos por adaptador (ex.: LinkedIn usa um semáforo de 5 simultâneos para proteção).
-- Orçamento global por execução via `SCRAPER_MAX_CONCURRENCY`, aplicado antes do cache e do pipeline.
+- Orçamento global e por provider aplicado pelo pipeline; adapters não criam fan-out concorrente independente.
+- Fila de tarefas limitada a duas vezes o teto global e workers fixos evitam materializar `adapters × keywords` ou abrir uma goroutine por tarefa.
+- O produtor round-robin evita que um provider com muitas instâncias monopolize a fila.
+- Cancelamento interrompe produção, espera por permits, paginação, retries e requisições HTTP; tarefas novas não começam após a perda do contexto/lock.
 - Tratamento de status 429 com backoff; aborta apenas a keyword afetada em caso de falhas persistentes.
 - Uso de `inflight` para evitar que múltiplas requisições idênticas disparem scrapes simultâneos.
 - Slots rotativos reduzem o número de keywords/queries por rodada em fontes caras, preservando cobertura progressiva em execuções futuras.
 
 ## Adaptadores
 
-Cada adaptador em `internal/adapters/<fonte>` implementa a porta `ports.JobSource` com `SourceName()` e `Search(ctx, keyword, req)`. Quando a fonte consegue buscar várias keywords em uma chamada/lote, ela também pode implementar `ports.BatchJobSource`.
+Cada adaptador em `internal/adapters/<fonte>` implementa `ports.JobSource` e declara `ProviderID` e `DiscoveryMode`. Fontes `batch` implementam `ports.BatchJobSource`; fontes `catalog` implementam `ports.CatalogJobSource`. Fontes legadas sem capacidade explícita usam o fallback `keyword`.
 Implementações incluem:
 
 - `internal/adapters/linkedin` — busca via endpoint público `jobs-guest` do LinkedIn; parsing com `goquery`.
@@ -334,9 +341,10 @@ Implementações incluem:
 - Adzuna: habilitado quando `ADZUNA_APP_ID` e `ADZUNA_APP_KEY` existem; `SearchBatch` usa slot rotativo. Defaults atuais: 5 páginas por keyword e 30 keywords por rodada.
 - Gupy: habilitado com `GUPY_ENABLED=true`; usa queries expandidas, descoberta por termos amplos e sweep opcional. O default atual limita o sweep a offset 10000 e processa 60 queries por rodada.
 - Jooble: habilitado com `JOOBLE_API_KEY`; usa cota diária, slot rotativo e cadência de 12h.
-- Greenhouse: habilitado com `GREENHOUSE_ENABLED=true`; cria um adapter por empresa listada em `internal/interfaces/greenhouseCompanies.json`.
-- Lever: habilitado com `LEVER_ENABLED=true`; cria adapters a partir de `internal/interfaces/leverCompanies.json`.
-- InHire: habilitado com `INHIRE_ENABLED=true`; consulta tenants de `internal/interfaces/inhireTenants.json` e só enriquece detalhes quando `INHIRE_ENRICH_DETAILS=true`.
+- Greenhouse: habilitado com `GREENHOUSE_ENABLED=true`; cria um catálogo por empresa listada em `internal/interfaces/greenhouseCompanies.json`, consulta cada catálogo uma vez e agrega todas as keywords correspondentes sem duplicar a vaga.
+- Lever: habilitado com `LEVER_ENABLED=true`; cria catálogos por empresa a partir de `internal/interfaces/leverCompanies.json`.
+- The Muse: consulta o catálogo uma vez por execução e filtra todas as keywords localmente.
+- InHire: habilitado com `INHIRE_ENABLED=true`; consulta tenants serialmente e só enriquece detalhes quando `INHIRE_ENRICH_DETAILS=true`.
 
 Boas práticas nos adaptadores:
 
@@ -371,12 +379,14 @@ docker compose \
   config
 ```
 
-Confirme no serviço `scraper-go` os equivalentes de `SCRAPER_MAX_CONCURRENCY=12`, `GOMAXPROCS=2`, `GOMEMLIMIT=1500MiB`, `cpus: 1.5` e `mem_limit: 2g`.
+Confirme no serviço `scraper-go` os equivalentes de `SCRAPER_MAX_CONCURRENCY=12`, `SCRAPER_PROVIDER_MAX_CONCURRENCY=2`, `SCRAPER_PROVIDER_CONCURRENCY_OVERRIDES=""`, `GOMAXPROCS=2`, `GOMEMLIMIT=1500MiB`, `cpus: 1.5` e `mem_limit: 2g`.
 
 ## Variáveis de ambiente importantes
 
 - `VALKEY_URL` — conexão Redis/Valkey. Em Docker Compose, use `redis://valkey:6379/0`; em execução local fora do Docker, use uma URL acessível pelo host, por exemplo `redis://localhost:6379/0`.
 - `SCRAPER_MAX_CONCURRENCY` — teto global de concorrência por execução. Padrão: `12`. Configuração explícita inválida impede a inicialização.
+- `SCRAPER_PROVIDER_MAX_CONCURRENCY` — limite padrão por provider. Padrão: `2`. Deve ser positivo e não pode superar `SCRAPER_MAX_CONCURRENCY`.
+- `SCRAPER_PROVIDER_CONCURRENCY_OVERRIDES` — lista opcional `provider=limite`, separada por vírgulas. Vazio significa nenhum override; entrada inválida, duplicada, desconhecida ou acima do teto global impede a inicialização.
 - `SCRAPER_RUN_LOCK_TTL` — duração do lock distribuído. Padrão: `120s`. Variável ausente usa o default; valor explícito vazio ou inválido impede a inicialização. No Compose, usa `${SCRAPER_RUN_LOCK_TTL-120s}` (mesmo padrão fail-fast de `SCRAPER_MAX_CONCURRENCY`).
 - `SCRAPER_RUN_LOCK_RENEW_INTERVAL` — intervalo de renovação. Padrão: `30s`; deve ser menor que `SCRAPER_RUN_LOCK_TTL`. Variável ausente usa o default; valor explícito vazio ou inválido impede a inicialização. No Compose, usa `${SCRAPER_RUN_LOCK_RENEW_INTERVAL-30s}`.
 - `GOMAXPROCS` — limite efetivo de threads executando código Go simultaneamente. Valor inicial no Compose: `2`.
@@ -389,16 +399,17 @@ Confirme no serviço `scraper-go` os equivalentes de `SCRAPER_MAX_CONCURRENCY=12
 - `GUPY_RAW_DISCOVERY_ENABLED` — adiciona queries amplas de tecnologia na Gupy.
 - `GUPY_FULL_SWEEP_ENABLED` / `GUPY_FULL_REMOTE_SWEEP_ENABLED` — controla sweeps amplos na Gupy.
 - `GUPY_QUERY_LIMIT` — limita quantas queries expandidas da Gupy rodam por execução. Padrão: `60`.
-- `INHIRE_ENABLED`, `INHIRE_TENANTS_FILE`, `INHIRE_ENRICH_DETAILS`, `INHIRE_DETAILS_MODE`, `INHIRE_DETAILS_CONCURRENCY`, `INHIRE_DETAILS_TIMEOUT_MS` — controlam fonte e enriquecimento InHire.
+- `INHIRE_ENABLED`, `INHIRE_TENANTS_FILE`, `INHIRE_ENRICH_DETAILS`, `INHIRE_DETAILS_MODE`, `INHIRE_DETAILS_TIMEOUT_MS` — controlam fonte e enriquecimento InHire. `INHIRE_DETAILS_CONCURRENCY` foi removida; detalhes seguem o orçamento do provider.
 - `GREENHOUSE_ENABLED`, `GREENHOUSE_COMPANIES_FILE` — controlam fonte Greenhouse.
 - `LEVER_ENABLED`, `LEVER_COMPANIES_FILE`, `LEVER_INCLUDE_ALL_JOBS` — controlam fonte Lever.
 - Configurações de logging, quota e performance podem ser definidas via `.env`.
 
 ## Observações operacionais
 
 - Projetado para rodar frequentemente; use caching e indexação para reduzir chamadas repetidas.
-- Monitorar erros 429 e ajustar `WaitBetweenSearchesMs` / semáforos por adaptador.
+- Monitorar erros 429 e ajustar `WaitBetweenSearchesMs` e os limites globais/por provider.
 - Verifique logs estruturados (slog JSON) e `/metrics` para métricas de sucesso/falhas por adaptador.
+- O log `scraper concurrency budget` registra uma vez por execução o teto global, o default por provider e os overrides; `scraper provider execution summary` registra modo, tarefas produzidas/concluídas/canceladas, erros, timeouts e duração agregada.
 - Logs `scraper run lock acquired`, `scraper execution skipped`, `scraper run lock lost` e `scraper run lock released` identificam `source` e `run_id`.
 
 ### Verificação operacional do lock

docker-compose.yml

@@ -14,6 +14,8 @@ services:
       - GO_SCRAPER_ADDR=:8081
       - VALKEY_URL=redis://valkey:6379/0
       - SCRAPER_MAX_CONCURRENCY=${SCRAPER_MAX_CONCURRENCY-12}
+      - SCRAPER_PROVIDER_MAX_CONCURRENCY=${SCRAPER_PROVIDER_MAX_CONCURRENCY-2}
+      - SCRAPER_PROVIDER_CONCURRENCY_OVERRIDES=${SCRAPER_PROVIDER_CONCURRENCY_OVERRIDES-}
       - SCRAPER_RUN_LOCK_TTL=${SCRAPER_RUN_LOCK_TTL-120s}
       - SCRAPER_RUN_LOCK_RENEW_INTERVAL=${SCRAPER_RUN_LOCK_RENEW_INTERVAL-30s}
       - GOMAXPROCS=${GOMAXPROCS:-2}
@@ -26,7 +28,6 @@ services:
       - INHIRE_TENANTS_FILE=/app/internal/interfaces/inhireTenants.json
       - INHIRE_ENRICH_DETAILS=${INHIRE_ENRICH_DETAILS:-false}
       - INHIRE_DETAILS_MODE=${INHIRE_DETAILS_MODE:-ambiguous}
-      - INHIRE_DETAILS_CONCURRENCY=${INHIRE_DETAILS_CONCURRENCY:-8}
       - INHIRE_DETAILS_TIMEOUT_MS=${INHIRE_DETAILS_TIMEOUT_MS:-10000}
       - GREENHOUSE_ENABLED=${GREENHOUSE_ENABLED:-true}
       - GREENHOUSE_COMPANIES_FILE=/app/internal/interfaces/greenhouseCompanies.json

frontend/src/domains/new_dashboard/NewDashboardPage.tsx

@@ -163,6 +163,7 @@ export default function NewDashboardPage() {
   const [countryFilter, setCountryFilter] = useState<CountryFilter>("Todos");
   const [matchSort, setMatchSort] = useState<MatchSort>("default");
   const [selectedJobId, setSelectedJobId] = useState<string | null>(null);
+  const [timelineVersion, setTimelineVersion] = useState(0);
   const [searchParams, setSearchParams] = useSearchParams();
   const [isAddJobOpen, setIsAddJobOpen] = useState(false);
   const [toast, setToast] = useState("");
@@ -357,6 +358,7 @@ export default function NewDashboardPage() {
       const updatedJob = await changeJobStatus(jobId, status);
       if (updatedJob && selectedJobId === jobId) {
         setSelectedJobId(updatedJob.id);
+        setTimelineVersion((current) => current + 1);
       }
       showToast(`Vaga atualizada para: ${jobStatuses[status]}`);
     } catch {
@@ -572,6 +574,8 @@ export default function NewDashboardPage() {
           onClose={handleCloseJob}
           onStatusChange={handleStatusChange}
           onNotesChange={handleNotesChange}
+          isTracked={trackedJobs.some((job) => job.id === selectedJob.id)}
+          timelineVersion={timelineVersion}
         />
       ) : null}
 

frontend/src/domains/new_dashboard/components/jobs/JobDetailModal.tsx

@@ -1,6 +1,8 @@
 import { ExternalLink } from "lucide-react";
+import { useEffect, useState } from "react";
 import { jobStatusClasses, jobStatuses } from "../../constants";
-import type { Job, JobStatus } from "../../types";
+import type { Job, JobStatus, JobTimelineEvent } from "../../types";
+import { getDashboardSavedJobEvents } from "../../infrastructure/dashboardJobsApi";
 import { Modal } from "../shared/Modal";
 import { FormattedJobDescription } from "./FormattedJobDescription";
 
@@ -9,6 +11,8 @@ interface JobDetailModalProps {
   onClose: () => void;
   onStatusChange: (jobId: string, status: JobStatus) => void;
   onNotesChange: (jobId: string, notes: string) => void;
+  isTracked?: boolean;
+  timelineVersion?: number;
 }
 
 const payloadLabels: Record<string, string> = {
@@ -44,12 +48,69 @@ function isExternalUrl(value: string) {
   return /^https?:\/\//i.test(value);
 }
 
+function formatTimelineDate(value: string) {
+  const date = new Date(value);
+  if (Number.isNaN(date.getTime())) return "Data não informada";
+
+  return new Intl.DateTimeFormat("pt-BR", {
+    dateStyle: "short",
+    timeStyle: "short",
+  }).format(date);
+}
+
+function orderTimeline(events: JobTimelineEvent[]) {
+  return [...events].sort(
+    (first, second) =>
+      new Date(first.createdAt).getTime() - new Date(second.createdAt).getTime(),
+  );
+}
+
+function timelineMetadataText(metadata: Record<string, unknown> | null) {
+  if (!metadata) return "";
+
+  return Object.entries(metadata)
+    .map(([key, value]) => `${key}: ${payloadValueToText(value)}`)
+    .join(" • ");
+}
+
 export function JobDetailModal({
   job,
   onClose,
   onStatusChange,
   onNotesChange,
+  isTracked = false,
+  timelineVersion = 0,
 }: JobDetailModalProps) {
+  const [timeline, setTimeline] = useState<JobTimelineEvent[]>([]);
+  const [isTimelineLoading, setIsTimelineLoading] = useState(false);
+  const [timelineError, setTimelineError] = useState(false);
+
+  useEffect(() => {
+    if (!isTracked) return;
+
+    let active = true;
+    void Promise.resolve()
+      .then(() => {
+        if (!active) return null;
+        setIsTimelineLoading(true);
+        setTimelineError(false);
+        return getDashboardSavedJobEvents(job.id);
+      })
+      .then((events) => {
+        if (active && events) setTimeline(orderTimeline(events));
+      })
+      .catch(() => {
+        if (active) setTimelineError(true);
+      })
+      .finally(() => {
+        if (active) setIsTimelineLoading(false);
+      });
+
+    return () => {
+      active = false;
+    };
+  }, [isTracked, job.id, timelineVersion]);
+
   const payloadEntries = Object.entries(job.rawPayload ?? {}).filter(
     ([key]) => key !== "description",
   );
@@ -199,6 +260,51 @@ export function JobDetailModal({
             className="min-h-28 w-full resize-y rounded-md border border-input bg-background px-3 py-2 text-sm outline-none focus:border-ring"
           />
         </label>
+
+        {isTracked ? (
+          <section className="space-y-2" aria-labelledby="timeline-title">
+            <h3
+              id="timeline-title"
+              className="text-xs font-bold uppercase text-muted-foreground"
+            >
+              Histórico da candidatura
+            </h3>
+            {isTimelineLoading ? (
+              <p className="text-sm text-muted-foreground">Carregando histórico...</p>
+            ) : null}
+            {timelineError ? (
+              <p className="text-sm text-destructive">
+                Não foi possível carregar o histórico.
+              </p>
+            ) : null}
+            {!isTimelineLoading && !timelineError && timeline.length === 0 ? (
+              <p className="text-sm text-muted-foreground">
+                Nenhuma mudança de status registrada.
+              </p>
+            ) : null}
+            {!isTimelineLoading && !timelineError && timeline.length > 0 ? (
+              <ol className="space-y-2 border-l border-border pl-4">
+                {timeline.map((event) => (
+                  <li key={event.id} className="relative text-sm">
+                    <span className="absolute -left-[21px] top-1.5 h-2 w-2 rounded-full bg-primary" />
+                    <p className="font-semibold">
+                      Status alterado de {jobStatuses[event.fromStatus]} para{" "}
+                      {jobStatuses[event.toStatus]}
+                    </p>
+                    <time className="text-xs text-muted-foreground" dateTime={event.createdAt}>
+                      {formatTimelineDate(event.createdAt)}
+                    </time>
+                    {timelineMetadataText(event.metadata) ? (
+                      <p className="text-xs text-muted-foreground">
+                        {timelineMetadataText(event.metadata)}
+                      </p>
+                    ) : null}
+                  </li>
+                ))}
+              </ol>
+            ) : null}
+          </section>
+        ) : null}
       </div>
     </Modal>
   );