From 6f3cf4463c97df4e1780f5e28bb10e21a70c6fc4 Mon Sep 17 00:00:00 2001
From: Filipp Lepalaan <filipp@mac.com>
Date: Mon, 1 Mar 2010 20:49:12 +0200
Subject: updated

---
 gl2drupal.php | 170 +++++++++++++++++++++++++++++++++++++++++-----------------
 1 file changed, 122 insertions(+), 48 deletions(-)

diff --git a/gl2drupal.php b/gl2drupal.php
index e9b0b22..952eebc 100755
--- a/gl2drupal.php
+++ b/gl2drupal.php
@@ -2,19 +2,23 @@
 <?php
 
 /**
- *	gl2drupal.php
- *	@author filipp@mac.com
- *  @version 20081019
- *  @todo
- *    - http://drupal.org/node/132202
- *    - drupal.history?
- *	Import Geeklog users, stories, comments, forums, polls and downloads
- *  afp548.com modules: Forum, Search, Profile
- *  11.11.08 user privileges (authenticated, admin)
- *  17.11.08 working on threading
- *  18.12.08 forum posts and comments
+ * gl2drupal.php
+ * Convert Geeklog site to Drupal
+ * @author filipp@mac.com
+ * @version 20081019
+ * @todo
+ * - http://drupal.org/node/132202
+ * - drupal.history?
+ * Import Geeklog users, stories, comments, forums, polls and downloads
+ * afp548.com modules: Forum, Search, Profile
+ * 11.11.08 user privileges (authenticated, admin)
+ * 17.11.08 working on threading
+ * 18.12.08 forum posts and comments
  */
 
+ini_set('display_errors', 'On');
+error_reporting(E_ALL|E_STRICT);
+
 // All arguments are mandatory
 $args = array(
   'h' => 'DBhost',
@@ -34,13 +38,13 @@ foreach ($args as $k => $v) {
 }
 
 $dbpw       = $opts['p'];
-$dbhost     = $opts['h'];
+$dbhost     = $opts['h'] . ":/Applications/MAMP/tmp/mysql/mysql.sock";
 $dbuser     = $opts['u'];
 $drupal_db  = $opts['d'];
 $geeklog_db = $opts['g'];
-
 $gl_tbl_prefix = "gl_";
-$db = mysql_connect($dbhost, $dbuser, $dbpw) or die(mysql_error() . "\n");
+
+$db = mysql_connect($dbhost, $dbuser, $dbpw) or exit(mysql_error() . "\n");
 
 // Add users
 mysql_query("DELETE FROM {$drupal_users}.users");
@@ -103,6 +107,7 @@ mysql_query("ALTER TABLE {$geeklog_db}.{$gl_tbl_prefix}stories DROP PRIMARY KEY"
 $sql = "ALTER TABLE {$geeklog_db}.{$gl_tbl_prefix}stories ADD `idx` INT AUTO_INCREMENT PRIMARY KEY";
 mysql_query($sql);
 
+// Clear all previous content
 mysql_query("DELETE FROM {$drupal_db}.node");
 
 $sql =<<<EOS
@@ -118,7 +123,7 @@ INSERT INTO {$drupal_db}.node
 		UNIX_TIMESTAMP(date),
 		2,
 		1
-		FROM geeklog.{$gl_tbl_prefix}stories);
+		FROM {$geeklog_db}.{$gl_tbl_prefix}stories);
 EOS;
 
 query($sql, "Importing headlines");
@@ -138,7 +143,7 @@ INSERT INTO {$drupal_db}.node_revisions
 		FROM {$geeklog_db}.{$gl_tbl_prefix}stories)
 EOS;
 
-query( $sql, "Importing stories" );
+query($sql, "Importing stories");
 
 /**
  * Import article comments
@@ -153,6 +158,8 @@ query( $sql, "Importing stories" );
  *    02.00/      -> First comment to the second comment
  *    02.00.00/   -> Second comment to the first comment of the second comment
  */
