$welcome
"; - echo "" . __('Please note that this importer does not work with Blogger (using your Google account).') . "
"; - if ( function_exists('curl_init') ) - echo ""; - else - echo "$incompat
"; - echo "\n"; + $next_url = get_option('siteurl') . '/wp-admin/index.php?import=blogger&noheader=true'; + $auth_url = "https://www.google.com/accounts/AuthSubRequest"; + $title = __('Import Blogger'); + $welcome = __('Howdy! This importer allows you to import posts and comments from your Blogger account into your WordPress blog.'); + $prereqs = __('To use this importer, you must have a Google account, an upgraded (New, was Beta) blog, and it must be on blogspot or a custom domain (not FTP).'); + $stepone = __('The first thing you need to do is tell Blogger to let WordPress access your account. You will be sent back here after providing authorization.'); + $auth = __('Authorize'); + + echo " +$welcome
$prereqs
$stepone
+ +$message
$info
'.print_r($this,1).''; + $start = js_escape( __('Import') ); + $continue = js_escape( __('Continue') ); + $stop = js_escape( __('Importing...') ); + $authors = js_escape( __('Set Authors') ); + $loadauth = js_escape( __('Preparing author mapping form...') ); + $authhead = js_escape( __('Final Step: Author Mapping') ); + $nothing = js_escape( __('Nothing was imported. Had you already imported this blog?') ); + $title = __('Blogger Blogs'); + $name = __('Blog Name'); + $url = __('Blog URL'); + $action = __('The Magic Button'); + $posts = __('Posts'); + $comments = __('Comments'); + $noscript = __('This feature requires Javascript but it seems to be disabled. Please enable Javascript and then reload this page. Don\'t worry, you can turn it back off when you\'re done.'); + + $interval = STATUS_INTERVAL * 1000; + + foreach ( $this->blogs as $i => $blog ) { + if ( $blog['mode'] == 'init' ) + $value = $start; + elseif ( $blog['mode'] == 'posts' || $blog['mode'] == 'comments' ) + $value = $continue; + else + $value = $authors; + $blogtitle = js_escape( $blog['title'] ); + $pdone = isset($blog['posts_done']) ? (int) $blog['posts_done'] : 0; + $cdone = isset($blog['comments_done']) ? (int) $blog['comments_done'] : 0; + $init .= "blogs[$i]=new blog($i,'$blogtitle','{$blog['mode']}'," . $this->get_js_status($i) . ');'; + $pstat = "
| $name | $url | $posts | $comments | $action | \n$rows
.*
#U', $response['body'], $matches); - $progress = $matches[0]; - die($head . $progress); - } else { - $this->import['blogs'][$_GET['blog']]['publish'][$i] = false; - update_option('import-blogger', $this->import); - die($head); - } - } else { - // Subsequent call. Keep checking status until Blogger reports publish complete. - $url = $this->import['blogs'][$_GET['blog']]['publish'][$i]; - $response = $this->get_blogger($url, $this->import['cookies']); - if ( preg_match('#.*
#U', $response['body'], $matches) ) { - $progress = $matches[0]; - if ( strstr($progress, '100%') ) { - $this->set_next_step($i); - $progress .= ''.__('Moving on...').'
'; + + $total_results = $this->get_total_results( 'comments', $blog['host'] ); + $this->blogs[$importing_blog]['total_comments'] = $total_results; + + if ( isset( $this->blogs[$importing_blog]['comments_start_index'] ) ) + $start_index = (int) $this->blogs[$importing_blog]['comments_start_index']; + elseif ( $total_results > MAX_RESULTS ) + $start_index = $total_results - MAX_RESULTS + 1; + else + $start_index = 1; + + if ( $start_index > 0 ) { + // Grab all the comments + $this->blogs[$importing_blog]['mode'] = 'comments'; + $query = "start-index=$start_index&max-results=" . MAX_RESULTS; + do { + $index = $struct = $entries = array(); + $headers = array( + "GET /feeds/comments/default?$query HTTP/1.0", + "Host: {$blog['host']}", + "Authorization: AuthSub token=\"$this->token\"" + ); + $request = join( "\r\n", $headers ) . "\r\n\r\n"; + $sock = $this->_get_blogger_sock( $blog['host'] ); + if ( ! $sock ) return; // TODO: Error handling + $response = $this->_txrx( $sock, $request ); + + $response = $this->parse_response( $response ); + + // Extract the comments and send for insertion + preg_match_all( '/" . __('Trying again...') . '
'); - } + + // Get the 'previous' query string which we'll use on the next iteration + $query = ''; + $links = preg_match_all('/'.__('Are you looking for %title%? It is temporarily out of service. Please try again in a few minutes. Meanwhile, discover a better blogging tool.').'
' . addslashes(print_r($headers, 1)) . addslashes(print_r($response, 1)) . ''); - $this->import['blogs'][$_GET['blog']]['url'] = 'http://' . $optary['modify']['subdomain'] . '.blogspot.com/'; - sleep(2); - } else { - $this->import['blogs'][$_GET['blog']]['url'] = 'http://' . $_POST['subdomain'] . '.blogspot.com/'; - update_option('import-blogger', $this->import); - $output .= "
$blog_opt
'.__('Error on form submission. Retry or reset the importer.').'
' . addslashes(print_r($response, 1))); - } - $output .= "$blog_opt
$blog_opt
'.sprintf(__('%s in progress, please wait...'), $blog_opt)."
\n"; - } else { - $output.= "$blog_opt
\n"; + function import_comment( $entry ) { + global $importing_blog; + + // Drop the #fragment and we have the comment's old post permalink. + foreach ( $entry->links as $link ) { + if ( $link['rel'] == 'alternate' ) { + $parts = parse_url( $link['href'] ); + $entry->old_permalink = $parts['fragment']; + $entry->old_post_permalink = $parts['path']; + break; } } - if ( $form ) - die($output . $form); - $this->set_next_step(4); - $this->do_next_step(); - } + $comment_post_ID = (int) $this->blogs[$importing_blog]['posts'][$entry->old_post_permalink]; + preg_match('#$directions
$archivename $status
\n"; - } - if ( ! $did_one ) - $this->set_next_step(7); - die( $this->refresher(1000) . $output ); - } - - // Step 7: Restore the backed-up settings to Blogger - function restore_settings() { - $output = '$blog_opt
\n"; - } elseif ( $optary['restored'] || ! $optary['modify'] ) { - $output .= "$blog_opt
'.__('Please tell the devs.').'
' . addslashes(print_r($response, 1)) ); - } - } - if ( $optary['backup'] != $optary['modify'] ) { - $response = $this->post_blogger($posturl, $headers, $optary['backup']); - if ( $response['code'] >= 400 || strstr($response['body'], 'There are errors on this form') ) { - $this->import['blogs'][$_GET['blog']]['options']["$blog_opt"]['error'] = true; - update_option('import-blogger', $this->import); - $output .= sprintf(__('%s failed. Trying again.'), "$blog_opt ").'
'; - } else { - $this->import['blogs'][$_GET['blog']]['options']["$blog_opt"]['restored'] = true; - update_option('import-blogger', $this->import); - $output .= sprintf(__('%s restored.'), "$blog_opt ").'
'; - } - } - $did_one = true; - } + $this->save_vars(); + + wp_redirect('edit.php'); + } + + function _get_auth_sock() { + // Connect to https://www.google.com + if ( !$sock = @ fsockopen('ssl://www.google.com', 443, $errno, $errstr) ) { + $this->uh_oh( + __('Could not connect to https://www.google.com'), + __('There was a problem opening a secure connection to Google. This is what went wrong:'), + "$errstr ($errno)" + ); + return false; } + return $sock; + } - if ( $did_one ) { - die( $this->refresher(1000) . $output ); - } elseif ( $this->import['blogs'][$_GET['blog']]['options']['blog-publishing']['backup']['publishMode'] > 0 ) { - $this->set_next_step(9); - } else { - $this->set_next_step(8); + function _get_blogger_sock($host = 'www2.blogger.com') { + if ( !$sock = @ fsockopen($host, 80, $errno, $errstr) ) { + $this->uh_oh( + sprintf( __('Could not connect to %s'), $host ), + __('There was a problem opening a connection to Blogger. This is what went wrong:'), + "$errstr ($errno)" + ); + return false; } + return $sock; + } - $this->do_next_step(); + function _txrx( $sock, $request ) { + fwrite( $sock, $request ); + while ( ! feof( $sock ) ) + $response .= @ fread ( $sock, 8192 ); + fclose( $sock ); + return $response; } - // Step 8: Republish, all back to normal - function republish_blog() { - $this->publish_blogger(9, __('Publishing with original template and options')); + function revoke($token) { + $headers = array( + "GET /accounts/AuthSubRevokeToken HTTP/1.0", + "Authorization: AuthSub token=\"$token\"" + ); + $request = join( "\r\n", $headers ) . "\r\n\r\n"; + $sock = $this->_get_auth_sock( ); + if ( ! $sock ) return false; + $this->_txrx( $sock, $request ); + } + + function restart() { + global $wpdb; + $options = get_option( 'blogger_importer' ); + + if ( isset( $options['token'] ) ) + $this->revoke( $options['token'] ); + + delete_option('blogger_importer'); + $wpdb->query("DELETE FROM $wpdb->postmeta WHERE meta_key = 'blogger_author'"); + wp_redirect('?import=blogger'); + } + + // Returns associative array of code, header, cookies, body. Based on code from php.net. + function parse_response($this_response) { + // Split response into header and body sections + list($response_headers, $response_body) = explode("\r\n\r\n", $this_response, 2); + $response_header_lines = explode("\r\n", $response_headers); + + // First line of headers is the HTTP response code + $http_response_line = array_shift($response_header_lines); + if(preg_match('@^HTTP/[0-9]\.[0-9] ([0-9]{3})@',$http_response_line, $matches)) { $response_code = $matches[1]; } + + // put the rest of the headers in an array + $response_header_array = array(); + foreach($response_header_lines as $header_line) { + list($header,$value) = explode(': ', $header_line, 2); + $response_header_array[$header] .= $value."\n"; + } + + $cookie_array = array(); + $cookies = explode("\n", $response_header_array["Set-Cookie"]); + foreach($cookies as $this_cookie) { array_push($cookie_array, "Cookie: ".$this_cookie); } + + return array("code" => $response_code, "header" => $response_header_array, "cookies" => $cookie_array, "body" => $response_body); } // Step 9: Congratulate the user function congrats() { + $blog = (int) $_GET['blog']; echo ''.__('Now that you have imported your Blogger blog into WordPress, what are you going to do? Here are some suggestions:').'
$message
'.print_r($this->import,1).'do_login();
- break;
- case 1 :
- $this->select_blog();
- break;
- case 2 :
- $this->backup_settings();
- break;
- case 3 :
- $this->wait_for_blogger();
- break;
- case 4 :
- $this->publish_blog();
- break;
- case 5 :
- $this->get_archive_urls();
- break;
- case 6 :
- $this->get_archive();
- break;
- case 7 :
- $this->restore_settings();
- break;
- case 8 :
- $this->republish_blog();
- break;
- case 9 :
- $this->congrats();
- break;
+ $attrs_str = join(' ', array_map($this->map_attrs_func, array_keys($attrs_prefix), array_values($attrs_prefix)));
+ if(strlen($attrs_str) > 0) {
+ $attrs_str = " " . $attrs_str;
}
- die;
- } else {
- $this->greet();
+ $xmlns_str = join(' ', array_map($this->map_xmlns_func, array_keys($this->ns_contexts[0]), array_values($this->ns_contexts[0])));
+ if(strlen($xmlns_str) > 0) {
+ $xmlns_str = " " . $xmlns_str;
+ }
+
+ // handle self-closing tags (case: a new child found right-away, no text node)
+ if(count($this->in_content) == 2) {
+ array_push($this->in_content, ">");
+ }
+
+ array_push($this->in_content, "<". $this->ns_to_prefix($name) ."{$xmlns_str}{$attrs_str}");
+ } else if(in_array($tag, $this->ATOM_CONTENT_ELEMENTS) || in_array($tag, $this->ATOM_SIMPLE_ELEMENTS)) {
+ $this->in_content = array();
+ $this->is_xhtml = $attrs['type'] == 'xhtml';
+ array_push($this->in_content, array($tag,$this->depth));
+ } else if($tag == 'link') {
+ array_push($this->entry->links, $attrs);
+ } else if($tag == 'category') {
+ array_push($this->entry->categories, $attrs['term']);
+ }
+
+ $this->ns_decls = array();
+ }
+
+ function end_element($parser, $name) {
+
+ $tag = array_pop(split(":", $name));
+
+ if(!empty($this->in_content)) {
+ if($this->in_content[0][0] == $tag &&
+ $this->in_content[0][1] == $this->depth) {
+ array_shift($this->in_content);
+ if($this->is_xhtml) {
+ $this->in_content = array_slice($this->in_content, 2, count($this->in_content)-3);
+ }
+ $this->entry->$tag = join('',$this->in_content);
+ $this->in_content = array();
+ } else {
+ $endtag = $this->ns_to_prefix($name);
+ if (strpos($this->in_content[count($this->in_content)-1], '<' . $endtag) !== false) {
+ array_push($this->in_content, "/>");
+ } else {
+ array_push($this->in_content, "");
+ }
+ }
}
+
+ array_shift($this->ns_contexts);
+
+ #print str_repeat(" ", $this->depth * $this->indent) . "end_element('$name')" ."\n";
+
+ $this->depth--;
}
- function Blogger_Import() {
- // This space intentionally left blank.
+ function start_ns($parser, $prefix, $uri) {
+ #print str_repeat(" ", $this->depth * $this->indent) . "starting: " . $prefix . ":" . $uri . "\n";
+ array_push($this->ns_decls, array($prefix,$uri));
}
-}
-$blogger_import = new Blogger_Import();
+ function end_ns($parser, $prefix) {
+ #print str_repeat(" ", $this->depth * $this->indent) . "ending: #" . $prefix . "#\n";
+ }
-register_importer('blogger', __('Old Blogger'), __('Import posts and comments from your Old Blogger account'), array ($blogger_import, 'start'));
+ function cdata($parser, $data) {
+ #print str_repeat(" ", $this->depth * $this->indent) . "data: #" . $data . "#\n";
+ if(!empty($this->in_content)) {
+ // handle self-closing tags (case: text node found, need to close element started)
+ if (strpos($this->in_content[count($this->in_content)-1], '<') !== false) {
+ array_push($this->in_content, ">");
+ }
+ array_push($this->in_content, $this->xml_escape($data));
+ }
+ }
+
+ function _default($parser, $data) {
+ # when does this gets called?
+ }
+
+
+ function ns_to_prefix($qname) {
+ $components = split(":", $qname);
+ $name = array_pop($components);
+
+ if(!empty($components)) {
+ $ns = join(":",$components);
+ foreach($this->ns_contexts as $context) {
+ foreach($context as $mapping) {
+ if($mapping[1] == $ns && strlen($mapping[0]) > 0) {
+ return "$mapping[0]:$name";
+ }
+ }
+ }
+ }
+ return $name;
+ }
+
+ function xml_escape($string)
+ {
+ return str_replace(array('&','"',"'",'<','>'),
+ array('&','"',''','<','>'),
+ $string );
+ }
+}
?>