aws

# WARNING: DO NOT EDIT, AUTO-GENERATED CODE!
# See https://github.com/aws-beam/aws-codegen for more details.

defmodule AWS.IoTDataPlane do
  @moduledoc """
  IoT data

  IoT data enables secure, bi-directional communication between Internet-connected
  things (such as sensors,
  actuators, embedded devices, or smart appliances) and the Amazon Web Services
  cloud.

  It implements a broker for applications and
  things to publish messages over HTTP (Publish) and retrieve, update, and delete
  shadows. A shadow is a
  persistent representation of your things and their state in the Amazon Web
  Services cloud.

  Find the endpoint address for actions in IoT data by running this CLI command:

  `aws iot describe-endpoint --endpoint-type iot:Data-ATS`

  The service name used by [Amazon Web ServicesSignature Version 4](https://docs.aws.amazon.com/general/latest/gr/signature-version-4.html)
  to sign requests is: *iotdevicegateway*.
  """

  alias AWS.Client
  alias AWS.Request

  @typedoc """

  ## Example:

      method_not_allowed_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type method_not_allowed_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      list_subscriptions_request() :: %{
        optional("maxResults") => integer(),
        optional("nextToken") => String.t() | atom()
      }

  """
  @type list_subscriptions_request() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      request_entity_too_large_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type request_entity_too_large_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      send_direct_message_response() :: %{
        "message" => String.t() | atom(),
        "traceId" => String.t() | atom()
      }

  """
  @type send_direct_message_response() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      service_unavailable_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type service_unavailable_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      throttling_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type throttling_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      subscription_summary() :: %{
        "qos" => integer(),
        "topicFilter" => String.t() | atom()
      }

  """
  @type subscription_summary() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      list_retained_messages_request() :: %{
        optional("maxResults") => integer(),
        optional("nextToken") => String.t() | atom()
      }

  """
  @type list_retained_messages_request() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      delete_thing_shadow_response() :: %{
        "payload" => binary()
      }

  """
  @type delete_thing_shadow_response() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      list_named_shadows_for_thing_response() :: %{
        "nextToken" => String.t() | atom(),
        "results" => list(String.t() | atom()),
        "timestamp" => float()
      }

  """
  @type list_named_shadows_for_thing_response() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      internal_failure_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type internal_failure_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      get_retained_message_response() :: %{
        "lastModifiedTime" => float(),
        "payload" => binary(),
        "qos" => integer(),
        "topic" => String.t() | atom(),
        "userProperties" => binary()
      }

  """
  @type get_retained_message_response() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      retained_message_summary() :: %{
        "lastModifiedTime" => float(),
        "payloadSize" => float(),
        "qos" => integer(),
        "topic" => String.t() | atom()
      }

  """
  @type retained_message_summary() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      unauthorized_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type unauthorized_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      list_named_shadows_for_thing_request() :: %{
        optional("nextToken") => String.t() | atom(),
        optional("pageSize") => integer()
      }

  """
  @type list_named_shadows_for_thing_request() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      gateway_timeout_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type gateway_timeout_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      resource_not_found_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type resource_not_found_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      get_retained_message_request() :: %{}

  """
  @type get_retained_message_request() :: %{}

  @typedoc """

  ## Example:

      conflict_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type conflict_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      delete_thing_shadow_request() :: %{
        optional("shadowName") => String.t() | atom()
      }

  """
  @type delete_thing_shadow_request() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      get_thing_shadow_request() :: %{
        optional("shadowName") => String.t() | atom()
      }

  """
  @type get_thing_shadow_request() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      unsupported_document_encoding_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type unsupported_document_encoding_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      delete_connection_request() :: %{
        optional("cleanSession") => boolean(),
        optional("preventWillMessage") => boolean()
      }

  """
  @type delete_connection_request() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      update_thing_shadow_response() :: %{
        "payload" => binary()
      }

  """
  @type update_thing_shadow_response() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      list_subscriptions_response() :: %{
        "nextToken" => String.t() | atom(),
        "subscriptions" => list(subscription_summary())
      }

  """
  @type list_subscriptions_response() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      send_direct_message_request() :: %{
        optional("confirmation") => boolean(),
        optional("contentType") => String.t() | atom(),
        optional("correlationData") => String.t() | atom(),
        optional("payload") => binary(),
        optional("payloadFormatIndicator") => list(any()),
        optional("responseTopic") => String.t() | atom(),
        optional("timeout") => integer(),
        optional("userProperties") => String.t() | atom(),
        required("topic") => String.t() | atom()
      }

  """
  @type send_direct_message_request() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      forbidden_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type forbidden_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      invalid_request_exception() :: %{
        "message" => String.t() | atom()
      }

  """
  @type invalid_request_exception() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      get_connection_request() :: %{
        optional("includeSocketInformation") => boolean()
      }

  """
  @type get_connection_request() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      update_thing_shadow_request() :: %{
        optional("shadowName") => String.t() | atom(),
        required("payload") => binary()
      }

  """
  @type update_thing_shadow_request() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      get_connection_response() :: %{
        "cleanSession" => boolean(),
        "clientId" => String.t() | atom(),
        "connected" => boolean(),
        "connectedSince" => float(),
        "disconnectReason" => String.t() | atom(),
        "disconnectedSince" => float(),
        "keepAliveDuration" => integer(),
        "sessionExpiry" => float(),
        "sourceIp" => String.t() | atom(),
        "sourcePort" => integer(),
        "targetIp" => String.t() | atom(),
        "targetPort" => integer(),
        "thingName" => String.t() | atom(),
        "vpcEndpointId" => String.t() | atom()
      }

  """
  @type get_connection_response() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      list_retained_messages_response() :: %{
        "nextToken" => String.t() | atom(),
        "retainedTopics" => list(retained_message_summary())
      }

  """
  @type list_retained_messages_response() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      publish_request() :: %{
        optional("contentType") => String.t() | atom(),
        optional("correlationData") => String.t() | atom(),
        optional("messageExpiry") => float(),
        optional("payload") => binary(),
        optional("payloadFormatIndicator") => list(any()),
        optional("qos") => integer(),
        optional("responseTopic") => String.t() | atom(),
        optional("retain") => boolean(),
        optional("userProperties") => String.t() | atom()
      }

  """
  @type publish_request() :: %{(String.t() | atom()) => any()}

  @typedoc """

  ## Example:

      get_thing_shadow_response() :: %{
        "payload" => binary()
      }

  """
  @type get_thing_shadow_response() :: %{(String.t() | atom()) => any()}

  @type delete_connection_errors() ::
          invalid_request_exception()
          | forbidden_exception()
          | resource_not_found_exception()
          | internal_failure_exception()
          | throttling_exception()

  @type delete_thing_shadow_errors() ::
          invalid_request_exception()
          | unsupported_document_encoding_exception()
          | resource_not_found_exception()
          | unauthorized_exception()
          | internal_failure_exception()
          | throttling_exception()
          | service_unavailable_exception()
          | method_not_allowed_exception()

  @type get_connection_errors() ::
          invalid_request_exception()
          | forbidden_exception()
          | resource_not_found_exception()
          | internal_failure_exception()
          | throttling_exception()

  @type get_retained_message_errors() ::
          invalid_request_exception()
          | resource_not_found_exception()
          | unauthorized_exception()
          | internal_failure_exception()
          | throttling_exception()
          | service_unavailable_exception()
          | method_not_allowed_exception()

  @type get_thing_shadow_errors() ::
          invalid_request_exception()
          | unsupported_document_encoding_exception()
          | resource_not_found_exception()
          | unauthorized_exception()
          | internal_failure_exception()
          | throttling_exception()
          | service_unavailable_exception()
          | method_not_allowed_exception()

  @type list_named_shadows_for_thing_errors() ::
          invalid_request_exception()
          | resource_not_found_exception()
          | unauthorized_exception()
          | internal_failure_exception()
          | throttling_exception()
          | service_unavailable_exception()
          | method_not_allowed_exception()

  @type list_retained_messages_errors() ::
          invalid_request_exception()
          | unauthorized_exception()
          | internal_failure_exception()
          | throttling_exception()
          | service_unavailable_exception()
          | method_not_allowed_exception()

  @type list_subscriptions_errors() ::
          invalid_request_exception()
          | forbidden_exception()
          | resource_not_found_exception()
          | internal_failure_exception()
          | throttling_exception()

  @type publish_errors() ::
          invalid_request_exception()
          | unauthorized_exception()
          | internal_failure_exception()
          | throttling_exception()
          | method_not_allowed_exception()

  @type send_direct_message_errors() ::
          invalid_request_exception()
          | forbidden_exception()
          | resource_not_found_exception()
          | gateway_timeout_exception()
          | unauthorized_exception()
          | internal_failure_exception()
          | throttling_exception()
          | request_entity_too_large_exception()

  @type update_thing_shadow_errors() ::
          invalid_request_exception()
          | unsupported_document_encoding_exception()
          | conflict_exception()
          | unauthorized_exception()
          | internal_failure_exception()
          | throttling_exception()
          | service_unavailable_exception()
          | request_entity_too_large_exception()
          | method_not_allowed_exception()

  def metadata do
    %{
      api_version: "2015-05-28",
      content_type: "application/x-amz-json-1.1",
      credential_scope: nil,
      endpoint_prefix: "data-ats.iot",
      global?: false,
      hostname: nil,
      protocol: "rest-json",
      service_id: "IoT Data Plane",
      signature_version: "v4",
      signing_name: "iotdata",
      target_prefix: nil
    }
  end

  @doc """
  Disconnects a connected MQTT client from Amazon Web Services IoT Core.

  When you disconnect a client, Amazon Web Services IoT Core closes the client's
  network connection and optionally cleans the session state.

  Requires permission to access the
  [DeleteConnection](https://docs.aws.amazon.com/service-authorization/latest/reference/list_awsiot.html#awsiot-actions-as-permissions)
  action.
  """
  @spec delete_connection(map(), String.t() | atom(), delete_connection_request(), list()) ::
          {:ok, nil, any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, delete_connection_errors()}
  def delete_connection(%Client{} = client, client_id, input, options \\ []) do
    url_path = "/connections/#{AWS.Util.encode_uri(client_id)}"
    headers = []
    custom_headers = []

    {query_params, input} =
      [
        {"cleanSession", "cleanSession"},
        {"preventWillMessage", "preventWillMessage"}
      ]
      |> Request.build_params(input)

    meta = metadata()

    Request.request_rest(
      client,
      meta,
      :delete,
      url_path,
      query_params,
      custom_headers ++ headers,
      input,
      options,
      200
    )
  end

  @doc """
  Deletes the shadow for the specified thing.

  Requires permission to access the
  [DeleteThingShadow](https://docs.aws.amazon.com/service-authorization/latest/reference/list_awsiot.html#awsiot-actions-as-permissions) action.

  For more information, see
  [DeleteThingShadow](http://docs.aws.amazon.com/iot/latest/developerguide/API_DeleteThingShadow.html)
  in the IoT Developer Guide.
  """
  @spec delete_thing_shadow(map(), String.t() | atom(), delete_thing_shadow_request(), list()) ::
          {:ok, delete_thing_shadow_response(), any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, delete_thing_shadow_errors()}
  def delete_thing_shadow(%Client{} = client, thing_name, input, options \\ []) do
    url_path = "/things/#{AWS.Util.encode_uri(thing_name)}/shadow"
    headers = []
    custom_headers = []

    {query_params, input} =
      [
        {"shadowName", "name"}
      ]
      |> Request.build_params(input)

    meta = metadata()

    Request.request_rest(
      client,
      meta,
      :delete,
      url_path,
      query_params,
      custom_headers ++ headers,
      input,
      options,
      200
    )
  end

  @doc """
  Retrieves connection information for the specified MQTT client.

  Requires permission to access the
  [GetConnection](https://docs.aws.amazon.com/service-authorization/latest/reference/list_awsiot.html#awsiot-actions-as-permissions)
  action.
  """
  @spec get_connection(map(), String.t() | atom(), String.t() | atom() | nil, list()) ::
          {:ok, get_connection_response(), any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, get_connection_errors()}
  def get_connection(
        %Client{} = client,
        client_id,
        include_socket_information \\ nil,
        options \\ []
      ) do
    url_path = "/connections/#{AWS.Util.encode_uri(client_id)}"
    headers = []
    query_params = []

    query_params =
      if !is_nil(include_socket_information) do
        [{"includeSocketInformation", include_socket_information} | query_params]
      else
        query_params
      end

    meta = metadata()

    Request.request_rest(client, meta, :get, url_path, query_params, headers, nil, options, 200)
  end

  @doc """
  Gets the details of a single retained message for the specified topic.

  This action returns the message payload of the retained message, which can
  incur messaging costs. To list only the topic names of the retained messages,
  call
  [ListRetainedMessages](https://docs.aws.amazon.com/iot/latest/apireference/API_iotdata_ListRetainedMessages.html). 
  Requires permission to access the
  [GetRetainedMessage](https://docs.aws.amazon.com/service-authorization/latest/reference/list_awsiot.html)
  action.

  For more information about messaging costs, see [Amazon Web Services IoT Core pricing - Messaging](http://aws.amazon.com/iot-core/pricing/#Messaging).
  """
  @spec get_retained_message(map(), String.t() | atom(), list()) ::
          {:ok, get_retained_message_response(), any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, get_retained_message_errors()}
  def get_retained_message(%Client{} = client, topic, options \\ []) do
    url_path = "/retainedMessage/#{AWS.Util.encode_uri(topic)}"
    headers = []
    query_params = []

    meta = metadata()

    Request.request_rest(client, meta, :get, url_path, query_params, headers, nil, options, 200)
  end

  @doc """
  Gets the shadow for the specified thing.

  Requires permission to access the
  [GetThingShadow](https://docs.aws.amazon.com/service-authorization/latest/reference/list_awsiot.html#awsiot-actions-as-permissions) action.

  For more information, see
  [GetThingShadow](http://docs.aws.amazon.com/iot/latest/developerguide/API_GetThingShadow.html)
  in the
  IoT Developer Guide.
  """
  @spec get_thing_shadow(map(), String.t() | atom(), String.t() | atom() | nil, list()) ::
          {:ok, get_thing_shadow_response(), any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, get_thing_shadow_errors()}
  def get_thing_shadow(%Client{} = client, thing_name, shadow_name \\ nil, options \\ []) do
    url_path = "/things/#{AWS.Util.encode_uri(thing_name)}/shadow"
    headers = []
    query_params = []

    query_params =
      if !is_nil(shadow_name) do
        [{"name", shadow_name} | query_params]
      else
        query_params
      end

    meta = metadata()

    Request.request_rest(client, meta, :get, url_path, query_params, headers, nil, options, 200)
  end

  @doc """
  Lists the shadows for the specified thing.

  Requires permission to access the
  [ListNamedShadowsForThing](https://docs.aws.amazon.com/service-authorization/latest/reference/list_awsiot.html#awsiot-actions-as-permissions)
  action.
  """
  @spec list_named_shadows_for_thing(
          map(),
          String.t() | atom(),
          String.t() | atom() | nil,
          String.t() | atom() | nil,
          list()
        ) ::
          {:ok, list_named_shadows_for_thing_response(), any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, list_named_shadows_for_thing_errors()}
  def list_named_shadows_for_thing(
        %Client{} = client,
        thing_name,
        next_token \\ nil,
        page_size \\ nil,
        options \\ []
      ) do
    url_path = "/api/things/shadow/ListNamedShadowsForThing/#{AWS.Util.encode_uri(thing_name)}"
    headers = []
    query_params = []

    query_params =
      if !is_nil(page_size) do
        [{"pageSize", page_size} | query_params]
      else
        query_params
      end

    query_params =
      if !is_nil(next_token) do
        [{"nextToken", next_token} | query_params]
      else
        query_params
      end

    meta = metadata()

    Request.request_rest(client, meta, :get, url_path, query_params, headers, nil, options, 200)
  end

  @doc """
  Lists summary information about the retained messages stored for the account.

  This action returns only the topic names of the retained messages. It doesn't
  return any message payloads. Although this action doesn't return a message
  payload,
  it can still incur messaging costs.

  To get the message payload of a retained message, call
  [GetRetainedMessage](https://docs.aws.amazon.com/iot/latest/apireference/API_iotdata_GetRetainedMessage.html)  with the topic name of the retained message.

  Requires permission to access the
  [ListRetainedMessages](https://docs.aws.amazon.com/service-authorization/latest/reference/list_awsiot.html)
  action.

  For more information about messaging costs, see [Amazon Web Services IoT Core pricing - Messaging](http://aws.amazon.com/iot-core/pricing/#Messaging).
  """
  @spec list_retained_messages(
          map(),
          String.t() | atom() | nil,
          String.t() | atom() | nil,
          list()
        ) ::
          {:ok, list_retained_messages_response(), any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, list_retained_messages_errors()}
  def list_retained_messages(
        %Client{} = client,
        max_results \\ nil,
        next_token \\ nil,
        options \\ []
      ) do
    url_path = "/retainedMessage"
    headers = []
    query_params = []

    query_params =
      if !is_nil(next_token) do
        [{"nextToken", next_token} | query_params]
      else
        query_params
      end

    query_params =
      if !is_nil(max_results) do
        [{"maxResults", max_results} | query_params]
      else
        query_params
      end

    meta = metadata()

    Request.request_rest(client, meta, :get, url_path, query_params, headers, nil, options, 200)
  end

  @doc """
  Returns a list of all subscriptions for MQTT clients with active sessions,
  including offline clients with persistent sessions.

  Requires permission to access the
  [ListSubscriptions](https://docs.aws.amazon.com/service-authorization/latest/reference/list_awsiot.html#awsiot-actions-as-permissions)
  action.
  """
  @spec list_subscriptions(
          map(),
          String.t() | atom(),
          String.t() | atom() | nil,
          String.t() | atom() | nil,
          list()
        ) ::
          {:ok, list_subscriptions_response(), any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, list_subscriptions_errors()}
  def list_subscriptions(
        %Client{} = client,
        client_id,
        max_results \\ nil,
        next_token \\ nil,
        options \\ []
      ) do
    url_path = "/connections/#{AWS.Util.encode_uri(client_id)}/subscriptions"
    headers = []
    query_params = []

    query_params =
      if !is_nil(next_token) do
        [{"nextToken", next_token} | query_params]
      else
        query_params
      end

    query_params =
      if !is_nil(max_results) do
        [{"maxResults", max_results} | query_params]
      else
        query_params
      end

    meta = metadata()

    Request.request_rest(client, meta, :get, url_path, query_params, headers, nil, options, 200)
  end

  @doc """
  Publishes an MQTT message.

  Requires permission to access the
  [Publish](https://docs.aws.amazon.com/service-authorization/latest/reference/list_awsiot.html#awsiot-actions-as-permissions) action.

  For more information about MQTT messages, see
  [MQTT Protocol](http://docs.aws.amazon.com/iot/latest/developerguide/mqtt.html)
  in the
  IoT Developer Guide.

  For more information about messaging costs, see [Amazon Web Services IoT Core pricing - Messaging](http://aws.amazon.com/iot-core/pricing/#Messaging).
  """
  @spec publish(map(), String.t() | atom(), publish_request(), list()) ::
          {:ok, nil, any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, publish_errors()}
  def publish(%Client{} = client, topic, input, options \\ []) do
    url_path = "/topics/#{AWS.Util.encode_uri(topic)}"

    {headers, input} =
      [
        {"correlationData", "x-amz-mqtt5-correlation-data"},
        {"payloadFormatIndicator", "x-amz-mqtt5-payload-format-indicator"},
        {"userProperties", "x-amz-mqtt5-user-properties"}
      ]
      |> Request.build_params(input)

    custom_headers = []

    {query_params, input} =
      [
        {"contentType", "contentType"},
        {"messageExpiry", "messageExpiry"},
        {"qos", "qos"},
        {"responseTopic", "responseTopic"},
        {"retain", "retain"}
      ]
      |> Request.build_params(input)

    meta = metadata()

    Request.request_rest(
      client,
      meta,
      :post,
      url_path,
      query_params,
      custom_headers ++ headers,
      input,
      options,
      200
    )
  end

  @doc """
  Sends an MQTT message directly to a specific client identified by its client ID.

  `SendDirectMessage` targets a single client ID. The receiving client does not
  need to subscribe to the topic, but the receiver's policy must allow
  `iot:Receive` on the specified topic.

  Requires permission to access the
  [SendDirectMessage](https://docs.aws.amazon.com/service-authorization/latest/reference/list_awsiot.html#awsiot-actions-as-permissions) action.

  For more information about messaging costs, see [Amazon Web Services IoT Core
  pricing](http://aws.amazon.com/iot-core/pricing/).
  """
  @spec send_direct_message(map(), String.t() | atom(), send_direct_message_request(), list()) ::
          {:ok, send_direct_message_response(), any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, send_direct_message_errors()}
  def send_direct_message(%Client{} = client, client_id, input, options \\ []) do
    url_path = "/connections/#{AWS.Util.encode_uri(client_id)}/messages"

    {headers, input} =
      [
        {"correlationData", "x-amz-mqtt5-correlation-data"},
        {"payloadFormatIndicator", "x-amz-mqtt5-payload-format-indicator"},
        {"userProperties", "x-amz-mqtt5-user-properties"}
      ]
      |> Request.build_params(input)

    custom_headers = []

    {query_params, input} =
      [
        {"confirmation", "confirmation"},
        {"contentType", "contentType"},
        {"responseTopic", "responseTopic"},
        {"timeout", "timeout"},
        {"topic", "topic"}
      ]
      |> Request.build_params(input)

    meta = metadata()

    Request.request_rest(
      client,
      meta,
      :post,
      url_path,
      query_params,
      custom_headers ++ headers,
      input,
      options,
      200
    )
  end

  @doc """
  Updates the shadow for the specified thing.

  Requires permission to access the
  [UpdateThingShadow](https://docs.aws.amazon.com/service-authorization/latest/reference/list_awsiot.html#awsiot-actions-as-permissions) action.

  For more information, see
  [UpdateThingShadow](http://docs.aws.amazon.com/iot/latest/developerguide/API_UpdateThingShadow.html)
  in the
  IoT Developer Guide.
  """
  @spec update_thing_shadow(map(), String.t() | atom(), update_thing_shadow_request(), list()) ::
          {:ok, update_thing_shadow_response(), any()}
          | {:error, {:unexpected_response, any()}}
          | {:error, term()}
          | {:error, update_thing_shadow_errors()}
  def update_thing_shadow(%Client{} = client, thing_name, input, options \\ []) do
    url_path = "/things/#{AWS.Util.encode_uri(thing_name)}/shadow"
    headers = []
    custom_headers = []

    {query_params, input} =
      [
        {"shadowName", "name"}
      ]
      |> Request.build_params(input)

    meta = metadata()

    Request.request_rest(
      client,
      meta,
      :post,
      url_path,
      query_params,
      custom_headers ++ headers,
      input,
      options,
      200
    )
  end
end