// ------------------------------------------------------------------------------
// <auto-generated>
//     This code was generated by a tool.
//     Runtime Version: 18.0.0.0
//  
//     Changes to this file may cause incorrect behavior and will be lost if
//     the code is regenerated.
// </auto-generated>
// ------------------------------------------------------------------------------
namespace Azure.Iot.Operations.EnvoyGenerator
{
    using Azure.Iot.Operations.CodeGeneration;
    using System;
    
    /// <summary>
    /// Class to produce the template output
    /// </summary>
    [global::System.CodeDom.Compiler.GeneratedCodeAttribute("Microsoft.VisualStudio.TextTemplating", "18.0.0.0")]
    public partial class RustPropertyConsumer : RustPropertyConsumerBase
    {
        /// <summary>
        /// Create the template output
        /// </summary>
        public virtual string TransformText()
        {
 // Copyright (c) Microsoft Corporation. 
 // Licensed under the MIT License 
            this.Write("/* Code generated by Azure.Iot.Operations.ProtocolCompilerLib v");
            this.Write(this.ToStringHelper.ToStringWithCulture(System.Reflection.Assembly.GetExecutingAssembly().GetName().Version));
            this.Write("; DO NOT EDIT. */\r\n\r\nuse std::collections::HashMap;\r\n");
 if (this.readErrorName != null) { 
            this.Write("use std::error::Error;\r\n");
 } 
            this.Write("use std::time::Duration;\r\n\r\nuse azure_iot_operations_mqtt::session::SessionManage" +
                    "dClient;\r\nuse azure_iot_operations_protocol::common::aio_protocol_error::{\r\n    " +
                    "AIOProtocolError,\r\n");
 if (this.readErrorName != null) { 
            this.Write("    AIOProtocolErrorKind,\r\n");
 } 
            this.Write("};\r\n");
 if (this.writeReqSchema != null) { 
            this.Write("use azure_iot_operations_protocol::common::payload_serialize::PayloadSerialize;\r\n" +
                    "");
 } 
            this.Write("use azure_iot_operations_protocol::rpc_command;\r\nuse azure_iot_operations_protoco" +
                    "l::application::ApplicationContext;\r\n\r\nuse super::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propSchema.GetFileName(TargetLanguage.Rust)));
            this.Write("::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(";\r\n");
 if (this.readRespSchema is CodeName && !this.readRespSchema.Equals(this.propSchema)) { 
            this.Write("use super::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readRespSchema.GetFileName(TargetLanguage.Rust)));
            this.Write("::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readRespSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(";\r\n");
 } 
 if (this.writeReqSchema is CodeName && !this.writeReqSchema.Equals(this.readRespSchema) && !this.writeReqSchema.Equals(this.propSchema)) { 
            this.Write("use super::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeReqSchema.GetFileName(TargetLanguage.Rust)));
            this.Write("::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeReqSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(";\r\n");
 } 
 if (this.writeRespSchema is CodeName) { 
            this.Write("use super::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeRespSchema.GetFileName(TargetLanguage.Rust)));
            this.Write("::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeRespSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(";\r\n");
 } 
 if (this.readErrorName != null) { 
            this.Write("use super::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readErrorSchema.GetFileName(TargetLanguage.Rust)));
            this.Write("::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readErrorSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(";\r\n");
 } 
 if (this.writeErrorName != null && !this.writeErrorSchema.Equals(this.readErrorSchema)) { 
            this.Write("use super::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeErrorSchema.GetFileName(TargetLanguage.Rust)));
            this.Write("::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeErrorSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(";\r\n");
 } 
            this.Write("use super::super::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.commonNs.GetFolderName(TargetLanguage.Rust)));
            this.Write("::options::CommandInvokerOptions;\r\nuse super::super::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.commonNs.GetFolderName(TargetLanguage.Rust)));
            this.Write("::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readSerializerEmptyType.GetFileName(TargetLanguage.Rust)));
            this.Write("::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readSerializerEmptyType.GetTypeName(TargetLanguage.Rust)));
            this.Write(";\r\n");
 if (!this.readSerializerEmptyType.Equals(this.writeSerializerEmptyType)) { 
            this.Write("use super::super::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.commonNs.GetFolderName(TargetLanguage.Rust)));
            this.Write("::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeSerializerEmptyType.GetFileName(TargetLanguage.Rust)));
            this.Write("::");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeSerializerEmptyType.GetTypeName(TargetLanguage.Rust)));
            this.Write(";\r\n");
 } 
            this.Write("\r\n");
 if (this.readRespSchema != null) { 
            this.Write("pub type ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "request")));
            this.Write(" = rpc_command::invoker::Request<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readSerializerEmptyType.GetTypeName(TargetLanguage.Rust)));
            this.Write(">;\r\npub type ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "response")));
            this.Write(" = rpc_command::invoker::Response<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(">;\r\npub type ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "request", "builder", "error")));
            this.Write(" = rpc_command::invoker::RequestBuilderError;\r\n");
 if (this.readErrorSchema != null) { 
            this.Write("pub type ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "response", "error")));
            this.Write(" = rpc_command::invoker::Response<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readErrorSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(">;\r\n");
 } 
 } 
 if (this.writeReqSchema != null) { 
            this.Write("pub type ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "request")));
            this.Write(" = rpc_command::invoker::Request<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeReqSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(">;\r\npub type ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "response")));
            this.Write(" = rpc_command::invoker::Response<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeSerializerEmptyType.GetTypeName(TargetLanguage.Rust)));
            this.Write(">;\r\npub type ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "request", "builder", "error")));
            this.Write(" = rpc_command::invoker::RequestBuilderError;\r\n");
 if (this.writeErrorSchema != null) { 
            this.Write("pub type ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "response", "error")));
            this.Write(" = rpc_command::invoker::Response<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeErrorSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(">;\r\n");
 } 
 } 
 if (this.readRespSchema != null) { 
            this.Write("\r\n#[derive(Default)]\r\n/// Builder for [`");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "request")));
            this.Write("`]\r\npub struct ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "request", "builder")));
            this.Write(" {\r\n    inner_builder: rpc_command::invoker::RequestBuilder<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readSerializerEmptyType.GetTypeName(TargetLanguage.Rust)));
            this.Write(">,\r\n");
 if (this.doesPropertyTargetReadMaintainer) { 
            this.Write("    set_maintainer_id: bool,\r\n");
 } 
            this.Write("    topic_tokens: HashMap<String, String>,\r\n}\r\n\r\nimpl ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "request", "builder")));
            this.Write(@" {
    /// Custom user data to set on the read request
    pub fn custom_user_data(&mut self, custom_user_data: Vec<(String, String)>) -> &mut Self {
        self.inner_builder.custom_user_data(custom_user_data);
        self
    }

    /// Topic token keys/values to be replaced into the publish topic of the request message.
    /// A prefix of ""ex:"" will be prepended to each key before scanning the topic pattern.
    /// Thus, only tokens of the form `{ex:SOMEKEY}` will be replaced.
    pub fn topic_tokens(&mut self, topic_tokens: HashMap<String, String>) -> &mut Self {
        for (k, v) in topic_tokens {
            self.topic_tokens.insert(format!(""ex:{k}""), v);
        }
        self
    }

    /// Timeout for the request
    pub fn timeout(&mut self, timeout: Duration) -> &mut Self {
        self.inner_builder.timeout(timeout);
        self
    }

");
 if (this.doesPropertyTargetReadMaintainer) { 
            this.Write(@"    /// Target maintainer ID
    pub fn maintainer_id(&mut self, maintainer_id: &str) -> &mut Self {
        self.topic_tokens
            .insert(""maintainerId"".to_string(), maintainer_id.to_string());
        self.set_maintainer_id = true;
        self
    }

");
 } 
            this.Write("    /// Builds a new `");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "request")));
            this.Write("`\r\n    ///\r\n    /// # Errors\r\n    /// If a required field has not been initialize" +
                    "d\r\n    #[allow(clippy::missing_panics_doc)] // The panic is not possible\r\n    pu" +
                    "b fn build(&mut self) -> Result<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "request")));
            this.Write(", ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "request", "builder", "error")));
            this.Write("> {\r\n");
 if (this.doesPropertyTargetReadMaintainer) { 
            this.Write("        if !self.set_maintainer_id {\r\n            return Err(");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "request", "builder", "error")));
            this.Write("::UninitializedField(\r\n                \"maintainer_id\",\r\n            ));\r\n       " +
                    " }\r\n\r\n");
 } 
            this.Write("        self.inner_builder.payload(");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readSerializerEmptyType.GetAllocator(TargetLanguage.Rust)));
            this.Write(").unwrap();\r\n\r\n        self.inner_builder.topic_tokens(self.topic_tokens.clone())" +
                    ";\r\n\r\n        self.inner_builder.build()\r\n    }\r\n}\r\n");
 } 
 if (this.writeReqSchema != null) { 
            this.Write("\r\n#[derive(Default)]\r\n/// Builder for [`");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "request")));
            this.Write("`]\r\npub struct ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "request", "builder")));
            this.Write(" {\r\n    inner_builder: rpc_command::invoker::RequestBuilder<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeReqSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(">,\r\n");
 if (this.doesPropertyTargetWriteMaintainer) { 
            this.Write("    set_maintainer_id: bool,\r\n");
 } 
            this.Write("    topic_tokens: HashMap<String, String>,\r\n}\r\n\r\nimpl ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "request", "builder")));
            this.Write(@" {
    /// Custom user data to set on the write request
    pub fn custom_user_data(&mut self, custom_user_data: Vec<(String, String)>) -> &mut Self {
        self.inner_builder.custom_user_data(custom_user_data);
        self
    }

    /// Topic token keys/values to be replaced into the publish topic of the request message.
    /// A prefix of ""ex:"" will be prepended to each key before scanning the topic pattern.
    /// Thus, only tokens of the form `{ex:SOMEKEY}` will be replaced.
    pub fn topic_tokens(&mut self, topic_tokens: HashMap<String, String>) -> &mut Self {
        for (k, v) in topic_tokens {
            self.topic_tokens.insert(format!(""ex:{k}""), v);
        }
        self
    }

    /// Timeout for the request
    pub fn timeout(&mut self, timeout: Duration) -> &mut Self {
        self.inner_builder.timeout(timeout);
        self
    }

");
 if (this.doesPropertyTargetWriteMaintainer) { 
            this.Write(@"    /// Target maintainer ID
    pub fn maintainer_id(&mut self, maintainer_id: &str) -> &mut Self {
        self.topic_tokens
            .insert(""maintainerId"".to_string(), maintainer_id.to_string());
        self.set_maintainer_id = true;
        self
    }

");
 } 
            this.Write("    /// Payload of the write request\r\n    ///\r\n    /// # Errors\r\n    /// If the p" +
                    "ayload cannot be serialized\r\n    pub fn payload(\r\n        &mut self,\r\n        pa" +
                    "yload: ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeReqSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(",\r\n    ) -> Result<&mut Self, AIOProtocolError> {\r\n        self.inner_builder.pay" +
                    "load(payload)?;\r\n        Ok(self)\r\n    }\r\n\r\n    /// Builds a new `");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "request")));
            this.Write("`\r\n    ///\r\n    /// # Errors\r\n    /// If a required field has not been initialize" +
                    "d\r\n    #[allow(clippy::missing_panics_doc)] // The panic is not possible\r\n    pu" +
                    "b fn build(&mut self) -> Result<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "request")));
            this.Write(", ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "request", "builder", "error")));
            this.Write("> {\r\n");
 if (this.doesPropertyTargetWriteMaintainer) { 
            this.Write("        if !self.set_maintainer_id {\r\n            return Err(");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "request", "builder", "error")));
            this.Write("::UninitializedField(\r\n                \"maintainer_id\",\r\n            ));\r\n       " +
                    " }\r\n\r\n");
 } 
            this.Write("        self.inner_builder.topic_tokens(self.topic_tokens.clone());\r\n\r\n        se" +
                    "lf.inner_builder.build()\r\n    }\r\n}\r\n");
 } 
 if (this.readRespSchema != null) { 
            this.Write("\r\n");
 if (!this.propertyName.IsEmpty) { 
            this.Write("/// Read requester for `");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.AsGiven));
            this.Write("`\r\n");
 } else { 
            this.Write("/// Read requester for a Property collection\r\n");
 } 
            this.Write("pub struct ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "requester")));
            this.Write("(\r\n    rpc_command::Invoker<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readSerializerEmptyType.GetTypeName(TargetLanguage.Rust)));
            this.Write(", ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readRespSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(">,\r\n);\r\n\r\nimpl ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "requester")));
            this.Write("\r\n{\r\n    /// Creates a new [`");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "requester")));
            this.Write(@"`]
    ///
    /// # Panics
    /// If the DTDL that generated this code was invalid
    pub fn new(application_context: ApplicationContext, client: SessionManagedClient, options: &CommandInvokerOptions) -> Self {
        let mut invoker_options_builder = rpc_command::invoker::OptionsBuilder::default();
        if let Some(topic_namespace) = &options.topic_namespace {
            invoker_options_builder.topic_namespace(topic_namespace.clone());
        }

        let mut topic_token_map: HashMap<String, String> = options
            .topic_token_map
            .clone()
            .into_iter()
            .map(|(k, v)| (format!(""ex:{k}""), v))
            .collect();

        topic_token_map.insert(""");
            this.Write(this.ToStringHelper.ToStringWithCulture(MqttTopicTokens.PropertyAction));
            this.Write("\".to_string(), \"");
            this.Write(this.ToStringHelper.ToStringWithCulture(MqttTopicTokens.PropertyActionValues.Read));
            this.Write("\".to_string());\r\n        topic_token_map.insert(\"");
            this.Write(this.ToStringHelper.ToStringWithCulture(MqttTopicTokens.PropertyConsumerId));
            this.Write("\".to_string(), client.client_id().to_string());\r\n\r\n        let invoker_options = " +
                    "invoker_options_builder\r\n            .request_topic_pattern(\"");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readTopicPattern));
            this.Write("\")\r\n            .command_name(\"");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readCommandName));
            this.Write(@""")
            .topic_token_map(topic_token_map)
            .response_topic_prefix(options.response_topic_prefix.clone())
            .response_topic_suffix(options.response_topic_suffix.clone())
            .build()
            .expect(""DTDL schema generated invalid arguments"");

        Self(
            rpc_command::Invoker::new(application_context, client, invoker_options)
                .expect(""DTDL schema generated invalid arguments""),
        )
    }

    /// Invokes the [`");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "request")));
            this.Write("`]\r\n    ///\r\n    /// # Errors\r\n    /// [`AIOProtocolError`] if there is a failure" +
                    " invoking the request\r\n    pub async fn invoke(\r\n        &self,\r\n        request" +
                    ": ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "request")));
            this.Write(",\r\n");
 if (this.readErrorName != null) { 
            this.Write("    ) -> Result<Result<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "response")));
            this.Write(", ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "response", "error")));
            this.Write(">, AIOProtocolError> {\r\n        let response = self.0.invoke(request).await;\r\n   " +
                    "     match response {\r\n            Ok(response) => {\r\n                if let Som" +
                    "e(");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readErrorName.GetVariableName(TargetLanguage.Rust)));
            this.Write(") = response.payload.");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readErrorName.GetFieldName(TargetLanguage.Rust)));
            this.Write(" {\r\n                    Ok(Err(");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "response", "error")));
            this.Write(" {\r\n                        payload: ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readErrorName.GetVariableName(TargetLanguage.Rust)));
            this.Write(@",
                        content_type: response.content_type,
                        format_indicator: response.format_indicator,
                        custom_user_data: response.custom_user_data,
                        timestamp: response.timestamp,
                        executor_id: response.executor_id,
                    }))
                } else if let Some(");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propValueName.GetVariableName(TargetLanguage.Rust)));
            this.Write(") = response.payload.");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propValueName.GetFieldName(TargetLanguage.Rust)));
            this.Write(" {\r\n                    Ok(Ok(");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "response")));
            this.Write(" {\r\n");
 if (this.separateProperties) { 
            this.Write("                        payload: ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(" { ");
            this.Write(this.ToStringHelper.ToStringWithCulture((this.propValueName ?? this.propertyName).GetFieldName(TargetLanguage.Rust)));
            this.Write(": ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propValueName.GetVariableName(TargetLanguage.Rust)));
            this.Write(" },\r\n");
 } else { 
            this.Write("                        payload: ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propValueName.GetVariableName(TargetLanguage.Rust)));
            this.Write(",\r\n");
 } 
            this.Write(@"                        content_type: response.content_type,
                        format_indicator: response.format_indicator,
                        custom_user_data: response.custom_user_data,
                        timestamp: response.timestamp,
                        executor_id: response.executor_id,
                    }))
                } else {
                    Err(AIOProtocolError {
                        message: Some(
                            ""Command response has neither normal nor error payload content""
                                .to_string(),
                        ),
                        kind: AIOProtocolErrorKind::PayloadInvalid,
                        is_shallow: false,
                        is_remote: true,
                        nested_error: None,
                        header_name: None,
                        header_value: None,
                        timeout_name: None,
                        timeout_value: None,
                        property_name: None,
                        property_value: None,
                        command_name: Some(""");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readCommandName));
            this.Write("\".to_string()),\r\n                        protocol_version: None,\r\n               " +
                    "         supported_protocol_major_versions: None,\r\n                    })\r\n     " +
                    "           }\r\n            }\r\n            Err(err) => Err(err),\r\n        }\r\n");
 } else { 
            this.Write("    ) -> Result<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "response")));
            this.Write(", AIOProtocolError> {\r\n        self.0.invoke(request).await\r\n");
 } 
            this.Write("    }\r\n\r\n    /// Shutdown the [`");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "read", "requester")));
            this.Write(@"`]. Unsubscribes from the response topic and cancels the receiver loop to drop the receiver and to prevent the task from looping indefinitely.
    ///
    /// Returns Ok(()) on success, otherwise returns [`AIOProtocolError`].
    /// # Errors
    /// [`AIOProtocolError`] of kind [`ClientError`](azure_iot_operations_protocol::common::aio_protocol_error::AIOProtocolErrorKind::ClientError) if the unsubscribe fails or if the unsuback reason code doesn't indicate success.
    pub async fn shutdown(&self) -> Result<(), AIOProtocolError> {
        self.0.shutdown().await
    }
}
");
 } 
 if (this.writeReqSchema != null) { 
            this.Write("\r\n");
 if (!this.propertyName.IsEmpty) { 
            this.Write("/// Write requester for `");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.AsGiven));
            this.Write("`\r\n");
 } else { 
            this.Write("/// Write requester for a Property collection\r\n");
 } 
            this.Write("pub struct ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "requester")));
            this.Write("(\r\n    rpc_command::Invoker<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeReqSchema.GetTypeName(TargetLanguage.Rust)));
            this.Write(", ");
            this.Write(this.ToStringHelper.ToStringWithCulture(((ITypeName)this.writeRespSchema ?? this.writeSerializerEmptyType).GetTypeName(TargetLanguage.Rust)));
            this.Write(">,\r\n);\r\n\r\nimpl ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "requester")));
            this.Write("\r\n{\r\n    /// Creates a new [`");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "requester")));
            this.Write(@"`]
    ///
    /// # Panics
    /// If the DTDL that generated this code was invalid
    pub fn new(application_context: ApplicationContext, client: SessionManagedClient, options: &CommandInvokerOptions) -> Self {
        let mut invoker_options_builder = rpc_command::invoker::OptionsBuilder::default();
        if let Some(topic_namespace) = &options.topic_namespace {
            invoker_options_builder.topic_namespace(topic_namespace.clone());
        }

        let mut topic_token_map: HashMap<String, String> = options
            .topic_token_map
            .clone()
            .into_iter()
            .map(|(k, v)| (format!(""ex:{k}""), v))
            .collect();

        topic_token_map.insert(""");
            this.Write(this.ToStringHelper.ToStringWithCulture(MqttTopicTokens.PropertyAction));
            this.Write("\".to_string(), \"");
            this.Write(this.ToStringHelper.ToStringWithCulture(MqttTopicTokens.PropertyActionValues.Write));
            this.Write("\".to_string());\r\n        topic_token_map.insert(\"");
            this.Write(this.ToStringHelper.ToStringWithCulture(MqttTopicTokens.PropertyConsumerId));
            this.Write("\".to_string(), client.client_id().to_string());\r\n\r\n        let invoker_options = " +
                    "invoker_options_builder\r\n            .request_topic_pattern(\"");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.readTopicPattern));
            this.Write("\")\r\n            .command_name(\"");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeCommandName));
            this.Write(@""")
            .topic_token_map(topic_token_map)
            .response_topic_prefix(options.response_topic_prefix.clone())
            .response_topic_suffix(options.response_topic_suffix.clone())
            .build()
            .expect(""DTDL schema generated invalid arguments"");

        Self(
            rpc_command::Invoker::new(application_context, client, invoker_options)
                .expect(""DTDL schema generated invalid arguments""),
        )
    }

    /// Invokes the [`");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "request")));
            this.Write("`]\r\n    ///\r\n    /// # Errors\r\n    /// [`AIOProtocolError`] if there is a failure" +
                    " invoking the request\r\n    pub async fn invoke(\r\n        &self,\r\n        request" +
                    ": ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "request")));
            this.Write(",\r\n");
 if (this.writeErrorName != null) { 
            this.Write("    ) -> Result<Result<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "response")));
            this.Write(", ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "response", "error")));
            this.Write(">, AIOProtocolError> {\r\n        let response = self.0.invoke(request).await;\r\n   " +
                    "     match response {\r\n            Ok(response) => {\r\n                if let Som" +
                    "e(");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeErrorName.GetVariableName(TargetLanguage.Rust)));
            this.Write(") = response.payload.");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeErrorName.GetFieldName(TargetLanguage.Rust)));
            this.Write(" {\r\n                    Ok(Err(");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "response", "error")));
            this.Write(" {\r\n                        payload: ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeErrorName.GetVariableName(TargetLanguage.Rust)));
            this.Write(@",
                        content_type: response.content_type,
                        format_indicator: response.format_indicator,
                        custom_user_data: response.custom_user_data,
                        timestamp: response.timestamp,
                        executor_id: response.executor_id,
                    }))
                } else {
                    Ok(Ok(");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "response")));
            this.Write(" {\r\n                        payload: ");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.writeSerializerEmptyType.GetAllocator(TargetLanguage.Rust)));
            this.Write(@",
                        content_type: response.content_type,
                        format_indicator: response.format_indicator,
                        custom_user_data: response.custom_user_data,
                        timestamp: response.timestamp,
                        executor_id: response.executor_id,
                    }))
                }
            }
            Err(err) => Err(err),
        }
");
 } else { 
            this.Write("    ) -> Result<");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "response")));
            this.Write(", AIOProtocolError> {\r\n        self.0.invoke(request).await\r\n");
 } 
            this.Write("    }\r\n\r\n    /// Shutdown the [`");
            this.Write(this.ToStringHelper.ToStringWithCulture(this.propertyName.GetTypeName(TargetLanguage.Rust, "write", "requester")));
            this.Write(@"`]. Unsubscribes from the response topic and cancels the receiver loop to drop the receiver and to prevent the task from looping indefinitely.
    ///
    /// Returns Ok(()) on success, otherwise returns [`AIOProtocolError`].
    /// # Errors
    /// [`AIOProtocolError`] of kind [`ClientError`](azure_iot_operations_protocol::common::aio_protocol_error::AIOProtocolErrorKind::ClientError) if the unsubscribe fails or if the unsuback reason code doesn't indicate success.
    pub async fn shutdown(&self) -> Result<(), AIOProtocolError> {
        self.0.shutdown().await
    }
}
");
 } 
            return this.GenerationEnvironment.ToString();
        }
    }
    #region Base class
    /// <summary>
    /// Base class for this transformation
    /// </summary>
    [global::System.CodeDom.Compiler.GeneratedCodeAttribute("Microsoft.VisualStudio.TextTemplating", "18.0.0.0")]
    public class RustPropertyConsumerBase
    {
        #region Fields
        private global::System.Text.StringBuilder generationEnvironmentField;
        private global::System.CodeDom.Compiler.CompilerErrorCollection errorsField;
        private global::System.Collections.Generic.List<int> indentLengthsField;
        private string currentIndentField = "";
        private bool endsWithNewline;
        private global::System.Collections.Generic.IDictionary<string, object> sessionField;
        #endregion
        #region Properties
        /// <summary>
        /// The string builder that generation-time code is using to assemble generated output
        /// </summary>
        public System.Text.StringBuilder GenerationEnvironment
        {
            get
            {
                if ((this.generationEnvironmentField == null))
                {
                    this.generationEnvironmentField = new global::System.Text.StringBuilder();
                }
                return this.generationEnvironmentField;
            }
            set
            {
                this.generationEnvironmentField = value;
            }
        }
        /// <summary>
        /// The error collection for the generation process
        /// </summary>
        public System.CodeDom.Compiler.CompilerErrorCollection Errors
        {
            get
            {
                if ((this.errorsField == null))
                {
                    this.errorsField = new global::System.CodeDom.Compiler.CompilerErrorCollection();
                }
                return this.errorsField;
            }
        }
        /// <summary>
        /// A list of the lengths of each indent that was added with PushIndent
        /// </summary>
        private System.Collections.Generic.List<int> indentLengths
        {
            get
            {
                if ((this.indentLengthsField == null))
                {
                    this.indentLengthsField = new global::System.Collections.Generic.List<int>();
                }
                return this.indentLengthsField;
            }
        }
        /// <summary>
        /// Gets the current indent we use when adding lines to the output
        /// </summary>
        public string CurrentIndent
        {
            get
            {
                return this.currentIndentField;
            }
        }
        /// <summary>
        /// Current transformation session
        /// </summary>
        public virtual global::System.Collections.Generic.IDictionary<string, object> Session
        {
            get
            {
                return this.sessionField;
            }
            set
            {
                this.sessionField = value;
            }
        }
        #endregion
        #region Transform-time helpers
        /// <summary>
        /// Write text directly into the generated output
        /// </summary>
        public void Write(string textToAppend)
        {
            if (string.IsNullOrEmpty(textToAppend))
            {
                return;
            }
            // If we're starting off, or if the previous text ended with a newline,
            // we have to append the current indent first.
            if (((this.GenerationEnvironment.Length == 0) 
                        || this.endsWithNewline))
            {
                this.GenerationEnvironment.Append(this.currentIndentField);
                this.endsWithNewline = false;
            }
            // Check if the current text ends with a newline
            if (textToAppend.EndsWith(global::System.Environment.NewLine, global::System.StringComparison.CurrentCulture))
            {
                this.endsWithNewline = true;
            }
            // This is an optimization. If the current indent is "", then we don't have to do any
            // of the more complex stuff further down.
            if ((this.currentIndentField.Length == 0))
            {
                this.GenerationEnvironment.Append(textToAppend);
                return;
            }
            // Everywhere there is a newline in the text, add an indent after it
            textToAppend = textToAppend.Replace(global::System.Environment.NewLine, (global::System.Environment.NewLine + this.currentIndentField));
            // If the text ends with a newline, then we should strip off the indent added at the very end
            // because the appropriate indent will be added when the next time Write() is called
            if (this.endsWithNewline)
            {
                this.GenerationEnvironment.Append(textToAppend, 0, (textToAppend.Length - this.currentIndentField.Length));
            }
            else
            {
                this.GenerationEnvironment.Append(textToAppend);
            }
        }
        /// <summary>
        /// Write text directly into the generated output
        /// </summary>
        public void WriteLine(string textToAppend)
        {
            this.Write(textToAppend);
            this.GenerationEnvironment.AppendLine();
            this.endsWithNewline = true;
        }
        /// <summary>
        /// Write formatted text directly into the generated output
        /// </summary>
        public void Write(string format, params object[] args)
        {
            this.Write(string.Format(global::System.Globalization.CultureInfo.CurrentCulture, format, args));
        }
        /// <summary>
        /// Write formatted text directly into the generated output
        /// </summary>
        public void WriteLine(string format, params object[] args)
        {
            this.WriteLine(string.Format(global::System.Globalization.CultureInfo.CurrentCulture, format, args));
        }
        /// <summary>
        /// Raise an error
        /// </summary>
        public void Error(string message)
        {
            System.CodeDom.Compiler.CompilerError error = new global::System.CodeDom.Compiler.CompilerError();
            error.ErrorText = message;
            this.Errors.Add(error);
        }
        /// <summary>
        /// Raise a warning
        /// </summary>
        public void Warning(string message)
        {
            System.CodeDom.Compiler.CompilerError error = new global::System.CodeDom.Compiler.CompilerError();
            error.ErrorText = message;
            error.IsWarning = true;
            this.Errors.Add(error);
        }
        /// <summary>
        /// Increase the indent
        /// </summary>
        public void PushIndent(string indent)
        {
            if ((indent == null))
            {
                throw new global::System.ArgumentNullException("indent");
            }
            this.currentIndentField = (this.currentIndentField + indent);
            this.indentLengths.Add(indent.Length);
        }
        /// <summary>
        /// Remove the last indent that was added with PushIndent
        /// </summary>
        public string PopIndent()
        {
            string returnValue = "";
            if ((this.indentLengths.Count > 0))
            {
                int indentLength = this.indentLengths[(this.indentLengths.Count - 1)];
                this.indentLengths.RemoveAt((this.indentLengths.Count - 1));
                if ((indentLength > 0))
                {
                    returnValue = this.currentIndentField.Substring((this.currentIndentField.Length - indentLength));
                    this.currentIndentField = this.currentIndentField.Remove((this.currentIndentField.Length - indentLength));
                }
            }
            return returnValue;
        }
        /// <summary>
        /// Remove any indentation
        /// </summary>
        public void ClearIndent()
        {
            this.indentLengths.Clear();
            this.currentIndentField = "";
        }
        #endregion
        #region ToString Helpers
        /// <summary>
        /// Utility class to produce culture-oriented representation of an object as a string.
        /// </summary>
        public class ToStringInstanceHelper
        {
            private System.IFormatProvider formatProviderField  = global::System.Globalization.CultureInfo.InvariantCulture;
            /// <summary>
            /// Gets or sets format provider to be used by ToStringWithCulture method.
            /// </summary>
            public System.IFormatProvider FormatProvider
            {
                get
                {
                    return this.formatProviderField ;
                }
                set
                {
                    if ((value != null))
                    {
                        this.formatProviderField  = value;
                    }
                }
            }
            /// <summary>
            /// This is called from the compile/run appdomain to convert objects within an expression block to a string
            /// </summary>
            public string ToStringWithCulture(object objectToConvert)
            {
                if ((objectToConvert == null))
                {
                    throw new global::System.ArgumentNullException("objectToConvert");
                }
                System.Type t = objectToConvert.GetType();
                System.Reflection.MethodInfo method = t.GetMethod("ToString", new System.Type[] {
                            typeof(System.IFormatProvider)});
                if ((method == null))
                {
                    return objectToConvert.ToString();
                }
                else
                {
                    return ((string)(method.Invoke(objectToConvert, new object[] {
                                this.formatProviderField })));
                }
            }
        }
        private ToStringInstanceHelper toStringHelperField = new ToStringInstanceHelper();
        /// <summary>
        /// Helper to produce culture-oriented representation of an object as a string
        /// </summary>
        public ToStringInstanceHelper ToStringHelper
        {
            get
            {
                return this.toStringHelperField;
            }
        }
        #endregion
    }
    #endregion
}
