modules/connect/connect.module

<?php
// $Id: connect.module,v 1.6 2009/04/03 19:09:52 stevem Exp $

/*
 *  connect.module
 *
 *  steve@openconcept.ca
 *
 *  This module uses a couple of GPL-licensed icons from the
 *  Silk icon set 1.3: http://www.famfamfam.com/lab/icons/silk/
 * 
 */


/**
 * Implementation of hook_help
 */
function connect_help($section = 'admin/help#connect') {
  $output = '';
  switch ($section) {
    case 'admin/modules#description':
      $output = t("Allows the creation of online actions, petitions, event registration ... anything where you want to associate two kinds of data in a one-to-many way.");
      break;
    case 'admin/help#connect':
      $output = file_get_contents(drupal_get_path('module', 'connect') .'/connect_help.html');
      break;
  }
  return $output;
}


/**
 * Implementation of hook_perm
 */
function connect_perm() {
  return array('manage connect', 'create connect campaign', 'access connect');
}


/*
 * Implementation of hook_cron
 */
function connect_cron() {  
  // clear out expired cached data
  require_once(drupal_get_path('module', 'connect') .'/connect_lookup.php');
  $cache_names = _connect_get_cache_names();
  foreach ($cache_names as $name => $title) {
    $lifetime = variable_get("connect_cache_$name", '0 s');
    list($num, $unit) = sscanf($lifetime, '%d %s');
    if ($num == 0) {
      continue;
    }
    switch ($unit) {
    case 'm' :
      $seconds = 60;
      break;
    case 'h' :
      $seconds = 60*60;
      break;
    case 'd' :
      $seconds = 60*60*24;
      break;
    default :
      continue;
      break;
    }
    $sql = "DELETE FROM {connect_cache} WHERE type='%s' AND created < %d;";
    $result = db_query($sql, $name, time() - $num * $seconds);
  }
}


/**
 * Implementation of hook_menu
 */
function connect_menu($may_cache) {
  require_once('connect_actions.php');
  
  $items = array();

  if ($may_cache) {
    // administer module settings
    $items[] = array(
      'path' => 'admin/settings/connect',
      'title' => t('Connect'),
      'description' => t("Configure your parent and participant node types."),
      'callback' => 'connect_admin_overview_page',
      'access' => user_access('manage connect'),
      );
      
    // register callbacks for connect_action functions
    $empty = array();
    $all_actions = connect_get_actions();
    foreach ($all_actions as $action) {
      $action_menu = call_user_func($action, $empty, $empty, 'menu');
      if (!empty($action_menu)) {
        $items = array_merge($items, $action_menu);
      }
    }
  }
  
  //TODO move the non-cached menu callbacks to the action functions too
  else {
    if (arg(0) == 'node' && is_numeric(arg(1))) {
      $node = node_load(arg(1));
      if ( !connect_is_parent_node($node) ) {
        return;
      }

      $can_admin = (($user->id == $node->uid && user_access('create connect campaign')) || user_access('manage connect'));

      // cache report ?
      $child = array();
      $cache_required = FALSE;
      $actions = connect_get_actions($node->nid);
      foreach ($actions as $action) {
        $desc = call_user_func($action, $node, $child, 'describe', 'parent');
        if (isset($desc['cache']) && $desc['cache'] == TRUE) {
          $items[] = array(
            'path' => 'node/'. arg(1) .'/connect/status',
            'title' => t('Cache report'),
            'callback' => 'connect_node_list_page',
            'access' => $can_admin,
            'type' => MENU_LOCAL_TASK,
            'weight' => 10,
          );
          break;
        }
      }

      // re-send emails
      if (in_array('connect_action_send_email', $actions)) {
        $items[] = array(
          'path' => 'node/'. arg(1) .'/connect/resend_failed_mail',
          'title' => t('Re-send emails'),
          'callback' => '_connect_action_send_email_resend_failed',
          'access' => $can_admin,
          'type' => MENU_LOCAL_TASK,
          'weight' => 10
        );
      }

      // select functions
      $items[] = array(
        'path' => 'node/'. arg(1) .'/connect/admin/functions',
        'title' => t('Functions'),
        'callback' => 'connect_node_config_functions',
        'access' => $can_admin,
        'type' => MENU_LOCAL_TASK,
        'weight' => 5
        );

      // configure functions
      $items[] = array(
        'path' => 'node/'. arg(1) .'/connect/admin/settings',
        'title' => t('Settings'),
        'callback' => 'connect_node_config_settings',
        'access' => $can_admin,
        'type' => MENU_LOCAL_TASK,
        'weight' => 6
        );
    }
    
    //embedded function  
    $items[] = array(
      'path' => 'connect/embed/'. arg(2),
      'title' => t('Connect Embed'),
      'access'   => TRUE,
      'callback' => '_connect_embed',
      'callback arguments' => array(arg(2)),
      'type'     => MENU_CALLBACK,
    );   
  }
  return $items;
}


