Open Build Service

rubygem-mail_agent.spec Added

@@ -0,0 +1,84 @@
+%define mod_name mail_agent
+%define mod_full_name %{mod_name}-%{version}
+
+Name:           rubygem-mail_agent
+Version:        1.1.1
+Release:        0
+Summary:        Mailserver Agent
+License:        Apache-2.0
+Group:          Development/Languages/Ruby
+URL:            https://intercom.it
+Source:         %{mod_full_name}.gem
+Source1:        mail_agent.service
+Source2:        mail_agent.tempfiles
+Source3:        mail_agent.yml
+Source4:        tomte.yml
+BuildRequires:  %{ruby >= 1.9}
+BuildRequires:  %{rubygem gem2rpm}
+BuildRequires:  ruby-macros >= 5
+
+%description
+Mail agent DB provisioning agent
+
+%package -n mail_agent
+Summary:  Mailserver Agent
+Group:    System/Daemons
+Requires: rubygem(%{mod_name}) = %{version}
+
+%description -n mail_agent
+Mail agent DB provisioning agent
+
+%prep
+
+%build
+
+%install
+%gem_install \
+  --symlink-binaries \
+  -f
+
+install -d %{buildroot}%{_sbindir}
+install -d %{buildroot}%{_sysconfdir}/tomte
+install -d %{buildroot}%{_localstatedir}/lib/tomte
+
+install -D -m 0644 %{SOURCE1} %{buildroot}%{_unitdir}/mail_agent.service
+install -D -m 0644 %{SOURCE2} %{buildroot}%{_tmpfilesdir}/mail_agent.conf
+ln -s /usr/sbin/service %{buildroot}%{_sbindir}/rcmail_agent
+install -D -m 0644 %{SOURCE3} %{buildroot}%{_sysconfdir}/tomte/mail_agent.yml
+install -D -m 0644 %{SOURCE4} %{buildroot}%{_sysconfdir}/tomte/tomte.yml
+
+%gem_packages
+
+%files -n mail_agent
+%dir %{_sysconfdir}/tomte
+%attr(0700, tomte, tomte) %dir %{_localstatedir}/lib/tomte
+
+%config(noreplace) %{_sysconfdir}/tomte/mail_agent.yml
+%config(noreplace) %{_sysconfdir}/tomte/tomte.yml
+
+%{_unitdir}/mail_agent.service
+%{_tmpfilesdir}/mail_agent.conf
+
+%{_sbindir}/rcmail_agent
+%ghost /run/mail_agent
+
+%pre -n mail_agent
+%{_bindir}/getent group  tomte >/dev/null || %{_sbindir}/groupadd -r tomte
+%{_bindir}/getent passwd tomte >/dev/null || %{_sbindir}/useradd -r -d %{_localstatedir}/lib/tomte -s /bin/false -c "intercom mail policyd" -g tomte tomte
+%service_add_pre mail_agent.service
+exit 0
+
+%preun -n mail_agent
+%service_del_preun mail_agent.service
+exit 0
+
+%post -n mail_agent
+%tmpfiles_create %_tmpfilesdir/mailserver_agent.conf
+%service_add_post mail_agent.service
+exit 0
+
+%postun -n mail_agent
+%service_del_postun mail_agent.service
+exit 0
+
+%changelog

mail_agent-1.1.0.gem/checksums.yaml.gz -> mail_agent-1.1.1.gem/checksums.yaml.gz Changed

mail_agent-1.1.0.gem/data/.gitignore -> mail_agent-1.1.1.gem/data/.gitignore Changed

mail_agent-1.1.0.gem/data/lib/mail_agent/models/policyd.rb -> mail_agent-1.1.1.gem/data/lib/mail_agent/models/policyd.rb Changed

mail_agent-1.1.0.gem/data/lib/mail_agent/models/policyd/authenticated_identity.rb -> mail_agent-1.1.1.gem/data/lib/mail_agent/models/policyd/authenticated_identity.rb Changed

mail_agent-1.1.0.gem/data/lib/mail_agent/models/policyd/client_address.rb -> mail_agent-1.1.1.gem/data/lib/mail_agent/models/policyd/client_address.rb Changed

