event_controller.php

<?php
  /*
   All Emoncms code is released under the GNU Affero General Public License.
   See COPYRIGHT.txt and LICENSE.txt.

    ---------------------------------------------------------------------
    Emoncms - open source energy visualisation
    Part of the OpenEnergyMonitor project:
    http://openenergymonitor.org
  */

  // no direct access
  defined('EMONCMS_EXEC') or die('Restricted access');

  function event_controller()
  {
    global $mysqli,$redis,$user, $session, $route, $timestore_adminkey;

    global $feed;
    include "Modules/feed/feed_model.php";
    $feed = new Feed($mysqli,$redis,$timestore_adminkey);

    require "Modules/event/event_model.php";
    $event = new Event($mysqli,$redis);

    $userid = $session['userid'];
    if ($route->action == 'add' && $session['write'])
    {
      $eventfeed = intval(get('eventfeed'));
      $eventtype = intval(get('eventtype'));
      $eventvalue = floatval(get('eventvalue'));
      $action = intval(get('action'));
      $setfeed = intval(get('setfeed'));
      $setemail = get('setemail');
      $setvalue = floatval(get('setvalue'));
      $callcurl = get('callcurl');
      $mutetime = get('mutetime');
      $priority = get('priority');
      $message = get('message');
      $mqtttopic = get('mqtttopic');
      $mqttqos = get('mqttqos');

      $event->add($userid,$eventfeed,$eventtype,$eventvalue,$action,$setfeed,$setemail,$setvalue,$callcurl,$message,$mutetime,$priority,$mqtttopic,$mqttqos);
      $result = "Event added";
    }

    if ($route->action == 'edit' && $session['write'])
    {
      $eventid = intval(get('eventid'));
      $eventfeed = intval(get('eventfeed'));
      $eventtype = intval(get('eventtype'));
      $eventvalue = floatval(get('eventvalue'));
      $action = intval(get('action'));
      $setfeed = intval(get('setfeed'));
      $setemail = get('setemail');
      $setvalue = floatval(get('setvalue'));
      $callcurl = get('callcurl');
      $mutetime = get('mutetime');
      $priority = get('priority');
      $message = get('message');
      $mqtttopic = get('mqtttopic');
      $mqttqos = get('mqttqos');

      $event->update($userid,$eventid,$eventfeed,$eventtype,$eventvalue,$action,$setfeed,$setemail,$setvalue,$callcurl,$message,$mutetime,$priority,$mqtttopic,$mqttqos);
      $result = "Event updated";
    }

    else if ($route->action == 'delete' && $session['write'])
    {
      $id = intval(get('id'));
      $event->delete($userid,$id);
      $result = "Event deleted";
    }

    else if ($route->action == 'status' && $session['write'])
    {
      $id = intval(get('id'));
      $status = intval(get('status'));
      $event->set_status($userid,$id,$status);
      $result = "Event deleted";
    }

    else if ($route->action == 'test' && $session['write'])
    {
      $id = intval(get('id'));
      $feedid = intval(get('feedid'));
      $event->test($userid,$id,$feedid);
      $result = "Event Test Sent";
    }

    else if ($route->action == 'settings' && $session['write'])
    {
      $settings = $event->get_settings($session['userid']);
      $result = view("Modules/event/event_settings_view.php", array('settings'=>$settings));
    }

    //--------------------------------------------------------------------------
    // SET TWITTER
    // http://yoursite/emoncms/user/settwitter
    //--------------------------------------------------------------------------
    else if ($route->action == 'savesettings' && $session['write'])
    {
      // Store userlang in database

      $prowlkey = post('prowlkey');
      $nmakey = post('nmakey');

      $smtpserver = post('smtpserver');
      $smtpuser = post('smtpuser');

      $salt = $user->get_salt($session['userid']);
      $ivlen = openssl_cipher_iv_length($cipher="AES-128-CBC");
      $iv = openssl_random_pseudo_bytes($ivlen);
      $ciphertext_raw = openssl_encrypt(post('smtppassword'), $cipher, $salt, $options=OPENSSL_RAW_DATA, $iv);
      $hmac = hash_hmac('sha256', $ciphertext_raw, $salt, $as_binary=true);
      $smtppassword = base64_encode( $iv.$hmac.$ciphertext_raw );
      
      $smtpport = preg_replace('/[^\w\s-]/','',post('smtpport'));

      $consumerkey = post('consumerkey');
      $consumersecret = post('consumersecret');
      $usertoken = post('usertoken');
      $usersecret = post('usersecret');

      $mqttbrokerip = post('mqttbrokerip');
      $mqttbrokerport = post('mqttbrokerport');
      $mqttusername = post('mqttusername');
      
      $ivlen = openssl_cipher_iv_length($cipher="AES-128-CBC");
      $iv = openssl_random_pseudo_bytes($ivlen);
      $ciphertext_raw = openssl_encrypt(post('mqttpassword'), $cipher, $salt, $options=OPENSSL_RAW_DATA, $iv);
      $hmac = hash_hmac('sha256', $ciphertext_raw, $salt, $as_binary=true);
      $mqttpassword = base64_encode( $iv.$hmac.$ciphertext_raw );

      $result = $event->set_settings($session['userid'],$prowlkey,$consumerkey,$consumersecret,$usertoken,$usersecret,$smtpserver,$smtpuser,$smtppassword,$smtpport,$nmakey,$mqttbrokerip,$mqttbrokerport, $mqttusername, $mqttpassword);
      if ($result) {
        $result = "Event settings updated!";
      }
      else {
        $result = "Error occours while updating settings!";
      }
    }

    else if ($session['write'])
    {
      $list = $event->eventlist($userid);
      $feeds = $feed->get_user_feeds($userid);
      $result = view("Modules/event/event_list.php", array('event_list'=>$list, 'feeds'=>$feeds));
    }

    return array('content'=>$result);
  }