array( 'title' => t('Can perform experiments'), 'description' => t('Can perform experiments'), ), 'perform inactive experiments' => array( 'title' => t('Can perform INACTIVE experiments'), 'description' => t('Can perform inactive experiments.'), ), ); } function ets_init() { module_load_include('inc', 'ets', 'ets.conditions'); drupal_add_css(drupal_get_path('module', 'ets') . '/css/experiment.css', array('type' => 'file')); drupal_add_js(drupal_get_path('module', 'ets') . '/ets.js'); // Accept custom request header; //drupal_add_http_header('Access-Control-Allow-Headers', 'Authentication'); /* This is needed by Rubedo or in any case you can't set a cookie in the device to check that login is done using the web service. This allows request to be done inserting in header the cookie like 'Authentication: session_name=sessid' */ if (isset($_SERVER['HTTP_AUTHENTICATION'])) { list($session_name, $sessid) = explode('=', $_SERVER['HTTP_AUTHENTICATION']); session_name($$session_name); $_COOKIE[session_name()] = $sessid; _drupal_session_read($sessid); } } /** * Implementation of hook_menu(). */ function ets_menu() { $items = array(); $items['ets/services/watchdog'] = array( 'title' => 'Log a message in the watchdog (ajax)', 'page callback' => 'ets_services_watchdog', 'access arguments' => array('access content'), 'file' => 'ets.services.inc', 'type' => MENU_CALLBACK, ); $items['ets/services/ping'] = array( 'title' => 'We are alive!', 'page callback' => 'ets_services_ping', 'access arguments' => array('access content'), 'file' => 'ets.services.inc', 'type' => MENU_CALLBACK, ); $items['ets/services/instance-scores'] = array( 'title' => 'We are alive!', 'page callback' => 'ets_services_instance_scores', 'access arguments' => array('access content'), 'file' => 'ets.services.inc', 'type' => MENU_CALLBACK, ); $items['ets/services/options-save/%node'] = array( 'title' => 'Saving custom experiment options', 'page callback' => 'ets_services_options_save', 'page arguments' => array(3), 'access arguments' => array('access content'), 'file' => 'ets.services.inc', 'type' => MENU_CALLBACK, ); $items['ets/services/options-load/%node'] = array( 'title' => 'Loading custom experiment options', 'page callback' => 'ets_services_options_load', 'page arguments' => array(3), 'access arguments' => array('access content'), 'file' => 'ets.services.inc', 'type' => MENU_CALLBACK, ); $items['ets/services/user-stats'] = array( 'title' => 'Update endpoint for users stats', 'page callback' => 'ets_services_user_stats', 'access arguments' => array('access content'), 'file' => 'ets.services.inc', 'type' => MENU_CALLBACK, ); $items['ets/services/exp-stats'] = array( 'title' => 'Update endpoint for experiments stats', 'page callback' => 'ets_services_experiment_stats', 'access arguments' => array('access content'), 'file' => 'ets.services.inc', 'type' => MENU_CALLBACK, ); $items['ets/services/user-info/%user'] = array( 'title' => 'User info (AJAX)', 'page callback' => 'ets_services_user_info', 'page arguments' => array(3), 'access arguments' => array('access content'), 'file' => 'ets.services.inc', 'type' => MENU_CALLBACK, ); $items['ets/services/user-info-an/%'] = array( 'title' => 'User info (AJAX)', 'page callback' => 'ets_services_user_info_anonymous', 'page arguments' => array(3), 'access arguments' => array('access content'), 'file' => 'ets.services.inc', 'type' => MENU_CALLBACK, ); $items['ets/services/exp-info/%node'] = array( 'title' => 'Experiment info (AJAX)', 'page callback' => 'ets_services_experiment_info', 'page arguments' => array(3), 'access arguments' => array('access content'), 'file' => 'ets.services.inc', 'type' => MENU_CALLBACK, ); $items['ets/services/close-hunged-instances'] = array( 'title' => 'Close hunged instances', 'page callback' => 'ets_services_close_hunged_instances', 'access arguments' => array('access content'), 'file' => 'ets.services.inc', 'type' => MENU_CALLBACK, ); /* Join and perform pages are duplicated to add /kreyon/ case. This is required to use different css style on Kreyon games. */ $items['ets/exp-join/%node'] = array( 'title' => 'Joining an experiment', 'page callback' => 'ets_join_experiment', 'file' => 'ets.pages.inc', 'page arguments' => array(2), 'access arguments' => array('perform experiments'), 'type' => MENU_CALLBACK, ); $items['ets/exp-join/%node/kreyon/'] = array( 'title' => 'Joining an experiment', 'page callback' => 'ets_join_experiment', 'file' => 'ets.pages.inc', 'page arguments' => array(2), 'access arguments' => array('perform experiments'), 'type' => MENU_CALLBACK, ); $items['ets/exp-join-strict/%node'] = array( 'title' => 'Complete your profile', 'page callback' => 'ets_join_experiment_contr_strict_mode', 'file' => 'ets.pages.inc', 'page arguments' => array(2), 'access arguments' => array('perform experiments'), 'type' => MENU_CALLBACK, ); $items['ets/exp-join-strict/%node/kreyon/'] = array( 'title' => 'Complete your profile', 'page callback' => 'ets_join_experiment_contr_strict_mode', 'file' => 'ets.pages.inc', 'page arguments' => array(2), 'access arguments' => array('perform experiments'), 'type' => MENU_CALLBACK, ); $items['ets/exp-perform/%node'] = array( 'title' => 'Perform an experiment', 'page callback' => 'ets_perform_experiment', 'file' => 'ets.pages.inc', 'page arguments' => array(2,3,4), 'access arguments' => array('perform experiments'), 'type' => MENU_CALLBACK, ); $items['ets/exp-perform-raw/%node'] = array( 'title' => 'Perform an experiment (raw version)', 'page callback' => 'ets_perform_experiment_raw', 'file' => 'ets.pages.inc', 'page arguments' => array(2,3,4), 'access arguments' => array('perform experiments'), 'type' => MENU_CALLBACK, ); $items['ets/exp-perform/%node/kreyon/'] = array( 'title' => 'Perform an experiment', 'page callback' => 'ets_perform_experiment', 'file' => 'ets.pages.inc', 'page arguments' => array(2,3,4), 'access arguments' => array('perform experiments'), 'type' => MENU_CALLBACK, ); $items['ets/exp-perform-raw/%node/kreyon/'] = array( 'title' => 'Perform an experiment (raw version)', 'page callback' => 'ets_perform_experiment_raw', 'file' => 'ets.pages.inc', 'page arguments' => array(2,3,4), 'access arguments' => array('perform experiments'), 'type' => MENU_CALLBACK, ); /*$items['ets/monitor'] = array( 'title' => 'Monitor', 'page callback' => 'ets_monitor', 'file' => 'ets.pages.inc', //'access arguments' => array('perform experiments'), 'access arguments' => TRUE, 'type' => MENU_CALLBACK, );*/ $items['ets/shared_experiments'] = array( 'title' => 'Shared Experiments', 'page callback' => 'ets_shared_experiments', 'file' => 'ets.pages.inc', 'access arguments' => array('access content'), 'type' => MENU_NORMAL_ITEM, ); $items['ets/instances-monitor'] = array( 'title' => 'Instances Monitor', 'page callback' => 'ets_instances_monitor', 'file' => 'ets.pages.inc', 'access arguments' => array('administer site configuration'), 'type' => MENU_NORMAL_ITEM, ); $items['ets/managers-monitor'] = array( 'title' => 'Managers Monitor', 'page callback' => 'ets_managers_monitor', 'file' => 'ets.pages.inc', 'access arguments' => array('administer site configuration'), 'type' => MENU_NORMAL_ITEM, ); $items['admin/config/system/ets'] = array( 'title' => 'ETS Services Setup', 'page callback' => 'drupal_get_form', 'file' => 'ets.pages.inc', 'page arguments' => array('ets_settings_form'), 'access arguments' => array('administer site configuration'), ); $items['ets/towns-update'] = array( 'title' => 'Updating towns coordinates', 'page callback' => 'ets_towns_update', 'access arguments' => array('administer site configuration'), 'type' => MENU_CALLBACK, ); $items['ets/exp-stats'] = array( 'title' => 'Experiments statistics', 'page callback' => 'ets_page_experiments_statistics', 'file' => 'ets.pages.inc', 'access arguments' => array('create experiment content'), // Drupal permission 'type' => MENU_CALLBACK, ); $items['ets/conditions'] = array( 'access callback' => FALSE, ); $items['ets/conditions/new'] = array( 'title' => 'Creates the HTML for a new experiment condition', 'page callback' => 'ets_conditions_new_ahah', 'delivery callback' => 'ajax_deliver', 'file' => 'ets.conditions.inc', 'access callback' => TRUE, 'type' => MENU_CALLBACK, ); $items['ets/conditions/load'] = array( 'title' => 'Load the join conditions for a specific node', 'page callback' => 'ets_conditions_load_ahah', 'delivery callback' => 'ajax_deliver', 'file' => 'ets.conditions.inc', 'access callback' => TRUE, 'type' => MENU_CALLBACK, ); $items['ets/conditions/ac'] = array( 'title' => 'Generic autocomplete for a condition fields', 'page callback' => 'ets_conditions_ac', 'file' => 'ets.conditions.inc', 'access callback' => TRUE, 'type' => MENU_CALLBACK, ); $items['user/%user/ets-stats'] = array( 'title' => t('Statistics'), 'page callback' => 'ets_page_user_statistics', 'file' => 'ets.pages.inc', 'page arguments' => array(1), 'access callback' => 'user_view_access', 'access arguments' => array(1), 'type' => MENU_LOCAL_TASK, ); $items['user/%user/ets-stats-hist/%node'] = array( 'title' => t('History'), 'page callback' => 'ets_page_user_statistics_history', 'file' => 'ets.pages.inc', 'page arguments' => array(1,3), 'access callback' => 'user_view_access', 'access arguments' => array(1), 'type' => MENU_DEFAULT_LOCAL_TASK, ); $items['node/%node/ets-stats'] = array( 'title' => t('Statistics'), 'page callback' => 'ets_page_experiment_statistics', 'page arguments' => array(1), 'file' => 'ets.pages.inc', 'access arguments' => array(1), 'access callback' => 'ets_access_view_experiment_statistics', 'type' => MENU_LOCAL_TASK, ); $items['node/%node/ets-ranks'] = array( 'title' => t('Scores'), 'page callback' => 'ets_page_experiment_scores', 'page arguments' => array(1), 'file' => 'ets.pages.inc', 'access arguments' => array(1), 'access callback' => 'ets_node_is_experiment', 'type' => MENU_LOCAL_TASK, ); # Not used $items['ets/get-position/%node'] = array( 'title' => t('Set your position'), 'page callback' => 'drupal_get_form', 'page arguments' => array('ets_position_form'), 'access arguments' => array('perform experiments'), 'file' => 'ets.pages.inc', 'type' => MENU_NORMAL_ITEM, ); # Not used $items['ets/random-point/%node'] = array( 'title' => t('A position, randomly'), 'page callback' => 'ets_random_point_page', 'access arguments' => array('perform experiments'), 'page arguments' => array(2), 'file' => 'ets.pages.inc', 'type' => MENU_NORMAL_ITEM, ); $items['ets/services/newsletter'] = array( 'title' => 'Newsletter', 'page callback' => 'ets_show_newsletter', 'access arguments' => array('access content'), 'file' => 'ets.pages.inc', 'type' => MENU_NORMAL_ITEM, ); return $items; } function ets_node_is_experiment($node) { return $node->type == 'experiment'; } function ets_access_view_experiment_statistics($node) { global $user; return $node->type == 'experiment' && (user_access('administer nodes') || (user_access('edit own experiment content') && $user->uid == $node->uid)); } function ets_node_view($node, $view_mode ) { if ("full" == $view_mode && $node->type == 'experiment') { drupal_add_js('sites/all/libraries/jquery.cycle/jquery.cycle.all.js'); } } function ets_towns_update() { // Warning: This list is the same used in the definition of geo_town Field $towns = array( 'London' => 'London, UK', 'Rome' => 'Rome, Italy', 'Turin' => 'Turin, Italy', 'Antwerpen' => 'Antwerpen, Belgium', 'Tursi' => 'Tursi, Italy', 'San Miniato' => 'San Miniato, Italy' ); db_query("DELETE FROM {ets_towns}"); foreach($towns as $name => $description) { $url = "http://maps.googleapis.com/maps/api/geocode/json?sensor=false&address=" . urlencode($description); $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $url); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); $r = curl_exec($ch); curl_close($ch); $data = json_decode($r); if (isset($data) && 'OK' == $data->status) { $data = $data->results[0]->geometry; db_query("INSERT INTO {ets_towns} (name, description, bounds_ne, bounds_sw, latitude, longitude) VALUES ('{$name}','{$description}','{$data->bounds->northeast->lat}:{$data->bounds->northeast->lng}','{$data->bounds->southwest->lat}:{$data->bounds->southwest->lng}', '{$data->location->lat}', '{$data->location->lng}')"); } } } function ets_admin_paths() { $paths = array( 'ets/get-position/*' => TRUE, ); return $paths; } function ets_overlay_child_initialize() { drupal_add_js(drupal_get_path('module', 'ets') . '/ets-overlay.js'); } /** * Implementation of hook_page_build(). */ function ets_page_build(&$page) { $node = menu_get_object('node', 1); if (!is_object($node) || arg(2) != '' ) { return; } if (!ets_user_can_join($node)) { if (user_is_anonymous() && ets_node_is_experiment($node)) { $url = ets_url_join($node); $page['content']['join'] = array( '#markup' => "

" . l(t("Register to join!"), $url, array('attributes' => array('class' => 'btn-x-green btn-join'))) . "

", '#weight' => -1, // Fields have weight 5 ); } return; } # $url = ets_get_node_field($node, 'geo_required') ? "ets/get-position/{$node->nid}" : "ets/exp-join/{$node->nid}"; //$url = "ets/exp-join/{$node->nid}"; $url = ets_url_join($node); #. "?c=" . rand(); $page['content']['join'] = array( //$page['content']['system_main']['nodes'][$node->nid]['join'] = array( '#markup' => "

" . l(t("Join the experiment!"), $url, array('attributes' => array('class' => 'btn-x-green btn-join'))) . "

", '#weight' => -1, // Fields have weight 5 ); } function ets_url_join($node) { $url = "ets/exp-join/{$node->nid}"; // ---- STRICT MODE CHECK // if strict mode is active we must eventually compell the user to declare some data before letting him join if (ets_get_node_field($node, 'strict_mode')==1 && !empty($node->ets_conditions)) { global $user; $cond_not_filled='-1'; //if ($user->uid!=0){ $conditions = $node->ets_conditions; foreach($conditions as $name => $cond) { $rc = ets_conditions_check_condition($name, $cond, $user); if (ETS_CONDITION_CANT_SAY == $rc) { $cond_not_filled='1'; break; } } /*}else{ // user is anonymous $cond_not_filled='0'; }*/ if ($cond_not_filled!='-1') { $url = "ets/exp-join-strict/{$node->nid}";//.$cond_not_filled."/"; } } /* If user is anonymous but anonymous join is not allowed, send it to join and it will be sent to registration*/ if (user_is_anonymous() && !ets_get_node_field($node, 'anonymous_join')) { $url = "ets/exp-join/{$node->nid}"; } /* Customized url for rubedo */ if ($node->nid==423) { $url="http://xtribe.eu/rubedo/"; } return $url; } function ets_page_alter(&$page) { } function ets_user_can_join($node) { global $user; if (!$node || 'experiment' != $node->type) { return FALSE; } if (!user_access('perform experiments')) { return FALSE; } if ($user->uid == 0 && !ets_get_node_field($node, 'anonymous_join')) { return FALSE; } if (!(ets_get_node_field($node, 'active') || user_access('perform inactive experiments') || $user->uid == $node->uid || $user->uid == 1)) { return FALSE; } // Get the "conditions" definition for the experiment $conditions = ets_conditions_get_experiment_conditions($node); foreach($conditions as $name => $cond) { // Name is something like "AGE:1" and cond is "greater than 33" // $rc values: // 1: condition is certainly satisfied // 2: condition is certainly NOT satisfied // 3: can't say (if the user data to check for is not set) // (those constant have a proper define in ets.conditions.inc) $rc = ets_conditions_check_condition($name, $cond, $user); if (ETS_CONDITION_NOT_SATISFIED == $rc) { //print "Not satisfied $name"; return FALSE; } } return TRUE; } function ets_form_alter(&$form, &$form_state, $form_id) { if ($form_id == 'user_profile_form' && isset($form_state['build_info']['args'][2]) && $form_state['build_info']['args'][2] = 'strict_mode' && !isset($form_state['build_info']['args'][3])) { $form['#after_build'][] = 'ets_hide_field_user_profile_form'; } if ($form_id == 'user_profile_form' && isset($form_state['build_info']['args'][3]) && $form_state['build_info']['args'][3] = 'add_data_mode') { $form['#after_build'][] = 'ets_ui_hide_field_user_profile_form'; } if ($form_id == 'user_login_block') { $form['actions']['#weight'] = 1; $form['links']['#weight'] = 2; # Horrible, but quick $form['links']['#markup'] = str_replace('Request new password', 'Lost password?', $form['links']['#markup']); } // if i'm registering someone if ($form_id == 'user_register_form') { // if i'm doing it by the web service //watchdog("ETS Client", "GLOBuser: ".print_r($GLOBALS['user'],true), array(), WATCHDOG_NOTICE); if (arg(0) == 'xtribe_api' /*&& $GLOBALS['user']->uid!=0*/) { unset($form['captcha']); } } /* This generates a new request password link linking with destination so that after request password in kreyon event iframe the user is eredirected to registration page instead that to login page inside the sitehyy */ if ($form_id == 'user_login' && ((strpos($_SERVER['REQUEST_URI'], 'register') != false)) ) { $newlinks = l(t('Request new password'), 'user/password', array('query' => array('destination' => strstr($_SERVER['REQUEST_URI'], 'node/')), 'attributes' => array('title' => t('Request new password via e-mail.')))); $form['links']['#markup'] = $newlinks; } } function ets_block_view_alter(&$data, $block) { if (isset($block->delta) && $block->delta == 'user-menu') { global $user; if ($user->uid > 0 && isset($data['content'][15])) { $data['content'][15]['#title'] .= " {$user->name}"; #array_unshift($data['content'], array('#markup' => "

{$user->name}

")); } } } function ets_form_experiment_node_form_alter(&$form, &$form_state) { $in_edit = !empty($form['nid']['#value']); $machine_name = ''; if (isset($form_state['node']->machine_name)) { $machine_name = $form_state['node']->machine_name; } if (!$in_edit) { $form['machine_name'] = array( '#type' => 'machine_name', '#default_value' => $machine_name, '#maxlength' => 21, '#description' => t("A unique machine-readable indentifier name for the experiment. Can only contain lowercase letters, numbers, and underscores.
WARNING: you can't change it once the experiment has been created."), '#required' => TRUE, '#machine_name' => array( 'exists' => 'ets_machine_name_exists', ) ); } else { $form['machine_name'] = array( '#type' => 'hidden', '#default_value' => $machine_name, ); $form['fake_machine_name'] = array( '#type' => 'machine_name', '#default_value' => $machine_name, '#description' => t("A unique machine-readable indentifier name for the experiment."), '#disabled' => TRUE, ); $play_link = 'http://'.$_SERVER['SERVER_NAME'].'/ets/exp-join/'.$form['nid']['#value']; $form['play_link_text'] = array( '#markup' => '

'.$play_link.'Your game can be started directly visiting this link. Use it to invite players directly or to include your game in your website.

' ); } $form['conditions'] = array( '#type' => 'fieldset', '#title' => t('Join conditions'), '#weight' => 3 ); // Renders the condition fields , so we // resort using javascript foreach ($conditions_fields as $name => $f) { $field_options[$name] = ((isset($f['disabled']) && $f['disabled']) ? 'disabled ' : '') . $f['label']; } $form['conditions']['fields'] = array( '#type' => 'select', '#prefix' => "
", '#title' => t('Choose an user field to set a condition against'), '#theme_wrappers' => array("ets_conditions_inline_select"), '#options' => $field_options, ); $form['conditions']['add_condition'] = array( '#type' => 'button', '#value' => t('Add'), '#name' => 'add_condition', '#suffix' => "
", '#button_type' => 'button', ); $form['conditions']['act_conditions'] = array( '#type' => 'fieldset', '#title' => 'Active conditions', ); /* $form['conditions']['notice'] = array( '#type' => 'item', '#markup' => '

(This is an experimental feature: conditions will not be applied until this notice will be removed.)

' ); */ if ($in_edit) { $conditions = ets_conditions_load_conditions('db', array($form['nid']['#value'])); if (!empty($conditions)) { ets_conditions_save_conditions('session', null, $conditions[$form['nid']['#value']]); } } $form['field_share_my_game']['#attributes'] = array('onclick' => 'if(!document.getElementById("edit-field-share-my-game-und").checked && !confirm("Revoking permission to share your experiment and saving your experiment will remove EVERY version of your experiment you previously shared. This action CANNOT BE UNDONE! Are you sure?")){ return false;}'); $form['#validate'][] = 'ets_experiment_form_validate'; $form['#submit'][] = 'ets_experiment_form_submit'; } /**/ function ets_boot() { // Always create a guid, so to manage even anonymous users if (!isset($_SESSION['guid'])) { $_SESSION['guid'] = uniqid(); } } function ets_user_update(&$edit, $account, $category) { require_once('ets.redis.inc'); ets_redis_del(ets_redis_user_key($account->uid)); } function ets_user_delete($account) { require_once('ets.redis.inc'); ets_redis_del(ets_redis_user_key($account->uid)); } /* This function gets called at the moment of a user login */ function ets_user_login($account) { //$_SESSION['guid'] = uniqid(); // Guid for registered users is calculated through the use of an md5 + a passphrase. It is always the same. // Before, it was calculated using the function uniqid, but this meant that a registered user could have // two different guid during two different sessions. Instead, we needed a user registered to have the same // guid and one that could be easily calculated starting from the xtribe user id // (not the reverse, for a privacy issue) $_SESSION['guid'] = ets_get_guid_from_uid($account['uid']); } function ets_get_guid_from_uid($uid) { $clientId=ets_get_guid(); watchdog("ETS debug", "uid_pre: 
".print_r($uid,true)."
", array(), WATCHDOG_NOTICE); watchdog("ETS debug", "guid_pre: 
".print_r($clientId,true)."
", array(), WATCHDOG_NOTICE); if (is_numeric($uid)) { watchdog("ETS debug", "uid_used (classic): 
".print_r($uid,true)."
", array(), WATCHDOG_NOTICE); $clientId=substr(md5($uid.'thistextisasimplepassphraseformd5'),19,32); }else{ global $user; if (is_numeric($user->uid)) { if ($user->uid!=0) { $uid_usr=$user->uid; watchdog("ETS debug", "uid_used (from user): 
".print_r($uid_usr,true)."
", array(), WATCHDOG_NOTICE); $clientId=substr(md5($uid_usr.'thistextisasimplepassphraseformd5'),19,32); } } } watchdog("ETS debug", "guid_final: 
".print_r($clientId,true)."
", array(), WATCHDOG_NOTICE); return $clientId; // guid and one that could be easily calculated starting from the xtribe user id // (not the reverse, for a privacy issue) //$_SESSION['guid'] = substr(md5($account['uid'].'thistextisasimplepassphraseformd5'),19,32); } function ets_get_guid() { return $_SESSION['guid']; } function ets_node_load($nodes, $types = FALSE) { if (FALSE === array_search('experiment', $types)) { return; } module_load_include('inc', 'ets', 'ets.conditions'); $result = db_query('SELECT nid, machine_name FROM {ets_experiment} WHERE nid IN(:nids)', array(':nids' => array_keys($nodes))); foreach ($result as $record) { $nodes[$record->nid]->machine_name = $record->machine_name; } $nodes_conditions = ets_conditions_load_conditions('db', array_keys($nodes)); foreach ($nodes_conditions as $nid => $conditions) { $nodes[$nid]->ets_conditions = $conditions; } } function ets_machine_name_exists($machine_name) { $result = db_query('SELECT nid FROM {ets_experiment} WHERE machine_name = :mn', array(':mn' => $machine_name)); return $result->rowCount() == 1; } function ets_node_insert($node) { if ('experiment' == $node->type) { db_insert('ets_experiment') ->fields(array('nid' => $node->nid, 'machine_name' => $node->machine_name)) ->execute(); db_insert('ets_experiment_stats') ->fields(array('nid' => $node->nid)) ->execute(); ets_conditions_save_conditions('db', $node->nid); } // adds automatically aliases to page of templeton project (needed to have templeton page use a specific theme) /*if ($node->type == 'kreyon_page' || $node->type == 'kreyon_news' || $node->type == 'kreyon_article' || $node->type == 'kreyon_game') { $node->path['alias'] = 'kreyon/'.$node->nid; }*/ add_kreyon_url_alias($node); } function ets_node_update($node) { if ('experiment' == $node->type) { ets_conditions_save_conditions('db', $node->nid); require_once('ets.redis.inc'); ets_redis_del(ets_redis_experiment_key($node->nid)); } add_kreyon_url_alias($node); /* By design: You can't change the machine name at the moment if ('experiment' == $node->type) { db_update('ets_experiment') ->fields(array('machine_name' => $node->machine_name)) ->condition('nid', $node->nid) ->execute(); } */ } function ets_node_delete($node) { if ('experiment' == $node->type) { require_once('ets.redis.inc'); ets_redis_del(ets_redis_experiment_key($node->nid)); db_delete('ets_experiment_stats') ->condition('nid', $node->nid) ->execute(); db_delete('ets_experiment') ->condition('nid', $node->nid) ->execute(); ets_conditions_delete_conditions('db', $node->nid); // Better safe than sorry if (trim($node->machine_name) == "") { return; } $tmp = file_directory_temp() . "/exp_packages/{$node->machine_name}"; ets_rrmdir($tmp); $path = "public://exp_packages"; $target = drupal_realpath($path); if (!empty($target)) { ets_rrmdir("{$target}/{$node->machine_name}"); } } } function ets_experiment_form_submit($form, $form_state) { $form_state['node']->machine_name = $form_state['values']['machine_name']; // Check if user chose to share publicly his game $lang_share_my_game = $form['field_share_my_game']['#language']; $field_share_my_game=trim($form_state['values']['field_share_my_game'][$lang_share_my_game][0]['value']); $game_machineName=$form_state['values']['machine_name']; $path_repo = 'public://published_games_repo/'.$game_machineName; // if user chose to share his game if ($field_share_my_game=='1') { // Create the game repo directory if does not exists drupal_mkdir($path_repo,0777); // load client file to move it in the right repository $lang_field_client = $form['field_package']['#language']; $file_field_client = $form_state['input']['field_package'][$lang_field_client][0]; $file_client = file_load($file_field_client['fid']); // load manager file to move it in the right repository $lang_field_manager = $form['field_share_my_manager']['#language']; $file_field_manager = $form_state['input']['field_share_my_manager'][$lang_field_manager][0]; $file_manager = file_load($file_field_manager['fid']); //$present_path_of_file=$file->uri; // If there is at least one of the two file loaded i start the deploy of files on the repo. // It is possible to have no file cause the "Share my manager" checkbox is intended to give permission // to share, then is up to the system to choose when and how. if (is_a($file_client,'stdClass') || is_a($file_manager,'stdClass')){ // Create the game repo directory for this deploy $path_repo = $path_repo."/".date('d-m-Y_H:i:s'); drupal_mkdir($path_repo,0777); // copy client file (it should remain in client dir, too) into repository and manager file // only if files have been loaded if (is_a($file_client,'stdClass')) { $path_repo_client = $path_repo."/client/"; drupal_mkdir($path_repo_client,0777); file_copy($file_client, $path_repo_client); } if (is_a($file_manager,'stdClass')) { $path_repo_manager = $path_repo."/manager/"; drupal_mkdir($path_repo_manager,0777); file_copy($file_manager, $path_repo_manager); } // Starts the bash script that add, commit and push the changes to the public games repo $oldPath=getcwd(); chdir('/var/www/xtribe.eu/etsmaintenance/'); $output= shell_exec('./push_public_game_repo.sh '.$game_machineName.' add'); chdir($oldPath); watchdog("ETS Client", "Added game to public repo. Log: ".$output, array(), WATCHDOG_NOTICE); } } $in_edit = !empty($form['nid']['#value']); if ($field_share_my_game=='0' and $in_edit) { //watchdog("ETS Client", "Removing shared content of experiment ".$form_state['values']['machine_name'], array(), WATCHDOG_NOTICE); $repoExists = file_prepare_directory($path_repo); if ($repoExists) { file_unmanaged_delete_recursive($path_repo); // Starts the bash script that remove, commit and push the changes to the public games repo $oldPath=getcwd(); chdir('/var/www/xtribe.eu/etsmaintenance/'); $output= shell_exec('./push_public_game_repo.sh '.$game_machineName.' remove'); chdir($oldPath); watchdog("ETS Client", "Removed game from public repo. Log: ".$output, array(), WATCHDOG_NOTICE); } } } function ets_experiment_form_validate($form, $form_state) { // Save in session the actual value for the conditions, so we // can eventually restore (and save) them ets_conditions_save_conditions('session'); // Check manager uri is correctly filled $lang_mgr_uri = $form['field_mgr_uri']['#language']; $mgr_uri_field = trim($form_state['values']['field_mgr_uri'][$lang_mgr_uri][0]['value']); if (!empty($mgr_uri_field) && !valid_url($mgr_uri_field, TRUE)) { form_set_error('field_mgr_uri', "The specified manager URL is not valid"); return; } // Check machine name has been filled $machine_name = $form_state['input']['machine_name']; $errors = form_get_errors(); if (isset($errors['machine_name'])) { return; } // Check if CLIENT file field has been filled. If it has, validate file field and do some operation to load // client into Xtribe. It it has not, return. It make sense to load an experiment with no code package // for i could want to fill a presentation page for my experiment and load a working version in a second time. $lang_field_package = $form['field_package']['#language']; $file_field_client = $form_state['values']['field_package'][$lang_field_package][0]; if (!empty($form_state['build_info']['args'][0]->field_package)) { $file_field_client_old = $form_state['build_info']['args'][0]->field_package[$lang_field_package][0]; }else{ $file_field_client_old = 0; } if ($file_field_client['fid'] != 0 && strcmp($file_field_client_old['fid'],$file_field_client['fid'])!=0) { $file = file_load($file_field_client['fid']); // Now unzip the file in the right place $zip = new ZipArchive(); $m = ''; $path = "public://exp_packages"; file_prepare_directory($path, FILE_CREATE_DIRECTORY | FILE_MODIFY_PERMISSIONS); $target = drupal_realpath($path) . "/{$machine_name}"; /* Before deleting dicrectory, check file exists */ $package = drupal_realpath($file->uri); if (empty($package)) { # Could happen during update: if the package doesn't exists, neither the directory containing an eventual # previous version of the experiment, the error must be pointed out if (!file_exists("{$target}/index.html")) { form_set_error('field_package', "Sorry, the specified package has been removed and cannot be saved"); } } else { $tmp = file_directory_temp() . "/exp_packages/{$machine_name}"; ets_rrmdir($tmp); if (!empty($file->uri)) { if ($zip->open(drupal_realpath($file->uri)) === TRUE) { $zip->extractTo($tmp); $zip->close(); # Check an index.html file exists if (!file_exists("{$tmp}/index.html")) { form_set_error('field_package', "The experiment package does not contain a index.html file"); } else { // @unlink("{$target}/{$machine_name}"); // @symlink($tmp, "{$target}/{$machine_name}"); ets_rrmdir($target); file_prepare_directory($target, FILE_CREATE_DIRECTORY | FILE_MODIFY_PERMISSIONS); ets_rcopy($tmp, $target); } ets_rrmdir($tmp); } else { form_set_error('field_package', "Sorry, a problem occurred opening the package. Please try uploading it again."); } } } }else{ watchdog("ETS Client", "No interface file available in this updated version", array(), WATCHDOG_NOTICE); } } function ets_block_info() { $blocks['ets_login'] = array( 'info' => 'ETS: Login block', 'cache' => DRUPAL_NO_CACHE, ); $blocks['menu_merge'] = array( 'info' => t('Xtribe Mobile Menu'), ); return $blocks; } function ets_block_view($delta) { $block = array(); switch ($delta) { case 'ets_login': $block = ets_block_login(); break; case 'menu_merge': // Merging two or more menus $menu_1 = i18n_menu_localize_tree(menu_tree_all_data('main-menu')); // This loads localized menu $menu_2 = i18n_menu_localize_tree(menu_tree_all_data('navigation')); // instead of menu_tree_all_data('navigation'); //$menu_3 = menu_tree_all_data('menu-footer-menu'); $mobile_menu = array_merge($menu_1, $menu_2/*, $menu_3*/); $content = menu_tree_output($mobile_menu); $block = array( 'subject' => t('Xtribe Mobile Menu'), 'content' => $content, ); break; } return $block; } /* Block shows the "Login" and "Facebook connect" buttons only */ function ets_block_login() { global $language ; $lang_name = '/'.$language->language; global $user; if ($user->uid) { return; } $destination = drupal_get_destination(); /*$block['content'] = "
Login
";*/ if (strpos($_SERVER['REQUEST_URI'], 'kreyon') != false) { $block['content'] = "
Login
"; }else{ $block['content'] = "
Login
"; } if (module_exists('fboauth')) { $block['content'] .= "
" . fboauth_action_display('connect') . "
"; } return $block; } /* * Helpers */ function ets_rrmdir($path) { return is_file($path) ? @unlink($path) : array_map('ets_rrmdir', glob($path.'/*')) == @rmdir($path) ; } function ets_rcopy($src, $dst) { $dir = opendir($src); @mkdir($dst); while(false !== ( $file = readdir($dir)) ) { if (( $file != '.' ) && ( $file != '..' )) { if ( is_dir($src . '/' . $file) ) { ets_rcopy($src . '/' . $file,$dst . '/' . $file); } else { copy($src . '/' . $file,$dst . '/' . $file); } } } closedir($dir); } /* Get the raw value of a node field. Hope there is better way */ function ets_get_node_field($node, $name, $key = 'value') { if (substr($name, 0, 6) != 'field_') { $name = "field_{$name}"; } $field = field_get_items('node', $node, $name); return $field[0][$key]; } /* * Get the raw value of a user field. * returns an array of values or FALSE */ function ets_get_user_field($account, $name, $key = 'value') { if ($account->uid==0 && ($name=='sex' || $name=='dob' || $name=='education' || $name=='language_sp')) { // if anonymous get data from database $guid=ets_get_guid(); $result = db_select('ets_anon_usr', 'a') ->fields('a', array( $name)) ->condition('guid', $guid,'=') ->execute() ->fetchAssoc(); if (empty($result)) { return FALSE; } if ($name=='language_sp') { if (empty($result['language_sp'])) { return FALSE; }else{ $result=json_decode($result['language_sp']); } } if ($name=='dob') { if (empty($result['dob'])) { return FALSE; }else{ $result=json_decode($result['dob']); $result=$result[0]; } } $output = array(); foreach($result as $record) { if ($record=='') { return FALSE; } $output[] = $record; } }else{ // if authenticated if (substr($name, 0, 6) != 'field_') { $name = "field_{$name}"; } $field = field_get_items('user', $account, $name); if (FALSE === $field) { // Field may not be loaded yet $account = user_load($account->uid); $field = field_get_items('user', $account, $name); } // Can't find the rquested field if ($field === FALSE) { return FALSE; } $output = array(); foreach($field as $instance) { $output[] = $instance[$key]; } } return $output; } /* // TOKEN MANAGEMENT FUNCTIONS // -------------------------- // This function gets called by join page and means to associate a token to an instance of the experiment and to a user, // that is the token gets inserted in the bunch of tokens currently valid for the game. // Note 1: we cannot use the instance id cause EHS will give it to us only at the moment of 'play' // Note 2: this force that the new user cannot partecipate to two istances of the same experiment simultaneously // Note 3: the uid is for use of statistics and will not be useful in verify phase. function ets_token_save($nid, $guid, $token) { global $user; // In the unlikely situation that the token exists for this game, we get rid of it db_delete('ets_experiment_token') ->condition('nid', $nid) ->condition('token', $token) ->execute(); // Reset user situation as it was at the moment of user join db_delete('ets_experiment_token') ->condition('nid', $nid) ->condition('guid', $guid) ->execute(); db_insert('ets_experiment_token') ->fields(array('nid' => $nid, 'guid' => $guid, 'uid' => $user->uid, 'created' => time(), 'token' => $token)) ->execute(); } // This function "consume" the token relative to a game. It does not remove it // for it can be useful for statitic calculations. function ets_token_spend($nid, $token) { db_update('ets_experiment_token') ->fields(array('spent' => 1)) ->condition('nid', $nid) ->condition('token', $token) ->execute(); } // This function verify a token is yet expendable. function ets_token_verify($nid, $token) { $result = db_query('SELECT token FROM {ets_experiment_token} WHERE nid = :nid AND token = :token AND spent = 0', array(':nid' => $nid, ':token' => $token)); return $result->rowCount() == 1; } function ets_token_generate($seed) { $part = 0; return substr(sha1('t' . $seed . microtime()), 0, 10); } */ function ets_get_town_data($name) { $result = db_query("SELECT * FROM {ets_towns} WHERE name = :name", array(':name' => $name)); return $result->fetchObject(); } function ets_theme() { return array( 'ets_conditions_inline_select' => array(), 'ets_conditions_condition' => array('field_name' => null, 'index' => null, 'value' => null, 'operator' => null), ); } function ets_dbg($data) { error_log(print_r($data, true), 3, "/tmp/xtribe.log"); } function ets_custom_theme() { if (isset($_GET['theme'])) { return $_GET['theme']; } } function ets_services_resources() { /* // This code activate a web service custom endpoint which gives back guid // Calling (in GET) http://sitename:8080/xtribe_api/guid/12 result in a json containing the guid of user '12' // using the callback ets_get_guid_from_uid from this file with argument the number given in the path return array( 'guid' => array( 'retrieve' => array( 'help' => 'Retrieves guid', //'file' => array('type' => 'inc', 'module' => 'ets', 'name' => 'ets.services'), 'callback' => 'ets_get_guid_from_uid', 'access callback' => 'user_access', 'access arguments' => array('create experiment content'), 'args' => array( array( 'uid' => 'uid', 'type' => 'string', 'description' => 'The id of the user', 'source' => array('path' => '0'), // 'data' in case of post request 'optional' => FALSE, ), ), ), ), );*/ } function ets_services_request_postprocess_alter($controller, $args, &$result) { //watchdog("ETS Client", "res: ".print_r($result, true)." con: ".print_r($controller, true)." arg: ".print_r($args, true), array(), WATCHDOG_NOTICE); // if (through api webservice) i'm logging or asking data of connected user if (strcmp($controller['callback'],"_user_resource_login")==0 || strcmp($controller['callback'],"_system_resource_connect")==0) { $result->guid = ets_get_guid_from_uid($result->user->uid); // remove from json data that must not be showed // TODO decide which data to show, remember to comment unset user in order to make drupal gap work unset($result->user); /*unset($result->user->mail); unset($result->user->init); unset($result->user->roles); unset($result->user->field_fullname); unset($result->user->rdf_mapping); unset($result->user->data); unset($result->user->session); unset($result->user->hostname); unset($result->user->cache); unset($result->user->location); unset($result->user->locations); unset($result->user->uid);*/ } //watchdog("ETS Client", "res: ".$controller['callback']." uid:".print_r($result['uid'],true), array(), WATCHDOG_NOTICE); // if i am creating a user if (strcmp($controller['callback'],"_user_resource_create")==0) { $result['guid'] = ets_get_guid_from_uid($result['uid']); // remove from json data that must not be showed // TODO decide what data to show unset($result['uid']); unset($result['uri']); } } /* This points out a specific file as the css that must be added to admin theme. This allow to make changes to overlay css, for example, which style would be managed by the system theme Seven, otherwise.*/ function ets_preprocess_html(&$variables) { global $theme; if($theme == 'seven') { drupal_add_css(drupal_get_path('theme', 'etslook') . '/css/etslook_admin_theme_override.css', array('weight' => CSS_THEME)); } } function add_kreyon_url_alias($node) { // adds automatically aliases to page of kreyon project (needed to have pages use a specific theme) if ($node->type == 'kreyon_page' || $node->type == 'kreyon_news' || $node->type == 'kreyon_article' || $node->type == 'kreyon_game' && $node->nid!=234 && $node->nid!=233 && $node->nid!=253 ) { $node->path['pathauto'] = 0; $safe_url_string=$node->title; // replace accented characters $unwanted_array = array('Š'=>'S', 'š'=>'s', 'Ž'=>'Z', 'ž'=>'z', 'À'=>'A', 'Á'=>'A', 'Â'=>'A', 'Ã'=>'A', 'Ä'=>'A', 'Å'=>'A', 'Æ'=>'A', 'Ç'=>'C', 'È'=>'E', 'É'=>'E','Ê'=>'E', 'Ë'=>'E', 'Ì'=>'I', 'Í'=>'I', 'Î'=>'I', 'Ï'=>'I', 'Ñ'=>'N', 'Ò'=>'O', 'Ó'=>'O', 'Ô'=>'O', 'Õ'=>'O', 'Ö'=>'O', 'Ø'=>'O', 'Ù'=>'U','Ú'=>'U', 'Û'=>'U', 'Ü'=>'U', 'Ý'=>'Y', 'Þ'=>'B', 'ß'=>'Ss', 'à'=>'a', 'á'=>'a', 'â'=>'a', 'ã'=>'a', 'ä'=>'a', 'å'=>'a', 'æ'=>'a', 'ç'=>'c','è'=>'e', 'é'=>'e', 'ê'=>'e', 'ë'=>'e', 'ì'=>'i', 'í'=>'i', 'î'=>'i', 'ï'=>'i', 'ð'=>'o', 'ñ'=>'n', 'ò'=>'o', 'ó'=>'o', 'ô'=>'o', 'õ'=>'o','ö'=>'o', 'ø'=>'o', 'ù'=>'u', 'ú'=>'u', 'û'=>'u', 'ý'=>'y', 'þ'=>'b', 'ÿ'=>'y' ); $safe_url_string = strtr( $safe_url_string, $unwanted_array ); // remove non alphanumeric character $safe_url_string=str_replace(" ","-", preg_replace("/[^A-Za-z0-9 ]/", '', strtolower($safe_url_string))); // remove extra dashes $safe_url_string=trim(preg_replace('/-+/', '-', $safe_url_string), '-'); $node->path['alias'] = 'kreyon/'.$safe_url_string; } } function ets_language_switch_links_alter(array &$links, $type, $path) { $language_type = variable_get('translation_language_type', LANGUAGE_TYPE_INTERFACE); if (/*$type == $language_type &&*/ preg_match("!^node/(\d+)(/.+|)!", $path, $matches)) { $node = node_load((int) $matches[1]); $trans = $node->translations->data; $diff = array_diff_key($links,$node->translations->data); if (!empty($trans)) { // for nodes that do provide translation foreach ($diff as $key => $value){ // disable language switcher element about languages not available array_push($links[$key]['attributes']['class'], 'dis_lang'); array_push($links[$key]['attributes']['class'], 'dis_'.$key); } } } } /* // Prints out the global variable user //dpm($GLOBALS['user']); // Watchdog // watchdog("ETS debug", "var: 
".print_r($form_state,true)."
", array(), WATCHDOG_NOTICE); */