modules/enewsletter/enewsletter.module

<?php
// $Id: enewsletter.module,v 1.14 2005/03/24 00:41:46 MegaGrunt Exp $

// Author: Robert Castelo
// Support: development@cortextcommunications.com
// Info: http://www.cortextcommunications.com/development/newsletter

// ********** LINKS, PERMISIONS & HELP  *****************************


define('ANNOUNCEMENT', 1);
define('ANNOUNCEMENT_ENABLED', 1);
define('ANNOUNCEMENT_AUTO', 1);

function enewsletter_help($section = "admin/help#enewsletter") {

  switch ($section) {
    case 'admin/modules#description':
      return t('Enables users to subscribe to email announcements and newsletters.');
    case 'admin/help#enewsletter':
      return t('Enables users to subscribe to an email newsletter.');
    case 'admin/enewsletters':
      return t('Statistics for email newsletters.');
    case 'admin/enewsletters/add':
      return t('Create an email newsletter.');
    case 'admin/enewsletters/templates':
      return t('Create an email newsletter template.');
    case 'admin/enewsletters/templates/add':
      return '<p>' . t('Create an email newsletter template.') . '</p>';
    case 'admin/enewsletters/templates/edit':
      return '<p>' . t('Edit an email newsletter template.') . '</p>';
    case 'enewsletters/newsletter':
      return t('Select content you would like included in this email newsletter.');
  }
}


function enewsletter_perm() {
  return array("administer enewsletters", "subscribe to enewsletters");
}


function enewsletter_menu($may_cache) {
 
  $items = array();
  $administer = user_access('administer enewsletters');
  $subscribe = user_access('subscribe to enewsletters');
  $email_link = 1;
  
  $items[] = array('path' => 'enewsletters', 'title' => t('email subscription'), 'callback' => 'enewsletter_callback_subscriptions', 'access' => $email_link);
  $items[] = array('path' => 'enewsletters/newsletter', 'title' => t('email newsletter'), 'callback' => 'enewsletter_callback_subscription_edit', 'access' => $email_link, 'type' => MENU_CALLBACK);

  if ($may_cache) {      
   
   $items[] = array('path' => 'admin/enewsletters', 'title' => t('email newsletters'), 'callback' => 'enewsletter_callback_admin', 'access' => $administer);
   $items[] = array('path' => 'admin/enewsletters/list', 'title' => t('list'), 'type' => MENU_DEFAULT_LOCAL_TASK, 'weight' => -10);
   $items[] = array('path' => 'admin/enewsletters/history', 'title' => t('history'), 'callback' => 'enewsletter_callback_newsletter_history', 'type' => MENU_CALLBACK);
   $items[] = array('path' => 'admin/enewsletters/subscribers', 'title' => t('subscribers'), 'callback' => 'enewsletter_callback_newsletter_subscribers', 'type' => MENU_CALLBACK);

   $items[] = array('path' => 'admin/enewsletters/newsletters', 'title' => t('newsletters'), 'callback' => 'enewsletter_callback_newsletters', 'access' => $administer);
   $items[] = array('path' => 'admin/enewsletters/newsletters/list', 'title' => t('list'), 'access' => $administer, 'type' => MENU_DEFAULT_LOCAL_TASK, 'weight' => -10);
   $items[] = array('path' => 'admin/enewsletters/newsletters/add', 'title' => t('add'), 'callback' => 'enewsletter_callback_newsletter_add', 'access' => $administer, 'type' => MENU_LOCAL_TASK); 

   $items[] = array('path' => 'admin/enewsletters/templates', 'title' => t('templates'), 'callback' => 'enewsletter_callback_templates', 'access' => $administer);
   $items[] = array('path' => 'admin/enewsletters/templates/list', 'title' => t('list'), 'access' => $administer, 'type' => MENU_DEFAULT_LOCAL_TASK, 'weight' => -10);
   $items[] = array('path' => 'admin/enewsletters/templates/edit', 'title' => t('edit'), 'callback' => 'enewsletter_callback_template_edit', 'access' => $administer, 'type' => MENU_CALLBACK);   
   $items[] = array('path' => 'admin/enewsletters/templates/add', 'title' => t('add'), 'callback' => 'enewsletter_callback_template_add', 'access' => $administer, 'type' => MENU_LOCAL_TASK);
   
   $items[] = array('path' => 'admin/enewsletters/announcements', 'title' => t('announcements'), 'callback' => 'enewsletter_callback_announcements', 'access' => $administer, 'weight' => 9);

   $items[] = array('path' => 'admin/enewsletters/undelivered', 'title' => t('undelivered'), 'callback' => 'enewsletter_callback_undelivered', 'access' => $administer, 'weight' => 10); 
   $items[] = array('path' => 'admin/enewsletters/configuration', 'title' => t('configuration'), 'callback' => 'enewsletter_callback_config', 'access' => $administer);
   
  }
  
  return $items;
}


// ********** ADMINISTRATION *****************************