/**
 *  Implementation of hook_block
 */
function connect_block($op = 'list', $delta = 0, $edit = array()) {
  require_once('connect_blocks.php');
  switch ($op) {
    case 'list':
      return connect_block_list();
      break;
      
    case 'view':
      return connect_block_view($delta);
      break;
  }
}


/**
 *  Implementation of hook_nodeapi
 */
function connect_nodeapi(&$node, $op, $teaser = NULL, $page = NULL) {
  $is_parent = connect_is_parent_node($node);
  $is_child  = $is_parent ? FALSE : connect_is_participant_node($node);
  if (!$is_parent && !$is_child) {
    return;
  }
  require_once('connect_actions.php');

  // prevent PHP4 from throwing a fit
  if (PHP_VERSION < 5) error_reporting(E_ALL ^ E_NOTICE ^ E_WARNING);

  // child nodes
  if ($is_child) {
    // prevent looping
    $lock = "connect_child_lock_$op";
    if (!isset($_SESSION[$lock])) {
      $_SESSION[$lock] = TRUE;
    }
    else {
      return $_SESSION[$lock];
    }

    // call hooks
    $parent =& _connect_parent_node();
    if (!$parent) {
      $temp   = node_load(connect_get_parent($node));
      $parent =& _connect_parent_node($temp);
    }
    connect_call_hooks($parent, $node, $op, 'child');
    
    // release lock
    unset($_SESSION[$lock]);
    return;
  }

  // don't cache me
  global $conf;
  $conf['cache'] = FALSE;
  
  // parent nodes
  switch ($op) {
    case 'delete' :
      // TODO: delete all child nodes too?
      $sql = "DELETE FROM {connect_data} WHERE pid=%d;";
      db_query($sql, $node->nid);
      break;

    case 'view':
      if ($teaser == TRUE || !user_access('access connect') || !_connect_captcha_test()) {
        break;
      }
      drupal_add_css(drupal_get_path('module', 'connect') .'/connect.css');
      $parent =& _connect_parent_node($node); // save a reference to this node
      $child  = NULL;

      // allow actions to add display items to the node
      $weight = 5; // arbitrary
      $additions = connect_call_hooks($parent, $child, 'display', 'parent');
      foreach ($additions as $function => $add) {
        $node->content[$function] = array(
          '#value'  => t($add['data']),
          '#weight' => $weight++,
        );
      }

      // display messages, forms, etc. depending on status
      $show_form = TRUE;
      $status = connect_call_hooks($parent, $child, 'status', 'parent');
      foreach ($status as $add) {
        if ( isset($add['show_form']) && $add['show_form'] === FALSE ) {
          $show_form = FALSE;
        }
        if ( isset($add['status']) && !empty($add['status']) ) {
          drupal_set_message( t($add['status']) );
        }
      }

      // add form
      if ($show_form) {
        $form = drupal_get_form('connect_form_page');
        $node->content['connect_form_page'] = array(
          '#value' => $form,
          '#weight' => 20,
        );
      }
      break;
  }
}

/*
 *  Implementation of hook_user
 *
 */
function connect_user($op, &$edit, &$account, $category = NULL) {
  switch ($op) {
  //clear session info on login/out
    case 'logout':
    case 'login':
      foreach ($_SESSION as $key => $value) {
        if (strpos($key, 'connect_') !== FALSE) unset($_SESSION[$key]);
      }
      break;
  }
}


/**
 * Menu callback: cache report
 */
function connect_node_list_page() {
  $nid = arg(1);
  $parent = node_load($nid);
  _connect_parent_node($parent); // cache the parent
  return drupal_get_form('connect_campaign_cache_report_form');
}