mail_agent-1.1.1.gem/data/lib/mail_agent/models/policyd/network_address.rb Added

mail_agent-1.1.0.gem/data/lib/mail_agent/version.rb -> mail_agent-1.1.1.gem/data/lib/mail_agent/version.rb Changed

mail_agent-1.1.0.gem/data/lib/tomte/agents/mail_agent.rb -> mail_agent-1.1.1.gem/data/lib/tomte/agents/mail_agent.rb Changed

mail_agent-1.1.0.gem/data/lib/tomte/workers/mail_worker_pubsub.rb -> mail_agent-1.1.1.gem/data/lib/tomte/workers/mail_worker_pubsub.rb Changed

mail_agent-1.1.1.gem/data/lib/tomte/workers/mail_worker_rpc.rb Added

@@ -0,0 +1,93 @@
+module Tomte::Workers
+  class MailWorkerRPC < Tomte::Worker
+    
+    class RPC < Tomte::Network::API::BasicServer
+      def quotas(options = {})
+        identity = options.delete('identity')
+        address = options.delete('address')
+        raise ArgumentError, "Must specify an identity or an address" unless address.present? || identity.present?
+        object = if identity.present?
+          MailAgent::Models::Policyd::AuthenticatedIdentity.find_by(identity: identity)
+        elsif address.present?
+          MailAgent::Models::Policyd::ClientAddress.find_by(address: address)
+        end
+        tracker = object&.tracker
+        policy = object&.policy
+
+        heuristics = tracker&.heuristics&.map do | k, v |
+          v.merge(address: k)
+        end
+
+        {
+          policy: policy&.name || 'unknown',
+          disabled: !!object&.disabled,
+          disable_reason: object&.disable_reason,
+          disable_date: object&.disable_date,
+          count: { quota: policy&.count || 0, count: tracker&.count || 0 },
+          recipients: { quota: policy&.recipients || 0, count: tracker&.recipients || 0 },
+          volume: { quota: policy&.volume || 0, count: tracker&.volume || 0 },          
+          addresses: heuristics,
+          last_update: tracker&.last_update
+        }
+      end
+
+      def reset_quotas!(options = {})
+        identity = options.delete('identity')
+        address = options.delete('address')
+        raise ArgumentError, "Must specify an identity or an address" unless address.present? || identity.present?
+        
+        object = if identity.present?
+          MailAgent::Models::Policyd::AuthenticatedIdentity.find_by(identity: identity)
+        elsif address.present?
+          MailAgent::Models::Policyd::ClientAddress.find_by(address: address)
+        end
+
+        object&.reset_tracker!
+      end
+
+      def blacklisted_addresses(options = {})
+        start = options:start || 0
+        limit = options:limit || 0
+        records = MailAgent::Models::Policyd::NetworkAddress.blacklisted
+          .reorder(id: :asc)
+          .limit(limit)
+          .offset(start)
+        
+          records.as_json
+      end
+
+      def whitelisted_addresses(options = {})
+        start = options:start || 0
+        limit = options:limit || 0
+        records = MailAgent::Models::Policyd::NetworkAddress.whitelisted
+          .reorder(id: :asc)
+          .limit(limit)
+          .offset(start)
+        
+          records.as_json
+      end
+      
+      def add_whitelist(address)
+        addr = MailAgent::Models::Policyd::NetworkAddress.find_or_initialize_by(address: address)
+        addr.flags = 'w'
+        addr.notes = "Whitelisted"
+        addr.inserted = Time.new
+        addr.save!
+      end
+      
+      def remove_network_address(address)
+        addr = MailAgent::Models::Policyd::NetworkAddress.find_by(address: address)
+        addr&.destroy!
+        nil
+      end
+    end
+
+    bus :service
+
+    api :api, :bus => :service,
+              :api => config.mail:rpc_exchange,
+              :class => RPC,
+              :queue_options => { :auto_delete => true }
+       
+  end
+end
\ No newline at end of file

mail_agent-1.1.0.gem/data/support/mail_agent.service -> mail_agent-1.1.1.gem/data/support/mail_agent.service Changed

