try:
    from hashlib import md5
except ImportError:
    import md5
    md5 = md5.new
from pyasn1.type import univ
from pysnmp.proto.secmod.rfc3414.auth import base
from pysnmp.proto.secmod.rfc3414 import localkey
from pysnmp.proto import errind, error

_twelveZeros = univ.OctetString((0,)*12).asOctets()
_fortyEightZeros = (0,)*48

# rfc3414: 6.2.4

class HmacMd5(base.AbstractAuthenticationService):
    serviceID = (1, 3, 6, 1, 6, 3, 10, 1, 1, 2)  # usmHMACMD5AuthProtocol
    __ipad = [0x36]*64
    __opad = [0x5C]*64

    def hashPassphrase(self, authKey):
        return localkey.hashPassphraseMD5(authKey)
            
    def localizeKey(self, authKey, snmpEngineID):
        return localkey.localizeKeyMD5(authKey, snmpEngineID)
    
    # 6.3.1
    def authenticateOutgoingMsg(self, authKey, wholeMsg):
        # Here we expect calling secmod to indicate where the digest
        # should be in the substrate. Also, it pre-sets digest placeholder
        # so we hash wholeMsg out of the box.
        # Yes, that's ugly but that's rfc...
        l = wholeMsg.find(_twelveZeros)
        if l == -1:
            raise error.ProtocolError('Cant locate digest placeholder')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l+12:]

        # 6.3.1.1 

        # 6.3.1.2a
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros

        # 6.3.1.2b --> noop

        # 6.3.1.2c
        k1 = univ.OctetString(
            map(lambda x,y: x^y, extendedAuthKey, self.__ipad)
            )

        # 6.3.1.2d --> noop

        # 6.3.1.2e
        k2 = univ.OctetString(
            map(lambda x,y: x^y, extendedAuthKey, self.__opad)
            )
        
        # 6.3.1.3
        d1 = md5(k1.asOctets()+wholeMsg).digest()
        
        # 6.3.1.4
        d2 = md5(k2.asOctets()+d1).digest()
        mac = d2[:12]

        # 6.3.1.5 & 6
        return wholeHead + mac + wholeTail

    # 6.3.2
    def authenticateIncomingMsg(self, authKey, authParameters, wholeMsg):
        # 6.3.2.1 & 2
        if len(authParameters) != 12:
            raise error.StatusInformation(
                errorIndication=errind.authenticationError
                )

        # 6.3.2.3
        l = wholeMsg.find(authParameters.asOctets())
        if l == -1:
            raise error.ProtocolError('Cant locate digest in wholeMsg')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l+12:]
        authenticatedWholeMsg = wholeHead + _twelveZeros + wholeTail

        # 6.3.2.4a
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros

        # 6.3.2.4b --> noop
        
        # 6.3.2.4c
        k1 = univ.OctetString(
            map(lambda x,y: x^y, extendedAuthKey, self.__ipad)
            )

        # 6.3.2.4d --> noop

        # 6.3.2.4e
        k2 = univ.OctetString(
            map(lambda x,y: x^y, extendedAuthKey, self.__opad)
            )

        # 6.3.2.5a
        d1 = md5(k1.asOctets()+authenticatedWholeMsg).digest()

        # 6.3.2.5b
        d2 = md5(k2.asOctets()+d1).digest()
        
        # 6.3.2.5c
        mac = d2[:12]
         
        # 6.3.2.6
        if mac != authParameters:
            raise error.StatusInformation(
                errorIndication=errind.authenticationFailure
                )

        return authenticatedWholeMsg

343db29f15605d5d86292678065e6aba810a6eb6
<mask token>


class HmacMd5(base.AbstractAuthenticationService):
    <mask token>
    <mask token>
    <mask token>

    def hashPassphrase(self, authKey):
        return localkey.hashPassphraseMD5(authKey)

    def localizeKey(self, authKey, snmpEngineID):
        return localkey.localizeKeyMD5(authKey, snmpEngineID)

    def authenticateOutgoingMsg(self, authKey, wholeMsg):
        l = wholeMsg.find(_twelveZeros)
        if l == -1:
            raise error.ProtocolError('Cant locate digest placeholder')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l + 12:]
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros
        k1 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__ipad))
        k2 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__opad))
        d1 = md5(k1.asOctets() + wholeMsg).digest()
        d2 = md5(k2.asOctets() + d1).digest()
        mac = d2[:12]
        return wholeHead + mac + wholeTail

    def authenticateIncomingMsg(self, authKey, authParameters, wholeMsg):
        if len(authParameters) != 12:
            raise error.StatusInformation(errorIndication=errind.
                authenticationError)
        l = wholeMsg.find(authParameters.asOctets())
        if l == -1:
            raise error.ProtocolError('Cant locate digest in wholeMsg')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l + 12:]
        authenticatedWholeMsg = wholeHead + _twelveZeros + wholeTail
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros
        k1 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__ipad))
        k2 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__opad))
        d1 = md5(k1.asOctets() + authenticatedWholeMsg).digest()
        d2 = md5(k2.asOctets() + d1).digest()
        mac = d2[:12]
        if mac != authParameters:
            raise error.StatusInformation(errorIndication=errind.
                authenticationFailure)
        return authenticatedWholeMsg

