<?php

/**

* @file

* Maps entity types to Open Data schemas.

*/

$module_path = drupal_get_path('module', 'open_data_schema_map');

require_once $module_path . '/open_data_schema_map.file_cache.inc';

define('OPEN_DATA_SCHEMA_MAP_ADMIN_PATH', 'admin/config/services/odsm');

/**

* Class OpenDataSchemaMapException

*/

class OpenDataSchemaMapException extends Exception {

private $data;

/**

* Override Exception constructor to add data parameter.

*

* {@inheritdoc}

*/

public function __construct($message, $code = 0, $data = NULL) {

parent::__construct($message, $code);

$this->data = !empty($data) ? $data : $message;

}

/**

* Returns the data associated with the exception.

*/

public function getData() {

return $this->data;

}

/**

* Returns HTTP status error given a code.

*/

public function getHTTPError() {

$code = $this->getCode();

switch ($code) {

case 400:

return '400 Bad Request';

case 403:

return '403 Forbidden';

case 404:

return '404 Not Found';

case 406:

return '406 Not Acceptable';

case 412:

return '412 Precondition Failed';

case 422:

return '422 Unprocessable Entity';

default:

return '500 Internal Server Error';

}

}

}

/**

* Implements hook_menu().

*/

function open_data_schema_map_menu() {

$items = array();

$pre = OPEN_DATA_SCHEMA_MAP_ADMIN_PATH;

$apis = open_data_schema_map_api_load_all();

if ($apis) {

foreach ($apis as $num => $api) {

$description = isset($api->description) ? $api->description : '';

if ($api->enabled) {

$items[$api->endpoint] = array(

'title' => $api->name,

'description' => $description,

'page callback' => 'open_data_schema_map_endpoint',

'page arguments' => array($api),

'access arguments' => array('access content'),

'file' => 'open_data_schema_map.pages.inc',

);

}

}

}

$items[$pre] = array(

'title' => 'Open Data Schema Mapper',

'description' => 'Map Drupal structures to Open Data specfications',

'page callback' => 'open_data_schema_map_page_overview',

'access arguments' => array('administer open data schema mapper'),

'file' => 'open_data_schema_map.pages.inc',

);

$items[$pre . '/overview'] = array(

'title' => 'Overview',

'type' => MENU_DEFAULT_LOCAL_TASK,

);

$items[$pre . '/add/api'] = array(

'title' => 'Add API',

'description' => 'Add a new API Endpoint',

'page callback' => 'drupal_get_form',

'page arguments' => array('open_data_schema_map_manage'),

'access arguments' => array('administer open data schema mapper'),

'file' => 'open_data_schema_map.pages.inc',

'type' => MENU_LOCAL_ACTION,

);

$items[$pre . '/settings'] = array(

'title' => 'Settings',

'description' => 'Open Data Schema Map Settings',

'page callback' => 'drupal_get_form',

'page arguments' => array('open_data_schema_map_admin_settings_form'),

'access arguments' => array('administer open data schema mapper'),

'file' => 'open_data_schema_map.admin.inc',

'type' => MENU_LOCAL_ACTION,

);

$items[$pre . '/edit/%open_data_schema_map_api'] = array(

'title' => 'Edit API',

'description' => 'Edit an existing API Endpoint',

'page callback' => 'drupal_get_form',

'page arguments' => array('open_data_schema_map_manage', 5),

'access arguments' => array('administer open data schema mapper'),

'file' => 'open_data_schema_map.pages.inc',

);

$items[$pre . '/cache/%open_data_schema_map_api'] = array(

'title' => 'API Cache File',

'description' => 'Administer an existing API Endpoint File Cache',

'page callback' => 'drupal_get_form',

'page arguments' => array('open_data_schema_map_cache_manage', 5),

'access arguments' => array('administer open data schema mapper'),

'file' => 'open_data_schema_map.file_cache.inc',

);

$items[$pre . '/delete/%open_data_schema_map_api'] = array(

'title' => 'Delete API',

'description' => 'Delete an existing API Endpoint',

'page callback' => 'drupal_get_form',

'page arguments' => array('open_data_schema_map_delete', 5),

'access arguments' => array('administer open data schema mapper'),

'file' => 'open_data_schema_map.pages.inc',

);

// Read validation implementation and add to menu.

foreach (module_implements('open_data_schema_map_validation') as $module) {

$data = module_invoke($module, 'open_data_schema_map_validation');

$path = OPEN_DATA_SCHEMA_MAP_ADMIN_PATH . '/validate/' . $data['name'];

$items[$path] = array(

'title' => $data['title'],

'page callback' => $data['page callback'],

'page arguments' => array(),

'access arguments' => array('administer open data schema mapper'),

'type' => MENU_NORMAL_ITEM,

'file' => $data['file'],

'file path' => $data['file path'],

);

}

return $items;

}