+ 
+// Clear all old comments
 mysql_query("DELETE FROM {$drupal_db}.comments");
 
 $sql =<<<EOS
@@ -171,35 +178,17 @@ SELECT pid,
   FROM {$geeklog_db}.{$gl_tbl_prefix}comments, {$geeklog_db}.{$gl_tbl_prefix}stories, {$geeklog_db}.{$gl_tbl_prefix}users
   WHERE {$gl_tbl_prefix}stories.sid = {$gl_tbl_prefix}comments.sid
     AND {$gl_tbl_prefix}users.uid = {$gl_tbl_prefix}comments.uid
-  ORDER BY {$gl_tbl_prefix}comments.sid, {$gl_tbl_prefix}comments.lft ASC
+    AND {$gl_tbl_prefix}comments.type = 'article'
+  ORDER BY {$gl_tbl_prefix}comments.sid, {$gl_tbl_prefix}comments.cid ASC
+/*  ORDER BY {$gl_tbl_prefix}comments.sid, {$gl_tbl_prefix}comments.lft ASC*/
 EOS;
 
 $result = mysql_query($sql);
 
-
 /**
- * Flatten a modified pre-order traversal structure
- * into the Drupal form.
- * @param 
- * @return (string) a "node's" full path in Drupal notation
- */
-function flatpot($lft, $rht, $indent, $current = '')
-{
-  $sql = "SELECT lft, rht, indent
-    FROM gl_comments
-    WHERE lft < $lft AND rht > $rht
-    ORDER BY lft ASC";
-  $result = mysql_query($sql);
-  while ($row = mysql_fetch_assoc($result)) {
-    $path = $current .
-    $out .= flatpot($row['lft'], $row['rht'], $row['indent'], $path);
-  }
-  return $out;
-}
-
-/**
- * Convert GL "pre-order traversal" to Drupal "notation"
+ * Convert GL "pre-order traversal" to Drupal's "vancode"
  * http://www.sitepoint.com/article/hierarchical-data-database/2/
+ * http://drupal.org/node/97327
  * Since we order by lft, we know that the next row always comes "after" the current one.
  * We only have to determine if it's a child or a sibling, which we should get from the indent.
  * 1	2	0	01/
@@ -210,8 +199,45 @@ function flatpot($lft, $rht, $indent, $current = '')
  */
 $sid = 0;
 while ($row = mysql_fetch_array($result))
