<?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            *
  \**************************************************************************/

  /* $Id$ */

	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 = '')
		{
			$this->db = $GLOBALS['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;
		}
	}
?>