mirror of
https://github.com/TracksApp/tracks.git
synced 2025-12-27 12:28:48 +01:00
d4bd8ed4db
This removes some intermediate steps that were ultimately not necessary to the math. It also consolidates some of the methods for counting events so that fewer intermediate values are necessary. To that end, a new scope is added to the ToDo model for events that are *either* created_at or completed_at after a certain date. This scope allows the StatsController to pull out the largest possible responsive set of values, and then filter just the particular slices that it needs for various steps in the calculation.
393 lines
13 KiB
Ruby
393 lines
13 KiB
Ruby
class Todo < ActiveRecord::Base
|
|
|
|
before_save :render_note
|
|
after_save :save_predecessors
|
|
|
|
# associations
|
|
belongs_to :context, :touch => true
|
|
belongs_to :project, :touch => true
|
|
belongs_to :user
|
|
belongs_to :recurring_todo
|
|
|
|
# Tag association
|
|
include IsTaggable
|
|
|
|
# Dependencies associations
|
|
has_many :predecessor_dependencies, :foreign_key => 'predecessor_id', :class_name => 'Dependency', :dependent => :destroy
|
|
has_many :successor_dependencies, :foreign_key => 'successor_id', :class_name => 'Dependency', :dependent => :destroy
|
|
has_many :predecessors, :through => :successor_dependencies
|
|
has_many :successors, :through => :predecessor_dependencies
|
|
has_many :uncompleted_predecessors, -> {where('NOT (todos.state = ?)', 'completed')}, :through => :successor_dependencies,
|
|
:source => :predecessor
|
|
has_many :pending_successors, -> {where('todos.state = ?', 'pending')}, :through => :predecessor_dependencies,
|
|
:source => :successor
|
|
|
|
# scopes for states of this todo
|
|
scope :active, -> { where state: 'active' }
|
|
scope :active_or_hidden, -> { where "todos.state = ? OR todos.state = ?", 'active', 'project_hidden' }
|
|
scope :not_completed, -> { where 'NOT (todos.state = ?)', 'completed' }
|
|
scope :completed, -> { where "todos.state = ?", 'completed' }
|
|
scope :deferred, -> { where "todos.state = ?", 'deferred' }
|
|
scope :blocked, -> {where 'todos.state = ?', 'pending' }
|
|
scope :pending, -> {where 'todos.state = ?', 'pending' }
|
|
scope :deferred_or_blocked, -> { where "(todos.state = ?) OR (todos.state = ?)", "deferred", "pending" }
|
|
scope :not_deferred_or_blocked, -> { where "(NOT todos.state=?) AND (NOT todos.state = ?)", "deferred", "pending" }
|
|
scope :hidden, -> {
|
|
joins("INNER JOIN contexts c_hidden ON c_hidden.id = todos.context_id").
|
|
where("todos.state = ? OR (c_hidden.state = ? AND (todos.state = ? OR todos.state = ? OR todos.state = ?))", 'project_hidden', 'hidden', 'active', 'deferred', 'pending') }
|
|
scope :not_hidden, -> {
|
|
joins("INNER JOIN contexts c_hidden ON c_hidden.id = todos.context_id").
|
|
where('NOT(todos.state = ? OR (c_hidden.state = ? AND (todos.state = ? OR todos.state = ? OR todos.state = ?)))','project_hidden', 'hidden', 'active', 'deferred', 'pending') }
|
|
|
|
# other scopes
|
|
scope :are_due, -> { where 'NOT (todos.due IS NULL)' }
|
|
scope :due_today, -> { where("todos.due <= ?", Time.zone.now) }
|
|
scope :with_tag, lambda { |tag_id| joins("INNER JOIN taggings ON todos.id = taggings.taggable_id").where("taggings.tag_id = ? ", tag_id) }
|
|
scope :with_tags, lambda { |tag_ids| where("EXISTS(SELECT * from taggings t WHERE t.tag_id IN (?) AND t.taggable_id=todos.id AND t.taggable_type='Todo')", tag_ids) }
|
|
scope :completed_after, lambda { |date| where("todos.completed_at > ?", date) }
|
|
scope :completed_before, lambda { |date| where("todos.completed_at < ?", date) }
|
|
scope :created_after, lambda { |date| where("todos.created_at > ?", date) }
|
|
scope :created_before, lambda { |date| where("todos.created_at < ?", date) }
|
|
scope :created_or_completed_after, lambda { |date| where("todos.created_at > ? or todos.completed_at > ?", date, date) }
|
|
|
|
def self.due_after(date)
|
|
where('todos.due > ?', date)
|
|
end
|
|
|
|
def self.due_between(start_date, end_date)
|
|
where('todos.due > ? AND todos.due <= ?', start_date, end_date)
|
|
end
|
|
|
|
STARRED_TAG_NAME = "starred"
|
|
DEFAULT_INCLUDES = [ :project, :context, :tags, :taggings, :pending_successors, :uncompleted_predecessors, :recurring_todo ]
|
|
|
|
# state machine
|
|
include AASM
|
|
aasm_initial_state Proc.new { |t| (t.show_from && t.user && (t.show_from > t.user.date)) ? :deferred : :active}
|
|
|
|
aasm :column => :state do
|
|
|
|
state :active
|
|
state :project_hidden
|
|
state :completed, :before_enter => Proc.new { |t| t.completed_at = Time.zone.now }, :before_exit => Proc.new { |t| t.completed_at = nil}
|
|
state :deferred, :after_exit => Proc.new { |t| t[:show_from] = nil }
|
|
state :pending
|
|
|
|
event :defer do
|
|
transitions :to => :deferred, :from => [:active]
|
|
end
|
|
|
|
event :complete do
|
|
transitions :to => :completed, :from => [:active, :project_hidden, :deferred, :pending]
|
|
end
|
|
|
|
event :activate do
|
|
transitions :to => :active, :from => [:project_hidden, :deferred]
|
|
transitions :to => :active, :from => [:completed], :guard => :no_uncompleted_predecessors?
|
|
transitions :to => :active, :from => [:pending], :guard => :no_uncompleted_predecessors_or_deferral?
|
|
transitions :to => :pending, :from => [:completed], :guard => :uncompleted_predecessors?
|
|
transitions :to => :deferred, :from => [:pending], :guard => :no_uncompleted_predecessors?
|
|
end
|
|
|
|
event :hide do
|
|
transitions :to => :project_hidden, :from => [:active, :deferred, :pending]
|
|
end
|
|
|
|
event :unhide do
|
|
transitions :to => :deferred, :from => [:project_hidden], :guard => Proc.new{|t| !t.show_from.blank? }
|
|
transitions :to => :pending, :from => [:project_hidden], :guard => :uncompleted_predecessors?
|
|
transitions :to => :active, :from => [:project_hidden]
|
|
end
|
|
|
|
event :block do
|
|
transitions :to => :pending, :from => [:active, :deferred, :project_hidden]
|
|
end
|
|
end
|
|
|
|
# Description field can't be empty, and must be < 100 bytes Notes must be <
|
|
# 60,000 bytes (65,000 actually, but I'm being cautious)
|
|
validates_presence_of :description
|
|
validates_length_of :description, :maximum => 100
|
|
validates_length_of :notes, :maximum => 60000, :allow_nil => true
|
|
validates_presence_of :show_from, :if => :deferred?
|
|
validates_presence_of :context
|
|
validate :check_show_from_in_future
|
|
validate :check_circular_dependencies
|
|
|
|
def check_show_from_in_future
|
|
if show_from_changed? # only check on change of show_from
|
|
if !show_from.blank? && (show_from < user.date)
|
|
errors.add("show_from", I18n.t('models.todo.error_date_must_be_future'))
|
|
end
|
|
end
|
|
end
|
|
|
|
def check_circular_dependencies
|
|
unless @predecessor_array.nil? # Only validate predecessors if they changed
|
|
@predecessor_array.each do |todo|
|
|
errors.add("Depends on:", "Adding '#{todo.specification}' would create a circular dependency") if is_successor?(todo)
|
|
end
|
|
end
|
|
end
|
|
|
|
def initialize(*args)
|
|
super(*args)
|
|
@predecessor_array = nil # Used for deferred save of predecessors
|
|
@removed_predecessors = nil
|
|
end
|
|
|
|
def no_uncompleted_predecessors_or_deferral?
|
|
no_deferral = show_from.blank? or Time.zone.now > show_from
|
|
return (no_deferral && no_uncompleted_predecessors?)
|
|
end
|
|
|
|
def no_uncompleted_predecessors?
|
|
return !uncompleted_predecessors?
|
|
end
|
|
|
|
def uncompleted_predecessors?
|
|
return !uncompleted_predecessors.empty?
|
|
end
|
|
|
|
def should_be_blocked?
|
|
return !( uncompleted_predecessors.empty? || state == 'project_hidden' )
|
|
end
|
|
|
|
def guard_for_transition_from_deferred_to_pending
|
|
no_uncompleted_predecessors? && not_part_of_hidden_container?
|
|
end
|
|
|
|
def not_part_of_hidden_container?
|
|
!( (self.project && self.project.hidden?) || self.context.hidden? )
|
|
end
|
|
|
|
# Returns a string with description <context, project>
|
|
def specification
|
|
project_name = self.project.is_a?(NullProject) ? "(none)" : self.project.name
|
|
return "\'#{self.description}\' <\'#{self.context.title}\'; \'#{project_name}\'>"
|
|
end
|
|
|
|
def save_predecessors
|
|
unless @predecessor_array.nil? # Only save predecessors if they changed
|
|
current_array = self.predecessors
|
|
remove_array = current_array - @predecessor_array
|
|
add_array = @predecessor_array - current_array
|
|
|
|
@removed_predecessors = []
|
|
remove_array.each do |todo|
|
|
unless todo.nil?
|
|
@removed_predecessors << todo
|
|
self.predecessors.delete(todo)
|
|
end
|
|
end
|
|
|
|
add_array.each do |todo|
|
|
unless todo.nil?
|
|
self.predecessors << todo unless self.predecessors.include?(todo)
|
|
else
|
|
logger.error "Could not find #{todo.description}" # Unexpected since validation passed
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
def touch_predecessors
|
|
self.touch
|
|
predecessors.each { |p| p.touch_predecessors }
|
|
end
|
|
|
|
def removed_predecessors
|
|
return @removed_predecessors
|
|
end
|
|
|
|
# remove predecessor and activate myself if it was the last predecessor
|
|
def remove_predecessor(predecessor)
|
|
self.predecessors.delete(predecessor)
|
|
if self.predecessors.empty?
|
|
self.not_part_of_hidden_container? ? self.activate! : self.hide!
|
|
else
|
|
save!
|
|
end
|
|
end
|
|
|
|
# Returns true if t is equal to self or a successor of self
|
|
def is_successor?(todo)
|
|
if self == todo
|
|
return true
|
|
elsif self.successors.empty?
|
|
return false
|
|
else
|
|
self.successors.each do |item|
|
|
if item.is_successor?(todo)
|
|
return true
|
|
end
|
|
end
|
|
end
|
|
return false
|
|
end
|
|
|
|
def has_pending_successors
|
|
return !pending_successors.empty?
|
|
end
|
|
|
|
def hidden?
|
|
return self.project_hidden? || ( self.context.hidden? && (self.active? || self.deferred?))
|
|
end
|
|
|
|
def update_state_from_project
|
|
if self.project_hidden? && (!self.project.hidden?)
|
|
if self.uncompleted_predecessors.empty?
|
|
self.activate!
|
|
else
|
|
self.block!
|
|
end
|
|
elsif self.active? && self.project.hidden?
|
|
self.hide!
|
|
end
|
|
self.save!
|
|
end
|
|
|
|
def toggle_completion!
|
|
return completed? ? activate! : complete!
|
|
end
|
|
|
|
def show_from
|
|
self[:show_from]
|
|
end
|
|
|
|
def show_from=(date)
|
|
if deferred? && date.blank?
|
|
activate
|
|
else
|
|
# parse Date objects into the proper timezone
|
|
date = user.at_midnight(date) if (date.is_a? Date)
|
|
|
|
# show_from needs to be set before state_change because of "bug" in aasm.
|
|
# If show_from is not set, the todo will not validate and thus aasm will not save
|
|
# (see http://stackoverflow.com/questions/682920/persisting-the-state-column-on-transition-using-rubyist-aasm-acts-as-state-machi)
|
|
self[:show_from] = date
|
|
|
|
defer if active? && !date.blank? && show_from > user.date
|
|
end
|
|
end
|
|
|
|
def starred?
|
|
return has_tag?(STARRED_TAG_NAME)
|
|
end
|
|
|
|
def toggle_star!
|
|
self.starred= !starred?
|
|
end
|
|
|
|
def starred=(starred)
|
|
if starred
|
|
_add_tags STARRED_TAG_NAME unless starred?
|
|
else
|
|
_remove_tags STARRED_TAG_NAME
|
|
end
|
|
starred
|
|
end
|
|
|
|
def from_recurring_todo?
|
|
return self.recurring_todo_id != nil
|
|
end
|
|
|
|
def add_predecessor_list(predecessor_list)
|
|
return unless predecessor_list.kind_of? String
|
|
|
|
@predecessor_array=predecessor_list.split(",").inject([]) do |list, todo_id|
|
|
predecessor = self.user.todos.find( todo_id.to_i ) unless todo_id.blank?
|
|
list << predecessor unless predecessor.nil?
|
|
list
|
|
end
|
|
|
|
return @predecessor_array
|
|
end
|
|
|
|
def add_predecessor(t)
|
|
return if t.nil?
|
|
|
|
@predecessor_array = predecessors
|
|
@predecessor_array << t
|
|
end
|
|
|
|
# activate todos that should be activated if the current todo is completed
|
|
def activate_pending_todos
|
|
pending_todos = successors.select {|t| t.uncompleted_predecessors.empty?}
|
|
pending_todos.each {|t| t.activate! }
|
|
return pending_todos
|
|
end
|
|
|
|
# Return todos that should be blocked if the current todo is undone
|
|
def block_successors
|
|
active_successors = successors.select {|t| t.active? or t.deferred?}
|
|
active_successors.each {|t| t.block!}
|
|
return active_successors
|
|
end
|
|
|
|
def raw_notes=(value)
|
|
self[:notes] = value
|
|
end
|
|
|
|
# XML API fixups
|
|
def predecessor_dependencies=(params)
|
|
deps = params[:predecessor]
|
|
return if deps.nil?
|
|
|
|
# for multiple dependencies, value will be an array of id's, but for a single dependency,
|
|
# value will be a string. In that case convert to array
|
|
deps = [deps] unless deps.class == Array
|
|
|
|
deps.each { |dep| self.add_predecessor(self.user.todos.find(dep.to_i)) unless dep.blank? }
|
|
end
|
|
|
|
alias_method :original_context=, :context=
|
|
def context=(value)
|
|
if value.is_a? Context
|
|
self.original_context=(value)
|
|
else
|
|
c = Context.where(:name => value[:name]).first
|
|
c = Context.create(value) if c.nil?
|
|
self.original_context=(c)
|
|
end
|
|
end
|
|
|
|
alias_method :original_project, :project
|
|
def project
|
|
original_project.nil? ? Project.null_object : original_project
|
|
end
|
|
|
|
alias_method :original_project=, :project=
|
|
def project=(value)
|
|
if value.is_a? Project
|
|
self.original_project=(value)
|
|
elsif !(value.nil? || value.is_a?(NullProject))
|
|
p = Project.where(:name => value[:name]).first
|
|
p = Project.create(value) if p.nil?
|
|
self.original_project=(p)
|
|
else
|
|
self.original_project=value
|
|
end
|
|
end
|
|
|
|
def has_project?
|
|
return ! (project_id.nil? || project.is_a?(NullProject))
|
|
end
|
|
|
|
# used by the REST API. <tags> will also work, this is renamed to add_tags in TodosController::TodoCreateParamsHelper::initialize
|
|
def add_tags=(params)
|
|
unless params[:tag].nil?
|
|
tag_list = params[:tag].inject([]) { |list, value| list << value[:name] }
|
|
tag_with tag_list.join(", ")
|
|
end
|
|
end
|
|
|
|
def render_note
|
|
unless self.notes.nil?
|
|
self.rendered_notes = Tracks::Utils.render_text(self.notes)
|
|
else
|
|
self.rendered_notes = nil
|
|
end
|
|
end
|
|
|
|
end
|