OSS_SNPM/OSS_SNMP/MIBS/DocsIfCmts.php

<?php

namespace OSS_SNMP\MIBS;

class DocsIfCmts extends \OSS_SNMP\MIB {

    const OID_docsIfCmtsCmStatusMacAddress	= "1.3.6.1.2.1.10.127.1.3.3.1.2";
    //const OID_docsIfCmtsCmStatusTable  		= "1.3.6.1.2.1.10.127.1.3.3";
    const OID_docsIfCmtsCmStatusUpChannelIfIndex =  "1.3.6.1.2.1.10.127.1.3.3.1.5";
    const OID_docsIfCmtsCmStatusDownChannelIfIndex = "1.3.6.1.2.1.10.127.1.3.3.1.4";
    const OID_docsIfCmtsCmStatusIpAddress	= "1.3.6.1.2.1.10.127.1.3.3.1.3";
    const OID_docsQosCmtsIfIndex		= "1.3.6.1.2.1.10.127.7.1.11.1.3";
    const OID_docsQos3CmtsIfIndex		= "1.3.6.1.4.1.4491.2.1.21.1.11.1.3";
    const OID_docsIfCmtsCmStatusIndex		= "1.3.6.1.2.1.10.127.1.3.3.1.1";
    const OID_docsQosServiceFlowOctets		= "1.3.6.1.2.1.10.127.7.1.4.1.2";
    const OID_docsQosServiceFlowDirection	= "1.3.6.1.2.1.10.127.7.1.3.1.7";
    const OID_docsQos3ServiceFlowDirection	= "1.3.6.1.4.1.4491.2.1.21.1.3.1.7";
    const OID_docsIfCmtsCmStatusRxPower		= "1.3.6.1.2.1.10.127.1.3.3.1.6";
    const OID_docsIfCmtsCmStatusValue		= "1.3.6.1.2.1.10.127.1.3.3.1.9";
    const OID_docsQos3ServiceFlowOctets 	= "1.3.6.1.4.1.4491.2.1.21.1.4.1.2";
    const OID_docsIfSigQSignalNoise		= "1.3.6.1.2.1.10.127.1.1.4.1.5";
    const OID_docsIfSigQMicroreflections        = "1.3.6.1.2.1.10.127.1.1.4.1.6";
    const docsIfCmtsChannelUtilization        = "1.3.6.1.2.1.10.127.1.3.9.1.3";
    const OID_ipNetToMediaPhysAddress 		= "1.3.6.1.2.1.4.22.1.2";
    const OID_docsIfCmtsCmPtr  			= "1.3.6.1.2.1.10.127.1.3.7.1.2";
    const OID_docsIfCmStatusTxPower 		= "1.3.6.1.2.1.10.127.1.2.2.1.3";


    public function docsIfCmtsCmPtr(){
	$ptr = array();
	foreach($this->getSNMP()->realWalk(self::OID_docsIfCmtsCmPtr) as $key => $val){
		$mac =implode('',array_map(function($x) { return sprintf("%02x", $x);}, array_slice(explode(".",$key),14,6)));
		$ptr[$mac] = $this->getSNMP()->parseSnmpValue($val);
	}
	return $ptr;
    }

    public function ipNetToMediaPhysAddress(){
	$rtr = array();
        foreach($this->getSNMP()->realWalk(self::OID_ipNetToMediaPhysAddress) as $k => $m){
////tring(40) ".1.3.6.1.2.1.4.22.1.2.2000001.10.14.8.69"
//string(23) "STRING: 0:c:e5:7d:93:d0"                  
////
		$karray = preg_split("|\.|",$k);
		$mac = preg_split("|:|", trim(substr($m,8)));
		$mac = sprintf("%02x:%02x:%02x:%02x:%02x:%02x",$mac[0], $mac[1], $mac[2], $mac[3], $mac[4], $mac[5]);
		$l_ke = count($karray);
		$rtr[$mac] = sprintf("%d.%d.%d.%d",$karray[$l_ke - 4],$karray[$l_ke - 3], $karray[$l_ke - 2], $karray[$l_ke-1]);
	}
	return $rtr;
    }

