import io.github.macfja.obd2.Command;
import io.github.macfja.obd2.Response;
import io.github.macfja.obd2.command.DTCsCommand;
import io.github.macfja.obd2.command.livedata.VehicleSpeed;
import io.github.macfja.obd2.elm327.Commander;
import io.github.macfja.obd2.response.MultipleDiagnosticTroubleCodeResponse;
import io.github.macfja.obd2.service.Obd2Service;
import io.github.macfja.obd2.service.ObdObserver;
import io.github.macfja.obd2.service.ObdObserverIgnoreError;
import io.github.macfja.obd2.service.Service;

public class Example {
    public static void main(String[] args) {
        new Example();
    }

    public Example()
    {
        Obd2Service service = new Service(new Commander());
        service.setCommunication(OBD.toComponent, OBD.fromComponent);

        service.schedule(VehicleSpeed.class, 5, new ObdObserver() {
            @Override
            public void update(Response response) {
                System.out.println(String.format("You are driving at: %s", response.getFormattedString()));
            }

            @Override
            public void error(Command request, Response response, Exception exception) {
                System.err.println(String.format("Unable to read vehicle speed: %s", exception.getLocalizedMessage()));
            }
        });

        service.addObserver(DTCsCommand.class, new ObdObserverIgnoreError() {
            @Override
            public void update(Response response) {
                if (response instanceof MultipleDiagnosticTroubleCodeResponse) {
                    System.out.println(String.format(
                            "DTCs have been requested. Here the result: %d DTC",
                            ((MultipleDiagnosticTroubleCodeResponse) response).getTroubleCodes().size()
                    ));
                }
            }
        });
    }
}