2016-05-18 22:19:25 +00:00
|
|
|
|
2016-08-09 06:48:23 +00:00
|
|
|
require_dependency 'gitlab/email/handler'
|
2016-05-18 22:19:25 +00:00
|
|
|
|
2015-08-20 18:05:06 +00:00
|
|
|
# Inspired in great part by Discourse's Email::Receiver
|
|
|
|
module Gitlab
|
|
|
|
module Email
|
2017-03-01 11:00:37 +00:00
|
|
|
ProcessingError = Class.new(StandardError)
|
|
|
|
EmailUnparsableError = Class.new(ProcessingError)
|
|
|
|
SentNotificationNotFoundError = Class.new(ProcessingError)
|
|
|
|
ProjectNotFound = Class.new(ProcessingError)
|
|
|
|
EmptyEmailError = Class.new(ProcessingError)
|
|
|
|
AutoGeneratedEmailError = Class.new(ProcessingError)
|
|
|
|
UserNotFoundError = Class.new(ProcessingError)
|
|
|
|
UserBlockedError = Class.new(ProcessingError)
|
|
|
|
UserNotAuthorizedError = Class.new(ProcessingError)
|
|
|
|
NoteableNotFoundError = Class.new(ProcessingError)
|
|
|
|
InvalidNoteError = Class.new(ProcessingError)
|
|
|
|
InvalidIssueError = Class.new(ProcessingError)
|
|
|
|
UnknownIncomingEmail = Class.new(ProcessingError)
|
2016-05-18 22:19:25 +00:00
|
|
|
|
2015-08-20 18:05:06 +00:00
|
|
|
class Receiver
|
|
|
|
def initialize(raw)
|
2016-05-21 00:03:39 +00:00
|
|
|
@raw = raw
|
2015-08-20 18:05:06 +00:00
|
|
|
end
|
|
|
|
|
|
|
|
def execute
|
2016-05-21 00:03:39 +00:00
|
|
|
raise EmptyEmailError if @raw.blank?
|
|
|
|
|
|
|
|
mail = build_mail
|
|
|
|
mail_key = extract_mail_key(mail)
|
2016-06-15 08:18:40 +00:00
|
|
|
handler = Handler.for(mail, mail_key)
|
2015-08-20 18:05:06 +00:00
|
|
|
|
2016-06-15 08:23:41 +00:00
|
|
|
raise UnknownIncomingEmail unless handler
|
|
|
|
|
|
|
|
handler.execute
|
2016-03-23 14:20:22 +00:00
|
|
|
end
|
2015-08-20 18:05:06 +00:00
|
|
|
|
2017-01-17 19:50:49 +00:00
|
|
|
private
|
|
|
|
|
2016-05-21 00:03:39 +00:00
|
|
|
def build_mail
|
|
|
|
Mail::Message.new(@raw)
|
2016-05-18 22:19:25 +00:00
|
|
|
rescue Encoding::UndefinedConversionError,
|
|
|
|
Encoding::InvalidByteSequenceError => e
|
2015-08-20 19:17:59 +00:00
|
|
|
raise EmailUnparsableError, e
|
|
|
|
end
|
|
|
|
|
2016-05-21 00:03:39 +00:00
|
|
|
def extract_mail_key(mail)
|
|
|
|
key_from_to_header(mail) || key_from_additional_headers(mail)
|
2016-03-01 05:29:20 +00:00
|
|
|
end
|
|
|
|
|
2016-05-21 00:03:39 +00:00
|
|
|
def key_from_to_header(mail)
|
2016-05-18 22:19:25 +00:00
|
|
|
mail.to.find do |address|
|
2016-03-23 12:05:31 +00:00
|
|
|
key = Gitlab::IncomingEmail.key_from_address(address)
|
2016-05-18 22:19:25 +00:00
|
|
|
break key if key
|
2015-08-20 18:05:06 +00:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2016-05-21 00:03:39 +00:00
|
|
|
def key_from_additional_headers(mail)
|
2017-02-03 09:30:54 +00:00
|
|
|
references = ensure_references_array(mail.references)
|
|
|
|
|
|
|
|
find_key_from_references(references)
|
2017-01-17 19:50:49 +00:00
|
|
|
end
|
|
|
|
|
|
|
|
def ensure_references_array(references)
|
|
|
|
case references
|
|
|
|
when Array
|
|
|
|
references
|
2017-01-20 12:20:40 +00:00
|
|
|
when String
|
|
|
|
# Handle emails from clients which append with commas,
|
|
|
|
# example clients are Microsoft exchange and iOS app
|
2017-01-17 19:50:49 +00:00
|
|
|
Gitlab::IncomingEmail.scan_fallback_references(references)
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
def find_key_from_references(references)
|
|
|
|
references.find do |mail_id|
|
2016-05-20 23:21:58 +00:00
|
|
|
key = Gitlab::IncomingEmail.key_from_fallback_message_id(mail_id)
|
2016-05-18 22:19:25 +00:00
|
|
|
break key if key
|
2016-03-01 05:29:20 +00:00
|
|
|
end
|
|
|
|
end
|
2015-08-20 18:05:06 +00:00
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|