/**
 * Menu callback: displays function selection page
 */
function connect_node_config_functions() {
  require_once('connect_admin.php');
  drupal_set_title(t('Select functions'));
  return drupal_get_form('connect_node_functions_form');
}

/**
 * Menu callback: displays function configuration page
 */
function connect_node_config_settings() {
  require_once('connect_admin.php');
  drupal_set_title(t('Function settings'));
  return drupal_get_form('connect_node_settings_form');
}

/**
 * Menu callback; displays the connect administration page.
 */
function connect_admin_overview_page() {
  require_once('connect_admin.php');
  drupal_set_title(t('Connect settings'));
  return drupal_get_form('connect_admin_form');
}


/**** FORM: participate ****/

function connect_forms() {
  $forms['connect_form_page'] = array(
    'callback' => 'connect_form',
    'callback arguments' => array('page'),
  );
  $forms['connect_form_block'] = array(
    'callback' => 'connect_form',
    'callback arguments' => array('block'),
  );
  return $forms;
}

function connect_form_page_validate($form_id, &$form_values) {
  connect_form_validate($form_id, &$form_values);
}

function connect_form_page_submit($form_id, &$form_values) {
  connect_form_submit($form_id, &$form_values);
}

function connect_form_block_validate($form_id, &$form_values) {
  connect_form_validate($form_id, &$form_values);
}

function connect_form_block_submit($form_id, &$form_values) {
  connect_form_submit($form_id, &$form_values);
}


/** added argument for block view **/

function connect_form($type = 'page') {
  $parent =& _connect_parent_node();
  if (!$parent || !isset($parent->nid)) return;
  
  $participant_type = connect_node_options($parent->nid, 'participant_type');
  if (!$participant_type) return;

  // generate form
  $participant->nid = NULL;
  $participant->type = $participant_type;
  $form = content_form($participant);

  // remove some fields (hidden, computed)
  $cck_type = content_types($participant_type);
  foreach ($cck_type["fields"] as $field) {
    if ($field['display_settings']["teaser"]["format"] == "hidden" || $field['display_settings']["full"]["format"] == "hidden" || $field["type"] == "computed") {
      unset($form[ $field['field_name'] ]);
    }
  }

  // allow action functions to alter the form
  $temp = connect_call_hooks($parent, $form, 'form_alter', 'child');
  if ($temp) $form = $temp;

  // add call to action
  $form['call_to_action'] = array(
    '#prefix' => '<div id="connect-form-title">',
    '#value' => t(connect_node_options($parent->nid, 'call_to_action')),
    '#suffix' => '</div>',
    '#weight' => -10,
  );

  // pass the participant type along so that a custom form can be generated in the template, if desired
  $form['participant_type'] = array(
    '#type' => 'hidden',
    '#value' => $participant_type,
  );

  $form['submit'] = array(
    '#type' => 'submit',
    '#value' => t('Submit'),
    '#weight' => 15,
  );
    
  return $form;
}


function connect_form_validate($form_id, &$form_values) {
  // call connect functions validation
  $parent =& _connect_parent_node();
  $results = connect_call_hooks($parent, $form_values, 'validate', 'child');
  if (!empty($results)) {
    foreach ($results as $result) {
      if ($result['value'] == FALSE) form_set_error('', $result['message']);
    }
  }

  // call cck fields validation
  $return       = array();
  $nothing      = array();
  $cck_type     = content_types($form_values['participant_type']);
  $cck_fields   = $cck_type['fields'];
  $widget_types = _content_widget_types();  
  foreach ($form_values as $form_field => $field_value) {
    $module   = $widget_types[$cck_fields[$form_field]['widget']['type']]['module'];
    $function = $module .'_widget'; 
    if (function_exists($function)) {
      $result = $function('validate', $nothing, $cck_fields[$form_field], $form_values[$form_field]);
    }
  }
}

