OBD Metrics Demo

About

OBD Metrics Demo is a simple project that demonstrates usage of the OBD Metrics java framework. It uses obd-metrics 9.23.5

Tcp connector demo

Full example can be found example

var connection = TcpAdapterConnection.of("192.168.0.10", 35000);
var collector = new DataCollector();

int commandFrequency = 6;
var workflow = Workflow
        .instance()
        .pids(Pids.DEFAULT)
        .observer(collector)
        .initialize();

var query = Query.builder()
        .pid(13l) // Engine RPM
        .pid(16l) // Intake air temperature
        .pid(18l) // Throttle position
        .pid(14l) // Vehicle speed
        .build();

var optional = Adjustments
        .builder()
        .adaptiveTimeoutPolicy(AdaptiveTimeoutPolicy
            .builder()
            .enabled(Boolean.TRUE)
            .checkInterval(1)
            .commandFrequency(commandFrequency)
            .build())
        .producerPolicy(ProducerPolicy.builder()
            .priorityQueueEnabled(Boolean.TRUE)
            .build())
        .cachePolicy(CachePolicy.builder().resultCacheEnabled(false).build())
        .batchPolicy(
    		BatchPolicy
    		.builder()
    		.responseLengthEnabled(Boolean.FALSE)
    		.enabled(Boolean.TRUE).build())
        .build();

workflow.start(connection, query, Init.DEFAULT, optional);

WorkflowFinalizer.finalizeAfter(workflow, 25000);

var registry = workflow.getPidRegistry();

var rpm = registry.findBy(13l);
double ratePerSec = workflow.getDiagnostics().rate().findBy(RateType.MEAN, rpm).get().getValue();

Assertions.assertThat(ratePerSec).isGreaterThanOrEqualTo(commandFrequency);

Bluetooth connector demo

Full example can be found example

var connection = BluetoothConnection.openConnection("OBDII");
var collector = new DataCollector();

final Pids pids = Pids
        .builder()
        .resource(Thread.currentThread().getContextClassLoader().getResource("giulia_2.0_gme.json"))
        .resource(Thread.currentThread().getContextClassLoader().getResource("extra.json"))
        .resource(Thread.currentThread().getContextClassLoader().getResource("mode01.json"))
		.build();

int commandFrequency = 6;
var workflow = Workflow
        .instance()
        .pids(pids)
        .observer(collector)
        .initialize();

var query = Query.builder()
		.pid(7005l) //Intake Pressure
		.pid(7006l) 
       	.pid(7007l) 
       	.pid(7008l) 
		.build();

var optional = Adjustments
		.builder()
		.vehicleCapabilitiesReadingEnabled(Boolean.TRUE)
      	.vehicleMetadataReadingEnabled(Boolean.TRUE)
		.adaptiveTimeoutPolicy(AdaptiveTimeoutPolicy
            .builder()
            .enabled(Boolean.TRUE)
            .checkInterval(5000)
            .commandFrequency(commandFrequency)
            .build())
        .producerPolicy(ProducerPolicy.builder()
            .priorityQueueEnabled(Boolean.TRUE)
            .build())
        .cachePolicy(CachePolicy.builder().resultCacheEnabled(Boolean.FALSE).build())
        .batchPolicy(
    		BatchPolicy
    		.builder()
    		.responseLengthEnabled(Boolean.FALSE)
    		.enabled(Boolean.FALSE).build())
        .build();

var init = Init.builder()
    .delayAfterInit(1000)
    .dri(Header.builder().mode("22").dri("DA10F1").build())
	.dri(Header.builder().mode("01").dri("DB33F1").build())
    .protocol(Protocol.CAN_29)
    .sequence(DefaultCommandGroup.INIT).build();

workflow.start(connection, query, init, optional);

WorkflowFinalizer.finalizeAfter(workflow,25000);

var registry = workflow.getPidRegistry();

var intakePressure = registry.findBy(7005l);
double ratePerSec = workflow.getDiagnostics().rate().findBy(RateType.MEAN, intakePressure).get().getValue();

Assertions.assertThat(ratePerSec).isGreaterThanOrEqualTo(commandFrequency);