import com.google.gson.JsonObject;

import java.util.Date;

public class TestClientRunnable implements Runnable {
    private TestClient testClient;
    private RequestMethod method;
    private long waitTime;
    private JsonObject data;
    private boolean running;
    private int count;
    private long totalTime;
    private int failCount;
    private long longestTime = 0;
    private long shortestTime = 0x7fffffffffffffffL;
    public TestClientRunnable(String url, RequestMethod method, long waitTime){
        this(url, method, waitTime, new JsonObject());
    }
    public TestClientRunnable(String url, RequestMethod method, long waitTime, JsonObject data){
        testClient = new TestClient(url);
        this.method = method;
        this.waitTime = waitTime;
        this.data = data;
        running = true;
    }
    public int getCount(){
        return count;
    }
    public int getFailCount(){
        return failCount;
    }
    public long getTotalTime(){
        return totalTime;
    }

    public long getLongestTime() {
        return longestTime;
    }

    public long getShortestTime() {
        return shortestTime;
    }

    @Override
    public void run() {
        int counter;
        //System.out.println(Thread.currentThread().getName() + " is running");
        while (running){
            counter = 1;
            switch (method){
                case GET:
                    if (testClient.get() == null)
                        counter = 0;
                    break;
                case POST:
                    if (testClient.post(data) == null)
                        counter = 0;
                    break;
                case PUT:
                    //TODO: PUT method
                    break;
                case DELETE:
                    //TODO: GET method
                    break;
            }
            count += counter;
            long dt = testClient.lastTime;
            //System.out.println(dt);
            longestTime = longestTime > dt ? longestTime : dt;
            shortestTime = shortestTime < dt ? shortestTime : dt;
            if (counter > 0){
                totalTime += dt;
            }
            else {
                failCount += 1;
            }


            try {
                Thread.sleep(waitTime - dt > 0 ? waitTime - dt : 0);
            }
            catch (InterruptedException e){
                running = false;
                //System.out.println(Thread.currentThread().getName() + " is exiting, sent " + count + " requests");
            }
        }

    }
}