Senior Full Stack
Developer

/**
 * Process and validate incoming data
 * with comprehensive error handling
 */
public function processData(
    array $payload,
    bool $validateFirst = true
): Result {
    try {
        if ($validateFirst) {
            $this->validator->validate($payload);
        }

        $processed = $this->transformer
            ->transform($payload);

        $this->repository->save($processed);
        $this->cache->invalidate($processed);
        $this->eventDispatcher->dispatch(
            new DataProcessedEvent($processed)
        );

        return Result::success($processed);
    } catch (ValidationException $e) {
        $this->logger->warning('Validation failed', [
            'errors' => $e->getErrors()
        ]);
        return Result::failure($e);
    }
}

async def fetch_with_retry(
    self,
    endpoint: str,
    max_retries: int = 3
) -> ApiResponse:
    """
    Fetch data with exponential backoff
    and comprehensive error handling.
    """
    for attempt in range(max_retries):
        try:
            async with self.session.get(
                endpoint,
                headers=self._auth_headers(),
                timeout=self.timeout
            ) as response:
                response.raise_for_status()
                data = await response.json()
                return ApiResponse(data)

        except ClientError as e:
            wait_time = 2 ** attempt
            self.logger.warning(
                f"Retry {attempt + 1}/{max_retries}"
            )
            await asyncio.sleep(wait_time)

    raise MaxRetriesExceeded(endpoint)