egroupware/phpgwapi/inc/class.msg_nntp_sock.inc.php

<?php
  /**************************************************************************\
  * phpGroupWare API - NNTP                                                  *
  * This file written by Mark Peters <skeeter@phpgroupware.org>              *
  * Handles specific operations in dealing with NNTP                         *
  * Copyright (C) 2001 Mark Peters                                           *
  * -------------------------------------------------------------------------*
  * This library is part of the phpGroupWare API                             *
  * http://www.phpgroupware.org/api                                          * 
  * ------------------------------------------------------------------------ *
  * This library is free software; you can redistribute it and/or modify it  *
  * under the terms of the GNU Lesser General Public License as published by *
  * the Free Software Foundation; either version 2.1 of the License,         *
  * or any later version.                                                    *
  * This library 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 Lesser General Public License for more details.              *
  * You should have received a copy of the GNU Lesser General Public License *
  * along with this library; if not, write to the Free Software Foundation,  *
  * Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA            *
  \**************************************************************************/

  class msg extends msg_base
  {
	var $db;
	var $folder;
	var $start_msg;
	var $end_msg;

	function mode_reader()
	{
		return $this->msg2socket('mode reader','^20[01]',&$response);
	}

	function login ($user,$passwd,$server,$port,$folder = '')
	{
		global $phpgw;
		
		$this->db = $phpgw->db;

		if(@!$server)
		{
			echo 'Error: Configuration Error! The administrator has not configured the NNTP Server.';
		}
		
		if(@!$port)
		{
			$port = 119;
		}

		if (!$this->open_port($server,$port,15))
		{
			$this->error();
		}
		$this->read_port();

		if ($user <> '' && $passwd <> '')
		{
			if (!$this->msg2socket('authinfo user '.$user,'^381',&$response))
			{
				$this->error();
			}
			if (!$this->msg2socket('authinfo pass '.$passwd,'^281',&$response))
			{
				$this->error();
			}
		}
		if (!$this->mode_reader())
		{
			$this->error();
		}
		if(!$folder)
		{
			$folder = $this->get_first_folder();
			if(!$folder)
			{
				$this->error();
			}
		}
		$this->folder = $folder;
		$this->mailbox = $this->get_mailbox_name($folder);
		$this->num_msgs = $this->num_msg($this->mailbox);
		$this->start_msg = $this->first_message($this->mailbox);
		$this->end_msg = $this->last_message($this->mailbox);
		echo 'Successful connection to '.$this->mailbox."<br>\n";
	}

	function fix_folder($folder='')
	{
		if($folder=='')
		{
			$mailbox = $this->mailbox;
		}
		elseif(is_int($folder))
		{
			$mailbox = $this->get_mailbox_name($folder);
		}
		else
		{
			$mailbox = $folder;
		}
		return $mailbox;
	}
	
	function get_first_folder()
	{
		if(@!$GLOBALS['phpgw_info']['user']['preferences']['nntp'])
		{
			$this->set_error('Configuration','User Preferences','You have not set your user preferences in NNTP.');
			$this->error();
		}
		else
		{
			$pref = @each($GLOBALS['phpgw_info']['user']['preferences']['nntp']);
			return $pref[0];
		}
	}

	function get_mailbox_name($folder)
	{
		$active = False;
		$this->db->query('SELECT name,active FROM newsgroups WHERE con='.$folder,_LINE__,__FILE__);
		if ($this->db->num_rows() > 0)
		{
			$this->db->next_record();
			$mailbox	= $this->db->f('name');
		}
		if ($this->db->f('active') != 'Y')
		{
			$GLOBALS['phpgw']->preferences->delete('nntp',$folder);
			$GLOBALS['phpgw']->preferences->save_repository();
			
			$this->set_error('Administration','Automatic Disabling','The newsgroup '.$mailbox.' is not activated by the Administrator.');
			$this->error();
		}
		return $mailbox;
	}

	function get_mailbox_counts($folder='',$index=1)
	{
		$mailbox = $this->fix_folder($folder);
		if (!$this->msg2socket('group '.$mailbox,'^211',&$response))
		{
			$this->error();
		}
		$temp_array = explode(' ',$response);
		return $temp_array[$index];
	}

	function num_msg($folder='')
	{
		if(($folder == '' || $folder == $this->mailbox) && isset($this->num_msgs))
		{
			return $this->num_msgs;
		}
		return $this->get_mailbox_counts($folder,1);
	}

	function first_message($folder='')
	{
		if(($folder == '' || $folder == $this->mailbox) && isset($this->start_msg))
		{
			return $this->start_msg;
		}
		return $this->get_mailbox_counts($folder,2);
	}

	function last_message($folder='')
	{
		if(($folder == '' || $folder == $this->mailbox) && isset($this->end_msg))
		{
			return $this->end_msg;
		}
		return $this->get_mailbox_counts($folder,3);
	}

	function mailboxmsginfo($folder='')
	{
		$info = new msg_mb_info;
		if($folder=='' || $folder==$this->mailbox || $folder==$this->folder)
		{
			if(isset($this->num_msgs))
			{
				$info->messages = $this->num_msgs;
			}
			else
			{
				if($folder==$this->folder)
				{
					$this->mailbox = $this->get_mailbox_name($folder);
				}
				$info->messages = $this->num_msg($this->mailbox);
			}
			$info->size  = 0;
			if ($info->messages)
			{
				return $info;
			}
			else
			{
				return False;
			}
		}
		else
		{
			$mailbox = $this->fix_folder($folder);
		}

		$info->messages = $this->num_msgs($mailbox);
		$info->size  = 0;

		$this->num_msgs($this->mailbox);

		if ($info->messages)
		{
			return $info;
		}
		else
		{
			return False;
		}
	}

	function fetch_field($start,$stop,$element)
	{
		if (!$this->msg2socket('XHDR '.$element.' '.$start.'-'.$stop,'^221',&$response))
		{
			$this->error();
		}

		$field_element = Array();
		while ($line = $this->read_port())
		{
			$line = chop($line);
			if ($line == '.')
			{
				break;
			}
			$breakpos = strpos($line,' ');
			
			$field_element[intval(substr($line,0,$breakpos-1))] = $this->phpGW_quoted_printable_decode2(substr($line,$breakpos+1));
		}
		return $field_element;
	}

	function status($folder='',$options=SA_ALL)
	{
		$info = new mailbox_status;
		$info->messages = $this->num_msg($folder);
		return $info;
	}

	function sort($folder='',$criteria=SORTDATE,$reverse=False,$options='')
	{
		if($folder == '' || $folder == $this->mailbox)
		{
			$mailbox = $this->mailbox;
			$start_msg = $this->start_msg;
			$end_msg = $this->end_msg;
		}
		else
		{
			$mailbox = $this->fix_folder($folder);
			$start_msg = $this->first_message($mailbox);
			$end_msg = $this->last_message($mailbox);
		}
		
		switch($criteria)
		{
			case SORTDATE:
				$old_list = $this->fetch_field($start_msg,$end_msg,'Date');
				$field_list = $this->convert_date_array($old_list);
				break;
			case SORTARRIVAL:
				break;
			case SORTFROM:
				$field_list = $this->fetch_field($start_msg,$end_msg,'From');
				break;
			case SORTSUBJECT:
				$field_list = $this->fetch_field($start_msg,$end_msg,'Subject');
				break;
			case SORTTO:
				$field_list = $this->fetch_field($start_msg,$end_msg,'To');
				break;
			case SORTCC:
				$field_list = $this->fetch_field($start_msg,$end_msg,'cc');
				break;
			case SORTSIZE:
				break;
		}
		@reset($field_list);
		if($criteria == SORTSUBJECT)
		{
			if(!$reverse)
			{
				uasort($field_list,array($this,"ssort_ascending"));
			}
			else
			{
				uasort($field_list,array($this,"ssort_decending"));
			}			
		}
		elseif(!$reverse)
		{
			asort($field_list);
		}
		else
		{
			arsort($field_list);
		}
		$return_array = Array();
		@reset($field_list);
		$i = 1;
		while(list($key,$value) = each($field_list))
		{
			$return_array[] = $key;
			echo '('.$i++.') Field: <b>'.$value."</b>\t\tMsg Num: <b>".$key."</b><br>\n";
		}
		@reset($return_array);
		return $return_array;
	}
}
?>