]+)>|i', $comment, $attribs );
+ preg_match( '| id=\'(\d+)\'|i', $attribs[1], $matches );
+ $lj_comment_ID = $matches[1];
+ preg_match( '| jitemid=\'(\d+)\'|i', $attribs[1], $matches );
+ $lj_comment_post_ID = $matches[1];
+ preg_match( '| posterid=\'(\d+)\'|i', $attribs[1], $matches );
+ $comment_author_ID = $matches[1];
+ preg_match( '| parentid=\'(\d+)\'|i', $attribs[1], $matches );
+ $lj_comment_parent = $matches[1];
+ preg_match( '| state=\'([SDFA])\'|i', $attribs[1], $matches );
+ $lj_comment_state = !empty( $matches[1] ) ? $matches[1] : 'A';
+
+ // Clean up "subject" - this will become the first line of the comment in WP
+ preg_match( '|(.*)|is', $comment, $matches );
+ $comment_subject = $wpdb->escape( trim( $matches[1] ) );
+ if ( 'Re:' == $comment_subject )
+ $comment_subject = '';
+
+ // Get the body and HTMLize it
+ preg_match( '|(.*)|is', $comment, $matches );
+ $comment_content = !empty( $comment_subject ) ? $comment_subject . "\n\n" . $matches[1] : $matches[1];
+ $comment_content = html_entity_decode( $comment_content );
+ $comment_content = str_replace( ''', "'", $comment_content );
+ $comment_content = wpautop( $comment_content );
+ $comment_content = str_replace( '
', '
', $comment_content );
+ $comment_content = str_replace( '
', '
', $comment_content );
+ $comment_content = preg_replace_callback( '|<(/?[A-Z]+)|', create_function( '$match', 'return "<" . strtolower( $match[1] );' ), $comment_content );
+ $comment_content = $wpdb->escape( trim( $comment_content ) );
+
+ // Get and convert the date
+ preg_match( '|(.*)|i', $comment, $matches );
+ $comment_date = trim( str_replace( array( 'T', 'Z' ), ' ', $matches[1] ) );
+
+ // Grab IP if available
+ preg_match( '|(.*)|i', $comment, $matches );
+ $comment_author_IP = $matches[1];
+
+ // Try to get something useful for the comment author, especially if it was "my" comment
+ $author = ( substr( $this->usermap[$comment_author_ID], 0, 4 ) == 'ext_' || empty( $comment_author_ID ) ) ? __( 'Anonymous' ) : $this->usermap[$comment_author_ID];
+ if ( get_option( 'ljapi_username' ) == $author ) {
+ $user = wp_get_current_user();
+ $user_id = $user->ID;
+ $author = $user->display_name;
+ $url = trailingslashit( get_option( 'home' ) );
+ } else {
+ $user_id = 0;
+ $url = ( __( 'Anonymous' ) == $author ) ? '' : 'http://' . $author . '.livejournal.com/';
+ }
+
+ // Send back the array of details
+ return array( 'lj_comment_ID' => $lj_comment_ID,
+ 'lj_comment_post_ID' => $lj_comment_post_ID,
+ 'lj_comment_parent' => ( !empty( $lj_comment_parent ) ? $lj_comment_parent : 0 ),
+ 'lj_comment_state' => $lj_comment_state,
+ 'comment_post_ID' => $this->get_wp_post_ID( $lj_comment_post_ID ),
+ 'comment_author' => $author,
+ 'comment_author_url' => $url,
+ 'comment_content' => $comment_content,
+ 'comment_date' => $comment_date,
+ 'comment_author_IP' => ( !empty( $comment_author_IP ) ? $comment_author_IP : '' ),
+ 'comment_approved' => ( in_array( $lj_comment_state, array( 'A', 'F' ) ) ? 1 : 0 ),
+ 'comment_agent' => 'WP LJ Importer',
+ 'user_id' => $user_id
+ );
+ }
+
+
+ // Gets the post_ID that a LJ post has been saved as within WP
+ function get_wp_post_ID( $post ) {
+ global $wpdb;
+ if ( empty( $this->postmap[$post] ) )
+ $this->postmap[$post] = $wpdb->get_var( $wpdb->prepare( "SELECT post_id FROM $wpdb->postmeta WHERE meta_key = 'lj_itemid' AND meta_value = %d", $post ) );
+ return $this->postmap[$post];
+ }
+
+ // Re-build the threading within a single cache file
+ function thread_comments( $filename ) {
+ if ( !is_file( $filename ) || !is_readable( $filename ) )
+ return new WP_Error( 'File', __( sprintf( 'Cannot access file %s', $filename ) ) );
+
+ $comments = array();
+ @include( $filename );
+ $this->comments = $comments;
+ unset( $comments );
+ if ( !is_array( $this->comments ) )
+ $this->comments = array();
+
+ $count = count( $this->comments );
+ for ( $c = 0; $c < $count; $c++ ) {
+ // Skip anything that's not "top-level" for now
+ if ( 0 != $this->comments[$c]['lj_comment_parent'] )
+ continue;
+ $this->comments[$c]['children'] = $this->get_child_comments( $this->comments[$c]['lj_comment_ID'] );
+ }
+
+ // Remove anything that's not supposed to be at top level
+ $top_comments = array();
+ for ( $c = 0; $c < $count; $c++ ) {
+ if ( 0 == $this->comments[$c]['lj_comment_parent'] ) {
+ $top_comments[] = $this->comments[$c];
+ }
+ }
+
+ // Write back to file
+ @unlink( $filename );
+ $this->write_file( '', $filename, $count, 'w' );
+ unset( $top_comments );
+ $this->close_file_pointers();
+
+ // Reference this file as being threaded
+ $files = get_option( 'ljapi_comment_threaded_files' );
+ $files[] = $filename;
+ array_unique( $files );
+ update_option( 'ljapi_comment_threaded_files', $files );
+ update_option( 'ljapi_comment_threaded_files_count', count( $files ) );
+
+ return true;
+ }
+
+ function get_child_comments( $id ) {
+ $children = array();
+ $count = count( $this->comments );
+ for ( $c = 0; $c < $count; $c++ ) {
+ // This comment is a child of the $id
+ if ( $id == $this->comments[$c]['lj_comment_parent'] ) {
+ $this->comments[$c]['children'] = $this->get_child_comments( $this->comments[$c]['lj_comment_ID'] );
+ $children[] = $this->comments[$c];
+ }
+ }
+ return $children;
+ }
+
+ // Inserts the contents of each cache file (should be threaded already)
+ function insert_comments( $filename ) {
+ echo '';
+ if ( !is_file( $filename ) || !is_readable( $filename ) )
+ return new WP_Error( 'File', __( sprintf( 'Cannot access file %s', $filename ) ) );
+
+ $comments = array();
+ @include( $filename );
+ $this->comments = $comments;
+ unset( $comments );
+ if ( !is_array( $this->comments ) )
+ $this->comments = array();
+
+ $count = count( $this->comments );
+ for ( $c = 0; $c < $count; $c++ ) {
+ $comment =& $this->comments[$c];
echo '- ';
- if ($post_id = post_exists($post_title, $post_content, $post_date)) {
- printf(__('Post %s already exists.'), stripslashes($post_title));
- } else {
- printf(__('Importing post %s...'), stripslashes($post_title));
- $postdata = compact('post_author', 'post_date', 'post_content', 'post_title', 'post_status');
- $post_id = wp_insert_post($postdata);
- if ( is_wp_error( $post_id ) )
- return $post_id;
- if (!$post_id) {
- _e("Couldn't get post ID");
- echo '
';
- break;
- }
+ printf( __( 'Imported comment from %s on %s' ), $comment['comment_author'], $comment['comment_date'] );
+
+ $id = wp_insert_comment( $comment );
+ $comment['comment_ID'] = $id;
+ if ( count( $comment['children'] ) ) {
+ _e( ' and replies:' );
+ $this->insert_child_comments( $comment['children'], $id );
}
+
+ echo '';
+ }
+
+ // Remove the file now that we're done with it
+ @unlink( $filename );
- preg_match_all('|(.*?)|is', $post, $comments);
- $comments = $comments[1];
+ echo '
';
+
+ return true;
+ }
+
+ function insert_child_comments( &$comments, $parent ) {
+ echo '';
+ $count = count( $comments );
+ for ( $c = 0; $c < $count; $c++ ) {
+ $comment =& $comments[$c];
+ $comment['comment_parent'] = $parent;
+ echo '- ';
+ printf( __( 'Imported reply from %s on %s' ), $comment['comment_author'], $comment['comment_date'] );
- if ( $comments ) {
- $comment_post_ID = (int) $post_id;
- $num_comments = 0;
- foreach ($comments as $comment) {
- preg_match('|(.*?)|is', $comment, $comment_content);
- $comment_content = str_replace(array (''), '', trim($comment_content[1]));
- $comment_content = $this->unhtmlentities($comment_content);
-
- // Clean up content
- $comment_content = preg_replace_callback('|<(/?[A-Z]+)|', create_function('$match', 'return "<" . strtolower($match[1]);'), $comment_content);
- $comment_content = str_replace('
', '
', $comment_content);
- $comment_content = str_replace('
', '
', $comment_content);
- $comment_content = $wpdb->escape($comment_content);
-
- preg_match('|(.*?)|is', $comment, $comment_date);
- $comment_date = trim($comment_date[1]);
- $comment_date = date('Y-m-d H:i:s', strtotime($comment_date));
-
- preg_match('|(.*?)|is', $comment, $comment_author);
- $comment_author = $wpdb->escape(trim($comment_author[1]));
-
- preg_match('|(.*?)|is', $comment, $comment_author_email);
- $comment_author_email = $wpdb->escape(trim($comment_author_email[1]));
-
- $comment_approved = 1;
- // Check if it's already there
- if (!comment_exists($comment_author, $comment_date)) {
- $commentdata = compact('comment_post_ID', 'comment_author', 'comment_author_email', 'comment_date', 'comment_content', 'comment_approved');
- $commentdata = wp_filter_comment($commentdata);
- wp_insert_comment($commentdata);
- $num_comments++;
- }
- }
- }
- if ( $num_comments ) {
- echo ' ';
- printf(__ngettext('(%s comment)', '(%s comments)', $num_comments), $num_comments);
+ $id = wp_insert_comment( $comment );
+ $comment['comment_ID'] = $id;
+ if ( count( $comment['children'] ) ) {
+ _e( ' and replies:' );
+ $this->insert_child_comments( $comment['children'], $id );
}
+
echo ' ';
}
echo '
';
}
-
- function import() {
- $file = wp_import_handle_upload();
- if ( isset($file['error']) ) {
- echo $file['error'];
- return;
+
+ function lj_ixr() {
+ if ( $challenge = $this->ixr->query( 'LJ.XMLRPC.getchallenge' ) ) {
+ $challenge = $this->ixr->getResponse();
+ }
+ if ( isset( $challenge['challenge'] ) ) {
+ $params = array( 'username' => $this->username,
+ 'auth_method' => 'challenge',
+ 'auth_challenge' => $challenge['challenge'],
+ 'auth_response' => md5( $challenge['challenge'] . md5( $this->password ) ) );
+ } else {
+ return new WP_Error( 'IXR', __( 'LiveJournal does not appear to be responding right now. Please try again later.' ) );
+ }
+
+ $args = func_get_args();
+ $method = array_shift( $args );
+ if ( isset( $args[0] ) )
+ $params = array_merge( $params, $args[0] );
+ if ( $this->ixr->query( 'LJ.XMLRPC.' . $method, $params ) ) {
+ return $this->ixr->getResponse();
+ } else {
+ $this->log( $this->ixr->message, 'ljimport-error-' . $method . '.txt' );
+ return new WP_Error( 'IXR', __( 'XML-RPC Request Failed - ' ) . $this->ixr->getErrorCode() . ': ' . $this->ixr->getErrorMessage() );
}
-
- $this->file = $file['file'];
- $result = $this->import_posts();
- if ( is_wp_error( $result ) )
- return $result;
- wp_import_cleanup($file['id']);
- do_action('import_done', 'livejournal');
-
- echo '';
- printf(__('All done. Have fun!'), get_option('home'));
- echo '
';
}
-
+
function dispatch() {
- if (empty ($_GET['step']))
+ if ( empty( $_REQUEST['step'] ) )
$step = 0;
else
- $step = (int) $_GET['step'];
+ $step = (int) $_REQUEST['step'];
$this->header();
-
- switch ($step) {
+
+ switch ( $step ) {
+ case -1 :
+ $this->cleanup();
+ // Intentional no break
case 0 :
$this->greet();
break;
case 1 :
- check_admin_referer('import-upload');
- $result = $this->import();
+ case 2 :
+ $this->ixr = new IXR_Client( $this->ixr_url );
+ // Intentional no break
+ case 3 :
+ case 4 :
+ case 5 :
+ check_admin_referer( 'lj-api-import' );
+ $result = $this->{ 'step' . $step }();
if ( is_wp_error( $result ) )
echo $result->get_error_message();
break;
@@ -183,12 +804,371 @@ class LJ_Import {
$this->footer();
}
- function LJ_Import() {
- // Nothing.
+ // Check form inputs and start importing posts
+ function step1() {
+ // Get details from form or from DB
+ if ( !empty( $_POST['lj_username'] ) && !empty( $_POST['lj_password'] ) ) {
+ // Store details for later
+ $this->username = $_POST['lj_username'];
+ $this->password = $_POST['lj_password'];
+ update_option( 'ljapi_username', $this->username );
+ update_option( 'ljapi_password', $this->password );
+ } else {
+ $this->username = get_option( 'ljapi_username' );
+ $this->password = get_option( 'ljapi_password' );
+ }
+
+ // This is the password to set on protected posts
+ if ( !empty( $_POST['protected_password'] ) ) {
+ $this->protected_password = $_POST['protected_password'];
+ update_option( 'ljapi_protected_password', $this->protected_password );
+ } else {
+ $this->protected_password = get_option( 'ljapi_protected_password' );
+ }
+
+ // Login to confirm the details are correct
+ if ( empty( $this->username ) || empty( $this->password ) ) {
+ ?>
+ and password so we can download your posts and comments.' ) ?>
+
+ lj_ixr( 'login' );
+ if ( is_wp_error( $login ) ) {
+ if ( 100 == $this->ixr->getErrorCode() || 101 == $this->ixr->getErrorCode() ) {
+ ?>
+
+
+ ' . __( 'Importing Posts' ) . '';
+ echo '' . __( "We're downloading and importing all your LiveJournal posts..." ) . '
';
+ ob_flush(); flush();
+
+ // Now do the grunt work
+ set_time_limit( 0 );
+ $result = $this->import_posts();
+ if ( is_wp_error( $result ) ) {
+ if ( 406 == $this->ixr->getErrorCode() ) {
+ ?>
+
+
+ ' . __( "Your posts have all been imported, but wait - there's more! Now we need to process & import your comments." ) . '';
+ echo $this->next_step( 2, __( 'Download my comments »' ) );
+ $this->auto_submit();
+ }
+
+ // Download comments to local XML
+ function step2() {
+ set_time_limit( 0 );
+ update_option( 'ljapi_step', 2 );
+ $this->username = get_option( 'ljapi_username' );
+ $this->password = get_option( 'ljapi_password' );
+
+ echo '' . __( 'Downloading Comments' ) . '
';
+ echo '' . __( 'Now we will download your comments so we can process and import them...' ) . '
';
+ ob_flush(); flush();
+
+ $result = $this->download_comments();
+ if ( is_wp_error( $result ) )
+ return $result;
+
+ echo '' . __( 'Your comments have all been downloaded to this server now, so we can process them and get them ready for importing.' ) . '
';
+ echo $this->next_step( 3, __( 'Process my comment files »' ) );
+ $this->auto_submit();
+ }
+
+ // Parse XML into comment cache files
+ function step3() {
+
+ set_time_limit( 0 );
+ update_option( 'ljapi_step', 3 );
+
+ $this->usermap = get_option( 'ljapi_usermap' );
+
+ echo '';
+ echo '
' . __( 'Parsing Comments' ) . '
';
+ echo '
' . __( 'Time to clean up your comments and get them into a format WordPress understands...' ) . '
';
+ ob_flush(); flush();
+
+ $files = get_option( 'ljapi_comment_xml_files' );
+ if ( count( $files ) ) {
+ $file = array_pop( $files );
+
+ $result = $this->parse_comment_xml( $file );
+ if ( is_wp_error( $result ) )
+ return $result;
+
+ update_option( 'ljapi_comment_xml_files', $files );
+ }
+
+ if ( count( $files ) ) {
+ ?>
+
+ auto_ajax( 'ljapi-auto-repost', 'auto-message', 0 ); ?>
+ ' . __( 'Yay, we finished processing all of your comment files! Now we need to re-build your conversation threads.' ) . '';
+ echo $this->next_step( 4, __( 'Thread my comments »' ) );
+ $this->auto_submit();
+ }
+ echo '
';
+ echo '
' . __( 'Threading Comments' ) . '
';
+ echo '
' . __( 'Re-building your conversation threads ready for import...' ) . '
';
+ ob_flush(); flush();
+
+ $files = get_option( 'ljapi_comment_cache_files' );
+ if ( count( $files ) ) {
+ $file = array_pop( $files );
+
+ $result = $this->thread_comments( $file );
+ if ( is_wp_error( $result ) )
+ return $result;
+
+ update_option( 'ljapi_comment_cache_files', $files );
+ }
+
+ if ( count( $files ) ) {
+ ?>
+
+ auto_ajax( 'ljapi-auto-repost', 'auto-message', 0 ); ?>
+ ' . __( "Alrighty, your comments are all threaded. There's just one last step -- time to actually import them all now!" ) . '';
+ echo '
' . __( 'This last part in particular can take a really long time if you have a lot of comments. You might want to go and do something else while you wait.' ) . '
';
+ echo $this->next_step( 5, __( 'Import my threaded comments into WordPress »' ) );
+ $this->auto_submit();
+ }
+ echo '
';
+ echo '
' . __( 'Importing Comments' ) . '
';
+ echo '
' . __( 'This is the big one -- we are now inserting your comment threads into WordPress...' ) . '
';
+
+ $files = get_option( 'ljapi_comment_threaded_files' );
+ echo '
' . sprintf( __( 'Importing cache file %d of %d' ), ( get_option( 'ljapi_comment_threaded_files_count' ) - count( $files ) + 1 ), get_option( 'ljapi_comment_threaded_files_count' ) ) . '
';
+ ob_flush(); flush();
+
+ if ( count( $files ) ) {
+ $file = array_pop( $files );
+
+ $result = $this->insert_comments( $file );
+ if ( is_wp_error( $result ) )
+ return $result;
+
+ update_option( 'ljapi_comment_threaded_files', $files );
+ }
+
+ if ( count( $files ) ) {
+ ?>
+
+ auto_ajax( 'ljapi-auto-repost', 'auto-message', 0 ); ?>
+ cleanup();
+ do_action( 'import_done', 'livejournal' );
+ echo '
';
+ printf( __( 'All done. Have fun!' ), get_option( 'home' ) );
+ echo '
';
+ }
+ echo '