try:
    from hashlib import md5
except ImportError:
    import md5
    md5 = md5.new
<mask token>


class HmacMd5(base.AbstractAuthenticationService):
    serviceID = 1, 3, 6, 1, 6, 3, 10, 1, 1, 2
    __ipad = [54] * 64
    __opad = [92] * 64

    def hashPassphrase(self, authKey):
        return localkey.hashPassphraseMD5(authKey)

    def localizeKey(self, authKey, snmpEngineID):
        return localkey.localizeKeyMD5(authKey, snmpEngineID)

    def authenticateOutgoingMsg(self, authKey, wholeMsg):
        l = wholeMsg.find(_twelveZeros)
        if l == -1:
            raise error.ProtocolError('Cant locate digest placeholder')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l + 12:]
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros
        k1 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__ipad))
        k2 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__opad))
        d1 = md5(k1.asOctets() + wholeMsg).digest()
        d2 = md5(k2.asOctets() + d1).digest()
        mac = d2[:12]
        return wholeHead + mac + wholeTail

    def authenticateIncomingMsg(self, authKey, authParameters, wholeMsg):
        if len(authParameters) != 12:
            raise error.StatusInformation(errorIndication=errind.
                authenticationError)
        l = wholeMsg.find(authParameters.asOctets())
        if l == -1:
            raise error.ProtocolError('Cant locate digest in wholeMsg')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l + 12:]
        authenticatedWholeMsg = wholeHead + _twelveZeros + wholeTail
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros
        k1 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__ipad))
        k2 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__opad))
        d1 = md5(k1.asOctets() + authenticatedWholeMsg).digest()
        d2 = md5(k2.asOctets() + d1).digest()
        mac = d2[:12]
        if mac != authParameters:
            raise error.StatusInformation(errorIndication=errind.
                authenticationFailure)
        return authenticatedWholeMsg

try:
    from hashlib import md5
except ImportError:
    import md5
    md5 = md5.new
<mask token>
_twelveZeros = univ.OctetString((0,) * 12).asOctets()
_fortyEightZeros = (0,) * 48


class HmacMd5(base.AbstractAuthenticationService):
    serviceID = 1, 3, 6, 1, 6, 3, 10, 1, 1, 2
    __ipad = [54] * 64
    __opad = [92] * 64

    def hashPassphrase(self, authKey):
        return localkey.hashPassphraseMD5(authKey)

    def localizeKey(self, authKey, snmpEngineID):
        return localkey.localizeKeyMD5(authKey, snmpEngineID)

    def authenticateOutgoingMsg(self, authKey, wholeMsg):
        l = wholeMsg.find(_twelveZeros)
        if l == -1:
            raise error.ProtocolError('Cant locate digest placeholder')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l + 12:]
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros
        k1 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__ipad))
        k2 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__opad))
        d1 = md5(k1.asOctets() + wholeMsg).digest()
        d2 = md5(k2.asOctets() + d1).digest()
        mac = d2[:12]
        return wholeHead + mac + wholeTail

    def authenticateIncomingMsg(self, authKey, authParameters, wholeMsg):
        if len(authParameters) != 12:
            raise error.StatusInformation(errorIndication=errind.
                authenticationError)
        l = wholeMsg.find(authParameters.asOctets())
        if l == -1:
            raise error.ProtocolError('Cant locate digest in wholeMsg')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l + 12:]
        authenticatedWholeMsg = wholeHead + _twelveZeros + wholeTail
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros
        k1 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__ipad))
        k2 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__opad))
        d1 = md5(k1.asOctets() + authenticatedWholeMsg).digest()
        d2 = md5(k2.asOctets() + d1).digest()
        mac = d2[:12]
        if mac != authParameters:
            raise error.StatusInformation(errorIndication=errind.
                authenticationFailure)
        return authenticatedWholeMsg

try:
    from hashlib import md5
except ImportError:
    import md5
    md5 = md5.new
from pyasn1.type import univ
from pysnmp.proto.secmod.rfc3414.auth import base
from pysnmp.proto.secmod.rfc3414 import localkey
from pysnmp.proto import errind, error
_twelveZeros = univ.OctetString((0,) * 12).asOctets()
_fortyEightZeros = (0,) * 48


