link

#!/usr/bin/php

<?
if ($_SERVER["REMOTE_ADDR"]) {
  print "This script must be run from command line\n";
  exit;
}


require (dirname($_SERVER["SCRIPT_FILENAME"]).'/../config.php');
require (dirname($_SERVER["SCRIPT_FILENAME"]).'/../lib/lib.php');

if (file_exists($linker_lock_file)) {
  print "Lock file exist! Another linker is running?\n";
  exit;
}

touch($linker_lock_file);

connect_to_sql($sql_host,$sql_base,$sql_user,$sql_pass);
//echo("Link is\n");
//var_dump($link);
// ▒▒▒▒▒▒▒ ▒▒▒▒▒▒▒▒▒ ▒▒▒▒▒▒▒ ▒▒▒ ▒▒▒▒▒▒▒▒▒
$quer=mysqli_query($link, "create temporary table `tmp` (
   `id` bigint(64) NOT NULL,
   `msgid` varchar(128) NULL,
   `reply` varchar(128) NULL,
   `recieved` datetime NULL,
   `area` text NULL,
   `thread` text NULL,
   `level` bigint(64) NOT NULL,
   `inthread` bigint(64) NOT NULL,
   `fromname` varchar(128) NULL,
   `fromaddr` varchar(128) NULL,
   `hash` varchar(128) NULL,
   `date` varchar(128) NULL,
   `subject` text NULL
) ENGINE=InnoDB  CHARSET=utf8;");
//var_dump($quer);

//if isset($argv[1]){
if ($argv['1']) {
  $area=$argv ['1'];
} else {
  $area="";
}

if ($area) {
  $query=("select upper(area) as area from `messages` where thread='' and area='$area' group by area");
} else {
  $query=("select upper(area) as area from `messages` where thread='' and area!='' group by area order by area;");
}
$result=mysqli_query($link, $query);
//$result=mysqli_query($link, "SELECT msgid FROM `tmp`");

//echo("result is\n");
//var_dump($result);
//echo("Query is\n");
//var_dump($query);

while ($row=mysqli_fetch_object($result)) {
  // ▒▒ ▒▒▒▒▒▒ ▒▒▒▒▒▒ ▒▒▒▒▒▒▒ ▒▒▒▒▒▒▒▒▒ ▒▒▒▒▒▒▒
  mysqli_query($link, "delete from `tmp`;");
  // ▒▒▒▒▒▒▒▒▒ ▒▒▒▒▒▒▒▒▒ ▒▒▒▒▒▒▒ ▒▒▒▒▒▒▒▒ ▒▒ ▒▒▒▒▒▒▒▒▒ ▒▒▒
  $rrl=mysqli_query($link, "insert into `tmp` (id, msgid, reply, recieved,area,thread,level,inthread,fromname,fromaddr,hash,date,subject) select id, msgid, reply, recieved,area,thread,level,inthread,fromname,fromaddr,hash,date,subject from `messages` where area=\"$row->area\"");

//$rrr=mysqli_query($link, "select * from `tmp`");
//print $rrr;
//var_dump($row);

  print $row->area." ";
  $area_end=0;
  while ($area_end==0){
    $result2=mysqli_query($link, "select msgid,reply,subject,fromname,fromaddr,date,recieved,hash from `tmp` where thread='' order by recieved limit 1");
print(".");
//echo "this is result2\n";
//var_dump($result2);
    if (mysqli_num_rows($result2)){
      $row2=mysqli_fetch_object($result2);
      echo("This  is row2\n");
      var_dump($row2);
      $thread_info = array (
        'area'                  => $row->area,
        'thread'                => find_begin($row2->msgid),
        'subject'               => $row2->subject,
        'author'                => $row2->fromname,
        'author_address'        => $row2->fromaddr,
        'author_date'           => $row2->date,
        'last_author'           => $row2->fromname,
        'last_author_address'   => $row2->fromaddr,
        'last_author_date'      => $row2->date,
        'num'                   => 0,
        'lastupdate'            => $row2->recieved,
        'last_hash'             => $row2->hash
      );
//      print_r ($thread_info);
      $thread_info=set_thread($thread_info);
      echo("This is thread_info\n");
      var_dump($thread_info);
//      print_r ($thread_info);
    } else {
      $area_end=1;
    }
    save_thread($thread_info);
  }
//▒ ▒▒▒▒ ▒▒▒▒▒▒▒▒▒
  print "\n";
}

