mqtt_pwn.connection package

Submodules

mqtt_pwn.connection.active_scanner module

class mqtt_pwn.connection.active_scanner.ActiveScanner(client_id=None, host='test.mosquitto.org', port=1883, timeout=60, topics=None, listen_timeout=60, scan_instance=None, cli=None)

Bases: object

check_for_timeout()

Checks if we should stop the loop based on self.listen_timeout

mqtt_on_message(mqtt_client, obj, msg)

Handles when a new message arrives

run()

The Scanner driver function

static start(cli, scan_instance, listen_timeout, topics)

Start A specific active scan - topic discovery

static start_async(cli, scan_instance, listen_timeout, topics)

Starts an active scan asynchronously

mqtt_pwn.connection.brute_forcer module

class mqtt_pwn.connection.brute_forcer.AuthBruteForce(cli, host, port, usernames, passwords)

Bases: object

The class responsible from brute force a broker

brute()

A wrapper for the _brute method, mainly to catch keyboard interrupts

valid_criterias = ('usernames', 'passwords')

class mqtt_pwn.connection.brute_forcer.ConnectionResult

Bases: object

Represents a connection result (success/fail)

did_succeed

A property that contains data whether the connection has succeeded

set_return_code(return_code)

Sets the return code field

mqtt_pwn.connection.mqtt_client module

class mqtt_pwn.connection.mqtt_client.MqttClient(client_id=None, host='test.mosquitto.org', port=1883, timeout=60, cli=None, username=None, password=None)

Bases: object

Represents a MQTT Client connection handler class

disconnect()

handle_failed_connection()

mqtt_on_connect(mqtt_client, userdata, flags, result)

A callback function that is responsible to being triggered when a connection was established

mqtt_on_message(mqtt_client, obj, msg)

Handles when a new message arrives

publish(topic, payload)

Publishes a message to a victim

run()

Run the MQTT client

send_command(victim, command)

Sends a command to a victim

stop()

Stops the mqtt connection loop

mqtt_pwn.connection.system_info module

class mqtt_pwn.connection.system_info.SystemInfo

Bases: object

Represents System Info of the broker

to_table()

Converts the data property to a prettytable table

topic_list

A property that contains only the topic names

topics = {('$SYS/broker/subscriptions/count', 0), ('$SYS/broker/timestamp', 0), ('$SYS/broker/clients/connected', 0), ('$SYS/broker/clients/total', 0), ('$SYS/broker/clients/maximum', 0), ('$SYS/broker/version', 0), ('$SYS/broker/clients/disconnected', 0), ('$SYS/broker/uptime', 0), ('$SYS/broker/clients/expired', 0)}

update(topic, payload)

Updates the system info data dict accordingly

Module contents