function connect_form_submit($form_id, &$form_values) {
 
  // build CCK node
  foreach ($form_values as $key => $value) {
    // simple form elements
    if (isset($value[0])) {
      $node_cck->$key = array($value[0]);
    }
    // single-value elements
    elseif (isset($value['key'])) {
      $node_cck->$key = array(array('value' => $value['key']));
    }
    // multi-value elements
    elseif (isset($value['keys'])) {
      // select lists
      if (is_array($value['keys'])) {
        foreach ($value['keys'] as $item_key => $item_value) {
          if ($item_key === $item_value) {
            $temp_array[] = array('value' => $item_value);
          }
        }
        $node_cck->$key = $temp_array;
      }
      // checkboxes
      else {
        $node_cck->$key = array(array('value' => $value['keys']));
      }
    }
  }

  $parent          =& _connect_parent_node();
  $node_cck->nid   = NULL;
  $node_cck->type  = connect_node_options($parent->nid, 'participant_type');
  $node_cck->title = 'participant in \''. $parent->title .'\'';
  node_save($node_cck);
  
  // allow actions to change redirected page
  $redirect = connect_call_hooks($parent, $node_cck, 'redirect', 'parent');
  if (!empty($redirect)) {
    // just grab first one ... yech, but necessary
    $keys = array_keys($redirect);
    $target = $redirect[$keys[0]];
  }
  else {
    $target = 'node/'. $parent->nid;
  }
  
  return $target;
}


/********************************
 *   UTILITY FUNCTIONS
 ********************************/

// is this node a participant node?
function connect_is_participant_node(&$node) {
  $participant_nodes = variable_get('connect_participant_nodes', array());
  $return = in_array($node->type, $participant_nodes);
  if ( $return ) {
    $sql = 'SELECT pid FROM {connect_data} WHERE nid = %d';
    $parent = db_result(db_query($sql, $node->nid));
    if ($parent) $node->parent_id[0]['value'] = $parent;
  }
  return $return;
}


// is this node type a parent node type?
function connect_is_parent_node(&$node) {
  $parent_nodes = variable_get('connect_parent_nodes', array());
  return (in_array($node->type, $parent_nodes));
}


// test for valid canadian postal code
function connect_is_postalcode($code) {
  $regexp = '/^[a-zA-Z][0-9][a-zA-Z]\s*[0-9][a-zA-Z][0-9]$/';
  return preg_match($regexp, $code);
}


// get db info for CCK field
function _connect_get_cck_db_info($type) {
  $field   = content_fields($type);
  $db_info = content_database_info($field);
  return $db_info;
}


// gets form value key(s) for cck field
function connect_get_field_keys($field) {
  if ($field == 'title' || $field == 'body' ) {
    return array('value');
  }
  $test_db = _connect_get_cck_db_info($field);
  if (isset($test_db['columns'])) {
    return array_keys($test_db['columns']);
  }
  else {
    return array();
  }
}


// counts the participants for a parent
function connect_participant_count(&$parent) {
  $sql   = "SELECT count(*) FROM {connect_data} WHERE pid = %d";
  $count = db_result(db_query($sql, $parent->nid));
  return $count;
}


// what type of participant does this parent use?
/*
function connect_get_participant_type($parent_nid) {
  $type   = connect_node_options( $parent_nid, 'participant_type' );
  return $type;
}
*/


// return an array of participant node types suitable for use in forms
function connect_participant_types_options() {
  $array = array();
  $values = variable_get('connect_participant_nodes', array() );
  foreach ($values as $value) {
    $array[$value] = $value;
  }
  return $array;
}


/**
 * Returns an array of connect_action_* functions
 * if an nid is passed in, returns the declared functions for that parent
 * otherwise, it returns all the available actions
 */
function connect_get_actions( $parent_id = FALSE ) {
  require_once('connect_actions.php');
  static $functions = array();
  $key = $parent_id ? (int) $parent_id : 'all';
  if (!isset($functions[$key])) {
    if ($key == 'all') {
      $allfns = get_defined_functions();
      $array  = $allfns['user'];
      foreach ($array as $fid => $fname) {
        if (strpos($fname, 'connect_action_') !== 0) {
          unset($array[$fid]);
        }
      }
      asort($array);
    }
    else {
      $array = connect_node_options($key, 'connect_actions');
      if (empty($array)) {
        $array = array('connect_action_basic');
      }
    }
    $functions[$key] = $array;
  }
  return $functions[$key];
}


/**
 * returns an array of arrays mapping action variables onto CCK fields
 * array( 'parent' => array( action => cck, ... ), 'child' => array( action => cck, ... ) )
 */