    public function docsQos3ServiceFlowDirection($translate=false){
	$rtr = array();
	$oid = self::OID_docsQos3ServiceFlowDirection;
	$stats = $this->getSNMP()->realWalk($oid);
        foreach((array)$stats as $k => $v){
	    $k_prim = preg_split("|\.|",$k);
	    //$dds = strpos($v, ':');
	    if(!isset($k_prim[15])){
		continue;
	    }
	    $rtr[$k_prim[15].".".$k_prim[16]] = $this->getSNMP()->parseSnmpValue($v);
	}
	if( !$translate )
            return $rtr;

        return $this->getSNMP()->translate( $rtr, self::$FLOW_DIRECTIONS);
    }

    public function docsQos3ServiceFlowDirectionX($translate=false, $id=null){
	$rtr = array();
	if(is_null($id)) $oid = self::OID_docsQos3ServiceFlowDirection;
	else $oid = self::OID_docsQos3ServiceFlowDirection. "." .$id;
	$stats = $this->getSNMP()->realWalk($oid);
        foreach((array)$stats as $k => $v){
	    $k_prim = preg_split("|\.|",$k);
	    //$dds = strpos($v, ':');
	    if(!isset($k_prim[15])){
		break;
	    }
	    $rtr[$k_prim[15].".".$k_prim[16]] = $this->getSNMP()->parseSnmpValue($v);
	}
	if( !$translate )
            return $rtr;

        return $this->getSNMP()->translate( $rtr, self::$FLOW_DIRECTIONS);
    }



    private function getDecMac($mac){
	preg_match('/^([a-f0-9]{1,2})[-:]*([a-f0-9]{1,2})[-:]*([a-f0-9]{1,2})[-:]*([a-f0-9]{1,2})[-:]*([a-f0-9]{1,2})[-:]*([a-f0-9]{1,2})$/i', $mac, $matches);
	unset($matches[0]);
	return implode('.', array_map('hexdec', $matches));
   }

   public function docsQos3CmtsIfIndex($mac=null){
	    $rtr = array();
	    if(!is_null($mac)){
		$oid = self::OID_docsQos3CmtsIfIndex .'.'.$this->getDecMac($mac);
	    }else{
		$oid = self::OID_docsQos3CmtsIfIndex;
	    }
            foreach((array)$this->getSNMP()->realWalk($oid) as $k => $v){
		$k_prim = preg_split("|\.|",$k);
		if(count($k_prim) < 20){
			continue;
		}
		$k_mac = sprintf("%02x:%02x:%02x:%02x:%02x:%02x",
				 $k_prim[15], $k_prim[16], $k_prim[17], $k_prim[18], $k_prim[19], $k_prim[20]);
		$rtr[$k_mac][] = $this->getSNMP()->parseSnmpValue($v). ".".$k_prim[21];
	    }
	    return $rtr;
   }

   public function docsQos3ServiceFlowOctets($ifId=null){
	try{
	    $rtr = array();
	    if(!is_null($ifId)){
		$oid = self::OID_docsQos3ServiceFlowOctets ."." .$ifId;
	    }else{
		$oid = self::OID_docsQos3ServiceFlowOctets;
            }
	    foreach($this->getSNMP()->realWalk($oid) as $k => $v){
		$k_prim = preg_split("|\.|",$k);
		$rtr[$k_prim[15].".".$k_prim[16]] = $this->getSNMP()->parseSnmpValue($v);
	    }
	    return $rtr;
	}catch (\Exception $e){ 
	    echo "ouch! ".$e->getMessage()."\n";
	    return array();
	}
   }

    public static $FLOW_DIRECTIONS = array(1 => "downstream", 2 => 'upstream');

    public function docsQosServiceFlowDirection($translate=false){
	$oid = self::OID_docsQosServiceFlowDirection;
	$states = $this->getSNMP()->walk1d($oid);
	$rtr = array();
	if( !$translate )
            return $states;

        return $this->getSNMP()->translate( $states, self::$FLOW_DIRECTIONS);
    }

