task.rb
6 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
# Task is the base class of ... tasks! Its instances represents tasks that must
# be confirmed by someone (like an environment administrator) or by noosfero
# itself.
#
# The specific types of tasks <em>must</em> override the #perform method, so
# the actual action associated to the type of task can be performed. See the
# documentation of the #perform method for details.
#
# This class has a +data+ field of type <tt>text</tt>, where you can store any
# type of data (as serialized Ruby objects) you need for your subclass (which
# will need to declare <ttserialize</tt> itself).
class Task < ActiveRecord::Base
module Status
include GetText
# the status of tasks just created
ACTIVE = 1
# the status of a task that was cancelled.
CANCELLED = 2
# the status os a task that was successfully finished
FINISHED = 3
def self.names
[nil, N_('Active'), N_('Cancelled'), N_('Finished')]
end
end
belongs_to :requestor, :class_name => 'Person', :foreign_key => :requestor_id
belongs_to :target, :foreign_key => :target_id, :polymorphic => true
validates_uniqueness_of :code, :on => :create
validates_presence_of :code
attr_protected :status
def initialize(*args)
super
self.status ||= Task::Status::ACTIVE
end
attr_accessor :code_length
before_validation_on_create do |task|
if task.code.nil?
task.code = Task.generate_code(task.code_length)
while (Task.find_by_code(task.code))
task.code = Task.generate_code(task.code_length)
end
end
end
after_create do |task|
begin
task.send(:send_notification, :created)
rescue NotImplementedError => ex
RAILS_DEFAULT_LOGGER.info ex.to_s
end
begin
target_msg = task.target_notification_message
TaskMailer.deliver_target_notification(task, target_msg) if target_msg
rescue NotImplementedError => ex
RAILS_DEFAULT_LOGGER.info ex.to_s
end
end
# this method finished the task. It calls #perform, which must be overriden
# by subclasses. At the end a message (as returned by #finish_message) is
# sent to the requestor with #notify_requestor.
def finish
transaction do
self.status = Task::Status::FINISHED
self.end_date = Time.now
self.save!
self.perform
begin
send_notification(:finished)
rescue NotImplementedError => ex
RAILS_DEFAULT_LOGGER.info ex.to_s
end
end
after_finish
end
# :nodoc:
def after_finish
end
# this method cancels the task. At the end a message (as returned by
# #cancel_message) is sent to the requestor with #notify_requestor.
def cancel
transaction do
self.status = Task::Status::CANCELLED
self.end_date = Time.now
self.save!
begin
send_notification(:cancelled)
rescue NotImplementedError => ex
RAILS_DEFAULT_LOGGER.info ex.to_s
end
end
end
# Returns the description of the task.
#
# This method +must+ be overriden in subclasses to return something
# meaningful for each kind of task
def description
_('Generic task')
end
# The message that will be sent to the requestor of the task when the task is
# created.
def task_created_message
raise NotImplementedError, "#{self} does not implement #task_created_message"
end
# The message that will be sent to the requestor of the task when its
# finished.
def task_finished_message
raise NotImplementedError, "#{self} does not implement #task_finished_message"
end
# The message that will be sent to the requestor of the task when its
# cancelled.
def task_cancelled_message
raise NotImplementedError, "#{self} does not implement #task_cancelled_message"
end
# The message that will be sent to the *target* of the task when it is
# created. The indent of this message is to notify the target about the
# request that was just created for him/her.
#
# The implementation in this class returns +nil+, what makes the notification
# not to be sent. If you want to send a notification to the target upon task
# creation, override this method and return a String.
def target_notification_message
raise NotImplementedError, "#{self} does not implement #target_notification_message"
end
# What permission is required to perform task?
def permission
:perform_task
end
protected
# This method must be overrided in subclasses, and its implementation must do
# the job the task is intended to. This method will be called when the finish
# method is called.
#
# To cancel the finish of the task, you can throw an exception in perform.
#
# The implementation on Task class just does nothing.
def perform
end
# Tells wheter e-mail notifications must be sent or not. Returns
# <tt>true</tt> by default (i.e. notification are sent), but can be overriden
# in subclasses to disable notifications or even to send notifications based
# on some conditions.
def sends_email?
true
end
# sends notification e-mail about a task, if the task has a requestor.
#
# If
def send_notification(action)
if sends_email?
if self.requestor
TaskMailer.send("deliver_task_#{action}", self)
end
end
end
named_scope :pending, :conditions => { :status => Task::Status::ACTIVE }
named_scope :finished, :conditions => { :status => [Task::Status::CANCELLED, Task::Status::FINISHED] }
class << self
# generates a random code string consisting of length characters (or 36 by
# default) in the ranges a-z and 0-9
def generate_code(length = nil)
chars = ('a'..'z').to_a + ('0'..'9').to_a
code = ""
(length || chars.size).times do |n|
code << chars[rand(chars.size)]
end
code
end
# finds a task by its (generated) code. Only returns a task with the
# specified code AND with status = Task::Status::ACTIVE.
#
# Can be used in subclasses to find only their instances.
def find_by_code(code)
self.find(:first, :conditions => { :code => code, :status => Task::Status::ACTIVE })
end
end
end