function connect_get_map( $parent_id = 0 ) {
  static $maps = array();
  if ( !isset($maps[$parent_id]) ) {
    $maps[$parent_id] = connect_node_options( $parent_id, 'connect_map' );
  }
  return $maps[$parent_id];
}


/**
 * determines all the required variables for a given campaign node
 * @ return
 *  array( 'parent' => array(), 'child' => array() )
 */
function connect_get_required_vars(&$node, &$child) {
  if (empty($node)) return;
  
  $parent    = array();
  $variables = array();
  $vars_done = array();

  $function_vars = connect_call_hooks($node, $child, 'requires', 'parent');
  foreach ($function_vars as $fn_name =>  $fn_requires) {
    foreach (array('parent', 'child') as $target ) {
      if (isset($fn_requires[$target])) {
        $$target = array_merge( $$target,  $fn_requires[$target] );
      }
    }
    if (isset($fn_requires['variables'])) {
      foreach ($fn_requires['variables'] as $name => $item) {
        if (!isset($vars_done[$name])) {
          $vars_done[$name] = TRUE;
          $variables[$fn_name][$name] = $item;
        }
      }
    }
  }
  return array(
    'parent' => $parent,
    'child' => $child,
    'variables' => $variables,
  );
}


/**
 *  determine the content fields in a node type and
 *  return as an array for use in admin forms
 */
function connect_get_node_fields( $typename ) {
  $options = array( 0 => '', 'title' => 'Title' );
  // body?
  $type = node_get_types('type', $typename);
  if ($type->has_body) $options['body'] = 'Body';
  $cck_type = content_types($typename);
  $fields   = $cck_type["fields"];
  if (!empty($fields)) {
    foreach ($fields as $field) {
      $options[$field['field_name']] = $field['widget']['label'];
    }
  }
  //asort($options);
  return $options;
}


/**
 * returns or sets the required value from $target = child | parent
  if $value is set, this is a setter, otherwise, it's a getter
 */
function connect_value($variable = '', &$parent, &$child, $target = '', $value=FALSE) {
  $return = '';
  if (!empty($variable) && isset($parent->nid) && ($target == 'child' || $target == 'parent')) {
    $map  = connect_get_map($parent->nid);
    $var  = $map[$variable];
    $path = _connect_get_field_path($$target, $var);
    if (!$path) return FALSE;
    
    if (!$value) {
      $exp = '$return = stripslashes($'. $target . $path .');';
      eval($exp);
    }
    else {
      $exp = '$'. $target . $path .' = "'. addslashes(trim($value)) .'";';
      eval($exp);
    }
  }
  return $return;
}


/**
 * Returns the correct object or array path to retrieve a node field value
 */
function _connect_get_field_path( $target = FALSE, $var = FALSE) {
  if (!$target || !$var) return FALSE;

  $path = '';
  // standard fields
  if ($var == 'body' || $var == 'title') {
    if (is_object($target)) {
      $path = "->$var";
    }
    else {
      $path = "['$var'][0]['value']";
    }

  // cck fields
  }
  elseif (!empty($var)) {
    $key  = connect_get_field_keys($var);
    if (is_object($target)) {
      $var = "->$var";
    }
    else {
      $var = "['$var']";
    }
    $path = $var .'[0][\''. $key[0] .'\']';
  }
  return $path;
}


/**
 * Returns the admin options for a parent node
 * @param $nid: the node id of the parent
 * @param $field: the name of the option to retrieve | NULL to retrieve all
 * @param $value: if provided, sets $field to $value
 *
 */
function connect_node_options($nid = 0, $field = NULL, $value = NULL) {
  if (empty($nid)) return FALSE;

  // cache this info
  static $options = array();
  if (!isset($options[$nid])) {
    $temp = variable_get('connect_'. $nid .'_options', FALSE);
    $options[$nid] = $temp ? unserialize($temp) : array();
  }

  // setter
  if ($value !== NULL && $field !== NULL) {
    $options[$nid][$field] = $value;
    variable_set( 'connect_'. $nid .'_options', serialize($options[$nid]) );
  }

  // getter
  if ($field !== NULL) {
    $return = isset($options[$nid][$field]) ? $options[$nid][$field]: '';
  }
  else {
    $return = $options[$nid];
  }

  return $return;
}


/**
 * Iterates through connect_action_* functions and calls them for the current operation and target
 */
