se/SE/se-lib/Core/AclSimpleSchemaBase.php

<?php

Lib::loadClass('Api_WfsNs');
Lib::loadClass('Api_WfsException');
Lib::loadClass('User');
Lib::loadClass('Core_AclHelper');
Lib::loadClass('Core_AclBase');

class Core_AclSimpleSchemaBase extends Core_AclBase {

  /** simpleSchema - php structure:

    $simpleSchema = [
      'root' => [
        '@namespace' => 'default_db/ZALICZKA/Zaliczka',

        'ID' => 'xsd:integer', // short syntax - define only simpleType

        'KWOTA' => [ // long syntax - define type with another params like restrictions
          '@type' => 'xsd:decimal'
        ],

        'worker' => 'ref:Worker' // short syntax - define only type = ref

        'pozycja' => [ // long syntax - define ref with maxOccurs, TODO: use more xsd attributes
          '@ref' => 'ZaliczkaPozycja',
          '@maxOccurs' => 'unbounded'
        ]
      ],
      'Worker' => [
        '@namespace' => 'default_objects/AccessOwner',
        ...
      ],
      'ZaliczkaPozycja' => [
        '@namespace' => 'default_db/ZALICZKA_POZYCJA/ZaliczkaPozycja',
        ...
      ]
    ]
   */
  public $_simpleSchema = array();
  public $_xsdTypes = null;// set by parseXsdTypes()
  public $_name = '';
  public $_rootTableName = '';
  public $_xmlnsMap = [];

  public function __construct($simpleSchema = null) {
    if ($simpleSchema) $this->_simpleSchema = $simpleSchema;

    if (!$this->_simpleSchema) throw new Exception("Missing simpleSchema");
    if (empty($this->_simpleSchema['root'])) throw new Exception("Wrong simpleSchema syntax");
    if (empty($this->_simpleSchema['root']['@namespace'])) throw new Exception("Missing @namespace in simpleSchema");
    $ns = explode('/', $this->_simpleSchema['root']['@namespace']);
    $this->_name = end($ns);
    if (count($ns) < 2) throw new Exception("Wrong @namespace syntax in simpleSchema");
    $this->_rootTableName = $ns[1];

    // $this->parseXsdTypes();// parse xsdTypes
    $this->_xsdTypes = array();
    {
      $generatedIdZasob = 10000;// fake zasob id
      foreach ($this->_simpleSchema['root'] as $key => $value) {
        if ('@' == substr($key, 0, 1)) continue;// skip attributes
        if (is_array($value)) {
          $fieldName = $key;
          $field = [ 'name' => $fieldName, 'perms' => '', 'idZasob' => $generatedIdZasob ];

          if (!empty($value['@type'])) $field['xsdType'] = "{$value['@type']}";
          else if (!empty($value['@ref'])) $field['xsdType'] = "ref:{$value['@ref']}";
          else throw new Exception("StorageAcl - field type not defined '{$key}'");

          if (!empty($value['@maxOccurs'])) $field['maxOccurs'] = $value['@maxOccurs'];
          $this->_xsdTypes[$fieldName] = $field;
        } else if (is_scalar($value)) {// short syntax: $fieldName => $xsdType
          $fieldName = $key;
          $field = [ 'name' => $fieldName, 'perms' => '', 'idZasob' => $generatedIdZasob ];
          $field['xsdType'] = $value;
          $this->_xsdTypes[$fieldName] = $field;
        } else {
          throw new Exception("StorageAcl - TODO: Unimplemented value type in simpleSchema: " . json_encode($value));
        }
        $generatedIdZasob++;
      }
    }

    // TODO: fix 'ref:*' types - use Core_AclHelper::parseNamespaceUrl($namespace)

  }

  public function getSimpleSchema() { return $this->_simpleSchema; }
  public function getName() { return $this->_name; }
  public function getRootTableName() { $this->_rootTableName; }
  public function getXsdTypes() { return $this->_xsdTypes; }

  public function getNamespace() { return 'default_db/' . $this->_rootTableName . '/' . $this->_name; }
  public function getSourceName() { return 'default_db__x3A__' . $this->_rootTableName; }
  public function init($force = false) {}
  public function isInitialized() { return true; }
  public function getFieldListByIdZasob() { return $this->getRealFieldListByIdZasob(); }
  public function getVisibleFieldListByIdZasob() { return $this->getRealFieldListByIdZasob(); }
  public function getVirtualFieldListByIdZasob() { return array(); }
  public function getRealFieldListByIdZasob($force = false) {
    $cols = array();
    foreach ($this->getFields() as $idField => $field) {
      $cols[$idField] = $field['name'];
    }
    return $cols;
  }
  public function getFields() {// @returns array - $this->_fields
    $fieldsById = array();
    foreach ($this->getXsdTypes() as $fieldName => $field) {
      $field['name'] = $fieldName;
      $fieldsById[ $field['idZasob'] ] = $field;
    }
    return $fieldsById;
  }
  public function getFieldType($fieldName) {
    foreach ($this->getFields() as $field) {
      if ($fieldName == $field['name']) return $field;
    }
    return null;
	}

  // TODO: replace legacy functions: isAllowed, hasFieldPerm, getFieldIdByName
  public function canCreateField($fieldName) {
    return false;// TODO: perms from Procesy
  }
  public function canReadField($fieldName) {
    return true;// TODO: perms from Procesy
  }
  public function canReadObjectField($fieldName, $record) {
    return true;// TODO: perms from Procesy
  }
  public function canWriteField($fieldName) {
    return false;// TODO: perms from Procesy
  }
  public function canWriteObjectField($fieldName, $record) {
    return false;// TODO: perms from Procesy
  }

  public function getTotal($params = array()) {// TODO: use ParseOgcQuery
    throw new Exception("Unimplemented - TODO: F." . __FUNCTION__);
  }
  public function getItem($primaryKey) {
    throw new Exception("Unimplemented - TODO: F." . __FUNCTION__);
  }
  public function getItems($params = array()) {// TODO: use ParseOgcQuery
    throw new Exception("Unimplemented - TODO: F." . __FUNCTION__);
  }
  public function fetchItemRef(&$items) {
    throw new Exception("Unimplemented - TODO: F." . __FUNCTION__);
  }
  public function addItem($itemTodo) {
    throw new Exception("Unimplemented - TODO: F." . __FUNCTION__);
    // return $this->parentAcl->addItem($itemTodo);
  }
  public function updateItem($itemPatch) {
    throw new Exception("Unimplemented - TODO: F." . __FUNCTION__);
    // return $this->parentAcl->updateItem($itemPatch);
  }

  public function getGeomFieldType($fieldName) { return null; }
  public function getPrimaryKeyField() { return 'ID'; }
  public function getID() { return 0; }
  public function getAttributesFromZasoby() { return array(); }
  public function isEnumerationField($fieldName) { return false; }
  public function getEnumerations($fieldName) { return null; }
  public function getXsdFieldType($fieldName) {
    $xsdTypes = $this->getXsdTypes();
    if (empty($xsdTypes[$fieldName])) throw new Exception("Field '{$fieldName}' not exists");
    return $xsdTypes[$fieldName]['xsdType'];
  }
  public function isGeomField($fldName) {
    if ('File' == $fieldName) return false;
    if ('AccessGroupRead' == $fieldName) return false;
    if ('AccessGroupWrite' == $fieldName) return false;
    if ('AccessOwner' == $fieldName) return false;
    // if ('NestedObjectTest' == $fieldName) return false;
    // return $this->parentAcl->isGeomField($fldName);
  }

}