From f3213f28d605a41c81d5861d2df0143758c82ca1 Mon Sep 17 00:00:00 2001
From: elie <elie>
Date: Sun, 5 May 2013 11:16:48 +0000
Subject: SNMP Proxy example apps separated into a larger set of more
 specialized ones

---
 .../asyncore/proxy/command/v2c-to-v1-conversion.py | 138 +++++++++++++++++++++
 1 file changed, 138 insertions(+)
 create mode 100644 examples/v3arch/asyncore/proxy/command/v2c-to-v1-conversion.py

(limited to 'examples/v3arch/asyncore/proxy/command/v2c-to-v1-conversion.py')

diff --git a/examples/v3arch/asyncore/proxy/command/v2c-to-v1-conversion.py b/examples/v3arch/asyncore/proxy/command/v2c-to-v1-conversion.py
new file mode 100644
index 00000000..6e456b72
--- /dev/null
+++ b/examples/v3arch/asyncore/proxy/command/v2c-to-v1-conversion.py
@@ -0,0 +1,138 @@
+#
+# SNMP Command Proxy example
+#
+# Act as a local SNMPv2c Agent, relay messages to distant SNMPv1 Agent:
+#     over IPv4/UDP
+#     with local SNMPv2c community public
+#     local Agent listening at 127.0.0.1:161
+#     remote SNMPv1, community public
+#     remote Agent listening at 195.218.195.228:161
+#
+# This script can be queried with the following Net-SNMP command:
+#
+# $ snmpbulkwalk -v2c -c public -ObentU 127.0.0.1:161 system
+#
+# due to proxy, it is equivalent to
+#
+# $ snmpwalk -v1 -c public 195.218.195.228:161 system
+#
+from pysnmp.carrier.asynsock.dgram import udp
+from pysnmp.entity import engine, config
+from pysnmp.entity.rfc3413 import cmdrsp, cmdgen, context
+from pysnmp.proto.api import v2c
+from pysnmp import error
+
+# Create SNMP engine with autogenernated engineID and pre-bound
+# to socket transport dispatcher
+snmpEngine = engine.SnmpEngine()
+
+#
+# Transport setup
+#
+
+# Agent section
+
+# UDP over IPv4
+config.addSocketTransport(
+    snmpEngine,
+    udp.domainName + (1,),
+    udp.UdpTransport().openServerMode(('127.0.0.1', 161))
+)
+
+# Manager section
+
+# UDP over IPv4
+config.addSocketTransport(
+    snmpEngine,
+    udp.domainName + (2,),
+    udp.UdpTransport().openClientMode()
+)
+
+#
+# SNMPv2c setup (Agent role)
+#
+
+# SecurityName <-> CommunityName mapping
+config.addV1System(snmpEngine, 'my-area', 'public')
+
+#
+# SNMPv1 setup (Manager role)
+#
+
+# SecurityName <-> CommunityName <-> Transport mapping
+config.addV1System(snmpEngine, 'distant-area', 'public', transportTag='distant')
+
+#
+# Transport target used by Manager
+#
+
+# Specify security settings per SecurityName (SNMPv1 - 0, SNMPv2c - 1)
+config.addTargetParams(snmpEngine, 'distant-agent-auth', 'distant-area',
+                       'noAuthNoPriv', 0)
+
+config.addTargetAddr(
+        snmpEngine, 'distant-agent', 
+        udp.domainName + (2,), ('195.218.195.228', 161),
+        'distant-agent-auth', retryCount=0, tagList='distant'
+)
+
+# Default SNMP context
+config.addContext(snmpEngine, '')
+
+class CommandResponder(cmdrsp.CommandResponderBase):
+    cmdGenMap = { 
+        v2c.GetRequestPDU.tagSet: cmdgen.GetCommandGenerator(),
+        v2c.SetRequestPDU.tagSet: cmdgen.SetCommandGenerator(),
+        v2c.GetNextRequestPDU.tagSet: cmdgen.NextCommandGeneratorSingleRun(),
+        v2c.GetBulkRequestPDU.tagSet: cmdgen.BulkCommandGeneratorSingleRun() 
+    }
+    pduTypes = cmdGenMap.keys()  # This app will handle these PDUs
+
+    # SNMP request relay
+    def handleMgmtOperation(self, snmpEngine, stateReference, contextName,
+                            PDU, acInfo):
+        cbCtx = snmpEngine, stateReference
+        varBinds = v2c.apiPDU.getVarBinds(PDU)
+        try:
+            if PDU.tagSet == v2c.GetBulkRequestPDU.tagSet:
+                self.cmdGenMap[PDU.tagSet].sendReq(
+                    snmpEngine, 'distant-agent', 
+                    v2c.apiBulkPDU.getNonRepeaters(PDU),
+                    v2c.apiBulkPDU.getMaxRepetitions(PDU),
+                    varBinds,
+                    self.handleResponse, cbCtx
+                )
+            elif PDU.tagSet in self.cmdGenMap:
+                self.cmdGenMap[PDU.tagSet].sendReq(
+                    snmpEngine, 'distant-agent', varBinds,
+                    self.handleResponse, cbCtx
+                )
+        except error.PySnmpError:
+            self.handleResponse(
+                stateReference,  'error', 0, 0, varBinds, cbCtx
+            )
+
+    # SNMP response relay
+    def handleResponse(self, sendRequestHandle, errorIndication, 
+                       errorStatus, errorIndex, varBinds, cbCtx):
+        if errorIndication:
+            errorStatus = 5
+            errorIndex = 0
+            varBinds = ()
+
+        snmpEngine, stateReference = cbCtx
+
+        self.sendRsp(
+            snmpEngine, stateReference,  errorStatus, errorIndex, varBinds
+        )
+
+CommandResponder(snmpEngine, context.SnmpContext(snmpEngine))
+
+snmpEngine.transportDispatcher.jobStarted(1) # this job would never finish
+
+# Run I/O dispatcher which would receive queries and send responses
+try:
+    snmpEngine.transportDispatcher.runDispatcher()
+except:
+    snmpEngine.transportDispatcher.closeDispatcher()
+    raise
-- 
cgit v1.2.1