Skip to content

Commit

Permalink
✨ Parsing ESEARCH, with examples from RFC9051
Browse files Browse the repository at this point in the history
Parses +ESEARCH+ into ESearchResult, with support for:
* RFC4466 syntax
* RFC4731 `ESEARCH`
* RFC5267 `CONTEXT=SEARCH`
* RFC6203 `SEARCH=FUZZY`
* RFC9394 `PARTIAL`

For compatibility, `ESearchResult#to_a` returns an array of integers
(sequence numbers or UIDs) whenever any `ALL` or `PARTIAL` result is
available.
  • Loading branch information
nevans committed Nov 8, 2024
1 parent 2b07d65 commit c8d85c5
Show file tree
Hide file tree
Showing 13 changed files with 1,164 additions and 7 deletions.
25 changes: 20 additions & 5 deletions lib/net/imap.rb
Original file line number Diff line number Diff line change
Expand Up @@ -1934,9 +1934,9 @@ def uid_expunge(uid_set)
#
# Sends a {SEARCH command [IMAP4rev1 §6.4.4]}[https://www.rfc-editor.org/rfc/rfc3501#section-6.4.4]
# to search the mailbox for messages that match the given search +criteria+,
# and returns a SearchResult. SearchResult inherits from Array (for
# backward compatibility) but adds SearchResult#modseq when the +CONDSTORE+
# capability has been enabled.
# and returns either a SearchResult or an ESearchResult. SearchResult
# inherits from Array (for backward compatibility) but adds
# SearchResult#modseq when the +CONDSTORE+ capability has been enabled.
#
# +criteria+ is one or more search keys and their arguments, which may be
# provided as an array or a string.
Expand Down Expand Up @@ -1967,8 +1967,11 @@ def uid_expunge(uid_set)
# set}[https://www.iana.org/assignments/character-sets/character-sets.xhtml]
# used by strings in the search +criteria+. When +charset+ isn't specified,
# either <tt>"US-ASCII"</tt> or <tt>"UTF-8"</tt> is assumed, depending on
# the server's capabilities. +charset+ may be sent inside +criteria+
# instead of as a separate argument.
# the server's capabilities.
#
# _NOTE:_ Return options and +charset+ may be sent as part of +criteria+.
# Do not use the +charset+ argument when either return options or charset
# are embedded in +criteria+.
#
# Related: #uid_search
#
Expand All @@ -1988,6 +1991,12 @@ def uid_expunge(uid_set)
# # criteria string contains charset arg
# imap.search("CHARSET UTF-8 OR UNSEEN (FLAGGED SUBJECT foo)")
#
# Sending return optionsand charset embedded in the +crriteria+ arg:
# imap.search("RETURN (MIN MAX) CHARSET UTF-8 (OR UNSEEN FLAGGED)")
# imap.search(["RETURN", %w(MIN MAX),
# "CHARSET", "UTF-8",
# %w(OR UNSEEN FLAGGED)])
#
# ===== Search keys
#
# For full definitions of the standard search +criteria+,
Expand Down Expand Up @@ -2178,6 +2187,12 @@ def uid_expunge(uid_set)
#
# ===== Capabilities
#
# Return options should only be specified when the server supports
# +IMAP4rev2+ or an extension that allows them, such as +ESEARCH+.
#
# When +IMAP4rev2+ is enabled, or when the server supports +IMAP4rev2+ but
# not +IMAP4rev1+, ESearchResult is always returned instead of SearchResult.
#
# If CONDSTORE[https://www.rfc-editor.org/rfc/rfc7162.html] is supported
# and enabled for the selected mailbox, a non-empty SearchResult will
# include a +MODSEQ+ value.
Expand Down
225 changes: 225 additions & 0 deletions lib/net/imap/esearch_result.rb
Original file line number Diff line number Diff line change
@@ -0,0 +1,225 @@
# frozen_string_literal: true

