Subversion Repositories HomeAutomation

<?php

require(dirname(__FILE__)."/config.php");

/*

  http://www.howtoforge.com/talking-soap-with-exchange

*/

if (isset($_GET["function"]))

{

    switch ($_GET["function"])

    {

        case "getMeetingsRestOfDay":

        if (isset($_GET["shortname"]))

        {

            echo getMeetingsRestOfDay($_GET["shortname"]);

        }

        break;

        case "bookMeeting":

        if (isset($_GET["from"]) && isset($_GET["to"]) && isset($_GET["shortname"]))

        {

            if (preg_match("/^\d\d:\d\d$/", $_GET["from"]) && preg_match("/^\d\d:\d\d$/", $_GET["to"]))

            {

                echo bookMeeting($_GET["shortname"], $_GET["from"], $_GET["to"]);

            }

        }

        break;

        //case "":

        //

        //break;

    }

}

/*

  Book meeting

  Return a JSON formed string with the result

*/

function bookMeeting($shortname, $bookFrom, $bookTo)

{

    global $Calender;

    global $wsdl;

    $founditem = false;

    foreach($Calender as $item)

    {

        if ($item->Shortname == $shortname)

        {

            $founditem = $item;

            break;

        }

    }

    $bookingsOk = true;

    $bookings = json_decode(getMeetingsRestOfDay($shortname));

    //print_array($bookings);

    //echo $bookings;

    if ($bookings->{'error'})

    {

        $bookingsOk = false;

    }

    if ($bookings->{'meetings'})

    {

        foreach ($bookings->{'meetings'} as $meeting)

        {

            $meetStart = strtotime($meeting->{'start'});

            $meetEnd = strtotime($meeting->{'end'});

            $start = strtotime($bookFrom);

            $end = strtotime($bookTo);

            //echo $meeting->{'start'}." ";

            if (($start >= $meetStart && $start < $meetEnd)

                || ($end > $meetStart && $end <= $meetEnd)

                || ($start <= $meetStart && $end >= $meetEnd))

            {

                $bookingsOk = false;

                break;

            }

        }

    }

    if ($founditem !== false && $bookingsOk)

    {

        $CreateItem->SendMeetingInvitations = "SendToNone";

        $CreateItem->SavedItemFolderId->DistinguishedFolderId->Id = "calendar";

        $CreateItem->Items->CalendarItem = array();

        $CreateItem->Items->CalendarItem[0]->Subject = "Booking from panel";

        /* Dont forget to use the proper timezone and setting for daylight saving time (php handles this fine) */

        $CreateItem->Items->CalendarItem[0]->Start = date("c",strtotime($bookFrom)); // "2009-05-22T17:00:00Z" ISO date format. Z denotes UTC time

        $CreateItem->Items->CalendarItem[0]->End = date("c",strtotime($bookTo));

        $CreateItem->Items->CalendarItem[0]->IsAllDayEvent = false;

        $CreateItem->Items->CalendarItem[0]->LegacyFreeBusyStatus = "Busy";

        $CreateItem->Items->CalendarItem[0]->Location = $founditem->Shortname;

        $CreateItem->Items->CalendarItem[0]->Categories->String = "Meeting";

        stream_wrapper_unregister('https');

        stream_wrapper_register('https', 'NTLMStream') or die("Failed to register protocol");

        try

        {

            $client = new ExchangeNTLMSoapClient($wsdl);

            $client->user = $founditem->UserName;

            $client->pass = $founditem->Password;

            $result = $client->CreateItem($CreateItem);

            if ($result)

            {

                //print_array($result);

                if ($result->ResponseMessages->CreateItemResponseMessage->ResponseClass == "Success")

                {

                    $returndata = "{ result:'success',\nshortname:'".$shortname."'}\n";

                }

                else

                {

                    $errorcode=$result->ResponseMessages->CreateItemResponseMessage->MessageText;

                    $returndata = "{ result:'error',\nerror:'".$errorcode."',\nshortname:'".$shortname."'}\n";

                }

            }

            else

            {

                $returdata = "{ error:'No result',\nshortname:'".$shortname."'}\n";

            }

        }

        catch (SoapFault $exception)

        {

            $returdata = "{ error:'".$exception."',\nshortname:'".$shortname."'}\n";

        }

        stream_wrapper_restore('https');

        return $returndata;

    }

    else if ($founditem === false)

    {

        return "{ error:'Unknown shortname',\nshortname:'".$shortname."'}\n";

    }

    else

    {

        return "{ error:'Double booking',\nshortname:'".$shortname."'}\n";

    }

}

