Method processRequest

internal/engines/bulk.go:332–358

processRequest handles a single request with comprehensive error handling. This method is executed in a separate goroutine for each request and: 1. Acquires a semaphore slot to control concurrency 2. Performs the permission check or uses pre-computed result 3. Processes the result in the correct ord

(ctx context.Context, sem *semaphore.Weighted, index int, req BulkCheckerRequest)

// Returns:
//   - error: Any error that occurred during processing
func (bc *BulkChecker) processRequest(ctx context.Context, sem *semaphore.Weighted, index int, req BulkCheckerRequest) error {
	// Check context before acquiring semaphore
	if err := ctx.Err(); err != nil {
		return nil
	}

	// Acquire semaphore slot to control concurrency
	if err := sem.Acquire(ctx, 1); err != nil {
		if isContextError(err) {
			return nil
		}
		return fmt.Errorf("failed to acquire semaphore: %w", err)
	}
	defer sem.Release(1)

	// Determine the result for this request
	result, err := bc.getRequestResult(ctx, req)
	if err != nil {
		if isContextError(err) {
			return nil
		}
		return fmt.Errorf("failed to get request result: %w", err)
	}

	// Process the result in the correct order
	return bc.processResult(index, result)
}

// getRequestResult determines the result for a request.
// This method either uses a pre-computed result if available,