<?php
/********************************************************************************
* banana/nntp.inc.php : NNTP protocole handler
* ------------------------
*
* This file is part of the banana distribution
* Copyright: See COPYING files that comes with this distribution
********************************************************************************/

require_once dirname(__FILE__) . '/banana.inc.php';
require_once dirname(__FILE__) . '/message.inc.php';
require_once dirname(__FILE__) . '/nntpcore.inc.php';
require_once dirname(__FILE__) . '/protocoleinterface.inc.php';

class BananaNNTP extends BananaNNTPCore implements BananaProtocoleInterface
{
    private $ingroup = null;

    private $mode = null;
    private $boxes = null;

    /** Build a protocole handler plugged on the given box
     */
    public function __construct()
    {
        $url = parse_url(Banana::$nntp_host);
        if ($url['scheme'] == 'nntps' || $url['scheme'] == 'snntp') {
            $url['host'] = 'ssl://' . $url['host'];
            if (!isset($url['port'])) {
                $url['port'] = 563;
            }
        } else if (!isset($url['port'])) {
            $url['port'] = 119;
        }
        parent::__construct($url['host'], $url['port']);
        if (isset($url['user'])) {
            $this->authinfo($url['user'], $url['pass']);
        }
    }

    /** Return the descript;ion of the current box
     */
    public function getDescription()
    {
        $descs = $this->xgtitle(Banana::$group);
        if (isset($descs[Banana::$group])) {
            return trim(utf8_encode($descs[Banana::$group]));
        }
        return null;
    }

    /** Return the list of the boxes
     * @param mode Kind of boxes to list
     * @param since date of last check (for new boxes and new messages)
     * @return Array(boxname => array(desc => boxdescripton, msgnum => number of message, unread =>number of unread messages)
     */
    public function getBoxList($mode = Banana::BOXES_ALL, $since = 0, $withstats = false)
    {
        if (!is_array($this->boxes) || $this->mode != $mode) {
            $descs = $this->xgtitle();
            if ($mode == Banana::BOXES_NEW && $since) {
                $list = $this->newgroups($since);
            } else {
                $list = $this->listGroups();
                if ($mode == Banana::BOXES_SUB) {
                    if (is_array(Banana::$profile['subscribe'])) {
                        $sub = array_flip(Banana::$profile['subscribe']);
                    } else {
                        $sub = array();
                    }
                    $list = array_intersect_key($list, $sub);
                }
            }
            $this->boxes = array();
            foreach ($list as $group=>&$infos) {
                if (isset($descs[$group])) {
                    $desc = $descs[$group];
                    if (!is_utf8($desc)) {
                        $desc = utf8_encode($desc);
                    }
                    $this->boxes[$group] = array('desc' => $desc);
                } else {
                    $this->boxes[$group] = array('desc' => null);
                }
            }
            ksort($this->boxes);
        }
        if ($withstats) {
            foreach ($this->boxes as $group=>&$desc) {
                list($msgnum, $first, $last, $groupname) = $this->group($group);
                $this->ingroup = $group;
                $new = $this->newnews($group, $since);
                if (!is_array($new)) {
                    $new = 0;
                } else {
                    $c = count($new);
                    if ($c > 0 && function_exists('hook_listReadMessages')) {
                        $msgs = hook_listReadMessages($group);
                        if (is_array($msgs)) {
                            foreach ($msgs as $msg) {
                                if (is_numeric($msg)) {
                                    $c--;
                                } else if (in_array($msg, $new)) {
                                    $c--;
                                }
                            }
                        }
                    }
                    $new = $c;
                }
                $desc['msgnum'] = $msgnum;
                $desc['unread'] = $new;
            }
        }
        return $this->boxes;
    }

