use Net::MQTT::Simple;

my ($mqtt, $topic, $message, $mqttuser, $mqttpass, $mqttIP, $mqttonly);

$status   = "https://spaceapi.c3l.lu/status.json";              # SpaceAPI direct link to status json file

$site     = "https://spaceapi.c3l.lu/open";                     # SpaceAPI direct link to change the state

$user     = "ledashbutton";                                     # SpaceAPI user

$pass     = "sohNgei3raiche2choo5";                             # SpaceAPI pass

$mqttIP   = "192.168.1.189";                                    # MQTT Server IP

$mqttuser = "dashbutton";                                       # MQTT User

$mqttpass = "oosahN0a";                                         # MQTT Pass

$mqttonly = "True";                                             # MQTT Only modus active = not changing Space Status by myself

$mac      = '78:e1:03:78:4a:0a';                                # MAC of Dash button.

$timeout  = 60;                                                 # Timeout in seconds.

$ENV{'MQTT_SIMPLE_ALLOW_INSECURE_LOGIN'} = 1;                   # Needed for the MQTT Login

$mqtt = Net::MQTT::Simple->new($mqttIP);

$mqtt->last_will("availability/dashbutton", "offline", 1);

$mqtt->login($mqttuser, $mqttpass);

$mqtt->retain("availability/dashbutton", "online");

say "[+] Connection to MQTT server established";

Amazon::Dash::Button->new( from => {                        # The author of the module says that you

        mac     => $mac,                                    # can omit a "dev" option to use another

        onClick => \&spaceapi,                              # network interface but actually it never

        name    => q{SpaceAPI},                             # gets used in the code. See the provided

        timeout => $timeout                                 # patch to define a different interface.

} )->listen;                                                # Patch changes default to eth0.

$mqtt->publish("space/status/trigger" => 1);

say "[+] MQTT message sent";

if ($mqttonly eq "False") {

    $curl = WWW::Curl::Easy->new;                        

    $curl->setopt(CURLOPT_URL, $status);

    $curl->setopt(CURLOPT_VERBOSE,0);

    $curl->setopt(CURLOPT_WRITEDATA,\$response_body);

    $curl->perform;

    $info = $curl->getinfo(CURLINFO_RESPONSE_CODE);

    say "[-] Server returned $info" and exit unless $info == 200;

    $json = valid_json($response_body);

    say  "[-] Malformed json!" and exit unless $json;

    $json = parse_json($response_body);

    if ($json->{state}{open} and $json->{state}{message} =~ /members only/i) {

            $space_status     = 2;                          # Propably needed in the future

        $new_space_status = "CLOSED";

            $postfields       = "close=close&message=";

    } elsif ($json->{state}{open}) {

            $space_status     = 1;                          # Propably needed in the future

        $new_space_status = "CLOSED";

            $postfields       = "close=close&message=";

    } else {

            $space_status     = 0;                          # Propably needed in the future

        $new_space_status = "OPEN";

            $postfields       = "open=open&message=";

    }

    $curl->setopt(CURLOPT_URL, $site);

    $curl->setopt(CURLOPT_VERBOSE,0);

    $curl->setopt(CURLOPT_USERPWD,"$user:$pass");

    $curl->setopt(CURLOPT_COOKIEFILE, 'cookiescurl');               # Apparently you need this

    $curl->setopt(CURLOPT_COOKIEJAR, '/tmp/cookiescurl');           # to make Digest Auth work

    $curl->setopt(CURLOPT_HTTPAUTH,CURLAUTH_DIGEST);                # ...sad!

    $curl->setopt(CURLOPT_POSTFIELDS(), $postfields);

    $curl->perform;

    $info = $curl->getinfo(CURLINFO_RESPONSE_CODE);

    say "[-] Server returned $info" and exit unless $info == 302||200;

    say "[+] Changed Space Status to $new_space_status";

}