class HmacMd5(base.AbstractAuthenticationService):
    serviceID = 1, 3, 6, 1, 6, 3, 10, 1, 1, 2
    __ipad = [54] * 64
    __opad = [92] * 64

    def hashPassphrase(self, authKey):
        return localkey.hashPassphraseMD5(authKey)

    def localizeKey(self, authKey, snmpEngineID):
        return localkey.localizeKeyMD5(authKey, snmpEngineID)

    def authenticateOutgoingMsg(self, authKey, wholeMsg):
        l = wholeMsg.find(_twelveZeros)
        if l == -1:
            raise error.ProtocolError('Cant locate digest placeholder')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l + 12:]
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros
        k1 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__ipad))
        k2 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__opad))
        d1 = md5(k1.asOctets() + wholeMsg).digest()
        d2 = md5(k2.asOctets() + d1).digest()
        mac = d2[:12]
        return wholeHead + mac + wholeTail

    def authenticateIncomingMsg(self, authKey, authParameters, wholeMsg):
        if len(authParameters) != 12:
            raise error.StatusInformation(errorIndication=errind.
                authenticationError)
        l = wholeMsg.find(authParameters.asOctets())
        if l == -1:
            raise error.ProtocolError('Cant locate digest in wholeMsg')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l + 12:]
        authenticatedWholeMsg = wholeHead + _twelveZeros + wholeTail
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros
        k1 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__ipad))
        k2 = univ.OctetString(map(lambda x, y: x ^ y, extendedAuthKey, self
            .__opad))
        d1 = md5(k1.asOctets() + authenticatedWholeMsg).digest()
        d2 = md5(k2.asOctets() + d1).digest()
        mac = d2[:12]
        if mac != authParameters:
            raise error.StatusInformation(errorIndication=errind.
                authenticationFailure)
        return authenticatedWholeMsg

try:
    from hashlib import md5
except ImportError:
    import md5
    md5 = md5.new
from pyasn1.type import univ
from pysnmp.proto.secmod.rfc3414.auth import base
from pysnmp.proto.secmod.rfc3414 import localkey
from pysnmp.proto import errind, error

_twelveZeros = univ.OctetString((0,)*12).asOctets()
_fortyEightZeros = (0,)*48

# rfc3414: 6.2.4

class HmacMd5(base.AbstractAuthenticationService):
    serviceID = (1, 3, 6, 1, 6, 3, 10, 1, 1, 2)  # usmHMACMD5AuthProtocol
    __ipad = [0x36]*64
    __opad = [0x5C]*64

    def hashPassphrase(self, authKey):
        return localkey.hashPassphraseMD5(authKey)
            
    def localizeKey(self, authKey, snmpEngineID):
        return localkey.localizeKeyMD5(authKey, snmpEngineID)
    
    # 6.3.1
    def authenticateOutgoingMsg(self, authKey, wholeMsg):
        # Here we expect calling secmod to indicate where the digest
        # should be in the substrate. Also, it pre-sets digest placeholder
        # so we hash wholeMsg out of the box.
        # Yes, that's ugly but that's rfc...
        l = wholeMsg.find(_twelveZeros)
        if l == -1:
            raise error.ProtocolError('Cant locate digest placeholder')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l+12:]

        # 6.3.1.1 

        # 6.3.1.2a
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros

        # 6.3.1.2b --> noop

        # 6.3.1.2c
        k1 = univ.OctetString(
            map(lambda x,y: x^y, extendedAuthKey, self.__ipad)
            )

        # 6.3.1.2d --> noop

        # 6.3.1.2e
        k2 = univ.OctetString(
            map(lambda x,y: x^y, extendedAuthKey, self.__opad)
            )
        
        # 6.3.1.3
        d1 = md5(k1.asOctets()+wholeMsg).digest()
        
        # 6.3.1.4
        d2 = md5(k2.asOctets()+d1).digest()
        mac = d2[:12]

        # 6.3.1.5 & 6
        return wholeHead + mac + wholeTail

    # 6.3.2
    def authenticateIncomingMsg(self, authKey, authParameters, wholeMsg):
        # 6.3.2.1 & 2
        if len(authParameters) != 12:
            raise error.StatusInformation(
                errorIndication=errind.authenticationError
                )

        # 6.3.2.3
        l = wholeMsg.find(authParameters.asOctets())
        if l == -1:
            raise error.ProtocolError('Cant locate digest in wholeMsg')
        wholeHead = wholeMsg[:l]
        wholeTail = wholeMsg[l+12:]
        authenticatedWholeMsg = wholeHead + _twelveZeros + wholeTail

        # 6.3.2.4a
        extendedAuthKey = authKey.asNumbers() + _fortyEightZeros

        # 6.3.2.4b --> noop
        
        # 6.3.2.4c
        k1 = univ.OctetString(
            map(lambda x,y: x^y, extendedAuthKey, self.__ipad)
            )

        # 6.3.2.4d --> noop

        # 6.3.2.4e
        k2 = univ.OctetString(
            map(lambda x,y: x^y, extendedAuthKey, self.__opad)
            )

        # 6.3.2.5a
        d1 = md5(k1.asOctets()+authenticatedWholeMsg).digest()

        # 6.3.2.5b
        d2 = md5(k2.asOctets()+d1).digest()
        
        # 6.3.2.5c
        mac = d2[:12]
         
        # 6.3.2.6
        if mac != authParameters:
            raise error.StatusInformation(
                errorIndication=errind.authenticationFailure
                )

        return authenticatedWholeMsg
