subscribers_import.php

<?php
/**
 * Copyright (C) 2005, 2006, 2007, 2008  Brice Burgess <bhb@iceburg.net>
 * 
 * This file is part of poMMo (http://www.pommo.org)
 * 
 * poMMo is free software; you can redistribute it and/or modify 
 * it under the terms of the GNU General Public License as published 
 * by the Free Software Foundation; either version 2, or any later version.
 * 
 * poMMo is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty
 * of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See
 * the GNU General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License
 * along with program; see the file docs/LICENSE. If not, write to the
 * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
 */

/**********************************
	INITIALIZATION METHODS
*********************************/
require ('bootstrap.php');
require_once(Pommo::$_baseDir.'classes/Pommo_Csv_Stream.php');

Pommo::init();
$logger	= &Pommo::$_logger;
$dbo 	= &Pommo::$_dbo;

/**********************************
	SETUP TEMPLATE, PAGE
 *********************************/
require_once(Pommo::$_baseDir.'classes/Pommo_Template.php');
$smarty = new Pommo_Template();


// Maximum File Size (in MB) 
$max_file_size = 2;
$smarty->assign('maxSize', $max_file_size * 1024 * 1024);

// Filename (in $_FILES array)
$fname = 'csvfile';

if (isset($_POST['submit']))
{
	// POST exists -- set pointer to content
	$fp		= false;
	$box 	= false;
	
	if (!empty($_FILES[$fname]['tmp_name']))
	{
		$fp = &fopen($_FILES[$fname]['tmp_name'], 'r');
	}
	elseif (!empty($_POST['box']))
	{
		$str = &$_POST['box'];
		
		//	wrap $c as a file stream -- requires PHP 4.3.2
		//  for early versions investigate using tmpfile() -- efficient?
		if (!stream_wrapper_register('pommoCSV', 'Pommo_Csv_Stream'))
		{
			Pommo::kill('Failed to register pommoCSV');
		}
		$fp = fopen('pommoCSV://str', 'r+'); 
		
		$box = true;
	}
	
	if (is_resource($fp))
	{
		if ($_POST['type'] == 'csv') // csv data, store first 10 for preview
		{
			$a = array();
			$i = 1;
			while (($data = fgetcsv($fp, 2048, ',', '"')) !== FALSE)
			{
				array_push($a, $data);

				if ($i > 9) // only get first 10 lines -- move file
				{
					break;
				}
				$i++;
			}
			
			// save file for access after assignments
			if ($box)
			{
				// when PHP5 is widespread, switch to file_put_contents()  && use the $fp stream
				if (!$handle = fopen(Pommo::$_workDir.'/import.csv', 'w'))
				{
					Pommo::kill('Could not write to temp CSV file ('.
							Pommo::$_workDir.'/import.csv)');
				}
				
				if (fwrite($handle, $_POST['box']) === FALSE)
				{
					Pommo::kill('Could not write to temp CSV file ('.
							Pommo::$_workDir.'/import.csv)');
				}
				
				 fclose($handle);
			}
			else
			{
				if (!move_uploaded_file($_FILES[$fname]['tmp_name'],
						Pommo::$_workDir.'/import.csv'))
				{
					Pommo::kill('Could not write to temp CSV file ('.
							Pommo::$_workDir.'/import.csv)');
				}
			}
			
			Pommo::set(array('preview' => $a));
			Pommo::redirect('import_csv.php'.(
				isset($_REQUEST['excludeUnsubscribed']) ?
				'?excludeUnsubscribed=true' : ''
			));
		}
		else
		{
			//	Saves all parsed E-mails in an array
			$a = array();
			while (($data = fgetcsv($fp, 2048, ',', '"')) !== FALSE)
			{
				foreach ($data as $email)
				{
					if (Pommo_Helper::isEmail($email))
					{
						array_push($a, $email);
					}
				}
			}
			
			//	Removes from the array E-mails that are already on the database
			$includeUnsubscribed = isset($_REQUEST['excludeUnsubscribed']) ?
					false : true;
			$dupes = &Pommo_Helper::isDupe($a, $includeUnsubscribed);
			
			if (!$dupes)
			{
				$dupes = array();
			}
			$emails = array_diff($a, $dupes);
			
			//	Saves emails in session and redirects to confirmation page
			Pommo::set(array(
				'emails' => $emails,
				'dupes' => (count($dupes))));
			Pommo::redirect('import_txt.php');
		}
	}
}

$smarty->display('admin/subscribers/subscribers_import.tpl');
Pommo::kill();