/**

* Implements hook_permission().

*/

function open_data_schema_map_permission() {

return array(

'administer open data schema mapper' => array(

'title' => t('Administer Open Data Schema Mapper'),

'description' => t('Make and update open data schema maps'),

'restrict access' => TRUE,

));

}

/**

* Implements hook_libraries_info().

*/

function open_data_schema_map_libraries_info() {

$libraries['symfonyserializer'] = array(

'name' => 'Simfony Serializer',

'vendor url' => 'https://github.com/symfony/serializer',

'download url' => 'https://github.com/symfony/serializer/zipball/master',

'version' => 'master',

'files' => array(),

);

$libraries['json-schema'] = array(

'name' => 'Justinrainbow JSON-Schema',

'vendor url' => 'https://github.com/justinrainbow/json-schema.git',

'download url' => 'https://github.com/justinrainbow/json-schema/tree/master/src/JsonSchema',

'version' => 'master',

'files' => array(),

);

return $libraries;

}

/**

* Registers declared schemas.

*/

function open_data_schema_map_register() {

static $schemas = array();

if ($schemas) {

return $schemas;

}

foreach (module_implements('open_data_schema') as $module) {

$module_schemas = module_invoke($module, 'open_data_schema');

foreach ($module_schemas as $schema) {

$schemas[$schema['short_name']] = $schema;

}

}

return $schemas;

}

/**

* Implements hook_help().

*/

function open_data_schema_map_help($path, $arg) {

switch ($path) {

case 'admin/config/services/odsm':

return t('Create APIs using Drupal entities that map to Open Data specifications. See !docs for more instructions.',

array('!docs' => l(t('documentation'), 'https://github.com/NuCivic/open_data_schema_map#open-data-schema-map')));

}

return NULL;

}

/**

* Provides form type from field type.

*

* @param string $field_type

* Field type

*

* @return string

* Form type

*/

function open_data_schema_map_form_field_type($field_type) {

switch ($field_type) {

case "string":

return 'textfield';

}

return '';

}

/**

* Recursive function to generate mapping form.

*

* @param array $form

* Form api ready array to build.

* @param array $schema

* Schema array which is reduced.

* @param object $api

* $api object which is passed around because procedural.

* @param array $defaults

* Array of defaults which matches up with the $schema.

*

* @return array

* Form array

*/

function open_data_schema_map_form_recursion(&$form, $schema, $api, $defaults = NULL) {

$entity_ref_fields = open_data_schema_map_entity_ref_fields($api->type, $api->bundle);

foreach ($schema as $key => $value) {

// Skip if not a top level item.

if (!is_array($value)) {

continue;

}

if (count($value) == count($value, COUNT_RECURSIVE)) {

$desc = isset($value['description']) ? $value['description'] : '';

$description = t('Machine name: %machine_name field type: %type description: %desc', array(

'%machine_name' => $key, '%type' => $value['type'], '%desc' => $desc));

$default = isset($defaults[$key]) ? $defaults[$key] : '';

$form[$key] = array(

'#title' => $value['title'],

'#type' => 'textfield',

'#maxlength' => 512,

'#description' => $description,

'#default_value' => $default,

);

}

elseif ($key) {

$form[$key] = array(

'#title' => $key,

'#type' => 'fieldset',

'#collapsible' => TRUE,

);

$entity_ref_fields = open_data_schema_map_entity_ref_fields($api->type, $api->bundle);

if ($value['type'] == 'array' && $entity_ref_fields) {

$odsm_entity_reference = isset($defaults[$key]['odsm_entity_reference']['value']) ? $defaults[$key]['odsm_entity_reference']['value'] : '';

$osd_key_map = $odsm_entity_reference ? open_data_schema_map_token_tree('[node:' . str_replace('_', '-', $odsm_entity_reference) . ']') : '';

$form[$key]['odsm_entity_reference'] = array(

'#title' => $key . ' Multivalue Field',

'#type' => 'select',

'#options' => array('' => t('-- none --')) + $entity_ref_fields,

'#default_value' => $odsm_entity_reference,

'#description' => t('This array can iterate over multi-value fields as long as they are an entity reference. Select entity reference field to use. If none is selected this output will not loop and accept single value tokens. "Nth" represents iteratable tokens.') . $osd_key_map,

);

}

open_data_schema_map_form_recursion($form[$key], $schema[$key], $api, $defaults[$key]);

}

}

return $form;

}

