AI Competitor Price Monitoring Tool

@pytest.mark.asyncio
async def test_price_scraping_accuracy():
    """Test price extraction accuracy across multiple platforms."""
    test_urls = [
        {"url": "https://amazon.com/dp/B08N5WRWNW", "expected_price": 29.99},
        {"url": "https://shopify-store.com/product/widget", "expected_price": 45.00},
        {"url": "https://ebay.com/itm/123456789", "expected_price": 19.95},
    ]

    for case in test_urls:
        response = await client.post(
            "/api/v1/scraper/extract-price",
            json={"url": case["url"]},
            headers={"Authorization": f"Bearer {API_TOKEN}"}
        )

        assert response.status_code == 200
        result = response.json()

        assert result["price"] is not None
        assert result["currency"] in ["USD", "EUR", "GBP"]
        assert abs(result["price"] - case["expected_price"]) < 0.01
        assert result["scrape_status"] == "success"
        assert response.elapsed.total_seconds() < 10.0

@Test
public void testPriceChangeDetectionAndAlert() {
    String productId = "PROD-12345";
    String competitorUrl = "https://competitor.com/product/widget";

    // Set initial price
    Response initialScrape = given()
        .header("Authorization", "Bearer " + API_TOKEN)
    .when()
        .post("/api/v1/products/" + productId + "/scrape")
    .then()
        .statusCode(200)
        .extract().response();

    double initialPrice = initialScrape.jsonPath().getDouble("price");

    // Simulate price change (mock competitor response)
    mockServer.stubFor(get(urlEqualTo("/product/widget"))
        .willReturn(aResponse()
            .withBody("<span class=\"price\">$" + (initialPrice - 5.00) + "</span>")));

    // Trigger new scrape
    Response newScrape = given()
        .header("Authorization", "Bearer " + API_TOKEN)
    .when()
        .post("/api/v1/products/" + productId + "/scrape")
    .then()
        .statusCode(200)
        .body("price_changed", equalTo(true))
        .body("change_amount", equalTo(-5.00f))
        .body("alert_triggered", equalTo(true))
        .extract().response();

    // Verify alert was sent
    await().atMost(60, SECONDS).until(() ->
        alertRepository.findByProductId(productId).isPresent()
    );
}

import http from "k6/http";
import { check, sleep } from "k6";

export const options = {
    stages: [
        { duration: "2m", target: 100 },  // Ramp up
        { duration: "5m", target: 100 },  // Sustain
        { duration: "2m", target: 0 },    // Ramp down
    ],
    thresholds: {
        http_req_duration: ["p(95)<3000"],
        http_req_failed: ["rate<0.01"],
    },
};

export default function () {
    const productIds = Array.from({ length: 100 }, (_, i) => `PROD-${i}`);

    // Batch scrape request
    const response = http.post(
        `${__ENV.API_URL}/api/v1/scraper/batch`,
        JSON.stringify({ product_ids: productIds }),
        {
            headers: {
                "Content-Type": "application/json",
                "Authorization": `Bearer ${__ENV.API_TOKEN}`,
            },
        }
    );

    check(response, {
        "status is 200": (r) => r.status === 200,
        "batch processed": (r) => r.json().processed === 100,
        "response time OK": (r) => r.timings.duration < 3000,
    });

    sleep(1);
}