Se agregan directorios y archivo para comando.

Command/NasOnuOctetsCommand.php

@@ -0,0 +1,136 @@
+<?php
+
+namespace NasBundle\Command;
+
+use BaseStatsBundle\Command\BaseCommand;
+use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use NasBundle\SNMP\SNMP as SNMP;
+//use RedisBundle\Services\RedisService;
+
+class NasOnuOctetsCommand extends BaseCommand
+{
+
+    protected function configure()
+    {
+        $this
+            ->setName('nas:onu:octets')
+            ->setDescription('Bandwidth ONTs de NAS')
+            ->setHelp('Se requieren parámetros para poder realizar la correcta consulta. El comando requiere Redis.')
+            ->setDefinition(array(
+                new InputOption('nas-device-id', null, InputOption::VALUE_OPTIONAL, "DeviceId del NAS",1),
+                new InputOption('nas-server-id', null, InputOption::VALUE_OPTIONAL, "ServerDevice del NAS",1),
+                new InputOption('nas-ip', false, InputOption::VALUE_OPTIONAL, "IP del NAS"),
+                new InputOption('nas-community', false, InputOption::VALUE_OPTIONAL, "COMMUNITY del NAS"),
+                new InputOption('nas-snmp-library', false, InputOption::VALUE_OPTIONAL, "Versión de librería SNMP"),
+                new InputOption('save-historic', null, InputOption::VALUE_OPTIONAL, "Send data to StatsD",1)
+            ))
+        ;
+    }
+
+    /**
+     * @param InputInterface $input
+     * @param OutputInterface $output
+     */
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        parent::execute($input, $output);
+        
+        $key_olt_scan = "olt_scan_{$this->d_s}";
+        $key_olt_onu_bandwidth = "olt_bandwidth_onu_{$this->d_s}";
+        $saveHistoric = (int) $input->getOption('save-historic');
+        $inicio = microtime(true);
+
+        $SNMP = new SNMP($this->oltIp, $this->oltCommunity);
+        $library = "use".$this->oltSnmpLibrary;
+        $this->apiSNMP = $SNMP->$library();
+        
+        $dataCached = $this->getData($key_olt_scan, true);
+        $bandwidthCached = $this->getData($key_olt_onu_bandwidth, true);
+
+        if(empty($dataCached)) {
+            $this->output->writeln("Se requiere {$key_olt_scan}.");
+            $this->removeLock($this->flag);
+            return true;
+        }
+
+        //counter64
+        $inOctets = $this->getSNMP("onuInOctets","onuInOctets");
+        $outOctets = $this->getSNMP("onuOutOctets","onuOutOctets");
+
+        $sendData = array();
+
+        $subId = $this->d_s;
+        
+        $t1 = time();
+        $totalConsOut = $totalConsIn = $totalIn = $totalOut = 0;
+        foreach($dataCached as $index => $onu) {
+            
+            $sn = $onu["serialNumber"];
+            
+            (isset($inOctets[$index]))? $in1 = $inOctets[$index] : $in1 = 0;
+            (isset($outOctets[$index]))? $out1 = $outOctets[$index] : $out1 = 0;
+
+            if(isset($bandwidthCached[$index])) {
+                $t0 = $bandwidthCached[$index]['t'];
+                $in0 = $bandwidthCached[$index]['inOct'];
+                $out0 = $bandwidthCached[$index]['outOct'];
+                $inAcc = $bandwidthCached[$index]['inAcc'];
+                $outAcc = $bandwidthCached[$index]['outAcc'];
+
+                $inBandwidth = $outBandwidth = 0; 
+                 
+                if(($in1 >= $in0) && ($t1 > $t0)) {
+                    $diff = $in1 - $in0;
+                    $inAcc += $diff;
+                    $inBandwidth = ($diff / ($t1 - $t0)) * 8;
+                }
+
+                if(($out1 >= $out0) && ($t1 > $t0)) {
+                    $diff = $out1 - $out0;
+                    $outAcc += $diff;
+                    $outBandwidth = ($diff / ($t1 - $t0)) * 8;
+                }
+
+                $totalIn += $inBandwidth;
+                $totalOut += $outBandwidth;
+
+                $sendData["inbandwidth_onu_{$sn}"] = "{$inBandwidth}|g";
+                $sendData["outbandwidth_onu_{$sn}"] = "{$outBandwidth}|g";
+
+                if(date("d",$t0) != date("d",$t1)) {
+                    $inAcc = $outAcc = 0;
+                }
+
+                $totalConsOut += $outAcc;
+                $totalConsIn += $inAcc;
+                
+                $bandwidthCached[$index] = array('t' => $t1, 'inOct' => $in1, 'outOct' => $out1, 'inAcc' => $inAcc, 'outAcc' => $outAcc, 'inBand' => $inBandwidth, 'outBand' => $outBandwidth);
+            } else {
+                $bandwidthCached[$index] = array('t' => $t1, 'inOct' => $in1, 'outOct' => $out1, 'inAcc' => 0, 'outAcc' => 0, 'inBand' => 0, 'outBand' => 0);
+            }
+        }
+
+        $this->setData($key_olt_onu_bandwidth, $bandwidthCached, true);
+        
+        if($sendData && $saveHistoric) {
+            $t_start_script = microtime(true); 
+            $statsdService = $this->getContainer()->get('statsd');
+            $statsdService->send($sendData);
+            $t_end_script = microtime(true); 
+            $time = $t_end_script - $t_start_script;
+            print_r("Tiempo de envío al StatsD: {$time} ms / Cantidad: ".count($sendData).PHP_EOL);
+        }
+
+        /* Fin de bloqueo */
+        $this->removeLock($this->flag);
+
+        $fin = microtime(true);
+        $time = $fin - $inicio;
+        $this->output->writeln("Tiempo: $time segundos");
+        
+    }
+
+}