function connect_call_hooks(&$parent, &$child, $op = '', $target = 'child') {
  $debug_hooks = FALSE; // use this to turn on a display of what hooks are called in what order
  $return = array();

  // parent always required, child only if acting on child, operation always required
  if (!$op || !$parent || ($target=='child' && !$child)) {
    return $return;
  }

  $parent = empty($parent) ? array() : $parent;
  $child  = empty($child)  ? array() : $child;
  $debug_parent = empty($parent) ? 'empty' : gettype($parent);
  $debug_child  = empty($child)  ? 'empty' : gettype($child);

  if ( $op != 'describe' ) {
    $actions = connect_get_actions($parent->nid);
  }
  else {
    $actions = connect_get_actions();
  }
  
  if ($debug_hooks) drupal_set_message("$op ($target | $debug_parent | $debug_child)");
  
  foreach ($actions as $action) {
    if ($debug_hooks) drupal_set_message("$action 1");

    // make sure we have the required vars before calling the function
    // skip check for purely informational $op values
    $skip_check = array('describe','requires', 'admin-validate');
    if (!in_array($op, $skip_check)) {
      if (_connect_hook_check_requirements($parent, $child, $action, $target) !== TRUE){
        continue;
      }
    }
    
    if ($debug_hooks) drupal_set_message("$action 2"); 

    // call the hook
    $action_return = call_user_func($action, &$parent, &$child, $op, $target);
    if ($action_return) {
      $return[$action]  = $action_return;
    }
  }
  return $return;
}


/*
 *  tests to see that the required settings are present for a given action
 */
function _connect_hook_check_requirements(&$parent, &$child, $action, $target) {
  static $requirements_ok = array();
  if (!isset($requirements_ok[$action])) {
    $required = call_user_func($action, $parent, $child, 'requires', $target);
    if (empty($required)) return TRUE; // no settings = no requirements, but let's not cache that

    // default to true, test for exceptions
    $requirements_ok[$action] = '';
    
    // parent + child fields, all required
    $map = connect_get_map($parent->nid);
    $map_keys = array_keys($map);
    foreach (array('parent', 'child') as $type) {
      if (isset($required[$type])) {
        foreach ($required[$type] as $name => $desc) {
          if (!in_array($name, $map_keys) || empty($map[$name])) {
            $requirements_ok[$action] .= "'$desc' (required field in $type node)<br />\n";
          }
        }
      }
    }
    
    // settings, might be optional
    if (isset($required['variables'])) {
      foreach ($required['variables'] as $name => $desc) {
        $value = connect_node_options($parent->nid, $name);
        if ($desc['#required'] == TRUE && empty($value)) {
            $requirements_ok[$action] .= $desc['#title'] . "<br />\n";
        }
      }
    }

    // return TRUE or a message
    if (empty($requirements_ok[$action])) $requirements_ok[$action] = TRUE;
  }
  return $requirements_ok[$action];
}

/*
 *  determine parent nid for child node
 */
function connect_get_parent(&$child) {
  if (empty($child->nid)) return 0;
  
  static $parents = array();
  if (!isset( $parents[$child->nid])) {
    $sql = "SELECT pid FROM {connect_data} WHERE nid = %d;";
    $parents[$child->nid]= db_result(db_query($sql, $child->nid));
  }
  $child->connect_parent_id = $parents[$child->nid];
  return $parents[$child->nid];
}


/*
 *  determines if connect_form captcha is required, and if so, if it's enabled
 */
function _connect_captcha_test($form_id = 'connect_form_page') {
  $captcha_required = variable_get('connect_captcha_required', 'yes');
  if ($captcha_required == 'yes') {
    $captcha = db_result(db_query("SELECT type FROM {captcha_points} WHERE form_id = '%s'", $form_id));
    if (!$captcha) {
      if (!user_access('skip CAPTCHA')) {
        watchdog('debug', 'connect form cannot be displayed: no CAPTCHA defined');
        return FALSE;
      }
      else {
        drupal_set_message('Warning: CAPTCHA has not been configured for connect forms yet.');
      }
    }
  }
  return TRUE;
}


/*
 *  use this wherever it's necessary to load the parent
 *  enforces a singleton pattern to solve reference problems in PHP4
 *
 *  made it an array to fix problems with displaying the form in a block
 *  - it is called twice when a block is visible and the current node is also a campaign
 */