/**

* Recursive function that walks throw tokens to output rows.

*

* @param array $rows

* Output rows

* @param array $token_info

* Tokens

*/

function open_data_schema_map_token_rows(&$rows, $token_info) {

if (isset($token_info['children'])) {

foreach ($token_info['children'] as $token_child => $token_child_info) {

if (is_array($token_child_info)) {

$token_child = str_replace('1', 'Nth', $token_child);

$token_child_info['name'] = str_replace('1', 'Nth', $token_child_info['name']);

$token_child_info['raw token'] = str_replace('1', 'Nth', $token_child_info['raw token']);

$token_child_info['token'] = str_replace('1', 'N', $token_child_info['token']);

$token_child_info['description'] = str_replace('1', 'Nth', $token_child_info['description']);

$token_child_info['parent'] = str_replace('1', 'Nth', $token_child_info['parent']);

$row = _token_token_tree_format_row($token_child, $token_child_info);

unset($row['data']['value']);

$rows[] = $row;

if (isset($token_info['children'])) {

open_data_schema_map_token_rows($rows, $token_child_info);

}

}

}

}

}

/**

* Creates token tree for single token.

*

* @param string $token

* Token

*

* @return string

* Rendered token

*/

function open_data_schema_map_token_tree($token) {

module_load_include('inc', 'token', 'token.pages');

$tree = token_build_tree('node');

if (!isset($tree[$token])) {

$token = substr($token, 0, -1) . ":?]";

}

if (isset($tree[$token])) {

$token_info = $tree[$token];

if (isset($token_info['children'])) {

$shifted = array_shift($token_info['children']);

$token_info['children'] = array($shifted['raw token'] => $shifted);

}

$row = _token_token_tree_format_row($token, $token_info);

unset($row['data']['value']);

$rows = array($row);

open_data_schema_map_token_rows($rows, $token_info);

$element = array(

'#theme' => 'tree_table',

'#header' => array(

t('Name'),

t('Token'),

t('Description'),

),

'#rows' => $rows,

'#attributes' => array('class' => array('token-tree')),

'#empty' => t('No tokens available'),

'#attached' => array(

'js' => array(drupal_get_path('module', 'token') . '/token.js'),

'css' => array(drupal_get_path('module', 'token') . '/token.css'),

'library' => array(array('token', 'treeTable')),

),

);

$element['#caption'] = t("Click a token to insert it into the field you've last clicked.");

$element['#attributes']['class'][] = 'token-click-insert';

return drupal_render($element);

}

return '';

}

/**

* Lists APIs created with this module.

*/

function open_data_schema_map_api_table() {

$apis = open_data_schema_map_api_load_all();

foreach ($apis as $num => $api) {

unset($apis[$num]->id);

unset($apis[$num]->description);

unset($apis[$num]->mapping);

unset($apis[$num]->arguments);

$apis[$num]->edit = l(t('edit'), 'admin/config/services/odsm/edit/' . $api->machine_name);

$apis[$num]->cache = open_data_schema_map_file_cache_admin_link($api);

}

return $apis;

}

/**

* Determines whether a machine name exists.

*

* @param string $machine_name

* API machine name.

*

* @return bool

* Returns FALSE

*/

function open_data_schema_map_api_exist($machine_name) {

return FALSE;

}

/**

* Loads all APIs.

*/

function open_data_schema_map_api_load_all() {

$list = array();

$records = &drupal_static(__FUNCTION__, array());

if ($records) {

return $records;

}

$results = db_query("select machine_name from {open_data_schema_map}")->fetchAll();

foreach ($results as $result) {

$list[] = $result->machine_name;

}

drupal_alter('open_data_schema_map_endpoints', $list);

foreach ($list as $item) {

$records[] = open_data_schema_map_api_load($item);

}

return $records;

}

