date = $_date; $this->subject = $_subject; $this->from = $_from; $this->desc = $_desc; $this->isread = $_read; $this->descunread = $_descunread; } } /** Class spool * builds and updates spool */ define("BANANA_SPOOL_VERSION", '0.2'); class spool { var $version; /** spool */ var $overview; /** group name */ var $group; /** array msgid => msgnum */ var $ids; /** constructor * @param $_nntp RESOURCE NNTP socket filehandle * @param $_group STRING group name * @param $_display INTEGER 1 => all posts, 2 => only threads with new posts * @param $_since INTEGER time stamp (used for read/unread) */ function spool(&$_nntp, $_group, $_display=0, $_since="") { global $news; $spool_path = dirname(dirname(__FILE__)).'/spool'; $spoolfile = "$spool_path/spool-$_group.dat"; $groupinfo = $_nntp->group($_group); $first = max($groupinfo[2]-$news['maxspool'], $groupinfo[1]); $last = $groupinfo[2]; if (!$groupinfo) { $this = null; return false; } if (file_exists($spoolfile)) { $this = unserialize(file_get_contents($spoolfile)); } if ($this->version == BANANA_SPOOL_VERSION) { $keys = array_values($this->ids); rsort($keys); // remove expired messages for ($id=min(array_keys($this->overview)); $id<$first; $id++) { $this->delid($id, false); } $first = max(array_keys($this->overview))+1; } else { unset($this->overview, $this->ids); $this->group = $_group; $this->version = BANANA_SPOOL_VERSION; } if (($first<$last) && $groupinfo[0]) { $dates = array_map("strtotime", $_nntp->xhdr("Date", "$first-$last")); $subjects = array_map("headerdecode", $_nntp->xhdr("Subject", "$first-$last")); $froms = array_map("headerdecode", $_nntp->xhdr("From", "$first-$last")); $msgids = $_nntp->xhdr("Message-ID", "$first-$last"); $refs = $_nntp->xhdr("References", "$first-$last"); if (isset($this->ids)) { $this->ids = array_merge($this->ids, array_flip($msgids)); } else { $this->ids = array_flip($msgids); } foreach ($msgids as $id=>$msgid) { $msg = new spoolhead($dates[$id], $subjects[$id], $froms[$id], 1); $refs[$id] = str_replace("><", "> <", $refs[$id]); $msgrefs = preg_split("/( |\t)/", strtr($refs[$id], $this->ids)); $parents = preg_grep("/^\d+$/", $msgrefs); $msg->parent = array_pop($parents); $msg->parent_direct = preg_match("/^\d+$/", array_pop($msgrefs)); $p = $msg->parent; while ($p) { if (isset($this->overview[$p])) { $this->overview[$p]->desc++; $p = $this->overview[$p]->parent; } else { $this->overview[$p] = new spoolhead($dates[$p], $subjects[$p], $froms[$p], 1); break; } } if ($msg->parent) { $this->overview[$msg->parent]->children[] = $id; } $this->overview[$id] = $msg; } uasort($this->overview, "spoolcompare"); file_put_contents($spoolfile, serialize($this)); } if ($_since) { $newpostsids = $_nntp->newnews($_since, $_group); if (sizeof($newpostsids)) { $newpostsids = array_intersect($newpostsids, array_keys($this->ids)); if ($newpostsids && !is_null($newpostsids)) { foreach ($newpostsids as $mid) { $this->overview[$this->ids[$mid]]->isread = false; $this->overview[$this->ids[$mid]]->descunread = 1; $parentmid = $this->ids[$mid]; while (isset($parentmid)) { $this->overview[$parentmid]->descunread ++; $parentmid = $this->overview[$parentmid]->parent; } } } } if (sizeof($newpostsids)>0) { switch ($_display) { case 1: foreach ($this->overview as $i=>$p) { if (isset($this->overview[$i]) && !isset($this->overview[$i]->parent) && ($this->overview[$i]->descunread==0)) { $this->killdesc($i); } } break; case 2: $flipids = array_flip($this->ids); foreach ($this->overview as $i=>$p) { if ($p->isread) { unset($this->overview[$i]); unset($flipids[$i]); } } $this->ids = array_flip($flipids); break; } } } return true; } /** kill post and childrens * @param $_id MSGNUM of post */ function killdesc($_id) { if (sizeof($this->overview[$_id]->children)) { foreach ($this->overview[$_id]->children as $c) { $this->killdesc($c); } } unset($this->overview[$_id]); $msgid = array_search($_id, $this->ids); if ($msgids) { unset($this->ids[$msgid]); } } /** delete a post from overview * @param $_id MSGNUM of post */ function delid($_id, $write=true) { if (isset($this->overview[$_id])) { if (sizeof($this->overview[$_id]->parent)) { $this->overview[$this->overview[$_id]->parent]->children = array_diff($this->overview[$this->overview[$_id]->parent]->children, array($_id)); if (sizeof($this->overview[$_id]->children)) { $this->overview[$this->overview[$_id]->parent]->children = array_merge($this->overview[$this->overview[$_id]->parent]->children, $this->overview[$_id]->children); foreach ($this->overview[$_id]->children as $c) { $this->overview[$c]->parent = $this->overview[$_id]->parent; $this->overview[$c]->parent_direct = false; } } $p = $this->overview[$_id]->parent; while ($p) { $this->overview[$p]->desc--; $p = $this->overview[$p]->parent; } } elseif (sizeof($this->overview[$_id]->children)) { foreach ($this->overview[$_id]->children as $c) { $this->overview[$c]->parent = null; } } unset($this->overview[$_id]); $msgid = array_search($_id, $this->ids); if ($msgid) { unset($this->ids[$msgid]); } if ($write) { $spool_path = dirname(dirname(__FILE__)).'/spool'; file_put_contents("$spool_path/spool-$_group.dat", serialize($this)); } } } /** displays children tree of a post * @param $_id INTEGER MSGNUM of post * @param $_index INTEGER linear number of post in the tree * @param $_first INTEGER linear number of first post displayed * @param $_last INTEGER linear number of last post displayed * @param $_ref STRING MSGNUM of current post * @param $_pfx_node STRING prefix used for current node * @param $_pfx_end STRING prefix used for children of current node * @param $_head BOOLEAN true if first post in thread */ function disp_desc($_id, $_index="", $_first=0, $_last=0, $_ref="", $_pfx_node="", $_pfx_end="", $_head=true) { global $css; $debug = false; $spfx_f = ''; $spfx_n = ''; $spfx_Tnd = ''; $spfx_Lnd = ''; $spfx_snd = ''; $spfx_T = ''; $spfx_L = ''; $spfx_s = ''; $spfx_e = ''; $spfx_I = ''; if ($_index == "") { $_index = $this->getndx($_id); } if (!sizeof($this->overview[$_id]->children) && ($_index<=$_last) && ($_index>=$_first)) { echo '