    /** Return a message
     * @param id Id of the emssage (can be either an Message-id or a message index)
     * @return A BananaMessage or null if the given id can't be retreived
     */
    public function &getMessage($id)
    {
        $message = null;
        if (is_numeric($id) && Banana::$group != $this->ingroup) {
            if (is_null(Banana::$spool)) {
                $this->group(Banana::$group);
                $this->ingroup = Banana::$group;
            } else {
                $id = array_search($id, Banana::$spool->ids);
            }
        }
        $data = $this->article($id);
        if ($data !== false) {
            $message = new BananaMessage($data);
        }
        return $message;
    }

    /** Return the sources of the message
     */
    public function getMessageSource($id)
    {
        if (is_numeric($id) && Banana::$group != $this->ingroup) {
            if (is_null(Banana::$spool)) {
                $this->group(Banana::$group);
                $this->ingroup = Banana::$group;
            } else {
                $id = array_search($id, Banana::$spool->ids);
            }
        }
        $data = $this->article($id);
        if ($data !== false) {
            return implode("\n", $data);
        }
        $data = null;
        return $data;
    }

    /** Return the indexes of the messages presents in the Box
     * @return Array(number of messages, MSGNUM of the first message, MSGNUM of the last message)
     */
    public function getIndexes()
    {
        list($msgnum, $first, $last, $groupname) = $this->group(Banana::$group);
        $this->ingroup = Banana::$group;
        return array($msgnum, $first, $last);
    }

    /** Return the message headers (in BananaMessage) for messages from firstid to lastid
     * @return Array(id => array(headername => headervalue))
     */
    public function &getMessageHeaders($firstid, $lastid, array $msg_headers = array())
    {
        $messages = array();
        foreach ($msg_headers as $header) {
            $headers = $this->xhdr($header, $firstid, $lastid);
            $header  = strtolower($header);
            if ($header == 'date') {
                $headers = array_map('strtotime', $headers);
            } else {
                array_walk($headers, array('BananaMimePart', 'decodeHeader'));
            }
            foreach ($headers as $id=>&$value) {
                if (!isset($messages[$id])) {
                    $messages[$id] = array();
                }
                $messages[$id][$header] =& $value;
            }
        }
        return $messages;
    }

    /** Add protocole specific data in the spool
     */
    public function updateSpool(array &$messages)
    {
        return true;
    }

    /** Return the indexes of the new messages since the give date
     * @return Array(MSGNUM of new messages)
     */
    public function getNewIndexes($since)
    {
        return $this->newnews(Banana::$group, $since);
    }

    /** Return true if can post
     */
    public function canSend()
    {
        return $this->isValid();
    }

    /** Return true if can cancel
     */
    public function canCancel()
    {
        return $this->isValid();
    }

    /** Return the list of requested header for a new post
     */
    public function requestedHeaders()
    {
        return Array('From', 'Subject', 'dest' => 'Newsgroups', 'reply' => 'Followup-To', 'Organization');
    }

    /** Send the message
     */
    public function send(BananaMessage $message)
    {
        $sources = $message->get(true);
        return $this->post($sources);
    }

    /** Cancel the message
     */
    public function cancel(BananaMessage $message)
    {
        $headers = Array('From' => Banana::$profile['From'],
                         'Newsgroups' => Banana::$group,
                         'Subject'    => 'cmsg ' . $message->getHeaderValue('message-id'),
                         'Control'    => 'cancel ' . $message->getHeaderValue('message-id'));
        $headers = array_merge($headers, Banana::$msgedit_headers);
        $body   = 'Message canceled with Banana';
        $msg    = BananaMessage::newMessage($headers, $body);
        return $this->send($msg);
    }

    /** Return the protocole name
     */
    public function name()
    {
        return 'NNTP';
    }

    /** Return the filename for the spool
     */
    public function filename()
    {
        $url  = parse_url(Banana::$nntp_host);
        $file = '';
        if (isset($url['host'])) {
            $file .= $url['host'] . '_';
        }
        if (isset($url['port'])) {
            $file .= $url['port'] . '_';
        }
        $file .= Banana::$group;
        return $file;
    }
}

// vim:set et sw=4 sts=4 ts=4 fenc=utf-8:
?>