/**

* Loads API.

*

* @param string $machine_name

* API machine name.

*

* @return object

* API object.

*/

function open_data_schema_map_api_load($machine_name) {

if ($record = module_invoke_all('open_data_schema_map_load', $machine_name)) {

return $record[0];

}

elseif ($record = db_query("select * from {open_data_schema_map} where machine_name = :machine_name", array(':machine_name' => $machine_name))->fetchObject()) {

$record->mapping = unserialize($record->mapping);

$record->arguments = unserialize($record->arguments);

return $record;

}

return NULL;

}

/**

* Loads schema from file.

*

* @param string $schema_name

* Schema name

*

* @return array

* Schema array

*/

function open_data_schema_map_schema_load($schema_name) {

$schemas = &drupal_static(__FUNCTION__, array());

if ($schemas) {

return $schemas;

}

$schemas = open_data_schema_map_register();

$loaded_schema = $schemas[$schema_name];

$json_file = $loaded_schema['schema_file'];

$json = file_get_contents($json_file);

$schema = drupal_json_decode($json);

foreach (module_implements('open_data_schema_fill_references') as $module) {

$hook_implementation = $module . '_open_data_schema_fill_references';

$hook_implementation($schema_name, $schema);

}

return $schema;

}

/**

* Retrieves public, published dataset nodes.

*

* @param object $api

* Api object.

* @param int $limit

* Number of results to return.

* @param int $offset

* Offset of results to return.

* @param array $args

* - query: current value of query.

* - value: value field

* - token: token to get data from

*

* @return array

* An array of dataset nodes.

*/

function open_data_schema_map_endpoint_query($api, $limit = 0, $offset = 0, $args = array()) {

$type = $api->type;

$bundle = $api->bundle;

$args = is_array($args) ? $args : array($args);

$query = new EntityFieldQuery();

$query->entityCondition('entity_type', $type)

->entityCondition('bundle', $bundle)

->propertyCondition('status', 1)

->propertyOrderBy('created', 'DESC')

// Run the query as user 1.

->addMetaData('account', user_load(1));

if ($limit) {

$query->range($offset, $limit);

}

foreach ($args as $arg => $arg_value) {

$field = open_data_schema_map_discover_field($arg_value['token']['value']);

drupal_alter('open_data_schema_map_args', $field, $arg_value, $api->machine_name);

// Pass conditions if no queries.

if (!isset($arg_value['query']) || !$arg_value['query']) {

continue;

}

if (!empty($field) && $field[0] == 'node') {

if (substr($field[1], 0, 5) == 'field' || $field[1] == 'og_group_ref') {

$query->fieldCondition($field[1], $arg_value['value'], $arg_value['query']);

}

else {

$query->propertyCondition($field[1], $arg_value['query']);

}

}

}

drupal_alter('open_data_schema_map_endpoint_query', $query, $api->machine_name);

$entities = $query->execute();

$ids = NULL;

if ($entities) {

$ids = array_keys($entities[$type]);

}

return $ids;

}

/**

* Returns array from token.

*

* @param string $token

* Token

*

* @return array

* Array from token

*/

function open_data_schema_map_discover_field($token) {

$token = rtrim(trim($token, '['), ']');

return explode(':', $token);

}

/**

* Discovers callback for argument options.

*

* @param string $id

* Argument option

*

* @return string

* Callback

*/

function open_data_schema_map_schema_options_callback($id) {

$schema_types = open_data_schema_map_schema_types();

foreach ($schema_types as $schema_type => $data) {

if ($data['id'] == $id) {

return $data['options_callback'];

}

}

return NULL;

}

/**

* Discovers callback for schema type.

*

* @param string $id

* Schema type

*

* @return string

* Callback

*/

function open_data_schema_map_schema_types_callback($id) {

$schema_types = open_data_schema_map_schema_types();

foreach ($schema_types as $schema_type => $data) {

if ($data['id'] == $id) {

return $data['callback'];

}

}

return NULL;

}

/**

* Creates array of schema types.

*/

