<?php
// $Id: citizenspeak.lib.php,v 1.3 2005/11/12 18:37:20 georgehotelling Exp $

/**
 * @file
 * Helper functions for the CitizenSpeak module
 */

function _citizenspeak_get_zips($nid) {
  $zip_result = db_query("SELECT zip, COUNT(*) AS from_zip FROM {citizenspeak_participants} WHERE nid = %d GROUP BY zip ORDER BY from_zip DESC", $nid);
  $distinct_zips = db_num_rows($zip_result);
  $zips = array();

  while ($row = db_fetch_array($zip_result)) {
    $zips[] = $row;
  }
  
  $total = db_result(db_query("SELECT COUNT(*) FROM {citizenspeak_participants} WHERE nid = %d", $nid));
  
  return array($distinct_zips, $zips, $total);  
}

/**
 * Split email addresses into an array
 *
 * @param $emails One or more email addresses separated with commas and spaces
 * @returns array of email addresses
 */
function _citizenspeak_split_emails($emails) {
  return preg_split('/[\s,]+/', $emails);
}

function _citizenspeak_validate_participation($edit) {
  $errors = false;
  if ($edit['name'] == "" && variable_get('citizenspeak_show_name', 1)) {
    form_set_error('name', t('You must enter your name'));
    $errors = true;
  }
  
  if (!valid_email_address($edit['email']) && variable_get('citizenspeak_show_city', 1)) {
    form_set_error('email', t('You must provide a valid email address'));
    $errors = true;
  }

  if ($edit['address'] == "" && variable_get('citizenspeak_show_address', 1)) {
    form_set_error('name', t('You must enter your address'));
    $errors = true;
  }  

  if ($edit['city'] == "" && variable_get('citizenspeak_show_city', 1)) {
    form_set_error('city', t('You must enter your city'));
    $errors = true;
  }

  if ($edit['state'] == "" && variable_get('citizenspeak_show_state', 1)) {
    form_set_error('state', t('You must enter your state'));
    $errors = true;
  }

  if (!_citizenspeak_valid_zipcode($edit['zip']) && variable_get('citizenspeak_show_zip', 1)) {
    form_set_error('zip', t('You must provide a 5 digit ZIP code'));
    $errors = true;
  }
  
  return !$errors;
}

function _citizenspeak_valid_zipcode($zip) {
  return preg_match('/^\d{5}$/', $zip);
}

function _citizenspeak_send_reminders($node) {
  $send_15  = variable_get('citizenspeak_remind_15', false);
  $send_50  = variable_get('citizenspeak_remind_50', false);
  $send_100 = variable_get('citizenspeak_remind_100', false);
  // Skip the DB hit if responses aren't sent
  if ($send_15 or $send_50 or $send_100) {
    $responses = db_result(db_query('SELECT COUNT(*) AS responses FROM {citizenspeak_participants} WHERE nid = %d', $node->nid));

    // Send the message if we are at a threshold
    if (($responses == 15 and $send_15) or
        ($responses == 50 and $send_50) or
        ($responses == 100 and $send_100)) {
      $owner = user_load(array("uid" => $node->uid));
      $headers = t('From: %site_name <%site_email>', array("%site_name" => variable_get("site_name", ""), "%site_email" => variable_get("site_mail", "")));
      $subject = variable_get('citizenspeak_reminder_subject', CITIZENSPEAK_DEFAULT_REMINDER_SUBJECT);
      $body = t(variable_get('citizenspeak_reminder_template', CITIZENSPEAK_DEFAULT_REMINDER_TEMPLATE), array("%title" => $node->title, "%count" => $responses, "%url" => url("node/$node->nid/report", null, null, true)));
      mail($owner->mail, $subject, $body, $headers);
    }
  }
}
?>