Add ReadDigitalWaveforms to NiDAQmxService

generated/nidaqmx/nidaqmx.proto

@@ -467,6 +467,7 @@ service NiDAQmx {
   rpc WriteToTEDSFromArray(WriteToTEDSFromArrayRequest) returns (WriteToTEDSFromArrayResponse);
   rpc WriteToTEDSFromFile(WriteToTEDSFromFileRequest) returns (WriteToTEDSFromFileResponse);
   rpc ReadAnalogWaveforms(ReadAnalogWaveformsRequest) returns (ReadAnalogWaveformsResponse);
+  rpc ReadDigitalWaveforms(ReadDigitalWaveformsRequest) returns (ReadDigitalWaveformsResponse);
 }
 
 enum BufferUInt32Attribute {
@@ -11535,3 +11536,19 @@ message ReadAnalogWaveformsResponse {
   int32 samps_per_chan_read = 3;
 }
 
+message ReadDigitalWaveformsRequest {
+  nidevice_grpc.Session task = 1;
+  int32 num_samps_per_chan = 2;
+  double timeout = 3;
+  oneof waveform_attribute_mode_enum {
+    WaveformAttributeMode waveform_attribute_mode = 4;
+    int32 waveform_attribute_mode_raw = 5;
+  }
+}
+
+message ReadDigitalWaveformsResponse {
+  int32 status = 1;
+  repeated ni.protobuf.types.DigitalWaveform waveforms = 2;
+  int32 samps_per_chan_read = 3;
+}
+

generated/nidaqmx/nidaqmx_client.cpp

@@ -12441,5 +12441,32 @@ read_analog_waveforms(const StubPtr& stub, const nidevice_grpc::Session& task, c
   return response;
 }
 
+ReadDigitalWaveformsResponse
+read_digital_waveforms(const StubPtr& stub, const nidevice_grpc::Session& task, const pb::int32& num_samps_per_chan, const double& timeout, const simple_variant<WaveformAttributeMode, pb::int32>& waveform_attribute_mode)
+{
+  ::grpc::ClientContext context;
+
+  auto request = ReadDigitalWaveformsRequest{};
+  request.mutable_task()->CopyFrom(task);
+  request.set_num_samps_per_chan(num_samps_per_chan);
+  request.set_timeout(timeout);
+  const auto waveform_attribute_mode_ptr = waveform_attribute_mode.get_if<WaveformAttributeMode>();
+  const auto waveform_attribute_mode_raw_ptr = waveform_attribute_mode.get_if<pb::int32>();
+  if (waveform_attribute_mode_ptr) {
+    request.set_waveform_attribute_mode(*waveform_attribute_mode_ptr);
+  }
+  else if (waveform_attribute_mode_raw_ptr) {
+    request.set_waveform_attribute_mode_raw(*waveform_attribute_mode_raw_ptr);
+  }
+
+  auto response = ReadDigitalWaveformsResponse{};
+
+  raise_if_error(
+      stub->ReadDigitalWaveforms(&context, request, &response),
+      context);
+
+  return response;
+}
+
 
 } // namespace nidaqmx_grpc::experimental::client

generated/nidaqmx/nidaqmx_client.h

@@ -469,6 +469,7 @@ BeginWriteRawResponse begin_write_raw(const StubPtr& stub, const nidevice_grpc::
 WriteToTEDSFromArrayResponse write_to_teds_from_array(const StubPtr& stub, const std::string& physical_channel, const std::string& bit_stream, const simple_variant<WriteBasicTEDSOptions, pb::int32>& basic_teds_options);
 WriteToTEDSFromFileResponse write_to_teds_from_file(const StubPtr& stub, const std::string& physical_channel, const std::string& file_path, const simple_variant<WriteBasicTEDSOptions, pb::int32>& basic_teds_options);
 ReadAnalogWaveformsResponse read_analog_waveforms(const StubPtr& stub, const nidevice_grpc::Session& task, const pb::int32& num_samps_per_chan, const double& timeout, const simple_variant<WaveformAttributeMode, pb::int32>& waveform_attribute_mode);
+ReadDigitalWaveformsResponse read_digital_waveforms(const StubPtr& stub, const nidevice_grpc::Session& task, const pb::int32& num_samps_per_chan, const double& timeout, const simple_variant<WaveformAttributeMode, pb::int32>& waveform_attribute_mode);
 
 } // namespace nidaqmx_grpc::experimental::client
 

