class ActivityFeedObserver < ActiveRecord::Observer
  observe :issue, :comment, :user

  def after_create(record)
    case record.class.to_s
    when 'User'
      ActivityFeed.create(
        :user => record,
        :kind => 'new_user_notification',
        :data => {:user_name => record.name, :user_email => record.email}
      )

    when 'Issue'
      recipients = record.collect_recipient_ids
      recipients.each do |recipient_id|
        recipient = User.find(recipient_id)
        UserMailer.delay.new_issue_notification(record, recipient) if User.find(recipient).notifier.can_notify && User.find(recipient).notifier.new_issue
        ActivityFeed.create(
          :user => recipient,
          :kind => 'new_issue_notification',
          :data => {:user_name => record.user.name, :issue_serial_id => record.serial_id, :issue_title => record.title, :project_id => record.project.id, :project_name => record.project.name}
        )
      end

      if record.user_id_was != record.user_id
        UserMailer.delay.issue_assign_notification(record, record.user) if record.user.notifier.issue_assign && record.user.notifier.can_notify
        ActivityFeed.create(
          :user => record.user,
          :kind => 'issue_assign_notification',
          :data => {:user_name => record.user.name, :issue_serial_id => record.serial_id, :project_id => record.project.id, :issue_title => record.title}
        )
      end

    when 'Comment'
      if record.commentable.class == Issue
        subscribes = record.commentable.subscribes.finder_hack
        subscribes.each do |subscribe|
          if record.user_id != subscribe.user_id
            UserMailer.delay.new_comment_notification(record, subscribe.user) if record.can_notify_on_new_comment?(subscribe)
            ActivityFeed.create(
              :user => subscribe.user,
              :kind => 'new_comment_notification',
              :data => {:user_name => subscribe.user.name, :comment_body => record.body, :issue_title => record.commentable.title,
                                 :issue_serial_id => record.commentable.serial_id, :project_id => record.commentable.project.id}
            )
          end
        end
      elsif record.commit_comment?
        subscribes = Subscribe.comment_subscribes(record).where(:status => true)
        subscribes.each do |subscribe|
          next if record.own_comment?(subscribe.user)
          UserMailer.delay.new_comment_notification(record, subscribe.user) if subscribe.user.notifier.can_notify
            ActivityFeed.create(
              :user => subscribe.user,
              :kind => 'new_comment_commit_notification',
              :data => {:user_name => subscribe.user.name, :comment_body => record.body, :commit_message => record.commentable.message.encode_to_default,
                                 :commit_id => record.commentable.id, :project_id => record.project.id}
            )
        end
      end

    when 'GitHook'
      change_type = record.change_type
      branch_name = record.refname.match(/\/([\w\d]+)$/)[1]
      #user_name = record.

      #owner = record.owner
      project = Project.find_by_name(record.repo)

      last_commits = project.git_repository.repo.log(branch_name, nil).first(3).collect do |commit| #:author => 'author'
        [commit.sha, commit.message]
      end

      if change_type == 'delete'
        kind = 'git_delete_branch_notification'
        options = {:project_id => project.id, :project_name => project.name, :branch_name => branch_name, :change_type => change_type}
      else
        kind = 'git_new_push_notification'
        options = {:project_id => project.id, :project_name => project.name, :last_commits => last_commits, :branch_name => branch_name, :change_type => change_type}
      end

      project.owner_and_admin_ids.each do |recipient|
        ActivityFeed.create(
          :user => User.find(recipient),
          :kind => kind,
          :data => options
        )
      end

    when 'Gollum::Committer'
      actor = User.find_by_uname(record.actor.name)
      project_name = record.wiki.path.match(/\/(\w+)\.wiki\.git$/)[1]
      project = Project.find_by_name(project_name)
      commit_sha = record.commit
      #wiki_name = record.wiki.name

      project.owner_and_admin_ids.each do |recipient|
        ActivityFeed.create(
          :user => User.find(recipient),#record.user,
          :kind => 'wiki_new_commit_notification',
          :data => {:user_id => actor.id, :user_name => actor.name, :project_id => project.id, :project_name => project_name, :commit_sha => commit_sha}
        )
      end
    end
  end

  def after_update(record)
    case record.class.to_s
    when 'Issue'
      if record.user_id_was != record.user_id
        UserMailer.delay.issue_assign_notification(record, record.user) if record.user.notifier.issue_assign && record.user.notifier.can_notify
        ActivityFeed.create(
          :user => record.user,
          :kind => 'issue_assign_notification',
          :data => {:user_name => record.user.name, :issue_serial_id => record.serial_id, :project_id => record.project.id, :issue_title => record.title}
        )
      end
    end
  end

end