    public function docsQosServiceFlowDirectionX($translate=false, $id=null){

	if(is_null($id)) $oid = self::OID_docsQosServiceFlowDirection;
	else $oid = self::OID_docsQosServiceFlowDirection. "." .$id;
	$rtr = array();
	if( !$translate ){
		return $states = $this->getSNMP()->walk1d($oid);
	}
	$states = $this->getSNMP()->realWalk($oid);
	foreach($states as $k => $v){
		$k_p= preg_split("|\.|",$k);
        	$rtr[$k_p[14].".".$k_p[15]] = self::$FLOW_DIRECTIONS[$this->getSNMP()->parseSnmpValue($v)];
	}
	return $rtr;
    }

    public function docsQosCmtsIfIndex($translate = false, $mac=null){
	    $rtr = array();
	    if(!is_null($mac)){
		$oid = self::OID_docsQosCmtsIfIndex .'.'.$this->getDecMac($mac);
	    }else{
		$oid = self::OID_docsQosCmtsIfIndex;
	    }
	    $ifIndex = $this->getSNMP()->realWalk($oid);
            foreach((array)$ifIndex as $k => $v){
		$k_prim = preg_split("|\.|",$k);
		if(!isset($k_prim[14]) OR !isset($k_prim[15]) OR !isset($k_prim[16]) OR !isset($k_prim[17]) OR !isset($k_prim[18]) OR !isset($k_prim[19])){
			continue;
		}
		$k_mac = sprintf("%02x:%02x:%02x:%02x:%02x:%02x",
				 $k_prim[14], $k_prim[15], $k_prim[16], $k_prim[17], $k_prim[18], $k_prim[19]);
		if(!$translate)
			$rtr[$k_mac][] = $k_prim[20]; //$this->getSNMP()->parseSnmpValue($v);
		else
			$rtr[$k_mac][] =$this->getSNMP()->parseSnmpValue($v).".". $k_prim[20];

	    }
	    return $rtr;
    }

    public function docsQosServiceFlowOctets($translate = false, $ifId=null){
	if(!is_null($ifId)){
		$oid = self::OID_docsQosServiceFlowOctets ."." .$ifId;
        }else{
		$oid = self::OID_docsQosServiceFlowOctets;
        }	
	$rtr = array();
	if($translate) foreach($this->getSNMP()->realWalk($oid) as $k => $v){
		$k_prim = preg_split("|\.|",$k);
		$rtr[$k_prim[14].".".$k_prim[15]] = $this->getSNMP()->parseSnmpValue($v);
	}
	else
		$rtr = $this->getSNMP()->walk1d($oid);
	return $rtr;
    }

    /**
other(1)   Any state other than below.
ranging(2)   The CMTS has received an Initial Ranging Request   message from the CM, and the ranging process is not  yet   complete.
rangingAborted(3)   The CMTS has sent a Ranging Abort message to the CM.
rangingComplete(4)   The CMTS has sent a Ranging Complete message to the CM.
ipComplete(5)   The CMTS has received a DHCP reply message and forwarded   it to the CM.
registrationComplete(6)   The CMTS has sent a Registration Response message to the CM.
accessDenied(7)   The CMTS has sent a Registration Aborted message   to the CM.
      **/
    public function docsIfCmtsCmStatusMacAddress()
    {
        $rtr = $this->getSNMP()->walk1d(self::OID_docsIfCmtsCmStatusMacAddress);
	return $rtr;
    }

    //public function docsIfCmtsCmStatusIndex(){
    //    return $this->getSNMP()->walk1d(self::OID_docsIfCmtsCmStatusDownChannelIfIndex);
    //}

    public function docsIfCmtsCmStatusUpChannelIfIndex(){
    	return $this->getSNMP()->walk1d(self::OID_docsIfCmtsCmStatusUpChannelIfIndex);
    }

    public function docsIfCmtsCmStatusDownChannelIfIndex(){
    	return $this->getSNMP()->walk1d(self::OID_docsIfCmtsCmStatusDownChannelIfIndex);
    }

    public function docsIfCmtsCmStatusIpAddress(){
        return $this->getSNMP()->walk1d(self::OID_docsIfCmtsCmStatusIpAddress);
    }


