subscribers_import.php

<?php
/**
 *  Original Code Copyright (C) 2005, 2006, 2007, 2008  Brice Burgess <bhb@iceburg.net>
 *  released originally under GPLV2
 *
 *  This file is part of poMMo.
 *
 *  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 3 of the License, or
 *  (at your option) 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 Pommo.  If not, see <http://www.gnu.org/licenses/>.
 *
 *  This fork is from https://github.com/soonick/poMMo
 *  Please see docs/contribs for Contributors
 *
 */

/**********************************
	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';
$view = new Pommo_Template();

// Maximum File Size (in MB)
$max_file_size = 2;
$view->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)) {
                        $email = strtolower($email);
                        $a[$email] = $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');
		}
	}
}

$view->display('admin/subscribers/subscribers_import');