discourse/app/models/user_action_observer.rb

class UserActionObserver < ActiveRecord::Observer
  observe :post_action, :topic, :post, :notification, :topic_user

  def after_save(model)
    case
    when (model.is_a?(PostAction) && (model.is_bookmark? || model.is_like?))
      log_post_action(model)
    when (model.is_a?(Topic))
      log_topic(model)
    when (model.is_a?(Post))
      log_post(model)
    when (model.is_a?(TopicUser))
      log_topic_user(model)
    end
  end

  def log_topic_user(model)
    action = UserAction::STAR

    row = {
        action_type: action,
        user_id: model.user_id,
        acting_user_id: model.user_id,
        target_topic_id: model.topic_id,
        target_post_id: -1,
        created_at: model.starred_at
    }

    if model.starred
      UserAction.log_action!(row)
    else
      UserAction.remove_action!(row)
    end
  end

  def self.log_notification(post, user, notification_type)
    action =
      case notification_type
        when Notification.types[:quoted]
          UserAction::QUOTE
        when Notification.types[:replied]
          UserAction::RESPONSE
        when Notification.types[:mentioned]
          UserAction::MENTION
        when Notification.types[:edited]
          UserAction::EDIT
      end

    # skip any invalid items, eg failed to save post and so on
    return unless action && post && user && post.id

    row = {
        action_type: action,
        user_id: user.id,
        acting_user_id: (action == UserAction::EDIT) ? post.last_editor_id : post.user_id,
        target_topic_id: post.topic_id,
        target_post_id: post.id
    }

    if post.deleted_at.nil?
      UserAction.log_action!(row)
    else
      UserAction.remove_action!(row)
    end
  end

  def log_post(model)
    # first post gets nada
    return if model.post_number == 1

    row = {
        action_type: UserAction::REPLY,
        user_id: model.user_id,
        acting_user_id: model.user_id,
        target_post_id: model.id,
        target_topic_id: model.topic_id,
        created_at: model.created_at
    }

    rows = [row]

    if model.topic.private_message?
      rows = []
      model.topic.topic_allowed_users.each do |ta|
        row = row.dup
        row[:user_id] = ta.user_id
        row[:action_type] = ta.user_id == model.user_id ? UserAction::NEW_PRIVATE_MESSAGE : UserAction::GOT_PRIVATE_MESSAGE
        rows << row
      end
    end

    rows.each do |r|
      if model.deleted_at.nil?
        UserAction.log_action!(r)
      else
        UserAction.remove_action!(r)
      end
    end
  end

  def log_topic(model)
    row = {
        action_type: model.archetype == Archetype.private_message ? UserAction::NEW_PRIVATE_MESSAGE : UserAction::NEW_TOPIC,
        user_id: model.user_id,
        acting_user_id: model.user_id,
        target_topic_id: model.id,
        target_post_id: -1,
        created_at: model.created_at
    }

    rows = [row]

    if model.private_message?
      model.topic_allowed_users.reject { |a| a.user_id == model.user_id }.each do |ta|
        row = row.dup
        row[:user_id] = ta.user_id
        row[:action_type] = UserAction::GOT_PRIVATE_MESSAGE
        rows << row
      end
    end

    rows.each do |r|
      if model.deleted_at.nil?
        UserAction.log_action!(r)
      else
        UserAction.remove_action!(r)
      end
    end
  end

  def log_post_action(model)
    action = UserAction::BOOKMARK if model.is_bookmark?
    action = UserAction::LIKE if model.is_like?

    row = {
      action_type: action,
      user_id: model.user_id,
      acting_user_id: model.user_id,
      target_post_id: model.post_id,
      target_topic_id: model.post.topic_id,
      created_at: model.created_at
    }

    if model.deleted_at.nil?
      UserAction.log_action!(row)
    else
      UserAction.remove_action!(row)
    end

    if model.is_like?
      row[:action_type] = UserAction::WAS_LIKED
      row[:user_id] = model.post.user_id
      if model.deleted_at.nil?
        UserAction.log_action!(row)
      else
        UserAction.remove_action!(row)
      end
    end
  end
end