';
screen_icon();
echo '' . __( 'Import Echo Comments', 'echo-importer' ) . '
';
}
// Prints the footer for the admin gui
function footer() {
echo '';
}
// Prints the import welcome page
function greet() {
echo '';
echo '
' . __( 'Howdy! Upload your Echo export file and we’ll import the comments.', 'echo-importer' ) . '
';
wp_import_upload_form( "admin.php?import=echo&step=1" );
echo '
- ') ) {
$this->post = '';
$doing_entry = true;
continue;
}
// Are we closing the current item
if ( false !== strpos($importline, '
') ) {
$doing_entry = false;
// Count or process the comment
if ( $process_comment_func )
call_user_func( $process_comment_func, $this->post );
continue;
}
// If we're in the middle of a post
if ( $doing_entry ) {
$this->post .= $importline . "\n";
}
}
$this->fclose($fp);
}
return $is_echo_file;
}
// Determine if the file uploaded appears to be an Echo file and act accordingly
function check_upload() {
$is_echo_file = $this->get_entries( array( &$this, 'count_entries' ));
if ( $is_echo_file ) {
$this->options();
}
else {
echo ''.__('Invalid file', 'echo-importer').'
';
echo ''.__('Please upload a valid Echo export file.', 'echo-importer').'
';
}
}
// Display the options page
function options() {
?>
found_comment_count, 'echo-importer' ), $this->found_comment_count ); ?>
get_tag( $comment, 'guid' );
if( $entry )
$this->found_comment_count++;
}
// Loop through comments and report error or process
function process_comments() {
echo '';
$this->get_entries( array( &$this, 'process_comment' ));
$this->process_orphan_comments(); // call it once to capture replies on the last post
$this->process_orphan_comments( TRUE ); // call it again to force import any remaining unmatched orphans
echo '
';
wp_import_cleanup($this->id);
do_action('import_done', 'echo');
if( $this->num_comments )
echo ''.sprintf( _n( 'Imported %s comment.' , 'Imported %s comments.', $this->num_comments, 'echo-importer' ) , $this->num_comments ) .'
';
if( $this->num_duplicates )
echo ''.sprintf( _n( 'Skipped %s duplicate.' , 'Skipped %s duplicates.', $this->num_duplicates, 'echo-importer' ) , $this->num_duplicates ) .'
';
if( $this->num_uncertain )
echo ''.sprintf( _n( 'Could not determine the correct item to attach %s comment to.' , 'Could not determine the correct item to attach %s comments to.', $this->num_uncertain, 'echo-importer' ) , $this->num_uncertain ) .'
';
echo '';
}
// Process a specific comment
function process_comment( $comment ) {
global $wpdb;
set_time_limit( 60 );
$new_comment['jskit_guid'] = $this->get_tag( $comment, 'guid' );
$new_comment['jskit_parent_guid'] = $this->get_tag( $comment, 'jskit:parent-guid' );
$new_comment['comment_author'] = $this->get_tag( $comment, 'author' );
$gmt_unixtime = strtotime( $this->get_tag( $comment, 'pubDate' ));
$new_comment['comment_date_gmt'] = date( 'Y-m-d H:i:s' , $gmt_unixtime );
$new_comment['comment_date'] = date( 'Y-m-d H:i:s' , $gmt_unixtime + get_option( 'gmt_offset' ) * 3600 ); // strangely, get_date_from_gmt returns unexpected results here
$new_comment['comment_content'] = $this->get_tag( $comment, 'description' );
$new_comment['comment_approved'] = 1; // the export appears to exclude non-public comments
$new_comment['comment_type'] = ''; // echo doesn't appear to support trackbacks or pingbacks
$jskit_attrs = $this->get_tag( $comment, 'jskit:attribute' , TRUE );
foreach( $jskit_attrs as $temp ) {
switch( $temp->attr->key ) {
case 'permalink':
$post_url = $temp->attr->value;
break;
case 'IP':
$new_comment['comment_author_IP'] = $temp->attr->value;
break;
case 'foreign':
// WP-native comments imported into Echo/JS-Kit get double-encoded entities here
// the bug is consistent throughout the JS-Kit world, and persists in the exports
if( 2 == $temp->attr->value )
$new_comment['comment_author'] = html_entity_decode( $new_comment['comment_author'] );
break;
case 'NativeCmtId':
$new_comment['comment_id'] = $temp->attr->value;
break;
}
}
$new_comment['comment_post_ID'] = ( trailingslashit( $post_url ) != trailingslashit( get_option( 'siteurl' ) ) ) ? (int) url_to_postid( $post_url ) : (int) get_option( 'page_on_front' );
if( ! $new_comment['comment_post_ID'] ) { // Couldn't determine the post id from path
echo ''. sprintf( __( 'Couldn’t determine the correct item to attach this comment to. Given URL: %s.', 'echo-importer' ) , esc_url( $post_url )) ."\n";
$this->num_uncertain++;
return 0;
}
$new_comment = array_map( 'html_entity_decode' , $new_comment );
if ( empty( $new_comment['jskit_parent_guid'] ) || $this->comment_exists( array( 'jskit_guid' => $new_comment['jskit_parent_guid'] ) ) ) {
$new_comment['comment_parent'] = $this->inserted_comments[ $new_comment['jskit_parent_guid'] ];
$this->insert_comment( $new_comment );
} else {
$this->orphan_comments[ $new_comment['jskit_guid'] ] = $new_comment;
}
// try to process orphan comments if we've moved on to a new post ID
if ( count( $this->orphan_comments ) && $new_comment['comment_post_ID'] <> $last_post_id )
$this->process_orphan_comments();
$last_post_id = $new_comment['comment_post_ID'];
}
// Attempt to match previously unpaired comments with their parents
function process_orphan_comments( $force = FALSE ) {
if( $force ) {
if ( count( $this->orphan_comments ) )
echo '' . sprintf( _n( 'Processing %s orphan.' , 'Processing %s orphans.', count( $this->orphan_comments ), 'echo-importer' ) , count( $this->orphan_comments ) ) . '.';
else
return;
}
ksort( $this->orphan_comments );
while( $this->orphan_comments ) {
foreach( $this->orphan_comments as $comment ){
if( $this->comment_exists( array( 'jskit_guid' => $comment['jskit_parent_guid'] ) ) || $force ) {
$comment['comment_parent'] = $this->inserted_comments[ $comment['jskit_parent_guid'] ];
$this->insert_comment( $comment );
unset( $this->orphan_comments[ $comment['jskit_guid'] ] );
}
}
// detect a loop condition when a comment's parent can't be found
if( count( $this->orphan_comments ) == $last_count )
return;
$last_count = count( $this->orphan_comments );
}
}
// Insert comment into database
function insert_comment( $comment ) {
if ( ! $this->comment_exists( $comment ) ) {
unset( $comment['comment_id'] );
$comment = wp_filter_comment( $comment );
$this->inserted_comments[ $comment['jskit_guid'] ] = wp_insert_comment( $comment );
update_comment_meta( $this->inserted_comments[ $comment['jskit_guid'] ], 'jskit_guid' , $comment['jskit_guid'], TRUE );
$this->post_ids_processed[ $comment['comment_post_ID'] ]++;
$this->num_comments++;
echo ''. sprintf( __( 'Imported comment by %s on %s.', 'echo-importer') , esc_html( stripslashes( $comment['comment_author'] ) ) , get_the_title( $comment['comment_post_ID'] ) ) . "\n";
} else {
$this->num_duplicates++;
echo '' . __( 'Skipped duplicate comment.', 'echo-importer' ) . "\n";
}
}
// Does this comment already exist in the database?
function comment_exists( $comment ) {
global $wpdb;
// must have jskit_guid
if( !isset( $comment['jskit_guid'] ) )
return FALSE;
// edge case: we've been given a comment_id because the comment was received through the Echo WP plugin
// still, the comment_id may not be correct, so confirm the time is close (because the servers' clocks may not be sync'd)
if ( isset( $comment['comment_id'] ) ) {
if( $local_comment_date_gmt = $wpdb->get_var( $wpdb->prepare( "SELECT comment_date_gmt FROM $wpdb->comments
WHERE comment_id = %s", (int) $comment['comment_id'] ) )
&& 2880 < absint( strtotime( $comment['comment_date_gmt'] ) - strtotime( $local_comment_date_gmt ) ) ) {
update_comment_meta( $comment_id, 'jskit_guid' , $comment['jskit_guid'], TRUE );
$this->inserted_comments[ $comment['jskit_guid'] ] = $comment['comment_id'];
return $comment['comment_id'];
}
}
// look for jskit_guids in the processed comment list (meaning comment parent has just been imported)
if( isset( $this->inserted_comments[ $comment['jskit_guid'] ] ) )
return $this->inserted_comments[ $comment['jskit_guid'] ];
// look for jskit_guids in the commentmeta (meaning the comment parent was previously imported)
if( ( $comment_id = $wpdb->get_var( $wpdb->prepare( "SELECT comment_id FROM $wpdb->commentmeta WHERE meta_key = 'jskit_guid' AND meta_value = %s", $comment['jskit_guid'] ) ) ) && $comment_id > 0 ) {
$this->inserted_comments[ $comment['jskit_guid'] ] = $comment_id;
return $comment_id;
}
// finally, try to match the comment using WP's comment_exists() rules
// unfortunately, we need the comment_id, not comment_post_ID, so we can't use the built-in
// add a jskit_guid to the comment if it matches
if( isset( $comment['comment_author'] , $comment['comment_date'] ) ) {
$comment_author = stripslashes( $comment['comment_author'] );
$comment_date = stripslashes( $comment['comment_date'] );
$comment_id = $wpdb->get_var( $wpdb->prepare( "SELECT comment_id FROM $wpdb->comments WHERE comment_author = %s AND comment_date = %s", $comment_author, $comment_date ) );
update_comment_meta( $comment_id, 'jskit_guid' , $comment['jskit_guid'], TRUE );
$this->inserted_comments[ $comment['jskit_guid'] ] = $comment_id;
return $comment_id;
}
return FALSE;
}
// Runs before import
function import_start() {
wp_defer_comment_counting( true );
do_action( 'import_start' );
}
// Runs after import
function import_end() {
do_action( 'import_end' );
// clear the caches after backfilling
foreach ( $this->post_ids_processed as $post_id )
clean_post_cache( $post_id );
wp_defer_comment_counting( false );
}
// Kicks off the import process
function import( $id ) {
$this->id = (int) $id;
$file = get_attached_file( $this->id );
$this->import_file( $file );
}
// Drives the import process
function import_file( $file ) {
$this->file = $file;
$this->import_start();
wp_suspend_cache_invalidation(true);
$this->get_entries();
$result = $this->process_comments();
wp_suspend_cache_invalidation(false);
$this->import_end();
if ( is_wp_error( $result ) )
return $result;
}
// handles the file upload
function handle_upload() {
$file = wp_import_handle_upload();
if ( isset($file['error']) ) {
echo '' . __( 'Sorry, there has been an error.', 'echo-importer' ) . '
';
echo '' . $file['error'] . '
';
return false;
}
$this->file = $file['file'];
$this->id = (int) $file['id'];
return true;
}
// Which page (step in the admin GUI) are we showing
function dispatch() {
if ( empty ($_GET['step'] ) )
$step = 0;
else
$step = (int) $_GET['step'];
$this->header();
switch ( $step ) {
case 0 :
$this->greet();
break;
case 1 :
check_admin_referer( 'import-upload' );
if ( $this->handle_upload() )
$this->check_upload();
break;
case 2:
check_admin_referer( 'import-echo' );
$result = $this->import( $_GET['id'] );
if ( is_wp_error( $result ) )
echo $result->get_error_message();
break;
}
$this->footer();
}
// Constructor - does nothing
function Echo_Import() {
}
}
/**
* Register Echo Importer
*
*/
$echo_import = new Echo_Import();
register_importer( 'echo', 'Echo Comments', __( 'Import comments from an Echo export file.', 'echo-importer' ), array ( $echo_import, 'dispatch' ) );
} // class_exists( 'WP_Importer' )
function echo_importer_init() {
load_plugin_textdomain( 'echo-importer', false, dirname( plugin_basename( __FILE__ ) ) . '/languages' );
}
add_action( 'init', 'echo_importer_init' );