function open_data_schema_map_schema_types() {

$schemas = array(

'json-4' => array(

'id' => 'http://json-schema.org/draft-04/schema#',

'callback' => 'open_data_schema_map_json_4',

'options_callback' => 'open_data_schema_mapper_args_options_json_4',

),

'json-3' => array(

'id' => 'http://json-schema.org/draft-03/schema#',

'callback' => 'open_data_schema_map_json_3',

'options_callback' => 'open_data_schema_mapper_args_options_json_3',

),

);

drupal_alter('open_data_schema_map_schema_types', $schemas);

return $schemas;

}

/**

* Creates argument form.

*

* @param int $num_args

* Number of args

* @param array $options

* Options array

* @param array $defaults

* Defaults array

* @param object $api

* API Object

*

* @return array

* Form array

*/

function open_data_schema_map_args_form($num_args, $options, $defaults, $api) {

$map = $api->mapping;

$form = $columns = array();

for ($i = 1; $i <= $num_args; $i++) {

if (isset($defaults[$i]['field']) &&

isset($map[$defaults[$i]['field']]['value']) &&

$token = $map[$defaults[$i]['field']]['value']) {

$token = open_data_schema_map_discover_field($token);

if ($token[0] == 'node') {

if (substr($token[1], 0, 5) == 'field') {

$field = str_replace('-', '_', $token[1]);

$field_info = field_info_field($field);

foreach ($field_info['columns'] as $column => $data) {

$columns[$column] = $column;

}

}

}

}

$form[$i] = array(

'#title' => 'Argument ' . $i,

'#type' => 'fieldset',

);

$form[$i]['field'] = array(

'#title' => 'Schema Field',

'#type' => 'select',

'#description' => t('Schema field to use as an argument. The schema field is the "key" in /endpoint?key=123456. Also available are special arguments "offset" and "limit."'),

'#options' => $options,

'#default_value' => isset($defaults[$i]['field']) ? $defaults[$i]['field'] : '',

);

$form[$i]['required'] = array(

'#title' => 'Required',

'#type' => 'checkbox',

'#description' => t('Whether argument is required.'),

'#default_value' => isset($defaults[$i]['required']) ? $defaults[$i]['required'] : 1,

);

$special_args = open_data_schema_map_special_arguments();

if (isset($defaults[$i]['field']) && isset($special_args[$defaults[$i]['field']])) {

$form[$i]['value'] = array(

'#title' => 'Default ' . $special_args[$defaults[$i]['field']] . ' Value',

'#type' => 'textfield',

'#description' => t('Defaut value for !value. IE /endpoint?%field=X.', array('!value' => $special_args[$defaults[$i]['field']], '%field' => $defaults[$i]['field'])),

'#default_value' => isset($defaults[$i]['value']) ? $defaults[$i]['value'] : '',

);

}

else {

if ($columns) {

$form[$i]['value'] = array(

'#title' => 'Schema Field Column',

'#type' => 'select',

'#options' => $columns,

'#description' => t('Value for schema field. Only for tokens with [nodes:field_FIELD_NAME]. This is the column name in the field table to grab. Defaults to "safe_value".'),

'#default_value' => isset($defaults[$i]['value']) ? $defaults[$i]['value'] : '',

);

}

}

}

return $form;

}

/**

* Special fields for arguments.

*

* @return array

* Array of arguments

*/

function open_data_schema_map_special_arguments() {

return array(

'offset' => t('offset'),

'limit' => t('limit'),

);

}

/**

* Finds entity reference fields for a given bundle.

*

* @param string $entity

* Entity machine name.

* @param string $bundle

* Bundle machine name.

* @param array $ref_fields

* List of fields

*

* @return array

* Array of entity reference or similar fields.

*/

function open_data_schema_map_entity_ref_fields($entity, $bundle, $ref_fields = array('entityreference', 'taxonomy')) {

// Get instances.

$instances = field_info_instances($entity, $bundle);

// Get reference fields.

$query = db_select('field_config', 'f');

$query->fields('f', array('field_name'));

$or = db_or();

$or->condition('cardinality', '1', '>');

$or->condition('cardinality', '-1', '=');

$query->condition($or);

$query->distinct();

$rows = $query->execute();

$field_names = array();

foreach ($rows as $row) {

$field_name = $row->field_name;

// See if reference field is used in bundle.

if (isset($instances[$field_name])) {

$field_names[$field_name] = $instances[$field_name]['label'];

}

}

return $field_names;

}

