Personio-REST-Import: authentifizierte Spiegelung der Stellenanzeigen · superseded

public function request(string $method, string $path, array $options = []): ResponseInterface
{
  $token = $this->getValidToken();
  $options['headers']['Authorization'] = "Bearer {$token}";

  try {
    return $this->httpClient->request($method, $this->baseUrl . $path, $options);
  } catch (ClientException $e) {
    if ($e->getResponse()->getStatusCode() !== 401) {
      throw $e;
    }
    // Token expired or rotated — invalidate + retry once.
    $this->cache->delete('solcom_vacancy.personio_jwt');
    $this->logger->notice('Personio JWT refresh triggered by 401');
    $token = $this->getValidToken();
    $options['headers']['Authorization'] = "Bearer {$token}";
    return $this->httpClient->request($method, $this->baseUrl . $path, $options);
  }
}

private function getValidToken(): string
{
  $cached = $this->cache->get('solcom_vacancy.personio_jwt');
  if ($cached !== false && isset($cached->data)) {
    return $cached->data;
  }
  return $this->fetchAndCacheToken();
}

public function syncFromCron(): array
{
  $positions = $this->apiClient->fetchPositions();
  $currentIds = array_column($positions, 'id');

  // Empty-feed guard — never sweep on empty.
  if ($currentIds === []) {
    $this->logger->warning('Personio returned 0 positions, skipping sweep');
    return ['synced' => 0, 'deleted' => 0, 'skipped_sweep' => true];
  }

  // 1) Synchronous sweep — must run BEFORE enqueue,
  //    otherwise workers and sweep race for the same nodes.
  $deleted = $this->deleteOrphans($currentIds);

  // 2) Enqueue one item per remaining position.
  $queue = $this->queueFactory->get('personio_position_import');
  foreach ($positions as $position) {
    $queue->createItem([
      'personio_id' => $position['id'],
      'payload'     => $position,
    ]);
  }

  $this->state->set('solcom_vacancy.last_sync', $this->time->getRequestTime());
  return ['synced' => count($positions), 'deleted' => $deleted, 'skipped_sweep' => false];
}