if(typeof oid !== 'string')

return oid;

if(oid.charAt(0) === '.')

return oid.substring(1, oid.length);

return oid;

var __DEBUG = netdata.options.DEBUG;

if(typeof service.snmp_oids === 'undefined' || service.snmp_oids === null || service.snmp_oids.length === 0) {

// this is the first time we see this service

if(__DEBUG === true)

netdata.debug(service.module.name + ': ' + service.name + ': preparing ' + this.name + ' OIDs');

// build an index of all OIDs

service.snmp_oids_index = {};

var chart_keys = Object.keys(service.request.charts);

var chart_keys_len = chart_keys.length;

while(chart_keys_len--) {

var c = chart_keys[chart_keys_len];

var chart = service.request.charts[c];

// for each chart

if(__DEBUG === true)

netdata.debug(service.module.name + ': ' + service.name + ': indexing ' + this.name + ' chart: ' + c);

if(typeof chart.titleoid !== 'undefined') {

service.snmp_oids_index[this.fixoid(chart.titleoid)] = {

type: 'title',

link: chart

};

}

var dim_keys = Object.keys(chart.dimensions);

var dim_keys_len = dim_keys.length;

while(dim_keys_len--) {

var d = dim_keys[dim_keys_len];

var dim = chart.dimensions[d];

// for each dimension in the chart

var oid = this.fixoid(dim.oid);

var oidname = this.fixoid(dim.oidname);

if(__DEBUG === true)

netdata.debug(service.module.name + ': ' + service.name + ': indexing ' + this.name + ' chart: ' + c + ', dimension: ' + d + ', OID: ' + oid + ", OID name: " + oidname);

// link it to the point we need to set the value to

service.snmp_oids_index[oid] = {

type: 'value',

link: dim

};

if(typeof oidname !== 'undefined')

service.snmp_oids_index[oidname] = {

type: 'name',

link: dim

};

// and set the value to null

dim.value = null;

}

}

if(__DEBUG === true)

netdata.debug(service.module.name + ': ' + service.name + ': indexed ' + this.name + ' OIDs: ' + netdata.stringify(service.snmp_oids_index));

// now create the array of OIDs needed by net-snmp

service.snmp_oids = Object.keys(service.snmp_oids_index);

if(__DEBUG === true)

netdata.debug(service.module.name + ': ' + service.name + ': final list of ' + this.name + ' OIDs: ' + netdata.stringify(service.snmp_oids));

service.snmp_oids_cleaned = 0;

}

else if(service.snmp_oids_cleaned === 0) {

service.snmp_oids_cleaned = 1;

// the second time, keep only values

service.snmp_oids = new Array();

var oid_keys = Object.keys(service.snmp_oids_index);

var oid_keys_len = oid_keys.length;

while(oid_keys_len--) {

if (service.snmp_oids_index[oid_keys[oid_keys_len]].type === 'value')

service.snmp_oids.push(oid_keys[oid_keys_len]);

}

}

var __DEBUG = netdata.options.DEBUG;

var that = this;

if(index >= service.snmp_oids.length) {

callback((ok > 0)?{ ok: ok, failed: failed }:null);

return;

}

var slice;

if(service.snmp_oids.length <= service.request.max_request_size) {

slice = service.snmp_oids;

index = service.snmp_oids.length;

}

else if(service.snmp_oids.length - index <= service.request.max_request_size) {

slice = service.snmp_oids.slice(index, service.snmp_oids.length);

index = service.snmp_oids.length;

}

else {

slice = service.snmp_oids.slice(index, index + service.request.max_request_size);

index += service.request.max_request_size;

}

if(__DEBUG === true)

netdata.debug(service.module.name + ': ' + service.name + ': making ' + slice.length + ' entries request, max is: ' + service.request.max_request_size);