SNMP/MIB.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace NasBundle\SNMP;
+
+/**
+ * Parent class for all "MIB" extensions.
+ *
+ * @copyright Copyright (c) 2012, Open Source Solutions Limited, Dublin, Ireland
+ * @author Barry O'Donovan <barry@opensolutions.ie>
+ */
+class MIB
+{
+    /**
+     * Instance for the SNMP object
+     */
+    private $_snmp = null;
+
+
+    /**
+     * Set the SNMP instance
+     *
+     * @param NasBundle\SNMP\SNMP $snmp the SNMP instance
+     * @return NasBundle\SNMP\MIB An instance of this class for fluent interfaces
+     */
+    public function setSNMP( $snmp )
+    {
+        $this->_snmp = $snmp;
+    }
+
+    /**
+     * Get the SNMP instance
+     *
+     * @return NasBundle\SNMP\SNMP Instance of the SNMP object
+     */
+    public function getSNMP()
+    {
+        return $this->_snmp;
+    }
+
+}

SNMP/MIBS/OIDSBase.php

@@ -0,0 +1,166 @@
+<?php
+
+namespace NasBundle\SNMP\MIBS;
+
+class OIDSFiberHomeV1 extends \NasBundle\SNMP\MIB {
+    
+    const OID_authOnuListSlot               = "1.3.6.1.4.1.5875.800.3.10.1.1.2";
+    const OID_authOnuListPon                = "1.3.6.1.4.1.5875.800.3.10.1.1.3";
+    const OID_authOnuListOnuid              = "1.3.6.1.4.1.5875.800.3.10.1.1.4";
+    const OID_authOnuListMac                = "1.3.6.1.4.1.5875.800.3.10.1.1.10";
+    const OID_onuPonRxOpticalPower                = "1.3.6.1.4.1.5875.800.3.9.3.3.1.6";
+    const OID_onuPonTxOpticalPower                = "1.3.6.1.4.1.5875.800.3.9.3.3.1.7";
+    const OID_onuPonOpticalVltage                 = "1.3.6.1.4.1.5875.800.3.9.3.3.1.8";
+    const OID_onuPonOpticalTemperature            = "1.3.6.1.4.1.5875.800.3.9.3.3.1.10";
+    const OID_onuStatus                           = "1.3.6.1.4.1.5875.800.3.10.1.1.11";
+    const OID_oltPonDesc                          = "1.3.6.1.4.1.5875.800.3.9.3.4.1.3";
+    const OID_oltPonEnableStatus                  = "1.3.6.1.4.1.5875.800.3.9.3.4.1.4";
+    
+    const OID_oltPonRxOpticalPower                = "1.3.6.1.4.1.5875.800.3.9.3.7.1.2";
+    const OID_oltPonTxOpticalPower                = "1.3.6.1.4.1.5875.800.3.9.3.4.1.8";
+    const OID_oltPonOpticalVltage                 = "1.3.6.1.4.1.5875.800.3.9.3.4.1.9";
+    const OID_oltPonOpticalCurrent                = "1.3.6.1.4.1.5875.800.3.9.3.4.1.10";
+    const OID_oltPonOpticalTemperature            = "1.3.6.1.4.1.5875.800.3.9.3.4.1.11";
+    
+    
+    //Genericos
+    const OID_ifHCInOctets                        = "1.3.6.1.2.1.31.1.1.1.6";
+    const OID_ifHCOutOctets                       = "1.3.6.1.2.1.31.1.1.1.10";
+    const OID_ifInOctets                          = "1.3.6.1.2.1.2.2.1.10";
+    const OID_ifOutOctets                         = "1.3.6.1.2.1.2.2.1.16";
+    const OID_ifDescr                             = "1.3.6.1.2.1.2.2.1.2";
+
+    const OID_cardCpu                             = "1.3.6.1.4.1.5875.800.3.9.8.1.1.5";
+    const OID_cardMemory                          = "1.3.6.1.4.1.5875.800.3.9.8.1.1.6";
+    
+
+    function convertIndex($index, $values) {
+        $data = array();
+        foreach($values as $i => $v) {
+            if(isset($index[$i])) {
+                $data[$index[$i]] = $v;
+            }
+        }
+        if(!empty($index)) return $data;
+        
+        return $values;
+    }
+    
+    public function onuSlot() {
+        return $this->getSNMP()->lastOidWalk(self::OID_authOnuListSlot,14);
+    }
+
+    public function onuPon() {
+        return $this->getSNMP()->lastOidWalk(self::OID_authOnuListPon,14);
+    }
+    
+    public function onuOnuid() {
+        return $this->getSNMP()->lastOidWalk(self::OID_authOnuListOnuid,14);
+    }
+
+    public function onuSerialNumber($index = null) {
+        if(is_null($index)) {
+            return $this->getSNMP()->lastOidWalk(self::OID_authOnuListMac,14);
+        } 
+        
+        $values = $this->getSNMP()->lastOidWalk(self::OID_authOnuListMac,14);
+        return $this->convertIndex($index, $values);
+    }
+    
+    public function onuPonRxOpticalPower($index = null) {
+        if(is_null($index)) {
+            return $this->getSNMP()->lastOidWalk(self::OID_onuPonRxOpticalPower,15);
+        } 
+        
+        $values = $this->getSNMP()->lastOidWalk(self::OID_onuPonRxOpticalPower,15);
+        return $this->convertIndex($index, $values);
+       
+    }
+    
+    public function onuPonTxOpticalPower($index = null) {
+        if(is_null($index)) {
+            return $this->getSNMP()->lastOidWalk(self::OID_onuPonTxOpticalPower,15);
+        } 
+
+        $values = $this->getSNMP()->lastOidWalk(self::OID_onuPonTxOpticalPower,15);
+        return $this->convertIndex($index, $values);
+    }
+    
+    public function onuPonOpticalVltage($index = null) {
+        $values = $this->getSNMP()->lastOidWalk(self::OID_onuPonOpticalVltage,15);
+        return $this->convertIndex($index, $values);
+    }
+    
+    public function onuPonOpticalTemperature($index = null) {
+        $values = $this->getSNMP()->lastOidWalk(self::OID_onuPonOpticalTemperature,15);
+        return $this->convertIndex($index, $values);
+    }
+    
+    public function onuStatus($index = null) {
+        $values = $this->getSNMP()->lastOidWalk(self::OID_onuStatus,14);
+        return $this->convertIndex($index, $values);
+    }
+    
+    /* OLT PON */
+    public function oltPonDesc($index = null) {
+        return $this->getSNMP()->lastOidWalk(self::OID_oltPonDesc,15);
+    }
+
+    public function oltPonEnableStatus($index = null) {
+        return $this->getSNMP()->lastOidWalk(self::OID_oltPonEnableStatus,15);
+//        return $this->convertIndex($index, $values);
+    }
+    
+    public function oltPonRxOpticalPower($index = null) {
+        return $this->getSNMP()->lastOidWalk(self::OID_oltPonRxOpticalPower,15);
+//        return $this->convertIndex($index, $values);
+    }
+    
+    public function oltPonTxOpticalPower($index = null) {
+        return $this->getSNMP()->lastOidWalk(self::OID_oltPonTxOpticalPower,15);
+//        return $this->convertIndex($index, $values);
+    }
+    
+    public function oltPonOpticalVltage($index = null) {
+        return $this->getSNMP()->lastOidWalk(self::OID_oltPonOpticalVltage,15);
+//        return $this->convertIndex($index, $values);
+    }
+    
+    public function oltPonOpticalCurrent($index = null) {
+        return $this->getSNMP()->lastOidWalk(self::OID_oltPonOpticalCurrent,15);
+//        return $this->convertIndex($index, $values);
+    }
+    
+    public function oltPonOpticalTemperature($index = null) {
+        return $this->getSNMP()->lastOidWalk(self::OID_oltPonOpticalTemperature,15);
+//        return $this->convertIndex($index, $values);
+    }
+    
+    public function ifInOctets() {
+        return $this->getSNMP()->lastOidWalk(self::OID_ifInOctets,11);
+    }
+    
+    public function ifOutOctets() {
+        return $this->getSNMP()->lastOidWalk(self::OID_ifOutOctets,11);
+    }
+    
+    public function ifHCInOctets() {
+        return $this->getSNMP()->lastOidWalk(self::OID_ifHCInOctets,12);
+    }
+    
+    public function ifHCOutOctets() {
+        return $this->getSNMP()->lastOidWalk(self::OID_ifHCOutOctets,12);
+    }
+    
+    public function ifDescr() {
+        return $this->getSNMP()->lastOidWalk(self::OID_ifDescr,11);
+    }
+
+    public function oltCardCpu($index = null) {
+        return $this->getSNMP()->lastOidWalk(self::OID_cardCpu,15);
+    }
+    
+    public function oltCardMemory($index = null) {
+        return $this->getSNMP()->lastOidWalk(self::OID_cardMemory,15);
+    }
+}

