X-Git-Url: http://gitweb.michael.orlitzky.com/?p=mailshears.git;a=blobdiff_plain;f=lib%2Fcommon%2Fpostfixadmin_db_plugin.rb;fp=lib%2Fcommon%2Fpostfixadmin_db_plugin.rb;h=0000000000000000000000000000000000000000;hp=da40879ed07c03214cab62d2984d5a5da86b7cf6;hb=7f8654ed6582062a295e1be75ae70e99de41b323;hpb=bd2dabf89ab277fbe315b05e6dfa839afb5ce5ef diff --git a/lib/common/postfixadmin_db_plugin.rb b/lib/common/postfixadmin_db_plugin.rb deleted file mode 100644 index da40879..0000000 --- a/lib/common/postfixadmin_db_plugin.rb +++ /dev/null @@ -1,119 +0,0 @@ -require 'common/plugin' -require 'pg' - -module PostfixadminDbPlugin - # Code that all PostfixadminDb plugins (Prune, Rm, Mv...) will - # share. That is, we implement the Plugin interface. - include Plugin - - def initialize() - - cfg = Configuration.new() - @db_host = cfg.dbhost - @db_port = cfg.dbport - @db_opts = cfg.dbopts - @db_tty = cfg.dbtty - @db_name = cfg.dbname - @db_user = cfg.dbuser - @db_pass = cfg.dbpass - end - - - def describe_account(account) - # There's no other unique identifier in PostfixAdmin - return account - end - - - def describe_domain(domain) - # There's no other unique identifier in PostfixAdmin - return domain - end - - - def list_domains() - domains = [] - - # Just assume PostgreSQL for now. - begin - connection = PGconn.connect(@db_host, - @db_port, - @db_opts, - @db_tty, - @db_name, - @db_user, - @db_pass) - - # 'ALL' is a magic domain, and we don't want it. - sql_query = "SELECT domain FROM domain WHERE domain <> 'ALL';" - connection.query(sql_query) do |result| - domains = result.field_values('domain') - end - connection.close() - rescue PGError => e - # But pretend like we're database-agnostic in case we ever are. - raise DatabaseError.new(e) - end - - return domains - end - - - def list_users() - accounts = [] - - # Just assume PostgreSQL for now. - begin - connection = PGconn.connect(@db_host, - @db_port, - @db_opts, - @db_tty, - @db_name, - @db_user, - @db_pass) - - # If address = goto, then the alias basically says, "really - # deliver to that address; it's not an alias." - sql_query = 'SELECT username FROM mailbox;' - connection.query(sql_query) do |result| - accounts = result.field_values('username') - end - connection.close() - rescue PGError => e - # But pretend like we're database-agnostic in case we ever are. - raise DatabaseError.new(e) - end - - return accounts - end - - - def list_domains_users(domains) - usernames = [] - - # Just assume PostgreSQL for now. - begin - connection = PGconn.connect(@db_host, - @db_port, - @db_opts, - @db_tty, - @db_name, - @db_user, - @db_pass) - - sql_query = 'SELECT username FROM mailbox WHERE domain IN $1;' - - connection.query(sql_query, [domains]) do |result| - usernames = result.field_values('username') - end - - connection.close() - rescue PGError => e - # Pretend like we're database-agnostic in case we ever are. - raise DatabaseError.new(e) - end - - return usernames - end - -end