# -*- coding: utf-8 -*-
#
# This file is part of Glances.
#
# Copyright (C) 2014 Nicolargo <nicolas@nicolargo.com>
#
# Glances is free software; you can redistribute it and/or modify
# it under the terms of the GNU Lesser General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# Glances is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Lesser General Public License for more details.
#
# You should have received a copy of the GNU Lesser General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.

import sys

try:
    from pysnmp.entity.rfc3413.oneliner import cmdgen
except ImportError:
    print("PySNMP library not found.")
    print("Install using pip: # pip install pysnmp")
    sys.exit(2)


class GlancesSNMPClient(object):
    """ SNMP client class (based on PySNMP) """

    def __init__(self, host='localhost', port=161, version='2c',
                 community='public', user='private', auth=''):

        super(GlancesSNMPClient, self).__init__()
        self.cmdGen = cmdgen.CommandGenerator()

        self.version = version

        self.host = host
        self.port = port

        self.community = community
        self.user = user
        self.auth = auth

    def __get_result__(self, errorIndication, errorStatus, errorIndex, varBinds):
        """
        Put results in table
        """

        ret = {}
        if not errorIndication or not errorStatus:
            for name, val in varBinds:
                if str(val) == '':
                    ret[name.prettyPrint()] = ''
                else:
                    ret[name.prettyPrint()] = val.prettyPrint()
        return ret

    def get_by_oid(self, *oid):
        """
        SNMP simple request (list of OID)
        One request per OID list
        * oid: oid list
        > Return a dict
        """

        if self.version == '3':
            errorIndication, errorStatus, errorIndex, varBinds = self.cmdGen.getCmd(
                cmdgen.UsmUserData(self.user, self.auth),
                cmdgen.UdpTransportTarget((self.host, self.port)),
                *oid
            )
        else:
            errorIndication, errorStatus, errorIndex, varBinds = self.cmdGen.getCmd(
                cmdgen.CommunityData(self.community),
                cmdgen.UdpTransportTarget((self.host, self.port)),
                *oid
            )
        return self.__get_result__(errorIndication, errorStatus, errorIndex, varBinds)

    def __bulk_result__(self, errorIndication, errorStatus, errorIndex, varBindTable):
        ret = []
        if not errorIndication or not errorStatus:
            for varBindTableRow in varBindTable:
                item = {}
                for name, val in varBindTableRow:
                    if str(val) == '':
                        item[name.prettyPrint()] = ''
                    else:
                        item[name.prettyPrint()] = val.prettyPrint()
                ret.append(item)
        return ret

    def getbulk_by_oid(self, non_repeaters, max_repetitions, *oid):
        """
        SNMP getbulk request
        In contrast to snmpwalk, this information will typically be gathered in a
        single transaction with the agent, rather than one transaction per variable found.
        * non_repeaters: This specifies the number of supplied variables that should not be iterated over.
        * max_repetitions: This specifies the maximum number of iterations over the repeating variables.
        * oid: oid list
        > Return a list of dicts
        """

        if self.version.startswith('3'):
            errorIndication, errorStatus, errorIndex, varBinds = self.cmdGen.getCmd(
                cmdgen.UsmUserData(self.user, self.auth),
                cmdgen.UdpTransportTarget((self.host, self.port)),
                non_repeaters,
                max_repetitions,
                *oid
            )
        if self.version.startswith('2'):
            errorIndication, errorStatus, errorIndex, varBindTable = self.cmdGen.bulkCmd(
                cmdgen.CommunityData(self.community),
                cmdgen.UdpTransportTarget((self.host, self.port)),
                non_repeaters,
                max_repetitions,
                *oid
            )
        else:
            # Bulk request are not available with SNMP version 1
            return []
        return self.__bulk_result__(errorIndication, errorStatus, errorIndex, varBindTable)
