X-Git-Url: http://gitweb.michael.orlitzky.com/?p=mailshears.git;a=blobdiff_plain;f=bin%2Fmailshears;h=01dcb30f2a2fc2d73d22f36f2f4b43ed92800f42;hp=fc20dd3b4b7302ce536e90210d87cad474ad1e34;hb=87c9c583caca33112f88622eed8849e98bdf3a26;hpb=da71911046617ccffbb899b57162c5e6bdbb37ee diff --git a/bin/mailshears b/bin/mailshears index fc20dd3..01dcb30 100755 --- a/bin/mailshears +++ b/bin/mailshears @@ -13,28 +13,7 @@ # filesystem, but not the database. # -# We need Pathname to get the real filesystem path -# of this script (and not, for example, the path of -# a symlink which points to it. -require 'pathname' - -# This bit of magic adds the parent directory (the -# project root) to the list of ruby load paths. -# Thus, our require statements will work regardless of -# how or from where the script was run. -executable = Pathname.new(__FILE__).realpath.to_s -$: << File.dirname(executable) + '/../' - -# Load our config file. -require 'bin/configuration' - -# And the necessary classes. -require 'src/errors.rb' -require 'src/exit_codes.rb' -require 'src/dovecot_mailstore' -require 'src/postfixadmin_db' - -dms = DovecotMailstore.new(Configuration::MAIL_ROOT) +require 'mailshears' pgadb = PostfixadminDb.new(Configuration::DBHOST, Configuration::DBPORT, @@ -44,28 +23,87 @@ pgadb = PostfixadminDb.new(Configuration::DBHOST, Configuration::DBUSER, Configuration::DBPASS) + begin - # Get the list of accounts according to the filesystem. - fs_accts = dms.get_accounts_from_filesystem() -rescue StandardError => e - puts "There was an error retrieving accounts from the filesystem: #{e.to_s}" - Kernel.exit(ExitCodes::FILESYSTEM_ERROR) + # 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 according to the Postfixadmin database. - db_accts = pgadb.get_accounts_from_db() + # 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 -# Figure out which addresses are in the filesystem, but not in the -# database. -difference = [fs_accts - db_accts] +Plugin.includers.each do |plugin_class| + plugin = plugin_class.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 + # The header that we output before the list of domains/accounts. + # Just the path of this script, the current time, and the plugin name. + header = "#{$0}, " + + current_time = Time.now() + if current_time.respond_to?(:iso8601) + # Somehow this method is missing on some machines. + header += current_time.iso8601.to_s + else + # Fall back to whatever this looks like. + header += current_time.to_s + "\n" + end + + header += 'Plugin: ' + plugin_class.to_s + "\n" + puts header + puts '-' * header.size # Underline the header. + + 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 Configuration::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 -# Don't output any unnecessary junk. Cron might mail it to someone. -if difference.size > 0 - puts difference end