/*

stdClass Object

(

    [ResponseMessages] => stdClass Object

        (

            [CreateItemResponseMessage] => stdClass Object

                (

                    [ResponseCode] => NoError

                    [ResponseClass] => Success

                    [Items] => stdClass Object

                        (

                            [CalendarItem] => stdClass Object

                                (

                                    [ItemId] => stdClass Object

                                        (

                                            [Id] =>

AAAcAEVudGVyLktvbmZlcmVuc3J1bUBxcnRlY2guc2UARgAAAAAAWx3xkPMlnUyMluTTqIdb4AcAdM/rfM3YaEeMsdYGn8jOeAAAAClWOAAAK68xOGjBUkCXHxa/+2eMqAAah/ErtAAA

                                            [ChangeKey] => DwAAABYAAAArrzE4aMFSQJcfFr/7Z4yoABqH8Tu3

                                        )

                                )

                        )

                )

        )

)

stdClass Object

(

    [ResponseMessages] => stdClass Object

        (

            [CreateItemResponseMessage] => stdClass Object

                (

                    [MessageText] => EndDate is earlier than StartDate

                    [ResponseCode] => ErrorCalendarEndDateIsEarlierThanStartDate

                    [DescriptiveLinkKey] => 0

                    [ResponseClass] => Error

                    [Items] => stdClass Object

                        (

                        )

                )

        )

)

*/

/*

  Get all meetings from now and 9 hours later

  Return a JSON formed string

*/

function getMeetingsRestOfDay($shortname)

{

    global $Calender;

    global $wsdl;

    $founditem = false;

    foreach($Calender as $item)

    {

        if ($item->Shortname == $shortname)

        {

            $founditem = $item;

            break;

        }

    }

    if ($founditem !== false)

    {

        $FindItem->Traversal = "Shallow";

        $FindItem->ItemShape->BaseShape = "AllProperties";

        $FindItem->ParentFolderIds->DistinguishedFolderId->Id = "calendar";

        /* Dont forget to use the proper timezone and setting for daylight saving time (php handles this fine) */

        $FindItem->CalendarView->StartDate = date("c");                     //"2009-04-07T08:00:00Z";

        $FindItem->CalendarView->EndDate = date("c", strtotime("+12 hour"));    //"2009-04-08T00:00:00Z";

        //echo date("c")." ".date("c", strtotime("+8 hour"))." ".date("c", strtotime("18:00"))."\n";

        stream_wrapper_unregister('https');

        stream_wrapper_register('https', 'NTLMStream') or die("Failed to register protocol");

        $returndata = "{ \n\t\"shortname\":\"".$shortname."\",\n\t\"meetings\":[\n";

        try

        {

            $client = new ExchangeNTLMSoapClient($wsdl);

            $client->user = $founditem->UserName;

            $client->pass = $founditem->Password;

            $result = $client->FindItem($FindItem);

            if ($result)

            {

                //print_array($result);

                $calendaritems = $result->ResponseMessages->FindItemResponseMessage->RootFolder->Items->CalendarItem;

                //print_array($calendaritems);

                for ($i = 0; $i < count($calendaritems); $i++)

                {

                    if (count($calendaritems) > 1)

                    {

                        $item = $calendaritems[$i];

                    }

                    else

                    {

                        $item = $calendaritems;

                    }

                    $returndata .= "\t\t{\n";

                    $returndata .= "\t\t\"organizer\":\"".$item->Organizer->Mailbox->Name."\",\n";

                    $returndata .= "\t\t\"subject\":\"".$item->Subject."\",\n";

                    $returndata .= "\t\t\"start\":\"".date("G:i", strtotime($item->Start))."\",\n";

                    $returndata .= "\t\t\"end\":\"".date("G:i", strtotime($item->End))."\"\n";

                    $returndata .= "\t\t}";

                    if ($i+1 < count($calendaritems))

                    {

                        $returndata .= ",\n";

                    }

                }

            }

            else

            {

                //return "{ \"error\":\"No result\",\n\"shortname\":\"".$shortname."\"}\n";

            }

        }

        catch (SoapFault $exception)

        {

            //return "{ \"error\":\"".$exception."\",\n\"shortname\":\"".$shortname."\"}\n"; 

        }

        stream_wrapper_restore('https');

        $returndata .= "\n\t]\n}\n";

        return $returndata;

    }

    else

    {

        return "{ \"error\":\"Unknown shortname\",\n\"shortname\":\"".$shortname."\"}\n";

    }

}

function print_array($var)

{

    echo "<pre>\n";

    print_r($var);

    echo "</pre>\n";

}

class NTLMSoapClient extends SoapClient {

    function __doRequest($request, $location, $action, $version)

    {

        global $exchangeurl;

        $location=$exchangeurl; //override url to exchange server

        $headers = array( 'Method: POST',

            'Connection: Keep-Alive',

            'User-Agent: PHP-SOAP-CURL',

            'Content-Type: text/xml; charset=utf-8',

            'SOAPAction: "'.$action.'"',

            );

        $this->__last_request_headers = $headers;

        $ch = curl_init($location);

        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);

        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);

        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

        curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

        curl_setopt($ch, CURLOPT_POST, true );

        curl_setopt($ch, CURLOPT_POSTFIELDS, $request);

        curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);

        curl_setopt($ch, CURLOPT_HTTPAUTH, CURLAUTH_NTLM);

        curl_setopt($ch, CURLOPT_USERPWD, $this->user.':'.$this->pass);

        $response = curl_exec($ch);

