AI WhatsApp Business Automation Platform

@Test
public void testWhatsAppMessageDelivery() {
    String phoneNumber = "+1234567890";
    String templateName = "order_confirmation";

    Response response = given()
        .header("Authorization", "Bearer " + WHATSAPP_ACCESS_TOKEN)
        .header("Content-Type", "application/json")
        .body("{" +
            "\"messaging_product\": \"whatsapp\"," +
            "\"to\": \"" + phoneNumber + "\"," +
            "\"type\": \"template\"," +
            "\"template\": {" +
                "\"name\": \"" + templateName + "\"," +
                "\"language\": {\"code\": \"en\"}" +
            "}" +
        "}")
    .when()
        .post(WHATSAPP_API_URL + "/messages")
    .then()
        .statusCode(200)
        .body("messages[0].id", notNullValue())
        .extract().response();

    String messageId = response.jsonPath().getString("messages[0].id");

    // Verify delivery status via webhook
    await().atMost(30, SECONDS).until(() ->
        webhookReceiver.hasStatus(messageId, "delivered")
    );
}

@pytest.mark.asyncio
async def test_faq_auto_reply_accuracy():
    """Test AI chatbot responds accurately to common FAQs."""
    test_cases = [
        {"query": "What are your store hours?", "expected_intent": "store_hours"},
        {"query": "Where is my order #12345?", "expected_intent": "order_status"},
        {"query": "How do I return a product?", "expected_intent": "return_policy"},
        {"query": "Do you offer free shipping?", "expected_intent": "shipping_info"},
    ]

    for case in test_cases:
        response = await client.post(
            "/api/v1/chatbot/process",
            json={
                "phone": "+1234567890",
                "message": case["query"],
                "channel": "whatsapp"
            },
            headers={"Authorization": f"Bearer {API_TOKEN}"}
        )

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

        assert result["detected_intent"] == case["expected_intent"]
        assert result["confidence_score"] >= 0.85
        assert result["response_text"] is not None
        assert response.elapsed.total_seconds() < 2.0

@Test
public void testOrderStatusWebhookNotification() {
    // Simulate Shopify order status update webhook
    String orderId = "ORD-" + System.currentTimeMillis();
    String webhookPayload = "{" +
        "\"id\": \"" + orderId + "\"," +
        "\"status\": \"shipped\"," +
        "\"tracking_number\": \"1Z999AA10123456784\"," +
        "\"customer_phone\": \"+1234567890\"" +
    "}";

    String signature = generateHmacSignature(webhookPayload, WEBHOOK_SECRET);

    Response response = given()
        .header("Content-Type", "application/json")
        .header("X-Shopify-Hmac-SHA256", signature)
        .body(webhookPayload)
    .when()
        .post("/webhooks/shopify/order-update")
    .then()
        .statusCode(200)
        .body("processed", equalTo(true))
        .body("whatsapp_message_queued", equalTo(true))
        .extract().response();

    // Verify WhatsApp message was sent
    await().atMost(10, SECONDS).until(() -> {
        return messageLogRepository.findByOrderId(orderId)
            .map(log -> log.getStatus().equals("sent"))
            .orElse(false);
    });
}