/**

* Creates form from JSON 4 schema.

*

* @param array $schema

* Schema array

* @param object $api

* API object

* @param array $defaults

* Array of defaults

*

* @return array

* Form array

*/

function open_data_schema_map_json_4($schema, $api, $defaults) {

$form = array();

$form['#title'] = $schema['title'] ? $schema['title'] : t('Mapping');

$form['#description'] = $schema['description'] ? $schema['description'] : t('Fields to map.');

$form['#type'] = 'fieldset';

foreach ($schema['properties'] as $item => $data) {

if (!isset($data['type'])) {

if (isset($data['anyOf'][0]['type'])) {

$data['type'] = $data['anyOf'][0]['type'];

}

else {

$data['type'] = 'string';

}

}

$desc = isset($data['description']) ? $data['description'] . t('Type:') . $data['type'] : t('Type:') . $data['type'];

$form[$item] = array(

'#title' => $data['title'] . ' (' . $item . ')',

'#type' => 'textfield',

'#maxlength' => 512,

'#description' => $desc,

'#default_value' => isset($defaults[$item]['value']) ? $defaults[$item]['value'] : '',

'#field_type' => $data['type'],

);

if ($data['type'] == 'array' && isset($data['anyOf'][0]['items']['type']) && $data['anyOf'][0]['items']['type'] == 'object') {

$entity_ref_fields = open_data_schema_map_entity_ref_fields($api->type, $api->bundle);

$odsm_entity_reference = isset($defaults[$item]['odsm_entity_reference']['value']) ? $defaults[$item]['odsm_entity_reference']['value'] : '';

$osd_key_map = $odsm_entity_reference ? open_data_schema_map_token_tree('[node:' . str_replace('_', '-', $odsm_entity_reference) . ']') : '';

$form[$item] = array(

'#title' => $data['title'],

'#type' => 'fieldset',

'#description' => isset($data['description']) ? $data['description'] : '',

);

$form[$item]['odsm_entity_reference'] = array(

'#title' => $item . ' Multivalue Field',

'#type' => 'select',

'#options' => array('' => t('-- none --')) + $entity_ref_fields,

'#default_value' => $odsm_entity_reference,

'#description' => t('This array can iterate over multi-value fields. Select multi-value field to use. If none is selected this output will not loop and accept single value tokens. Selecting and saving an entity reference will produce a list of chaiabale tokens. For non entity reference fields, replace "?" with "Nth:value". "Nth" represents iteratable tokens.') . $osd_key_map,

);

foreach ($data['anyOf'][0]['items']['properties'] as $subitem => $subdata) {

$desc = isset($subdata['description']) ? $subdata['description'] : '';

$desc .= isset($subdata['type']) ? ' ' . t('Type:') . $subdata['type'] : '';

$form[$item][$subitem] = array(

'#title' => $subdata['title'] . ' (' . $subitem . ')',

'#type' => 'textfield',

'#maxlength' => 256,

'#description' => $desc,

'#default_value' => isset($defaults[$item][$subitem]['value']) ? $defaults[$item][$subitem]['value'] : '',

);

}

}

if ($data['type'] == 'object') {

$description = '';

if (isset($data['description'])) {

$description = $data['description'];

}

$form[$item] = array(

'#title' => $data['title'],

'#type' => 'fieldset',

'#description' => $description,

);

if (isset($data['properties'])) {

foreach ($data['properties'] as $subitem => $subdata) {

$desc = isset($subdata['description']) ? $subdata['description'] : '';

$desc .= isset($subdata['type']) ? ' ' . t('Type:') . $subdata['type'] : '';

$form[$item][$subitem] = array(

'#title' => $subdata['title'] . ' (' . $subitem . ')',

'#type' => 'textfield',

'#maxlength' => 512,

'#description' => $desc,

'#default_value' => isset($defaults[$item][$subitem]['value']) ? $defaults[$item][$subitem]['value'] : '',

);

}

}

}

}

return $form;

}

/**

* Constructs form for json schema 3.

*

* @param array $form

* Form array

* @param array $schema

* Schema

* @param object $api

* API object

* @param array $defaults

* Array of defaults

*/

