From 622309aa2453245233abddd4ec7384895c194d73 Mon Sep 17 00:00:00 2001
From: =?utf8?q?Tim=20D=C3=BCsterhus?= <timwolla@bastelstu.be>
Date: Wed, 11 Sep 2013 20:47:20 +0200
Subject: [PATCH] Export conversation users (SMF)

---
 .../system/exporter/SMF2xExporter.class.php   | 46 ++++++++++++++++++-
 1 file changed, 45 insertions(+), 1 deletion(-)

diff --git a/files/lib/system/exporter/SMF2xExporter.class.php b/files/lib/system/exporter/SMF2xExporter.class.php
index e5faf5e..06badfc 100644
--- a/files/lib/system/exporter/SMF2xExporter.class.php
+++ b/files/lib/system/exporter/SMF2xExporter.class.php
@@ -156,7 +156,7 @@ class SMF2xExporter extends AbstractExporter {
 				
 				$queue[] = 'com.woltlab.wcf.conversation';
 				$queue[] = 'com.woltlab.wcf.conversation.message';
-				/*$queue[] = 'com.woltlab.wcf.conversation.user';*/
+				$queue[] = 'com.woltlab.wcf.conversation.user';
 			}
 		}
 		/*
@@ -522,6 +522,50 @@ class SMF2xExporter extends AbstractExporter {
 		}
 	}
 	
+	/**
+	 * Counts conversation recipients.
+	 */
+	public function countConversationUsers() {
+		$sql = "SELECT	COUNT(*) AS count
+			FROM	".$this->databasePrefix."pm_recipients";
+		$statement = $this->database->prepareStatement($sql);
+		$statement->execute();
+		$row = $statement->fetchArray();
+		return $row['count'];
+	}
+	
+	/**
+	 * Exports conversation recipients.
+	 */
+	public function exportConversationUsers($offset, $limit) {
+		$sql = "SELECT		recipients.*, pm.id_pm_head, members.member_name
+			FROM		".$this->databasePrefix."pm_recipients recipients
+			LEFT JOIN	".$this->databasePrefix."personal_messages pm
+			ON		(pm.id_pm = recipients.id_pm)
+			LEFT JOIN	".$this->databasePrefix."members members
+			ON		(recipients.id_member = members.id_member)
+			ORDER BY	recipients.id_pm ASC, recipients.id_member ASC";
+		$statement = $this->database->prepareStatement($sql, $limit, $offset);
+		$statement->execute();
+		while ($row = $statement->fetchArray()) {
+			$labels = array_map(function ($item) use ($row) {
+				return $row['id_member'].'-'.$item;
+			}, array_unique(ArrayUtil::toIntegerArray(explode(',', $row['labels']))));
+			$labels = array_filter($labels, function ($item) {
+				return $item != '-1';
+			});
+			
+			ImportHandler::getInstance()->getImporter('com.woltlab.wcf.conversation.user')->import(0, array(
+				'conversationID' => $row['id_pm_head'],
+				'participantID' => $row['id_member'],
+				'username' => $row['member_name'],
+				'hideConversation' => $row['deleted'] ? 1 : 0,
+				'isInvisible' => $row['bcc'] ? 1 : 0,
+				'lastVisitTime' => $row['is_new'] ? 0 : 1
+			), array('labelIDs' => $labels));
+		}
+	}
+	
 	private static function fixBBCodes($message) {
 		// TODO: This is a identity function right now...
 		return $message;
-- 
2.20.1