SourceForge.net

 <?PHP

 #

 # Copyright (c) 2010, 2011 Adam Tauno Williams <awilliam@whitemice.org>

 #

 # Permission is hereby granted, free of charge, to any person obtaining a copy

 # of this software and associated documentation files (the "Software"), to deal

 # in the Software without restriction, including without limitation the rights

 # to use, copy, modify, merge, publish, distribute, sublicense, and/or sell

 # copies of the Software, and to permit persons to whom the Software is

 # furnished to do so, subject to the following conditions:

 #

 # The above copyright notice and this permission notice shall be included in

 # all copies or substantial portions of the Software.

 #

 # THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR

 # IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,

 # FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE

 # AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER

 # LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,

 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN

 #

 class OIEProcess {

    private $http_root;

    private $route_name;

    private $parameters;

    private $headers;   

    private $status;

    function __construct($_http_root, $_route_name, $_parameters=array()) {

        $this->http_root   = $_http_root;

        $this->route_name  = $_route_name;

        $this->parameters  = $_parameters;

        $this->headers     = array();

        $this->status      = 0;

    }

    function _build_url() {

        $url = sprintf('%s/dav/Workflow/Routes/%s/input', $this->http_root, $this->route_name);

        if (count($this->parameters) > 0) {

            $counter = 0;

            foreach($this->parameters as $key => $value) {

                if ($counter == 0) {

                    $url = sprintf('%s?%s=%s', $url, urlencode($key), urlencode($value));

                } else {

                    $url = sprintf('%s&%s=%s', $url, urlencode($key), urlencode($value));

                }

                $counter++;

            }

        }

        return $url;

    }

    function _process_header($_ch, $_header) {

        $tmp = explode(':', $_header);

        if (count($tmp) == 2) {

            $header = $tmp[0];

            $value = substr($tmp[1], 1);

            $this->headers[$header] = $value;

        }

        return strlen($_header);

    }

    function start($_username, $_secret, $_stream = null, $_mimetype='application/octet-stream')

    {

         #Prepare a stream that is the input message

         if ($_stream) {

             fseek($_stream, 0, SEEK_END);

             $size = ftell($_stream);

             fseek($_stream, 0, SEEK_SET);

             $close_stream = false;

         } else {

             # create an empty stream for the input as there is no input stream

             $_stream = tmpfile();

             $size = 0;

             $close_stream = true;

         }

         $url = $this->_build_url();

         # FIRE!

         $oie_put = curl_init();

         curl_setopt($oie_put, CURLOPT_URL, $url);

         curl_setopt($oie_put, CURLOPT_TIMEOUT, 5);

         curl_setopt($oie_put, CURLOPT_PUT, true);

         curl_setopt($oie_put, CURLOPT_HTTPHEADER, array('Content-Type: ' . $_mimetype)); 

         curl_setopt($oie_put, CURLOPT_USERPWD, sprintf('%s:%s', $_username, $_secret));         

         curl_setopt($oie_put, CURLOPT_INFILE, $_stream);

         curl_setopt($oie_put, CURLOPT_INFILESIZE, $size);

         curl_setopt($oie_put, CURLOPT_HEADERFUNCTION, array(&$this,'_process_header'));

         #Perform transaction

         if (curl_exec($oie_put)) {

             $response = curl_getinfo($oie_put); 

             if ($response['http_code'] == 301)

                $this->status = 'OK';

             else

                $this->status = 'OIERRR';

         } else $this->status = 'SYSERR';

         curl_close($oie_put);

         if ($close_stream)

             fclose($_stream);

         return $this->status;

     } /* end function invoke */

     function get_process_id() {

         if ($this->status == 'OK') {

             return $this->headers['X-COILS-WORKFLOW-PROCESS-ID'];

         }

         return null;

     }

     function get_message_id() {

         if ($this->status == 'OK') {

             return $this->headers['X-COILS-WORKFLOW-MESSAGE-UUID'];

         }

         return null;    

     }

 } /* end class OIEProcessInvocation */

 $HTTPROOT   = "http://opengroupware.mormail.com:8080";

 $ROUTENAME  = "TEST_MailBack";

 $PARAMETERS = array('myParameter'=>'YOYO MAMA', 'otherParam'=>4);

 $request = new OIEProcess($HTTPROOT, $ROUTENAME, $PARAMETERS);

 #

 # TEST: an empty input stream

 # if ($request->start('adam', '*******', null, 'text/plain') == 'OK') {

 #

 if ($request->start('adam', '********', fopen('/etc/passwd', 'r'), 'text/plain') == 'OK') {

     echo "\n";

     echo "Process ID: " . $request->get_process_id() . "\n";

     echo "Message UUID: " . $request->get_message_id() . "\n";    

 }