-{  
-  // Process these by chunks of "stories"
+{
+  // parts of this borrowed from Drupal's comment.module
+/*
+  // pid == 0 means comment is top level (no parent)
+  if ($row['pid'] == 0) {
+    $sql = "SELECT MAX(thread) FROM {$drupal_db}.comments WHERE nid = {$row['idx']}";
+    $max = mysql_result(mysql_query($sql), 0);
+    // Strip the "/" from the end of the thread.
+    $max = rtrim($max, '/');
+    // Finally, build the thread field for this new comment.
+    $thread = int2vancode(vancode2int($max) + 1) .'/';
+//    $sql = "SELECT MAX(thread) FROM {$drupal_db}.comments WHERE thread LIKE '%s.%%' AND nid = %d";
+  } else {
+    // This comment has a parent
+    $sql = "SELECT `thread` FROM {$drupal_db}.comments WHERE cid = {$row['pid']}";
+    $parent = mysql_result(mysql_query($sql), 0);
+    
+    // Get the max value in _this_ thread.
+    $max = mysql_result(mysql_query("SELECT MAX(thread)
+    FROM {comments} WHERE thread LIKE '{$parent}.%%' AND nid = {$row['idx']}"), 0);
+    if ($max == '') {
+      // First child of this parent.
+      $thread = $parent.'.'. int2vancode(0) .'/';
+    } else {
+      // Strip the "/" at the end of the thread.
+      $max = rtrim($max, '/');
+
+      // We need to get the value at the correct depth.
+      $parts = explode('.', $max);
+      $parent_depth = count(explode('.', $parent));
+      $last = $parts[$parent_depth];
+      
+      // Finally, build the thread field for this new comment.
+      $thread = $parent.'.'. int2vancode(vancode2int($last) + 1) .'/';
+    }
+  }
+*/
+
+  // Process these as chunks of "stories"
   if ($sid != $row['sid']) {
     $sid = $row['sid'];
     $indent = (int) $row['indent'];
@@ -230,9 +256,9 @@ while ($row = mysql_fetch_array($result))
   print_r($t);
   // Build the thread representation
 //  foreach ($)
-  foreach($t as $k => $v) {
-    $thread .= str_pad($k)
-  }
+//  foreach($t as $k => $v) {
+//    $thread .= str_pad($k)
+//  }
 //  $thread = $index . str_repeat(".{$index}", $indent) . '/';
   $thread = implode('.', $t) . '/';
   $comment = mysql_real_escape_string($row['comment']);
@@ -243,10 +269,10 @@ while ($row = mysql_fetch_array($result))
 	VALUES ({$row['pid']}, {$row['idx']}, {$row['uid']}, '$subject', '$comment',
 	  '{$row['ipaddress']}', {$row['date']}, 0, 1, '{$thread}',
 	  '{$row['username']}', '{$row['email']}')";
-	  
-//	query($insert, "Inserting comment thread $thread");
-	
+	query($insert, "Inserting comment thread $thread");
+echo "{$thread}\n";
 }
+//exit();
 
 // Remap Anonymous user
 $sql = "UPDATE {$drupal_db}.comments SET `uid` = 0 WHERE `uid` = 1";
@@ -267,7 +293,7 @@ INSERT INTO {$drupal_db}.node_comment_statistics
 		GROUP BY {$gl_tbl_prefix}stories.idx)
 EOS;
 
-query( $sql, "Generating story comment counts" );
+query($sql, "Generating story comment counts");
 
 // Restore forum comment coounts
 // Without this forum posts don't show up at all
@@ -438,4 +464,52 @@ function result( $action ) {
 	return "$out $result\n";
 }
 
+/**
+ * Flatten a modified pre-order traversal structure
+ * into the Drupal form.
+ * @param [string] $lft
+ * @param (string) $rht
+ * @param (string) $indent
+ * @param (string) $current the current path
+ * @return (string) a "node's" full path in Drupal notation
+ */
+function flatpot($lft, $rht, $indent, $current = '')
+{
+  $sql = "SELECT lft, rht, indent
+    FROM gl_comments
+    WHERE lft < $lft AND rht > $rht
+    ORDER BY lft ASC";
+  $result = mysql_query($sql);
+  while ($row = mysql_fetch_assoc($result)) {
+    $path = $current .
+    $out .= flatpot($row['lft'], $row['rht'], $row['indent'], $path);
+  }
+  return $out;
+}
+
+/**
+ * Generate vancode.
+ *
+ * Consists of a leading character indicating length, followed by N digits
+ * with a numerical value in base 36. Vancodes can be sorted as strings
+ * without messing up numerical order.
+ *
+ * It goes:
+ * 00, 01, 02, ..., 0y, 0z,
+ * 110, 111, ... , 1zy, 1zz,
+ * 2100, 2101, ..., 2zzy, 2zzz,
+ * 31000, 31001, ...
+ */
+function int2vancode($i = 0) {
+  $num = base_convert((int)$i, 10, 36);
+  $length = strlen($num);
+  return chr($length + ord('0') - 1) . $num;
+}
+
+/**
+ * Decode vancode back to an integer.
+ */
+function vancode2int($c = '00') {
+  return base_convert(substr($c, 1), 36, 10);
+}
 ?>
\ No newline at end of file
-- 
cgit v1.2.3