device_controller.php

<?php

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

function device_controller()
{
    global $mysqli, $redis, $session, $route, $device, $settings;

    $result = false;

    require_once "Modules/device/device_model.php";
    $device = new Device($mysqli,$redis);

    if ($route->format == 'html')
    {
        if ($route->action == "view" && $session['write']) {
            $templates = $device->get_template_list_meta($session['userid']);
            $result = view("Modules/device/Views/device_view.php", array('templates'=>$templates));
        }
        else if ($route->action == 'api') $result = view("Modules/device/Views/device_api.php", array());
    }

    if ($route->format == 'json')
    {
        // ---------------------------------------------------------------
        // Method for sharing authentication details with a node
        // that does not require copying and pasting passwords and apikeys
        // 1. device requests authentication - reply "request registered"
        // 2. notification asks user whether to allow or deny device
        // 3. user clicks on allow
        // 4. device makes follow up request for authentication
        //    - reply authentication details
        // ---------------------------------------------------------------
        if ($route->action == "authcheck") { $route->action = "auth"; $route->subaction = "check"; } 
        if ($route->action == "authallow") { $route->action = "auth"; $route->subaction = "allow"; }         

        if ($route->action == "auth") {
            if (!isset($settings["device"])) {
                return array('content'=>array('success'=>false, 'message'=>'Auth functionality not enabled'));
            }
            if (!isset($settings["device"]["enable_auth_check"]) || !$settings["device"]["enable_auth_check"]) {
                return array('content'=>array('success'=>false, 'message'=>'Auth functionality not enabled'));
            }

            if ($route->subaction=="request") {
                // 1. Register request for authentication details, or provide if allowed
                $result = $device->request_auth($_SERVER['REMOTE_ADDR']);
                if (isset($result['success'])) {
                    $result = $result['message'];
                }
                $route->format = "text";
            }
            else if ($route->subaction=="check" && $session['read']) {
                // 2. User checks for device waiting for authentication
                $result = $device->get_auth_request();

                if (isset($settings["device"]["enable_UDP_broadcast"]) && $settings["device"]["enable_UDP_broadcast"]) {
                    $port = 5005;
                    $broadcast_string = "emonpi.local";
                    $sock = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
                    socket_set_option($sock, SOL_SOCKET, SO_BROADCAST, 1);
                    socket_sendto($sock, $broadcast_string, strlen($broadcast_string), 0, '255.255.255.255', $port);
                }
            }
            else if ($route->subaction=="allow" && $session['write']) {
                // 3. User allows device to receive authentication details
                $result = $device->allow_auth_request(get("ip"));
            }
        }
            
        if ($route->action == 'list') {
            if ($session['userid']>0 && $session['read']) $result = $device->get_list($session['userid']);
        }
        else if ($route->action == "create") {
            if ($session['userid']>0 && $session['write']) $result = $device->create($session['userid'],get("nodeid"),get("name"),get("description"),get("type"),get("dkey"));
        }
        // Used in conjunction with input name describe to auto create device
        else if ($route->action == "autocreate") {
            if ($session['userid']>0 && $session['write']) $result = $device->autocreate($session['userid'],get('nodeid'),get('type'));
        }
        else if ($route->action == "generatekey") {
            if ($session['userid']>0 && $session['write']) $result = $device->generate_devicekey();
        }
        else if ($route->action == "template" && $route->subaction != "prepare" && $route->subaction != "prepare_custom" && $route->subaction != "init" && $route->subaction != "init_custom" && $route->subaction != "generate") {
            if ($route->subaction == "listshort") {
                if ($session['userid']>0 && $session['write']) $result = $device->get_template_list_meta();
            }
            else if ($route->subaction == "list") {
                if ($session['userid']>0 && $session['write']) $result = $device->get_template_list();
            }
            else if ($route->subaction == "get") {
                if ($session['userid']>0 && $session['write']) $result = $device->get_template(get('type'));
            }
        }
        else {
            $deviceid = (int) get('id');
            if ($device->exist($deviceid)) // if the feed exists
            {
                $deviceget = $device->get($deviceid);
                if (isset($session['write']) && $session['write'] && $session['userid']>0 && $deviceget['userid']==$session['userid']) {
                    if ($route->action == "get") $result = $deviceget;
                    else if ($route->action == 'set') $result = $device->set_fields($deviceid, get('fields'));
                    else if ($route->action == 'init') $result = $device->init($deviceid, prop('template'));
                    else if ($route->action == "delete") $result = $device->delete($deviceid);
                    else if ($route->action == "setnewdevicekey") $result = $device->set_new_devicekey($deviceid);
                    else if ($route->action == 'template') {
                        if (isset($_GET['type'])) {
                            $device->set_fields($deviceid, json_encode(array("type"=>$_GET['type'])));
                        }
                        if ($route->subaction == 'prepare') $result = $device->prepare_template($deviceid);
                        else if ($route->subaction == 'prepare_custom') $result = $device->prepare_custom_template($deviceid, $_POST['template']);
                        else if ($route->subaction == 'init') $result = $device->init_template($deviceget, $_POST['template']);
                        else if ($route->subaction == 'init_custom') $result = $device->init_custom_template($deviceget, $_POST['template']);
                        else if ($route->subaction == 'generate') $result = $device->generate_template($deviceid);
                    }
                }
            }
            else {
                $result = array('success'=>false, 'message'=>'Device does not exist');
            }
        }
    }


    if ($route->action == "clean" && $session['write']) {
        $route->format = 'text';
        $active = 0; if (isset($_GET['active'])) $active = (int) $_GET['active'];
        $dryrun = 0; if (isset($_GET['dryrun']) && $_GET['dryrun']==1) $dryrun = 1;
        return $device->clean($session['userid'],$active,$dryrun);
    }

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