ProsodyRestApi.php

<?php
	
namespace andrea11;

use GuzzleHttp\Client;

class ProsodyRestApi
{
    private $host;
	private $port;
    private $username;
    private $password;
	private $module;
    
    private $params;
    private $client;
    /**
     * Class Contructor
     *
     */
    public function __construct($host = 'fiduhub.dev', $port = '5280', $username = 'admin', $password = 'pass', $module = 'admin_rest')
    {
        $this->client = new Client(['http_errors' => false]);
        $this->host = $host;
        $this->port = $port;
        $this->username = $username;
        $this->password = $password;
        $this->module = $module;
        $this->params = array();
    }

    /**
     * Make the request and analyze the result
     *
     * @param   string          $type           Request method
     * @param   string          $endpoint       Api request endpoint
     * @param   array           $params         Parameters
     * @return  array|false                     Array with data or error, or False when something went fully wrong
     */
    
    private function doRequest($type, $endpoint, $params=array())
    {
    	$url = "http://" . $this->host . ":" .$this->port . "/" . $this->module . "/" . $endpoint;
    	$headers = array(
  			'Accept' => 'application/json',
  			'Authorization' => 'Basic '. base64_encode($this->username . ":" . $this->password)
  		);

        $body = json_encode($params);

        switch ($type) {
            case 'get':
                $result = $this->client->get($url, compact('headers'));
                break;
            case 'post':
                $headers += ['Content-Type'=>'application/json'];
                $result = $this->client->post($url, compact('headers','body'));
                break;
            case 'delete':
                $headers += ['Content-Type'=>'application/json'];
                $result = $this->client->delete($url, compact('headers','body'));
                break;
            case 'put':
                $headers += ['Content-Type'=>'application/json'];
                $result = $this->client->put($url, compact('headers','body'));
                break;
            default:
                $result = null;
                break;
        }
        if ($result->getStatusCode() == 200 || $result->getStatusCode() == 201) {
            return array('status'=>true, 'message'=>json_decode($result->getBody()));
        }
        return array('status'=>false, 'message'=>json_decode($result->getBody()));
    	
    }

    /**
     * Get all connected users
     *
     * @return json|False   Json with data or error, or False when something went fully wrong
     */
    public function getUsers()
    {
    	$endpoint = 'users';        
    	return $this->doRequest('get',$endpoint);
    }

    /**
     * Create a new user
     *
     * @param   string          $username   Username
     * @param   string          $password   Password
     * @param   string|false    $name       Name    (Optional)
     * @param   string|false    $email      Email   (Optional)
     * @param   string[]|false  $groups     Groups  (Optional)
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function addUser($username, $password, $name=false, $email=false, $groups=false)
    {
        $endpoint = 'user/' . $username; 
        return $this->doRequest('post', $endpoint, compact('password','name','email', 'groups'));
    }

    /**
     * NOW : Get user satus (connected or not)
     * TODO : Get information for a specified user
     *
     * @return json|false   Json with data or error, or False when something went fully wrong
     */
    public function getUser($username)
    {
        $endpoint = '/'.$username.'/connected'; 
        return $this->doRequest('get', $endpoint);
    }

