Class: Mass::ProfileMTA
- Defined in:
- lib/first-line/profile_mta.rb
Constant Summary
Constants inherited from Profile
Mass::Profile::LOCKFILE_PATH, Mass::Profile::LOCK_TIMEOUT
Instance Attribute Summary
Attributes inherited from Profile
Instance Method Summary collapse
-
#inboxcheck(limit: 100, only_unread: true, logger: nil) ⇒ Object
Scrape the inbox of the profile.
Methods inherited from Profile
#acquire_lock, #child_class_instance, #class_name_from_profile_type, #connectioncheck, #download_image, #download_image_0, #initialize, object_name, #release_lock, #running?, #upload_to_dropbox_with_lock
Constructor Details
This class inherits a constructor from Mass::Profile
Instance Method Details
#inboxcheck(limit: 100, only_unread: true, logger: nil) ⇒ Object
Scrape the inbox of the profile. Return a an array of hash descriptors of outreach records.
Parameters:
-
limit: the maximum number of messages to scrape. Default: 100.
-
only_unread: if true, then only the unread messages will be scraped. This parameter is not used by :mta profiles. Default: true.
-
logger: a logger object to log the process. Default: nil.
Example of a hash descritor into the returned array: “‘
# a scraped message is always a :performed message
'status' => :performed,
# what is the outreach type?
# e.g.: :LinkedIn_DirectMessage
# decide this in the child class.
'outreach_type' => nil,
# hash descriptor of the profile who is scraping the inbox
'profile' => self.desc,
# hash descriptor of the lead who is the conversation partner
'lead' => nil,
# if the message has been sent by the profile, it is :outgoing.
# if the message has been sent by the lead, it is :incoming.
'direction' => nil,
# the content of the message
'subject' => nil,
'body' => nil,
“‘
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 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 |
# File 'lib/first-line/profile_mta.rb', line 34 def inboxcheck(limit: 100, only_unread:true, logger:nil) l = logger || BlackStack::DummyLogger.new(nil) ret = [] p = self t = self.type sources = [ {:folder=>p.desc['inbox_label'] || t.desc['default_inbox_label'], :track_field=>'imap_inbox_last_id'}, #{:folder=>p.desc['spam_label'] || t.desc['default_inbox_label'], :track_field=>'imap_spam_last_id'}, ] # connecting imap l.logs "Connecting IMAP... " imap = Net::IMAP.new( p.desc['imap_address'] || t.desc['default_imap_address'], p.desc['imap_port'] || t.desc['default_imap_port'], true ) conn = imap.login( p.desc['imap_username'], p.desc['imap_password'] ) l.logf "done (#{conn.name})" sources.each { |source| folder = source[:folder] track_field = source[:track_field] l.logs "Choosing mailbox #{folder}... " l.logs "Examine folder... " res = imap.examine(folder) l.logf "done (#{res.name})" # Gettin latest `limit` messages received, in descendent order (newer first), # in order to stop when I find the latest procesed before. l.logs "Getting latest #{limit.to_s} messages... " ids = imap.search(["SUBJECT", p.desc['search_all_wildcard']]).reverse[0..limit] l.logf "done (#{ids.size.to_s} messages)" # iterate the messages = nil ids.each { |id| l.logs "Processing message #{id.to_s.blue}... " # getting the envelope envelope = imap.fetch(id, "ENVELOPE")[0].attr["ENVELOPE"] # TODO: develop a normalization function for mail.message_id = envelope..to_s.gsub(/^</, '').gsub(/>$/, '') = envelope.in_reply_to.to_s.gsub(/^</, '').gsub(/>$/, '') # use this parameter to track a conversation thread # if this is the first message, then remember it = if .nil? # check if this message_id is the latest processed if == p.desc[track_field] l.logf "skip".yellow + " (already processed)" break #elsif envelope.subject =~ /[0-9A-Z]{7}\-[0-9A-Z]{7}/i # l.logf "Instantly warming email".red else lead_email = envelope.from[0].mailbox.to_s + '@' + envelope.from[0].host.to_s lead_name = envelope.from[0].name subject = envelope.subject body = imap.fetch(id, "BODY[]")[0].attr["BODY[]"] # analyzing bounce reports #rep = Sisimai.make(body) #is_bounce = !rep.nil? #bounce_reason = rep[0].reason if rep #bounce_diagnosticcode = rep[0].diagnosticcode if rep if lead_name.nil? l.skip(details: "lead_name is nil") elsif lead_email.nil? l.skip(details: "lead_email is nil") else h = { # a scraped message is always a :performed message 'status' => :performed, # what is the outreach type? # e.g.: :LinkedIn_DirectMessage # decide this in the child class. 'outreach_type' => :GMail_DirectMessage, # hash descriptor of the profile who is scraping the inbox 'profile' => p.desc, # hash descriptor of the lead who is the conversation partner 'lead_or_company' => { 'name' => lead_name, 'email' => lead_email, }, # if the message has been sent by the profile, it is :outgoing. # if the message has been sent by the lead, it is :incoming. 'direction' => :incoming, # the content of the message 'subject' => subject, 'body' => body, 'message_id' => , 'reply_to_message_id' => , } ret << h l.logf "done".green end end } # remember the latest message_id processed p.desc[track_field] = if l.done } # end folders.each # disconnect l.logs "Disconnecting IMAP... " res = imap.logout l.logf "done (#{res.name})" # return return ret end |