@@ -88,6 +88,7 @@ if ARGV[0] # path/to/people.csv or path/to/groups.csv end end agent.push + agent.send_notification puts "Completed at #{Time.now.strftime('%m/%d/%Y %I:%M %p')}\n\n" else puts "Nothing to push\n\n" bin/update_onebody @@ -1,6 +1,11 @@ site: http://localhost:3000 user_email: admin@example.com user_key: dafH2KIiAcnLEr5JxjmX2oveuczq0R6u7Ijd329DtjatgdYcKp +notifications: + from_email: noreply@crccministries.com + to_email: youremail@example.com + host: mailserver + port: 25 #converter: # name: ACS # visible: example.yml @@ -1,6 +1,11 @@ site: http://localhost:3000 user_email: admin@example.com user_key: dafH2KIiAcnLEr5JxjmX2oveuczq0R6u7Ijd329DtjatgdYcKp +notifications: + from_email: noreply@crccministries.com + to_email: youremail@example.com + host: mailserver + port: 25 converter: name: ACS visible: example_using_converter.yml @@ -4,6 +4,7 @@ require 'fastercsv' require 'highline/import' require 'activeresource' require 'digest/sha1' +require 'net/smtp' HighLine.track_eof = false lib/onebody-updateagent.rb @@ -116,6 +116,7 @@ class UpdateAgent # use ActiveResource to create/update records on remote end def push + @errors = [] puts 'Updating remote end...' index = 0 print "#{resource.name} 0/0\r"; STDOUT.flush @@ -123,7 +124,9 @@ class UpdateAgent response = resource.post(:batch, {}, records.to_xml) statuses = Hash.from_xml(response.body)['records'] statuses.select { |s| s['status'] == 'error' }.each do |status| + record = data_by_id[status['legacy_id']] puts "#{status['legacy_id']}: #{status['error']}" + @errors << {:record => record, :error => status['error']} end index += records.length print "#{resource.name} #{index}/#{@create.length + @update.length}\r"; STDOUT.flush @@ -132,6 +135,32 @@ class UpdateAgent puts end + def send_notification + if n = @options['notifications'] + puts 'Sending notification...' + if @errors and @errors.any? + subject = 'OneBody UpdateAgent Errors' + body = "There was one or more errors running UpdateAgent:\n\n" + @errors.each do |error| + body << error[:error] + "\n" + body << error[:record].inspect + "\n\n" + end + body << "\n#{@create.length} create(s) were attempted.\n#{@update.length} update(s) were attempted." + else + subject = 'OneBody UpdateAgent Success' + body = "OneBody UpdateAgent completed without any errors.\n" + body << "\n#{@create.length} create(s) were completed.\n#{@update.length} update(s) were completed." + end + Net::SMTP.start(n['host'], n['port'].to_i) do |smtp| + smtp.send_message( + "From: #{n['from_email']}\nTo: #{n['to_email']}\nSubject: #{subject}\n\n#{body}", + n['from_email'], + n['to_email'] + ) + end + end + end + def data_by_id @data_by_id ||= begin by_id = {} lib/updateagent/updateagent.rb 24a80df9adbc6594d7aae1b0489417a66fe96d15 Tim Morgan tim@timmorgan.org http://github.com/seven1m/onebody-updateagent/commit/63d8ff08056ab6a771c0daabd333dd63452c9751 63d8ff08056ab6a771c0daabd333dd63452c9751 2009-09-30T12:42:35-07:00 2009-09-30T05:14:42-07:00 Add 'notifications' section to config file. Sends email upon completion. fadf7a3fe8667727c0611161ec3ef0a2395e1e2d Tim Morgan tim@timmorgan.org