    /**
     * Delete an user
     *
     * @param   string          $username   Username
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function deleteUser($username)
    {
        $endpoint = '/user/'.$username; 
        return $this->doRequest('delete', $endpoint);
    }

    /**
     * NOW: Update user's infos (password)
     * TODO: Update user's infos (all)
     *
     * @param   string          $username   Username
     * @param   string|false    $password   Password (Optional)
     * @param   string|false    $name       Name (Optional)
     * @param   string|false    $email      Email (Optional)
     * @param   string[]|false  $groups     Groups (Optional)
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function updateUser($username, $password, $name=false, $email=false, $groups=false)
    {
        $endpoint = '/user/'.$username.'/attribute';
        return $this->doRequest('patch', $endpoint, compact('username', 'password','name','email', 'groups'));
    }

    /**
     * Create a roster between an user and a contact
     *
     * @param   string          $username       Username
     * @param   string          $contactJID     Contact's JID
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function addRoster($username, $contact)
    {
        $endpoint = 'roster/' . $username;
        $contact = $contact . '@' . $this->host;
        return $this->doRequest('post', $endpoint, compact('contact'));
    }

    /**
     * Delete a roster between an user and a contact
     *
     * @param   string          $username       Username
     * @param   string          $contactJID     Contact's JID
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function deleteRoster($username, $contact)
    {
        $endpoint = 'roster/' . $username;
        $contact = $contact . '@' . $this->host;
        return $this->doRequest('delete', $endpoint, compact('contact'));
    }







































































































































     /**
     * locks/Disables an OpenFire user
     *
     * @param   string          $username   Username
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function lockoutUser($username)
    {
        $endpoint = '/lockouts/'.$username; 
        return $this->doRequest('post', $endpoint);
    }


    /**
     * unlocks an OpenFire user
     *
     * @param   string          $username   Username
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function unlockUser($username)
    {
        $endpoint = '/lockouts/'.$username; 
        return $this->doRequest('delete', $endpoint);
    }


    /**
     * Adds to this OpenFire user's roster
     *
     * @param   string          $username       Username
     * @param   string          $jid            JID
     * @param   string|false    $nickname           Name         (Optional)
     * @param   int|false       $subscriptionType   Subscription (Optional)
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function addToRoster($username, $jid, $nickname=false, $subscriptionType=false)
    {
        $endpoint = '/users/'.$username.'/roster';
        return $this->doRequest('post', $endpoint, compact('jid','nickname','subscriptionType'));
    }


    /**
     * Removes from this OpenFire user's roster
     *
     * @param   string          $username   Username
     * @param   string          $jid        JID
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function deleteFromRoster($username, $jid)
    {
        $endpoint = '/users/'.$username.'/roster/'.$jid;
        return $this->doRequest('delete', $endpoint, $jid);
    }

    /**
     * Updates this OpenFire user's roster
     *
     * @param   string          $username           Username
     * @param   string          $jid                 JID
     * @param   string|false    $nickname           Nick Name (Optional)
     * @param   int|false       $subscriptionType   Subscription (Optional)
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function updateRoster($username, $jid, $nickname=false, $subscriptionType=false)
    {
        $endpoint = '/users/'.$username.'/roster/'.$jid;
        return $this->doRequest('put', $endpoint, $jid, compact('jid','username','subscriptionType'));     
    }

    /**
     * Get all groups
     *
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function getGroups()
    {
        $endpoint = '/groups';
        return $this->doRequest('get', $endpoint);
    }

    /**
     *  Retrieve a group
     *
     * @param  string   $name                       Name of group
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function getGroup($name)
    {
        $endpoint = '/groups/'.$name;
        return $this->doRequest('get', $endpoint);
    }

    /**
     * Create a group 
     *
     * @param   string   $name                      Name of the group
     * @param   string   $description               Some description of the group
     *
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function createGroup($name, $description = false)
    {
        $endpoint = '/groups/';
        return $this->doRequest('post', $endpoint, compact('name','description'));
    }

    /**
     * Delete a group
     *
     * @param   string      $name               Name of the Group to delete
     * @return  json|false  Json with data or error, or False when something went fully wrong
     */
    public function deleteGroup($name)
    {
        $endpoint = '/groups/'.$name;
        return $this->doRequest('delete', $endpoint);
    }

    /**
     * Update a group (description)
     *
     * @param   string      $name               Name of group
     * @param   string      $description        Some description of the group
     *
     */
    public function updateGroup($name,  $description)
    {
        $endpoint = '/groups/'.$name;
        return $this->doRequest('put', $endpoint, compact('name','description'));
    }

    /**
     * Gell all active sessions
     *
     * @return json|false   Json with data or error, or False when something went fully wrong
     */
    public function getSessions()
    {
        $endpoint = '/sessions';
        return $this->doRequest('get', $endpoint);
    }
}