unlink($linker_lock_file);

/*
function find_begin($msgid){
  global $link;
  $result=mysqli_query($link, "select reply from `tmp` where msgid=\"$msgid\"");
  if(mysqli_num_rows($result)){
    $row=mysqli_fetch_object($result);
    if ($row->reply) {
      $return=find_begin($row->reply);
    } else {
      $return=$msgid;
    }
  } else {
    $return=$msgid;
  }
  return $return;
}
*/

function find_begin($msgid){
  global $link;
  $result=mysqli_query($link, "select reply from `tmp` where msgid=\"$msgid\"");
  if(mysqli_num_rows($result)){
    $row=mysqli_fetch_object($result);
    if ($row->reply) {
      $return=find_begin($row->reply);
      if (!$return) {
        $return=$msgid;
      }
    } else {
      $return=$msgid;
    }
  } else {
    $return=0;
  }
  return $return;
}

function match_text($str1,$str2){
  $str1=preg_replace('/^Re/','',$str1);
  $str2=preg_replace('/^Re/','',$str2);
  $str1=preg_replace('/▒/','H',$str1);
  $str2=preg_replace('/▒/','H',$str2);
  $str1=preg_replace('/(:|\^| |[0-9]|\[.*\]|\(no subject\))/','',$str1);
  $str2=preg_replace('/(:|\^| |[0-9]|\[.*\]|\(no subject\))/','',$str2);
  if (levenshtein($str1,$str2, 1,10,1) < 20) {
    return 1;
  }else{
    print "splitted thread: $str1\n";
    return 0;
  }
}

function save_thread($thread_info){
    global $link;
    mysqli_query($link, "
        insert into `tmp_threads` set
          area=\"".$thread_info['area']."\",
          thread=\"".$thread_info['thread']."\",
          hash=\"".$thread_info['last_hash']."\",
          subject=\"".$thread_info['subject']."\",
          author=\"".$thread_info['author']."\",
          author_address=\"".$thread_info['author_address']."\",
          author_date=\"".$thread_info['author_date']."\",
          last_author=\"".$thread_info['last_author']."\",
          last_author_date=\"".$thread_info['last_author_date']."\",
          num=\"".$thread_info['num']."\",
          lastupdate=\"".$thread_info['lastupdate']."\";
    ");

}

function set_thread($thread_info,$msgid=0,$level=0){
  global $link;
  if (!$msgid){ $msgid=$thread_info['thread']; }
  mysqli_query($link, "delete from `tmp` where msgid=\"$msgid\";");
  mysqli_query($link, "update `messages` set thread=\"".$thread_info['thread']."\", inthread=\"".$thread_info['num']."\", level=\"$level\" where msgid=\"$msgid\" and area=\"".$thread_info['area']."\";");
  $thread_info['num']++;
  $result=mysqli_query($link, "select msgid,recieved,date,fromaddr,fromname,hash,subject from `tmp` where reply=\"$msgid\" order by recieved;");
  while ($row=mysqli_fetch_object($result)){
    if (match_text($row->subject,$thread_info['subject'])){
      if ($row->recieved > $thread_info['recieved']){
        $thread_info['lastupdate']=$row->recieved;
        $thread_info['last_author']=$row->fromname;
        $thread_info['last_author_address']=$row->fromaddr;
        $thread_info['last_author_date']=$row->date;
        $thread_info['last_hash']=$row->hash;
      }
      $thread_info=set_thread($thread_info,$row->msgid,$level+1);
    }else{
      $new_thread_info = array (
        'area'                  => $thread_info['area'],
        'thread'                => $row->msgid,
        'subject'               => $row->subject,
        'author'                => $row->fromname,
        'author_address'        => $row->fromaddr,
        'author_date'           => $row->date,
        'last_author'           => $row->fromname,
        'last_author_address'   => $row->fromaddr,
        'last_author_date'      => $row->date,
        'num'                   => 0,
        'lastupdate'            => $row->recieved,
        'last_hash'             => $row->hash
        );
      $new_thread_info=set_thread($new_thread_info);
      save_thread($new_thread_info);
    }
  }
  return $thread_info;
}


?>