SNMP/SNMP.php

@@ -0,0 +1,730 @@
+<?php
+
+namespace NasBundle\SNMP;
+use \Exception;
+use \Cache;
+
+class SNMP
+{
+    /**
+     * The SNMP community to use when polling SNMP services. Defaults to 'public' by the constructor.
+     *
+     * @var string The SNMP community to use when polling SNMP services. Defaults to 'public' by the constructor.
+     */
+    protected $_community;
+
+    /**
+     * The SNMP host to query. Defaults to '127.0.0.1'
+     * @var string The SNMP host to query. Defaults to '127.0.0.1' by the constructor.
+     */
+    protected $_host;
+
+    /**
+     * The SNMP query timeout value (microseconds). Default: 1000000
+     * @var int The SNMP query timeout value (microseconds). Default: 1000000
+     */
+    protected $_timeout = 100000000;
+
+    /**
+     * The SNMP query retry count. Default: 5
+     * @var int The SNMP query retry count. Default: 5
+     */
+    protected $_retry = 5;
+
+
+    /**
+     * A variable to hold the last unaltered result of an SNMP query
+     * @var mixed The last unaltered result of an SNMP query
+     */
+    protected $_lastResult = null;
+
+    /**
+     * The cache object to use as the cache
+     * @var \Cache The cache object to use
+     */
+    protected $_cache = null;
+
+    /**
+     * Set to true to disable local cache lookup and force SNMP queries
+     *
+     * Results are still stored. If you need to force a SNMP query, you can:
+     *
+     * $snmp = new OSS_SNMP( ... )'
+     * ...
+     * $snmp->disableCache();
+     * $snmp->get( ... );
+     * $snmp->enableCache();
+     */
+    protected $_disableCache = false;
+
+    /**
+     * SNMP output constants to mirror those of PHP
+     * @var SNMP output constants to mirror those of PHP
+     */
+    const OID_OUTPUT_FULL    = SNMP_OID_OUTPUT_FULL;
+
+    /**
+     * SNMP output constants to mirror those of PHP
+     * @var SNMP output constants to mirror those of PHP
+     */
+    const OID_OUTPUT_NUMERIC = SNMP_OID_OUTPUT_NUMERIC;
+
+
+    /**
+     * Definition of an SNMP return type 'TruthValue'
+     * @var Definition of an SNMP return type 'TruthValue'
+     */
+    const SNMP_TRUTHVALUE_TRUE  = 1;
+
+    /**
+     * Definition of an SNMP return type 'TruthValue'
+     * @var Definition of an SNMP return type 'TruthValue'
+     */
+    const SNMP_TRUTHVALUE_FALSE = 2;
+
+    /**
+     * PHP equivalents of SNMP return type TruthValue
+     * @var array PHP equivalents of SNMP return type TruthValue
+     */
+    public static $SNMP_TRUTHVALUES = array(
+        self::SNMP_TRUTHVALUE_TRUE  => true,
+        self::SNMP_TRUTHVALUE_FALSE => false
+    );
+
+    /**
+     * The constructor.
+     *
+     * @param string $host The target host for SNMP queries.
+     * @param string $community The community to use for SNMP queries.
+     * @return NasBundle\SNMP\SNMP An instance of $this (for fluent interfaces)
+     */
+    public function __construct( $host = '127.0.0.1', $community = 'public' )
+    {
+        return $this->setHost( $host )
+                    ->setCommunity( $community )
+                    ->setOidOutputFormat( self::OID_OUTPUT_NUMERIC );
+    }
+
+
+    /**
+     * Proxy to the snmp2_real_walk command
+     *
+     * @param string $oid The OID to walk
+     * @return array The results of the walk
+     */
+    public function realWalk( $oid )
+    {
+        return $this->_lastResult = @snmp2_real_walk( $this->getHost(), $this->getCommunity(), $oid, $this->getTimeout(), $this->getRetry() );
+    }
+
+
+    /**
+     * Get a single SNMP value
+     *
+     * @throws \Exception On *any* SNMP error, warnings are supressed and a generic exception is thrown
+     * @param string $oid The OID to get
+     * @return mixed The resultant value
+     */
+    public function get( $oid )
+    {
+        if( $this->cache() && ( $rtn = $this->getCache()->load( $oid ) ) !== null )
+            return $rtn;
+
+        $this->_lastResult = @snmp2_get( $this->getHost(), $this->getCommunity(), $oid, $this->getTimeout(), $this->getRetry() );
+
+        if( $this->_lastResult === false )
+            throw new Exception( 'Cound not perform walk for OID ' . $oid );
+
+        return $this->getCache()->save( $oid, $this->parseSnmpValue( $this->_lastResult ) );
+    }
+
+    /**
+     * Get indexed SNMP values (first degree)
+     *
+     * Walks the SNMP tree returning an array of key => value pairs.
+     *
+     * This is a first degree walk and it will throw an exception if there is more that one degree of values.
+     *
+     * I.e. the following query with sample results:
+     *
+     * walk1d( '.1.0.8802.1.1.2.1.3.7.1.4' )
+     *
+     *       .1.0.8802.1.1.2.1.3.7.1.4.1 = STRING: "GigabitEthernet1/0/1"
+     *       .1.0.8802.1.1.2.1.3.7.1.4.2 = STRING: "GigabitEthernet1/0/2"
+     *       .1.0.8802.1.1.2.1.3.7.1.4.3 = STRING: "GigabitEthernet1/0/3"
+     *       .....
+     *
+     * would yield an array:
+     *
+     *      1 => GigabitEthernet1/0/1
+     *      2 => GigabitEthernet1/0/2
+     *      3 => GigabitEthernet1/0/3
+     *
+     * @param string $oid The OID to walk
+     * @return array The resultant values
+     * @throws \Exception On *any* SNMP error, warnings are supressed and a generic exception is thrown
+     */
+    public function walk1d( $oid )
+    {
+        if( $this->cache() && ( $rtn = $this->getCache()->load( $oid ) ) !== null )
+            return $rtn;
+
+        $this->_lastResult = @snmp2_real_walk( $this->getHost(), $this->getCommunity(), $oid, $this->getTimeout(), $this->getRetry() );
+
+        if( $this->_lastResult === false )
+            throw new Exception( 'Cound not perform walk for OID ' . $oid );
+
+        $result = array();
+
+        $oidPrefix = null;
+        foreach( $this->_lastResult as $_oid => $value )
+        {
+            if( $oidPrefix !== null && $oidPrefix != substr( $_oid, 0, strrpos( $_oid, '.' ) ) )
+                throw new Exception( 'Requested OID tree is not a first degree indexed SNMP value' );
+            else
+                $oidPrefix = substr( $_oid, 0, strrpos( $_oid, '.' ) );
+
+            $result[ substr( $_oid, strrpos( $_oid, '.' ) + 1 ) ] = $this->parseSnmpValue( $value );
+        }
+
+        return $this->getCache()->save( $oid, $result );
+    }
+
+    /**
+     * Get indexed SNMP values where the array key is the given position of the OID
+     *
+     * I.e. the following query with sample results:
+     *
+     * subOidWalk( '.1.3.6.1.4.1.9.9.23.1.2.1.1.9', 15 )
+     *
+     *
+     *       .1.3.6.1.4.1.9.9.23.1.2.1.1.9.10101.5 = Hex-STRING: 00 00 00 01
+     *       .1.3.6.1.4.1.9.9.23.1.2.1.1.9.10105.2 = Hex-STRING: 00 00 00 01
+     *       .1.3.6.1.4.1.9.9.23.1.2.1.1.9.10108.4 = Hex-STRING: 00 00 00 01
+     *
+     * would yield an array:
+     *
+     *      10101 => Hex-STRING: 00 00 00 01
+     *      10105 => Hex-STRING: 00 00 00 01
+     *      10108 => Hex-STRING: 00 00 00 01
+     *
+     * @throws \Exception On *any* SNMP error, warnings are supressed and a generic exception is thrown
+     * @param string $oid The OID to walk
+     * @param int $position The position of the OID to use as the key
+     * @return array The resultant values
+     */
+    public function subOidWalk( $oid, $position )
+    {
+        if( $this->cache() && ( $rtn = $this->getCache()->load( $oid ) ) !== null )
+            return $rtn;
+
+        $this->_lastResult = @snmp2_real_walk( $this->getHost(), $this->getCommunity(), $oid, $this->getTimeout(), $this->getRetry() );
+
+        if( $this->_lastResult === false )
+            throw new Exception( 'Cound not perform walk for OID ' . $oid );
+
+        $result = array();
+
+        foreach( $this->_lastResult as $_oid => $value )
+        {
+            $oids = explode( '.', $_oid );
+
+            $result[ $oids[ $position] ] = $this->parseSnmpValue( $value );
+        }
+
+        return $this->getCache()->save( $oid, $result );
+    }
+
+
+
+    /**
+     * Get indexed SNMP values where they are indexed by IPv4 addresses
+     *
+     * I.e. the following query with sample results:
+     *
+     * subOidWalk( '.1.3.6.1.2.1.15.3.1.1. )
+     *
+     *
+     *       .1.3.6.1.2.1.15.3.1.1.10.20.30.4 = IpAddress: 192.168.10.10
+     *       ...
+     *
+     * would yield an array:
+     *
+     *      [10.20.30.4] => "192.168.10.10"
+     *      ....
+     *
+     * @throws \Exception On *any* SNMP error, warnings are supressed and a generic exception is thrown
+     * @param string $oid The OID to walk
+     * @return array The resultant values
+     */
+    public function walkIPv4( $oid )
+    {
+        if( $this->cache() && ( $rtn = $this->getCache()->load( $oid ) ) !== null )
+            return $rtn;
+
+        $this->_lastResult = @snmp2_real_walk( $this->getHost(), $this->getCommunity(), $oid, $this->getTimeout(), $this->getRetry() );
+
+        if( $this->_lastResult === false )
+            throw new Exception( 'Cound not perform walk for OID ' . $oid );
+
+        $result = array();
+
+        foreach( $this->_lastResult as $_oid => $value )
+        {
+            $oids = explode( '.', $_oid );
+
+            $len = count( $oids );
+
+            $result[ $oids[ $len - 4 ] . '.' . $oids[ $len - 3 ] . '.' . $oids[ $len - 2 ] . '.' . $oids[ $len - 1 ]  ] = $this->parseSnmpValue( $value );
+        }
+
+        return $this->getCache()->save( $oid, $result );
+    }
+
+
+
+    /**
+     * Parse the result of an SNMP query into a PHP type
+     *
+     * For example, [STRING: "blah"] is parsed to a PHP string containing: blah
+     *
+     * @param string $v The value to parse
+     * @return mixed The parsed value
+     * @throws Exception
+     */
+    public function parseSnmpValue( $v )
+    {
+        // first, rule out an empty string
+        if( $v == '""' || $v == '' )
+            return "";
+
+        $type = substr( $v, 0, strpos( $v, ':' ) );
+        $value = trim( substr( $v, strpos( $v, ':' ) + 1 ) );
+
+        switch( $type )
+        {
+            case 'STRING':
+                if($value == '"-"') return "";
+                    
+                if( substr( $value, 0, 1 ) == '"' )
+                    $rtn = (string)trim( substr( substr( $value, 1 ), 0, -1 ) );
+                else
+                    $rtn = (string)$value;
+                break;
+
+            case 'INTEGER': //case : INTEGER : someText(intValue) // INTEGER : -3.15 Unidad
+                if( strpos( $value, '(' ) !== false and substr($value, 0,1) != '-'){
+                    $rtn = (float)substr( substr( $value, strpos( $value, '(' ) + 1 ), 0);
+                }else{
+                    $rtn = (float)$value;
+		}
+
+		if($rtn == (int)$rtn) $rtn = (int) $rtn;
+                break;
+
+            case 'Counter32':
+            case 'Counter64':
+                $rtn = (int)$value;
+                break;
+
+            case 'Gauge32':
+            case 'Gauge64':
+                $rtn = (int)$value;
+                break;
+
+            case 'Hex-STRING':
+                $rtn = (string)implode( '', explode( ' ', $value ) );
+                break;
+
+            case 'IpAddress':
+                $rtn = (string)$value;
+                break;
+
+            case 'Timeticks':
+                $rtn = (int)substr( $value, 1, strrpos( $value, ')' ) - 1 );
+                break;
+
+            default:
+                throw new Exception( "ERR: Unhandled SNMP return type: $type\n" );
+        }
+
+        return $rtn;
+    }
+
+    /**
+     * Utility function to convert TruthValue SNMP responses to true / false
+     *
+     * @param integer $value The TruthValue ( 1 => true, 2 => false) to convert
+     * @return boolean
+     */
+    public static function ppTruthValue( $value )
+    {
+        if( is_array( $value ) )
+            foreach( $value as $k => $v )
+                $value[$k] = self::$SNMP_TRUTHVALUES[ $v ];
+        else
+            $value = self::$SNMP_TRUTHVALUES[ $value ];
+
+        return $value;
+    }
+
+    /**
+     * Utility function to translate one value(s) to another via an associated array
+     *
+     * I.e. all elements '$value' will be replaced with $translator( $value ) where
+     * $translator is an associated array.
+     *
+     * Huh? Just read the code below!
+     *
+     * @param mixed $values A scalar or array or values to translate
+     * @param array $translator An associated array to use to translate the values
+     * @return mixed The translated scalar or array
+     */
+    public static function translate( $values, $translator )
+    {
+        if( !is_array( $values ) )
+        {
+            if( isset( $translator[ $values ] ) )
+                return $translator[ $values ];
+            else
+                return "*** UNKNOWN ***";
+        }
+
+        foreach( $values as $k => $v )
+        {
+            if( isset( $translator[ $v ] ) )
+                $values[$k] = $translator[ $v ];
+            else
+                $values[$k] = "*** UNKNOWN ***";
+        }
+
+        return $values;
+    }
+
+    /**
+     * Sets the output format for SNMP queries.
+     *
+     * Should be one of the class OID_OUTPUT_* constants
+     *
+     * @param int $f The fomat to use
+     * @return NasBundle\SNMP\SNMP An instance of $this (for fluent interfaces)
+     */
+    public function setOidOutputFormat( $f )
+    {
+        snmp_set_oid_output_format( $f );
+        return $this;
+    }
+
+
+    /**
+     * Sets the target host for SNMP queries.
+     *
+     * @param string $h The target host for SNMP queries.
+     * @return NasBundle\SNMP\SNMP An instance of $this (for fluent interfaces)
+     */
+    public function setHost( $h )
+    {
+        $this->_host = $h;
+
+        // clear the temporary result cache and last result
+        $this->_lastResult = null;
+        unset( $this->_resultCache );
+        $this->_resultCache = array();
+
+        return $this;
+    }
+
+    /**
+     * Returns the target host as currently configured for SNMP queries
+     *
+     * @return string The target host as currently configured for SNMP queries
+     */
+    public function getHost()
+    {
+        return $this->_host;
+    }
+
+    /**
+     * Sets the community string to use for SNMP queries.
+     *
+     * @param string $c The community to use for SNMP queries.
+     * @return NasBundle\SNMP\SNMP An instance of $this (for fluent interfaces)
+     */
+    public function setCommunity( $c )
+    {
+        $this->_community = $c;
+        return $this;
+    }
+
+    /**
+     * Returns the community string currently in use.
+     *
+     * @return string The community string currently in use.
+     */
+    public function getCommunity()
+    {
+        return $this->_community;
+    }
+
+    /**
+     * Sets the timeout to use for SNMP queries (microseconds).
+     *
+     * @param int $t The timeout to use for SNMP queries (microseconds).
+     * @return NasBundle\SNMP\SNMP An instance of $this (for fluent interfaces)
+     */
+    public function setTimeout( $t )
+    {
+        $this->_timeout = $t;
+        return $this;
+    }
+
+    /**
+     * Returns the SNMP query timeout (microseconds).
+     *
+     * @return int The the SNMP query timeout (microseconds)
+     */
+    public function getTimeout()
+    {
+        return $this->_timeout;
+    }
+
+    /**
+     * Sets the SNMP query retry count.
+     *
+     * @param int $r The SNMP query retry count
+     * @return NasBundle\SNMP\SNMP An instance of $this (for fluent interfaces)
+     */
+    public function setRetry( $r )
+    {
+        $this->_retry = $r;
+        return $this;
+    }
+
+    /**
+     * Returns the SNMP query retry count
+     *
+     * @return string The SNMP query retry count
+     */
+    public function getRetry()
+    {
+        return $this->_retry;
+    }
+
+    /**
+     * Returns the unaltered original last SNMP result
+     *
+     * @return mixed The unaltered original last SNMP result
+     */
+    public function getLastResult()
+    {
+        return $this->_lastResult;
+    }
+
+    /**
+     * Returns the internal result cache
+     *
+     * @return array The internal result cache
+     */
+    public function getResultCache()
+    {
+        return $this->_resultCache;
+    }
+
+
+    /**
+     * Disable lookups of the local cache
+     *
+     * @return SNMP An instance of this for fluent interfaces
+     */
+    public function disableCache()
+    {
+        $this->_disableCache = true;
+        return $this;
+    }
+
+
+    /**
+     * Enable lookups of the local cache
+     *
+     * @return SNMP An instance of this for fluent interfaces
+     */
+    public function enableCache()
+    {
+        $this->_disableCache = false;
+        return $this;
+    }
+
+    /**
+     * Query whether we are using the cache or not
+     *
+     * @return boolean True of the local lookup cache is enabled. Otherwise false.
+     */
+    public function cache()
+    {
+        return !$this->_disableCache;
+    }
+
+    /**
+     * Set the cache to use
+     *
+     * @param \OSS_SNMP\Cache $c The cache to use
+     * @return NasBundle\SNMP\SNMP For fluent interfaces
+     */
+    public function setCache( $c )
+    {
+        $this->_cache = $c;
+        return $this;
+    }
+
+    /**
+     * Get the cache in use (or create a Cache\Basic instance
+     *
+     * We kind of mandate the use of a cache as the code is written with a cache in mind.
+     * You are free to disable it via disableCache() but your machines may be hammered!
+     *
+     * We would suggest disableCache() / enableCache() used in pairs only when really needed.
+     *
+     * @return \OSS_SNMP\Cache The cache object
+     */
+    public function getCache()
+    {
+        if( $this->_cache === null )
+            $this->_cache = new \OSS_SNMP\Cache\Basic();
+
+        return $this->_cache;
+    }
+
+
+    /**
+     * Magic method for generic function calls
+     *
+     * @param string $method
+     * @param array $args
+     * @throws Exception
+     */
+    public function __call( $method, $args )
+    {
+        if( substr( $method, 0, 3 ) == 'use' )
+            return $this->useExtension( substr( $method, 3 ), $args );
+
+        throw new Exception( "ERR: Unknown method requested in magic __call(): $method\n" );
+    }
+
+
+    /**
+     * This is the MIB Extension magic
+     *
+     * Calling $this->useXXX_YYY_ZZZ()->fn() will instantiate
+     * an extension MIB class is the given name and this $this SNMP
+     * instance and then call fn().
+     *
+     * See the examples for more information.
+     *
+     * @param string $mib The extension class to use
+     * @param array $args
+     * @return NasBundle\MIBS
+     */
+    public function useExtension( $mib, $args )
+    {
+        $mib = 'NasBundle\\SNMP\\MIBS\\' . str_replace( '_', '\\', $mib );
+        $m = new $mib();
+        $m->setSNMP( $this );
+        return $m;
+    }
+    
+    /**
+     * Retorna la última parte del oid, iniciando desde $position
+     *
+     * I.e. the following query with sample results:
+     *
+     * lastOidWalk( '1.3.6.1.4.1.13464.1.11.3.1.1.2', 14 )
+     *
+     * tener en cuenta que retorna con . por delante y realiza explode por .
+     * 
+     *      .1.3.6.1.4.1.13464.1.11.3.1.1.2.0.1 2
+     *      .1.3.6.1.4.1.13464.1.11.3.1.1.2.0.2 2
+     *      .1.3.6.1.4.1.13464.1.11.3.1.1.2.0.3 2
+     *      .1.3.6.1.4.1.13464.1.11.3.1.1.2.0.4 2
+     *      
+     * Posiciones:
+     *        .  1  .  3  .  6  .  1  .  4  .  1  .  13464  .  1  .  11  .  3  .  1  .  1  .  2  .  0  .  4   2 
+     *      0    1     2     3     4     5     6       7       8     9      10    11    12    13    14    15  value
+     *
+     * Would yield an array:
+     *
+     *      [0.1] => 2
+     *      [0.2] => 2
+     *      [0.3] => 2
+     *      [0.4] => 2
+     *
+     *
+     * @throws \Exception On *any* SNMP error, warnings are supressed and a generic exception is thrown
+     * @param string $oid The OID to walk
+     * @param int $position The position of the OID to use as the key
+     * @return array The resultant values
+     */
+    public function lastOidWalk( $oid, $position)
+    {
+        if( $this->cache() && ( $rtn = $this->getCache()->load( $oid ) ) !== null )
+            return $rtn;
+
+        $this->_lastResult = @snmp2_real_walk( $this->getHost(), $this->getCommunity(), $oid, $this->getTimeout(), $this->getRetry() );
+
+        if( $this->_lastResult === false )
+            throw new Exception( 'Cound not perform walk for OID ' . $oid );
+
+        $result = array();
+
+        foreach( $this->_lastResult as $_oid => $value )
+        {
+            $oids = explode( '.', $_oid );
+
+            $_oids = array_slice($oids, $position);
+            $oid = implode(".", $_oids);
+            
+            $result[ $oid ] = $this->parseSnmpValue( $value );
+        }
+
+        return $this->getCache()->save( $oid, $result );
+    }
+    
+    /**
+     * Proxy to the snmprealwalk command
+     *
+     * @param string $oid The OID to walk
+     * @return array The results of the walk
+     */
+    public function realWalkV1( $oid )
+    {
+        return $this->_lastResult = @snmprealwalk( $this->getHost(), $this->getCommunity(), $oid, $this->getTimeout(), $this->getRetry() );
+    }
+    
+    public function lastOidWalkV1( $oid, $position )
+    {
+        if( $this->cache() && ( $rtn = $this->getCache()->load( $oid ) ) !== null )
+            return $rtn;
+
+        $this->_lastResult = @snmprealwalk( $this->getHost(), $this->getCommunity(), $oid, $this->getTimeout(), $this->getRetry() );
+
+        if( $this->_lastResult === false )
+            throw new Exception( 'Cound not perform walk for OID ' . $oid );
+
+        $result = array();
+
+        foreach( $this->_lastResult as $_oid => $value )
+        {
+            $oids = explode( '.', $_oid );
+
+            $_oids = array_slice($oids, $position);
+            $oid = implode(".", $_oids);
+            
+            $result[ $oid ] = $this->parseSnmpValue( $value );
+        }
+
+        return $this->getCache()->save( $oid, $result );
+        
+    }
+    
+}
+
+

