Merge pull request #649 from mavlink/pr-update-v2

Update to MAVSDK v2.1.0

Author: julianoes

.github/workflows/main.yml

@@ -143,16 +143,21 @@ jobs:
          echo $?
          git tag --list
 
+      - name: Set up Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: 3.11
+
       - name: Install prerequisites
         run: |
-          python3 -m pip install -r requirements.txt
-          python3 -m pip install twine wheel
-          python3 -m pip install --user delocate
+          python -m pip install -r requirements.txt
+          python -m pip install twine wheel
+          python -m pip install --user delocate
 
       - name: Create wheel
         run: |
-          python3 setup.py bdist_wheel
-          export PATH="$(python3 -m site --user-base)/bin:$PATH"
+          python setup.py bdist_wheel
+          export PATH="$(python -m site --user-base)/bin:$PATH"
           echo "PATH: $PATH"
           delocate-wheel -w wheelhouse -v dist/*.whl
           ls wheelhouse/*any.whl | sed -e 'p;s/any/macosx_10_9_x86_64/' | xargs -n2 mv
@@ -195,9 +200,9 @@ jobs:
          git tag --list
 
       - name: Set up Python
-        uses: actions/setup-python@v2
+        uses: actions/setup-python@v5
         with:
-          python-version: 3.10
+          python-version: 3.11
           architecture: ${{ matrix.arch }}
 
       - name: Install prerequisites

MAVSDK_SERVER_VERSION

@@ -1 +1 @@
-v1.4.17
+v2.1.0

mavsdk/action.py

@@ -127,6 +127,9 @@ class Result(Enum):
          UNSUPPORTED
               Action not supported
 
+         FAILED
+              Action failed
+
          """
 
 
@@ -143,6 +146,7 @@ class Result(Enum):
         NO_VTOL_TRANSITION_SUPPORT = 10
         PARAMETER_ERROR = 11
         UNSUPPORTED = 12
+        FAILED = 13
 
         def translate_to_rpc(self):
             if self == ActionResult.Result.UNKNOWN:
@@ -171,6 +175,8 @@ def translate_to_rpc(self):
                 return action_pb2.ActionResult.RESULT_PARAMETER_ERROR
             if self == ActionResult.Result.UNSUPPORTED:
                 return action_pb2.ActionResult.RESULT_UNSUPPORTED
+            if self == ActionResult.Result.FAILED:
+                return action_pb2.ActionResult.RESULT_FAILED
 
         @staticmethod
         def translate_from_rpc(rpc_enum_value):
@@ -201,6 +207,8 @@ def translate_from_rpc(rpc_enum_value):
                 return ActionResult.Result.PARAMETER_ERROR
             if rpc_enum_value == action_pb2.ActionResult.RESULT_UNSUPPORTED:
                 return ActionResult.Result.UNSUPPORTED
+            if rpc_enum_value == action_pb2.ActionResult.RESULT_FAILED:
+                return ActionResult.Result.FAILED
 
         def __str__(self):
             return self.name

mavsdk/action_pb2.py

@@ -135,6 +135,9 @@ class Result(Enum):
          NO_SYSTEM
               No system connected
 
+         PROTOCOL_UNSUPPORTED
+              Definition file protocol not supported
+
          """
 
 
@@ -147,6 +150,7 @@ class Result(Enum):
         TIMEOUT = 6
         WRONG_ARGUMENT = 7
         NO_SYSTEM = 8
+        PROTOCOL_UNSUPPORTED = 9
 
         def translate_to_rpc(self):
             if self == CameraResult.Result.UNKNOWN:
@@ -167,6 +171,8 @@ def translate_to_rpc(self):
                 return camera_pb2.CameraResult.RESULT_WRONG_ARGUMENT
             if self == CameraResult.Result.NO_SYSTEM:
                 return camera_pb2.CameraResult.RESULT_NO_SYSTEM
+            if self == CameraResult.Result.PROTOCOL_UNSUPPORTED:
+                return camera_pb2.CameraResult.RESULT_PROTOCOL_UNSUPPORTED
 
         @staticmethod
         def translate_from_rpc(rpc_enum_value):
@@ -189,6 +195,8 @@ def translate_from_rpc(rpc_enum_value):
                 return CameraResult.Result.WRONG_ARGUMENT
             if rpc_enum_value == camera_pb2.CameraResult.RESULT_NO_SYSTEM:
                 return CameraResult.Result.NO_SYSTEM
+            if rpc_enum_value == camera_pb2.CameraResult.RESULT_PROTOCOL_UNSUPPORTED:
+                return CameraResult.Result.PROTOCOL_UNSUPPORTED
 
         def __str__(self):
             return self.name
@@ -1978,44 +1986,56 @@ async def stop_video(self):
             raise CameraError(result, "stop_video()")
 
 
-    async def start_video_streaming(self):
+    async def start_video_streaming(self, stream_id):
         """
          Start video streaming.
 
+         Parameters
+         ----------
+         stream_id : int32_t
+              video stream id
+
          Raises
          ------
          CameraError
              If the request fails. The error contains the reason for the failure.
         """
 
         request = camera_pb2.StartVideoStreamingRequest()
+        request.stream_id = stream_id
         response = await self._stub.StartVideoStreaming(request)
 
 
         result = self._extract_result(response)
 
         if result.result != CameraResult.Result.SUCCESS:
-            raise CameraError(result, "start_video_streaming()")
+            raise CameraError(result, "start_video_streaming()", stream_id)
 
 
-    async def stop_video_streaming(self):
+    async def stop_video_streaming(self, stream_id):
         """
          Stop current video streaming.
 
+         Parameters
+         ----------
+         stream_id : int32_t
+              video stream id
+
          Raises
          ------
          CameraError
              If the request fails. The error contains the reason for the failure.
         """
 
         request = camera_pb2.StopVideoStreamingRequest()
+        request.stream_id = stream_id
         response = await self._stub.StopVideoStreaming(request)
 
 
         result = self._extract_result(response)
 
         if result.result != CameraResult.Result.SUCCESS:
-            raise CameraError(result, "stop_video_streaming()")
+            raise CameraError(result, "stop_video_streaming()", stream_id)
 
 
     async def set_mode(self, mode):
@@ -2330,26 +2350,32 @@ async def get_setting(self, setting):
         return Setting.translate_from_rpc(response.setting)
 
 
-    async def format_storage(self):
+    async def format_storage(self, storage_id):
         """
          Format storage (e.g. SD card) in camera.
 
          This will delete all content of the camera storage!
 
+         Parameters
+         ----------
+         storage_id : int32_t
+             Storage identify to be format
+
          Raises
          ------
          CameraError
              If the request fails. The error contains the reason for the failure.
         """
 
         request = camera_pb2.FormatStorageRequest()
+        request.storage_id = storage_id
         response = await self._stub.FormatStorage(request)
 
 
         result = self._extract_result(response)
 
         if result.result != CameraResult.Result.SUCCESS:
-            raise CameraError(result, "format_storage()")
+            raise CameraError(result, "format_storage()", storage_id)
 
 
     async def select_camera(self, camera_id):
@@ -2378,4 +2404,26 @@ async def select_camera(self, camera_id):
 
         if result.result != CameraResult.Result.SUCCESS:
             raise CameraError(result, "select_camera()", camera_id)
+        
+
+    async def reset_settings(self):
+        """
+         Reset all settings in camera.
+
+         This will reset all camera settings to default value
+
+         Raises
+         ------
+         CameraError
+             If the request fails. The error contains the reason for the failure.
+        """
+
+        request = camera_pb2.ResetSettingsRequest()
+        response = await self._stub.ResetSettings(request)
+
+        
+        result = self._extract_result(response)
+
+        if result.result != CameraResult.Result.SUCCESS:
+            raise CameraError(result, "reset_settings()")
 

mavsdk/camera.py

@@ -127,6 +127,11 @@ def __init__(self, channel):
                 request_serializer=camera_dot_camera__pb2.SelectCameraRequest.SerializeToString,
                 response_deserializer=camera_dot_camera__pb2.SelectCameraResponse.FromString,
                 )
+        self.ResetSettings = channel.unary_unary(
+                '/mavsdk.rpc.camera.CameraService/ResetSettings',
+                request_serializer=camera_dot_camera__pb2.ResetSettingsRequest.SerializeToString,
+                response_deserializer=camera_dot_camera__pb2.ResetSettingsResponse.FromString,
+                )
 
 
 class CameraServiceServicer(object):
@@ -316,6 +321,16 @@ def SelectCamera(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def ResetSettings(self, request, context):
+        """
+        Reset all settings in camera.
+
+        This will reset all camera settings to default value
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
 
 def add_CameraServiceServicer_to_server(servicer, server):
     rpc_method_handlers = {
@@ -424,6 +439,11 @@ def add_CameraServiceServicer_to_server(servicer, server):
                     request_deserializer=camera_dot_camera__pb2.SelectCameraRequest.FromString,
                     response_serializer=camera_dot_camera__pb2.SelectCameraResponse.SerializeToString,
             ),
+            'ResetSettings': grpc.unary_unary_rpc_method_handler(
+                    servicer.ResetSettings,
+                    request_deserializer=camera_dot_camera__pb2.ResetSettingsRequest.FromString,
+                    response_serializer=camera_dot_camera__pb2.ResetSettingsResponse.SerializeToString,
+            ),
     }
     generic_handler = grpc.method_handlers_generic_handler(
             'mavsdk.rpc.camera.CameraService', rpc_method_handlers)
@@ -798,3 +818,20 @@ def SelectCamera(request,
             camera_dot_camera__pb2.SelectCameraResponse.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def ResetSettings(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_unary(request, target, '/mavsdk.rpc.camera.CameraService/ResetSettings',
+            camera_dot_camera__pb2.ResetSettingsRequest.SerializeToString,
+            camera_dot_camera__pb2.ResetSettingsResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)