68 lines
2.4 KiB
Ruby
68 lines
2.4 KiB
Ruby
# -*- encoding : utf-8 -*-
|
|
class Subscribe < ActiveRecord::Base
|
|
belongs_to :subscribeable, :polymorphic => true
|
|
belongs_to :user
|
|
belongs_to :project
|
|
|
|
scope :finder_hack, order('') # FIXME .subscribes - error; .subscribes.finder_hack - success Oo
|
|
|
|
def subscribed?
|
|
status
|
|
end
|
|
|
|
def self.comment_subscribes(comment)
|
|
Subscribe.where(:subscribeable_id => comment.commentable.id, :subscribeable_type => comment.commentable.class.name, :project_id => comment.project)
|
|
end
|
|
|
|
def self.new_comment_notification(comment)
|
|
commentable_class = comment.commentable.class
|
|
Subscribe.new_comment_issue_notification(comment) if commentable_class == Issue
|
|
Subscribe.new_comment_commit_notification(comment) if commentable_class == Grit::Commit
|
|
end
|
|
|
|
def self.new_comment_issue_notification(comment)
|
|
comment.commentable.subscribes.finder_hack.each do |subscribe|
|
|
next if comment.own_comment?(subscribe.user) || !subscribe.user.notifier.can_notify
|
|
UserMailer.delay.new_comment_notification(comment, subscribe.user) if subscribe.user.notifier.new_comment_reply
|
|
end
|
|
end
|
|
|
|
def self.new_comment_commit_notification(comment)
|
|
subscribes = Subscribe.comment_subscribes(comment).where(:status => true)
|
|
subscribes.each do |subscribe|
|
|
next if comment.own_comment?(subscribe.user) || !subscribe.user.notifier.can_notify
|
|
UserMailer.delay.new_comment_notification(comment, subscribe.user)
|
|
end
|
|
end
|
|
|
|
def self.subscribed_to_commit?(project, user, commit)
|
|
subscribe = user.subscribes.where(:subscribeable_id => commit.id, :subscribeable_type => commit.class.name, :project_id => project.id).first
|
|
return subscribe.subscribed? if subscribe # return status if already subscribe present
|
|
# return status by settings
|
|
(project.owner?(user) && user.notifier.new_comment_commit_repo_owner) or
|
|
(user.commentor?(commit) && user.notifier.new_comment_commit_commentor) or
|
|
(user.committer?(commit) && user.notifier.new_comment_commit_owner)
|
|
end
|
|
|
|
|
|
def self.subscribe_to_commit(options)
|
|
Subscribe.set_subscribe_to_commit(options, true)
|
|
end
|
|
|
|
|
|
def self.unsubscribe_from_commit(options)
|
|
Subscribe.set_subscribe_to_commit(options, false)
|
|
end
|
|
|
|
private
|
|
|
|
def self.set_subscribe_to_commit(options, status)
|
|
if subscribe = Subscribe.where(options).first
|
|
subscribe.update_attribute(:status, status)
|
|
else
|
|
Subscribe.create(options.merge(:status => status))
|
|
end
|
|
end
|
|
|
|
end
|