X-Git-Url: http://gitweb.michael.orlitzky.com/?p=mailshears.git;a=blobdiff_plain;f=src%2Fdovecot_mailstore.rb;h=ee12da905412a207f9e092b60507382fb84ab16d;hp=a794032c246d3c171a33193ab56c1cc823429cec;hb=6a172f997768b49c5e56cecdfcc4f67a5f11d793;hpb=198f0d2d3198311e4ccdf988cb5996f585071014 diff --git a/src/dovecot_mailstore.rb b/src/dovecot_mailstore.rb index a794032..ee12da9 100644 --- a/src/dovecot_mailstore.rb +++ b/src/dovecot_mailstore.rb @@ -1,26 +1,110 @@ +require 'src/errors' require 'src/filesystem' require 'src/mailstore' class DovecotMailstore < Mailstore + def initialize + @domain_root = Configuration::MAIL_ROOT + end + + def describe_domain(domain) + return get_domain_path(domain) + end + + def describe_account(account) + return get_account_path(account) + end + + def delete_domain(domain) + domain_path = self.get_domain_path(domain) + FileUtils.rm_rf(domain_path) + end + + def delete_account(account) + account_path = self.get_account_path(account) + FileUtils.rm_rf(account_path) + end + + def get_leftover_domains(db_domains) + # Get the list of domains according to the filesystem. + fs_domains = self.get_domains_from_filesystem() + + # Return the list of domains on the filesystem that aren't in the DB. + return (fs_domains - db_domains) + end + + def get_leftover_accounts(db_accounts) + # Get the list of accounts according to the filesystem. + fs_domains = self.get_domains_from_filesystem() + fs_accounts = self.get_accounts_from_filesystem(fs_domains) + + # And return the accounts on the filesystem that aren't in the DB. + return (fs_accounts - db_accounts) + end + + protected; + def get_domains_from_filesystem() return Filesystem.get_subdirs(@domain_root) end - def get_accounts_from_filesystem(domains) accounts = [] domains.each do |domain| - domain_path = File.join(@domain_root, domain) - usernames = Filesystem.get_subdirs(domain_path) + begin + # Throws a NonexistentDomainError if the domain's path + # doesn't exist on the filesystem. In this case, we want + # to report zero accounts. + domain_path = get_domain_path(domain) + usernames = Filesystem.get_subdirs(domain_path) - usernames.each do |username| - accounts << "#{username}@#{domain}" + usernames.each do |username| + accounts << "#{username}@#{domain}" + end + rescue NonexistentDomainError => e + # Party hard. end end return accounts end + + def get_domain_path(domain) + # Return the filesystem path for the given domain. + # That is, the directory where its mail is stored. + # Only works if the domain directory exists! + domain_path = File.join(@domain_root, domain) + + if File.directory?(domain_path) + return domain_path + else + raise NonexistentDomainError.new(domain_path) + end + end + + + def get_account_path(account) + # Return the filesystem path of this account's mailbox. + # Only works if the account exists! + if not account.include?('@') + raise InvalidAccountError.new("#{account}: Accounts must contain an '@' symbol.") + end + + account_parts = account.split('@') + user_part = account_parts[0] + domain_part = account_parts[1] + + domain_path = get_domain_path(domain_part) + account_path = File.join(domain_path, user_part) + + if File.directory?(account_path) + return account_path + else + raise NonexistentAccountError.new(account_path) + end + end + end