module Net
class IMAP
# An Extended search result which is returned by IMAP#search,
# IMAP#uid_search, IMAP#sort, and IMAP#uid_sort instead of SearchResult
# under the following conditions:
#
# * The server supports +ESEARCH+ and a +return+ option was specified.
# * The server supports +ESORT+ and a +return+ options was specified (for
# IMAP#sort and IMAP#uid_sort).
# * The server supports +IMAP4rev2+ but _not_ +IMAP4rev1+.
# * +IMAP4rev2+ has been enabled.
#
class ESearchResult < Data.define(:tag, :uid, :data)
def initialize(tag: nil, uid: nil, data: nil)
tag => String | nil; tag = -tag if tag
uid => true | false | nil; uid = !!uid
data => Array | nil; data ||= []; data.freeze
super
end

# :call-seq: to_a -> Array of integers
#
# When either #all or #partial contains a SequenceSet of message sequence
# numbers or UIDs, +to_a+ returns that set as an array of integers.
#
# When both #all and #partial are +nil+, either because the server
# returned no results or because +ALL+ and +PARTIAL+ were not included in
# the IMAP#search +RETURN+ options, #to_a returns an empty array.
#
# Note that +to_a+ is also a valid method on SearchResult, so it can be
# used without checking if the server returned +SEARCH+ or +ESEARCH+ data.
def to_a; all&.numbers || partial&.to_a || [] end

##
# method: tag
# :call-seq: tag -> string or nil
#
# The tag of the command that caused the response to be returned.
#
# If it is missing, then the response was not caused by a particular IMAP
# command.

##
# method: uid
# :call-seq: uid -> boolean
#
# When true, all #data in the +ESEARCH+ response refers to UIDs;
# otherwise, all returned #data refers to message sequence numbers.

alias uid? uid

##
# method: data
# :call-seq: data -> array of [name, value] pairs
#
# Search return data, which can also be retrieved by #min, #max, #all,
# #count, #modseq, and other methods. Most names correspond to an
# IMAP#search +return+ option of the same name.
#
# Stored as an array of (name, value) pairs rather than as a hash, because
# extensions may allow the same name to be used more than once per result.

# :call-seq: min -> integer or nil
#
# The lowest message number/UID that satisfies the SEARCH criteria.
# Returns nil when the associated search command has no results, or when
# the +MIN+ return option wasn't specified.
#
# See +ESEARCH+ ({RFC4731
# §3.1}[https://www.rfc-editor.org/rfc/rfc4731.html#section-3.1]) or
# +IMAP4rev2+ ({RFC9051
# §7.3.4}[https://www.rfc-editor.org/rfc/rfc9051.html#section-7.3.4])
def min; data.assoc("MIN")&.last end

# :call-seq: max -> integer or nil
#
# The highest message number/UID that satisfies the SEARCH criteria.
# Returns nil when the associated search command has no results, or when
# the +MAX+ return option wasn't specified.
#
# See +ESEARCH+ ({RFC4731
# §3.1}[https://www.rfc-editor.org/rfc/rfc4731.html#section-3.1]) or
# +IMAP4rev2+ ({RFC9051
# §7.3.4}[https://www.rfc-editor.org/rfc/rfc9051.html#section-7.3.4])
def max; data.assoc("MAX")&.last end

# :call-seq: all -> sequence set or nil
#
# A SequenceSet containing all message numbers/UIDs that satisfy the
# SEARCH criteria. Returns +nil+ when the associated search command has
# no results, or when the +ALL+ return option wasn't specified.
#
# See +ESEARCH+ ({RFC4731
# §3.1}[https://www.rfc-editor.org/rfc/rfc4731.html#section-3.1]) or
# +IMAP4rev2+ ({RFC9051
# §7.3.4}[https://www.rfc-editor.org/rfc/rfc9051.html#section-7.3.4])
#
# See also: #to_a
def all; data.assoc("ALL")&.last end

# :call-seq: count -> integer or nil
#
# Returns the number of messages that satisfy the SEARCH criteria.
# Returns +nil+ when the associated search command has no results.
#
# See +ESEARCH+ ({RFC4731
# §3.1}[https://www.rfc-editor.org/rfc/rfc4731.html#section-3.1]) or
# +IMAP4rev2+ ({RFC9051
# §7.3.4}[https://www.rfc-editor.org/rfc/rfc9051.html#section-7.3.4])
def count; data.assoc("COUNT")&.last end

