cmis_bridge.inc

<?php

require_once SQ_INCLUDE_PATH.'/asset.inc';
require_once SQ_PACKAGES_PATH.'/sharepoint/lib/cmis_common.inc';

class CMIS_Bridge extends Asset
{

    public $soap = NULL;
    
    function __construct($assetid=0)
    {
        $this->_ser_attrs = TRUE;
        parent::__construct($assetid);
        
    }//end constructor

    
    protected function _preCreateCheck(Array &$link)
    {   
        if (!parent::_preCreateCheck($link)) return FALSE;

        $name = trim($this->attr('name'));
        if ($name == '') {
            trigger_localised_error('CORE0083', E_USER_WARNING, $GLOBALS['SQ_SYSTEM']->am->getTypeInfo($this->type(), 'name'));
            return FALSE;
        }

        return TRUE;

    }//end _preCreateCheck()


    protected function _createAdditional(Array &$link)
    {
        if (!parent::_createAdditional($link)) return FALSE;

        return $this->makeAndSaveInitialWebPath(strtolower($this->attr('name')), $link);

    }//end _createAdditional()
    
    
    public function _getAllowedLinks()
    {
        
        $allowed = parent::_getAllowedLinks();
        $allowed[SQ_LINK_TYPE_1]['file']   = Array('card' => 'M', 'exclusive' => FALSE);
        $allowed[SQ_LINK_TYPE_2]['file']   = Array('card' => 'M', 'exclusive' => FALSE);
        
        return $allowed;

    }//end _getAllowedLinks()

    
    protected function _getName($short_name=FALSE)
    {
    
        $values = $GLOBALS['SQ_SYSTEM']->am->getAttributeValuesByName('name', $this->type(), Array($this->id), 0);
        if (empty($values) === TRUE) {
            return parent::_getName($short_name);
        } else {
            return $values[$this->id];
        }

    }//end _getName()

    
    public function connect($service_name, $verify = FALSE)
    {
        
        if (!$verify && isset($this->soap[$service_name])) return TRUE;
        
        $cmis = new CMIS_Common();
        $wsdl = $this->attr('wsdl');
        $conn_info = Array(
                        'username' => $this->attr('username'),
                        'password' => $this->attr('password'),
                        'ws_security' => $this->attr('ws_security'),
                        'verify'      => $verify,
                        'service_name'=> $service_name
                    );
        
        // Create and connect
        if (!$cmis->connect($wsdl[$service_name], $conn_info)) return FALSE;
        if (is_null($cmis->ptr)) return FALSE;
        
        $this->soap[$service_name] = $cmis;
        return TRUE;

    }//end connect()
    
    
    public function synchronizeCheck()
    {
        
        $sync_info = Array(
                        'update_assetids'   => Array(),
                        'create_objectIds'  => Array(),
                        'delete_assetids'   => Array()
                    );
                    
        $dont_delete = Array();
                    
        //metadata info
        $current_files = $this->getCurrentFileInfo();
        
        //soap calls
        $repositoryId = $this->getRepositoryId();
        if (empty($repositoryId)) return $sync_info;
        
        $folderId = $this->getRootFolderId($repositoryId);
        if (empty($folderId)) return $sync_info;
        
        $children_data = $this->getFolderChildren($repositoryId, $folderId);
        if ($children_data === FALSE) return $sync_info;
        
        foreach ($children_data as $object_data){
            
            //if not document type or there is no contentStreamFileName this object is not applicable.
            if ($object_data['cmis:objectTypeId'] != 'cmis:document' || !isset($object_data['cmis:contentStreamFileName'])) continue;
            
            $objectId = $object_data['cmis:objectId'];
            if (array_key_exists($objectId, $current_files)) {
                $assetid = $current_files[$objectId]['assetid'];
                $dont_delete[] = $assetid;
                
                //check if needs updating
                if (isset($current_files[$objectId]['lastModificationDate'])){
                    $lastModifiedCMIS = strtotime($object_data['cmis:lastModificationDate']);
                    $lastModifiedMetadata = str_replace('/', '-', $current_files[$objectId]['lastModificationDate']);
                    $lastModifiedMetadata = strtotime($lastModifiedMetadata);
                    
                    if ($lastModifiedCMIS > $lastModifiedMetadata){
                        $sync_info['update_assetids'][] = Array(
                                                                    'object_data'           => $object_data,
                                                                    'assetid'               => $assetid
                                                                );
                    }
                }
            } else {//mark for creation
                $sync_info['create_objectIds'][] = $object_data;
            }
        }
        
        //anything unmarked mark for deletion.
        foreach ($current_files as $objectid => $info){
            if (!in_array($info['assetid'], $dont_delete)) {
                $sync_info['delete_assetids'][] = $info['assetid'];
            }
        }
        
        return $sync_info;
        
    }//end synchronizeCheck()
    
    
    public function getCurrentFileInfo()
    {
        $file_info = Array();
        
        $mm = $GLOBALS['SQ_SYSTEM']->getMetadataManager();
        $metadata_fields = $this->attr('metadata_fields');
        if (!empty($metadata_fields['cmis:objectId']['field'])) $sync_fields['objectId'] = $metadata_fields['cmis:objectId']['field'];
        if (!empty($metadata_fields['cmis:lastModificationDate']['field'])) $sync_fields['lastModificationDate'] = $metadata_fields['cmis:lastModificationDate']['field'];
        
        if (!isset($sync_fields['objectId'])) return $file_info;
        $field_names = $GLOBALS['SQ_SYSTEM']->am->getAssetInfo(array_values($sync_fields), 'metadata_field', FALSE, 'name');
        
        $files = $GLOBALS['SQ_SYSTEM']->am->getChildren($this->id, 'file', FALSE);
        foreach (array_keys($files) as $file_id){
            $metadata_values = $mm->getMetadataFieldValues($file_id, array_values($field_names));
            $objectId = $metadata_values[$field_names[$sync_fields['objectId']]];
            if (!empty($objectId)) {
                $file_info[$objectId]['assetid'] = $file_id;
                if (isset($sync_fields['lastModificationDate'])){
                    $lastModificationDate = $metadata_values[$field_names[$sync_fields['lastModificationDate']]];
                    if (!empty($lastModificationDate)) $file_info[$objectId]['lastModificationDate'] = $lastModificationDate;
                }
            }
        }
        
        return $file_info;
    }//end getCurrentFileInfo()
    
    
    public function getAvailableDocumentFields()
    {
        $fields = Array();
        if (!$this->connect('RepositoryService')) return $fields;
        
        $repositoryId = $this->getRepositoryId();
        if (empty($repositoryId)) return $fields;
        
        $type_def = $this->soap['RepositoryService']->getTypeDefinition($repositoryId, 'cmis:document');
        if(!isset($type_def->type->q1id) || (string)$type_def->type->q1id != 'cmis:document') return $fields;
        
        $properties = Array (   
                                'q1propertyBooleanDefinition',
                                'q1propertyDateTimeDefinition',
                                'q1propertyDecimalDefinition',
                                'q1propertyIdDefinition',
                                'q1propertyIntegerDefinition',
                                'q1propertyStringDefinition'
                            );

        $cmis_fields = Array (
                                'cmis:objectId',
                                'cmis:lastModificationDate',
                                'cmis:createdBy',
                                'cmis:creationDate'
                            );
        foreach($properties as $propertyType) {
            if (isset($type_def->type->$propertyType)){ 
                $type = str_replace('Definition', '', substr($propertyType, 10));
                foreach($type_def->type->$propertyType as $property){
                    $propertyId = (string)$property->q1id;
                    if (strpos($propertyId, 'cmis:') !== FALSE && !in_array($propertyId, $cmis_fields)) continue;
                    $fields[$propertyId] = Array ( 
                                                            'display_name' => (string)$property->q1displayName,
                                                            'type'         => $type,
                                                            'field'        => ''
                                                        );
                }
            }
        }
        
        return $fields;
        
    }//end getAvailableDocumentFields()
    
    
    public function getRepositoryId()
    {
        $repositoryId = '';
        
        if (!$this->connect('RepositoryService')) return $repositoryId;
        
        $repositories = $this->soap['RepositoryService']->getRepositories();
        if(!isset($repositories->repositories)) return $repositoryId;
        
        foreach($repositories->repositories as $repository){
            if ($repository->repositoryName == $this->attr('repository_name')){
                $repositoryId = (string)$repository->repositoryId;
                break;
            }
        }
        
        return $repositoryId;
    }//end getRepositoryId()

    
    public function getRootFolderId($repositoryId)
    {   
        $folderId = '';
        if (!$this->connect('RepositoryService')) return $folderId;
        
        $repositoryInfo = $this->soap['RepositoryService']->getRepositoryInfo($repositoryId);
        if (isset($repositoryInfo->repositoryInfo->rootFolderId)) $folderId = (string)$repositoryInfo->repositoryInfo->rootFolderId;
        
        return $folderId;
    }//end getRootFolderId()

    
    public function getFolderChildren($repositoryId, $folderId)
    {
        $children_data = Array();
        if (!$this->connect('NavigationService')) return FALSE;
        
        $children =  $this->soap['NavigationService']->getChildren($repositoryId, $folderId);
        if (isset($children->objects->numItems)){
            if ((int)$children->objects->numItems == 0) return $children_data;
        } 
        if (!isset($children->objects->objects)) return FALSE;
        
        $key = 0;
        $properties = Array (   
                                'propertyBoolean',
                                'propertyDateTime',
                                'propertyDecimal',
                                'propertyId',
                                'propertyInteger',
                                'propertyString'
                            );
        foreach ($children->objects->objects as $object){
            foreach($properties as $propertyType) {
                if (isset($object->object->properties->$propertyType)){
                    foreach($object->object->properties->$propertyType as $property){
                        $attributes = $property->attributes();
                        $children_data[$key][(string)$attributes['propertyDefinitionId']] = (string)$property->value;
                    }
                }
            }
            $key++;
        }
        
        
        return $children_data;
    }//end getFolderChildren()

    
    public function getObjectContents($repositoryId, $objectId)
    {
        $binary_data = '';
        if (!$this->connect('ObjectService')) return $binary_data;
        
        $binary_data = $this->soap['ObjectService']->getContentStream($repositoryId, $objectId);
        return $binary_data;

    }//end getObjectContents()
    
    
}//end class
?>