boincimport_posts_op()

Complexity

Conditions	17
Paths	322

Size

Total Lines	181
Code Lines	97

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
function boincimport_posts_op($offset, $batch_size, &$context) {
  // Initialize the batch, if needed
  if (!isset($context['sandbox']['progress'])) {
    $context['sandbox']['progress'] = 0;
    $context['sandbox']['max'] = $batch_size;
  }

  $input_format = variable_get('boincimport_input_format', 0);

 // Get the topics with posts to import
  db_set_active('boinc_rw');
  $boinc_topic_ids = db_query('
    SELECT DISTINCT t.id FROM %sthread t
    JOIN %sforum f ON f.id = t.forum
    JOIN %spost p ON p.thread = t.id
    WHERE f.parent_type = 0
    ORDER BY t.id
    LIMIT %d,%d',
    $pre, $pre, $pre, $offset, $batch_size

The variable $pre seems to be never defined.

  );
  db_set_active('default');

  while ($boinc_topic = db_fetch_object($boinc_topic_ids)) {
    // Get the posts in this topic
    db_set_active('boinc_rw');
    $boinc_posts = db_query('
      SELECT id, user, thread, timestamp, content, parent_post, hidden
      FROM %spost WHERE thread = %d ORDER BY id ASC', $pre, $boinc_topic->id);
    db_set_active('default');

    $first_post = true;
    $topic_has_responses = FALSE;
    $success = FALSE;
    $posts_imported = 0;
    $empty_posts = 0;
    $error_posts = 0;
    $duplicate_posts = 0;

    while ($post = db_fetch_object($boinc_posts)) {

      // Skip the first post as it has already been imported as a topic
      if ($first_post) {
        $first_post = false;
        continue;
      }

      // Making it this far confirms that there are posts to import
      $topic_has_responses = TRUE;

      $is_duplicate = db_result(db_query('
        SELECT COUNT(*) FROM {boincimport_temp_post}
        WHERE post_id = %d',
        $post->id
      ));
      if ($is_duplicate) {
        // This post has already been imported
        $context['results']['posts']['duplicate'][] = $post->id;
        $duplicate_posts++;
        continue;
      }

      // Make sure the post is valid
      if ($post->content) {

        // Get user, node, and parent IDs for the post and sanitize
        $uid = boincuser_lookup_uid($post->user);
        $node = db_fetch_object(db_query('
          SELECT nr.nid, nr.title
          FROM {boincimport_temp_topic} btt
          LEFT JOIN {node_revisions} AS nr ON btt.nid = nr.nid
          WHERE btt.topic_id = %d',
          $post->thread
        ));
        $nid = $node->nid;
        $pid = db_result(db_query('
          SELECT cid
          FROM {boincimport_temp_post}
          WHERE post_id = %d',
          $post->parent_post));
        if (is_null($pid)) $pid = 0;
        if (!$uid) $uid = 0;

        $post->content = _boincimport_strip_bbcode($post->content);
        $post->content = _boincimport_text_sanitize($post->content);

        $topic_reply = db_result(db_query('
          SELECT COUNT(*)
          FROM {comments}
          WHERE nid = %d',
          $nid
        ));
        $post_reply = $pid;

        if ($post_reply OR $topic_reply) {
          // Create a subject for the post from the post content. The body may be in
          // any format, so we:
          //  1) Filter it into HTML
          //  2) Strip out all HTML tags
          //  3) Convert entities back to plain-text.
          // Note: format is checked by check_markup().
          $subject = truncate_utf8(trim(decode_entities(strip_tags(check_markup($post->content, $input_format)))), 29, TRUE);
          // Replace "Quote:" with "RE:"
          $subject = str_replace('Quote:', 'RE: ', $subject);
          // Fringe cases where the comment body is populated only by HTML tags
          // will require a default subject...
          if ($subject === '')
            $subject = "RE: {$node->title}";
        } else {
          // This is the first post in the topic
          $subject = $node->title;
        }

        // Construct the post as a Drupal comment
        $comment = array(
          'pid' => $pid,
          'nid' => $nid,
          'uid' => $uid,
          'subject' => $subject,
          'comment' => $post->content,
          'timestamp' => $post->timestamp,
          'status' => $post->hidden,
          'format' => $input_format
        );

        // Save the comment
        if (boincimport_forum_comment_save($comment)) {
          $success = db_query('
            INSERT INTO {boincimport_temp_post} (post_id, cid)
            VALUES (%d, %d)',
            $post->id, $comment['cid']
          );
          if ($success) {
            $posts_imported++;
            $context['results']['posts']['success'][] = $post->id;
          }
          else {
            $context['results']['posts']['failure'][] = $post->id;
            $error_posts++;
          }
        }
        else {
          $context['results']['posts']['failure'][] = $post->id;
          $error_posts++;
        }
      }
      else {
        $context['results']['posts']['empty'][] = $post->id;
        $empty_posts++;
      }
    }

    $message = '';
    if ($success OR !$topic_has_responses) {
      // Store some result for post-processing in the finished callback.
      $context['results']['success'][] = $boinc_topic->id;
      $message = "Imported {$posts_imported} post(s) for topic {$boinc_topic->id}";
    }
    else {
      $context['results']['failure'][] = $boinc_topic->id;
      $message = "Failed to import any posts for topic {$boinc_topic->id} (excluded {$error_posts} errors, {$duplicate_posts} duplicates, and {$empty_posts} empty)";
      watchdog('boincimport', 'Failed to import any posts for topic @id (excluded @error_posts errors, @duplicate_posts duplicates, and @empty_posts empty)',
        array(
          '@id' => $boinc_topic->id,
          '@error_posts' => $error_posts,
          '@duplicate_posts' => $duplicate_posts,
          '@empty_posts' => $empty_posts,
        ), WATCHDOG_WARNING
      );
    }

    // Update our progress information.
    $context['sandbox']['progress']++;
    $context['sandbox']['current_topic'] = $boinc_topic->id;
    $context['message'] = $message;

    // Update the progress for the batch engine
    if ($context['sandbox']['progress'] >= $context['sandbox']['max']) {
      $context['finished'] = 1;
    }
    else {
      $context['finished'] = $context['sandbox']['progress'] / $context['sandbox']['max'];
    }