# :call-seq: modseq -> integer or nil
#
# The highest +mod-sequence+ of all messages in the set that satisfy the
# SEARCH criteria and result options. Returns +nil+ when the associated
# search command has no results.
#
# See +CONDSTORE+
# {[RFC7162]}[https://www.rfc-editor.org/rfc/rfc7162.html].
def modseq; data.assoc("MODSEQ")&.last end

class ContextUpdate < Data.define(:position, :set)
def initialize(position:, set:)
position = NumValidator.ensure_number(position)
set => SequenceSet
super
end

##
# method: position

##
# method: set

end

class AddToContext < ContextUpdate
end

class RemoveFromContext < ContextUpdate
end

# :call-seq: addto -> array of insertion updates, or nil
#
# Notification of updates, inserting messages into the result list for the
# command issued with #tag.
#
# See <tt>CONTEXT=SEARCH</tt>/<tt>CONTEXT=SORT</tt>
# {[RFC5267]}[https://www.rfc-editor.org/rfc/rfc5267.html]
def addto
data.flat_map { _1 == "ADDTO" ? _2 : [] }
end

# :call-seq: removefrom -> array of removal updates, or nil
#
# Notification of updates, removing messages into the result list for the
# command issued with #tag.
#
# See <tt>CONTEXT=SEARCH</tt>/<tt>CONTEXT=SORT</tt>
# {[RFC5267]}[https://www.rfc-editor.org/rfc/rfc5267.html]
def removefrom
data.flat_map { _1 == "REMOVEFROM" ? _2 : [] }
end

# :call-seq: updates -> array of context updates, or nil
#
# Notification of updates, inserting or removing messages to or from the
# result list for the command issued with #tag.
#
# See <tt>CONTEXT=SEARCH</tt>/<tt>CONTEXT=SORT</tt>
# {[RFC5267]}[https://www.rfc-editor.org/rfc/rfc5267.html]
def updates
data.flat_map { %w[ADDTO REMOVEFROM].include?(_1) ? _2 : [] }
end

# See +PARTIAL+ {[RFC9394]}[https://www.rfc-editor.org/rfc/rfc9394.html]
# or <tt>CONTEXT=SEARCH</tt>/<tt>CONTEXT=SORT</tt>
# {[RFC5267]}[https://www.rfc-editor.org/rfc/rfc5267.html]
#
# See also: #to_a
class PartialResult < Data.define(:range, :results)
def initialize(range:, results:)
range => Range
results => SequenceSet | nil
super
end

##
# method: range
# :call-seq: range -> range

##
# method: results
# :call-seq: results -> sequence set or nil

# Converts #results to an array of integers.
#
# See ESearchResult#to_a.
def to_a; results&.numbers || [] end
end

# :call-seq: partial -> PartialResult or nil
#
# Return a PartialResult with a subset of the message numbers/UIDs that
# satisfy the SEARCH criteria.
#
# See +PARTIAL+ {[RFC9394]}[https://www.rfc-editor.org/rfc/rfc9394.html]
# or <tt>CONTEXT=SEARCH</tt>/<tt>CONTEXT=SORT</tt>
# {[RFC5267]}[https://www.rfc-editor.org/rfc/rfc5267.html]
def partial; data.assoc("PARTIAL")&.last end

# :call-seq: relevancy -> integer or nil
#
# Return a relevancy score for each message that satisfies the SEARCH
# criteria.
#
# See <tt>SEARCH=FUZZY</tt>
# {[RFC6203]}[https://www.rfc-editor.org/rfc/rfc6203.html]
def relevancy; data.assoc("RELEVANCY")&.last end

end
end
end
1 change: 1 addition & 0 deletions lib/net/imap/response_data.rb
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@

module Net
class IMAP < Protocol
autoload :ESearchResult, "#{__dir__}/esearch_result"
autoload :FetchData, "#{__dir__}/fetch_data"
autoload :SearchResult, "#{__dir__}/search_result"
autoload :SequenceSet, "#{__dir__}/sequence_set"
Expand Down
Loading

0 comments on commit c8d85c5

Please sign in to comment.