Make WordPress Core

Ticket #7644: mt.diff

File mt.diff, 26.4 KB (added by cavemonkey50, 17 years ago)

The MT portion of the Atom importer.

  • mt-atom.php

     
     1<?php
     2
     3class MT_Atom_Import {
     4       
     5        // General
     6        var $username;
     7        var $password;
     8       
     9        // XML parsing
     10        var $parser;
     11        var $inside_tag = '';
     12        var $active_tag = '';
     13        var $entry_tag = '';
     14        var $last = '';
     15        var $start_byte = '';
     16        var $first_child = 0;
     17        var $inside_entry = 0;
     18        var $channel = array();
     19        var $items = array();
     20        var $item = array();
     21       
     22        // The data
     23        var $posts = array();
     24        var $site_url;
     25        var $xmlrpc_url;
     26        var $next_url;
     27        var $post_count = 0;
     28        var $current_post = 0;
     29        var $more_posts = true;
     30        var $first_run = true;
     31       
     32        function header() {
     33                echo '<div class="wrap">';
     34                echo '<h2>'.__('Import Movable Type').'</h2>';
     35        }
     36
     37        function footer() {
     38                echo '</div>';
     39        }
     40
     41        function greet() {
     42                $this->header();
     43?>
     44<div class="narrow">
     45<p><?php _e('Howdy! We&#8217;re about to begin importing all of your Movable Type entries into WordPress. To begin, enter the URL of your blog followed by the username and password of an administrator account. When you&#8217;re finished, click "Start Importing".'); ?></p>
     46<p><?php _e('<strong>Note:</strong> Use your web services password instead of your regular account password. To obtain this password, log in to your MT blog and follow these steps:'); ?></p>
     47<ol>
     48<li><?php _e('In the upper right, click Hi [username].'); ?></li>
     49<li><?php _e('Scroll down to the Preferences section.'); ?></li>
     50<li><?php _e('Under Web Services Password, click reveal.'); ?></li>
     51<li><?php _e('Enter the password displayed in the password box below.'); ?></li>
     52</ol>
     53
     54<form method="post" action="<?php echo add_query_arg('step', 1); ?>" class="import-upload-form">
     55
     56<?php wp_nonce_field('import-mt-atom'); ?>
     57<table class="form-table">
     58<tr>
     59<td><label for="mturl"><?php _e('Blog URL:') ?></label></td>
     60<td><input type="text" style="width:300px" name="mturl" id="mturl" value="http://" /></td>
     61</tr>
     62<tr>
     63<td><label for="mtuser"><?php _e('Username:') ?></label></td>
     64<td><input type="text" style="width:300px" name="mtuser" id="mtuser" value="" /></td>
     65</tr>
     66<tr>
     67<td><label for="mtpass"><?php _e("Password:") ?></label></td>
     68<td><input type="password" style="width:300px" name="mtpass" id="mtpass" value="" /></td>
     69</tr>
     70</table>
     71<p class="submit">
     72<input type="submit" value="<?php echo attribute_escape(__('Start Importing')); ?>" id="atom-submit" onclick="jQuery('#atom-loading').show();jQuery('#atom-submit').val('<?php echo attribute_escape(__('Importing...')); ?>');" /> <span style="display: none;" id="atom-loading"><img src="<?php echo get_option('home'); ?>/wp-admin/images/loading.gif" alt="Loading" style="margin-bottom: -3px;" /> <?php echo attribute_escape(__('Retrieving entries from server. Do not navigate away from this page.')); ?></span>
     73</p>
     74</form>
     75<p><?php _e('The importer is smart enough not to import duplicates, so you can run this multiple times without worry if&#8212;for whatever reason&#8212;it doesn\'t finish.'); ?> </p>
     76</div>
     77<?php
     78                $this->footer();
     79        }
     80               
     81        function detect_atom_uri($url) {
     82                // Set the RSD URL
     83                $rsd_url = $url . '/rsd.xml';
     84               
     85                // Grab the RSD page
     86                $ch2 = curl_init();
     87                curl_setopt($ch2, CURLOPT_URL, $rsd_url);
     88                curl_setopt($ch2, CURLOPT_RETURNTRANSFER, 1);
     89                curl_setopt($ch2, CURLOPT_TIMEOUT, 5);
     90                $output = @curl_exec($ch2);
     91               
     92                // Parse out the version number
     93                preg_match('#<engineName>([^"]*)</engineName>#i', $output, $version);
     94               
     95                // If the MT version is less than supported, report an error
     96                $ver = trim(strrchr($version[1], ' '));
     97                if ( $ver < '4.2' )
     98                        return 'version error';
     99               
     100                // Parse out the xmlrpc URI
     101                preg_match('#<api name="MovableType" preferred="false" apiLink="([^"]*)" blogid="([^"]*)" \/>#i', $output, $xmlrpc);
     102                $this->xmlrpc_url = $xmlrpc[1];
     103               
     104                // Parse out the Atom URI
     105                preg_match('#<api name="Atom" preferred="false" apiLink="([^"]*)" blogid="([^"]*)" \/>#i', $output, $matches);
     106               
     107                return $matches[1] . '/blog_id=' . $matches[2];
     108        }
     109       
     110        function fetch_atom($url, $username, $password) {
     111                include_once(ABSPATH . '/wp-admin/includes/class-atom-api.php');
     112               
     113                // If the MT blog is not a supported version
     114                        if ( $url == 'version error/offset=0/limit=20' ) {
     115                                $this->version_error();
     116                                return 'error';
     117                        }
     118               
     119               
     120                $atom_api = new AtomAPI($url, $username, $password, 'WSSE'); // Authenticate to the AtomPub feed using WSSE
     121               
     122                // If the login failed, throw an error message
     123                if ( ( $atom_api->err_no != '' ) && ( count($this->posts) == 0 ) ) {
     124                        $this->error();
     125                        return 'error';
     126                }
     127               
     128                 // Grab the raw feed data and pass it to the parser
     129                $this->parse_atom( $atom_api->get_feeds( $xml = false ) );
     130        }
     131       
     132        function parse_atom($xml) {
     133                // Reset the data before parsing a new feed
     134                unset($this->parser);
     135                unset($this->inside_tag);
     136                unset($this->active_tag);
     137                unset($this->channel);
     138                unset($this->items);
     139                unset($this->item);
     140                $this->inside_tag = '';
     141                $this->active_tag = '';
     142                $this->entry_tag = '';
     143                $this->last = '';
     144                $this->start_byte = '';
     145                $this->first_child = 0;
     146                $this->inside_entry = 0;
     147                $this->channel = array();
     148                $this->items = array();
     149                $this->item = array();
     150               
     151                // Create an XML parser
     152                $this->parser = xml_parser_create();
     153               
     154                // Used to make the XML parser work in a class
     155                xml_set_object($this->parser, $this);
     156               
     157                // Set the start and ending element functions           
     158                xml_set_element_handler($this->parser, "start_element", "end_element");
     159               
     160                // Set the character data functions
     161                xml_set_character_data_handler($this->parser, "character_data");
     162               
     163                // Begin parsing the XML
     164                xml_parse($this->parser, $xml)
     165                        or die(sprintf("XML error: %s at line %d", xml_error_string(xml_get_error_code($this->parser)), xml_get_current_line_number($this->parser)));
     166               
     167                // Clean up after the parse
     168                xml_parser_free($this->parser);
     169        }
     170       
     171        function start_element($parser, $element, $attrs) {
     172                switch ($element) {
     173                        case 'FEED':
     174                        case 'ENTRY':
     175                                $this->inside_tag = $element;
     176                                break;
     177
     178                        case 'CONTENT':
     179                        case 'SUMMARY':
     180                                if ( $this->inside_tag == 'ENTRY' ) {
     181                                        $this->inside_entry = 1;
     182                                        $this->entry_tag = strtolower($element);
     183                                }
     184                                break;
     185
     186                        case 'LINK' :
     187                                if ( $this->inside_tag == 'FEED' ) {
     188                                        if ( $attrs['REL'] == 'alternate' || !$attrs['REL'] ) {
     189                                                $this->_add('channel', 'link', $attrs['HREF']);
     190                                        } elseif ( $attrs['REL'] == 'next' ) {
     191                                                $this->_add('channel', 'next', $attrs['HREF']);
     192                                        }
     193                                } elseif ( $this->inside_tag == 'ENTRY' ) {
     194                                        if ( $attrs['REL'] == 'alternate' || !$attrs['REL'] ) {
     195                                                $this->_add('item', 'link', $attrs['HREF']);
     196                                        } elseif ( $attrs['REL'] == 'service.edit' ) {
     197                                                $this->_add('item', 'link:service.edit', $attrs['HREF']);
     198                                        } elseif ( $attrs['REL'] == 'replies' ) {
     199                                                $this->_add('item', 'link:replies', $attrs['HREF']);
     200                                        }
     201                                } elseif ( $this->inside_tag != 'FEED' && $this->inside_tag != 'ENTRY' ) {
     202                                        if ( $attrs['REL'] == 'next' ) {
     203                                                $this->_add('channel', 'next', $attrs['HREF']);
     204                                        }
     205                                }
     206                                break;
     207                       
     208                        case 'CATEGORY':
     209                                if ( $this->inside_tag == 'ENTRY' ) {
     210                                        $cats = array ( 'type' => $attrs['SCHEME'], 'term' => $attrs["TERM"] );
     211                                        $this->_add('item', 'categories', $cats, 1);
     212                                }
     213                                break;
     214                       
     215                        case 'AUTHOR':
     216                                if ( $this->inside_tag == 'ENTRY' ) {
     217                                        $this->inside_tag = 'ENTRY|AUTHOR';
     218                                }
     219                                break;
     220
     221                        default :
     222                                $this->active_tag = $element;
     223                }
     224               
     225                // Deal with tags inside of content and summary
     226                if ( $this->inside_entry && $element != 'CONTENT' && $element != 'SUMMARY' ) {
     227                        // If tags are inlined, then flatten
     228                        $attrs = array_change_key_case($attrs, CASE_LOWER);
     229                        $attrs_str = implode(' ',
     230                                array_map(array($this, 'map_attrs'),
     231                                array_keys($attrs),
     232                                array_values($attrs) ) );
     233                               
     234                        // Add a space if there are attrs
     235                        if ( $attrs_str != '' )
     236                                $attrs_str = ' ' . $attrs_str;
     237                       
     238                        // Make the element lowercase
     239                        $el = strtolower($element);
     240                       
     241                        // Close an opening tag if it had no data
     242                        if ( $this->first_child )
     243                                $this->_add('item', $this->entry_tag, ">");
     244                       
     245                        // Add the start tag
     246                        $this->_add('item', $this->entry_tag, "<$el" . "$attrs_str");
     247                       
     248                        // Handle self-closing tags
     249                        $this->first_child = 1;
     250                        $this->start_byte = xml_get_current_byte_index($parser);
     251                }
     252        }
     253       
     254        function character_data($parser, $cdata) {
     255                switch ($this->inside_tag) {
     256
     257                        // Grab general channel information
     258                        case 'FEED':
     259                                switch ($this->active_tag) {
     260                                        case 'TITLE':
     261                                                $this->_add('channel', strtolower($this->active_tag), $cdata);
     262                                                break;
     263                                        case 'FULLCOUNT':
     264                                                $this->_add('channel', strtolower($this->active_tag), $cdata);
     265                                                break;
     266                                }
     267                                break;
     268
     269                        // Grab item information
     270                        case 'ENTRY':
     271                                switch ($this->active_tag) {
     272                                        case 'TITLE':
     273                                                $this->_add('item', strtolower($this->active_tag), $cdata);
     274                                                break;
     275
     276                                        case 'CONTENT':
     277                                        case 'SUMMARY':
     278                                                $this->_add('item', $this->inside_tag, $cdata);
     279                                                break;
     280                                       
     281                                        case 'ISSUED':
     282                                                $this->_add('item', strtolower($this->active_tag), $cdata);
     283                                                break;
     284                                       
     285                                        case 'PUBLISHED':
     286                                                $this->_add('item', strtolower($this->active_tag), $cdata);
     287                                                break;
     288                                       
     289                                        case 'ID':
     290                                                $this->_add('item', strtolower($this->active_tag), $cdata);
     291                                                break;
     292                                }
     293                                break;
     294                       
     295                        // For author tags
     296                        case 'ENTRY|AUTHOR':
     297                                switch ($this->active_tag) {
     298                                        case 'NAME':
     299                                                $this->_add('item', 'author', $cdata);
     300                                                break;
     301                                        case 'URI':
     302                                                $this->_add('item', 'author_uri', $cdata);
     303                                                break;
     304                                        case 'EMAIL':
     305                                                $this->_add('item', 'author_email', $cdata);
     306                                                break;
     307                                }
     308                                break;
     309
     310                        }   
     311
     312                        // Deal with data inside content tags
     313                        if ( $this->inside_entry ) {
     314                                // Append the start tag close if first_child
     315                                if ( $this->first_child ) {
     316                                        $this->_add('item', $this->entry_tag, '>');
     317                                        $this->first_child = 0;
     318                                }
     319                               
     320                                $this->_add('item', $this->entry_tag, $cdata);
     321                        }
     322        }
     323       
     324        function end_element($parser, $element) {
     325                // Deal with tags inside of content and summary
     326                if ( $this->inside_entry && $element != 'CONTENT' && $element != 'SUMMARY' ) {
     327                        $el = strtolower($element);                     
     328                       
     329                        // Add the appropriate end tag depending if the element is a self-closing element
     330                        if ( xml_get_current_byte_index($parser) - $this->start_byte > 2 ) {
     331                                if ( $this->first_child )
     332                                        $this->_add('item', $this->entry_tag, ">");
     333                                $this->_add('item', $this->entry_tag, "</$el>");
     334                        } else {
     335                                $this->_add('item', $this->entry_tag, " />");
     336                        }
     337                        $this->first_child = 0;
     338                }
     339               
     340                // Reset inside tag back to entry for author tags
     341                if ( $element == 'AUTHOR' && $this->inside_tag == 'ENTRY|AUTHOR' ) {
     342                        $this->inside_tag = 'ENTRY';
     343                }
     344               
     345                if ( $element == $this->inside_tag ) {
     346                        $this->inside_tag = '';
     347                        $this->struct[] = array_merge(array('type' => strtolower($element)), $this->last);
     348                }
     349
     350                if ( $element == 'ENTRY' ) {
     351                        $this->items[] = $this->item;
     352                        $this->item = '';
     353                }
     354
     355                if ( $element == 'CONTENT' || $element == 'SUMMARY' ) {                 
     356                        $this->inside_entry = 0;
     357                }
     358
     359                $this->active_tag = '';
     360        }
     361       
     362        function _add($type, $field, $value, $array = 0) {
     363                if ( $array ) {
     364                        $this->{$type}[$field][] = $value;
     365                } else {               
     366                        if ( empty($this->{$type}) || empty($this->{$type}[$field]) ) {
     367                                $this->{$type}[$field] = $value;
     368                        } else {
     369                                $this->{$type}[$field] .= $value;
     370                        }
     371                }
     372
     373                $this->last = $this->{$type};
     374        }
     375       
     376        function map_attrs($k, $v) {
     377                return "$k=\"$v\"";
     378        }
     379       
     380        function get_entries() {
     381                // Set the URL
     382                if ( $this->next_url != '' )
     383                        $url = $this->detect_atom_uri(trim($_POST['mturl'])) . '/offset=' . $this->next_url . '/limit=20';
     384                else
     385                        $url = $this->detect_atom_uri(trim($_POST['mturl'])) . '/offset=0/limit=20';
     386       
     387                // Get the entries from the atom feed
     388                $result = $this->fetch_atom($url, $this->username, $this->password);
     389                if ( $result == 'error' ) return $result;
     390       
     391                // Set the site URL and next URLs
     392                $this->site_url = $this->channel['link'];
     393                $this->next_url = $this->next_url + 20;
     394        //      $this->post_count = $this->channel['fullcount'];
     395               
     396                // Convert the parsed atom feed to the posts / pages array
     397                foreach ( $this->items AS $item ) {                     
     398                        $this->posts[] = $item;
     399                }
     400        }
     401       
     402        function get_comments($comment_feed) {
     403                $comments = array();
     404               
     405                // While there are more comments
     406                do {
     407               
     408                        // Select the right comments feed URL
     409                        if ( $comments_next != '' )
     410                                $comment_uri = $comment_feed . '/offset=' . $comments_next . '/limit=20';       
     411                        else
     412                                $comment_uri = $comment_feed . '/offset=0/limit=20';
     413               
     414                        // Get the comments from the atom feed
     415                        if ( !empty($comment_uri) )
     416                                $this->fetch_atom($comment_uri, $this->username, $this->password);
     417                       
     418                        // Convert the parsed atom feed to the comments array
     419                        foreach ( $this->items AS $item ) {                     
     420                                $comments[] = $item;
     421                        }
     422                       
     423                        $comments_next = $comments_next + 20;
     424                        $more_comments = ( count($this->items) > 0 ) ? true : false;
     425               
     426                } while ( $more_comments );
     427               
     428                return $comments;
     429        }
     430       
     431        function get_additional_data($post_id) {
     432                include_once(ABSPATH . WPINC . '/class-IXR.php');
     433               
     434                $rpc = new IXR_Client($this->xmlrpc_url);
     435                if ( !$rpc->query('metaWeblog.getPost', $post_id, $this->username, $this->password) ) {
     436                //      print("Error (" . $rpc->getErrorCode() . "): ");
     437                //      print($rpc->getErrorMessage() . "\n\n");
     438                }
     439               
     440                return $rpc->getResponse();
     441        }
     442       
     443        function get_trackbacks($post_id) {
     444                include_once(ABSPATH . WPINC . '/class-IXR.php');
     445               
     446                $rpc = new IXR_Client($this->xmlrpc_url);
     447                if ( !$rpc->query('mt.getTrackbackPings', $post_id) ) {
     448                //      print("Error (" . $rpc->getErrorCode() . "): ");
     449                //      print($rpc->getErrorMessage() . "\n\n");
     450                }
     451               
     452                return $rpc->getResponse();
     453        }
     454       
     455        function check_draft($url) {
     456                $ch = curl_init();
     457                curl_setopt($ch, CURLOPT_URL, $url);
     458                curl_setopt($ch, CURLOPT_HEADER, 1);
     459                curl_setopt($ch, CURLOPT_NOBODY, 1);
     460                curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
     461                curl_setopt($ch, CURLOPT_TIMEOUT, 5);
     462                $output = @curl_exec($ch);
     463                $response = @curl_getinfo($ch, CURLINFO_HTTP_CODE);
     464               
     465                // If 404 assume this a draft
     466                if ( $response == '404' )
     467                        return 'draft';
     468                else
     469                        return 'publish';
     470        }
     471       
     472        function process_posts() {
     473                // Start the output list if this is the first run
     474                if ( $this->first_run == true ) {
     475                        echo '<div class="wrap"><ol>';
     476                        $this->first_run = false;
     477                }
     478               
     479                // Use output buffering to show the current import progress
     480                if (ob_get_level() == 0) {
     481                    ob_start();
     482                }
     483                // Pad the page with some data so output buffering works across browsers
     484                echo str_pad('',4096);
     485               
     486                foreach ( $this->posts AS $entry ) {
     487                       
     488                        // Construct the post class from the AtomPub feed
     489                        $post = new StdClass();
     490
     491                        // The entry type (over 1 and we have a post)
     492                        if ( count(explode('/', substr($entry['link'], strlen($this->site_url)))) > 1 )
     493                                $post->post_type = 'post';
     494                        else
     495                                $post->post_type = 'page';
     496                        // The entry title
     497                        if ( isset($entry['title']) )
     498                                $post->post_title = trim($entry['title']);
     499                        else
     500                                $post->post_title = '';
     501                        // The post content
     502                        if ( isset($entry['content']) )
     503                                $post->post_content = trim($entry['content']);
     504                        // The post excerpt
     505                        if ( isset($entry['summary']) )
     506                                $post->post_excerpt = trim($entry['summary']);
     507                        // The post date
     508                        $date = strtotime(trim($entry['issued']));
     509                        $date = date('Y-m-d H:i:s', $date);
     510                        $date_gmt = get_gmt_from_date($date);
     511                        $post->post_modified = $date;
     512                        $post->post_modified_gmt = $date_gmt;
     513                        $post->post_date = $date;
     514                        $post->post_date_gmt = $date_gmt;
     515                        // The post slug
     516                        $slug = array_reverse(explode('/', trim($entry['link'])));
     517                        $slug = substr($slug[0], 0 , -5);
     518                        $post->post_name = $slug;
     519                        // The categories and tags
     520                        if ( isset($entry['categories']) ) {
     521                                foreach ( $entry['categories'] AS $cat ) {
     522                                        $post->categories[] = trim($cat['term']);
     523                                        $post_keywords = '';
     524                                }
     525                        } else {
     526                                $post->categories = array();
     527                                $post->post_keywords = '';
     528                        }
     529                        // The post author
     530                        if ( isset($entry['author']) )
     531                                $post->post_author = trim($entry['author']);                   
     532                        // The post id
     533                        $post_id = trim($entry['id']);
     534                        $post_id = substr(strrchr($post_id, '.'), 1);
     535                        // The additional data
     536                        $additional_data = $this->get_additional_data($post_id);
     537                        // The comment status
     538                        if ( $additional_data['mt_allow_comments'] == 1 )
     539                                $post->comment_status = 'open';
     540                        else
     541                                $post->comment_status = 'closed';
     542                        if ( $additional_data['mt_allow_pings'] == 1 )
     543                                $post->ping_status = 'open';
     544                        else
     545                                $post->ping_status = 'closed';
     546                        // The tags
     547                        $post->post_keywords = $additional_data['mt_tags'];
     548                        // The draft status
     549                        $post->post_status = $this->check_draft(trim($entry['link']));
     550                       
     551                        // Set the post count if we weren't able to determine it earlier. Asssume the current ID count is the number of posts
     552                        if ( $this->post_count == '' )
     553                                $this->post_count = $post_id;
     554                       
     555                        unset($comments);
     556                        $comments = array();
     557                       
     558                        // Fetch the comments if the post has comments
     559                        $coms = $this->get_comments(trim($entry['link:replies']));
     560                                               
     561                        if ( count($coms) > 0 ) {
     562                                foreach ( $coms AS $com ) {
     563                                        // Construct the comment class from the AtomPub feed
     564                                        $comment = new StdClass();
     565                       
     566                                        // The comment date
     567                                        $date = strtotime(trim($com['published']));
     568                                        $date = date('Y-m-d H:i:s', $date);
     569                                        $comment->comment_date = $date;
     570                                        // The comment content
     571                                        $comment->comment_content = trim($com['content']);
     572                                        // The comment author
     573                                        $comment->comment_author = trim($com['author']);
     574                                        // The comment author uri
     575                                        $comment->comment_author_url = trim($com['author_uri']);
     576                                        // The comment author email
     577                                        $comment->comment_author_email = trim($com['author_email']);
     578                                        // Set the unknown variables
     579                                        $comment->comment_author_IP = '';
     580                       
     581                                        // Add the comment to the comments array
     582                                        $comments[] = $comment;
     583                                }
     584                        }
     585                       
     586                        unset($trackbacks);
     587                        $pings = array();
     588                       
     589                        // Fetch the trackbacks
     590                        $trackbacks = $this->get_trackbacks($post_id);
     591                        if ( count($trackbacks) > 0 ) {
     592                                foreach ( $trackbacks AS $trackback ) {
     593                                        $ping = new StdClass();
     594                                        // The ping date (the date of the post since we don't know the real one)
     595                                        $ping->comment_date = $post->post_date;
     596                                        // The ping IP address
     597                                        $ping->comment_author_IP = $trackback['pingIP'];
     598                                        // The ping URL
     599                                        $ping->comment_author_url = $trackback['pingURL'];
     600                                        // The ping author
     601                                        $ping->comment_author = $trackback['pingTitle'];
     602                                        // Set the unknow variables
     603                                        $ping->comment_author_email = '';
     604                                        $ping->comment_content = '';
     605                                        $ping->comment_type = 'pingback';
     606                               
     607                                        // Add the ping to the pings array
     608                                        $pings[] = $ping;
     609                                }
     610                        }
     611                       
     612                        $result = $this->save_post($post, $comments, $pings);
     613                        if ( is_wp_error( $result ) )
     614                                return $result;
     615                       
     616                        // Increase the post count
     617                        $this->current_post++;
     618                       
     619                        // Update the progress bar
     620                        $progress_bar = round(( $this->current_post / $this->post_count ) * 500);
     621                        $progress_percent = round(( $this->current_post / $this->post_count ) * 100, 1);
     622?>
     623<script type="text/javascript">
     624        jQuery('.progress_bar .progress_display').animate({
     625                width: "<?php echo $progress_bar; ?>px"
     626        }, 200);
     627        jQuery('.progress_percent span.percent').html('<?php echo $progress_percent; ?>');
     628        <?php if ( $progress_percent == 100 ) { ?>
     629                jQuery('.progress_percent img').hide();
     630        <?php } ?>
     631</script>
     632<?php
     633                       
     634                        // Flush the output buffer to show current state
     635                        ob_flush();
     636                        flush();
     637                        usleep(50000);
     638                }
     639               
     640                // Clean up after using the output buffer
     641                ob_end_flush();
     642               
     643                // If there are no more posts end the list tags
     644                if ( $this->more_posts == false ) {
     645                       
     646                        // Update the progress bar
     647                        $progress_bar = 500;
     648                        $progress_percent = 100;
     649?>
     650<script type="text/javascript">
     651        jQuery('.progress_bar .progress_display').animate({
     652                width: "<?php echo $progress_bar; ?>px"
     653        }, 200);
     654        jQuery('.progress_percent span.percent').html('<?php echo $progress_percent; ?>');
     655        <?php if ( $progress_percent == 100 ) { ?>
     656                jQuery('.progress_percent img').hide();
     657        <?php } ?>
     658</script>
     659<?php
     660                       
     661                        echo '</ol>';           
     662                        do_action('import_done', 'mt-atom');           
     663                        echo '<h3>'.sprintf(__('All done. <a href="%s">Have fun!</a>'), get_option('home')).'</h3></div>';
     664                }
     665        }
     666       
     667        function save_post(&$post, &$comments, &$pings) {
     668                $post = get_object_vars($post);
     669                $post = add_magic_quotes($post);
     670                $post = (object) $post;
     671               
     672                if ( $post_id = post_exists($post->post_title, '', $post->post_date) ) {
     673                        echo '<li>';
     674                        printf(__('Post <em>%s</em> already exists.'), stripslashes($post->post_title));
     675                } else {
     676                        echo '<li>';
     677                        printf(__('Importing post <em>%s</em>...'), stripslashes($post->post_title));
     678                       
     679                        $post->post_author = $this->check_author($post->post_author); //just so that if a post already exists, new users are not created by checkauthor
     680                        $post_id = wp_insert_post($post);
     681                        if ( is_wp_error( $post_id ) )
     682                                return $post_id;
     683               
     684                        // Add categories.
     685                        if ( 0 != count($post->categories) ) {
     686                                wp_create_categories($post->categories, $post_id);
     687                        }
     688                       
     689                        // Add tags or keywords
     690                        if ( 1 < strlen($post->post_keywords) ) {
     691                                // Keywords exist.
     692                                printf(__('<br />Adding tags <i>%s</i>...'), stripslashes($post->post_keywords));
     693                                wp_add_post_tags($post_id, $post->post_keywords);
     694                        }
     695                       
     696                        $num_comments = 0;
     697                        foreach ( $comments as $comment ) {
     698                                $comment = get_object_vars($comment);
     699                                $comment = add_magic_quotes($comment);
     700
     701                                if ( !comment_exists($comment['comment_author'], $comment['comment_date'])) {
     702                                        $comment['comment_post_ID'] = $post_id;
     703                                        $comment = wp_filter_comment($comment);
     704                                        wp_insert_comment($comment);
     705                                        $num_comments++;
     706                                }
     707                        }
     708
     709                        if ( $num_comments )
     710                                printf(' '.__ngettext('(%s comment)', '(%s comments)', $num_comments), $num_comments);
     711                       
     712                        $num_pings = 0;
     713                        foreach ( $pings as $ping ) {
     714                                $ping = get_object_vars($ping);
     715                                $ping = add_magic_quotes($ping);
     716
     717                                if ( !comment_exists($ping['comment_author'], $ping['comment_date'])) {
     718                                        $ping['comment_content'] = "<strong>{$ping['comment_author']}</strong>";
     719                                        $ping['comment_post_ID'] = $post_id;
     720                                        $ping = wp_filter_comment($ping);
     721                                        wp_insert_comment($ping);
     722                                        $num_pings++;
     723                                }
     724                        }
     725
     726                        if ( $num_pings )
     727                                printf(' '.__ngettext('(%s ping)', '(%s pings)', $num_pings), $num_pings);
     728                }
     729               
     730                echo '</li>';
     731        }
     732       
     733        function check_author($author) {
     734                global $wpdb;
     735               
     736                $user_id = username_exists($author);
     737               
     738                // If the username does not exist
     739                if ( !$user_id ) {
     740                        $pass = wp_generate_password();
     741                        $user_id = wp_create_user($author, $pass);
     742                }
     743               
     744                return $user_id;
     745        }
     746       
     747        function error() {
     748?>
     749                <div class="narrow">
     750                        <h3><?php _e('Import Failed'); ?></h3>
     751                        <p><?php _e('There was an error starting the import process. Please go back and verify that the URL, username, and password were entered correctly.'); ?></p>
     752                        <p><a href="<?php echo add_query_arg('step', 0); ?>"><?php _e('Restart the Import Process &raquo;')?></a></p>
     753                </div>
     754<?php
     755        }
     756
     757                function version_error() {
     758        ?>
     759                        <div class="narrow">
     760                                <h3><?php _e('Older Movable Type Version Detected'); ?></h3>
     761                                <p><?php _e('The importer has detected you are running an older version of Movable Type. To use this importer you must be running version 4.2 or higher. No worries; just use the Movable Type file-based importer.') ?></p>
     762                                <p><a href="?import=mt"><?php _e('Restart the Import Process Using the File Importer &raquo;')?></a></p>
     763                        </div>
     764        <?php
     765                }
     766       
     767        function import() {
     768                $this->header();
     769               
     770                // Add the username and password as a global
     771                $this->username = $_POST['mtuser'];
     772                $this->password = $_POST['mtpass'];
     773               
     774                // Use output buffering so the progress bar appears immediately
     775                if (ob_get_level() == 0) {
     776                    ob_start();
     777                }
     778               
     779                // Pad the page with some data so output buffering works across browsers
     780                echo str_pad('',4096);
     781               
     782?>
     783<h3><?php _e('Import in Progress, Results Will Appear Momentarily'); ?></h3>
     784
     785<p><?php _e('While the importer is running do not navigate away from this page.'); ?></p>
     786
     787<div class="progress_bar" style="float:left; width: 500px; height; 20px; padding: 1px; border: 1px solid #dadada;">
     788        <div class="progress_display" style="width: 0px; background: #ccc">&nbsp;</div>
     789</div>
     790<div class="progress_percent" style="padding: 2px;">&nbsp;<img src="<?php echo get_option('home'); ?>/wp-admin/images/loading.gif" alt="Loading" style="margin-bottom: -3px;" />&nbsp;<span class="percent">0</span>%</div>
     791<?php
     792               
     793                // Clear the output buffer
     794                ob_flush();
     795                flush();
     796                ob_end_flush();
     797               
     798                // While we have more posts
     799                do {
     800               
     801                        $result = $this->get_entries();
     802                       
     803                        $this->more_posts = ( count($this->posts) > 0 ) ? true : false;
     804               
     805                        if ( $result != 'error' )               
     806                                $result = $this->process_posts();
     807               
     808                        if ( is_wp_error( $result ) )
     809                                echo $result->get_error_message();
     810                       
     811                        // Free memory for next round of post
     812                        unset($this->posts);
     813                        $this->posts = array();
     814                               
     815                } while ( $this->more_posts );
     816               
     817                $this->footer();
     818        }
     819       
     820        function dispatch() {
     821                if (empty ($_GET['step']))
     822                        $step = 0;
     823                else
     824                        $step = (int) $_GET['step'];
     825
     826                switch ($step) {
     827                        case 0 :
     828                                $this->greet();
     829                                break;
     830                        case 1 :
     831                                check_admin_referer('import-mt-atom');
     832                                $this->import();
     833                                break;
     834                }
     835        }
     836
     837        function MT_Atom_Import() {
     838                // Nothing.
     839        }
     840}
     841
     842$mt_atom_import = new MT_Atom_Import();
     843
     844register_importer('mt-atom', __('Movable Type - Web'), __('Import posts and comments from a Movable Type blog with only your login credentials.'), array ($mt_atom_import, 'dispatch'));
     845?>
     846 No newline at end of file
  • mt.php

     
    478478
    479479$mt_import = new MT_Import();
    480480
    481 register_importer('mt', __('Movable Type and TypePad'), __('Import posts and comments from a Movable Type or Typepad blog.'), array ($mt_import, 'dispatch'));
     481register_importer('mt', __('Movable Type and TypePad - File'), __('Import posts and comments from a Movable Type or TypePad blog using the file export option.'), array ($mt_import, 'dispatch'));
    482482?>