From: Michael Orlitzky Date: Mon, 18 Mar 2013 22:15:51 +0000 (-0400) Subject: Add AgenDAV plugin, totally untested. X-Git-Tag: 0.0.1~103 X-Git-Url: https://gitweb.michael.orlitzky.com/?a=commitdiff_plain;h=df840dca0bcbbb7c2c814f56f72d4785665e6191;p=mailshears.git Add AgenDAV plugin, totally untested. --- diff --git a/lib/mailshears/plugins/agendav.rb b/lib/mailshears/plugins/agendav.rb new file mode 100644 index 0000000..6ea60a2 --- /dev/null +++ b/lib/mailshears/plugins/agendav.rb @@ -0,0 +1,116 @@ +require 'pg' + +class AgendavDb + + include Plugin + + def initialize() + cfg = Configuration.new() + @db_host = cfg.agendav_dbhost + @db_port = cfg.agendav_dbport + @db_opts = cfg.agendav_dbopts + @db_tty = cfg.agendav_dbtty + @db_name = cfg.agendav_dbname + @db_user = cfg.agendav_dbuser + @db_pass = cfg.agendav_dbpass + end + + + def describe_domain(domain) + # AgenDAV doesn't have a concept of domains. + return 'N/A' + end + + def describe_account(account) + if user_exists(account) + return "Username: #{account}" + else + return 'User not found' + end + end + + def delete_domain(domain) + # AgenDAV doesn't have a concept of domains. + end + + def delete_account(account) + # Delete the given username and any records in other tables + # belonging to it. + + sql_queries = ['DELETE FROM prefs WHERE username = $1::int;'] + sql_queries << 'DELETE FROM shared WHERE user_from = $1::int;' + + begin + connection = PGconn.connect(@db_host, + @db_port, + @db_opts, + @db_tty, + @db_name, + @db_user, + @db_pass) + + sql_queries.each do |sql_query| + connection.query(sql_query, [account]) + end + + connection.close() + + rescue PGError => e + # Pretend like we're database-agnostic in case we ever are. + raise DatabaseError.new(e) + end + + end + + + def get_leftover_domains(db_domains) + # AgenDAV doesn't have a concept of domains. + return [] + end + + + def get_leftover_accounts(db_accounts) + # Get a list of all users who have logged in to AgenDAV. + ad_accounts = self.get_agendav_usernames() + return ad_accounts - db_accounts + end + + + protected; + + def user_exists(account) + ad_users = get_agendav_usernames() + return ad_users.include?(account) + end + + def get_agendav_usernames() + 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 prefs)' + sql_query += 'UNION' + sql_query += '(SELECT user_from FROM shared);' + + connection.query(sql_query) 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 diff --git a/mailshears.example.conf.yml b/mailshears.example.conf.yml index 35f8b05..3701cb5 100644 --- a/mailshears.example.conf.yml +++ b/mailshears.example.conf.yml @@ -8,7 +8,7 @@ dbuser: postgres dbpass: dbname: postfix -plugins: [dovecot_mailstore, roundcube_db] +plugins: [dovecot_mailstore, roundcube_db, agendav] mail_root: /var/spool/mail/vhosts @@ -19,3 +19,11 @@ roundcube_dbtty: roundcube_dbuser: postgres roundcube_dbpass: roundcube_dbname: roundcube + +agendav_dbhost: localhost +agendav_dbport: 5432 +agendav_dbopts: +agendav_dbtty: +agendav_dbuser: postgres +agendav_dbpass: +agendav_dbname: agendav