name: HelloWorldModule
version: 1.0.0
description: "Simple hello world module"

module:
  tasks:
    - name: HelloWorldTask
      description: "Publishes hello messages"
      update_rate_hz: 1

      outputs:
        - name: message
          topic: "/hello/message"
          message_type: "roboticks.messages.common.StringMessage"
          qos: "RELIABLE"

      custom:
        greeting: "Hello World!"

  logging:
    level: "INFO"

#include "HelloWorldTask.hpp"
#include <roboticks/module/TaskFactory.hpp>

static roboticks::module::TaskRegistrar<HelloWorldTask> registrar("HelloWorldTask");

HelloWorldTask::HelloWorldTask(const std::string& config)
    : HelloWorldTaskIO(config)
{
    greeting_ = getConfig("custom.greeting", "Hello!");
    ROBOTICKS_INFO(*getLogger(), "HelloWorldTask created");
}

bool HelloWorldTask::onInitialize() {
    ROBOTICKS_INFO(*getLogger(), "Initializing...");
    return true;
}

bool HelloWorldTask::onStart() {
    ROBOTICKS_INFO(*getLogger(), "Starting...");
    return true;
}

void HelloWorldTask::onUpdate() {
    count_++;

    roboticks::messages::common::StringMessage msg(greeting_, count_);
    message_output_->publish(msg);

    ROBOTICKS_INFO(*getLogger(), "Published: {} (count: {})", greeting_, count_);
}

void HelloWorldTask::onStop() {
    ROBOTICKS_INFO(*getLogger(), "Stopped after {} messages", count_);
}

cd modules/HelloWorldModule
mkdir build && cd build
cmake .. && make
./HelloWorldModule

[INFO] HelloWorldTask created
[INFO] Initializing...
[INFO] Starting...
[INFO] Published: Hello World! (count: 1)
[INFO] Published: Hello World! (count: 2)
...

name: Ros2BridgeModule
version: 1.0.0

module:
  tasks:
    - name: Ros2BridgeTask
      update_rate_hz: 100

      # ROS2 input topics
      inputs:
        - name: ros_cmd_vel
          topic: "/ros2/cmd_vel"
          message_type: "geometry_msgs.msg.Twist"

      # Roboticks output topics
      outputs:
        - name: roboticks_velocity
          topic: "/robot/velocity"
          message_type: "roboticks.messages.control.Velocity"
          qos: "RELIABLE"

      custom:
        ros_domain_id: 0

name: SensorProcessorModule
version: 1.0.0

module:
  tasks:
    - name: SensorProcessorTask
      update_rate_hz: 30

      inputs:
        - name: lidar
          topic: "/sensors/lidar/points"
          message_type: "roboticks.messages.sensors.PointCloud"
          qos: "BEST_EFFORT"

        - name: imu
          topic: "/sensors/imu/data"
          message_type: "roboticks.messages.sensors.Imu"
          qos: "BEST_EFFORT"

      outputs:
        - name: obstacles
          topic: "/perception/obstacles"
          message_type: "roboticks.messages.perception.ObstacleList"
          qos: "RELIABLE"

      custom:
        min_obstacle_size: 0.1
        max_range: 50.0

void SensorProcessorTask::onUpdate() {
    // Fuse sensor data
    if (lidar_input_->hasData() && imu_input_->hasData()) {
        const auto& lidar_data = lidar_input_->getData();
        const auto& imu_data = imu_input_->getData();

        // Transform point cloud using IMU orientation
        auto transformed = transformPointCloud(lidar_data, imu_data);

        // Detect obstacles
        auto obstacles = detectObstacles(transformed);

        // Publish results
        obstacles_output_->publish(obstacles);
    }
}

version: '3.8'

services:
  hello-world:
    build:
      context: .
      dockerfile: docker/roboticks/Dockerfile
      args:
        COMPOSITION: HelloWorldComposition
    volumes:
      - roboticks-logs:/var/roboticks/logs
    networks:
      - roboticks

  sensor-processor:
    build:
      context: .
      dockerfile: docker/roboticks/Dockerfile
      args:
        COMPOSITION: SensorProcessorComposition
    depends_on:
      - hello-world
    networks:
      - roboticks

networks:
  roboticks:
    driver: bridge

volumes:
  roboticks-logs:

# Build and start
docker compose up -d --build

# View logs
docker compose logs -f

# Stop
docker compose down

from ci.cli_wrapper import CLI
from ci.helpers import wait_for, assert_session_success

def test_my_module():
    cli = CLI()

    # Upload module as capsule
    result = cli.capsule_push(
        "./build/MyModule.tar.gz",
        name="my-module",
        version="1.0.0"
    )
    capsule_id = result["id"]

    # Create test job on cloud runner
    job = cli.simulate_run(
        fleet_id=1,
        test_package_id=test_pkg_id
    )

    # Wait for completion
    wait_for(
        lambda: cli.simulate_get(job["id"])["status"] == "completed",
        timeout=300
    )

    # Verify results
    result = cli.simulate_get(job["id"])
    assert_session_success(result)

# Install test dependencies
pip install -r ci/requirements.txt

# Run tests
python ci/run_tests.py pr

git clone https://github.com/roboticks-io/roboticks-examples.git