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
|
# encoding: utf-8
#--
# Copyright (C) 2009 Nokia Corporation and/or its subsidiary(-ies)
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Affero General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
#++
class MessagesController < ApplicationController
before_filter :login_required
after_filter :mark_thread_as_read, :only => :show
renders_in_global_context
def index
@messages = current_user.messages_in_inbox.paginate(:page => params[:page])
@root = Breadcrumb::ReceivedMessages.new(current_user)
respond_to do |wants|
wants.html
wants.xml {render :xml => @messages}
end
end
def all
@messages = current_user.top_level_messages.paginate(:page => params[:page])
@root = Breadcrumb::AllMessages.new(current_user)
end
def sent
@messages = current_user.sent_messages.paginate(:all,
:page => params[:page])
@root = Breadcrumb::SentMessages.new(current_user)
end
def read
@message = current_user.received_messages.find(params[:id])
@message.read
respond_to do |wants|
wants.js
end
end
def bulk_update
message_ids = params[:message_ids].to_a
message_ids.each do |message_id|
# if message = current_user.all_messages.find(message_id)
if message = Message.find(:first, :conditions => ['(recipient_id=? OR sender_id=?) AND id=?', current_user, current_user, message_id])
if params[:requested_action] == 'archive'
message.archived_by(current_user)
message.save!
else
logger.info("Marking message #{message_id} as read")
message.read
end
end
end
redirect_to :action => :index
end
def show
@message = Message.find(params[:id])
unless @message.sender == current_user or @message.recipient == current_user
raise ActiveRecord::RecordNotFound and return
end
@message.read if @message.recipient == current_user
respond_to do |wants|
wants.html
wants.xml {render :xml => @message}
wants.js {render :partial => "message", :layout => false}
end
end
def create
thread_options = params[:message].merge({
:recipients => params[:message][:recipients],
:sender => current_user
})
@messages = MessageThread.new(thread_options)
if @messages.save
flash[:notice] = "#{@messages.title} sent"
redirect_to :action => :index
else
@message = @messages.message
render :action => :new
end
end
def new
@message = current_user.sent_messages.new(:recipients => params[:to])
end
# POST /messages/<id>/reply
def reply
original_message = current_user.received_messages.find(params[:id])
@message = original_message.build_reply(params[:message])
original_message.read! unless original_message.read?
if @message.save
flash[:notice] = "Your reply was sent"
redirect_to :action => :show, :id => original_message
else
flash[:error] = "Your message could not be sent"
redirect_to :action => :index
end
end
def auto_complete_for_message_recipients
login = params[:message][:recipients]
@users = User.find(:all,
:conditions => [ 'LOWER(login) LIKE ?', '%' + login.downcase + '%' ],
:limit => 10).reject{|u|u == current_user}
render :layout => false
end
protected
def ssl_required?
# Always required.
true
end
def mark_thread_as_read
return unless @message
@message.messages_in_thread.each do |msg|
msg.read
end
end
end
|