function &_connect_parent_node($node = NULL) {
  static $parent_node = array( 0 => NULL );
  if ($node == NULL && arg(0) == 'node') {
    $nid = arg(1);
  }
  else {
    $nid = isset($node->nid) ? $node->nid : 0;
  }
  if (!isset($parent_node[$nid])) {
    $parent_node[$nid] = $node;
  }
  return $parent_node[$nid];
}


/*
 *  returns cck fields in array for use in forms
 */
function _connect_get_child_fields($child_type = NULL) {
  $cck_options = array();
  if ($child_type) {
    $cck_info = _content_type_info();
    $cck_vars = $cck_info['content types'][$child_type]['fields'];
    foreach ($cck_vars as $name => $field) {
      if ($field['display_settings']['teaser']['format'] != 'hidden' && $field['display_settings']['full']['format'] != 'hidden') {
        $cck_options[$name] = $field['widget']['label'];
      }
    }
    $cck_options[''] = '';
    asort($cck_options);
  }
  return $cck_options;
}


/*
 * accept a range of values that mean 'yes'/true
 */
function _connect_positive_value($in) {
  $positive_strings = array('y', 'yes', 'true', 'ok', '1');
  if (in_array(strtolower($in), $positive_strings) || $in === TRUE) {
    return TRUE;
  }
  else {
    return FALSE;
  }
  //if (empty($in) || strtolower($in) == 'no' || strtolower($in) == 'n') {
  //  return FALSE;
  //}
  //else {
  //  return TRUE;
  //}
}


/*
 *  menu callback: display the participants
 */
function _connect_action_display_participants($parent_nid = NULL) {
  $output = FALSE;
  if (is_numeric($parent_nid)) {
    $parent = node_load($parent_nid);
    drupal_set_title('"'. $parent->title .'" '. connect_node_options($parent->nid, 'participant_title'));

    // determine display field names
    $header = array();
    $display_fields = variable_get('connect_'. $parent->nid .'_options', FALSE);
    if (!$display_fields) return;
    
    $display_fields = unserialize($display_fields);
    foreach ($display_fields as $key => $value) {
      if (empty($value) || strpos($key, 'display_participants_fields_') === FALSE) {
        unset($display_fields[$key]);
      }
    }
    
    // set header
    $child_type  = connect_node_options($parent->nid, 'participant_type');
    $cck_options = _connect_get_child_fields($child_type);
    foreach ($display_fields as $key => $value) {
      $header[] = $cck_options[$value];
    }

    // double opt-in? 
    $double_opt_in = (in_array('connect_action_double_optin', connect_get_actions($parent->nid)));
    
    // walk through participants
    $pager  = connect_node_options($parent->nid, 'display_participants_pager');
    if (!$pager) $pager = 25; 
    $data   = array();
    $sql    = "SELECT nid FROM {connect_data} WHERE pid = %d";
    $result = pager_query($sql, $pager, 0, NULL, $parent->nid);
    while ($row = db_fetch_object($result)) {
      $this_item = array();
      $child   = node_load($row->nid);
      $display = connect_value('display_participants_displayme', $parent, $child, 'child');
      
      // double opt-in?
      if ($double_opt_in) {
        $opt_in = connect_value('double_optin_token', $parent, $child, 'child');
        if (!_connect_positive_value($opt_in)) continue;
      }
      
      if (_connect_positive_value($display)) {
        foreach ($display_fields as $key => $value) {
          $path = _connect_get_field_path($child, $value);
          $exp = '$this_item[] = $child'. $path .';';
          eval($exp);
        }
        $data[] = $this_item;
      }
    }
    if (empty($data)) return theme_page('<p>no participants</p>');
  }

  $link    = theme('connect_action_display_participants_return', $parent->title, $parent->nid);
  $output  = theme_table($header, $data) . $link;
  $output .= theme('pager', NULL, $pager);
  return $output;
}

/* themeable function */
function theme_connect_action_display_participants_return($parent_title, $parent_nid) {
  $link =  l(t('Return to ') . $parent_title, 'node/'. $parent_nid);
  return "<div id='connect-returnto-link'>&raquo; ". $link .'</div>';
}


/** report for admins **/