mail_agent-1.1.0.gem/metadata.gz -> mail_agent-1.1.1.gem/metadata.gz Changed

mail_agent.service Added

mail_agent.tempfiles Added

mail_agent.yml Added

@@ -0,0 +1,135 @@
+development:
+  core:
+    log_level: debug
+    debug: false
+  hel:
+    host: HEL_ADDRESS
+    username: HEL_USERNAME
+    password: HEL_PASSWORD
+  raven:
+    dsn: 
+  database:
+    email:
+      adapter: mysql2
+      encoding: utf8
+      database: DATABASE
+      pool: 5
+      host: DATABASE_ADDRESS
+      username: DATABASE_USERNAME
+      password: DATABASE_PASSWORD
+      #reconnect: false
+      #socket: /tmp/mysql.sock 
+    rate_limit:
+      adapter: mysql2
+      encoding: utf8
+      database: DATABASE
+      pool: 5
+      host: DATABASE_ADDRESS
+      username: DATABASE_USERNAME
+      password: DATABASE_PASSWORD
+      #reconnect: false
+      #socket: /tmp/mysql.sock 
+    policyd:
+      adapter: mysql2
+      encoding: utf8
+      database: DATABASE
+      pool: 5
+      host: DATABASE_ADDRESS
+      username: DATABASE_USERNAME
+      password: DATABASE_PASSWORD
+      #reconnect: false
+      #socket: /tmp/mysql.sock 
+    amavis:
+      adapter: mysql2
+      encoding: utf8
+      database: DATABASE
+      pool: 5
+      host: DATABASE_ADDRESS
+      username: DATABASE_USERNAME
+      password: DATABASE_PASSWORD
+      #reconnect: false
+      #socket: /tmp/mysql.sock 
+
+production:
+  core:
+    log_level: info
+    debug: false
+  hel:
+    host: HEL_ADDRESS
+    username: HEL_USERNAME
+    password: HEL_PASSWORD
+  raven:
+    dsn: 
+  database:
+    email:
+      adapter: mysql2
+      encoding: utf8
+      database: DATABASE
+      pool: 5
+      host: DATABASE_ADDRESS
+      username: DATABASE_USERNAME
+      password: DATABASE_PASSWORD
+      #reconnect: false
+      #socket: /tmp/mysql.sock 
+    rate_limit:
+      adapter: mysql2
+      encoding: utf8
+      database: DATABASE
+      pool: 5
+      host: DATABASE_ADDRESS
+      username: DATABASE_USERNAME
+      password: DATABASE_PASSWORD
+      #reconnect: false
+      #socket: /tmp/mysql.sock  
+    cluebringer:
+      adapter: mysql2
+      encoding: utf8
+      database: DATABASE
+      pool: 5
+      host: DATABASE_ADDRESS
+      username: DATABASE_USERNAME
+      password: DATABASE_PASSWORD
+      #reconnect: false
+      #socket: /tmp/mysql.sock  
+    amavis:
+      adapter: mysql2
+      encoding: utf8
+      database: DATABASE
+      pool: 5
+      host: DATABASE_ADDRESS
+      username: DATABASE_USERNAME
+      password: DATABASE_PASSWORD
+      #reconnect: false
+      #socket: /tmp/mysql.sock 
+
+test:
+  core:
+    log_level: debug
+    debug: false
+  hel:
+    host: HEL_ADDRESS
+    username: HEL_USERNAME
+    password: HEL_PASSWORD
+  raven:
+    dsn: 
+  database:
+    email:
+      adapter: mysql2
+      encoding: utf8
+      database: mail
+      pool: 5
+      host: DATABASE_ADDRESS
+      username: DATABASE_USERNAME
+      password: DATABASE_PASSWORD
+      #reconnect: false
+      #socket: /tmp/mysql.sock 
+    rate_limit:
+      adapter: mysql2
+      encoding: utf8
+      database: smtp_out_ng
+      pool: 5
+      host: DATABASE_ADDRESS
+      username: DATABASE_USERNAME
+      password: DATABASE_PASSWORD
+      #reconnect: false
+      #socket: /tmp/mysql.sock

tomte.yml Added

Changes of Revision 7