Add the application name to the event (#10)

CHANGELOG.md

@@ -1,7 +1,10 @@
 # postgres-vacuum-monitor
 
 ## v.0.8.0
-- Also report on queries that are being blocked by another process.
+- Add the application name in the event.
+
+## v.0.8.0
+- Report on queries that are being blocked by another process.
 
 ## v.0.7.0
 - Lower the default `LongTransactions` threshold from 1 hour to 5 minutes and make this configurable via

lib/postgres/vacuum/jobs/monitor_job.rb

@@ -40,8 +40,10 @@ def perform(*)
                 BLOCKED_QUERIES,
                 database_name: name,
                 blocked_pid: row['blocked_pid'],
+                blocked_application: row['blocked_application'],
                 blocked_statement: row['blocked_statement'],
                 blocking_pid: row['blocking_pid'],
+                blocking_application: row['blocking_application'],
                 current_statement_in_blocking_process: row['current_statement_in_blocking_process']
               )
             end

lib/postgres/vacuum/monitor/version.rb

@@ -1,7 +1,7 @@
 module Postgres
   module Vacuum
     module Monitor
-      VERSION = '0.8.0'.freeze
+      VERSION = '0.9.0'.freeze
     end
   end
 end

spec/postgres/vacuum/jobs/monitor_job_spec.rb

@@ -76,8 +76,10 @@ def self.report_event(name, attributes = {})
       allow(mock_connection).to receive(:execute).with(Postgres::Vacuum::Monitor::Query.blocked_queries).and_return(
         [
           'blocked_pid' => 2,
+          'blocked_application' => 'foo',
           'blocked_statement' => 'SELECT 1 FROM products',
           'blocking_pid' => 3,
+          'blocking_application' => 'bar',
           'current_statement_in_blocking_process' => 'SELECT 2 FROM products'
         ]
       )
@@ -87,9 +89,11 @@ def self.report_event(name, attributes = {})
       expect(TestMetricsReporter).to have_received(:report_event).with(
         Postgres::Vacuum::Jobs::MonitorJob::BLOCKED_QUERIES,
         database_name: 'postgres_vacuum_monitor_test',
+        blocked_application: 'foo',
         blocked_pid: 2,
         blocked_statement: 'SELECT 1 FROM products',
         blocking_pid: 3,
+        blocking_application: 'bar',
         current_statement_in_blocking_process: 'SELECT 2 FROM products'
       )
     end