X-Git-Url: http://gitweb.michael.orlitzky.com/?p=mailshears.git;a=blobdiff_plain;f=bin%2Fmailshears;h=389c1774a52dbf96dc9936bb07515404da970ee6;hp=09735ba26ba7087711a8b81605483a0b00d9ea4b;hb=777b6426d542acd0ead2e24af2cdeb5cda478a78;hpb=e3826d8926e11763837a591986d453e9ef5d9dec diff --git a/bin/mailshears b/bin/mailshears index 09735ba..389c177 100755 --- a/bin/mailshears +++ b/bin/mailshears @@ -103,9 +103,14 @@ else end +# Buffer the output so that we can avoid printing the informational +# header when no plugins produce output. +require 'stringio' +output_buffer = StringIO.new() +$stdout = output_buffer + plugin_class.includers.each do |plugin_class_includer| plugin = plugin_class_includer.new() - puts make_header(plugin_class.to_s()) if cfg.i_mean_business then runner = runner_class.new() @@ -117,89 +122,13 @@ plugin_class.includers.each do |plugin_class_includer| # appropriate runner. The Rm(Dummy)Runner have splats on their # *target arguments as well, to turn ARGV back into an array. runner.run(plugin, *ARGV) - - puts "" -end - - - -Kernel.exit(0) -pgadb = PostfixadminDb.new(cfg.dbhost, - cfg.dbport, - cfg.dbopts, - cfg.dbtty, - cfg.dbname, - cfg.dbuser, - cfg.dbpass) - - - - -begin - # Get a list of domains from the Postfixadmin database. - db_domains = pgadb.get_domains_from_db() -rescue DatabaseError => e - puts "There was an error connecting to the database: #{e.to_s}" - Kernel.exit(ExitCodes::DATABASE_ERROR) end -begin - # And the accounts. - db_accounts = pgadb.get_accounts_from_db() -rescue DatabaseError => e - puts "There was an error connecting to the database: #{e.to_s}" - Kernel.exit(ExitCodes::DATABASE_ERROR) -end - - -Plugin.includers.each do |plugin_class_includer| - plugin = plugin_class_includer.new() - - begin - leftover_domains = plugin.get_leftover_domains(db_domains) - rescue StandardError => e - puts "There was an error retrieving domains from the filesystem: #{e.to_s}" - Kernel.exit(ExitCodes::FILESYSTEM_ERROR) - end - - begin - leftover_accounts = plugin.get_leftover_accounts(db_accounts) - rescue StandardError => e - puts "There was an error retrieving accounts from the filesystem: #{e.to_s}" - Kernel.exit(ExitCodes::FILESYSTEM_ERROR) - end - - if leftover_domains.size > 0 or leftover_accounts.size > 0 - puts make_header(plugin_class.to_s()) - - leftover_domains.each do |domain| - puts "Found: #{domain} (#{plugin.describe_domain(domain)})" - end - - leftover_accounts.each do |account| - puts "Found: #{account} (#{plugin.describe_account(account)})" - end - - if cfg.i_mean_business - # We have to delete the accounts before the domain, - # otherwise they'd already be gone. - leftover_accounts.each do |account| - # Get the description before we delete the domain. - # This can still fail if the account's domain is gone. - account_description = plugin.describe_account(account) - plugin.delete_account(account) - puts "Removed: #{account} (#{account_description})" - end - - leftover_domains.each do |domain| - # Get the description before we delete the domain. - domain_description = plugin.describe_domain(domain) - plugin.delete_domain(domain) - puts "Removed: #{domain} (#{domain_description})" - end - end - - puts "" - end - +# Restore stdout, and print the header plus whatever the plugins +# produced if they produced anything. If they didn't, we avoid +# printing the header. +$stdout = STDOUT +if output_buffer.size > 0 then + puts make_header(plugin_class.to_s()) + puts output_buffer.string() end