cmis_common.inc

<?php
require_once 'Mail/mimeDecode.php';

class CMIS_Common
{
    
    var $security_header = NULL;
    
    var $ptr = NULL;


    function CMIS_Common()
    {
        
    }//end constructor


    function connect($wsdl, $conn_info)
    {
        if (empty($wsdl) || empty($conn_info['username']) || empty($conn_info['password'])) return FALSE;
        
        if ($conn_info['ws_security']) {
            $created = date('Y-m-d\TH:i:s\Z', time());
            $soap_header_data =
            '<wsse:Security xmlns:wsse="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd" SOAP-ENV:mustUnderstand="1">
                <wsu:Timestamp xmlns:wsu="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd">
                    <wsu:Created>'.$created.'</wsu:Created>
                 </wsu:Timestamp>
                 <wsse:UsernameToken>
                    <wsse:Username>'.$conn_info['username'].'</wsse:Username>
                    <wsse:Password Type="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-username-token-profile-1.0#PasswordText">'.$conn_info['password'].'</wsse:Password>
                 </wsse:UsernameToken>
             </wsse:Security>';
         
            $soap_header_var = @new SoapVar($soap_header_data, XSD_ANYXML);
            $namespace = 'http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd';
            $this->security_header = @new SoapHeader($namespace, "wsse:Security", $soap_header_var, TRUE);
        }
        
        // Prep the params to be passed to the SOAP client
        $params = Array();
        $params['exceptions'] = TRUE;
        $params['trace'] = TRUE;
        $params['soap_version'] = SOAP_1_1;
        $params['login'] = $conn_info['username'];
        $params['password'] = $conn_info['password'];
        //This is Sharepoint 2010 specific, using basic authentication.
        if (!$conn_info['ws_security']) $params['location'] = substr($wsdl, 0, strpos($wsdl, '?')).'/basic';

        // Make sure the pointer is open
        if ($this->ptr) $this->ptr=NULL;
        
        if ($conn_info['verify']){
            $options = array(
                        'FOLLOWLOCATION' => 1,
                        'RETURNTRANSFER' => 1,
                        'HTTPAUTH'          => CURLAUTH_BASIC,
                        'TIMEOUT'        => 3,
                        'USERPWD'        => $conn_info['username'].":".$conn_info['password'],
                       );
            $details  = fetch_url($wsdl, $options, array(), FALSE);
            $contents = $details['response'];

            if (strpos($contents, '?xml') === FALSE) return FALSE;
            
            try {
                $this->ptr = new SoapClient($wsdl, $params);
                $fns = $this->ptr->__getFunctions();
                if (empty($fns)) return FALSE; 

                if ($conn_info['service_name'] == 'RepositoryService') {
                    $response = $this->ptr->__soapCall('getRepositories',  Array(), Array('uri'=>''), $this->security_header);
                } else if ($conn_info['service_name'] == 'NavigationService'){
                    $response = $this->ptr->__soapCall('getChildren', Array('paramaters' => Array ('repositoryId' => '', 'folderId' => '')), Array('uri'=>''), $this->security_header);
                } else if ($conn_info['service_name'] == 'ObjectService'){
                    $response = $this->ptr->__soapCall('getContentStream', Array('paramaters' => Array ('repositoryId' => '', 'objectId' => '')), Array('uri'=>''), $this->security_header);
                }
            } catch (SoapFault $e) {
                if (strpos($e->getMessage(), 'looks like we got no XML document') === FALSE) {
                    trigger_error("Failed to connect to CMIS ".$conn_info['service_name'].": ".$e->getMessage()."\n", E_USER_WARNING);
                    return FALSE;
                }
            }//end if
                
        } else {
            $this->ptr = new SoapClient($wsdl, $params);
        }
        
        return TRUE;

    }//end connect()
    
    
    public function getRepositories()
    {   
        $repositories = NULL;
        if (!$this->ptr) return $repositories;
        
        try {
            $response = $this->ptr->__soapCall('getRepositories',  Array(), Array('uri'=>''), $this->security_header);
        } catch (SoapFault $e) {
            if (strpos($e->getMessage(), 'looks like we got no XML document') === FALSE) {
                trigger_error("Failed to getRepositories: ".$e->getMessage()."\n", E_USER_WARNING);
                return $repositories;
            }
        }

        $data = $this->processSoapRequest();
        
        if (isset($data['xml']->getRepositoriesResponse)){
            $repositories = $data['xml']->getRepositoriesResponse;
        }
        
        return $repositories;
    }

    
    public function getRepositoryInfo($repositoryId)
    {
        $repositoryInfo = NULL;
        if (!$this->ptr) return $repositoryInfo;
        
        try {
            $response = $this->ptr->__soapCall('getRepositoryInfo', Array('paramaters' => Array ('repositoryId' => $repositoryId)), Array('uri'=>''), $this->security_header);
        } catch (SoapFault $e) {
            if (strpos($e->getMessage(), 'looks like we got no XML document') === FALSE) {
                trigger_error("Failed to getRepositoryInfo: ".$e->getMessage()."\n", E_USER_WARNING);
                return $repositoryInfo;
            }
        }

        $data = $this->processSoapRequest();
        if (isset($data['xml']->getRepositoryInfoResponse)) {
            $repositoryInfo = $data['xml']->getRepositoryInfoResponse;
        }
        
        return $repositoryInfo;
    }

    
    public function getTypeDefinition($repositoryId, $typeId)
    {
        $type_def = NULL;
        if (!$this->ptr) return $type_def;
        
        try {
            $response = $this->ptr->__soapCall('getTypeDefinition', Array('paramaters' => Array ('repositoryId' => $repositoryId, 'typeId' => $typeId)), Array('uri'=>''), $this->security_header);
        } catch (SoapFault $e) {
            if (strpos($e->getMessage(), 'looks like we got no XML document') === FALSE) {
                trigger_error("Failed to getTypeDefinition: ".$e->getMessage()."\n", E_USER_WARNING);
                return $type_def;
            }
        }

        $data = $this->processSoapRequest();
        if (isset($data['xml']->getTypeDefinitionResponse)){
            $type_def = $data['xml']->getTypeDefinitionResponse;
        }

        return $type_def;
    }
    
    
    public function getChildren($repositoryId, $folderId)
    {
        $children = NULL;
        if (!$this->ptr) return $children;
        
        try {
            $response = $this->ptr->__soapCall('getChildren', Array('paramaters' => Array ('repositoryId' => $repositoryId, 'folderId' => $folderId, 'includePathSegment' => TRUE)), Array('uri'=>''), $this->security_header);
        } catch (SoapFault $e) {
            if (strpos($e->getMessage(), 'looks like we got no XML document') === FALSE) {
                trigger_error("Failed to getChildren: ".$e->getMessage()."\n", E_USER_WARNING);
                return $children;
            }
        }

        $data = $this->processSoapRequest();
        if (isset($data['xml']->getChildrenResponse)){
            $children = $data['xml']->getChildrenResponse;
        }

        return $children;
    }
    
    
    public function getContentStream($repositoryId, $objectId)
    {
        $contentStream = '';
        if (!$this->ptr) return $contentStream;
        
        try {
            $response = $this->ptr->__soapCall('getContentStream', Array('paramaters' => Array ('repositoryId' => $repositoryId, 'objectId' => $objectId)), Array('uri'=>''), $this->security_header);
        } catch (SoapFault $e) {
            if (strpos($e->getMessage(), 'looks like we got no XML document') === FALSE) {
                trigger_error("Failed to getContentStream: ".$e->getMessage()."\n", E_USER_WARNING);
                return $contentStream;
            }
        }

        $data = $this->processSoapRequest();
        if (isset($data['binary'])) {
            $contentStream = $data['binary'];
        } else if (isset($data['xml']->getContentStreamResponse->contentStream->stream)){
            $contentStream = (string)$data['xml']->getContentStreamResponse->contentStream->stream;
            $contentStream = base64_decode($contentStream);
        }

        return $contentStream;
    }

    
    public function processSoapRequest()
    {
        $data = Array();
        $decode_params['include_bodies'] = TRUE;
        $decode_params['decode_bodies']  = TRUE;
        $decode_params['decode_headers'] = TRUE;
    
        $soap_header = $this->ptr->__getLastResponseHeaders();
        $soap_response = $this->ptr->__getLastResponse(); 
        
        $decoder = new Mail_mimeDecode($soap_header."\r\n".$soap_response);
        $structure = $decoder->decode($decode_params);

        if (isset($structure->parts[1]->body)) {
            $data['binary'] = $structure->parts[1]->body;
            $data['binary'] = preg_replace('|\r\n$|', '', $data['binary']); //decoding seems to add extra line to end
        }
        
        $soap_env = (isset($structure->parts[0]->body)) ? $structure->parts[0]->body : '';
        
        if (preg_match('|<([^:]+:)?Body[^>]*>(.*)</([^:]+:)?Body>|msi', $soap_env, $match)) {//extract the soap body
            //take out the colons in the tag names which SimpleXMLElement can't process
            $match[0] = preg_replace("/(<\/?)(\w+):([^>]*>)/", "$1$2$3", $match[0]); 
            try {
                $xml = new SimpleXMLElement($match[0]);
                $data['xml'] = $xml;
            }catch(Exception $e){
                trigger_error("Failed to parse XML".$e->getMessage()."\n", E_USER_WARNING);
            }
        } 
        
        return $data;
    }
    
}//end class

?>