function open_data_schema_map_json_3_recursion(&$form, $schema, $api, $defaults = NULL) {

foreach ($schema as $item => $data) {

$default_value = isset($defaults[$item]['value']) ? $defaults[$item]['value'] : '';

// Skip if not a top level item.

if (!is_array($data)) {

continue;

}

$field_type = $data['type'] ? $data['type'] : 'string';

$form[$item] = array(

'#title' => $item,

'#type' => 'textfield',

'#maxlength' => 512,

'#description' => $data['description'],

'#field_type' => $field_type,

'#default_value' => $default_value,

);

if ($field_type == 'object' || $field_type == 'array' && $data['items']['type'] == 'object') {

$entity_ref_fields = open_data_schema_map_entity_ref_fields($api->type, $api->bundle);

$odsm_entity_reference = isset($defaults[$item]['odsm_entity_reference']['value']) ? $defaults[$item]['odsm_entity_reference']['value'] : '';

$osd_key_map = $odsm_entity_reference ? open_data_schema_map_token_tree('[node:' . str_replace('_', '-', $odsm_entity_reference) . ']') : '';

$form[$item] = array(

'#title' => $item,

'#type' => 'fieldset',

'#description' => $data['description'],

'#field_type' => $field_type,

);

$form[$item]['odsm_entity_reference'] = array(

'#title' => $item . ' Multivalue Field',

'#type' => 'select',

'#options' => array('' => t('-- none --')) + $entity_ref_fields,

'#default_value' => $odsm_entity_reference,

'#description' => t('This array can iterate over multi-value fields as long as they are an entity reference. Select entity reference field to use. If none is selected this output will not loop and accept single value tokens. "Nth" represents iteratable tokens.') . $osd_key_map,

);

if ($data['type'] == 'object') {

open_data_schema_map_json_3_recursion($form[$item], $data['properties'], $api, $defaults[$item]);

}

elseif ($data['type'] == 'array' && $data['items']['type'] == 'object') {

open_data_schema_map_json_3_recursion($form[$item], $data['items']['properties'], $api, $defaults[$item]);

}

}

}

}

/**

* Creates form from JSON 3 schema.

*

* @param array $schema

* Schema array

* @param object $api

* API object

* @param array $defaults

* Array of defaults

*

* @return array

* Form array

*/

function open_data_schema_map_json_3($schema, $api, $defaults) {

$form = array();

$form['#title'] = t('Mapping');

$form['#description'] = $schema['description'] ? $schema['description'] : t('Fields to map.');

$form['#type'] = 'fieldset';

open_data_schema_map_json_3_recursion($form, $schema['properties'], $api, $defaults);

return $form;

}

/**

* Creates option list from available arguments.

*

* @param array $schema

* Schema array

*

* @return array

* Options array

*/

function open_data_schema_mapper_args_options_json_4($schema) {

$options = array();

foreach ($schema['properties'] as $id => $data) {

$options[$id] = $id;

}

return $options;

}

/**

* Creates option list from available arguments.

*

* @param array $schema

* Schema array

*

* @return array

* Options array

*/

function open_data_schema_mapper_args_options_json_3($schema) {

$options = array();

foreach ($schema['properties'] as $id => $data) {

$options[$id] = $id;

}

return $options;

}

/**

* Wrapper around token_replace.

*

* @param string $token

* Token

* @param string $entity_type

* Entity Type

* @param object $entity

* Entity object

*

* @return string

* Token replaced string

*/

function open_data_schema_mapper_token_replace($token, $entity_type, $entity) {

$rend_tokens = array();

// Does the token have an "or".

$output = '';

if (preg_match('/\] \|\| \[/', $token)) {

$tokens = explode(' || ', $token);

foreach ($tokens as $token) {

if ($output = token_replace($token, array($entity_type => $entity), array('clear' => TRUE))) {

return $output;

}

}

}

// Does the token have an "and".

elseif (preg_match('/\] && \[/', $token)) {

$tokens = explode(' && ', $token);

foreach ($tokens as $token) {

$rend_tokens[] = token_replace($token, array($entity_type => $entity), array('clear' => TRUE));

}

$output = implode(' ', $rend_tokens);

}

else {

$output = token_replace($token, array($entity_type => $entity), array('clear' => TRUE));

}

return $output;

}

/**

* Provides working arguments by validating fields and queries.

*

* @param array $map

* Map array

* @param array $queries

* Queries array

* @param array $args

* Args array

*

* @return array

* Array of args

*/

function open_data_schema_map_endpoint_args(&$map, $queries, $args = array()) {