// Display all newsletters
function enewsletter_callback_admin() {

  $newsletters = enewsletter_get_db_rows("SELECT * FROM {enewsletter_newsletters} WHERE enewsletter_id != '%d'", ANNOUNCEMENT);
  
  if (!$newsletters) return print theme('page', 'There are no email newsletters.');
  
  $configuration = enewsletter_get_configuration();
  
  // convert to function
  foreach($newsletters as $newsletter) {
    unset($rows);
    $header = array(t('last publication'), t('sent (last)'), t('in que'), t('next publication')); 
    $last = ($newsletter->last == 0) ? '-' : format_date($newsletter->last, 'small');
    $next = ($newsletter->next == 0) ? t('manual') : format_date($newsletter->next, 'small');
    
    $sent_count = enewsletter_count_sent($newsletter->enewsletter_id, $newsletter->next, $newsletter->last);
    $qued_count = enewsletter_count_qued($newsletter->enewsletter_id, $newsletter->next, $configuration['bounce_limit']);
    
    $last_subscribers = db_result(db_query("SELECT count(*) FROM {enewsletter_subscriptions} WHERE enewsletter_id = '%d' AND subscribed <= '%d'", $newsletter->enewsletter_id, $newsletter->last));

    if ($que == 0) {
            $sent = $last_subscribers;
    } else {
        $sent = db_result(db_query("SELECT count(*) FROM {enewsletter_subscriptions} WHERE enewsletter_id = '%d' AND uid <= '%d' AND subscribed <= '%d'", $newsletter->enewsletter_id, $que, $newsletter->last));
    }
    
    $qued = $last_subscribers - $sent;
    
    $rows[] = array( 
    array("data" => $last, "align" => "center"),  
    array("data" => $sent_count, "align" => "center"), 
    array("data" => $qued_count, "align" => "center"), 
    array("data" => $next, "align" => "center")
    );
    
    $output .= '<div class="enewsletter-status">';
    $output .= '<h2>';
    $output .= $newsletter->title;
    $output .= '</h2>';
    $output .= '<p>';
    $output .= $newsletter->description;
    $output .= '</p>';
    $output .= theme('table', $header, $rows, array('id' => 'enewsletter-admin'));
    $output .= '</div>';
  }
  
  print theme('page', $output);
  return;
}


