:tocdepth: 3 base/protocols/mqtt/main.zeek ============================= .. zeek:namespace:: MQTT Implements base functionality for MQTT (v3.1.1) analysis. Generates the mqtt.log file. :Namespace: MQTT :Imports: :doc:`base/protocols/mqtt/consts.zeek ` Summary ~~~~~~~ Types ##### ================================================================== ====================================================================== :zeek:type:`MQTT::ConnectInfo`: :zeek:type:`record` :zeek:type:`MQTT::PublishInfo`: :zeek:type:`record` :zeek:type:`MQTT::State`: :zeek:type:`record` Data structure to track pub/sub messaging state of a given connection. :zeek:type:`MQTT::SubUnsub`: :zeek:type:`enum` :zeek:attr:`&redef` :zeek:type:`MQTT::SubscribeInfo`: :zeek:type:`record` ================================================================== ====================================================================== Redefinitions ############# ==================================================================== ============================================================= :zeek:type:`Log::ID`: :zeek:type:`enum` * :zeek:enum:`MQTT::CONNECT_LOG` * :zeek:enum:`MQTT::PUBLISH_LOG` * :zeek:enum:`MQTT::SUBSCRIBE_LOG` :zeek:type:`connection`: :zeek:type:`record` :New Fields: :zeek:type:`connection` mqtt: :zeek:type:`MQTT::ConnectInfo` :zeek:attr:`&optional` mqtt_state: :zeek:type:`MQTT::State` :zeek:attr:`&optional` :zeek:id:`likely_server_ports`: :zeek:type:`set` :zeek:attr:`&redef` ==================================================================== ============================================================= Events ###### ============================================= ==================================================================== :zeek:id:`MQTT::log_mqtt`: :zeek:type:`event` Event that can be handled to access the MQTT record as it is sent on to the logging framework. ============================================= ==================================================================== Hooks ##### =================================================================== = :zeek:id:`MQTT::log_policy_connect`: :zeek:type:`Log::PolicyHook` :zeek:id:`MQTT::log_policy_publish`: :zeek:type:`Log::PolicyHook` :zeek:id:`MQTT::log_policy_subscribe`: :zeek:type:`Log::PolicyHook` =================================================================== = Functions ######### ======================================================== ========================================================================== :zeek:id:`MQTT::publish_expire`: :zeek:type:`function` The expiration function for published messages that haven't been logged yet simply causes the message to be logged. :zeek:id:`MQTT::subscribe_expire`: :zeek:type:`function` The expiration function for subscription messages that haven't been logged yet simply causes the message to be logged. ======================================================== ========================================================================== Detailed Interface ~~~~~~~~~~~~~~~~~~ Types ##### .. zeek:type:: MQTT::ConnectInfo :source-code: base/protocols/mqtt/main.zeek 24 45 :Type: :zeek:type:`record` ts: :zeek:type:`time` :zeek:attr:`&log` Timestamp for when the event happened uid: :zeek:type:`string` :zeek:attr:`&log` Unique ID for the connection id: :zeek:type:`conn_id` :zeek:attr:`&log` The connection's 4-tuple of endpoint addresses/ports proto_name: :zeek:type:`string` :zeek:attr:`&log` :zeek:attr:`&optional` Indicates the protocol name proto_version: :zeek:type:`string` :zeek:attr:`&log` :zeek:attr:`&optional` The version of the protocol in use client_id: :zeek:type:`string` :zeek:attr:`&log` :zeek:attr:`&optional` Unique identifier for the client connect_status: :zeek:type:`string` :zeek:attr:`&log` :zeek:attr:`&optional` Status message from the server in response to the connect request will_topic: :zeek:type:`string` :zeek:attr:`&log` :zeek:attr:`&optional` Topic to publish a "last will and testament" message to will_payload: :zeek:type:`string` :zeek:attr:`&log` :zeek:attr:`&optional` Payload to publish as a "last will and testament" .. zeek:type:: MQTT::PublishInfo :source-code: base/protocols/mqtt/main.zeek 67 107 :Type: :zeek:type:`record` ts: :zeek:type:`time` :zeek:attr:`&log` Timestamp for when the publish message started uid: :zeek:type:`string` :zeek:attr:`&log` UID for the connection id: :zeek:type:`conn_id` :zeek:attr:`&log` ID fields for the connection from_client: :zeek:type:`bool` :zeek:attr:`&log` Indicates if the message was published by the client of this connection or published to the client. retain: :zeek:type:`bool` :zeek:attr:`&log` Indicates if the message was to be retained by the server qos: :zeek:type:`string` :zeek:attr:`&log` QoS level set for the message status: :zeek:type:`string` :zeek:attr:`&log` :zeek:attr:`&default` = ``"incomplete_qos"`` :zeek:attr:`&optional` Status of the published message. This will be set to "incomplete_qos" if the full back and forth for the requested level of QoS was not seen. Otherwise if it's successful the field will be "ok". topic: :zeek:type:`string` :zeek:attr:`&log` Topic the message was published to payload: :zeek:type:`string` :zeek:attr:`&log` Payload of the message payload_len: :zeek:type:`count` :zeek:attr:`&log` The actual length of the payload in the case the *payload* field's contents were truncated according to :zeek:see:`MQTT::max_payload_size`. ack: :zeek:type:`bool` :zeek:attr:`&default` = ``F`` :zeek:attr:`&optional` Track if the message was acked rec: :zeek:type:`bool` :zeek:attr:`&default` = ``F`` :zeek:attr:`&optional` Indicates if the server sent the RECEIVED qos message rel: :zeek:type:`bool` :zeek:attr:`&default` = ``F`` :zeek:attr:`&optional` Indicates if the client sent the RELEASE qos message comp: :zeek:type:`bool` :zeek:attr:`&default` = ``F`` :zeek:attr:`&optional` Indicates if the server sent the COMPLETE qos message qos_level: :zeek:type:`count` :zeek:attr:`&default` = ``0`` :zeek:attr:`&optional` Internally used for comparing numeric qos level .. zeek:type:: MQTT::State :source-code: base/protocols/mqtt/main.zeek 122 128 :Type: :zeek:type:`record` publish: :zeek:type:`table` [:zeek:type:`count`] of :zeek:type:`MQTT::PublishInfo` :zeek:attr:`&optional` :zeek:attr:`&write_expire` = ``5.0 secs`` :zeek:attr:`&expire_func` = :zeek:see:`MQTT::publish_expire` Published messages that haven't been logged yet. subscribe: :zeek:type:`table` [:zeek:type:`count`] of :zeek:type:`MQTT::SubscribeInfo` :zeek:attr:`&optional` :zeek:attr:`&write_expire` = ``5.0 secs`` :zeek:attr:`&expire_func` = :zeek:see:`MQTT::subscribe_expire` Subscription/unsubscription messages that haven't been ACK'd or logged yet. Data structure to track pub/sub messaging state of a given connection. .. zeek:type:: MQTT::SubUnsub :source-code: base/protocols/mqtt/main.zeek 19 23 :Type: :zeek:type:`enum` .. zeek:enum:: MQTT::SUBSCRIBE MQTT::SubUnsub .. zeek:enum:: MQTT::UNSUBSCRIBE MQTT::SubUnsub :Attributes: :zeek:attr:`&redef` .. zeek:type:: MQTT::SubscribeInfo :source-code: base/protocols/mqtt/main.zeek 47 65 :Type: :zeek:type:`record` ts: :zeek:type:`time` :zeek:attr:`&log` Timestamp for when the subscribe or unsubscribe request started uid: :zeek:type:`string` :zeek:attr:`&log` UID for the connection id: :zeek:type:`conn_id` :zeek:attr:`&log` ID fields for the connection action: :zeek:type:`MQTT::SubUnsub` :zeek:attr:`&log` Indicates if a subscribe or unsubscribe action is taking place topics: :zeek:type:`string_vec` :zeek:attr:`&log` The topics (or topic patterns) being subscribed to qos_levels: :zeek:type:`index_vec` :zeek:attr:`&log` :zeek:attr:`&optional` QoS levels requested for messages from subscribed topics granted_qos_level: :zeek:type:`count` :zeek:attr:`&log` :zeek:attr:`&optional` QoS level the server granted ack: :zeek:type:`bool` :zeek:attr:`&log` :zeek:attr:`&default` = ``F`` :zeek:attr:`&optional` Indicates if the request was acked by the server Events ###### .. zeek:id:: MQTT::log_mqtt :source-code: base/protocols/mqtt/main.zeek 111 111 :Type: :zeek:type:`event` (rec: :zeek:type:`MQTT::ConnectInfo`) Event that can be handled to access the MQTT record as it is sent on to the logging framework. Hooks ##### .. zeek:id:: MQTT::log_policy_connect :source-code: base/protocols/mqtt/main.zeek 15 15 :Type: :zeek:type:`Log::PolicyHook` .. zeek:id:: MQTT::log_policy_publish :source-code: base/protocols/mqtt/main.zeek 17 17 :Type: :zeek:type:`Log::PolicyHook` .. zeek:id:: MQTT::log_policy_subscribe :source-code: base/protocols/mqtt/main.zeek 16 16 :Type: :zeek:type:`Log::PolicyHook` Functions ######### .. zeek:id:: MQTT::publish_expire :source-code: base/protocols/mqtt/main.zeek 131 135 :Type: :zeek:type:`function` (tbl: :zeek:type:`table` [:zeek:type:`count`] of :zeek:type:`MQTT::PublishInfo`, idx: :zeek:type:`count`) : :zeek:type:`interval` The expiration function for published messages that haven't been logged yet simply causes the message to be logged. .. zeek:id:: MQTT::subscribe_expire :source-code: base/protocols/mqtt/main.zeek 137 141 :Type: :zeek:type:`function` (tbl: :zeek:type:`table` [:zeek:type:`count`] of :zeek:type:`MQTT::SubscribeInfo`, idx: :zeek:type:`count`) : :zeek:type:`interval` The expiration function for subscription messages that haven't been logged yet simply causes the message to be logged.