класс Net::IMAP
Net::IMAP реализует функциональность клиента протокола Internet Message Access Protocol (IMAP). Протокол описан в [IMAP].
IMAP Обзор
Клиент IMAP подключается к серверу и затем аутентифицирует себя с помощью authenticate() или login(). После аутентификации ему доступен ряд команд. Большинство из них работают с почтовыми ящиками, которые могут быть организованы в иерархическом пространстве имен, и каждый из которых содержит ноль или более сообщений. Способ реализации на сервере зависит от реализации; на сервере UNIX он часто реализуется как файлы в формате почтового ящика внутри иерархии каталогов.
Чтобы работать с сообщениями внутри почтового ящика, клиент должен сначала выбрать этот почтовый ящик, используя select() или (для только для чтения) examine(). После успешного выбора почтового ящика клиент переходит в состояние «выбран» и этот почтовый ящик становится текущим почтовым ящиком, на котором команды, связанные с почтовыми элементами, действуют неявно.
Сообщения имеют два вида идентификаторов: порядковые номера сообщений и UIDs.
Порядковые номера сообщений нумеруют сообщения в почтовом ящике от 1 до количества элементов в почтовом ящике. Если новое сообщение поступает во время сессии, оно получает порядковый номер, равный новому размеру почтового ящика. Если сообщения удаляются из почтового ящика, оставшиеся сообщения изменяют свои порядковые номера, «сдвигая» их вниз, чтобы заполнить пробелы.
С другой стороны, UIDs гарантированно не идентифицируют другое сообщение в том же почтовом ящике, даже если существующее сообщение удалено. UIDs должны присваиваться в возрастающем (но необязательно последовательном) порядке в почтовом ящике; это означает, что если клиент, не использующий IMAP, переупорядочивает порядок почтовых элементов в почтовом ящике, UIDs должны быть переприсвоены. Таким образом, клиент IMAP не может переупорядочивать порядок сообщений.
Примеры использования
Список отправителей и тем всех последних сообщений в почтовом ящике по умолчанию
imap = Net::IMAP.new('mail.example.com')
imap.authenticate('LOGIN', 'joe_user', 'joes_password')
imap.examine('INBOX')
imap.search(["RECENT"]).each do |message_id|
envelope = imap.fetch(message_id, "ENVELOPE")[0].attr["ENVELOPE"]
puts "#{envelope.from[0].name}: \t#{envelope.subject}"
end
Переместить все сообщения из апреля 2003 года из «Mail/sent-mail» в «Mail/sent-apr03»
imap = Net::IMAP.new('mail.example.com')
imap.authenticate('LOGIN', 'joe_user', 'joes_password')
imap.select('Mail/sent-mail')
if not imap.list('Mail/', 'sent-apr03')
imap.create('Mail/sent-apr03')
end
imap.search(["BEFORE", "30-Apr-2003", "SINCE", "1-Apr-2003"]).each do |message_id|
imap.copy(message_id, "Mail/sent-apr03")
imap.store(message_id, "+FLAGS", [:Deleted])
end
imap.expunge
Thread Безопасность
Net::IMAP поддерживает многопоточность. Например,
imap = Net::IMAP.new("imap.foo.net", "imap2")
imap.authenticate("cram-md5", "bar", "password")
imap.select("inbox")
fetch_thread = Thread.start { imap.fetch(1..-1, "UID") }
search_result = imap.search(["BODY", "hello"])
fetch_result = fetch_thread.value
imap.disconnect
Этот скрипт вызывает команды FETCH и SEARCH одновременно.
Ошибки
Сервер IMAP может отправлять три разных типа ответов для указания ошибки:
- NO
-
попытка выполнения команды не увенчалась успехом. Например, имя пользователя/пароль, используемые для входа, неверны; выбранный почтовый ящик не существует и т. д.
- BAD
-
запрос клиента не соответствует пониманию сервером протокола
IMAP. Это включает в себя попытки команд из неправильного состояния клиента; например, попытка выполнить команду SEARCH без выбора текущего почтового ящика. Он также может сигнализировать об внутренней ошибке сервера (например, о сбое диска). - BYE
-
сервер прощается. Это может быть частью нормальной последовательности выхода из системы, а также может использоваться в рамках последовательности входа в систему для указания того, что сервер (по какой-то причине) не хочет принимать подключение. В ответ на любую другую команду это указывает либо на то, что сервер завершает работу, либо на то, что сервер отключает подключение клиента из-за бездействия.
Эти три ответа об ошибке представлены ошибками Net::IMAP::NoResponseError, Net::IMAP::BadResponseError и Net::IMAP::ByeResponseError, которые являются подклассами Net::IMAP::ResponseError. По существу, все методы, которые подразумевают отправку запроса на сервер, могут генерировать одну из этих ошибок. Ниже описаны только наиболее важные случаи.
Поскольку класс IMAP использует сокеты для связи, его методы также уязвимы для различных ошибок, которые могут возникнуть при работе с сокетами. Они обычно представлены как ошибки Errno. Например, любой метод, предполагающий отправку запроса на сервер и/или получение ответа от него, может вызвать ошибку Errno::EPIPE, если сетевое подключение неожиданно прервётся. См. страницы руководства socket(7), ip(7), tcp(7), socket(2), connect(2) и связанные с ними.
Наконец, Net::IMAP::DataFormatError вызывается, если обнаружены неправильные низкоуровневые данные (например, при преобразовании между UTF-8 и UTF-16), а Net::IMAP::ResponseParseError — если ответ сервера не поддаётся разбору.
Ссылки
- [IMAP]
-
-
Crispin, «INTERNET MESSAGE ACCESS PROTOCOL - VERSION 4rev1»,
RFC 2060, декабрь 1996. (Примечание: устарел RFC 3501)
-
- [LANGUAGE-TAGS]
-
Alvestrand, H., «Теги для идентификации языков», RFC 1766, март 1995.
- [MD5]
-
Myers, J., и M. Rose, «Поле заголовка Content-MD5», RFC 1864, октябрь 1995.
- [MIME-IMB]
-
Freed, N., и N. Borenstein, «MIME (Multipurpose Internet Mail Extensions) Часть первая: Формат тел сообщений Интернет», RFC 2045, ноябрь 1996.
- [RFC-822]
-
Crocker, D., «Стандарт для формата текстовых сообщений ARPA Интернет», STD 11, RFC 822, Университет Делавэр, август 1982.
- [RFC-2087]
-
Myers, J., «Расширение IMAP4 QUOTA», RFC 2087, январь 1997.
- [RFC-2086]
-
Myers, J., «Расширение IMAP4
ACL», RFC 2086, январь 1997. - [RFC-2195]
-
Klensin, J., Catoe, R., и Krumviede, P., «IMAP/POP AUTHorize Расширение для простого запроса/ответа», RFC 2195, сентябрь 1997.
- [SORT-THREAD-EXT]
-
Crispin, M., «INTERNET MESSAGE ACCESS PROTOCOL - Расширения SORT и THREAD», draft-ietf-imapext-sort, май 2003.
- [OSSL]
- [RSSL]
- [UTF7]
-
Goldsmith, D. и Davis, M., «UTF-7: Формат преобразования Unicode, безопасный для почты», RFC 2152, май 1997.
Константы
- ANSWERED
-
Флаг, указывающий, что сообщение было обработано.
- Address
-
Net::IMAP::Addressпредставляет электронные адреса почты.Поля:
- name
-
Возвращает фразу из [RFC-822] почтового ящика.
- route
-
Возвращает маршрут из [RFC-822] route-addr.
- mailbox
-
nil указывает на конец группы [RFC-822]. Если не nil и host равен nil, возвращает имя группы [RFC-822]. В противном случае возвращает локальную часть [RFC-822].
- host
-
nil указывает на синтаксис группы [RFC-822]. В противном случае возвращает доменное имя [RFC-822].
- ContentDisposition
-
Net::IMAP::ContentDispositionпредставляет поля Content-Disposition.Поля:
- dsp_type
-
Возвращает тип расположения.
- param
-
Возвращает хэш, представляющий параметры поля Content-Disposition.
- ContinuationRequest
-
Net::IMAP::ContinuationRequestпредставляет запросы продолжения команд.Ответ на запрос продолжения команды указывается маркером “+” вместо тега. Такая форма ответа указывает, что сервер готов принять продолжение команды от клиента. Остальная часть этого ответа — строка текста.
continue_req ::= "+" SPACE (resp_text / base64)
Поля:
- data
-
Возвращает данные (
Net::IMAP::ResponseText). - raw_data
-
Возвращает строку исходных данных.
- DATE_MONTH
- DELETED
-
Флаг, указывающий, что сообщение помечено для удаления. Это произойдёт при закрытии или удалении почтового ящика.
- DRAFT
-
Флаг, указывающий, что сообщение является только черновиком или рабочей версией.
- Envelope
-
Net::IMAP::Envelopeпредставляет структуры конвертов сообщений.Поля:
- date
-
Возвращает строку, представляющую дату.
- subject
-
Возвращает строку, представляющую тему.
- from
-
Возвращает массив
Net::IMAP::Address, представляющий поле «от». - sender
-
Возвращает массив
Net::IMAP::Address, представляющий поле «отправлено». - reply_to
-
Возвращает массив
Net::IMAP::Address, представляющий поле «ответ». - to
-
Возвращает массив
Net::IMAP::Address, представляющий поле «кому». - cc
-
Возвращает массив
Net::IMAP::Address, представляющий поле «копия». - bcc
-
Возвращает массив
Net::IMAP::Address, представляющий поле «слепая копия». - in_reply_to
-
Возвращает строку, представляющую поле «в ответ на».
- message_id
-
Возвращает строку, представляющую идентификатор сообщения.
- FLAGGED
-
Флаг, указывающий, что сообщение помечено для особого или срочного внимания.
- FetchData
-
Net::IMAP::FetchDataпредставляет содержимое ответа FETCH.Поля:
- seqno
-
Возвращает порядковый номер сообщения. (Примечание: не уникальный идентификатор, даже для ответа команды UID.)
- attr
-
Возвращает хэш. Каждый ключ — имя элемента данных, а каждое значение — его значение.
Текущие элементы данных:
- BODY
-
Форма BODYSTRUCTURE без расширенных данных.
-
Net::IMAP::BodyTypeBasic,Net::IMAP::BodyTypeText,Net::IMAP::BodyTypeMessage,Net::IMAP::BodyTypeMultipart.
- ENVELOPE
-
Объект
Net::IMAP::Envelope, описывающий структуру конверта сообщения. - FLAGS
-
Массив символов флагов, установленных для данного сообщения. Символы флагов капитализируются с помощью
String#capitalize. - INTERNALDATE
-
Строка, представляющая внутреннюю дату сообщения.
- RFC822
-
Эквивалентно BODY[].
- RFC822.HEADER
-
Эквивалентно BODY.PEEK.
- RFC822.SIZE
-
Число, выражающее размер сообщения [RFC-822].
- RFC822.TEXT
-
Эквивалентно BODY.
- UID
-
Число, выражающее уникальный идентификатор сообщения.
Флаг, указывающий, что почтовый ящик помечен как «интересный» сервером; это обычно означает, что ящик содержит новые сообщения.
Net::IMAP::MailboxACLItem представляет ответ от GETACL.
acl_data ::= "ACL" SPACE mailbox *(SPACE identifier SPACE rights) identifier ::= astring rights ::= astring
Поля:
- user
-
Имя пользователя, имеющего определённые права на указанный почтовый ящик с помощью команды getacl.
- rights
-
Права доступа указанного пользователя к почтовому ящику.
Net::IMAP::MailboxList представляет содержимое ответа LIST.
mailbox_list ::= "(" #("\Marked" / "\Noinferiors" /
"\Noselect" / "\Unmarked" / flag_extension) ")"
SPACE (<"> QUOTED_CHAR <"> / nil) SPACE mailbox Поля:
- attr
-
Возвращает атрибуты имени. Каждый атрибут имени — символ, капитализированный с помощью
String#capitalize, например :Noselect (а не :NoSelect). - delim
-
Возвращает разделитель иерархии.
- name
-
Возвращает имя почтового ящика.
Net::IMAP::MailboxQuota представляет содержимое ответа GETQUOTA. Этот объект также может быть ответом на GETQUOTAROOT. В синтаксическом описании ниже разделитель, используемый с конструкцией “#”, — это одиночный пробел (SPACE).
quota_list ::= "(" #quota_resource ")"
quota_resource ::= atom SPACE number SPACE number
quota_response ::= "QUOTA" SPACE astring SPACE quota_list Поля:
- mailbox
-
Почтовый ящик с ассоциированным квотой.
- usage
-
Текущее использование места в почтовом ящике.
- quota
-
Предел квоты, установленный для почтового ящика.
Net::IMAP::MailboxQuotaRoot представляет часть ответа GETQUOTAROOT. (GETQUOTAROOT также может возвращать Net::IMAP::MailboxQuota.)
quotaroot_response ::= "QUOTAROOT" SPACE astring *(SPACE astring)
Поля:
- mailbox
-
Почтовый ящик с ассоциированным квотой.
- quotaroots
-
Ноль или более quotaroots, которые влияют на квоту для указанного почтового ящика.
Флаг, указывающий, что имя контекста почтового ящика не может содержать дочерние элементы.
Флаг, указывающий, что почтовый ящик не выбран.
Флаг, указывающий, что сообщение «недавнее», что означает, что этот сеанс — первый сеанс, в котором клиент получил уведомление об этом сообщении.
Net::IMAP::ResponseCode представляет коды ответов.
resp_text_code ::= "ALERT" / "PARSE" /
"PERMANENTFLAGS" SPACE "(" #(flag / "\*") ")" /
"READ-ONLY" / "READ-WRITE" / "TRYCREATE" /
"UIDVALIDITY" SPACE nz_number /
"UNSEEN" SPACE nz_number /
atom [SPACE 1*<any TEXT_CHAR except "]">] Поля:
- name
-
Возвращает имя, например «ALERT», «PERMANENTFLAGS» или «UIDVALIDITY».
- data
-
Возвращает данные, если они существуют.
Net::IMAP::ResponseText представляет тексты ответов. Текст может быть префиксным кодом ответа.
resp_text ::= ["[" resp_text_code "]" SPACE] (text_mime2 / text)
;; text SHOULD NOT begin with "[" or "=" Поля:
- code
-
Возвращает код ответа. См. ((<Net::IMAP::ResponseCode>)).
- text
-
Возвращает текст.
Флаг, указывающий, что сообщение было прочитано.
Net::IMAP::StatusData представляет содержимое ответа STATUS.
Поля:
- mailbox
-
Возвращает имя почтового ящика.
- attr
-
Возвращает хэш. Каждый ключ — один из «MESSAGES», «RECENT», «UIDNEXT», «UIDVALIDITY», «UNSEEN». Каждое значение — число.
Net::IMAP::TaggedResponse представляет помеченные ответы.
Ответ сервера о результате выполнения указывает на успех или неудачу операции. Он помечен тем же тегом, что и команда клиента, которая начала операцию.
response_tagged ::= tag SPACE resp_cond_state CRLF
tag ::= 1*<any ATOM_CHAR except "+">
resp_cond_state ::= ("OK" / "NO" / "BAD") SPACE resp_text Поля:
- tag
-
Возвращает тег.
- name
-
Возвращает имя, одно из «OK», «NO» или «BAD».
- data
-
Возвращает данные. См. ((<Net::IMAP::ResponseText>)).
- raw_data
-
Возвращает строку исходных данных.
Net::IMAP::ThreadMember представляет узел потока, возвращаемый Net::IMAP#thread.
Поля:
- seqno
-
Порядковый номер данного сообщения.
- children
-
Массив объектов
Net::IMAP::ThreadMemberдля элементов почты, являющихся дочерними для данного в потоке.
Флаг, указывающий, что почтовый ящик не содержит новых сообщений.
Net::IMAP::UntaggedResponse представляет немаркированные ответы.
Data передаваемые сервером клиенту, и ответы статуса, которые не указывают на завершение команды, предваряются маркером «*» и называются немаркированными ответами.
response_data ::= "*" SPACE (resp_cond_state / resp_cond_bye /
mailbox_data / message_data / capability_data) Поля:
- name
-
Возвращает имя, такое как «FLAGS», «LIST» или «FETCH».
- data
-
Возвращает данные, такие как массив символов флагов, объект ((<Net::IMAP::MailboxList>)).
- raw_data
-
Возвращает строку с сырыми данными.
Атрибуты
Поток для получения исключений.
Возвращает начальный ответ приветствия от сервера.
Секунды ожидания открытия подключения. Если объект IMAP не может открыть подключение в течение этого времени, он вызывает исключение Net::OpenTimeout. Значение по умолчанию — 30 секунд.
Возвращает все обработчики ответов.
Возвращает записанные немаркированные ответы. Например:
imap.select("inbox")
p imap.responses["EXISTS"][-1]
#=> 2
p imap.responses["UIDVALIDITY"][-1]
#=> 968263756
Общедоступные методы класса
# File lib/net/imap.rb, line 301 def self.add_authenticator(auth_type, authenticator) @@authenticators[auth_type] = authenticator end
Добавляет аутентификатор для Net::IMAP#authenticate. auth_type — это тип аутентификации, который поддерживает данный аутентификатор (например, «LOGIN»). authenticator — это объект, который определяет метод process() для обработки аутентификации с сервером. См. Net::IMAP::LoginAuthenticator, Net::IMAP::CramMD5Authenticator и Net::IMAP::DigestMD5Authenticator для примеров.
Если auth_type ссылается на существующий аутентификатор, он будет заменён новым.
# File lib/net/imap.rb, line 271 def self.debug return @@debug end
Возвращает режим отладки.
# File lib/net/imap.rb, line 276 def self.debug=(val) return @@debug = val end
Устанавливает режим отладки.
# File lib/net/imap.rb, line 1000
def self.decode_utf7(s)
return s.gsub(/&([^-]+)?-/n) {
if $1
($1.tr(",", "/") + "===").unpack1("m").encode(Encoding::UTF_8, Encoding::UTF_16BE)
else
"&"
end
}
end Декодирование строки из модифицированного формата UTF-7 в UTF-8.
UTF-7 — это 7-битовое кодирование Unicode [UTF7]. IMAP использует немного изменённую версию этого для кодирования имён почтовых ящиков, содержащих не-ASCII символы; см. раздел 5.1.3 [IMAP].
Net::IMAP не автоматически кодирует и декодирует имена почтовых ящиков в и из UTF-7.
# File lib/net/imap.rb, line 306 def self.default_port return PORT end
Порт по умолчанию для подключений IMAP, порт 143
# File lib/net/imap.rb, line 311 def self.default_tls_port return SSL_PORT end
Порт по умолчанию для подключений IMAPS, порт 993
# File lib/net/imap.rb, line 1011
def self.encode_utf7(s)
return s.gsub(/(&)|[^\x20-\x7e]+/) {
if $1
"&-"
else
base64 = [$&.encode(Encoding::UTF_16BE)].pack("m0")
"&" + base64.delete("=").tr("/", ",") + "-"
end
}.force_encoding("ASCII-8BIT")
end Кодирование строки из формата UTF-8 в модифицированный UTF-7.
# File lib/net/imap.rb, line 1023
def self.format_date(time)
return time.strftime('%d-%b-%Y')
end Форматирование time как даты в стиле IMAP.
# File lib/net/imap.rb, line 1028
def self.format_datetime(time)
return time.strftime('%d-%b-%Y %H:%M %z')
end Форматирование time как даты и времени в стиле IMAP.
# File lib/net/imap.rb, line 281 def self.max_flag_count return @@max_flag_count end
Возвращает максимальное количество флагов, интернированных в символы.
# File lib/net/imap.rb, line 286 def self.max_flag_count=(count) @@max_flag_count = count end
Устанавливает максимальное количество флагов, интернированных в символы.
# File lib/net/imap.rb, line 1071
def initialize(host, port_or_options = {},
usessl = false, certs = nil, verify = true)
super()
@host = host
begin
options = port_or_options.to_hash
rescue NoMethodError
# for backward compatibility
options = {}
options[:port] = port_or_options
if usessl
options[:ssl] = create_ssl_params(certs, verify)
end
end
@port = options[:port] || (options[:ssl] ? SSL_PORT : PORT)
@tag_prefix = "RUBY"
@tagno = 0
@open_timeout = options[:open_timeout] || 30
@parser = ResponseParser.new
@sock = tcp_socket(@host, @port)
begin
if options[:ssl]
start_tls_session(options[:ssl])
@usessl = true
else
@usessl = false
end
@responses = Hash.new([].freeze)
@tagged_responses = {}
@response_handlers = []
@tagged_response_arrival = new_cond
@continued_command_tag = nil
@continuation_request_arrival = new_cond
@continuation_request_exception = nil
@idle_done_cond = nil
@logout_command_tag = nil
@debug_output_bol = true
@exception = nil
@greeting = get_response
if @greeting.nil?
raise Error, "connection closed"
end
if @greeting.name == "BYE"
raise ByeResponseError, @greeting
end
@client_thread = Thread.current
@receiver_thread = Thread.start {
begin
receive_responses
rescue Exception
end
}
@receiver_thread_terminating = false
rescue Exception
@sock.close
raise
end
end Создаёт новый объект Net::IMAP и подключает его к указанному host.
options — это хэш параметров, каждый ключ которого — символ.
Доступные параметры:
- port
-
Номер порта (значение по умолчанию — 143 для imap или 993 для imaps)
- ssl
-
Если options истинно, будет выполнена попытка использования SSL (теперь TLS) для подключения к серверу. Для этого необходимо установить расширения
OpenSSL[OSSL] и RubyOpenSSL[RSSL]. Если options — хэш, он передаётся вOpenSSL::SSL::SSLContext#set_paramsв качестве параметров. -
open_timeout -
Секунды ожидания открытия подключения
Наиболее распространённые ошибки:
- Errno::ECONNREFUSED
-
Подключение отклонено
hostили промежуточным брандмауэром. - Errno::ETIMEDOUT
-
Подключение истекло (возможно, из-за потери пакетов промежуточным брандмауэром).
- Errno::ENETUNREACH
-
Маршрута к этой сети нет.
-
SocketError -
Имя хоста неизвестно или другая ошибка сокета.
-
Net::IMAP::ByeResponseError -
Подключение к хосту было успешным, но он сразу же сказал «пока».
Публичные методы экземпляра
# File lib/net/imap.rb, line 906 def add_response_handler(handler = nil, &block) raise ArgumentError, "two Procs are passed" if handler && block @response_handlers.push(block || handler) end
Добавляет обработчик ответов. Например, чтобы обнаружить, когда сервер отправляет новый ответ EXISTS (что обычно указывает на добавление новых сообщений в почтовый ящик), добавьте следующий обработчик после выбора почтового ящика:
imap.add_response_handler { |resp|
if resp.kind_of?(Net::IMAP::UntaggedResponse) and resp.name == "EXISTS"
puts "Mailbox now has #{resp.data} messages"
end
}
# File lib/net/imap.rb, line 699
def append(mailbox, message, flags = nil, date_time = nil)
args = []
if flags
args.push(flags)
end
args.push(date_time) if date_time
args.push(Literal.new(message))
send_command("APPEND", mailbox, *args)
end Отправляет команду APPEND, чтобы добавить message в конец mailbox. Необязательный аргумент flags представляет собой массив флагов, изначально переданных новому сообщению. Необязательный аргумент date_time указывает время создания, которое нужно назначить новому сообщению; по умолчанию используется текущее время. Например:
imap.append("inbox", <<EOF.gsub(/\n/, "\r\n"), [:Seen], Time.now)
Subject: hello
From: shugo@ruby-lang.org
To: shugo@ruby-lang.org
hello world
EOF
Возникает исключение Net::IMAP::NoResponseError, если почтовый ящик не существует (он не создается автоматически) или если аргументы flags, date_time или message содержат ошибки.
# File lib/net/imap.rb, line 417
def authenticate(auth_type, *args)
auth_type = auth_type.upcase
unless @@authenticators.has_key?(auth_type)
raise ArgumentError,
format('unknown auth type - "%s"', auth_type)
end
authenticator = @@authenticators[auth_type].new(*args)
send_command("AUTHENTICATE", auth_type) do |resp|
if resp.instance_of?(ContinuationRequest)
data = authenticator.process(resp.data.text.unpack("m")[0])
s = [data].pack("m0")
send_string_data(s)
put_string(CRLF)
end
end
end Отправляет команду AUTHENTICATE для аутентификации клиента. Параметр auth_type представляет собой строку, которая обозначает используемый механизм аутентификации. В настоящее время Net::IMAP поддерживает следующие механизмы аутентификации:
LOGIN:: login using cleartext user and password.
CRAM-MD5:: login with cleartext user and encrypted password
(see [RFC-2195] for a full description). This
mechanism requires that the server have the user's
password stored in clear-text password. Для обоих этих механизмов должно быть два args: имя пользователя и (открытый) пароль. Сервер может не поддерживать один или другой из этих механизмов; проверьте capability() на наличие возможности в формате «AUTH=LOGIN» или «AUTH=CRAM-MD5».
Аутентификация выполняется с использованием соответствующего объекта аутентификатора: см. @@authenticators для получения дополнительной информации о подключении собственного аутентификатора.
Например:
imap.authenticate('LOGIN', user, password)
Возникает исключение Net::IMAP::NoResponseError, если аутентификация не удалась.
# File lib/net/imap.rb, line 359
def capability
synchronize do
send_command("CAPABILITY")
return @responses.delete("CAPABILITY")[-1]
end
end Отправляет команду CAPABILITY и возвращает массив возможностей, поддерживаемых сервером. Каждая возможность представляет собой строку. См. [IMAP] для списка возможных возможностей.
Обратите внимание, что класс Net::IMAP не изменяет свое поведение в соответствии с возможностями сервера; пользователь класса должен убедиться, что определенная возможность поддерживается сервером, прежде чем использовать ее.
# File lib/net/imap.rb, line 713
def check
send_command("CHECK")
end Отправляет команду CHECK для запроса контрольной точки текущего выбранного почтового ящика. Это выполняет специфичные для реализации действия по ведению домашнего хозяйства; например, согласование состояния почтового ящика в памяти и на диске.
# File lib/net/imap.rb, line 720
def close
send_command("CLOSE")
end Отправляет команду CLOSE для закрытия текущего выбранного почтового ящика. Команда CLOSE окончательно удаляет из почтового ящика все сообщения, у которых установлен флаг Deleted.
# File lib/net/imap.rb, line 853
def copy(set, mailbox)
copy_internal("COPY", set, mailbox)
end Отправляет команду COPY для копирования указанного сообщения (сообщений) в конец указанного почтового ящика назначения mailbox. Параметр set представляет собой число, массив чисел или объект Range. Число представляет собой порядковый номер сообщения.
# File lib/net/imap.rb, line 480
def create(mailbox)
send_command("CREATE", mailbox)
end Отправляет команду CREATE для создания нового mailbox.
Возникает исключение Net::IMAP::NoResponseError, если почтовый ящик с таким именем не может быть создан.
# File lib/net/imap.rb, line 489
def delete(mailbox)
send_command("DELETE", mailbox)
end Отправляет команду DELETE для удаления mailbox.
Возникает исключение Net::IMAP::NoResponseError, если почтовый ящик с таким именем не может быть удален, либо потому что он не существует, либо потому что у клиента нет прав на его удаление.
# File lib/net/imap.rb, line 322
def disconnect
return if disconnected?
begin
begin
# try to call SSL::SSLSocket#io.
@sock.io.shutdown
rescue NoMethodError
# @sock is not an SSL::SSLSocket.
@sock.shutdown
end
rescue Errno::ENOTCONN
# ignore `Errno::ENOTCONN: Socket is not connected' on some platforms.
rescue Exception => e
@receiver_thread.raise(e)
end
@receiver_thread.join
synchronize do
@sock.close
end
raise e if e
end Отключается от сервера.
# File lib/net/imap.rb, line 345 def disconnected? return @sock.closed? end
Возвращает true, если отключено от сервера.
# File lib/net/imap.rb, line 469
def examine(mailbox)
synchronize do
@responses.clear
send_command("EXAMINE", mailbox)
end
end Отправляет команду EXAMINE для выбора mailbox, чтобы можно было получить доступ к сообщениям в mailbox. Ведет себя так же, как select(), за исключением того, что выбранный mailbox определен как доступный только для чтения.
Возникает исключение Net::IMAP::NoResponseError, если почтовый ящик не существует или по какой-либо причине недоступен для просмотра.
# File lib/net/imap.rb, line 726
def expunge
synchronize do
send_command("EXPUNGE")
return @responses.delete("EXPUNGE")
end
end Отправляет команду EXPUNGE для окончательного удаления из текущего выбранного почтового ящика всех сообщений, у которых установлен флаг Deleted.
# File lib/net/imap.rb, line 817
def fetch(set, attr, mod = nil)
return fetch_internal("FETCH", set, attr, mod)
end Отправляет команду FETCH для извлечения данных, связанных с сообщением в почтовом ящике.
Параметр set представляет собой число или диапазон между двумя числами, или массив из них. Число представляет собой порядковый номер сообщения, где -1 представляет собой '*' для использования в обозначении диапазона, например, 100..-1 интерпретируется как '100:*'. Имейте в виду, что свойство exclude_end? объекта Range игнорируется, а содержимое диапазона не зависит от порядка конечных точек диапазона в соответствии со спецификацией протокола, поэтому 1…5, 5..1 и 5…1 эквивалентны 1..5.
attr представляет собой список атрибутов для извлечения; см. документацию для Net::IMAP::FetchData для списка допустимых атрибутов.
Возвращаемое значение представляет собой массив Net::IMAP::FetchData или nil (вместо пустого массива), если нет совпадающих сообщений.
Например:
p imap.fetch(6..8, "UID")
#=> [#<Net::IMAP::FetchData seqno=6, attr={"UID"=>98}>, \\
#<Net::IMAP::FetchData seqno=7, attr={"UID"=>99}>, \\
#<Net::IMAP::FetchData seqno=8, attr={"UID"=>100}>]
p imap.fetch(6, "BODY[HEADER.FIELDS (SUBJECT)]")
#=> [#<Net::IMAP::FetchData seqno=6, attr={"BODY[HEADER.FIELDS (SUBJECT)]"=>"Subject: test\r\n\r\n"}>]
data = imap.uid_fetch(98, ["RFC822.SIZE", "INTERNALDATE"])[0]
p data.seqno
#=> 6
p data.attr["RFC822.SIZE"]
#=> 611
p data.attr["INTERNALDATE"]
#=> "12-Oct-2000 22:40:59 +0900"
p data.attr["UID"]
#=> 98
# File lib/net/imap.rb, line 639
def getacl(mailbox)
synchronize do
send_command("GETACL", mailbox)
return @responses.delete("ACL")[-1]
end
end Отправляет команду GETACL вместе с указанным mailbox. Если этот почтовый ящик существует, возвращается массив, содержащий объекты Net::IMAP::MailboxACLItem.
# File lib/net/imap.rb, line 603
def getquota(mailbox)
synchronize do
send_command("GETQUOTA", mailbox)
return @responses.delete("QUOTA")
end
end Отправляет команду GETQUOTA вместе с указанным mailbox. Если этот почтовый ящик существует, то возвращается массив, содержащий объект Net::IMAP::MailboxQuota. Эта команда обычно доступна только администратору сервера.
# File lib/net/imap.rb, line 589
def getquotaroot(mailbox)
synchronize do
send_command("GETQUOTAROOT", mailbox)
result = []
result.concat(@responses.delete("QUOTAROOT"))
result.concat(@responses.delete("QUOTA"))
return result
end
end Отправляет команду GETQUOTAROOT вместе с указанным mailbox. Эта команда обычно доступна как администраторам, так и пользователям. Если почтовый ящик существует, она возвращает массив, содержащий объекты типа Net::IMAP::MailboxQuotaRoot и Net::IMAP::MailboxQuota.
# File lib/net/imap.rb, line 953
def idle(timeout = nil, &response_handler)
raise LocalJumpError, "no block given" unless response_handler
response = nil
synchronize do
tag = Thread.current[:net_imap_tag] = generate_tag
put_string("#{tag} IDLE#{CRLF}")
begin
add_response_handler(&response_handler)
@idle_done_cond = new_cond
@idle_done_cond.wait(timeout)
@idle_done_cond = nil
if @receiver_thread_terminating
raise @exception || Net::IMAP::Error.new("connection closed")
end
ensure
unless @receiver_thread_terminating
remove_response_handler(response_handler)
put_string("DONE#{CRLF}")
response = get_tagged_response(tag, "IDLE")
end
end
end
return response
end Отправляет команду IDLE, которая ожидает уведомления о новых или удалённых сообщениях. Возвращает ответы от сервера во время IDLE.
Используйте idle_done(), чтобы выйти из режима IDLE.
Если timeout указано, этот метод возвращает результат после того, как пройдёт timeout секунд. timeout может быть использовано для поддержания соединения. Например, следующий код проверяет соединение каждые 60 секунд.
loop do
imap.idle(60) do |res|
...
end
end # File lib/net/imap.rb, line 983
def idle_done
synchronize do
if @idle_done_cond.nil?
raise Net::IMAP::Error, "not during IDLE"
end
@idle_done_cond.signal
end
end Выходит из режима IDLE.
# File lib/net/imap.rb, line 546
def list(refname, mailbox)
synchronize do
send_command("LIST", refname, mailbox)
return @responses.delete("LIST")
end
end Отправляет команду LIST и возвращает подмножество имён из полного набора всех доступных клиенту имён. refname предоставляет контекст (например, базовый каталог в иерархии почтовых ящиков на основе каталогов). mailbox задаёт почтовый ящик или (с использованием подстановочных знаков) почтовые ящики в этом контексте. В mailbox можно использовать два подстановочных знака: «*», который соответствует всем символам, включая разделитель иерархии (например, «/» в иерархии почтовых ящиков на основе каталогов на серверах UNIX); и «%», который соответствует всем символам кроме разделителя иерархии.
Если refname пусто, mailbox используется непосредственно для определения, какие почтовые ящики соответствуют. Если mailbox пусто, возвращается корневое имя refname и разделитель иерархии.
Возвращаемое значение — массив Net::IMAP::MailboxList. Например:
imap.create("foo/bar")
imap.create("foo/baz")
p imap.list("", "foo/%")
#=> [#<Net::IMAP::MailboxList attr=[:Noselect], delim="/", name="foo/">, \\
#<Net::IMAP::MailboxList attr=[:Noinferiors, :Marked], delim="/", name="foo/bar">, \\
#<Net::IMAP::MailboxList attr=[:Noinferiors], delim="/", name="foo/baz">]
# File lib/net/imap.rb, line 440
def login(user, password)
send_command("LOGIN", user, password)
end Отправляет команду LOGIN для идентификации клиента и передает текстовый password для аутентификации этого user. Обратите внимание, что в отличие от вызова authenticate() с auth_type «LOGIN», login() не использует аутентификатор входа.
Ошибка Net::IMAP::NoResponseError возникает в случае неудачной аутентификации.
# File lib/net/imap.rb, line 373
def logout
send_command("LOGOUT")
end Отправляет команду LOGOUT, чтобы сообщить серверу, что клиент закончил работу с соединением.
# File lib/net/imap.rb, line 651
def lsub(refname, mailbox)
synchronize do
send_command("LSUB", refname, mailbox)
return @responses.delete("LSUB")
end
end Отправляет команду LSUB и возвращает подмножество имён из набора имён, которые пользователь объявил «активными» или «подписанными». refname и mailbox интерпретируются так же, как для list(). Возвращаемое значение — массив Net::IMAP::MailboxList.
# File lib/net/imap.rb, line 867
def move(set, mailbox)
copy_internal("MOVE", set, mailbox)
end Отправляет команду MOVE для перемещения указанного сообщения(сообщений) в указанное конечное mailbox. Параметр set — число, массив чисел или объект Range. Число — номер последовательности сообщения. Расширение IMAP MOVE описано в [RFC-6851].
# File lib/net/imap.rb, line 367
def noop
send_command("NOOP")
end Отправляет команду NOOP на сервер. Она ничего не делает.
# File lib/net/imap.rb, line 912 def remove_response_handler(handler) @response_handlers.delete(handler) end
Удаляет обработчик ответов.
# File lib/net/imap.rb, line 500
def rename(mailbox, newname)
send_command("RENAME", mailbox, newname)
end Отправляет команду RENAME для изменения имени mailbox на newname.
Ошибка Net::IMAP::NoResponseError возникает, если почтовый ящик с именем mailbox нельзя переименовать в newname по какой-либо причине; например, потому что mailbox не существует или потому, что уже существует почтовый ящик с именем newname.
# File lib/net/imap.rb, line 773
def search(keys, charset = nil)
return search_internal("SEARCH", keys, charset)
end Отправляет команду SEARCH для поиска сообщений в почтовом ящике, соответствующих заданным критериям поиска, и возвращает номера последовательности сообщений. keys может быть либо строкой, содержащей всю строку поиска, либо одномерным массивом ключевых слов и аргументов поиска. Ниже приведены некоторые распространённые критерии поиска; полный список см. в разделе [IMAP] 6.4.4.
- <множество сообщений>
-
множество номеров последовательности сообщений. «,» обозначает интервал, «:» — диапазон. Например, «2,10:12,15» означает «2,10,11,12,15».
- BEFORE <дата>
-
сообщения с внутренней датой строго до <дата>. Аргумент даты имеет формат, похожий на 8-Aug-2002.
- BODY <строка>
-
сообщения, содержащие <строку> в своём теле.
- CC <строка>
-
сообщения, содержащие <строку> в поле CC.
- FROM <строка>
-
сообщения, содержащие <строку> в поле FROM.
- NEW
-
сообщения со флагом Recent, но без флага Seen.
- NOT <ключ-поиска>
-
отменить следующий ключ поиска.
- OR <ключ-поиска> <ключ-поиска>
-
«или» два ключа поиска вместе.
- ON <дата>
-
сообщения с внутренней датой точно равной <дата>, имеющей формат, похожий на 8-Aug-2002.
- SINCE <дата>
-
сообщения с внутренней датой равной или позже <дата>.
- SUBJECT <строка>
-
сообщения, содержащие <строку> в поле темы.
- TO <строка>
-
сообщения, содержащие <строку> в поле TO.
Например:
p imap.search(["SUBJECT", "hello", "NOT", "NEW"]) #=> [1, 6, 7, 8]
# File lib/net/imap.rb, line 456
def select(mailbox)
synchronize do
@responses.clear
send_command("SELECT", mailbox)
end
end Отправляет команду SELECT для выбора mailbox, чтобы сообщения в mailbox можно было получить.
После выбора почтового ящика вы можете получить количество элементов в этом почтовом ящике из @responses[-1], и количество последних сообщений из @responses[-1]. Обратите внимание, что эти значения могут измениться, если во время сессии прибудут новые сообщения; см. add_response_handler() для получения информации об этом событии.
Ошибка Net::IMAP::NoResponseError возникает, если почтового ящика не существует или он по каким-либо причинам недоступен для выбора.
# File lib/net/imap.rb, line 628
def setacl(mailbox, user, rights)
if rights.nil?
send_command("SETACL", mailbox, user, "")
else
send_command("SETACL", mailbox, user, rights)
end
end Отправляет команду SETACL вместе с mailbox, user и rights правами, которые пользователь должен иметь на этот почтовый ящик. Если rights равно null, права этого пользователя для этого почтового ящика будут удалены. Команды IMAP ACL описаны в [RFC-2086].
# File lib/net/imap.rb, line 615
def setquota(mailbox, quota)
if quota.nil?
data = '()'
else
data = '(STORAGE ' + quota.to_s + ')'
end
send_command("SETQUOTA", mailbox, RawData.new(data))
end Отправляет команду SETQUOTA вместе с указанными mailbox и quota. Если quota равно nil, то quota будет сброшено для этого почтового ящика. Обычно для этого необходимо войти в систему как администратор сервера. Команды квот IMAP описаны в [RFC-2087].
# File lib/net/imap.rb, line 885
def sort(sort_keys, search_keys, charset)
return sort_internal("SORT", sort_keys, search_keys, charset)
end Отправляет команду SORT для сортировки сообщений в почтовом ящике. Возвращает массив номеров последовательности сообщений. Например:
p imap.sort(["FROM"], ["ALL"], "US-ASCII") #=> [1, 2, 3, 5, 6, 7, 8, 4, 9] p imap.sort(["DATE"], ["SUBJECT", "hello"], "US-ASCII") #=> [6, 7, 8, 1]
См. [SORT-THREAD-EXT] для получения более подробной информации.
# File lib/net/imap.rb, line 378
def starttls(options = {}, verify = true)
send_command("STARTTLS") do |resp|
if resp.kind_of?(TaggedResponse) && resp.name == "OK"
begin
# for backward compatibility
certs = options.to_str
options = create_ssl_params(certs, verify)
rescue NoMethodError
end
start_tls_session(options)
end
end
end Отправляет команду STARTTLS для начала сеанса TLS.
# File lib/net/imap.rb, line 674
def status(mailbox, attr)
synchronize do
send_command("STATUS", mailbox, attr)
return @responses.delete("STATUS")[-1].attr
end
end Отправляет команду STATUS и возвращает состояние указанного mailbox. attr представляет собой список одного или нескольких атрибутов, состояния которых необходимо запросить. Поддерживаемые атрибуты включают:
MESSAGES:: the number of messages in the mailbox. RECENT:: the number of recent messages in the mailbox. UNSEEN:: the number of unseen messages in the mailbox.
Возвращаемое значение представляет собой хэш атрибутов. Например:
p imap.status("inbox", ["MESSAGES", "RECENT"])
#=> {"RECENT"=>0, "MESSAGES"=>44}
Возникает исключение Net::IMAP::NoResponseError, если значения состояния для mailbox не могут быть возвращены; например, потому что он не существует.
# File lib/net/imap.rb, line 840
def store(set, attr, flags)
return store_internal("STORE", set, attr, flags)
end Отправляет команду STORE для изменения данных, связанных с сообщениями в почтовом ящике, в частности, их флагов. Параметр set представляет собой число, массив чисел или объект Range. Каждое число — это номер последовательности сообщений. attr — это имя элемента данных для хранения: 'FLAGS' заменит список флагов сообщения на предоставленный, '+FLAGS' добавит предоставленные флаги, а '-FLAGS' удалит их. flags — это список флагов.
Возвращаемое значение представляет собой массив Net::IMAP::FetchData. Например:
p imap.store(6..8, "+FLAGS", [:Deleted])
#=> [#<Net::IMAP::FetchData seqno=6, attr={"FLAGS"=>[:Seen, :Deleted]}>, \\
#<Net::IMAP::FetchData seqno=7, attr={"FLAGS"=>[:Seen, :Deleted]}>, \\
#<Net::IMAP::FetchData seqno=8, attr={"FLAGS"=>[:Seen, :Deleted]}>]
# File lib/net/imap.rb, line 510
def subscribe(mailbox)
send_command("SUBSCRIBE", mailbox)
end Отправляет команду SUBSCRIBE, чтобы добавить указанное имя mailbox в набор «активных» или «подписанных» почтовых ящиков сервера, возвращаемых функцией lsub().
Возникает исключение Net::IMAP::NoResponseError, если подписка на mailbox невозможна; например, потому что он не существует.
# File lib/net/imap.rb, line 929
def thread(algorithm, search_keys, charset)
return thread_internal("THREAD", algorithm, search_keys, charset)
end Аналогично search(), но возвращает номера последовательности сообщений в формате потока в виде дерева Net::IMAP::ThreadMember. Поддерживаемые алгоритмы:
- ORDEREDSUBJECT
-
разделение на одноуровневые потоки в соответствии с темой, упорядоченные по дате.
- REFERENCES
-
разделение на потоки по отношениям родитель/потомок, определяемым тем, какое сообщение является ответом на какое.
В отличие от search(), charset является обязательным аргументом. US-ASCII и UTF-8 являются примерами значений.
См. [SORT-THREAD-EXT] для получения более подробной информации.
# File lib/net/imap.rb, line 858
def uid_copy(set, mailbox)
copy_internal("UID COPY", set, mailbox)
end Аналогично copy(), но set содержит уникальные идентификаторы.
# File lib/net/imap.rb, line 822
def uid_fetch(set, attr, mod = nil)
return fetch_internal("UID FETCH", set, attr, mod)
end Аналогично fetch(), но set содержит уникальные идентификаторы.
# File lib/net/imap.rb, line 872
def uid_move(set, mailbox)
copy_internal("UID MOVE", set, mailbox)
end Аналогично move(), но set содержит уникальные идентификаторы.
# File lib/net/imap.rb, line 778
def uid_search(keys, charset = nil)
return search_internal("UID SEARCH", keys, charset)
end Аналогично search(), но возвращает уникальные идентификаторы.
# File lib/net/imap.rb, line 890
def uid_sort(sort_keys, search_keys, charset)
return sort_internal("UID SORT", sort_keys, search_keys, charset)
end Аналогично sort(), но возвращает массив уникальных идентификаторов.
# File lib/net/imap.rb, line 845
def uid_store(set, attr, flags)
return store_internal("UID STORE", set, attr, flags)
end Аналогично store(), но set содержит уникальные идентификаторы.
# File lib/net/imap.rb, line 935
def uid_thread(algorithm, search_keys, charset)
return thread_internal("UID THREAD", algorithm, search_keys, charset)
end Аналогично thread(), но возвращает уникальные идентификаторы вместо номеров последовательности сообщений.
# File lib/net/imap.rb, line 520
def unsubscribe(mailbox)
send_command("UNSUBSCRIBE", mailbox)
end Отправляет команду UNSUBSCRIBE для удаления указанного имени mailbox из набора «активных» или «подписанных» почтовых ящиков сервера.
Возникает исключение Net::IMAP::NoResponseError, если отписка от mailbox невозможна; например, потому что клиент в настоящее время не подписан на него.
# File lib/net/imap.rb, line 578
def xlist(refname, mailbox)
synchronize do
send_command("XLIST", refname, mailbox)
return @responses.delete("XLIST")
end
end Отправляет команду XLIST и возвращает подмножество имен из полного набора всех имен, доступных клиенту. refname предоставляет контекст (например, базовый каталог в иерархии почтовых ящиков на основе каталогов). mailbox указывает почтовый ящик или (с помощью подстановочных знаков) почтовые ящики в этом контексте. В mailbox можно использовать два подстановочных знака: '*', который соответствует всем символам включая разделитель иерархии (например, '/' в иерархии почтовых ящиков на основе каталогов, размещенных на UNIX); и '%', который соответствует всем символам кроме разделителя иерархии.
Если refname пусто, mailbox используется напрямую для определения того, какие почтовые ящики нужно сопоставить. Если mailbox пусто, возвращаются корневое имя refname и разделитель иерархии.
Команда XLIST похожа на команду LIST, за исключением того, что возвращаемые флаги относятся к функции папки/почтового ящика, например :Sent
Возвращаемое значение представляет собой массив Net::IMAP::MailboxList. Например:
imap.create("foo/bar")
imap.create("foo/baz")
p imap.xlist("", "foo/%")
#=> [#<Net::IMAP::MailboxList attr=[:Noselect], delim="/", name="foo/">, \\
#<Net::IMAP::MailboxList attr=[:Noinferiors, :Marked], delim="/", name="foo/bar">, \\
#<Net::IMAP::MailboxList attr=[:Noinferiors], delim="/", name="foo/baz">]
Приватные методы экземпляра
# File lib/net/imap.rb, line 1459 def copy_internal(cmd, set, mailbox) send_command(cmd, MessageSet.new(set), mailbox) end
# File lib/net/imap.rb, line 1498
def create_ssl_params(certs = nil, verify = true)
params = {}
if certs
if File.file?(certs)
params[:ca_file] = certs
elsif File.directory?(certs)
params[:ca_path] = certs
end
end
if verify
params[:verify_mode] = VERIFY_PEER
else
params[:verify_mode] = VERIFY_NONE
end
return params
end # File lib/net/imap.rb, line 1427
def fetch_internal(cmd, set, attr, mod = nil)
case attr
when String then
attr = RawData.new(attr)
when Array then
attr = attr.map { |arg|
arg.is_a?(String) ? RawData.new(arg) : arg
}
end
synchronize do
@responses.delete("FETCH")
if mod
send_command(cmd, MessageSet.new(set), attr, mod)
else
send_command(cmd, MessageSet.new(set), attr)
end
return @responses.delete("FETCH")
end
end # File lib/net/imap.rb, line 1283
def generate_tag
@tagno += 1
return format("%s%04d", @tag_prefix, @tagno)
end # File lib/net/imap.rb, line 1228
def get_response
buff = String.new
while true
s = @sock.gets(CRLF)
break unless s
buff.concat(s)
if /\{(\d+)\}\r\n/n =~ s
s = @sock.read($1.to_i)
buff.concat(s)
else
break
end
end
return nil if buff.length == 0
if @@debug
$stderr.print(buff.gsub(/^/n, "S: "))
end
return @parser.parse(buff)
end # File lib/net/imap.rb, line 1212
def get_tagged_response(tag, cmd)
until @tagged_responses.key?(tag)
raise @exception if @exception
@tagged_response_arrival.wait
end
resp = @tagged_responses.delete(tag)
case resp.name
when /\A(?:NO)\z/ni
raise NoResponseError, resp
when /\A(?:BAD)\z/ni
raise BadResponseError, resp
else
return resp
end
end # File lib/net/imap.rb, line 1487
def normalize_searching_criteria(keys)
keys.collect! do |i|
case i
when -1, Range, Array
MessageSet.new(i)
else
i
end
end
end # File lib/net/imap.rb, line 1288
def put_string(str)
@sock.print(str)
if @@debug
if @debug_output_bol
$stderr.print("C: ")
end
$stderr.print(str.gsub(/\n(?!\z)/n, "\nC: "))
if /\r\n\z/n.match(str)
@debug_output_bol = true
else
@debug_output_bol = false
end
end
end # File lib/net/imap.rb, line 1141
def receive_responses
connection_closed = false
until connection_closed
synchronize do
@exception = nil
end
begin
resp = get_response
rescue Exception => e
synchronize do
@sock.close
@exception = e
end
break
end
unless resp
synchronize do
@exception = EOFError.new("end of file reached")
end
break
end
begin
synchronize do
case resp
when TaggedResponse
@tagged_responses[resp.tag] = resp
@tagged_response_arrival.broadcast
case resp.tag
when @logout_command_tag
return
when @continued_command_tag
@continuation_request_exception =
RESPONSE_ERRORS[resp.name].new(resp)
@continuation_request_arrival.signal
end
when UntaggedResponse
record_response(resp.name, resp.data)
if resp.data.instance_of?(ResponseText) &&
(code = resp.data.code)
record_response(code.name, code.data)
end
if resp.name == "BYE" && @logout_command_tag.nil?
@sock.close
@exception = ByeResponseError.new(resp)
connection_closed = true
end
when ContinuationRequest
@continuation_request_arrival.signal
end
@response_handlers.each do |handler|
handler.call(resp)
end
end
rescue Exception => e
@exception = e
synchronize do
@tagged_response_arrival.broadcast
@continuation_request_arrival.broadcast
end
end
end
synchronize do
@receiver_thread_terminating = true
@tagged_response_arrival.broadcast
@continuation_request_arrival.broadcast
if @idle_done_cond
@idle_done_cond.signal
end
end
end # File lib/net/imap.rb, line 1248
def record_response(name, data)
unless @responses.has_key?(name)
@responses[name] = []
end
@responses[name].push(data)
end # File lib/net/imap.rb, line 1411
def search_internal(cmd, keys, charset)
if keys.instance_of?(String)
keys = [RawData.new(keys)]
else
normalize_searching_criteria(keys)
end
synchronize do
if charset
send_command(cmd, "CHARSET", charset, *keys)
else
send_command(cmd, *keys)
end
return @responses.delete("SEARCH")[-1]
end
end # File lib/net/imap.rb, line 1255
def send_command(cmd, *args, &block)
synchronize do
args.each do |i|
validate_data(i)
end
tag = generate_tag
put_string(tag + " " + cmd)
args.each do |i|
put_string(" ")
send_data(i, tag)
end
put_string(CRLF)
if cmd == "LOGOUT"
@logout_command_tag = tag
end
if block
add_response_handler(&block)
end
begin
return get_tagged_response(tag, cmd)
ensure
if block
remove_response_handler(block)
end
end
end
end # File lib/net/imap.rb, line 1324
def send_data(data, tag = nil)
case data
when nil
put_string("NIL")
when String
send_string_data(data, tag)
when Integer
send_number_data(data)
when Array
send_list_data(data, tag)
when Time
send_time_data(data)
when Symbol
send_symbol_data(data)
else
data.send_data(self, tag)
end
end # File lib/net/imap.rb, line 1383
def send_list_data(list, tag = nil)
put_string("(")
first = true
list.each do |i|
if first
first = false
else
put_string(" ")
end
send_data(i, tag)
end
put_string(")")
end # File lib/net/imap.rb, line 1362
def send_literal(str, tag = nil)
synchronize do
put_string("{" + str.bytesize.to_s + "}" + CRLF)
@continued_command_tag = tag
@continuation_request_exception = nil
begin
@continuation_request_arrival.wait
e = @continuation_request_exception || @exception
raise e if e
put_string(str)
ensure
@continued_command_tag = nil
@continuation_request_exception = nil
end
end
end # File lib/net/imap.rb, line 1379 def send_number_data(num) put_string(num.to_s) end
# File lib/net/imap.rb, line 1358
def send_quoted_string(str)
put_string('"' + str.gsub(/["\\]/n, "\\\\\\&") + '"')
end # File lib/net/imap.rb, line 1343
def send_string_data(str, tag = nil)
case str
when ""
put_string('""')
when /[\x80-\xff\r\n]/n
# literal
send_literal(str, tag)
when /[(){ \x00-\x1f\x7f%*"\\]/n
# quoted string
send_quoted_string(str)
else
put_string(str)
end
end # File lib/net/imap.rb, line 1407
def send_symbol_data(symbol)
put_string("\\" + symbol.to_s)
end # File lib/net/imap.rb, line 1399
def send_time_data(time)
t = time.dup.gmtime
s = format('"%2d-%3s-%4d %02d:%02d:%02d +0000"',
t.day, DATE_MONTH[t.month - 1], t.year,
t.hour, t.min, t.sec)
put_string(s)
end # File lib/net/imap.rb, line 1463
def sort_internal(cmd, sort_keys, search_keys, charset)
if search_keys.instance_of?(String)
search_keys = [RawData.new(search_keys)]
else
normalize_searching_criteria(search_keys)
end
normalize_searching_criteria(search_keys)
synchronize do
send_command(cmd, sort_keys, charset, *search_keys)
return @responses.delete("SORT")[-1]
end
end # File lib/net/imap.rb, line 1515
def start_tls_session(params = {})
unless defined?(OpenSSL::SSL)
raise "SSL extension not installed"
end
if @sock.kind_of?(OpenSSL::SSL::SSLSocket)
raise RuntimeError, "already using SSL"
end
begin
params = params.to_hash
rescue NoMethodError
params = {}
end
context = SSLContext.new
context.set_params(params)
if defined?(VerifyCallbackProc)
context.verify_callback = VerifyCallbackProc
end
@sock = SSLSocket.new(@sock, context)
@sock.sync_close = true
@sock.hostname = @host if @sock.respond_to? :hostname=
ssl_socket_connect(@sock, @open_timeout)
if context.verify_mode != VERIFY_NONE
@sock.post_connection_check(@host)
end
end # File lib/net/imap.rb, line 1448
def store_internal(cmd, set, attr, flags)
if attr.instance_of?(String)
attr = RawData.new(attr)
end
synchronize do
@responses.delete("FETCH")
send_command(cmd, MessageSet.new(set), attr, flags)
return @responses.delete("FETCH")
end
end # File lib/net/imap.rb, line 1132
def tcp_socket(host, port)
s = Socket.tcp(host, port, :connect_timeout => @open_timeout)
s.setsockopt(:SOL_SOCKET, :SO_KEEPALIVE, true)
s
rescue Errno::ETIMEDOUT
raise Net::OpenTimeout, "Timeout to open TCP connection to " +
"#{host}:#{port} (exceeds #{@open_timeout} seconds)"
end # File lib/net/imap.rb, line 1476
def thread_internal(cmd, algorithm, search_keys, charset)
if search_keys.instance_of?(String)
search_keys = [RawData.new(search_keys)]
else
normalize_searching_criteria(search_keys)
end
normalize_searching_criteria(search_keys)
send_command(cmd, algorithm, charset, *search_keys)
return @responses.delete("THREAD")[-1]
end # File lib/net/imap.rb, line 1303
def validate_data(data)
case data
when nil
when String
when Integer
NumValidator.ensure_number(data)
when Array
if data[0] == 'CHANGEDSINCE'
NumValidator.ensure_mod_sequence_value(data[1])
else
data.each do |i|
validate_data(i)
end
end
when Time
when Symbol
else
data.validate
end
end
Ruby Core © 1993–2017 Yukihiro Matsumoto
Licensed under the Ruby License.
Ruby Standard Library © contributors
Licensed under their own licenses.