Como Criar um Job Scheduler em Ruby para Processar Consultas de CPF Automaticamente

# Gemfile
gem "sidekiq", "~> 7.0"
gem "sidekiq-cron", "~> 1.12"
gem "faraday", "~> 2.0"

# config/initializers/sidekiq_cron.rb
schedule = [
    {
    "name" => "Revalidar CPFs antigos - diario",
    "cron" => "0 2 * * *", # Todo dia às 2h
    "class" => "RevalidarCpfsAntigosWorker",
    "queue" => "agendado"
    },
    {
    "name" => "Processar fila de CPFs pendentes - a cada 5min",
    "cron" => "*/5 * * * *",
    "class" => "ProcessarCpfsPendentesWorker",
    "queue" => "agendado"
    },
    {
    "name" => "Limpar consultas expiradas - semanal",
    "cron" => "0 3 * * 0", # Domingo às 3h
    "class" => "LimparConsultasExpiradasWorker",
    "queue" => "manutencao"
    },
    {
    "name" => "Relatorio de consultas - mensal",
    "cron" => "0 6 1 * *", # Dia 1 às 6h
    "class" => "RelatorioConsultasWorker",
    "queue" => "relatorios"
    }
]

Sidekiq::Cron::Job.load_from_array!(schedule)

# app/workers/revalidar_cpfs_antigos_worker.rb
class RevalidarCpfsAntigosWorker
    include Sidekiq::Worker
    sidekiq_options queue: :agendado, retry: 3

    LIMITE_DIARIO = 500
    DIAS_PARA_REVALIDAR = 30

    def perform
    cpfs_antigos = ConsultaCpf
    .where(status: "sucesso")
    .where("consultado_em < ?", DIAS_PARA_REVALIDAR.days.ago)
    .order(consultado_em: :asc)
    .limit(LIMITE_DIARIO)

    logger.info(
    "[Revalidar] Iniciando revalidacao de #{cpfs_antigos.count} CPFs"
    )

    cliente = build_api_client
    resultados = { sucesso: 0, falha: 0, erro: 0 }

    cpfs_antigos.find_each do |consulta|
    resultado = revalidar_cpf(cliente, consulta)
    resultados[resultado] += 1
    sleep(0.2) # Respeitar rate limit
    end

    logger.info("[Revalidar] Concluido: #{resultados}")
    end

    private

    def build_api_client
    Faraday.new(url: "https://api.cpfhub.io") do |conn|
    conn.headers["x-api-key"] = ENV["CPFHUB_API_KEY"]
    conn.options.timeout = 10
    conn.adapter Faraday.default_adapter
    end
    end

    def revalidar_cpf(cliente, consulta)
    cpf = consulta.cpf_cifrado
    resposta = cliente.get("/cpf/#{cpf}")
    dados = JSON.parse(resposta.body)

    if dados["success"]
    consulta.update!(
    nome: dados["data"]["name"],
    genero: dados["data"]["gender"],
    data_nascimento: dados["data"]["birthDate"],
    consultado_em: Time.current,
    expira_em: 24.hours.from_now,
    status: "sucesso"
    )
    :sucesso
    else
    consulta.update!(status: "falha", motivo_falha: "Nao encontrado na revalidacao")
    :falha
    end
    rescue StandardError => e
    logger.error("[Revalidar] Erro no CPF #{consulta.id}: #{e.message}")
    :erro
    end
end

# app/workers/processar_cpfs_pendentes_worker.rb
class ProcessarCpfsPendentesWorker
    include Sidekiq::Worker
    sidekiq_options queue: :agendado, retry: 2

    def perform
    pendentes = ConsultaCpf.where(status: "pendente").limit(100)
    return if pendentes.empty?

    logger.info("[Pendentes] Processando #{pendentes.count} CPFs pendentes")

    cliente = Faraday.new(url: "https://api.cpfhub.io") do |conn|
    conn.headers["x-api-key"] = ENV["CPFHUB_API_KEY"]
    conn.options.timeout = 10
    conn.adapter Faraday.default_adapter
    end

    pendentes.find_each do |consulta|
    resposta = cliente.get("/cpf/#{consulta.cpf_cifrado}")
    dados = JSON.parse(resposta.body)

    if dados["success"]
    consulta.update!(
    nome: dados["data"]["name"],
    genero: dados["data"]["gender"],
    data_nascimento: dados["data"]["birthDate"],
    status: "sucesso",
    consultado_em: Time.current,
    expira_em: 24.hours.from_now
    )
    else
    consulta.update!(status: "falha", motivo_falha: "Nao encontrado")
    end

    sleep(0.1)
    rescue StandardError => e
    consulta.update!(status: "falha", motivo_falha: e.message)
    end
    end
end

require "rufus-scheduler"
require "faraday"
require "json"

scheduler = Rufus::Scheduler.new

# Job a cada 5 minutos: processar CPFs pendentes
scheduler.every "5m", first: :now do
    puts "[#{Time.now}] Verificando CPFs pendentes..."
    processar_pendentes
end

# Job diário às 2h: revalidar CPFs antigos
scheduler.cron "0 2 * * *" do
    puts "[#{Time.now}] Iniciando revalidacao diaria..."
    revalidar_antigos
end

# Job semanal: gerar relatório
scheduler.cron "0 6 * * 1" do
    puts "[#{Time.now}] Gerando relatorio semanal..."
    gerar_relatorio
end

def processar_pendentes
    # Lógica de processamento
end

def revalidar_antigos
    # Lógica de revalidação
end

def gerar_relatorio
    # Lógica de relatório
end

scheduler.join

# app/workers/relatorio_consultas_worker.rb
class RelatorioConsultasWorker
    include Sidekiq::Worker
    sidekiq_options queue: :relatorios, retry: 1

    def perform
    periodo = 1.month.ago..Time.current

    metricas = {
    total: ConsultaCpf.where(consultado_em: periodo).count,
    sucesso: ConsultaCpf.where(consultado_em: periodo, status: "sucesso").count,
    falha: ConsultaCpf.where(consultado_em: periodo, status: "falha").count,
    por_origem: ConsultaCpf.where(consultado_em: periodo)
    .group(:origem).count,
    por_genero: ConsultaCpf.where(consultado_em: periodo, status: "sucesso")
    .group(:genero).count
    }

    taxa_sucesso = metricas[:total].positive? ?
    (metricas[:sucesso].to_f / metricas[:total] * 100).round(2) : 0

    metricas[:taxa_sucesso] = "#{taxa_sucesso}%"

    logger.info("[Relatorio] Metricas do periodo: #{metricas}")

    # Alerta se taxa de sucesso cair abaixo do esperado
    if taxa_sucesso < 90
    NotificacaoService.alertar(
    "Taxa de sucesso de consulta CPF abaixo de 90%: #{taxa_sucesso}%"
    )
    end
    end
end