qid = 0; // will be autoset by the DB serial $this->uid = $user->uid; $this->type = $type; $this->name = $name; $this->query = serialize($ar_values); $this->created = $this->updated = time(); } /** * Save a named query to the DB, erasing previous homonym queries is any exists. * * @return int */ public function save() { // Avoid duplicates if (!empty($this->name)) { $sq = "DELETE FROM {%s} WHERE name = '%s' AND uid = '%d' "; db_query($sq, QBF_TABLE_NAME, $this->name, $this->uid); // $n = db_affected_rows(); // Know how many homonym queries we deleted } $ret = drupal_write_record(QBF_TABLE_NAME, $this); // no update param: we just deleted the previous version if ($ret) // has to be SAVED_NEW, by construction { $ret = $this->qid; // from serial } return $ret; } } /** * Recursively build a query array from the form and its values * * In the current version, element names are supposed to be unique, even at * different levels in the tree. * * @ingroup forms * @param array $form * @param array $form_values */ function _qbf_extract_query($element_id, $form, $form_values) { // Elements which are unnamed (form), removed, or display-only have no place in the query if (!empty($element_id) && array_key_exists('#qbf', $form) && array_key_exists('#level', $form['#qbf']) && $form['#qbf']['#level'] >= QBF_LEVEL_OPTIONAL) { $ret = array($element_id => $form_values[$element_id]); } else { $ret = array(); } // QBF level is not inherited, so this loop is outside the "if" above foreach (element_children($form) as $child_name) { $ret += _qbf_extract_query($child_name, $form[$child_name], $form_values); } return $ret; } /** * Submit handler for qbf_form, Perform search button. * * @param array $form * @param array $form_state */ function _qbf_form_perform_submit($form, &$form_state) { // dsm($form); // dsm($form_state); $callback = $form_state['values']['qbf_query']; if (function_exists(($callback))) { $ar_query = _qbf_extract_query(NULL, $form, $form_state['values']); $form_state['qbf_results'] = $callback($ar_query); } $form_state['rebuild'] = TRUE; } /** * Validate handler for qbf_form, Perform search button. * * @param array $form * @param array $form_state */ function _qbf_form_perform_validate($form, &$form_state) { // @todo validate searches: checkboxes sets needs at least one value checked, otherwise there won't be any result } /** * Submit handler for qbf_form, Save search button. * * @param array $form * @param array $form_state * @return integer * The id of the saved query. */ function _qbf_form_save_submit($form, &$form_state) { $qid = _qbf_save($form_state['values']['form_id'], $form_state); drupal_set_message(t('Your query was saved as "@name".', array('@name' => $form_state['values']['qbf_save_name']))); global $user; $form_state['redirect'] = "user/$user->uid/edit/qbf"; return $qid; } /** * Validate handler for qbf_form, Save search button. * * @param array $form * @param array $form_state */ function _qbf_form_save_validate($form, &$form_state) { // @todo validate saves. Check whether any validation is necessary. } /** * Delete a query by qid * * In the qbf//delete case, $query has been tested for validity and access * in qbf_query_load(), so it is safe and accessible. * * Outside this context, the function can also be invoken with just a qid, and * the same check via qbf_query_load() will be performed. * * @param mixed $query * int or object */ function _qbf_query_delete($query) { global $user; if (is_int($query)) { $query = qbf_query_load($query); } if ($query) // access already checked in explicit or implicit qbf_query_load { $qid = $query->qid; $sq = 'DELETE FROM %s WHERE qid = %d '; $q = db_query($sq, QBF_TABLE_NAME, $qid); $message = t('Query @id "@name" has been deleted.', array ( '@id' => $qid, '@name' => $query->name, )); drupal_set_message($message, 'status'); $link = l($qid, QBF_PATH_MAIN .'/'. $qid .'/delete'); $notify = variable_get(QBF_VAR_NOTIFY_DELETE, QBF_DEF_NOTIFY_DELETE); watchdog('qbf', $message, NULL, WATCHDOG_NOTICE, $link); // access check: we only send the message to the query owner, so access is // granted without an additional check if ($notify /* && $query->uid != $user->uid */) { $owner = user_load(array('uid' => $query->uid)); $language = user_preferred_language($account); $params = array ( 'query' => $query, 'owner' => $owner, // unused by default, but can be used in a hook_mail_alter() implementation 'deletor' => $user, 'language' => $language, ); $ret = drupal_mail('qbf', __FUNCTION__, $user->mail, $language, $params, $user->mail); drupal_set_message(t('User !link has been informed', array ( '!link' => l($account->name, 'user/'. $query->uid), ))); // dsm(array("QQD, ret" => $ret)); } } else { $message = t('Failed attempt to delete query @qid. Administrator has been alerted.', array ( '@qid' => $qid, )); drupal_set_message($message, 'error'); watchdog('qbf', $message, NULL, WATCHDOG_ERROR, $link); } drupal_goto(); } /** * Main query page. * * @param object $query * Valid query, loaded by qbf_query_load(). * @return string */ function _qbf_query_form($query) { $qbf_form_id = 'qbf_' . $query->type; $form = drupal_get_form($qbf_form_id, $query); return $form; } /** * Save a query and return its qid. * * This is not a hook_save() implementation, hence the "_". * * @ingroup forms * * @param $form_id string * @param $form_state array * @return int */ function _qbf_save($form_id, $form_state) { if (user_is_anonymous()) { $warning = t('Attempt by anonymous user to save a QBF query. Should not happen.'); drupal_set_message($warning, 'error'); watchdog('qbf', $warning, NULL, WATCHDOG_WARNING); $ret = 0; } else { // @FIXME check whether form_state is now needed. It wasn't in QBF for D5 $form = drupal_retrieve_form($form_id, $form_state); // dsm($form, "retrieve"); drupal_prepare_form($form_id, $form, $form_state); // dsm($form, "prepare"); $name = $form_state['values']['qbf_save_name']; $type = $form_state['values']['qbf_save_type']; // dsm($form_state); $form_values = _qbf_extract_query(NULL, $form, $form_state['values']); // dsm($form_values); $ar_values = array(); foreach ($form_values as $key => $value) { if (empty($value)) { continue; } $ar_values[$key] = $value; } $query = new Qbf_Query($type, $name, $ar_values); $ret = $query->save(); } return $ret; } /** * Transform a form element for QBF. * * QBF-specific properties are: * - #qbf : array of properties * - #level: only within #qbf * * See QBF_* constants * * @ingroup forms * @param string $key * @param array $element * @return void */ function _qbf_transform_element($key, $element, $form_state, $query) { // dsm(array('key' => $key, 'element' => $element)); /** * List default type transformations applied to widget by FAPI. * Types without a default transformation are not transformed */ static $ar_default_type_transformations = array ( 'button' => NULL, // no content 'file' => NULL, // non-querable (yet ?) 'image_button' => NULL, // new in D6 'markup' => NULL, // no content 'password' => NULL, // forbidden 'radio' => NULL, // single radio is useless, unlike a set of them 'submit' => NULL, // no content 'textarea' => 'textfield', // reduce text for searches // Don't transform these: // 'checkbox' => NULL, // 'checkboxes' => NULL, // 'date' => NULL, // 'fieldset' => NULL, // useful visually // 'form' => NULL, // removing it would delete the whole shebang // 'hidden' => NULL, // non-querable visually, but may be useful // 'item' => NULL, // 'radios' => NULL, // 'select' => NULL, // 'textfield' => NULL, // 'value' => 'value', // 'weight' => NULL, ); /** * List default property transformations applied to widget by FAPI property. * * Properties without a default transformation are not transformed */ static $ar_default_property_transformations = array ( // Standard properties '#action' => NULL, '#after_build' => NULL, // '#base' => NULL, // gone in D6 '#button_type' => NULL, '#built' => NULL, '#description' => NULL, '#method' => NULL, '#parents' => NULL, '#redirect' => NULL, '#ref' => NULL, '#required' => NULL, '#rows' => NULL, '#submit' => NULL, '#tree' => NULL, '#validate' => NULL, ); /** * List properties causing causing element removal. * * The key is the property name, the value is the one causing removal. */ static $ar_killer_properties = array ( '#disabled' => TRUE, ); // Transform type $source_type = $element['#type']; // .. Default transformation $dest_type = array_key_exists($source_type, $ar_default_type_transformations) ? $ar_default_type_transformations[$source_type] : $source_type; // .. Apply form-defined type override if (isset($element['#qbf']['#type'])) { $dest_type = $element['#qbf']['#type']; } if (is_null($dest_type)) { $ret = NULL; } else { $ret = $element; $ret['#type'] = $dest_type; if (!array_key_exists('#qbf', $element) || $element['#qbf']['#level'] == QBF_LEVEL_REMOVE) { $ret = NULL; } else { foreach (element_properties($element) as $property_name) { // Apply killer properties first to avoid useless work if (array_key_exists($property_name, $ar_killer_properties) && ($element[$property_name] = $ar_killer_properties[$property_name])) { $ret = NULL; break; } // Now transform or copy remaining properties if (array_key_exists($property_name, $ar_default_property_transformations)) { $ret[$property_name] = $ar_default_property_transformations[$property_name]; } else { $ret[$property_name] = $element[$property_name]; } // And apply form-defined property overrides if ($property_name == '#qbf') { foreach ($element[$property_name] as $override_name => $override_value) { $ret[$override_name] = $override_value; } } } if (isset($form_state['values'][$key])) { $ret['#default_value'] = $form_state['values'][$key]; } elseif (isset($query->query[$key])) { $ret['#default_value'] = $query->query[$key]; } // Recursively transform children foreach (element_children($element) as $child_name) { $child = _qbf_transform_element($child_name, $element[$child_name], $form_state, $query); if (is_null($child)) { unset($ret[$child_name]); } else { $ret[$child_name] = $child; } } } } //dsm(array('key' => $key, 'transformed element' => $ret)); return $ret; } /** * Implement the former hook_settings(). * * @return array */ function qbf_admin_settings() { $form = array(); $form[QBF_VAR_NOTIFY_DELETE] = array ( '#type' => 'checkbox', '#default_value' => variable_get(QBF_VAR_NOTIFY_DELETE, QBF_DEF_NOTIFY_DELETE), '#title' => t('Notify users when one of their saved searches has been deleted'), ); return system_settings_form($form); } /** * The QBF form builder. * * @param array $form_state * @param array $query_info * The query structure array * @param string $qbf_form_id * The name of the QBF form * @param string $query * The saved query. */ function qbf_form(&$form_state, $query_info, $qbf_form_id, $query = NULL) { $form_id = $query_info['form']; // Fetch the basic form and rename it, passing it the previous values $node = new stdClass(); $form = $form_id($node, $form_state); $qbf_form = array(); $qbf_form['#qbf_source_form_id'] = $form_id; // On the form element itself, only keep the QBF properties and the children if (in_array('#qbf', element_properties($form))) { $qbf_form += $form['#qbf']; } foreach (element_children($form) as $key) { $new_element = _qbf_transform_element($key, $form[$key], $form_state, $query); if (!is_null($new_element)) { $qbf_form[$key] = $new_element; } } $qbf_form['#id'] = $qbf_form_id; $qbf_form['qbf'] = array ( '#type' => 'fieldset', '#title' => t('Query'), ); if (isset($form_state['values']) && !empty($form_state['values'])) { if (isset($form_state['qbf_results'])) { $qbf_form['qbf']['qbf_results'] = array ( '#type' => 'markup', '#prefix' => '

