Add New Plugin

/*
 * Copyright (c) 2026 LG Electronics Inc.
 *
 * SPDX-License-Identifier: MIT
 */

using System.Collections;
using UnityEngine;
using Any = cloisim.msgs.Any;

public class MyPlugin : CLOiSimPlugin
{
	private SensorDevices.MySensor _sensor;
	// For bidirectional: private SensorDevices.MyCommand _command;

	protected override void OnAwake()
	{
		_type = ICLOiSimPlugin.Type.SENSOR;
		_sensor = gameObject.GetComponent<SensorDevices.MySensor>();
		// _command = gameObject.GetComponent<SensorDevices.MyCommand>();
	}

	protected override IEnumerator OnStart()
	{
		// 1. Service port (always first — handles info/config queries)
		if (RegisterServiceDevice(out var portService, "Info"))
		{
			AddThread(portService, ServiceThread);
		}

		// 2. TX port (sensor data publishing)
		if (RegisterTxDevice(out var portTx, "Data"))
		{
			AddThread(portTx, SenderThread, _sensor);
		}

		// 3. RX port (command reception — bidirectional only)
		// if (RegisterRxDevice(out var portRx, "Rx"))
		// {
		//     AddThread(portRx, ReceiverThread, _command);
		// }

		yield return null;
	}

	protected override void HandleCustomRequestMessage(
		in string requestType, in Any requestValue, ref DeviceMessage response)
	{
		switch (requestType)
		{
			case "request_transform":
				var devicePose = _sensor.GetPose();
				var deviceName = _sensor.DeviceName;
				SetTransformInfoResponse(ref response, deviceName, devicePose, _parentLinkName);
				break;

			// Add plugin-specific request handlers:
			// case "request_output_type":
			//     SetMyCustomResponse(ref response);
			//     break;

			default:
				break;
		}
	}

	// Overload for children-based requests (messages.Param with sub-params)
	protected override void HandleCustomRequestMessage(
		in string requestType, in List<messages.Param> requestChildren, ref DeviceMessage response)
	{
		switch (requestType)
		{
			default:
				break;
		}
	}
}

protected override IEnumerator OnStart()
{
	var pluginParameters = GetPluginParameters();
	if (pluginParameters != null)
	{
		// Read specific elements
		var myParam = pluginParameters.GetValue<float>("my_parameter");
		// Read nested elements
		var noiseElem = pluginParameters.GetElement("noise");
	}

	// ... register devices and threads ...
	yield return null;
}

<plugin name="MyPlugin" filename="MyPlugin">
  <my_parameter>42.0</my_parameter>
  <ros2>
    <topic_name>/my_topic</topic_name>
    <frame_id>my_frame</frame_id>
  </ros2>
</plugin>

// Transform info (pose + frame_id)
SetTransformInfoResponse(ref response, deviceName, pose, parentLinkName);

// Camera info (intrinsics, distortion)
SetCameraInfoResponse(ref response, cameraSensor);

// ROS 2 common info (topic, frame_id)
SetROS2CommonInfoResponse(ref response, topicName, frameId);

// Empty ack (boolean true)
SetEmptyResponse(ref response);

protected override void OnReset()
{
	// Reset plugin-specific state
}

protected override void OnAwake()
{
	_type = ICLOiSimPlugin.Type.MICOM;
	_sensorDevice = gameObject.GetComponent<SensorDevices.MicomSensor>();
	_commandDevice = gameObject.GetComponent<SensorDevices.MicomCommand>();
}

protected override IEnumerator OnStart()
{
	if (RegisterServiceDevice(out var portService, "Info"))
		AddThread(portService, ServiceThread);

	if (RegisterTxDevice(out var portTx, "Tx"))
		AddThread(portTx, SenderThread, _sensorDevice);

	if (RegisterRxDevice(out var portRx, "Rx"))
		AddThread(portRx, ReceiverThread, _commandDevice);

	yield return null;
}