from typing import Annotated, Optional

import pytest
from fastapi import FastAPI, Query
from fastapi.testclient import TestClient
from pydantic import BaseModel, Field

app = FastAPI()

# =====================================================================================
# Without aliases


@app.get("/optional-str")
async def read_optional_str(p: Optional[str] = None):
    return {"p": p}

		err = errors.New("invalid ARN string format")
		return arn, err
	}

	if ps[1] != string(arnPartitionMinio) {
		err = errors.New("invalid ARN - bad partition field")
		return arn, err
	}

	if ps[2] != string(arnServiceIAM) {
		err = errors.New("invalid ARN - bad service field")
		return arn, err
	}

	// ps[3] is region and is not validated here. If the region is invalid,

     */
    private void resetHandlerState() throws Exception {
        // Reset the static factory field
        Field factoryField = Handler.class.getDeclaredField("factory");
        factoryField.setAccessible(true);
        factoryField.set(null, null);

        // Clear the protocol handlers cache
        Field handlersField = Handler.class.getDeclaredField("PROTOCOL_HANDLERS");
        handlersField.setAccessible(true);

void cleanup(String sessionId)  // Clean up session
void stop()                     // Stop gracefully
```

**Key Fields**: `crawlerContext`, `urlFilter`, `intervalController`, `clientFactory`, `ruleManager`

### CrawlerContext (`CrawlerContext.java`)

Execution context and configuration.

**Important Fields**:
```java
String sessionId                // Format: yyyyMMddHHmmssSSS
volatile CrawlerStatus status   // DONE, RUNNING

 * the License.
 */

package com.google.common.collect.testing.testers;

import static java.lang.annotation.ElementType.CONSTRUCTOR;
import static java.lang.annotation.ElementType.FIELD;
import static java.lang.annotation.ElementType.METHOD;
import static java.lang.annotation.ElementType.TYPE;

import java.lang.annotation.Target;
import org.jspecify.annotations.NullMarked;

/**

	// See https://docs.aws.amazon.com/AmazonS3/latest/API/API_PutBucketLifecycle.html
	// In the newer PutBucketLifecycleConfiguration API, Rule has a prefix field that is deprecated, and there exists an optional
	// Filter field, and within it, an optional Prefix field.
	// See https://docs.aws.amazon.com/AmazonS3/latest/API/API_PutBucketLifecycleConfiguration.html

		expectedSha256hex   string
		expectedReleaseInfo string
		expectedErr         bool
	}{
		{"more than two fields", time.Time{}, "", "", true},
		{"more than", time.Time{}, "", "", true},
		{"more than.two.fields", time.Time{}, "", "", true},
		{"more minio.RELEASE.fields", time.Time{}, "", "", true},
		{"more minio.RELEASE.2016-10-07T01-16-39Z", time.Time{}, "", "", true},
		{

        assertEquals("test", InputValidator.requireNonEmpty("test", "field"));

        assertThrows(IllegalArgumentException.class, () -> InputValidator.requireNonEmpty(null, "field"));
        assertThrows(IllegalArgumentException.class, () -> InputValidator.requireNonEmpty("", "field"));
        assertThrows(IllegalArgumentException.class, () -> InputValidator.requireNonEmpty("   ", "field"));
    }

    @Test

        assertEquals(acctFlags, request.acct_flags, "The account flags should be set correctly.");
        assertEquals(mockSamArray, request.sam, "The sam array should be set correctly.");
        // ptype and flags are protected fields in DcerpcMessage, cannot test directly
    }

    private QueryBuilder builder;

    /**
     * Constructs a GeoInfo instance by parsing geographic parameters from the HTTP request.
     * Extracts geo.{field}.point and geo.{field}.distance parameters to create
     * geo-distance queries for each configured geographic field.
     *
     * @param request the HTTP servlet request containing geographic parameters
     * @throws InvalidQueryException if geo point format is invalid or parsing fails