/*$myfile = "/tmp/debugex.txt";

$fh = fopen($myfile, 'w+') or die("can't open file");

fwrite($fh, "user: ". $this->user. " pass: ".$this->pass."\n");

fwrite($fh, "req: ". $request ."loc: ". $location ." act: ". $action ." ver: ". $version."\n");

fwrite($fh, "reponse: ". $response."\n\n");

fclose($fh);

*/

        return $response;

    }

    function __getLastRequestHeaders()

    {

        return implode("\n", $this->__last_request_headers)."\n";

    }

}

class ExchangeNTLMSoapClient extends NTLMSoapClient

{

    public $user = '';

    public $password = '';

}

class NTLMStream

{

    private $path;

    private $mode;

    private $options;

    private $opened_path;

    private $buffer;

    private $pos;

    /**

     * Open the stream

     *

     * @param unknown_type $path

     * @param unknown_type $mode

     * @param unknown_type $options

     * @param unknown_type $opened_path

     * @return unknown

     */

    public function stream_open($path, $mode, $options, $opened_path)

    {

        echo "[NTLMStream::stream_open] $path , mode=$mode \n";

        $this->path = $path;

        $this->mode = $mode;

        $this->options = $options;

        $this->opened_path = $opened_path;

        $this->createBuffer($path);

        return true;

    }

    /**

     * Close the stream

     *

     */

    public function stream_close()

    {

        echo "[NTLMStream::stream_close] \n";

        curl_close($this->ch);

    }

    /**

     * Read the stream

     *

     * @param int $count number of bytes to read

     * @return content from pos to count

     */

    public function stream_read($count)

    {

        echo "[NTLMStream::stream_read] $count \n";

        if(strlen($this->buffer) == 0)

        {

            return false;

        }

        $read = substr($this->buffer,$this->pos, $count);

        $this->pos += $count;

        return $read;

    }

    /***

     * write the stream

     *

     * @param $data

     * @return

     */

    public function stream_write($data)

    {

        echo "[NTLMStream::stream_write] \n";

        if(strlen($this->buffer) == 0)

        {

            return false;

        }

        return true;

    }

    /**

     *

     * @return true if eof else false

     */

    public function stream_eof()

    {

        echo "[NTLMStream::stream_eof] ";

        if($this->pos > strlen($this->buffer))

        {

            echo "true \n";

            return true;

        }

        echo "false \n";

        return false;

    }

    /**

     * @return int the position of the current read pointer

     */

    public function stream_tell()

    {

        echo "[NTLMStream::stream_tell] \n";

        return $this->pos;

    }

    /**

     * Flush stream data

     */

    public function stream_flush()

    {

        echo "[NTLMStream::stream_flush] \n";

        $this->buffer = null;

        $this->pos = null;

    }

    /**

     * Stat the file, return only the size of the buffer

     *

     * @return array stat information

     */

    public function stream_stat()

    {

        echo "[NTLMStream::stream_stat] \n";

        $this->createBuffer($this->path);

        $stat = array( 'size' => strlen($this->buffer), );

        return $stat;

    }

    /**

     * Stat the url, return only the size of the buffer

     *

     * @return array stat information

     */

    public function url_stat($path, $flags)

    {

        echo "[NTLMStream::url_stat] \n";

        $this->createBuffer($path);

        $stat = array( 'size' => strlen($this->buffer), );

        return $stat;

    }

    /* Create the buffer by requesting the url through cURL */

    private function createBuffer($path)

    {

        if($this->buffer)

        {

            return;

        }

        echo "[NTLMStream::createBuffer] create buffer from : $path \n";

        $this->ch = curl_init($path);

        curl_setopt($this->ch, CURLOPT_SSL_VERIFYPEER, false);

        curl_setopt($this->ch, CURLOPT_SSL_VERIFYHOST, false);

        curl_setopt($this->ch, CURLOPT_RETURNTRANSFER, true);

        curl_setopt($this->ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);

        curl_setopt($this->ch, CURLOPT_HTTPAUTH, CURLAUTH_NTLM);

        curl_setopt($this->ch, CURLOPT_USERPWD, $user.':'.$pass);

        echo $this->buffer = curl_exec($this->ch);

        echo "[NTLMStream::createBuffer] buffer size : ".strlen($this->buffer)."bytes \n";

        $this->pos = 0;

/*$myfile = "/tmp/debugex.txt";

$fh = fopen($myfile, 'w+') or die("can't open file");

fwrite($fh, "user: ". $this->user. " pass: ".$this->pass."\n");

fwrite($fh, "req: ". $request ."loc: ". $location ." act: ". $action ." ver: ". $version."\n");

fwrite($fh, "reponse: ". $response."\n\n");

fclose($fh);

*/

    }

}

?>