From 6d0b3ef31e23928795da13446338a38379732e8b Mon Sep 17 00:00:00 2001
From: Lotfi zaouche <lotfi.zaouche@gmail.com>
Date: Wed, 13 May 2020 11:13:46 +0000
Subject: [PATCH] POC prct

---
 blockchain/parity/ethpoller/mode/prct.pm | 129 +++++++++++++++++++++++
 blockchain/parity/ethpoller/plugin.pm    |   3 +-
 2 files changed, 131 insertions(+), 1 deletion(-)
 create mode 100644 blockchain/parity/ethpoller/mode/prct.pm

diff --git a/blockchain/parity/ethpoller/mode/prct.pm b/blockchain/parity/ethpoller/mode/prct.pm
new file mode 100644
index 000000000..633c13b35
--- /dev/null
+++ b/blockchain/parity/ethpoller/mode/prct.pm
@@ -0,0 +1,129 @@
+#
+# Copyright 2020 Centreon (http://www.centreon.com/)
+#
+# Centreon is a full-fledged industry-strength solution that meets
+# the needs in IT infrastructure and application monitoring for
+# service performance.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
+package blockchain::parity::ethpoller::mode::prct;
+
+use base qw(centreon::plugins::templates::counter);
+
+use strict;
+use warnings;
+use bigint;
+use Digest::MD5 qw(md5_hex);
+
+sub set_counters {
+    my ($self, %options) = @_;
+    
+    $self->{maps_counters_type} = [
+        { name => 'balances', cb_prefix_output => 'prefix_output_balances', type => 1, message_multiple => 'Balances metrics are ok' }
+    ];
+
+    $self->{maps_counters}->{balances} = [
+        { label => 'balance-fluctuation-prct', nlabel => 'parity.tracking.balances.variation.persecond', display_ok => 0, set => {
+                key_values => [],
+                manual_keys => 1,
+                closure_custom_calc => $self->can('custom_loss_calc'),
+                closure_custom_output => $self->can('custom_loss_output'),
+                threshold_use => 'balance_fluctuation',
+                perfdatas => [
+                   { value => 'balance_fluctuation', template => '%d',
+                     min => 0, label_extra_instance => 1, instance_use => 'display'  },
+                ],
+            }
+        }
+    ];
+
+}
+
+sub custom_loss_output {
+    my ($self, %options) = @_;
+
+    # use Data::Dumper;
+    # print Dumper('$total_balance');
+    return sprintf(
+        "balance variation: %.2f%% ",
+        $self->{result_values}->{balance_fluctuation}
+    );
+}
+
+sub custom_loss_calc {
+    my ($self, %options) = @_;
+
+        my $new_balance = $options{new_datas}->{$_};
+        my $old_balance = $options{old_datas}->{$_};
+    
+    # use Data::Dumper;
+    # print Dumper($total_balance);
+
+    $self->{result_values}->{display} = $options{new_datas}->{$self->{instance} . '_display'};
+    $self->{result_values}->{balance_fluctuation} = 0;
+    if ($old_balance > 0) {
+        $self->{result_values}->{balance_fluctuation} = ($new_balance - $old_balance) / $old_balance;
+    }
+
+
+}
+
+sub prefix_output_balances {
+    my ($self, %options) = @_;
+
+    return "Balance '" . $options{instance_value}->{display} . "' ";
+}
+
+sub new {
+    my ($class, %options) = @_;
+    my $self = $class->SUPER::new(package => __PACKAGE__, %options, statefile => 1, force_new_perfdata => 1);
+    bless $self, $class;
+    
+    $options{options}->add_options(arguments => {
+        "filter-name:s" => { name => 'filter_name' },
+    });
+   
+    return $self;
+}
+
+sub manage_selection {
+    my ($self, %options) = @_;
+
+    $self->{cache_name} = "parity_ethpoller_" . $self->{mode} . '_' . (defined($self->{option_results}->{hostname}) ? $self->{option_results}->{hostname} : 'me') . '_' .
+       (defined($self->{option_results}->{filter_counters}) ? md5_hex($self->{option_results}->{filter_counters}) : md5_hex('all'));
+
+    my $result = $options{custom}->request_api(url_path => '/tracking');
+    use Data::Dumper;
+    # print Dumper($result);
+
+    foreach my $balance (@{$result->{balances}}) {
+        # print Dumper($balance);
+        $self->{balances}->{$balance->{label}} = { display => $balance->{label} };
+        $self->{balances}->{$balance->{label}}->{'balance_fluctuation'} = $balance->{balance};
+    }
+
+}
+    
+
+
+1;
+
+__END__
+
+=head1 MODE
+
+Check Parity eth-poller for events, miners and balances tracking
+
+=cut
diff --git a/blockchain/parity/ethpoller/plugin.pm b/blockchain/parity/ethpoller/plugin.pm
index 48e08df5c..d28ab211d 100644
--- a/blockchain/parity/ethpoller/plugin.pm
+++ b/blockchain/parity/ethpoller/plugin.pm
@@ -35,7 +35,8 @@ sub new {
         # 'fork'      => 'blockchain::parity::ethpoller::mode::fork',
         'stats'     => 'blockchain::parity::ethpoller::mode::stats',
         'disk'      => 'blockchain::parity::ethpoller::mode::disk',
-        'tracking'  => 'blockchain::parity::ethpoller::mode::tracking'
+        'tracking'  => 'blockchain::parity::ethpoller::mode::tracking',
+        'prct'      => 'blockchain::parity::ethpoller::mode::prct'
     );
     $self->{custom_modes}{api} = 'blockchain::parity::ethpoller::custom::api';
     return $self;