From: x99bachelart <x99bachelart>
Date: Wed, 3 Sep 2003 11:18:05 +0000 (+0000)
Subject: spool subroutines
X-Git-Tag: 1.8~443
X-Git-Url: http://git.polytechnique.org/?a=commitdiff_plain;h=810ac1df95ca39b09eb7b970b197fd2608396588;p=banana.git

spool subroutines
---

diff --git a/include/spool.inc.php b/include/spool.inc.php
new file mode 100644
index 0000000..efebf23
--- /dev/null
+++ b/include/spool.inc.php
@@ -0,0 +1,359 @@
+<?php
+/********************************************************************************
+* include/spool.inc.php : spool subroutines
+* -----------------------
+*
+* This file is part of the banana distribution
+* Copyright: See COPYING files that comes with this distribution
+********************************************************************************/
+
+/** Class spoolhead
+ *  class used in thread overviews
+ */
+class spoolhead {
+  /** date (timestamp) */
+  var $date;
+  /** subject */
+  var $subject;
+  /** author */
+  var $from;
+  /** reference of parent */
+  var $parent;
+  /** array of children */
+  var $children;
+  /** true if post is read */
+  var $isread;
+  /** number of posts deeper in this branch of tree */
+  var $desc;
+  /**  same as desc, but counts only unread posts */
+  var $descunread;
+
+  /** constructor
+   * @param $_date INTEGER timestamp of post
+   * @param $_subject STRING subject of post
+   * @param $_from STRING author of post
+   * @param $_desc INTEGER desc value (1 for a new post)
+   * @param $_read BOOLEAN true if read
+   * @param $_descunread INTEGER descunread value (0 for a new post)
+   */
+
+  function spoolhead($_date,$_subject,$_from,$_desc=1,$_read=true,$_descunread=0) {
+    $this->date=$_date;
+    $this->subject=$_subject;
+    $this->from=$_from;
+    $this->children=array();
+    $this->desc=$_desc;
+    $this->isread=$_read;
+    $this->descunread=$_descunread;
+  }
+}
+
+/** Class spool
+ * builds and updates spool 
+ */
+
+class spool {
+#  var $date;
+  /**  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=""){
+    $groupinfo = $_nntp->group($_group);
+    if (!$groupinfo) {
+      $this = false;
+      return false;
+    }
+    if (file_exists("/home/basile/dev/banana-dev/spool/spool-$_group.dat")) {
+      $f = fopen("/home/basile/dev/banana-dev/spool/spool-$_group.dat","r");
+      $this = unserialize(fread($f,filesize("/home/basile/dev/banana-dev/spool/spool-$_group.dat")));
+      fclose($f);
+      $keys = array_values($this->ids);
+      rsort($keys);
+      $first = $keys[0]+1;
+      $last = $groupinfo[2];
+    } else {
+      $first = $groupinfo[1];
+      $last = $groupinfo[2];
+      $this->group = $_group;
+    }
+    if (($first<=$groupinfo[2]) && ($groupinfo[0]!=0)) {
+      $dates = array_map("strtotime",
+        $_nntp->xhdr("Date","$first-$last"));
+      $msgids=$_nntp->xhdr("Message-ID","$first-$last");
+      $subjects = array_map("headerdecode",$_nntp->xhdr("Subject",
+        "$first-$last"));
+      $froms = array_map("headerdecode",$_nntp->xhdr("From",
+        "$first-$last"));
+      $refs = $_nntp->xhdr("References","$first-$last");
+#      $this->date=$nntp->date;
+      if ($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],
+          (isset($this->overview[$id]->desc)?
+          $this->overview[$id]->desc+1: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);
+        $p = $msg->parent;
+        while ($p) {
+          $this->overview[$p]->desc++;
+          $p = $this->overview[$p]->parent;
+        }
+        if ($msg->parent!="") 
+          $this->overview[$msg->parent]->children[]=$id;
+        $this->overview[$id] = $msg;
+      }
+      uasort($this->overview,"spoolcompare");
+      $f = fopen("spool/spool-$_group.dat","w");
+      fputs($f,serialize($this));
+      fclose($f);
+    }
+    
+    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->overview[$this->ids[$mid]]->parent;
+            while (!is_null($parentmid)) {
+              $this->overview[$parentmid]->descunread++;
+              $parentmid = $this->overview[$parentmid]->parent;
+            }
+          }
+        }
+      }
+      if (sizeof($newpostsids)>0) {
+        $flipids = array_flip($this->ids);
+        switch ($_display) {
+          case 1:
+            foreach ($this->overview as $i=>$p) {
+              if (!isset($this->overview[$i]->parent) && 
+              ($this->overview[$i]->descunread==0)) {
+                $this->killdesc($i);
+              }
+            }
+            break;
+          case 2:
+            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]);
+#    $flipid=array_flip($this->ids);
+#    unset($flipid[$id]);
+#    $this->ids=array_flip($flipid);
+  }
+
+  /** delete a post from overview
+   * @param $_id MSGNUM of post
+   */
+
+  function delid($_id) {
+    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;
+          }
+        }
+        $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]);
+      $ids = array_flip($this->ids);
+      unset($ids[$_id]);
+      $this->ids = array_flip($ids);
+      $f = fopen("spool/spool-{$this->group}.dat","w");
+      fputs($f,serialize($this));
+      fclose($f);
+    }
+  }
+
+  /** 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) {
+    $debug = false;
+    $spfx_f = '<img src="img/k1.gif" height="21" width="9" alt="o" />'; 
+    $spfx_n = '<img src="img/k2.gif" height="21" width="9" alt="*" />'; 
+    $spfx_T = '<img src="img/T.gif" height="21" width="12" alt="+" />';
+    $spfx_L = '<img src="img/L.gif" height="21" width="12" alt="`" />';
+    $spfx_s = '<img src="img/s.gif" height="21" width="5" alt="-" />';
+    $spfx_e = '<img src="img/e.gif" height="21" width="12" alt="&nbsp;" />';
+    $spfx_I = '<img src="img/I.gif" height="21" width="12"alt="|" />';
+    
+    if ($_index == "") $_index = $this->getndx($_id);
+    
+    if (!sizeof($this->overview[$_id]->children) && ($_index<=$_last)
+    && ($_index>=$_first)) {
+      echo '<tr class="'.($_index%2?"pair":"impair")."\">\n";
+      echo "<td class=\"date\">"
+        .formatSpoolHeader("date",$this->overview[$_id]->date,$_id,
+        $this->group,($_index==$_ref),$this->overview[$_id]->isread)
+        ." </td>\n";
+      echo "<td class=\"subject\"><div class=\"tree\">"
+        .$_pfx_node.($_head?$spfx_f:$spfx_s)."</div>"
+        .formatSpoolHeader("subject",$this->overview[$_id]->subject,$_id,
+        $this->group,($_index==$_ref),$this->overview[$_id]->isread)
+        .($debug?" $_id $_index ".
+        $this->overview[$_id]->desc." ".$this->overview[$_id]->descunread." ":"")." </td>\n";
+      echo "<td class=\"author\">"
+        .formatSpoolHeader("from",$this->overview[$_id]->from,$_id,
+        $this->group,($_index==$_ref),$this->overview[$_id]->isread)
+        ." </td>\n</tr>";
+      return true;
+    } 
+    $children = $this->overview[$_id]->children;
+    if (($_index<=$_last) && ($_index>=$_first)) {
+      echo '<tr class="'.($_index%2?"pair":"impair")."\">\n";
+      echo "<td class=\"date\">"
+         .formatSpoolHeader("date",$this->overview[$_id]->date,$_id,
+         $this->group,($_index==$_ref),$this->overview[$_id]->isread)
+         ." </td>\n";
+      echo "<td class=\"subject\"><div class=\"tree\">"
+        .$_pfx_node.$spfx_n."</div>"
+        .formatSpoolHeader("subject",$this->overview[$_id]->subject,$_id,
+        $this->group,($_index==$_ref),$this->overview[$_id]->isread)
+        .($debug?" $_id $_index ".
+        $this->overview[$_id]->desc." ".$this->overview[$_id]->descunread." ":"")." </td>\n";
+      echo "<td class=\"author\">"
+        .formatSpoolHeader("from",$this->overview[$_id]->from,$_id,
+        $this->group,($_index==$_ref),$this->overview[$_id]->isread)
+        ." </td>\n</tr>";
+    }
+	$index=$_index+1;
+    while ($child = array_shift($children)) {
+      if (($index+$this->overview[$child]->desc-1>=$_first)
+      ||($index<$_last)){
+        if (sizeof($children)) {
+          $this->disp_desc($child,$index,$_first,$_last,$_ref,
+            $_pfx_end.$spfx_T,$_pfx_end.$spfx_I,false);
+        } else {
+          $this->disp_desc($child,$index,$_first,$_last,$_ref,
+            $_pfx_end.$spfx_L,$_pfx_end.$spfx_e,false);
+        }
+      }
+      $index += $this->overview[$child]->desc;
+    }
+  }
+
+  /** Displays overview
+   * @param $_first INTEGER MSGNUM of first post
+   * @param $_last INTEGER MSGNUM of last post
+   * @param $_ref STRING MSGNUM of current/selectionned post
+   */
+
+  function disp($_first=0,$_last=0,$_ref="") {
+    $index=1;
+    if (sizeof($this->overview)) {
+      foreach ($this->overview as $id=>$msg) {
+        if (!sizeof($msg->parent)) {
+          $this->disp_desc($id,$index,$_first,$_last,$_ref);
+          $index += $msg->desc;
+        }
+      }
+    } else {
+     echo "<tr class=\"pair\">\n";
+     echo "\t<td colspan=\"3\">\n";
+     echo "\t\tNo post in this newsgroup\n";
+     echo "\t</td>\n";
+     echo "</tr>\n";
+    }
+  }
+  
+  /** computes linear post index
+   * @param $_id INTEGER MSGNUM of post
+   * @return INTEGER linear index of post
+   */
+
+  function getndx($_id) {
+    $ndx = 1;
+    // on remonte l'arbre
+    $id_parent = $this->overview[$_id]->parent;
+    $id_curr = $_id;
+    while (!is_null($id_parent)) {
+      for ($i=0; $i<array_search($id_curr,
+      $this->overview[$id_parent]->children) ; $i++) {
+        $ndx += $this->overview[$this->overview[$id_parent]->children[$i]]->desc;
+      }
+      $ndx++; //noeud père
+      $id_curr = $id_parent;
+      $id_parent = $this->overview[$id_curr]->parent;
+    }
+    // on compte les threads précédents
+    foreach ($this->overview as $i=>$p) {
+      if ($i==$id_curr) {
+        break;
+      }
+      if (is_null($p->parent)) {
+        $ndx += $this->overview[$i]->desc;
+      }
+    }
+    return $ndx;
+  }
+}
+
+?>