package io.trygvis.esper.testing;

import com.espertech.esper.client.*;
import org.apache.log4j.*;

import java.util.*;

public class Main {
//    private static final String JDBC_URL = "jdbc:h2:mem:esper;DB_CLOSE_DELAY=-1";
    private static final String JDBC_URL = "jdbc:h2:tcp://127.0.0.1/esper;DB_CLOSE_DELAY=-1";

    public static void main(String[] args) throws Exception {
        configureLog4j();
        Main main = new Main();
        main.work();
    }

    public static void configureLog4j() {
        Properties properties = new Properties();
        properties.setProperty("log4j.rootLogger", "DEBUG, A1");
        properties.setProperty("log4j.logger.httpclient.wire.content", "INFO");
        properties.setProperty("log4j.logger.httpclient.wire.header", "INFO");
        properties.setProperty("log4j.logger.org.apache.commons.httpclient", "INFO");
        properties.setProperty("log4j.appender.A1", "org.apache.log4j.ConsoleAppender");
        properties.setProperty("log4j.appender.A1.layout", "org.apache.log4j.PatternLayout");
        properties.setProperty("log4j.appender.A1.layout.ConversionPattern", "%-4r [%t] %-5p %c %x - %m%n");
        PropertyConfigurator.configure(properties);
    }

    private void work() throws Exception {
        Configuration config = new Configuration();

        ConfigurationDBRef configurationDBRef = new ConfigurationDBRef();
        configurationDBRef.setDriverManagerConnection("org.h2.Driver", JDBC_URL, "", "");
        configurationDBRef.setConnectionAutoCommit(false);
        config.addDatabaseReference("db1", configurationDBRef);
        config.addEventTypeAutoName(getClass().getPackage().getName());
        EPServiceProvider epService = EPServiceProviderManager.getDefaultProvider(config);

//        String expression = "select avg(price) from OrderEvent.win:time(30 sec)";

        String expression = "select price, SUBSCRIBER from OrderEvent.win:time(30 sec)," +
            "sql:db1 ['select subscriber from subscription where itemName=${itemName}']";

        EPStatement statement = epService.getEPAdministrator().createEPL(expression);

        MyListener listener = new MyListener();
        statement.addListener(listener);

        System.out.println("Inserting events");
        epService.getEPRuntime().sendEvent(new OrderEvent("shirt", 72));
        epService.getEPRuntime().sendEvent(new OrderEvent("shirt", 73));
        epService.getEPRuntime().sendEvent(new OrderEvent("shirt", 74));

        System.out.println("Sleeping");
        Thread.sleep(1000);
        System.out.println("Done..");
    }
}

class OrderEvent {
    private String itemName;
    private double price;

    public OrderEvent(String itemName, double price) {
        this.itemName = itemName;
        this.price = price;
    }

    public String getItemName() {
        return itemName;
    }

    public double getPrice() {
        return price;
    }
}

class MyListener implements UpdateListener {
    public void update(EventBean[] newEvents, EventBean[] oldEvents) {
        for (EventBean event : newEvents) {
            System.out.println("event.getEventType() = " + event.getEventType());
            System.out.println("event.getUnderlying() = " + event.getUnderlying());
            System.out.println("avg=" + event.get("price"));
        }
    }
}