', '#value' => $form_state['qbf_results'], '#suffix' => '

', ); } } $qbf_form['qbf']['qbf_save_type'] = array ( '#type' => 'hidden', '#value' => $query_info['form'], ); $qbf_form['qbf']['qbf_query'] = array ( '#type' => 'hidden', '#value' => $query_info['callback'], ); $qbf_form['qbf']['qbf_save_name'] = array ( '#title' => t('Name of query in your save list'), '#type' => 'textfield', '#required' => TRUE, '#default_value' => empty($query->name) ? t('@label - @time', array('@label' => $query_info['label'], '@time' => format_date(time(), 'large'))) : $query->name, ); $qbf_form['qbf']['qbf_perform'] = array ( '#submit' => array('_qbf_form_perform_submit'), '#validate' => array('_qbf_form_perform_validate'), '#type' => 'submit', '#value' => t('Perform query'), ); $qbf_form['qbf']['qbf_save'] = array ( '#submit' => array('_qbf_form_save_submit'), '#validate' => array('_qbf_form_save_validate'), '#type' => 'submit', '#value' => t('Save query'), ); return $qbf_form; } /** * Implement hook_forms(). * * @link http://drupal.org/node/144132#hook-forms @endlink * * hook_qbf_register() returns an array of QBF-able node types, indexed by the * node type, with the following properties: * - form: the name of the hook_form() implementation (a $form_id) * - label: the human-readable type name under which the queries are saved by QBF * - callback: the function QBF must invoke to query the node type. It will * receive the query type and a filtered version of $form_state['values'] * containing only valid node fields, and must return a themed grid of query * results, which will be displayed as a #markup FAPI element. In advanced * uses, a single callback can be used for several query types by using the * query type parameter to know what the values apply to. * * @ingroup forms * @ingroup hooks * * @param string $qbf_form_id * @param array $args * @return array */ function qbf_forms($args = NULL) { static $forms = array(); if (empty($forms)) { $hook_name = 'qbf_register'; // dsm(array("QBF_forms $qbf_form_id" => $args)); // More efficient than using module_invoke_all: we avoid array-merging + re-looping foreach (module_implements($hook_name) as $module) { $arImplementations = module_invoke($module, $hook_name); // dsm($arImplementations); foreach ($arImplementations as /* $node_type => */ $query_info) { $qbf_form_id = 'qbf_' . $query_info['form']; $forms[$qbf_form_id] = array ( 'callback' => 'qbf_form', 'callback arguments' => array($query_info, $qbf_form_id), ); } // foreach implementation } // foreach module } // if empty return $forms; } /** * List queries owned by a given user. * * @param int $uid > 0 * @return array */ function qbf_get_queries_by_user($uid = NULL) { if (is_null($uid)) { global $user; $uid = $user->uid; } $sq = 'SELECT qq.qid, qq.uid, qq.name, qq.query, qq.updated ' . 'FROM {%s} qq ' . 'WHERE qq.uid = %d ' . 'ORDER BY qq.name '; // no db_rewrite_sql: this function is not in a menu callback, so it is up to // the caller to check access $q = db_query($sq, QBF_TABLE_NAME, $uid); $ret = array(); while ($o = db_fetch_object($q)) { $ret[$o->qid] = $o; // qid is the PK, so it is present and unique } return $ret; } /** * Implement hook_menu(). * * @return array */ function qbf_menu() { $items = array(); $items[QBF_PATH_MAIN . '/demo'] = array ( 'title' => 'QBF Demo', 'access arguments' => array(QBF_PERM_QUERY), 'page callback' => 'qbf_show', 'type' => MENU_NORMAL_ITEM, ); $items[QBF_PATH_SETTINGS] = array ( 'title' => 'Query-By-Form', 'access arguments' => array(QBF_PERM_ADMIN), 'page callback' => 'drupal_get_form', 'page arguments' => array('qbf_admin_settings'), 'type' => MENU_NORMAL_ITEM, ); $items[QBF_PATH_MAIN . '/%qbf_query'] = array ( 'type' => MENU_CALLBACK, 'access arguments' => array(QBF_PERM_QUERY), 'page callback' => '_qbf_query_form', 'page arguments' => array(1), ); $items[QBF_PATH_MAIN . '/%qbf_query/delete'] = array ( 'type' => MENU_CALLBACK, 'access arguments' => array(QBF_PERM_QUERY), 'page callback' => '_qbf_query_delete', 'page arguments' => array(1), ); return $items; } /** * Implement hook_mail(). * * @param string $key * @param array $message * @param array $params * @return void */ function qbf_mail($key, &$message, $params) { // dsm(array('QBF_mail key' => $key, 'message' => $message, 'params' => $params)); $deletor_tokens = user_mail_tokens($params['deletor'], $params['language']->language); $tokens = array_merge($deletor_tokens, array ( '!qname' => $params['query']->name, '!qid' => $params['query']->qid, )); $message['subject'] = t('Effacement d\'une recherche !site enregistrée', $tokens); $message['body'] = t("!date\n\nVotre recherche !qid: !qname\nsur le site !site vient d'être effacée par !username.", $tokens); } /** * Implement hook_perm(). * * @todo D7: Format will change * @see http://drupal.org/node/224333#descriptions-permissions * * @ingroup hooks * @return array */ function qbf_perm() { $ret = array ( QBF_PERM_ADMIN, QBF_PERM_QUERY, ); return $ret; } /** * Load a saved QBF query. * * @link http://drupal.org/node/109153#load @endlink * * @param int $us_qid * @return array * A form_values array */ function qbf_query_load($us_qid) { static $query = NULL; // Only allow query loading by logged-in users if (user_is_anonymous()) { return FALSE; } // Filter out visibly invalid values $qid = (is_numeric($us_qid) && ($us_qid > 0)) ? $us_qid : 0; if (is_null($query)) { $sq = 'SELECT qq.qid, qq.uid, qq.type, qq.name, qq.query ' . 'FROM {%s} qq ' . 'WHERE qq.qid = %d '; // db_rewrite_sql does not apply here: access control is further down $q = db_query($sq, QBF_TABLE_NAME, $qid); $query = db_fetch_object($q); // 0 or 1 row: we are querying on the primary key if ($query !== FALSE) { $query->query = unserialize($query->query); // dsm($query); } } global $user; $ret = (isset($query) && (($query->uid == $user->uid) || user_access(QBF_PERM_ADMIN))) ? $query : FALSE; return $ret; } /** * Provide an optional automatic mapping mechanism for query building. * * This function takes a partly built query map $ar_queryMap, and a defaults * array to complete it in $ar_defaults, and returns a fully built query array * ready to be used for querying. * * @param array $ar_query_map * @param array $ar_defaults * @return array */ function qbf_query_mapper($ar_query_map = array(), $ar_defaults = array()) { $ret = array(); foreach ($ar_query_map as $name => $value) { // accept NULL, empty strings... if (!is_array($value)) { $value = array(); } $item = $value; foreach ($ar_defaults as $default_key => $default_value) { if (!array_key_exists($default_key, $item)) { $item[$default_key] = is_null($default_value) ? $name : $default_value; } // else if is already in $item, so we don't touch it } $ret[$name] = $item; } return $ret; } error_reporting($_qbf_er); function qbf___________________________________________________(){} // ======== D6 LIMIT ================================================================================================== /** * Implement hook_profile_alter(). * * Add saved queries to the profile rendering * * @ingroup hooks * @param object $account * @return void */ function qbf_profile_alter(&$account) { // @TODO D6 use $account->content instead of $fields: check whether this is sufficient global $user; // Only allow field to QBF admins and own user if ($user->uid != $account->uid && !user_access(QBF_PERM_ADMIN)) { return; } $ar_queries = qbf_get_queries_by_user($account->uid); $count = count($ar_queries); // @todo Create New link needs to use hook_qbf_register info $new_query_link = l(t('Create new query'), JOB_PATH_MAIN); $none_message = ($account->uid == $user->uid) ? t('None yet. !newQuery', array('!newQuery' => $new_query_link)) : t('None yet.'); $saved = ($count > 0) ? format_plural($count, 'One saved query. ', '@count saved queries. ') . l(t('View/edit'), "user/$account->uid/edit/qbf") : $none_message; // @todo Support per-application/per-node profile categories $cat_name = variable_get(QBF_VAR_PROFILE_CATEGORY, QBF_DEF_PROFILE_CATEGORY); /* * Due to the way profile.module works, existing categories are never empty, * so any existing category name points to a non-empty array */ if (!array_key_exists($cat_name, $account->content)) { $account->content[$cat_name] = array(); } // @FIXME: breaks drupal_render() // $account->content[$cat_name] += array // ( // 'job-saved' => array // ( // 'title' => t('Saved queries'), // 'value' => $saved, // 'class' => 'job-saved-queries', // ), // ); // dsm(array("jpa fields" => $account->content)); }