service.snmp_session.get(slice, function(error, varbinds) {

if(error) {

service.error('Received error = ' + netdata.stringify(error) + ' varbinds = ' + netdata.stringify(varbinds));

// make all values null

var len = slice.length;

while(len--)

service.snmp_oids_index[slice[len]].value = null;

}

else {

if(__DEBUG === true)

netdata.debug(service.module.name + ': ' + service.name + ': got valid ' + service.module.name + ' response: ' + netdata.stringify(varbinds));

var varbinds_len = varbinds.length;

for(var i = 0; i < varbinds_len ; i++) {

var value = null;

if(net_snmp.isVarbindError(varbinds[i])) {

if(__DEBUG === true)

netdata.debug(service.module.name + ': ' + service.name + ': failed ' + service.module.name + ' get for OIDs ' + varbinds[i].oid);

service.error('OID ' + varbinds[i].oid + ' gave error: ' + snmp.varbindError(varbinds[i]));

value = null;

failed++;

}

else {

// test fom Counter64

// varbinds[i].type = net_snmp.ObjectType.Counter64;

// varbinds[i].value = new Buffer([0x34, 0x49, 0x2e, 0xdc, 0xd1]);

switch(varbinds[i].type) {

case net_snmp.ObjectType.OctetString:

if(service.snmp_oids_index[varbinds[i].oid].type !== 'title')

// parse floating point values, exposed as strings

value = parseFloat(varbinds[i].value) * 1000;

if(__DEBUG === true) netdata.debug(service.module.name + ': ' + service.name + ': found ' + service.module.name + ' value of OIDs ' + varbinds[i].oid + ", ObjectType " + net_snmp.ObjectType[varbinds[i].type] + " (" + netdata.stringify(varbinds[i].type) + "), typeof(" + typeof(varbinds[i].value) + "), in JSON: " + netdata.stringify(varbinds[i].value) + ", value = " + value.toString() + " (parsed as float in string)");

else

// just use the string

value = varbinds[i].value;

if(__DEBUG === true) netdata.debug(service.module.name + ': ' + service.name + ': found ' + service.module.name + ' value of OIDs ' + varbinds[i].oid + ", ObjectType " + net_snmp.ObjectType[varbinds[i].type] + " (" + netdata.stringify(varbinds[i].type) + "), typeof(" + typeof(varbinds[i].value) + "), in JSON: " + netdata.stringify(varbinds[i].value) + ", value = " + value.toString() + " (parsed as string)");

break;

case net_snmp.ObjectType.Counter64:

// copy the buffer

value = '0x' + varbinds[i].value.toString('hex');

if(__DEBUG === true) netdata.debug(service.module.name + ': ' + service.name + ': found ' + service.module.name + ' value of OIDs ' + varbinds[i].oid + ", ObjectType " + net_snmp.ObjectType[varbinds[i].type] + " (" + netdata.stringify(varbinds[i].type) + "), typeof(" + typeof(varbinds[i].value) + "), in JSON: " + netdata.stringify(varbinds[i].value) + ", value = " + value.toString() + " (parsed as buffer)");

break;

case net_snmp.ObjectType.Integer:

case net_snmp.ObjectType.Counter:

case net_snmp.ObjectType.Gauge:

default:

value = varbinds[i].value;

if(__DEBUG === true) netdata.debug(service.module.name + ': ' + service.name + ': found ' + service.module.name + ' value of OIDs ' + varbinds[i].oid + ", ObjectType " + net_snmp.ObjectType[varbinds[i].type] + " (" + netdata.stringify(varbinds[i].type) + "), typeof(" + typeof(varbinds[i].value) + "), in JSON: " + netdata.stringify(varbinds[i].value) + ", value = " + value.toString() + " (parsed as number)");

break;

}

ok++;

}

if(value !== null) {

switch(service.snmp_oids_index[varbinds[i].oid].type) {

case 'title': service.snmp_oids_index[varbinds[i].oid].link.title += ' ' + value; break;

case 'name' : service.snmp_oids_index[varbinds[i].oid].link.name = value; break;

case 'value': service.snmp_oids_index[varbinds[i].oid].link.value = value; break;

}

}

}

if(__DEBUG === true)

netdata.debug(service.module.name + ': ' + service.name + ': finished ' + service.module.name + ' with ' + ok + ' successful and ' + failed + ' failed values');

}

that.getdata(service, index, ok, failed, callback);

});

var __DEBUG = netdata.options.DEBUG;

this.prepare(service);

if(service.snmp_oids.length === 0) {

// no OIDs found for this service

if(__DEBUG === true)

service.error('no OIDs to process.');

callback(null);

return;

}

