Created tests for PPBC. Passed all the tests. One test left.

Signed-off-by: Vlad Iftime <vladiftime60@gmail.com>

Author: VladIftime

src/flexmeasures_client/s2/cem.py

@@ -43,8 +43,8 @@ class CEM(Handler):
 
     def __init__(
         self,
-        sensor_id: int,
         fm_client: FlexMeasuresClient,
+        sensor_id: int = 1,
         logger: Logger | None = None,
     ) -> None:
         """

tests/conftest.py

@@ -1,6 +1,7 @@
 from __future__ import annotations
 
-from datetime import datetime
+import uuid
+from datetime import datetime, timedelta, timezone
 
 import pytest
 from s2python.common import (
@@ -11,6 +12,7 @@
     EnergyManagementRole,
     Handshake,
     NumberRange,
+    PowerForecastValue,
     PowerRange,
     ResourceManagerDetails,
     Role,
@@ -23,6 +25,12 @@
     FRBCStorageDescription,
     FRBCSystemDescription,
 )
+from s2python.ppbc import (
+    PPBCPowerProfileDefinition,
+    PPBCPowerSequence,
+    PPBCPowerSequenceContainer,
+    PPBCPowerSequenceElement,
+)
 
 from flexmeasures_client.s2.utils import get_unique_id
 
@@ -46,7 +54,7 @@ def frbc_system_description():
     )
 
     thp_operation_mode = FRBCOperationMode(
-        id="tarnoc-operation-mode",
+        id=str(uuid.uuid4()),
         elements=[thp_operation_mode_element],
         abnormal_condition_only=False,
     )
@@ -64,13 +72,13 @@ def frbc_system_description():
     )
 
     nes_operation_mode = FRBCOperationMode(
-        id="nestore-operation-mode",
+        id=str(uuid.uuid4()),
         elements=[nes_operation_mode_element],
         abnormal_condition_only=False,
     )
 
     actuator = FRBCActuatorDescription(
-        id="id-of-the-actuator",
+        id=str(uuid.uuid4()),
         supported_commodities=[Commodity.ELECTRICITY],
         operation_modes=[thp_operation_mode, nes_operation_mode],
         transitions=[],
@@ -86,7 +94,7 @@ def frbc_system_description():
 
     system_description_message = FRBCSystemDescription(
         message_id=get_unique_id(),
-        valid_from=datetime(2024, 1, 1),
+        valid_from=datetime(2024, 1, 1, tzinfo=timezone.utc),  # Attach UTC timezone
         actuators=[actuator],
         storage=storage,
     )
@@ -95,12 +103,100 @@ def frbc_system_description():
 
 
 @pytest.fixture(scope="session")
-def resource_manager_details():
+def ppbc_power_profile_definition():
+    forecast1 = PowerForecastValue(
+        value_expected=100.0, commodity_quantity=CommodityQuantity.ELECTRIC_POWER_L1
+    )
+    forecast2 = PowerForecastValue(
+        value_expected=200.0, commodity_quantity=CommodityQuantity.ELECTRIC_POWER_L1
+    )
+    forecast3 = PowerForecastValue(
+        value_expected=300.0, commodity_quantity=CommodityQuantity.ELECTRIC_POWER_L1
+    )
+
+    element1 = PPBCPowerSequenceElement(
+        duration=Duration(1), power_values=[forecast1, forecast2]
+    )
+    element2 = PPBCPowerSequenceElement(
+        duration=Duration(1), power_values=[forecast2, forecast3, forecast1]
+    )
+
+    power_sequence1 = PPBCPowerSequence(
+        id=uuid.uuid4(),
+        elements=[element1, element2],
+        is_interruptible=False,
+        max_pause_before=Duration(0),
+        abnormal_condition_only=False,
+    )
+
+    power_sequence2 = PPBCPowerSequence(
+        id=uuid.uuid4(),
+        elements=[element2, element1],
+        is_interruptible=True,
+        max_pause_before=Duration(0),
+        abnormal_condition_only=True,
+    )
+
+    power_sequence3 = PPBCPowerSequence(
+        id=uuid.uuid4(),
+        elements=[element2],
+        is_interruptible=False,
+        max_pause_before=Duration(10000),
+        abnormal_condition_only=False,
+    )
+
+    power_sequence4 = PPBCPowerSequence(
+        id=uuid.uuid4(),
+        elements=[element1],
+        is_interruptible=True,
+        max_pause_before=Duration(10000),
+        abnormal_condition_only=True,
+    )
+
+    power_sequence_container1 = PPBCPowerSequenceContainer(
+        id=uuid.uuid4(),
+        power_sequences=[
+            power_sequence1,
+            power_sequence2,
+        ],
+    )
+
+    power_sequence_container2 = PPBCPowerSequenceContainer(
+        id=uuid.uuid4(),
+        power_sequences=[
+            power_sequence3,
+        ],
+    )
+
+    power_sequence_container3 = PPBCPowerSequenceContainer(
+        id=uuid.uuid4(),
+        power_sequences=[
+            power_sequence4,
+        ],
+    )
+
+    power_profile_definition = PPBCPowerProfileDefinition(
+        message_id=uuid.uuid4(),
+        id=uuid.uuid4(),
+        start_time=datetime.now(timezone.utc),
+        end_time=datetime.now(timezone.utc) + timedelta(hours=4),
+        power_sequences_containers=[
+            power_sequence_container1,
+            power_sequence_container2,
+            power_sequence_container3,
+        ],
+    )
+
+    return power_profile_definition
+
+
+@pytest.fixture(scope="session")
+def resource_manager_details_frbc():
     return ResourceManagerDetails(
         message_id=get_unique_id(),
         resource_id=get_unique_id(),
         roles=[Role(role=RoleType.ENERGY_STORAGE, commodity=Commodity.ELECTRICITY)],
-        instruction_processing_delay=Duration(__root__=1.0),
+        instruction_processing_delay=Duration(1),
         available_control_types=[
             ControlType.FILL_RATE_BASED_CONTROL,
             ControlType.NO_SELECTION,
@@ -112,6 +208,26 @@ def resource_manager_details():
     )
 
 
+@pytest.fixture(scope="session")
+def resource_manager_details_ppbc():
+    return ResourceManagerDetails(
+        message_id=get_unique_id(),
+        resource_id=get_unique_id(),
+        roles=[Role(role=RoleType.ENERGY_CONSUMER, commodity=Commodity.ELECTRICITY)],
+        instruction_processing_delay=Duration(1),
+        available_control_types=[
+            ControlType.POWER_PROFILE_BASED_CONTROL,
+            ControlType.NO_SELECTION,
+        ],
+        provides_forecast=True,
+        provides_power_measurement_types=[
+            CommodityQuantity.ELECTRIC_POWER_L1,
+            CommodityQuantity.ELECTRIC_POWER_L2,
+            CommodityQuantity.ELECTRIC_POWER_L3,
+        ],
+    )
+
+
 @pytest.fixture(scope="session")
 def rm_handshake():
     return Handshake(