    public function docsIfCmtsCmStatusValue(){	

        $rtr = $this->getSNMP()->walk1d(self::OID_docsIfCmtsCmStatusValue);
        $replace = array(1 => 'other' , 2 =>  'ranging', 3 => 'rangingAborted', 4 => 'rangingComplete', 5 => 'ipComplete',
                        6 => 'registrationComplete', 7 => 'accessDenied');
        foreach($rtr as $k => $v){ $rtr[$k] = $replace[$v]; }
	return $rtr;
        
    }

    public function docsIfCmtsCmStatusRxPower(){
	$rtr = $this->getSNMP()->walk1d(self::OID_docsIfCmtsCmStatusRxPower);
	return $rtr;
    }

    public function docsIfSigQSignalNoise(){
	$rtr = array();
	$data = $this->getSNMP()->realWalk(self::OID_docsIfSigQSignalNoise);
	foreach($data as $oid => $val){
		sscanf($val,"INTEGER: %f TenthdB", $readval);
		$rtr[substr($oid,strlen(self::OID_docsIfSigQSignalNoise)+2)] = $readval;
	}
	return $rtr;
    }

    public function docsIfSigQMicroreflections($trans = false){
	$oid = self::OID_docsIfSigQMicroreflections;
	$rtr = array();
	if($trans){
	foreach($this->getSNMP()->realWalk($oid) as $oid => $val){
		sscanf($val,"INTEGER: %f -dBc", $readval);
		$rtr[substr($oid,strlen(self::OID_docsIfSigQSignalNoise)+2)] = $readval;
	}
		return $rtr;
	}else{
		return $this->getSNMP()->walk1d(self::OID_docsIfSigQMicroreflections);
	}
    }
    
    public function docsIfCmtsChannelUtilization(){
	return $this->getSNMP()->realWalk(self::docsIfCmtsChannelUtilization);
    }


    public function docsIfCmStatusTxPower($decode=false){
	if(!$decode) return $this->getSNMP()->walk1d(self::OID_docsIfCmStatusTxPower);
	else{
		$rtr = array();
		foreach($this->getSNMP()->realWalk(self::OID_docsIfCmStatusTxPower) as $_oid => $val){
			$k = substr($_oid, strlen(self::OID_docsIfCmStatusTxPower)+2);
			$rtr[$k] = $this->getSNMP()->parseSnmpValue($val);
		}
		return $rtr;
	}
    }

   public function getCmStatus($index){
	   $mibs = array(
                'docsIfCmtsCmStatusMacAddress' => 'docsIfCmtsCmStatusMacAddress',
                'docsIfCmtsCmStatusIpAddress' => 'docsIfCmtsCmStatusIpAddress',
                'docsIfCmtsCmStatusDownChannelIfIndex' => 'docsIfCmtsCmStatusDownChannelIfIndex',
                'docsIfCmtsCmStatusUpChannelIfIndex' => 'docsIfCmtsCmStatusUpChannelIfIndex',
                'docsIfCmtsCmStatusRxPower' => 'docsIfCmtsCmStatusRxPower',
                'docsIfCmtsCmStatusValue' => 'docsIfCmtsCmStatusValue',
                'docsIfCmtsCmStatusUnerroreds' => 'docsIfCmtsCmStatusUnerroreds',
                'docsIfCmtsCmStatusCorrecteds' => 'docsIfCmtsCmStatusCorrecteds',
                'docsIfCmtsCmStatusUncorrectables' => 'docsIfCmtsCmStatusUncorrectables',
                'docsIfCmtsCmStatusSignalNoise' => 'docsIfCmtsCmStatusSignalNoise',
                'docsIfCmtsCmStatusMicroreflections' => 'docsIfCmtsCmStatusMicroreflections',
                'docsIfCmtsCmStatusDocsisRegMode' => 'docsIfCmtsCmStatusDocsisRegMode',
                'docsIfCmtsCmStatusModulationType' => 'docsIfCmtsCmStatusModulationType',  
	);
	
	foreach($mibs as $k=> $m){
		$m .= ".".$index;
		$rta = $this->getSNMP()->realWalk($m);
		if(!$rta) continue;
		$v = current($rta);
		$dds = strpos($v, ':');
		$v = substr($v, $dds+2);
		$rtr[$k] = $v;
	}
	return $rtr;
    }
}