function enewsletter_count_qued($publication_id, $publication_timestamp, $bounce_limit) {
    
    // publication has finished sending
    if ($publication_timestamp > time() || $publication_timestamp == 0) return 0;
    
    $qued_count = db_result(db_query("
    SELECT count(*) 
    FROM {enewsletter_subscriptions} s 
    LEFT JOIN {users} u ON s.uid = u.uid 
    LEFT JOIN {enewsletter_bounce_count} b ON u.mail = b.email 
    LEFT JOIN {enewsletter_sent} m ON (m.uid = s.uid AND m.enewsletter_id = s.enewsletter_id AND m.pub_time = '%d') 
    WHERE s.enewsletter_id = '%d' 
    AND (b.bounces IS NULL OR b.bounces < '%d') 
    AND m.sent IS NULL 
    ORDER BY u.name 
  ", $publication_timestamp, $publication_id, $bounce_limit));
  
  return $qued_count;

}


function enewsletter_count_sent($publication_id, $publication_timestamp, $previous_publication_timestamp) {
    
    // publication finished sending?
    // count all emails on this send out - or
    // count all emails on last send out
    $timestamp = ($publication_timestamp > time() || $publication_timestamp == 0) ? $previous_publication_timestamp : $publication_timestamp;

    $sent_count = db_result(db_query("
    SELECT count(*) 
    FROM {enewsletter_sent} 
    WHERE enewsletter_id = '%d' 
    AND pub_time = '%d' 
    ", $publication_id, $timestamp)); 
    
    return $sent_count;
}


function enewsletter_callback_newsletter_subscribers($newsletter_id) {

    $result = db_query("SELECT s.uid, s.format, s.subscribed, u.name FROM {enewsletter_subscriptions} s LEFT JOIN {users} u ON s.uid = u.uid WHERE s.enewsletter_id = '%d'", $newsletter_id);
    if (!$result) return print theme('page', 'No subscribers');
    
    $header = array(t('user'), t('format'), t('subscribed')); 
    
    while ($subscriber = db_fetch_object($result)) {
    
        $name = l($subscriber->name, "user/$subscriber->uid/edit");
        $format = $subscriber->format;

        if ( !$subscriber->subscribed ) {
            $subscriber->subscribed = time();
            db_query("UPDATE {enewsletter_subscriptions} SET subscribed = '%d' WHERE enewsletter_id = '%d' AND uid = '%d'", $subscriber->subscribed, $newsletter_id, $subscriber->uid);
        }
        
        $subscribed= format_date($subscriber->subscribed, 'medium');
        $rows[] = array(array("data" => $name), array("data" => $format), array("data" => $subscribed));
    }
  
  $newsletter = enewsletter_get_newsletter($newsletter_id);
  $title = t('Subscribers to %newsletter', array('%newsletter' => $newsletter['title']));
  $output = theme('table', $header, $rows, array('id' => 'enewsletter-subscriptions'));
  
  print theme('page', $output, $title);
  return;
}


function enewsletter_callback_config() {
    
  $edit = $_POST["edit"];
  
  if ($edit) {
    enewsletter_set_configuration($edit);
    drupal_set_message (t("Newsletter settings have been updated." ));
  }
  $configuration = enewsletter_get_configuration();
  $output = enewsletter_form_configuration($configuration);
  $output .= form_submit(t("Save settings"));
  $output = form($output);
  print theme('page', $output);
  return;
}   


// Display all newsletters
function enewsletter_callback_newsletters() {
  
    $edit = $_POST["edit"];
    $operation = $_POST["op"];

    
    switch ($operation) {
    
        case t('Send Now'):
        case t('Send'):
            $form = enewsletter_form_send_now($edit, $operation);
            break;
        case t('Schedule'):
        case t('Set Schedule'):
            $form = enewsletter_callback_newsletter_schedule($edit, $operation);
            break;
        case t('Set Content'):
        case t('Save Newsletter'):
            $form = enewsletter_callback_newsletter_content($edit, $operation);
            break;
        case t('Delete'):
        case t('Delete Newsletter'):
            $form = enewsletter_callback_newsletter_delete($edit, $operation);
            break;
        default:
            break;
    }
  
  if ($form) {
    print theme('page', form($form));
    return;
  }
  
  $newsletters = enewsletter_get_db_rows('SELECT * FROM {enewsletter_newsletters} WHERE enewsletter_id != ' . ANNOUNCEMENT);
  if (!$newsletters) return print theme('page', 'There are no email newsletters.');
  
  foreach($newsletters as $newsletter) {
    
    $header = array(t('first published'), t('last published'), t('next published'), t('subscribers')); 
    $first = ($newsletter->first == 0) ? '-' : format_date($newsletter->first, 'small');
    $last = ($newsletter->last == 0) ? '-' : format_date($newsletter->last, 'small');
    $next = ($newsletter->next== 0) ? t('manual') : format_date($newsletter->next, 'small');
    $subscribers = db_result(db_query("SELECT count(*) FROM {enewsletter_subscriptions} WHERE enewsletter_id = '%d'", $newsletter->enewsletter_id));
    $subscribers = ($subscribers) ? l($subscribers, "admin/enewsletters/subscribers/$newsletter->enewsletter_id") : 0;
        
    unset($rows);
    $rows[] = array(
    array('data' => $first, 'align' => 'center'), 
    array('data' => $last, 'align' => 'center'), 
    array('data' => $next, 'align' => 'center'),  
    array('data' => $subscribers, 'align' => 'center')
    );
    
    $controls = form_hidden ('enewsletter_id' , $newsletter->enewsletter_id);
    $controls .= form_submit(t('Send Now'));
    $controls .= form_submit(t('Schedule'));
    $controls .= form_submit(t('Set Content'));
    $controls .= form_submit(t('Delete'));

    $form = '<div class="enewsletter-controls">';
    $form .= '<h2>' . $newsletter->title . '</h2>';
    $form .= '<p>' . $newsletter->description . '</p>';
    $form .= theme('table', $header, $rows, array('id' => 'enewsletter-newsletters'));
    $form .= '<p>' . $controls . '</p>';
    $form .= '</div>';
    $output .= form($form);
  }
  
  print theme('page', $output);
  return;
}


// Create new newsletter
function enewsletter_callback_newsletter_add() {
    
  $edit = $_POST["edit"];
  $operation = $_POST["op"];
  
  if ($operation == 'Cancel') {
      drupal_goto('admin/enewsletters/newsletters');
  }

  if ($operation == 'Save newsletter') {
        $edit['tid'] = enewsletter_selected_checkboxes($edit['tid']);
        enewsletter_validate_content($edit);
        enewsletter_validate_schedule($edit);
        $error = form_get_errors();
        
        if ($error) {
          $output = enewsletter_form_content($edit);
          $output .= enewsletter_form_schedule($edit);
          $output .= form_submit(t("Save newsletter"));
          $output .= form_submit(t("Cancel"));
          return print theme('page', form($output));
        }
        
        db_query("INSERT INTO {enewsletter_newsletters} (enewsletter_id, title, description, track, template_text, template_html, start, next, every, frequency) VALUES (NULL, '%s', '%s', '%d', '%d', '%d', '%d', '%d', '%d', '%s')", $edit['title'], $edit['description'], $edit['track'], $edit['template_text'], $edit['template_html'], $edit['start'], $edit['next'], $edit['every'], $edit['frequency']);
        $edit['enewsletter_id'] = db_result(db_query("SELECT LAST_INSERT_ID()"));
        enewsletter_set_allowed_terms($edit);
        drupal_set_message (t('Email newsletter settings have been saved for "' . $edit['title'] . '"'));
        drupal_goto('admin/enewsletters/newsletters');  
  }
    
    $output = enewsletter_form_content();
    $output .= enewsletter_form_schedule();
    $output .= form_submit(t("Save newsletter"));
    $output .= form_submit(t("Cancel"));
    print theme('page', form($output));
    return;
} 


// Edit content of existing newsletter
function enewsletter_callback_newsletter_content($edit, $operation) {
  
    if ($operation == t('Save Newsletter')) {
        $edit['tid'] = enewsletter_selected_checkboxes($edit['tid']);
        enewsletter_validate_content($edit);
        $error = form_get_errors();
        if (!$error) {
            if ($edit['enewsletter_id']) {
              db_query("UPDATE {enewsletter_newsletters} SET title = '%s', description = '%s', track = '%d', template_text = '%d', template_html = '%d' WHERE enewsletter_id = '%d'", $edit['title'], $edit['description'], $edit['track'], $edit['template_text'], $edit['template_html'], $edit['enewsletter_id']);
            }
            enewsletter_set_allowed_terms($edit);
            drupal_set_message (t('Email newsletter content settings have been saved for "' . $edit['title'] . '"'));
            return;   
        }
    }
  
    $edit = enewsletter_get_newsletter($edit['enewsletter_id']);
    $edit['tid'] = enewsletter_get_allowed_terms($edit['enewsletter_id']);   
    $output = enewsletter_form_content($edit);
    $output .= form_submit(t("Save Newsletter"));
    $output .= form_submit(t("Cancel"));
  
    return $output; 
}


// Edit schedule of existing newsletter
function enewsletter_callback_newsletter_schedule($edit, $operation) {
  
  if ($operation == t('Set Schedule')) {
    enewsletter_validate_schedule($edit);
    $error = form_get_errors();
    if (!$error) {
        db_query("UPDATE {enewsletter_newsletters} SET start = '%d', next = '%d', every = '%d', frequency = '%s' WHERE enewsletter_id = '%d'", $edit['start'], $edit['next'], $edit['every'], $edit['frequency'], $edit['enewsletter_id']);
        drupal_set_message (t('Publication schedule settings have been saved for "' . $edit['title'] . '"'));
        return;
    }
  }
  
    $edit = enewsletter_get_newsletter($edit['enewsletter_id']);
    $output = '<h2>' . t('Schedule: ') . $edit['title'] . '</h2>';
    $output .= enewsletter_form_schedule($edit);
    $output .= form_submit(t('Set Schedule'));
    $output .= form_submit(t("Cancel"));  
    return $output; 
}


// Edit content of existing newsletter
function enewsletter_callback_newsletter_delete($edit, $operation) {
  
    if ($operation == t('Delete Newsletter')) {
    
        if ($edit['enewsletter_id']) {
                
            $newsletter = db_fetch_object(db_query("SELECT enewsletter_id, title FROM {enewsletter_newsletters} WHERE enewsletter_id = '%d' LIMIT 1", $edit['enewsletter_id']));
            if ($newsletter) {
                db_query("DELETE FROM {enewsletter_newsletters} WHERE enewsletter_id = '%d'", $newsletter->enewsletter_id);
                db_query("DELETE FROM {enewsletter_allowed} WHERE enewsletter_id = '%d'", $newsletter->enewsletter_id);
                db_query("DELETE FROM {enewsletter_selected} WHERE enewsletter_id = '%d'", $newsletter->enewsletter_id);
                db_query("DELETE FROM {enewsletter_subscriptions} WHERE enewsletter_id = '%d'", $newsletter->enewsletter_id);
                watchdog("special", "Email newsletter: deleted newsletter '$enewsletter_id'");
                drupal_set_message(t('The newsletter "' . $newsletter->title . '" has been deleted.'));
                cache_clear_all();
            } else {
                drupal_set_message(t("Newsletter doesn't exist."));
            }
                
            return;;   
        }
    }
  
    $edit = enewsletter_get_newsletter($edit['enewsletter_id']);
    $output = '<p>';
    $output .= t('Are you sure you want to delete the email newsletter ') . '<strong>' . $edit['title'] . '</strong>';
    $output .= '</p>';
    $output .= form_hidden ('enewsletter_id', $edit['enewsletter_id']);
    $output .= form_submit(t('Delete Newsletter'));
    $output .= form_submit(t('Cancel'));
  
  return $output; 
}


// Display all templates
function enewsletter_callback_templates() {
  $templates = enewsletter_get_db_rows("SELECT * FROM {enewsletter_templates} WHERE template_id > 2 ORDER BY type");
  $output .= enewsletter_form_templates($templates);
  print theme('page', $output);
}


// add template
function enewsletter_callback_template_add() {

  $edit = $_POST["edit"];
  
  if ($edit) {
      enewsletter_validate_template($edit);
        $errors = form_get_errors(); 
        if ($errors) return print theme('page', enewsletter_form_template($edit));
        
        $edit['template_id'] = enewsletter_set_template($edit);
        drupal_set_message (t('Settings have been saved for "' . $edit['name'] . '" template.'));
        drupal_goto('admin/enewsletters/templates');
  }
  
  $output .= enewsletter_form_template();
  print theme('page', $output);
  return;
}


// edit template
function enewsletter_callback_template_edit($template_id = NULL) {

  $edit = $_POST["edit"];
  $operation = $_POST["op"];
  
  if ($operation == 'Delete template') {
    enewsletter_template_delete($edit['template_id']);
    drupal_goto('admin/enewsletters/templates');
    return;
  }
  
  if ($operation == 'Save template') {
    enewsletter_validate_template($edit);
    
        $errors = form_get_errors(); 
        if ($errors) return print theme('page', enewsletter_form_template($edit));
        
        enewsletter_set_template($edit);
        drupal_set_message (t('Settings have been saved for "' . $edit['name'] . '" template.'));
        drupal_goto('admin/enewsletters/templates');
    return;
  }
  
  // if new form
  $edit = enewsletter_get_template($template_id);
  $edit['delete_button'] = 'YES';
  $output = enewsletter_form_template($edit);
  print theme('page', $output);
  return;
}


// Process edited template form
function enewsletter_validate_template($edit) {

  if (!$edit['name']) form_set_error('name', t('Template name must be set.'));
  
  // Check if template has unique title
  $template_id = db_result(db_query("SELECT template_id FROM {enewsletter_templates} WHERE name = '%s' LIMIT 1", $edit['name']));
  if ($template_id && $template_id != $edit['template_id']) {
    form_set_error('name', t('Title already in use by another email template.')); 
  }
  
  if (!$edit['template']) form_set_error('template', t('Template layout must be set.'));
  
  return;
}

function enewsletter_callback_announcements() {

    $edit = $_POST["edit"];
    $operation = $_POST["op"];
    
    $configuration = enewsletter_get_configuration();
    
    if ($configuration['announce_enable'] != ANNOUNCEMENT_ENABLED) {
        $output = t('Announcements must be enabled in ') . l('configuration', 'admin/enewsletters/configuration');
        return print theme('page', $output);
    }
    
    switch ($operation) {
    
        case t('Send Now'):
            enewsletter_validate_announcement($edit);
            $errors = form_get_errors(); 
            if (!$errors) {
                enewsletter_set_template(array('template_id' => 1, 'name' => t('announcements'), 'template' => $edit['announce_text_msg'], 'type' => 0, 'format' => $edit['format_text']));
                enewsletter_set_template(array('template_id' => 2, 'name' => t('announcements HTML'), 'template' => $edit['announce_html_msg'], 'type' => 1, 'format' => $edit['format_html']));
                $form = enewsletter_form_send_now($edit, $operation);
            }
            break;
        case t('Send'):
            db_query("UPDATE {enewsletter_newsletters} SET next = '%d' WHERE enewsletter_id = '%d'", time(), $edit['enewsletter_id']);
            $form = enewsletter_form_send_now($edit, $operation);
            break;
        case t('Schedule'):
            enewsletter_validate_announcement($edit);
            $errors = form_get_errors(); 
            if (!$errors) {
                enewsletter_set_template(array('template_id' => 1, 'name' => t('announcements'), 'template' => $edit['announce_text_msg'], 'type' => 0, 'format' => $edit['format_text']));
                enewsletter_set_template(array('template_id' => 2, 'name' => t('announcements HTML'), 'template' => $edit['announce_html_msg'], 'type' => 1, 'format' => $edit['format_html']));
                $form = enewsletter_callback_newsletter_schedule($edit, $operation);
            }
            break;
        case t('Set Schedule'):
            $form = enewsletter_callback_newsletter_schedule($edit, $operation);
            break;
        default:
            break;
    }
    
    if ($form) {
        print theme('page', form($form));
        return;
    }
  
    $announcement = enewsletter_get_template(1);
    $announcement_HTML = enewsletter_get_template(2);
    
    $edit['announce_text_msg'] = $announcement['template'];
    $edit['format_text'] = $announcement['format'];
    $edit['announce_html_msg'] = $announcement_HTML['template'];
    $edit['format_html'] = $announcement_HTML['format'];
    
    $output .= enewsletter_form_announcement($edit);
    
    print theme('page', $output);
    return;
}

function enewsletter_form_announcement($edit = NULL) {

  $output .= enewsletter_form_profile_fields();
  $output .= form_hidden ('enewsletter_id' , ANNOUNCEMENT);
  $output .= form_textarea(t('Text Message'), 'announce_text_msg', $edit['announce_text_msg'], 50, 6, t('Plain text version of announcement message'), '', TRUE);
  $output .= filter_form('format_text', $edit['format_text']);
  $output .= form_textarea(t('HTML Message'), 'announce_html_msg', $edit['announce_html_msg'], 50, 6, t("HTML version of announcement message - leave blank if you don't want to send a HTML version"));
  $output .= filter_form('format_html', $edit['format_html']);
  $output .= form_submit(t('Send Now'));
  $output .= form_submit(t('Schedule'));
  return form($output);
}

function enewsletter_validate_announcement($edit) {

    if (!$edit['announce_text_msg']) form_set_error('announce_text_msg', t('Plain text version of announcement message must be set.'));
    return;
}
  

// Get rows from database
function enewsletter_get_db_rows($query) {
  
  $results = db_query($query);

  while ($row = db_fetch_object($results)) {
        $rows[] = $row;
    }

  return $rows;
}


function enewsletter_get_configuration() {
  $results = db_query("SELECT * FROM {enewsletter_config}");
  while ($row = db_fetch_object($results)) {
    $configuration[$row->variable] = $row->value;
  }
  return $configuration;
}


function enewsletter_set_configuration($configuration) {
  
  while(list($variable, $value) = each ($configuration)) {
    db_query("DELETE FROM {enewsletter_config} WHERE variable = '%s'", $variable);
    db_query("INSERT INTO {enewsletter_config} (variable, value) VALUES ('%s', '%s')", $variable, $value);    
  }

  return;
}


function enewsletter_form_configuration($configuration) {

  // Email Addresses  
  if ($configuration[ "set_return_path" ] == NULL) $configuration[ "set_return_path" ] = 'Yes';
  $addresses = form_textfield (t('From'), 'from_address', $configuration[ 'from_address' ], 40, 64, t('The email address you would like messages to be sent from.'));
  $addresses .= form_textfield (t('Reply-To'), 'reply_address', $configuration[ 'reply_address' ], 40, 64, t('The email address you would like messages to go to when a recipient uses their Reply button. (can be the same as the From address)'));
  $addresses .= form_textfield (t('Bounce'), 'bounce_addresss', $configuration[ 'bounce_addresss' ], 40, 64, t('The email address you would like messages to bounce back to if undelivered - configuration settings below. (sets Errors-To: and Return-Path:)'));
  $addresses .= form_radios(t("Set Return-Path"), "set_return_path", $configuration["set_return_path"], array(t('No'), t('Yes')), t("It's preferable to set the Return-Path, but some systems do not allow Drupal to set this."));
  $output = form_group(t('Email Addresses'), $addresses, t('Make sure that these addresses correspond to mailboxes you have set up on your server.'));

  // Sending Configuration
  if ($configuration[ 'send_maximum' ] == NULL) $configuration[ 'send_maximum' ] = 50;
  if ($configuration[ 'send_delay' ] == NULL) $configuration[ 'send_delay' ] = 2;  
  $send = form_textfield (t('Maximum Emails'), 'send_maximum', $configuration[ 'send_maximum' ], 10, 64, t('The maximum number of emails to send at each cron run'));
  $send .= form_textfield (t('Send Delay'), 'send_delay', $configuration[ 'send_delay' ], 10, 64, t('Delay in microseconds between each email (avoid chocking mail server)'));
  $output .= form_group( t('Sending'), $send );
  
  // Announcements
  $announcements = form_checkbox(t('Enabled'), 'announce_enable', ANNOUNCEMENT_ENABLED, $configuration['announce_enable'], t('Allow announcement messages.'));
  $announcements .= form_checkbox(t('Automatic Subscription'), 'announce_auto', ANNOUNCEMENT_AUTO, $configuration['announce_auto'], t('When users create accounts, automatically subscribe them to announcements.'));
  $announcements .= form_textarea(t('Subscribe Message (Optional)'), 'announce_optional_msg', $configuration['announce_optional_msg'], 50, 2, t('Displayed when users have the option to subscribe to announcements - always displayed on the user account page'));
  $announcements .= form_textarea(t('Subscribe Message (Automatic)'),  'announce_auto_msg', $configuration['announce_auto_msg'], 50, 2, t('Displayed when users are automatically subscribed as part of account creation'));
  $output .= form_group( t('Announcements'), $announcements );
  
  // Security
  if ($configuration[ 'loggin' ] == NULL) $configuration[ 'loggin' ] = 0;
  $loggin = form_radios(t("Loggin"), "loggin", $configuration["loggin"], array(t('Limited'), t('Full')), t("Restricts access to just the subscription settings, or all aspects of an account."));
  $output .= form_group( t('Security'), $loggin, t("Controls how much access links in email newsletters give to an account. Limited loggin gives access to specific pages only, the user is still treated as if they have not logged in." ) );
  
  // Receiving Configuration
  if ($configuration[ "bounce_store_deleted" ] == NULL) $configuration[ "bounce_store_deleted" ] = '48';
  if ($configuration[ "bounce_mailbox_connection" ] == NULL) $configuration[ "bounce_mailbox_connection" ] = 'POP';
  $receive = form_radios(t("Connection Type"), "bounce_mailbox_connection", $configuration["bounce_mailbox_connection"], array(t('POP'), t('IMAP')), t("How to connect to your mail server."));
  $receive .= form_textfield (t("Mailbox Host" ), "bounce_mailbox_host" , $configuration[ "bounce_mailbox_host" ], 40, 64, t('Your host mail sever, usualy in the format:  mail.yourdomain.com'));
  $receive .= form_textfield (t("Mailbox Port" ), "bounce_port" , $configuration[ "bounce_port" ], 40, 64, t("For POP connection usually: '110/pop3' or '110/pop3/notls'. For IMAP usually: '143'."));
  $receive .= form_textfield (t("Mailbox Username" ), "bounce_mailbox_user" , $configuration[ "bounce_mailbox_user" ], 40, 64, t("Username of mailbox for receiving undelivered email, usually the address of the mailbox: bounce@yourdomain.com."));
  $receive .= form_password (t("Mailbox Password" ), "bounce_mailbox_password" , $configuration[ "bounce_mailbox_password" ], 40, 64, t("Password of mailbox for receiving undelivered email."));
  $receive .= form_textfield (t("Max Process" ), "bounce_max_process" , $configuration[ "bounce_max_process" ], 10, 64, t("Maximum number of bounced emails to process per run."));
  $receive .= form_textfield (t("Store Processed" ), "bounce_store_processed" , $configuration[ "bounce_store_processed" ], 10, 64, t("How long to store copy of processed messages in Drupal. (hours)"));
  $receive .= form_textfield (t("Bounce Limit" ), "bounce_limit" , $configuration[ "bounce_limit" ], 10, 64, t("Stop sending to an address after this number of bounces"));
  $output .= form_group(t('Receiving (Undelivered)'), $receive, t("Settings for connecting to a mailbox and processing emails that have bounced back as undelivered" ));

  return $output;
}


// Get newsletter settings from database (single)
function enewsletter_get_newsletter($enewsletter_id) {
  
  $settings = db_fetch_array(db_query("SELECT * FROM {enewsletter_newsletters} WHERE enewsletter_id = '%d'", $enewsletter_id));
  
  return $settings;
}


// Get terms allowed in newsletter from database (all) (single)
function enewsletter_get_allowed_terms($enewsletter_id = NULL) {

  if ($enewsletter_id == NULL) {
    $terms = db_query("SELECT DISTINCT tid FROM {enewsletter_allowed} ORDER BY tid");
  } else {
    $terms = db_query("SELECT tid FROM {enewsletter_allowed} WHERE enewsletter_id = '%d' ORDER BY tid", $enewsletter_id);
  }
  
  $term_rows = db_num_rows($terms) - 1;
  
  for ($counter = 0; $counter <=  $term_rows; $counter++) {
    $allowed_terms[] = db_result($terms, $counter);
  }
  
  return $allowed_terms;
}


// Update database with terms allowed in database (single)
function enewsletter_set_allowed_terms($settings) {
  
  db_query("DELETE FROM {enewsletter_allowed} WHERE enewsletter_id = '%d'", $settings['enewsletter_id']);   
      
  foreach($settings['tid'] as $tid) {
    db_query("INSERT INTO {enewsletter_allowed} (enewsletter_id, tid) VALUES ('%d', '%d')", $settings['enewsletter_id'], $tid);
  }

  return;
}


function enewsletter_validate_content(&$edit) {

  // Check that there is a title
  if (!$edit['title']) form_set_error('title', t('A title must be set.')); 
    
  // Check if new newsletter has unique title
  $newsletter_id = db_result(db_query("SELECT enewsletter_id FROM {enewsletter_newsletters} WHERE title = '%s' LIMIT 1", $edit['title']));
  if (is_string($newsletter_id) == true && $edit['enewsletter_id'] != $newsletter_id) {
    form_set_error('title', t('Title already in use by another email newsletter.')); 
  }
  
  // Check that at least one term has been selected
  if (!$edit['tid']) form_set_error('tid', t('At least one term must be selected.')); 
      
  return;
}


// Date and time checks
function enewsletter_validate_schedule(&$edit) {

  // Skip these checks if announcement is being validated
  if ($edit['enewsletter_id'] != ANNOUNCEMENT) {

        // Check node inclusion date 
        // - if before first publication
        if ($edit['last'] == 0) {
        
            if ($edit['start'] == 0) {
                $edit['start'] = mktime (1, 0, 0, 1, 1, 1999, -1);
            } else {
        
                $edit['start'] = strtotime ($edit['start']);
                $include_nodes_date = getdate($edit['start']);
        
                // Is node inclusion date a valid date?
                if (checkdate( $include_nodes_date['mon'], $include_nodes_date['mday'], $include_nodes_date['year'] ) == FALSE) {
                    form_set_error('start', t("The 'Include Nodes From' date is not correct, please use the mm/dd/yy format.")); 
                    $edit['start'] = mktime (1, 0, 0, 1, 1, 1999, -1);
                }
                
            }
        }
        
        // If schedule set to Manual, set 'every' to 0
        if ($edit['frequency'] == 'manual') {
          $edit['every'] = 0;
          $edit['next_date'] = 0;
          return;
        }
       
        // Check frequency amount has been set
        if ($edit['every'] == 0) form_set_error('every', t("Send Schedule: 'Every' cannot be 0"));
    
    }
    
    // Check there is a publication date
    if ($edit['next_date'] == 0) {
    
        form_set_error('next_date', t("The 'Send Start' date must be set if you want to send a scheduled email.")); 
        
    } else {

        $next = strtotime ($edit['next_date']);
        $next_array = getdate($next);
        
        // Is this a valid date?
        if (checkdate( $next_array['mon'], $next_array['mday'], $next_array['year'] ) == FALSE) {
            drupal_set_message (t("The 'Send Start' date is not correct, please use the mm/dd/yy format."), 'error');
            $edit['next'] = time();
        } else {
            $edit['next'] = mktime ($edit['next_hour'], 0, 0, $next_array['mon'], $next_array['mday'], $next_array['year'], -1);
        }
        
        // Has publication time already passed?
        $send_time = mktime ($edit['next_hour'], 0, 0, $next_array['mon'], $next_array['mday'], $next_array['year'], -1);
        if ( $send_time <= time() ) form_set_error('next_hour', t("The 'Send Start' date has already passed.")); 
        
    }
    
    // Is nodes inclusion date earlier than send out time?
    if ( $edit['start'] > $send_time && $edit['frequency'] != 'manual' && $edit['enewsletter_id'] != 1) form_set_error('start', t("The 'Include Nodes From' date is later than the send time.")); 
      
  return;
}


// Validate 'save newsletter' form submition
function enewsletter_validate_newsletter(&$edit) {

  // Check that there is a title
  if (!$edit['title']) form_set_error('title', t('A title must be set.')); 
    
  // Check if new newsletter has unique title
  $newsletter_id = db_result(db_query("SELECT enewsletter_id FROM {enewsletter_newsletters} WHERE title = '%s' LIMIT 1", $edit['title']));
  if (is_string($newsletter_id) == true && $edit['enewsletter_id'] != $newsletter_id) {
    form_set_error('title', t('Title already in use by another email newsletter.')); 
  }
  
  // Check that at least one term has been selected
  if (!$edit['tid']) form_set_error('tid', t('At least one term must be selected.')); 
  
  // If schedule set to Manual, set 'every' to 0
  if ($edit['frequency'] == 'manual') {
  
    $edit['every'] = 0;
    
  } else {
   
    // Date and time checks
    
    // Check Schedule (every) has been set
    if ($edit['every'] == 0) form_set_error('every', t("Send Schedule: 'Every' cannot be 0")); 
    
    // Check there is a start date
    if ($edit['next_date'] == 0) {
    
      form_set_error('next_date', t("The 'Send Start' date must be set if you want to send a scheduled email.")); 
      
    } else {

      $next = strtotime ($edit['next_date']);
      $next_array = getdate($next);
      
      // Is this a valid date?
      if (checkdate( $next_array['mon'], $next_array['mday'], $next_array['year'] ) == FALSE) {
        drupal_set_message (t("The 'Send Start' date is not correct, please use the mm/dd/yy format."), 'error');
        $edit['next'] = time();
      } else {
        $edit['next'] = mktime ($edit['next_hour'], 0, 0, $next_array['mon'], $next_array['mday'], $next_array['year'], -1);
      }
      
      // Has Start time already passed?
      $send_time = mktime ($edit['next_hour'], 0, 0, $next_array['mon'], $next_array['mday'], $next_array['year'], -1);
      if ( $send_time <= time() ) form_set_error('next_hour', t("The 'Send Start' date has already passed.")); 
      
    }
    
    // Check Node Start date   (if before first publication)
    if ($edit['last'] == 0) {
      if ($edit['start'] == 0) {
        $edit['start'] = mktime (1, 0, 0, 1, 1, 1999, -1);
      } else {
  
        $edit['start'] = strtotime ($edit['start']);
        $include_nodes_date = getdate($edit['start']);
        
        // Is node start date a valid date?
        if (checkdate( $include_nodes_date['mon'], $include_nodes_date['mday'], $next_array['year'] ) == FALSE) {
          form_set_error('start', t("The 'Include Nodes From' date is not correct, please use the mm/dd/yy format.")); 
          $edit['start'] = mktime (1, 0, 0, 1, 1, 1999, -1);
        }
  
        // Is Nodes Start time earlier than send out time?
        if ( $edit['start'] > $send_time) form_set_error('start', t("The 'Include Nodes From' date is later than the send time.")); 
        
      }
    }
  }
      
  return;
}


function enewsletter_form_content($settings = array()) {
  
  $allowed_terms = $settings['tid'];
  if ($settings['enewsletter_id']) $output .= form_hidden ("enewsletter_id" , $settings['enewsletter_id']);
  if ($settings['last']) $output .= form_hidden ("last" , $settings['last']);
  $description .= form_textfield(t("Title" ), "title" , $settings[ "title" ], 50, 64, t('Used as the subject line of each email'));
  $description .= form_textarea(t("Description" ), "description" , $settings[ "description" ], 50, 2, t('Description for subscribers'));
  $output .= form_group(t('Description'), $description); 
  
  $after_send = form_checkbox(t('Track'), "track", 1, $settings[ "track" ]);
  $output .= form_group(t('After Sending'), $after_send, t('Track user behaviour after email is sent'));  
  $templates = enewsletter_get_db_rows("SELECT * FROM {enewsletter_templates} WHERE template_id > 2 ORDER BY type");
  
  foreach($templates as $template) {
  // set default to text template
  if ($template->type == '0') {
    $text_templates["$template->template_id"] = $template->name;
  } else {
    $html_templates["$template->template_id"] = $template->name;
  }
  }
  
  $template_select .= form_select(t('Text Template'), 'template_text', $settings['template_text'], $text_templates);
  $template_select .= form_select(t('HTMLTemplate'), 'template_html', $settings['template_html'], $html_templates);
  $output .= form_group(t('Templates'), $template_select, t('Select a plain text template and a HTML template')); 
  $header = array(t("include"), t("name"), t("node types"));
  $vocabularies = taxonomy_get_vocabularies();

  foreach ($vocabularies as $vocabulary) {
    $links = array();
    $types = array();
    foreach(explode(",", $vocabulary->nodes) as $type) {
      $types[] = node_invoke($type, "node_name");
    }
    $rows[] = array('select', $vocabulary->name, array("data" => implode(", ", $types), "align" => "center"));

    $tree = taxonomy_get_tree($vocabulary->vid);
    if ($tree) {
      unset($checkboxes);
      unset($data);
      foreach ($tree as $term) {
        $label = _taxonomy_depth($term->depth) ." ". $term->name;
        if (is_array($allowed_terms)) {
          $checked = in_array($term->tid, $allowed_terms) ? 1 : 0;
        } else {
          $checked = 0;
        }
        $checkboxes = form_checkbox($label, "tid][$term->tid", 1, $checked);
        $rows[] = array(array("data" => $checkboxes, "colspan" => 3));
      }
      
    }
    
  }
  
  $taxonomy .= theme('table', $header, $rows, array('id' => 'enewsletter-content'));
  $output .= form_group(t('Content'), $taxonomy);  
  return $output;
}


function enewsletter_form_schedule($settings = array()) {
    
    // Frequency form group
    $start_date = date ("m/d/y", time());
    $start_day = date ("l, M j Y", time());
    if ($settings['enewsletter_id']) $output .= form_hidden ('enewsletter_id', $settings['enewsletter_id']);
    if ($settings['title']) $output .= form_hidden ('title', $settings[ 'title' ]);
    if ($settings['last']) $output .= form_hidden ('last', $settings[ 'last' ]);
    if ($settings[ 'frequency' ] == NULL) $settings[ 'frequency' ] = 'manual';
    
    if ($settings['enewsletter_id'] != ANNOUNCEMENT) {  

        if ($settings[ 'next' ] == NULL OR $settings[ 'next' ] == 0) {
            $start_hour = ($settings[ 'next_hour' ]) ? $settings[ 'next_hour' ] : '8';
        } else {
            $start_hour = date ('G', $settings[ 'next' ]);
            $start_date = date ('m/d/y', $settings[ 'next' ]);
            $start_day = date ('l, M j Y', $settings[ 'next' ]);
        }
        
        $frequency .= form_textfield (t("Every" ), "every" , $settings[ "every" ], 5, 3);
        $frequency .= form_radios(t("Frequency"), "frequency", $settings[ 'frequency' ], array('hour' => t('Hour(s)'), 'day' => t('Day(s)'), 'month' => t('Month(s)'), 'manual' => t('Manual')));
        $output .= form_group(t('Frequency'), $frequency, t('How often this email newsletter should be sent'));
    }
  
  // Include start form group
  // Only needed before first send out
  if ($settings[ "last" ] == 0) {
    if ($settings[ "start" ] == NULL OR $settings[ "start" ] == 0) {
      $nodes_date = '1/1/99';
    } else {
      $nodes_date = date ("m/d/y", $settings[ "start" ]);
    }
  
    $include_start  .= form_textfield (t("Include Nodes From (date)" ),