add library scenario_execution_network (#40)

Author: fred-labs

libs/scenario_execution_network/MANIFEST.in

@@ -0,0 +1 @@
+include scenario_execution_network/lib_osc/*.osc

libs/scenario_execution_network/README.md

@@ -0,0 +1,8 @@
+# Scenario Execution Library for network
+
+The `scenario_execution_network` package provides actions to interact with network services.
+
+It provides the following scenario execution library:
+
+- `network.osc`: Actions specific to network functions
+

libs/scenario_execution_network/package.xml

@@ -0,0 +1,21 @@
+<?xml version="1.0"?>
+<?xml-model href="http://download.ros.org/schema/package_format3.xsd" schematypens="http://www.w3.org/2001/XMLSchema"?>
+<package format="3">
+  <name>scenario_execution_network</name>
+  <version>1.3.0</version>
+  <description>Scenario Execution library for network functionality</description>
+  <author email="[email protected]">Frederik Pasch</author>
+  <maintainer email="[email protected]">Frederik Pasch</maintainer>
+  <license>Apache-2.0</license>
+
+  <depend>scenario_execution</depend>
+
+  <test_depend>ament_copyright</test_depend>
+  <test_depend>ament_flake8</test_depend>
+  <test_depend>ament_pep257</test_depend>
+  <test_depend>python3-pytest</test_depend>
+  
+  <export>
+    <build_type>ament_python</build_type>
+  </export>
+</package>

libs/scenario_execution_network/resource/scenario_execution_network

@@ -0,0 +1,21 @@
+# Copyright (C) 2025 Frederik Pasch
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions
+# and limitations under the License.
+#
+# SPDX-License-Identifier: Apache-2.0
+
+from . import actions
+
+__all__ = [
+    'actions'
+]

libs/scenario_execution_network/scenario_execution_network/__init__.py

@@ -0,0 +1,15 @@
+# Copyright (C) 2025 Frederik Pasch
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions
+# and limitations under the License.
+#
+# SPDX-License-Identifier: Apache-2.0

libs/scenario_execution_network/scenario_execution_network/actions/__init__.py

@@ -0,0 +1,84 @@
+# Copyright (C) 2025 Frederik Pasch
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions
+# and limitations under the License.
+#
+# SPDX-License-Identifier: Apache-2.0
+
+from enum import Enum
+from scenario_execution.actions.base_action import BaseAction
+import py_trees
+from concurrent.futures import ThreadPoolExecutor
+import requests
+
+class RequestStatus(Enum):
+    IDLE = 1
+    REQUESTING = 2
+    DONE = 3
+
+
+class HttpGet(BaseAction):
+    """
+    Class to perform an HTTP GET request asynchronously
+    """
+
+    def __init__(self) -> None:
+        super().__init__()
+        self.response = None
+        self.future = None
+        self.parameters = {}
+        self.executor = ThreadPoolExecutor(max_workers=1)
+        self.current_state = RequestStatus.IDLE
+
+    def execute(self, url: str, parameters: list) -> None:  # pylint: disable=arguments-differ,arguments-renamed
+        self.url = url
+        self.parameters = {}
+        for param in parameters:
+            self.parameters[param["key"]] = param["value"]
+
+    def update(self) -> py_trees.common.Status:
+        if self.current_state == RequestStatus.IDLE:
+            # Start the async HTTP request in a separate thread
+            self.future = self.executor.submit(self._make_request)
+            self.current_state = RequestStatus.REQUESTING
+            return py_trees.common.Status.RUNNING
+
+        elif self.current_state == RequestStatus.REQUESTING:
+            if self.future.done():
+                try:
+                    self.response = self.future.result()
+                    if self.response.status_code == 200:
+                        self.current_state = RequestStatus.DONE
+                        return py_trees.common.Status.SUCCESS
+                    else:
+                        self.logger.error(f"HTTP GET returned status code {self.response.status_code}")
+                        self.current_state = RequestStatus.DONE
+                        return py_trees.common.Status.FAILURE
+                except Exception as e:
+                    self.logger.error(f"HTTP GET request failed: {e}")
+                    return py_trees.common.Status.FAILURE
+            else:
+                return py_trees.common.Status.RUNNING
+
+        elif self.current_state == RequestStatus.DONE:
+            return py_trees.common.Status.SUCCESS
+
+        return py_trees.common.Status.FAILURE
+
+    def _make_request(self):
+        """Make the HTTP request synchronously in a thread pool"""
+        return requests.get(self.url, params=self.parameters)
+
+    def shutdown(self):
+        """Clean up the thread pool on shutdown"""
+        if self.executor:
+            self.executor.shutdown(wait=False)

libs/scenario_execution_network/scenario_execution_network/actions/http_get.py

@@ -0,0 +1,19 @@
+# Copyright (C) 2025 Frederik Pasch
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions
+# and limitations under the License.
+#
+# SPDX-License-Identifier: Apache-2.0
+
+
+def get_osc_library():
+    return 'scenario_execution_network', 'network.osc'

libs/scenario_execution_network/scenario_execution_network/get_osc_library.py

@@ -0,0 +1,10 @@
+import osc.types
+
+###########
+# Actions
+###########
+
+action http_get:
+    # Perform an HTTP GET request to the specified URL
+    url: string                          # URL to send the GET request to
+    parameters: list of key_value            # Optional query parameters for the request

libs/scenario_execution_network/scenario_execution_network/lib_osc/network.osc

@@ -0,0 +1,4 @@
+[develop]
+script_dir=$base/lib/scenario_execution_network
+[install]
+install_scripts=$base/lib/scenario_execution_network