Mahlon E. Smith
3871084daa
- Remove the runtime dependency on rake-compiler. - Use #rb_str_new instead of #rb_str_new2, the hash character array isn't null terminated. - Add various safeguards for object instantiations. - Remove the 'threaded' options for messages, folding them into 'archived'. If archiving is enabled, so is threading. - Return nil for lookups from the list object instead of raising exceptions. - Open subject indexes with the proper encodings (thanks Michael Granger!) - Allow touching and unlinking files to operate on multiple paths at once, within a single safety() wrap.
117 lines
2.6 KiB
Ruby
117 lines
2.6 KiB
Ruby
#!/usr/bin/ruby
|
|
# vim: set nosta noet ts=4 sw=4:
|
|
|
|
|
|
# A collection of messages for a specific archive thread.
|
|
#
|
|
# thread = Ezmlm::List::Thread.new( list, 'acgcbmbmeapgpfckcdol' )
|
|
# thread.subject #=> "Help - navigate on interface?"
|
|
# thread.first.date.to_s #=> "2017-05-07T14:55:05-07:00"
|
|
#
|
|
#
|
|
# == Version
|
|
#
|
|
# $Id$
|
|
#
|
|
#---
|
|
|
|
require 'pathname'
|
|
require 'ezmlm' unless defined?( Ezmlm )
|
|
|
|
|
|
### A collection of messages for a specific archive thread.
|
|
###
|
|
class Ezmlm::List::Thread
|
|
include Enumerable
|
|
|
|
### Instantiate a new thread of messages given
|
|
### a +list+ and a +thread_id+.
|
|
###
|
|
def initialize( list, thread_id )
|
|
raise ArgumentError, "Unknown list object." unless list.respond_to?( :listdir )
|
|
raise ArgumentError, "Malformed Thread ID." unless thread_id =~ /^\w{20}$/
|
|
raise "Archiving is not enabled." unless list.archived?
|
|
|
|
@list = list
|
|
@id = thread_id
|
|
@subject = nil
|
|
@messages = nil
|
|
|
|
self.load_thread
|
|
end
|
|
|
|
|
|
# The list object this message is stored in.
|
|
attr_reader :list
|
|
|
|
# The thread's identifier.
|
|
attr_reader :id
|
|
|
|
# The subject line of the thread.
|
|
attr_reader :subject
|
|
|
|
# An array of member messages.
|
|
attr_reader :messages
|
|
|
|
# An array of member authors.
|
|
attr_reader :authors
|
|
|
|
|
|
### Enumerable API: Lazy load each message ID as a
|
|
### Ezmlm::List::Message, yielding it to the block.
|
|
###
|
|
def each
|
|
self.load_thread # refresh for any thread updates since object was created
|
|
self.messages.each do |id|
|
|
yield Ezmlm::List::Message.new( self.list, id )
|
|
end
|
|
end
|
|
alias_method :each_message, :each
|
|
|
|
|
|
### Lazy load each author ID as a Ezmlm::List::Author, yielding it
|
|
### to the block.
|
|
###
|
|
def each_author
|
|
self.load_thread # refresh for any thread updates since object was created
|
|
self.authors.each do |id|
|
|
yield Ezmlm::List::Author.new( self.list, id )
|
|
end
|
|
end
|
|
|
|
|
|
#########
|
|
protected
|
|
#########
|
|
|
|
### Parse the subject index into an array of Messages.
|
|
###
|
|
def load_thread
|
|
@messages = []
|
|
@authors = []
|
|
path = self.thread_path
|
|
raise "Unknown thread: %p" % [ self.id ] unless path.exist?
|
|
|
|
path.open( 'r', encoding: Encoding::ISO8859_1 ) do |fh|
|
|
fh.each_line.with_index do |line, i|
|
|
if i.zero?
|
|
@subject = line.match( /^\w+ (.+)/ )[1]
|
|
else
|
|
match = line.match( /^(\d+):\d+:(\w+) / ) or next
|
|
self.messages << match[1].to_i
|
|
self.authors << match[2]
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
|
|
### Return the path on disk for the thread index.
|
|
###
|
|
def thread_path
|
|
prefix = self.id[ 0 .. 1 ]
|
|
hash = self.id[ 2 .. -1 ]
|
|
return self.list.listdir + 'archive' + 'subjects' + prefix + hash
|
|
end
|
|
|
|
end # class Ezmlm::List::Thread
|