if(typeof service.snmp_session === 'undefined' || service.snmp_session === null) {

// no SNMP session has been created for this service

// the SNMP session is just the initialization of NET-SNMP

if(__DEBUG === true)

netdata.debug(service.module.name + ': ' + service.name + ': opening ' + this.name + ' session on ' + service.request.hostname + ' community ' + service.request.community + ' options ' + netdata.stringify(service.request.options));

// create the SNMP session

service.snmp_session = net_snmp.createSession (service.request.hostname, service.request.community, service.request.options);

if(__DEBUG === true)

netdata.debug(service.module.name + ': ' + service.name + ': got ' + this.name + ' session: ' + netdata.stringify(service.snmp_session));

// if we later need traps, this is how to do it:

//service.snmp_session.trap(net_snmp.TrapType.LinkDown, function(error) {

// if(error) console.error('trap error: ' + netdata.stringify(error));

//});

}

// do it, get the SNMP values for the sessions we need

this.getdata(service, 0, 0, 0, callback);

if(data !== null) {

if(service.added !== true)

service.commit();

var chart_keys = Object.keys(service.request.charts);

var chart_keys_len = chart_keys.length;

for(var i = 0; i < chart_keys_len; i++) {

var c = chart_keys[i];

var chart = snmp.charts[c];

if(typeof chart === 'undefined') {

chart = service.chart(c, service.request.charts[c]);

snmp.charts[c] = chart;

}

service.begin(chart);

var dimensions = service.request.charts[c].dimensions;

var dim_keys = Object.keys(dimensions);

var dim_keys_len = dim_keys.length;

for(var j = 0; j < dim_keys_len ; j++) {

var d = dim_keys[j];

if (dimensions[d].value !== null) {

if(typeof dimensions[d].offset === 'number')

service.set(d, dimensions[d].value + dimensions[d].offset);

else

service.set(d, dimensions[d].value);

}

}

service.end();

}

}

var __DEBUG = netdata.options.DEBUG;

if(__DEBUG === true)

netdata.debug(this.name + ': snmp hostname: ' + conf.hostname + ', update_every: ' + conf.update_every);

var service = netdata.service({

name: conf.hostname,

request: conf,

update_every: conf.update_every,

module: this,

processor: netdata.processors.snmp

});

// multiply the charts, if required

var chart_keys = Object.keys(service.request.charts);

var chart_keys_len = chart_keys.length;

for( var i = 0; i < chart_keys_len ; i++ ) {

var c = chart_keys[i];

var service_request_chart = service.request.charts[c];

if(__DEBUG === true)

netdata.debug(this.name + ': snmp hostname: ' + conf.hostname + ', examining chart: ' + c);

if(typeof service_request_chart.update_every === 'undefined')

service_request_chart.update_every = service.update_every;

if(typeof service_request_chart.multiply_range !== 'undefined') {

var from = service_request_chart.multiply_range[0];

var to = service_request_chart.multiply_range[1];

var prio = service_request_chart.priority || 1;

if(prio < snmp.base_priority) prio += snmp.base_priority;

while(from <= to) {

var id = c + from.toString();

var chart = extend(true, {}, service_request_chart);

chart.title += from.toString();

if(typeof chart.titleoid !== 'undefined')

chart.titleoid += from.toString();

chart.priority = prio++;

var dim_keys = Object.keys(chart.dimensions);

var dim_keys_len = dim_keys.length;

for(var j = 0; j < dim_keys_len ; j++) {

var d = dim_keys[j];

chart.dimensions[d].oid += from.toString();

if(typeof chart.dimensions[d].oidname !== 'undefined')

chart.dimensions[d].oidname += from.toString();

}

service.request.charts[id] = chart;

from++;

}

delete service.request.charts[c];

}

else {

if(service.request.charts[c].priority < snmp.base_priority)

service.request.charts[c].priority += snmp.base_priority;

}

}

service.execute(this.processResponse);

var added = 0;

if(typeof config.max_request_size === 'undefined')

config.max_request_size = 50;

if(typeof(config.servers) !== 'undefined') {

var len = config.servers.length;

while(len--) {

if(typeof config.servers[len].update_every === 'undefined')

config.servers[len].update_every = this.update_every;

if(typeof config.servers[len].max_request_size === 'undefined')

config.servers[len].max_request_size = config.max_request_size;

this.serviceExecute(config.servers[len]);

added++;

}

}

return added;

service.execute(function(serv, data) {

service.module.processResponse(serv, data);

callback();

});