comment_save

• Drupal 4.6
• Drupal 4.7
• Drupal 5
• Drupal 6
• Drupal 7

Versions

4.6

comment_save($id, $edit)

4.7 – 6

comment_save($edit)

7

comment_save($comment)

Accepts a submission of new or changed comment content.

Parameters

$comment A comment object.

Code

modules/comment/comment.module, line 1256

<?php
function comment_save($comment) {
  global $user;

  $defaults =  array(
    'mail' => '',
    'homepage' => '',
    'name' => '',
    'status' => user_access('post comments without approval') ? COMMENT_PUBLISHED : COMMENT_NOT_PUBLISHED,
  );
  foreach ($defaults as $key => $default) {
    if (!isset($comment->$key)) {
      $comment->$key = $default;
    }
  }
  // Make sure we have a bundle name.
  if (!isset($comment->node_type)) {
    $node = node_load($comment->nid);
    $comment->node_type = 'comment_node_' . $node->type;
  }

  field_attach_presave('comment', $comment);

  // Allow modules to alter the comment before saving.
  module_invoke_all('comment_presave', $comment);

  if ($comment->cid) {
    // Update the comment in the database.
    db_update('comment')
      ->fields(array(
        'status' => $comment->status,
        'created' => $comment->created,
        'changed' => $comment->changed,
        'subject' => $comment->subject,
        'comment' => $comment->comment,
        'format' => $comment->comment_format,
        'uid' => $comment->uid,
        'name' => $comment->name,
        'mail' => $comment->mail,
        'homepage' => $comment->homepage,
        'language' => $comment->language,
      ))
      ->condition('cid', $comment->cid)
      ->execute();
    field_attach_update('comment', $comment);
    // Allow modules to respond to the updating of a comment.
    module_invoke_all('comment_update', $comment);
    // Add an entry to the watchdog log.
    watchdog('content', 'Comment: updated %subject.', array('%subject' => $comment->subject), WATCHDOG_NOTICE, l(t('view'), 'comment/' . $comment->cid, array('fragment' => 'comment-' . $comment->cid)));
  }
  else {
    // Add the comment to database. This next section builds the thread field.
    // Also see the documentation for comment_build().
    if ($comment->pid == 0) {
      // This is a comment with no parent comment (depth 0): we start
      // by retrieving the maximum thread level.
      $max = db_query('SELECT MAX(thread) FROM {comment} WHERE nid = :nid', array(':nid' => $comment->nid))->fetchField();
      // Strip the "/" from the end of the thread.
      $max = rtrim($max, '/');
      // Finally, build the thread field for this new comment.
      $thread = int2vancode(vancode2int($max) + 1) . '/';
    }
    else {
      // This is a comment with a parent comment, so increase the part of the
      // thread value at the proper depth.

      // Get the parent comment:
      $parent = comment_load($comment->pid);
      // Strip the "/" from the end of the parent thread.
      $parent->thread = (string) rtrim((string) $parent->thread, '/');
      // Get the max value in *this* thread.
      $max = db_query("SELECT MAX(thread) FROM {comment} WHERE thread LIKE :thread AND nid = :nid", array(
        ':thread' => $parent->thread . '.%',
        ':nid' => $comment->nid,
      ))->fetchField();

      if ($max == '') {
        // First child of this parent.
        $thread = $parent->thread . '.' . int2vancode(0) . '/';
      }
      else {
        // Strip the "/" at the end of the thread.
        $max = rtrim($max, '/');
        // Get the value at the correct depth.
        $parts = explode('.', $max);
        $parent_depth = count(explode('.', $parent->thread));
        $last = $parts[$parent_depth];
        // Finally, build the thread field for this new comment.
        $thread = $parent->thread . '.' . int2vancode(vancode2int($last) + 1) . '/';
      }
    }

    if (empty($comment->created)) {
      $comment->created = REQUEST_TIME;
    }

    if (empty($comment->changed)) {
      $comment->changed = $comment->created;
    }

    if ($comment->uid === $user->uid && isset($user->name)) { // '===' Need to modify anonymous users as well.
      $comment->name = $user->name;
    }

    $comment->cid = db_insert('comment')
      ->fields(array(
        'nid' => $comment->nid,
        'pid' => empty($comment->pid) ? 0 : $comment->pid,
        'uid' => $comment->uid,
        'subject' => $comment->subject,
        'comment' => $comment->comment,
        'format' => $comment->comment_format,
        'hostname' => ip_address(),
        'created' => $comment->created,
        'changed' => $comment->changed,
        'status' => $comment->status,
        'thread' => $thread,
        'name' => $comment->name,
        'mail' => $comment->mail,
        'homepage' => $comment->homepage,
        'language' => $comment->language,
      ))
      ->execute();

    // Ignore slave server temporarily to give time for the
    // saved node to be propagated to the slave.
    db_ignore_slave();

    field_attach_insert('comment', $comment);

    // Tell the other modules a new comment has been submitted.
    module_invoke_all('comment_insert', $comment);
    // Add an entry to the watchdog log.
    watchdog('content', 'Comment: added %subject.', array('%subject' => $comment->subject), WATCHDOG_NOTICE, l(t('view'), 'comment/' . $comment->cid, array('fragment' => 'comment-' . $comment->cid)));
  }
  _comment_update_node_statistics($comment->nid);
  // Clear the cache so an anonymous user can see his comment being added.
  cache_clear_all();

  if ($comment->status == COMMENT_PUBLISHED) {
    module_invoke_all('comment_publish', $comment);
  }
}
?>

Login or register to post comments