import requests
import json
import time
import sys

# Configuration
SERVER_URL = "http://localhost:2480"
DATABASE_NAME = "LATENCYTEST" 
USERNAME = "root"
PASSWORD = "rootroot"
PAYLOAD_FILE = "result_payload.json"
THRESHOLD_SEC = 4.0

def run_reproduction():
    url = f"{SERVER_URL}/api/v1/command/{DATABASE_NAME}"
    auth = (USERNAME, PASSWORD)
    
    try:
        with open(PAYLOAD_FILE, 'r', encoding='utf-8') as f:
            payload = json.load(f)
    except FileNotFoundError:
        print(f"Error: {PAYLOAD_FILE} not found.")
        sys.exit(1)

    print(f"Target Database: {DATABASE_NAME}")
    print(f"Command Language: {payload.get('language')}")
    print(f"Batch Size: {len(payload.get('params', {}).get('batch', []))} entries")
    print("-" * 30)

    start_time = time.time()
    
    try:
        response = requests.post(
            url,
            json=payload,
            auth=auth,
            timeout=60
        )
        
        elapsed = time.time() - start_time

        if response.status_code == 200:
            print("Execution successful")
            if elapsed > THRESHOLD_SEC:
                print(f"⚠️  WARNING: Execution time is abnormally high: {elapsed:.4f}s (Threshold: {THRESHOLD_SEC}s)")
            else:
                print(f"Execution Time: {elapsed:.4f}s")
        else:
            print(f"HTTP Error {response.status_code}")
            print(f"Response: {response.text}")

    except requests.exceptions.RequestException as e:
        print(f"Connection error: {e}")

if __name__ == "__main__":
    run_reproduction()

Target Database: LATENCYTEST
Command Language: opencypher
Batch Size: 3,423 entries
------------------------------
Execution successful
⚠️  WARNING: Execution time is abnormally high: 7.5667s (Threshold: 4.0s)