generated/nidaqmx/nidaqmx_service.h

@@ -539,6 +539,7 @@ class NiDAQmxService final : public NiDAQmx::WithCallbackMethod_RegisterSignalEv
   ::grpc::Status WriteToTEDSFromArray(::grpc::ServerContext* context, const WriteToTEDSFromArrayRequest* request, WriteToTEDSFromArrayResponse* response) override;
   ::grpc::Status WriteToTEDSFromFile(::grpc::ServerContext* context, const WriteToTEDSFromFileRequest* request, WriteToTEDSFromFileResponse* response) override;
   ::grpc::Status ReadAnalogWaveforms(::grpc::ServerContext* context, const ReadAnalogWaveformsRequest* request, ReadAnalogWaveformsResponse* response) override;
+  ::grpc::Status ReadDigitalWaveforms(::grpc::ServerContext* context, const ReadDigitalWaveformsRequest* request, ReadDigitalWaveformsResponse* response) override;
 private:
   LibrarySharedPtr library_;
   ResourceRepositorySharedPtr session_repository_;

source/codegen/metadata/nidaqmx/functions_addon.py

@@ -68,6 +68,76 @@
                 'type': 'int32'
             }
         ]
+    },
+    'ReadDigitalWaveforms': {
+        'returns': 'int32',
+        'codegen_method': 'CustomCodeNoLibrary',
+        'parameters': [
+            {
+                'ctypes_data_type': 'ctypes.TaskHandle',
+                'direction': 'in',
+                'is_optional_in_python': False,
+                'name': 'task',
+                'python_data_type': 'TaskHandle',
+                'python_description': '',
+                'python_type_annotation': 'TaskHandle',
+                'type': 'TaskHandle'
+            },
+            {
+                'ctypes_data_type': 'ctypes.c_int',
+                'direction': 'in',
+                'is_optional_in_python': False,
+                'name': 'numSampsPerChan',
+                'python_data_type': 'int',
+                'python_description': '',
+                'python_type_annotation': 'int',
+                'type': 'int32'
+            },
+            {
+                'ctypes_data_type': 'ctypes.c_double',
+                'direction': 'in',
+                'is_optional_in_python': True,
+                'name': 'timeout',
+                'python_data_type': 'float',
+                'python_default_value': '10.0',
+                'python_description': 'Specifies the time in seconds to wait for the device to respond before timing out.',
+                'python_type_annotation': 'Optional[float]',
+                'type': 'float64'
+            },
+            {
+                'ctypes_data_type': 'ctypes.c_int',
+                'direction': 'in',
+                'enum': 'WaveformAttributeMode',
+                'is_optional_in_python': True,
+                'name': 'waveformAttributeMode',
+                'python_data_type': 'WaveformAttributeMode',
+                'python_default_value': 'WaveformAttributeMode.NONE',
+                'python_description': 'Specifies which waveform attributes to return with the waveforms.',
+                'python_type_annotation': 'Optional[nidaqmx.constants.WaveformAttributeMode]',
+                'type': 'int32'
+            },
+            {
+                'direction': 'out',
+                'is_optional_in_python': False,
+                'name': 'waveforms',
+                'python_data_type': 'object',
+                'python_description': 'The waveforms read from the specified channels.',
+                'python_type_annotation': 'List[object]',
+                'type': 'repeated ni.protobuf.types.DigitalWaveform'
+            },
+            {
+                'ctypes_data_type': 'ctypes.c_int',
+                'direction': 'out',
+                'is_optional_in_python': False,
+                'is_streaming_type': True,
+                'name': 'sampsPerChanRead',
+                'python_data_type': 'int',
+                'python_description': '',
+                'python_type_annotation': 'int',
+                'return_on_error_key': 'ni-samps-per-chan-read',
+                'type': 'int32'
+            }
+        ]
     }
 }
 
@@ -104,6 +174,12 @@
             # size is determined by the number of channels in the task
             'waveforms': ['ARRAY_PARAMETER_NEEDS_SIZE']
         }
+    },
+    'ReadDigitalWaveforms': {
+        'parameters': {
+            # size is determined by the number of channels in the task
+            'waveforms': ['ARRAY_PARAMETER_NEEDS_SIZE']
+        }
     }
 }