keys/gogs.drone.id_rsa

@@ -0,0 +1,51 @@
+-----BEGIN RSA PRIVATE KEY-----
+MIIJKgIBAAKCAgEAv3JFQcLLXAWvLO8dYHdGI70zQ/XATfl79Ogrh+uA6IZqcgJD
+FFkP3cpvI0PNrOsX8tOIraEFf9/UTg+gzQ1Up2NPEN3UB+u7C3uVUa0BZ2XuNLah
+1kxZDT5u4zyxFTq/1YFILwkCi7NJxxwlTE4c5fuWoNKj3lOwzd2lSGN4FaP1irMk
+zCgwxOU0HUGHLjrmjuW1j7LPzd8vvRyVH7bY+Biie5cuH9Vb2tIp+lSc2/FCVswc
+3eAKmVK+acLQ8Lo4MoJtllxHJhUW27gUdtFXI+nHHwBvkm/mY5+DV4CY7nC5903l
+Y6tekpLsnPDNsY2gvnH83f+thLKU8REcIdv/5kI4CCeJr5wf5lEqFbogDw0ooRKp
+dKxMxjfyzdHxgXgNoGSQtHWKxfwOe5Y4tloqAlpptzgWY9aYI7ZsLXWDAhWEKF0T
+RbV6EkvZs3S3J2oKiqE3HJUu3Y3gxr5j8gCK/iafc1R86kLxtleEr2FyPNneyzYi
+nlJIAKgwHuDcqjqXyzKB4xNus76wg+2/RDqNp8lgPHFiVcXV6n6auplbEIMm41J0
+GfxpSOfQl1bLGgiyPpNzJ3m2qprGyEa1D+NQlhSDKMgqj5bruWkzk5EG2rBceurn
+mU3h5z8jniFb5xZ54IF5yEI5PssBiUW/fnl1m1FNU5BHyhGMSG1pAgPNQ8MCAwEA
+AQKCAgAxg6Zx6aWa+UVjQ7y/VFnpqGd37jl8cUgkAWAw2TIP8aPaNMeQnbBC1raD
+0meBj5Q0E43ICltXxVYtklEud4IrgL3USOsr2UYZJC9sXmh8i5peO9YDjN+DU2Bu
+mSXbrcQrvjIjKBtmckpkmtzyrUlAGh/NHG2RdOfHdsnmvQMz5aH963Na8hIa+oTO
+BEKoLEexMawRrFeekVjRenD/MNVQ5V4wxNsDFLWbFLwSqIuhPva/aC8XG3jiSspA
+pEhR2nfqaF1bhCZKrS2qSiPQzzfQbAg59mzk3NgjcAASQ4pKMRGH6renXY0qL6HO
+vWEVyOGIIAcci6IfLejjqF80SqgWPPfrCZL9sdczzQekQDVD8Gz9mfgrDWYXBL1r
+uXYyXRc8cYgWKqd6NzuqoImKVRenbVs2up3E3N+E4B6LxwezUelpDjvcYaKzg7hn
+RWZ1VBo1k+PYnGZ+lV7rs6Q4kueSYLcZdLzVqhKdIcP23wtR8rj+wZgYw5SQ3Mly
+Fu7aDU89lv6aRSncDJzS5NvWXpMoGqmmaUXu8AHBuGS3Xxca+fokFSxZ7EGwn3R1
+UVEYH1GIEI7W3o53xmwoCrBNt9w7YzGHvbE84uQXXs5hDKphNb2b1WPM+Yx2vS39
+83Eo7vy599JQDwr8E91ZRN1foizDU99nOHAxR2446hpat1wokQKCAQEA5Vs0JkdG
+bl4vCaawys9xkr//FJK3nvyaa/nwhHs7DHPxdDiIPiZajgnrSDdYXr8/4woEchuo
+p7W6p5Yn/3wHyaXzK+eyf80SeTYKzCB+wUn9X+4lQ8ncNtVx7fFbnZBmYdxk1oER
+/rPdTnUf22zis93X7sOOtPGCVuJNLvDJuB4XAOfKCxn5zTxLr03HnQCEaeYNQfVA
+cQQaQCzBFSClaU3HcbjLkVi6ygKrioomtfARTZnEWYrIF2++6jfGojs1r3ExqCpo
+hPqUOvOBo8Tfnzb5cLYpKGh9gpveUHbkCX2kWa/bQbEOGqCy8Phnd2phb1JcQylE
+MqBdMXXdUUkX5QKCAQEA1a+rWsqAi8alHypycHwzbYbWv6+JpahOrDftuLn4cBtt
+YREpbRrS0Nrw9l+wWHvCDvC36TkOFxssE5ZRQWpaDoms5+AcJK7yAxd8WT16b05v
+veU/NKbHtUQK+ykm99WSDiQytlCB7Dc24Zg0hr4zbE9niOBW4GgJZeZwdGBmFJCO
+fhT1bDEQeka0usrZZ07AY5bNyRyMtVGfCQSWeOx8D4fh+3zxjeYKlH/i1HayQJRV
+LJzz4mEDVYSM/Qgb6WzOND4c9IyDcIiv74ueXwYkwAebl0Hdab/ZqCj5dWHhP1g6
+wfVdUc1JJLZN8hVY7OSwrN3FIXMTPiuPCf/RVOxihwKCAQEAySnCRqSTILBY30Ul
+oOxrd8QQLXI1vStfIb9ZdklDVDvJFh+TV7d6C0Sl6XQpfQiPN0oM9ixOM7KP4Pcx
+Y8Lcbb+w1dxlUfSC9G8y7zC9HDkSE3ajlp5RGIMDZygfK8aAFeshQoZ4SwZk37CY
+3XLWL94uy0sYOpnssNnRyo8EzgkOMgwayLvivmDZHQvCPXE7skpFbIl4GOf5Qjo+
+q5IzonXGrXbgjT3ertnCrUNYipDiDEcG0WaI8w1ezL1Y6ee2wYctf4qam6/QHRiA
+pyxA2rtz8qjC1p83HjwptDdi8PQTF1rHmwl5Dl/OMs4cqb9TcDkzlPB30VOYCY6Q
+LABJBQKCAQEAx72pYvifKAjLGFLJHjQ6rkq4Of2PoPWudHTjFSVhAQniODWej4nf
+PbMqQmI3qL4mK2j/wFXAwgB4NubvlUIgZC51HVnzdKbDOfieF5zL8XdUJCFB76lm
+TB4KVbOl5UwRdn6HmLuwdmk2N7Hah4kK8FdY5C0viBw3jLTWsTHauaZWS6yzrCpA
+yMuG7IPorBSE6ZJxUWgKbwKYsglDzkzfunS93CJyeL1rblwMX6WEAbGl3Enp/tXI
+FAwO7gbCcHNwXI0i68TcqDhcnIHZy+EmQQnbeovqt4rJndKPPBX+QwPqCJueW3SU
+xmhSe9NQiD9MlonGVvoGJrr4vdQOjF9ZyQKCAQEA00ZEjQ1xdMnMrqzMeac/Ow3T
+Isv08lPY+V6/4O8UGjPINeBOho2Lu1p3x8t0sOzcW5iRA24amGts9/M1qOtmhtd3
+f7ssHzZc7Kg3rCATnZ1yL548YYaGPb9/T7Et9U/bWnGNGSX75nssAIxmHmwDWCPK
+OW6OHuKnccFzRmV/WHc364jwnseuna1yYW5trqXIR7iEaTW2dmVU7Z9wDwgHFwkv
+k8co5CiEc3im10ilo3eaRsDaD9BBP3/qryLBOZg5Yj0edGDDR+xSNwPYbiRZ/oO3
+sSWAuLrZKXB+FIXD2r3AH1IqMxCXDSf2d/wGpEEfllKSmc84RFsvN6V2A8/K3w==
+-----END RSA PRIVATE KEY-----