This project is intended to make testing the PPM easier.

The objective here is to verify the following:

• BSMs inside the geofence are retained
• BSMs with a partII section are retained
• BSMs outside the geofence are suppressed
• BSMs above the speed range are suppressed
• BSMs below the speed range are suppressed

1. Make sure that the KAFKA_HOST environment variable is set to the IP address of the WSL instance running the PPM. This should be set in the WSL instance running the testing-ppm project. If you run into trouble, setting this to localhost may help.

2. Make sure that the DOCKER_HOST_IP environment variable is set to the IP address of the WSL instance running the PPM. It should be noted that environment variables in the .env file will override the environment variables set in the WSL instance, so if the .env file is being used, the DOCKER_HOST_IP environment variable should be set in the .env file.

3. Spin up PPM using standalone docker-compose script.

docker-compose -f docker-compose-standalone.yml up --build --remove-orphans

1. Send test BSMs by invoking the test.sh script or the send_bsm.sh script.
2. Observe the result by checking the info.log file in the logs directory in the container or by checking the terminal running the consumer.

1. Spin up PPM using standalone docker-compose script.

    docker-compose -f docker-compose-standalone.yml up --build --remove-orphans
   

2. Exec into the container running kafka in two separate terminals.

    docker ps
   
    docker exec -it (container ID) /bin/bash
   

3. Navigate to the /opt/kafka/bin directory.

    cd /opt/kafka/bin
   

4. On one terminal, start reading from the topic.

    kafka-console-consumer --bootstrap-server localhost:9092 --topic (topic name) --from-beginning
   

5. On the other terminal, start writing to the topic.

    kafka-console-producer --bootstrap-server localhost:9092 --topic (topic name)
   

1. Write test BSMs (located in the bsms directory) to the topic.
2. Verify that the BSMs are written to the topic.
3. Observe the result by checking the info.log file in the logs directory in the container or by checking the terminal running the consumer.

https://github.com/usdot-jpo-ode/jpo-cvdp/tree/develop

https://kafka.apache.org/quickstart