Skip to content

Instantly share code, notes, and snippets.

@bradgessler

bradgessler/posterous-importer.php

Created July 27, 2012 00:01
Download ZIP

Revisions

  1. bradgessler created this gist Jul 27, 2012.
    1,007 changes: 1,007 additions & 0 deletions posterous-importer.php
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,1007 @@
    <?php
    /*
    Plugin Name: Posterous Importer
    Plugin URI: http://wordpress.org/extend/plugins/posterous-importer/
    Description: Import posts, comments, tags, and attachments from a Posterous.com blog.
    Author: Automattic, Brian Colinger, Peter Westwood, Daryl L. L. Houston
    Author URI: http://automattic.com/
    Version: 0.10
    License: GPL v2 - http://www.gnu.org/licenses/old-licenses/gpl-2.0.html
    */

    if ( !defined('WP_LOAD_IMPORTERS') )
    return;

    // Load Importer API
    require_once ABSPATH . 'wp-admin/includes/import.php';

    if ( !class_exists( 'WP_Importer' ) ) {
    $class_wp_importer = ABSPATH . 'wp-admin/includes/class-wp-importer.php';
    if ( file_exists( $class_wp_importer ) )
    require_once $class_wp_importer;
    }
    /**
    * Posterous Importer
    *
    * @package WordPress
    * @subpackage Importer
    */
    if ( class_exists( 'WP_Importer' ) ) {
    class Posterous_Import extends WP_Importer {
    var $blog_id = 0;
    var $user_id = 0;
    var $hostname;
    var $sites;
    var $sites_id;
    var $auth = false;
    var $username = '';
    var $password = '';
    var $bid = '';
    var $permalinks = array();
    var $comments = array();
    var $attachments = array();
    var $url_remap = array();
    var $have_posts = true;


    /**
    * Constructor
    *
    * @return void
    */
    function __construct() {
    parent::__construct();
    add_action( 'process_attachment', array( &$this, 'process_attachment' ), 10, 3 );
    add_action( 'posterous_handle_bad_response', array( &$this, 'handle_bad_response' ), 10, 2 );

    if ( isset( $_GET['import'] ) && 'posterous' == $_GET['import'] ) {
    add_action( 'admin_enqueue_scripts', array( &$this, 'admin_enqueue_scripts' ) );
    add_action( 'admin_head', array ( &$this, 'admin_head' ) );
    }
    }

    /**
    * PHP 4 Constructor
    *
    * @return void
    */
    function Posterous_Import(){
    $this->__construct();
    }

    /**
    * Strip out protocol, check for proper domain.
    *
    * @param string $hostname
    * @return string
    */
    function sanitize_hostname( $hostname ) {
    $hostname = str_replace( array( 'http://', 'https://' ), '', trim( stripslashes( strtolower( $hostname ) ) ) );
    if ( !strstr( $hostname, '.posterous.com' ) )
    $hostname = $hostname . '.posterous.com';
    return $hostname;
    }

    /**
    * Import calls each step of the process
    *
    * @return void
    */
    function import() {
    if ( !defined( 'WP_IMPORTING' ) )
    define( 'WP_IMPORTING', true );
    do_action( 'import_start' );
    // Set time limit after import_start to avoid the 900 second limit
    set_time_limit( 0 );
    $this->sites = $this->get_sites();
    // Sleep after fetching sites because Posterous doesn't like if you do more than one request in a second.
    usleep( 1100000 );
    $this->permalinks = $this->get_imported_posts( 'posterous', $this->bid );
    $this->comments = $this->get_imported_comments();
    $this->attachments = $this->get_imported_attachments( 'posterous', $this->bid );
    $this->do_posts();
    $this->process_attachments();
    $this->cleanup();
    }

    function get_sites() {
    $url = 'http://posterous.com/api/getsites';
    $data = $this->get_page( $url, $this->username, $this->password );
    if ( is_wp_error( $data ) ) {
    echo "Error:\n" . $data->get_error_message() . "\n";
    return;
    }

    $code = (int) $data['response']['code'];
    if ( 200 !== $code ) {
    printf( "<em>%s</em><br />\n", __( 'Got HTTP code' ) . ' ' . $code . ' ' . __( 'from' ) . ' ' . $url );
    exit();
    }

    $xml = simplexml_load_string( $data['body'] );
    if ( !$xml ) {
    printf( __METHOD__ . ": <em>%s</em><br />\n", __( 'Error loading XML' ) );
    exit();
    }

    $subdomain = substr( $this->hostname, 0, strpos( $this->hostname, '.posterous.com' ) );
    foreach ( $xml->site as $site ) {
    // Compare the subdomain to the hostname from Posterous.
    if ( $subdomain == (string) $site->hostname ) {
    $this->site_id = (int) $site->id;
    break;
    }
    }
    }

    /**
    * Loop over each feed and process posts
    *
    * @return void
    */
    function do_posts() {
    $page = 1;
    do {
    $url = 'http://posterous.com/api/readposts';
    $url = add_query_arg( 'site_id', $this->site_id, $url );
    $url = add_query_arg( 'num_posts', 10, $url );
    $url = add_query_arg( 'page', $page, $url );
    $this->process_posts( $url );
    $page++;
    // Sleep after fetching sites because Posterous doesn't like if you do more than one request in a second.
    usleep( 1100000 );
    } while ( true === $this->have_posts );
    }

    /**
    * Print an error if we didn't get a 200 response from the Posterous API.
    * @param array $data The data our API request fetched, in case we want to do more with it.
    * @return void
    */
    function handle_bad_response( $data, $code ) {
    printf( "<em>%s</em><br />\n", __( 'Got HTTP code' ) . ' ' . $code . ' ' . __( 'from' ) . ' ' . $url );
    exit();
    }

    /**
    * Extract XML from URL and import as posts
    *
    * @param string $url
    * @return void
    */
    function process_posts( $url ) {
    $data = $this->get_page( $url, $this->username, $this->password );
    if ( is_wp_error( $data ) ) {
    echo "Error:\n" . $data->get_error_message() . "\n";
    return;
    }

    $code = (int) $data['response']['code'];
    if ( 200 !== $code ) {
    do_action( 'posterous_handle_bad_response', $data, $code );
    }

    $body = $data['body'];
    $xml = @simplexml_load_string( $body );
    if ( !$xml ) {
    printf( __METHOD__ . ": <em>%s</em><br />\n", __( 'Error loading XML' ) );
    $this->have_posts = false;
    return;
    }

    // If posts is empty, we're done here, move along
    if ( empty( $xml->post ) ) {
    $this->have_posts = false;
    return;
    }

    foreach ( $xml->post as $entry ) {
    $entry->title = (string) $entry->title;
    $permalink = (string) $entry->link;
    $commentscount = (int) $entry->commentsCount;
    $parsed_url = parse_url($permalink);
    $slug = trim($parsed_url["path"], "/"); // Remove leading / from the path.

    if ( isset( $this->permalinks[$permalink] ) ) {
    printf( "<em>%s</em><br />\n", __( 'Skipping' ) . ' ' . $entry->title );
    // process_comments here to check for any new comments or ones that we missed
    printf( "\t<em>%s</em><br />\n", __( 'Found Comments:' ) . ' ' . $commentscount );
    if ( $commentscount > 0 )
    $this->process_comments( $this->permalinks[$permalink], $entry->comment );
    continue;
    }

    $post = array();
    $post['post_title'] = (string) $entry->title;
    $post['post_date'] = gmdate( "Y-m-d H:i:s", strtotime( (string) $entry->date ) );
    $post['post_content'] = (string) $entry->body;
    $post['post_name'] = (string) $slug;

    printf( "\t<em>%s</em><br />\n", __( 'Slug:' ) . ' ' . $post['post_name'] );

    $post['post_status'] = 'publish';
    if ( 'true' == (string) $entry->private )
    $post['post_status'] = 'private';

    $post_id = wp_insert_post( $post );

    if ( is_wp_error( $post_id ) ) {
    printf( __('Error: %s') . "\n", htmlspecialchars( $post_id->get_error_message() ) );
    continue;
    }

    add_post_meta( $post_id, 'posterous_' . $this->bid . '_post_id', (int) $entry->id, true );
    add_post_meta( $post_id, 'posterous_' . $this->bid . '_permalink', $permalink, true );

    // Check to see if we have audio or video files and add relevant data to postmeta for later use if so.
    if ( isset( $entry->media ) ) {
    $media = array();

    foreach ( $entry->media as $m ) {
    if ( in_array( (string) $m->type, array( 'audio', 'video' ) ) ) {
    $file = new stdClass();
    $file->type = (string) $m->type;
    $file->url = (string) $m->url;
    $file->filesize = (string) $m->filesize;
    $file->thumb = (string) $m->thumb;
    $media[] = $file;
    }
    }
    if ( 0 < count( $media ) )
    add_post_meta( $post_id, 'posterous_' . $this->bid . '_media', $media, true );
    }

    printf( "<em>%s</em><br />\n", __( 'Importing' ) . ' ' . $entry->title );
    $this->permalinks[$permalink] = $post_id;

    $tags = $this->get_tags( $entry );
    if ( !empty( $tags ) )
    printf( "\t<em>%s</em><br />\n", __( 'Found tags:' ) . ' ' . implode( ', ', $tags ) );
    $this->add_post_tags( $post_id, $tags );

    printf( "\t<em>%s</em><br />\n", __( 'Found Comments:' ) . ' ' . $commentscount );
    if ( $commentscount > 0 )
    $this->process_comments( $post_id, $entry->comment );
    }
    }

    /**
    * Extract XML from URL, find and import comments
    *
    * @param string $url
    * @return array
    */
    function process_comments( $post_id, $comments ) {
    foreach ( $comments as $comment ) {
    $author = (string) $comment->author;
    $date = gmdate( "Y-m-d H:i:s", strtotime( (string) $comment->date ) );
    $import_comment_hash = md5( $author . $date );
    // Skip existing comments
    if ( isset( $this->comments[$import_comment_hash] ) )
    continue;

    $body = (string) $comment->body;

    $comment_post_ID = $post_id;
    $comment_author = $author;
    $comment_date = $date;
    $comment_content = addslashes( trim( strip_tags( $body ) ) );
    $comment = compact( 'comment_post_ID', 'comment_author', 'comment_author_url', 'comment_date', 'comment_content' );
    $comment = wp_filter_comment( $comment );
    $comment_id = (int) wp_insert_comment( $comment );

    $meta_key = 'posterous_' . $this->bid . '_comment_id';
    add_comment_meta( $comment_id, $meta_key, $import_comment_hash, true );
    }

    return $comments;
    }

    /**
    * Add tags to post
    *
    * @param int $post_id
    * @param array $tags
    * @return void
    */
    function add_post_tags( $post_id, $tags ) {
    if ( empty( $tags ) )
    return;
    global $wpdb;
    $post_tags = array();
    foreach ( $tags as $tag ) {
    $slug = sanitize_term_field( 'slug', $tag, 0, 'post_tag', 'db' );
    $tag_obj = get_term_by( 'slug', $slug, 'post_tag' );
    $tag_id = 0;
    if ( !empty( $tag_obj ) )
    $tag_id = $tag_obj->term_id;
    if ( $tag_id == 0 ) {
    $tag = $wpdb->escape( $tag );
    $tag_id = wp_insert_term( $tag, 'post_tag' );
    if ( is_wp_error( $tag_id ) )
    continue;
    $tag_id = $tag_id['term_id'];
    }
    $post_tags[] = (int) $tag_id;
    }
    if ( empty( $post_tags ) )
    return;
    wp_set_post_tags( $post_id, $post_tags );
    }

    /**
    * Get tags from post
    *
    * @param object $entry
    * @return array
    */
    function get_tags( $entry ) {
    $tags = array();
    if ( isset( $entry->tag ) ) {
    foreach ( $entry->tag as $tag ) {
    $tags[] = (string) $tag;
    }
    }

    return array_unique( $tags );
    }

    /**
    * Scan all posts for attachments
    *
    * @return void
    */
    function process_attachments() {
    if ( empty( $this->permalinks ) )
    return;

    // Loop over each post ID
    foreach ( $this->permalinks as $permalink => $post_id ) {
    // Get post data
    $post = get_post( $post_id );
    $media = get_post_meta( $post_id, 'posterous_' . $this->bid . '_media' );

    printf( "<em>%s</em>", __( 'Checking' ) . " '$post->post_title' " . __( 'for images...' ) );
    $attachments = $this->extract_post_media( $post->post_content, $media );
    printf( "<em>%s</em><br />\n", ' ' . sizeof( $attachments['fullsize'] ) + sizeof( $attachments['single'] ) . ' ' . __( 'images found' ) );

    // Process attachments
    if ( !empty( $attachments['fullsize'] ) ) {
    do_action( 'process_attachment', $post, $attachments['fullsize'], $attachments['thumb'] );
    }

    if ( !empty( $attachments['single'] ) ) {
    do_action( 'process_attachment', $post, $attachments['single'], $attachments['single'] );
    }

    unset( $post, $attachments );

    $this->stop_the_insanity();
    }
    }

    /**
    * Import and processes each attachment
    *
    * @param object $post
    * @param array $fullsizes
    * @param array $thumbs
    * @return void
    */
    function process_attachment( $post, $fullsizes, $thumbs ) {

    // Add media files from postmeta to the $fullsizes array for fetching.
    $media_types = array();
    $media = get_post_meta( $post->ID, 'posterous_' . $this->bid . '_media', true );
    if ( is_array( $media ) ) {
    foreach ( $media as $m ) {
    $fullsizes[] = $m->url;
    $media_types[$m->url] = $m->type;
    }
    }

    if ( empty( $fullsizes ) )
    return;

    foreach ( $fullsizes as $id => $fullsize ) {
    if( $this->is_user_over_quota() )
    return false;

    $thumb = $thumbs[$id];

    // Skip duplicates
    if ( isset( $this->attachments[$fullsize] ) ) {
    $post_id = $this->attachments[$fullsize];
    printf( "<em>%s</em><br />\n", __( 'Skipping duplicate' ) . ' ' . $fullsize );
    // Get new attachment URL
    $attachment_url = wp_get_attachment_url( $post_id );

    // Update url_remap array
    $this->url_remap[$fullsize] = $attachment_url;
    $sized = image_downsize( $post_id, 'medium' );
    if ( isset( $sized[0] ) ) {
    $this->url_remap[$thumb] = $sized[0];
    }

    continue;
    }

    echo '<em>Importing attachment ' . htmlspecialchars( $fullsize ) . "...</em>";
    $upload = $this->fetch_remote_file( $post, $fullsize );

    if ( is_wp_error( $upload ) ) {
    printf( "<em>%s</em><br />\n", __( 'Remote file error:' ) . ' ' . htmlspecialchars( $upload->get_error_message() ) );
    continue;
    } else {
    printf( "<em> (%s)</em><br />\n", size_format( filesize( $upload['file'] ) ) );
    }

    if ( 0 == filesize( $upload['file'] ) ) {
    print __( "Zero length file, deleting..." ) . "<br />\n";
    @unlink( $upload['file'] );
    continue;
    }

    $info = wp_check_filetype( $upload['file'] );
    if ( false === $info['ext'] ) {
    printf( "<em>%s</em><br />\n", $upload['file'] . __( 'has an invalid file type') );
    @unlink( $upload['file'] );
    continue;
    }

    // as per wp-admin/includes/upload.php
    $attachment = array (
    'post_title' => $post->post_title,
    'post_content' => '',
    'post_status' => 'inherit',
    'guid' => $upload['url'],
    'post_mime_type' => $info['type']
    );

    $post_id = (int) wp_insert_attachment( $attachment, $upload['file'], $post->ID );
    $attachment_meta = @wp_generate_attachment_metadata( $post_id, $upload['file'] );
    wp_update_attachment_metadata( $post_id, $attachment_meta );

    // Fire an action to do anything we might like to do to the post after adding an attachment (e.g. inserting shortcodes).
    // This is not implemented within the plugin; it's just here so that it can be extended.
    do_action( 'posterous_process_attachment_post_update', $post, $post_id, $fullsize, $media_types );

    // Add remote_url to post_meta
    add_post_meta( $post_id, 'posterous_' . $this->bid . '_attachment', $fullsize, true );
    // Add remote_url to hash table
    $this->attachments[$fullsize] = $post_id;

    // Get new attachment URL
    $attachment_url = wp_get_attachment_url( $post_id );
    // Update url_remap array
    $this->url_remap[$fullsize] = $attachment_url;
    $sized = image_downsize( $post_id, 'medium' );
    if ( isset( $sized[0] ) ) {
    $this->url_remap[$thumb] = $sized[0];
    }
    }

    $this->backfill_attachment_urls( $post );
    }

    /**
    * Update url references in post bodies to point to the new local files
    *
    * @return void
    */
    function backfill_attachment_urls( $post = false ) {
    if ( false === $post )
    return;

    // make sure we do the longest urls first, in case one is a substring of another
    uksort( $this->url_remap, array( &$this, 'cmpr_strlen') );

    $from_urls = array_keys( $this->url_remap );
    $to_urls = array_values( $this->url_remap );

    $hash_1 = md5( $post->post_content );
    $post->post_content = str_replace( $from_urls, $to_urls, $post->post_content );
    $hash_2 = md5( $post->post_content );

    if ( $hash_1 !== $hash_2 )
    wp_update_post( $post );
    }

    /**
    * Download remote file, keep track of URL map
    *
    * @param object $post
    * @param string $url
    * @return array
    */
    function fetch_remote_file( $post, $url ) {
    // Increase the timeout
    add_filter( 'http_request_timeout', array( &$this, 'bump_request_timeout' ) );

    $parts = parse_url( $url );
    $filename = basename( $parts['path'] );

    // get placeholder file in the upload dir with a unique sanitized filename
    $upload = wp_upload_bits( $filename, 0, '', $post->post_date );
    if ( is_wp_error( $upload ) ) {
    return $upload;
    }

    if ( $upload['error'] ) {
    echo $upload['error'];
    return false;
    }

    // fetch the remote url and write it to the placeholder file
    $headers = wp_get_http( $url, $upload['file'] );

    // make sure the fetch was successful
    if ( $headers['response'] != '200' ) {
    @unlink( $upload['file'] );
    return new WP_Error( 'import_file_error', sprintf( __( 'Remote file returned error response %d' ), intval( $headers['response'] ) ) );
    }

    // keep track of the old and new urls so we can substitute them later
    $this->url_remap[$url] = $upload['url'];
    // if the remote url is redirected somewhere else, keep track of the destination too
    if ( isset( $headers['x-final-location'] ) && $headers['x-final-location'] != $url )
    $this->url_remap[$headers['x-final-location']] = $upload['url'];

    return apply_filters( 'wp_handle_upload', $upload );
    }

    /**
    * Return array of images from the post
    *
    * @param string $post_content
    * @return array
    */
    function extract_post_media( $post_content, $media ) {
    $post_content = stripslashes( $post_content );
    $post_content = str_replace( "\n", '', $post_content );
    $post_content = $this->min_whitespace( $post_content );
    $attachments = array();
    $attachments['thumb'] = array();
    $attachments['fullsize'] = array();
    $attachments['single'] = array();
    $attachments['audiovideo'] = array();

    // Find all linked images
    $matches = array();
    preg_match_all( '|<a.*?href=[\'"](.*?)[\'"].*?><img.*?src=[\'"](.*?)[\'"].*?>|i', $post_content, $matches );
    foreach ( $matches[1] as $i => $url ) {
    if ( strstr( $url, 'posterous.com' ) ) {
    $attachments['thumb'][$i] = $matches[2][$i];
    $attachments['fullsize'][$i] = $url;
    }
    }

    // Find all not linked images
    $matches = array();
    preg_match_all( '|<img.*?src=[\'"](.*?)[\'"].*?>|i', $post_content, $matches );
    foreach ( $matches[1] as $i => $url ) {
    if ( strstr( $url, 'posterous.com' ) && !in_array( $url, $attachments['thumb'] ) && !in_array( $url, $attachments['fullsize'] ) ) {
    $attachments['single'][$i] = $url;
    }
    }
    $attachments['single'] = array_unique( $attachments['single'] );

    // Find all linked mp3s and videos
    $matches = array();
    preg_match_all( '!href=(\'|")(http:\/\/[a-zA-Z0-9\-+%\&\?#\/\.]+\/files\.posterous\.com\/[a-zA-Z0-9\-+%_&\?#\/\.]+\.(mp3|m4v|mp4|mov|avi|wmv|3gv|3g2))(\'|")/!i', $post_content, $matches );
    if ( !empty( $matches[2] ) ) {
    foreach ( $matches[2] as $i => $url ) {
    $attachments['audiovideo'][$i] = $url;
    }
    }

    unset( $post_content, $matches );

    return $attachments;
    }

    /**
    * Set array with imported attachments from WordPress database
    *
    * @param string $importer_name
    * @param string $bid
    * @return array
    */
    function get_imported_attachments( $importer_name, $bid ) {
    global $wpdb;

    $hashtable = array ();

    // Get all attachments
    $sql = $wpdb->prepare( "SELECT post_id, meta_value FROM $wpdb->postmeta WHERE meta_key = '%s'", $importer_name . '_' . $bid . '_attachment' );
    $results = $wpdb->get_results( $sql );

    if (! empty( $results )) {
    foreach ( $results as $r ) {
    // Set permalinks into array
    $hashtable[$r->meta_value] = (int) $r->post_id;
    }
    }

    // unset to save memory
    unset( $results, $r );

    return $hashtable;
    }

    /**
    * Return hash table of imported comment_id's
    *
    * @return array
    */
    function get_imported_comments() {
    global $wpdb;

    $hashtable = array ();
    $limit = 100;
    $offset = 0;
    $meta_key = 'posterous_' . $this->bid . '_comment_id';

    // Grab all comments in chunks
    do {
    $sql = $wpdb->prepare ( "SELECT comment_id, meta_value FROM $wpdb->commentmeta WHERE meta_key LIKE '%s' LIMIT %d,%d", $meta_key, $offset, $limit );
    $results = $wpdb->get_results ( $sql );

    // Increment offset
    $offset = ($limit + $offset);

    if (! empty ( $results )) {
    foreach ( $results as $r ) {
    $hashtable [$r->meta_value] = (int) $r->comment_id;
    }
    }
    } while ( count ( $results ) == $limit );

    // unset to save memory
    unset ( $results, $r );
    return $hashtable;
    }

    /**
    * Extract page number from URL
    *
    * @param string $url
    * @return int
    */
    function get_page_number( $url ) {
    $path = parse_url( $url, PHP_URL_PATH );
    $parts = explode( '/', $path );
    $pos = ( sizeof( $parts ) - 2 );
    $num = $parts[$pos];
    if ( ! is_numeric( $num ) ) {
    return false;
    }

    return (int) $num;
    }

    /**
    * Check links object for rel= , return url or false
    *
    * @param object $links
    * @param string $rel
    * @return mixed
    */
    function get_link_by_rel( $links, $rel ) {
    foreach ( $links as $link ) {
    $attr = $link->attributes();
    $_rel = (string) $attr['rel'];
    $href = (string) $attr['href'];

    if ( $rel == $_rel ) {
    return $href;
    }
    }

    return false;
    }

    /**
    * Perform cleanup operations
    *
    * @return void
    */
    function cleanup() {
    delete_option( 'posterous_import' );
    do_action( 'import_done', 'posterous' );
    printf ( "<strong>%s</strong><br />\n", __( 'All Done!' ) );
    }

    // Enqueue the core js our js depends on
    function admin_enqueue_scripts() {
    wp_enqueue_script( 'jquery' );
    }

    function admin_head() {
    ?>
    <style type="text/css">
    #posterous_info label {
    display:inline;
    float:left;
    font-weight:bold;
    width:85px;
    }
    #auth_message {
    margin:10px;
    color:red;
    }
    #spinner {
    display:none;
    }
    </style>

    <script type="text/javascript">
    var $ = jQuery.noConflict();
    $( function() {
    var code = 0;
    $('#import_submit').click( function() {
    email_regex = /[\w_\.\+]+@[\w\.][\w\.]{2,}/;
    if ( !email_regex.test( $( '#username' ).val() ) ) {
    alert( '<?php echo esc_js( __( 'Please specify your Posterous account email address as the username.' ) ); ?>' );
    return false;
    }
    $('#import_submit').attr('value', 'Please Wait...');
    $('#import_submit').attr('disabled', 'disabled');
    $('#spinner').show();
    var dataString = $('#posterous_info').serialize();
    $.ajax({
    type: 'POST',
    url: 'admin.php?import=posterous&noheader=true&test_user_pass=true',
    data: dataString,
    success: function( data, status ) {
    code = data;
    //alert(code);
    if ( '401' == code ) {
    $('#spinner').hide();
    $('#auth_message').html("Please check your user name and password, Posterous says it's incorrect.");
    $('#import_submit').attr('value', 'Submit');
    $('#import_submit').removeAttr('disabled');

    return false;
    }

    if ( '200' == code ) {
    $.ajax({
    type: 'POST',
    url: 'admin.php?import=posterous&noheader=true&step=2',
    data: dataString,
    success: function( data, status ) {
    if ( 'ready' == data ) {
    window.location = 'admin.php?import=posterous&step=3';
    }
    }
    });

    return true;
    }

    }
    });
    });
    });
    </script>

    <script type="text/javascript">
    /*
    * jQuery doTimeout: Like setTimeout, but better! - v0.4 - 7/15/2009
    * http://benalman.com/projects/jquery-dotimeout-plugin/
    *
    * Copyright (c) 2009 "Cowboy" Ben Alman
    * Dual licensed under the MIT and GPL licenses.
    * http://benalman.com/about/license/
    */
    (function($){var a={},c="doTimeout",d=Array.prototype.slice;$[c]=function(){return b.apply(window,[0].concat(d.call(arguments)))};$.fn[c]=function(){var e=d.call(arguments),f=b.apply(this,[c+e[0]].concat(e));return typeof e[0]==="number"||typeof e[1]==="number"?this:f};function b(l){var m=this,h,k={},n=arguments,i=4,g=n[1],j=n[2],o=n[3];if(typeof g!=="string"){i--;g=l=0;j=n[1];o=n[2]}if(l){h=m.eq(0);h.data(l,k=h.data(l)||{})}else{if(g){k=a[g]||(a[g]={})}}k.id&&clearTimeout(k.id);delete k.id;function f(){if(l){h.removeData(l)}else{if(g){delete a[g]}}}function e(){k.id=setTimeout(function(){k.fn()},j)}if(o){k.fn=function(p){o.apply(m,d.call(n,i))&&!p?e():f()};e()}else{if(k.fn){j===undefined?f():k.fn(j===false);return true}else{f()}}}})(jQuery);
    </script>

    <script type="text/javascript">
    var $ = jQuery.noConflict();
    $( function() {
    $('#start_poll').hide();
    $('#stop_poll').hide();
    var elem = $('#polling_loop');
    $('#start_poll').click( function() {
    //$('#start_poll').hide();
    //$('#stop_poll').show();
    // Start a polling loop with an id of 'loop' and a counter.
    var i = 0;

    elem.doTimeout( 'loop', 3000, function() {
    $('#loop_count').html( ++i );
    var hostname = $('#hostname').val();
    if( $.trim( hostname ) == '') {
    return false;
    }

    var ajaxurl = 'admin.php?import=posterous&noheader=true&status=true&hostname=' + $('#hostname').val();
    $.getJSON( ajaxurl, function( data ) {
    var jo = eval( data );
    $('#posts_count').html( jo.posts );
    $('#comments_count').html( jo.comments );
    $('#attachments_count').html( jo.attachments );
    });

    return true;
    });
    });

    $('#stop_poll').click( function() {
    // Cancel the polling loop with id of 'loop'.
    elem.doTimeout( 'loop' );
    $('#start_poll').show();
    $('#stop_poll').hide();
    });

    $('#start_poll').click();
    });
    </script>

    <?php
    }

    function print_header() {
    echo "<div class='wrap'>\n";
    screen_icon();
    echo "<h2>" . __( 'Import Posterous' ) . "</h2>\n";
    }

    function print_footer() {
    echo "</div>\n";
    }

    function test_user_pass( $hostname, $username, $password ) {
    $hostname = $this->sanitize_hostname( $hostname );
    $username = strtolower( $username );

    $this->username = $username;
    $this->password = $password;
    $this->auth = true;
    $url = 'http://posterous.com/api/getsites';
    $data = $this->get_page( $url, $this->username, $this->password );
    if ( is_wp_error( $data ) ) {
    echo "Error:\n" . $data->get_error_message() . "\n";
    return;
    }

    $code = (int) $data['response']['code'];
    unset( $data );
    echo $code;
    }

    function step_1() {
    $action = add_query_arg( 'step', 2, $_SERVER['REQUEST_URI'] );
    $hostname = $this->sanitize_hostname( get_option( 'posterous_hostname' ) );
    $hostname = str_replace( '.posterous.com', '', $hostname );
    $username = get_option( 'posterous_username' );
    ?>

    <p><?php _e( 'Howdy! So, you want to import your Posterous blog? No problem, we just need a little information.' ); ?></p>
    <p><?php _e( 'Please enter your Posterous user name and password.' ); ?></p>
    <p><?php _e( 'WordPress will not permanently store your Posterous password. After the import is finished, your password will be deleted immediately.' ); ?></p>

    <form id="posterous_info" name="posterous_info" action="<?php echo esc_url( $action ); ?>" method="POST">
    <label><?php _e( 'Host name' ); ?></label> <input id="hostname" name="hostname" type="text" value="<?php echo esc_attr( $hostname ); ?>" /> .posterous.com<br />
    <label><?php _e( 'Email Address' ); ?></label> <input id="username" name="username" type="text" value="<?php echo esc_attr( $username ); ?>" /><br />
    <label><?php _e( 'Password' ); ?></label> <input id="password" name="password" type="password" value="" /><br />
    <input class="button" id="import_submit" name="import_submit" type="button" value="Submit" /> <img id="spinner" src="images/loading.gif" />
    <div id="auth_message"></div>
    </form>
    <hr />
    <?php

    }

    function step_2() {
    $hostname = $this->sanitize_hostname( $_POST['hostname'] );
    $hostname = str_replace( '.posterous.com', '', $hostname );
    update_option( 'posterous_hostname', $hostname );
    $username = trim( stripslashes( strtolower( $_POST['username'] ) ) );
    update_option( 'posterous_username', $username );
    $password = trim( stripslashes( $_POST['password'] ) );
    update_option( 'posterous_password', $password );

    $data = new stdClass();
    $data->hostname = $hostname;
    $data->username = $username;
    $data->password = $password;

    add_option( 'posterous_import', $data );
    echo 'ready';
    }

    function step_3() {
    global $blog_id, $current_user, $current_blog;

    $data = get_option( 'posterous_import' );
    if ( !is_object( $data ) )
    die();

    $this->hostname = $this->sanitize_hostname( $data->hostname );
    $this->bid = md5( $this->hostname );
    $this->username = $data->username;
    $this->password = $data->password;
    $this->auth = false;
    if ( !empty( $this->username ) && !empty( $this->password ) )
    $this->auth = true;

    $this->blog_id = $this->set_blog( $blog_id );
    $this->user_id = $this->set_user( $current_user->ID );

    $this->import();
    }

    function importer_status() {
    $hostname = $this->sanitize_hostname( get_option( 'posterous_hostname' ) );
    $status = $this->get_importer_status( $hostname, 'array' );
    ?>
    <div id="polling_loop">
    <div id="importer_status">
    <h2><?php _e( 'Importer Status' ); ?></h2>
    <input type="hidden" id="hostname" name="hostname" value="<?php echo $hostname; ?>" />
    <strong><?php _e( 'Posts:' ); ?></strong> <span id="posts_count"><?php echo $status['posts']; ?></span><br />
    <strong><?php _e( 'Comments:' ); ?></strong> <span id="comments_count"><?php echo $status['comments']; ?></span><br />
    <strong><?php _e( 'Attachments:' ); ?></strong> <span id="attachments_count"><?php echo $status['attachments']; ?></span><br />
    <p><input type="button" class="button" id="start_poll" name="start_poll" value="<?php _e( 'Check Status' ); ?>" /><input type="button" class="button" id="stop_poll" name="stop_poll" value="<?php _e( 'Stop Checking' ); ?>" /></p>
    </div>
    </div>
    <hr />
    <?php
    }

    function get_importer_status( $hostname, $return = 'json' ) {
    $this->hostname = $this->sanitize_hostname( $hostname );
    $this->bid = md5( $this->hostname );
    $this->permalinks = $this->get_imported_posts( 'posterous', $this->bid );
    $this->comments = $this->get_imported_comments();
    $this->attachments = $this->get_imported_attachments( 'posterous', $this->bid );

    $status = array();
    $status['posts'] = count( $this->permalinks );
    $status['comments'] = count( $this->comments );
    $status['attachments'] = count( $this->attachments );

    if ( 'json' == $return )
    return json_encode( $status );
    if ( 'array' == $return )
    return $status;
    }

    function dispatch() {
    // A hook to do anything we might like to do before proceeding. Not implemented but potentially useful for extending the plugin.
    do_action( 'posterous_pre_dispatch' );

    // Set step
    $step = isset( $_GET['step'] ) ? (int) $_GET['step'] : 1;

    if ( isset( $_GET['hostname'] ) && isset( $_GET['status'] ) )
    die( $this->get_importer_status( $_GET['hostname'] ) );

    if ( isset( $_GET['test_user_pass'] ) )
    die( $this->test_user_pass( $_POST['hostname'], $_POST['username'], $_POST['password'] ) );

    if ( 2 === $step )
    die( $this->step_2() );

    $this->print_header();

    if ( 1 === $step )
    $this->step_1();
    if ( 3 === $step )
    $this->step_3();

    $this->importer_status();

    // A hook to do anything we might like to do before printing the status. Not implemented but potentially useful for extending the plugin.
    do_action( 'posterous_after_status' );

    $this->print_footer();
    }
    }
    }

    $posterous = new Posterous_Import();
    register_importer( 'posterous', __( 'Posterous' ), __( 'Import posts, comments, tags, and attachments from a Posterous.com blog.' ), array( $posterous, 'dispatch' ) );