function connect_campaign_cache_report_form() {
  $parent =& _connect_parent_node();
  $form = array();

  // intro
  $form['report_intro'] = array(
    '#value' => 'This form allows you to create reports based on when participant data was cached by connect. If you keep persistent caches, this offers a rough measurement of the number of participants who are new to your system. Note that this assumes you are using a connect feature that uses caching (such as email target lookups) and that caching has been turned on.',
  );
  
  // date
  $form['report_date'] = array(
    '#type' => 'date',
    '#title' => 'Date',
  );
  
  // operator
  $form['report_operator'] = array(
    '#type' => 'radios',
    '#title' => 'Date range',
    '#options' => array('Before this date', 'On or after this date'),
  );

  // type of report
  $form['report_type'] = array(
    '#type' => 'radios',
    '#title' => 'Type of report',
    '#options' => array('Numeric report', 'CSV'),
  );

  // cache to test
  require_once(drupal_get_path('module', 'connect') .'/connect_lookup.php');
  $cache_names = _connect_get_cache_names();
  $form['report_cache'] = array(
    '#type' => 'radios',
    '#title' => 'Cache to query',
    '#description' => 'Connect maintains a number of caches, each of which can be set to expire independently. Please select the cache that will be the basis of your query.',
    '#options' => $cache_names,
  );

  // relevant participant field
  $child_type  = connect_node_options($parent->nid, 'participant_type');
  $cck_options = _connect_get_child_fields($child_type);
  unset($cck_options['']);
  $form['report_field'] = array(
    '#type' => 'radios',
    '#title' => 'Cached participant field',
    '#description' => 'Please select the participant item that is cached as the "source" of the lookup (i.e., if the chosen cache stores the results of "Postal code to riding" lookups, select the participant field holding the postal code).',
    '#options' => $cck_options,
  );

  $form['submit'] = array(
    '#type' => 'submit',
    '#value' => t('Submit'),
  );

  return $form;
}


function connect_campaign_cache_report_form_submit($form_id, $form_values) {
  $output = '';
  $parent =& _connect_parent_node();
  
  // date
  $date = sprintf('%04d%02d%02d 00:00:00', $form_values['report_date']['year'], $form_values['report_date']['month'], $form_values['report_date']['day']);
  $date = strtotime($date);
  
  // participant field
  $cck_db     = _connect_get_cck_db_info($form_values['report_field']);
  $cck_table  = $cck_db['table'];
  $cck_column = $cck_db['columns']['value']['column'];

  // date operator
  $modal = ($form_values['report_operator'] == 0) ? '<': '>=';

  // CSV reports: set header
  if ($form_values['report_type'] > 0) {
    $child_type   = connect_node_options($parent->nid, 'participant_type');
    $child_fields = _connect_get_child_fields($child_type);
    unset($child_fields['']);
    $output = join(',', array_values($child_fields)) ."\n";
  }
    
  // loop through all children
  $path = FALSE;
  $sql  = "SELECT d.nid from {connect_data} d WHERE d.pid=%d;";
  $result = db_query($sql, $parent->nid);
  while ($row = db_fetch_object($result)) {
    $child = node_load($row->nid);
    if (!$path) {
      $path = _connect_get_field_path($child, $form_values['report_field']);
    }
    eval('$value = strtoupper($child'. $path .');');
    $value = preg_replace('/[^0-9A-Z]/', '', $value);

    // match value, date parameters
    $sql = "SELECT count(*) as total FROM {connect_cache} WHERE type='%s' AND source='%s' AND created $modal %d;";
    $count  = db_query($sql, $form_values['report_cache'], $value, $date);
    $number = db_result($count);
    if ($number > 0) {
      $cached_total++;
      if ($form_values['report_type'] > 0) {
        foreach ($child_fields as $field => $title) {
          $path = _connect_get_field_path($child, $field);
          eval('$item = $child'. $path .';');
          $line[] = '"'. str_replace('"', '""', $item) .'"';
        }
        if (!empty($line)) {
          $output .= join(',', $line) ."\n";
          $line = '';
        }
      }
    }
  }
  
  // display numeric report
  if ($form_values['report_type'] == 0) {
    $total = connect_participant_count($parent);
    drupal_set_message("total participants: $total");
    drupal_set_message("cached since ". date('d M Y', $date) .": $cached_total");
    return;