Merge pull request #59 from vjardin/dev-coa

server: fix listen for CoAs without auth, neither acct , add runtime CoA+disconnect example

example/coa.py

@@ -3,13 +3,20 @@
 from pyrad.client import Client
 from pyrad import dictionary
 from pyrad import packet
+import sys
+
+if len(sys.argv) != 3:
+  print ("usage: coa.py {coa|dis} daemon-1234")
+  sys.exit(1)
 
 ADDRESS = "127.0.0.1"
 SECRET = b"Kah3choteereethiejeimaeziecumi"
 ATTRIBUTES = {
     "Acct-Session-Id": "1337"
 }
 
+ATTRIBUTES["NAS-Identifier"] = sys.argv[2]
+
 # create coa client
 client = Client(server=ADDRESS, secret=SECRET, dict=dictionary.Dictionary("dictionary"))
 
@@ -19,10 +26,14 @@
 # create coa request packet
 attributes = {k.replace("-", "_"): ATTRIBUTES[k] for k in ATTRIBUTES}
 
-# create coa request
-request = client.CreateCoAPacket(**attributes)
-# create disconnect request
-# request = client.CreateCoAPacket(code=packet.DisconnectRequest, **attributes)
+if sys.argv[1] == "coa":
+    # create coa request
+    request = client.CreateCoAPacket(**attributes)
+elif sys.argv[1] == "dis":
+    # create disconnect request
+    request = client.CreateCoAPacket(code=packet.DisconnectRequest, **attributes)
+else:
+  sys.exit(1)
 
 # send request
 result = client.SendPacket(request)

pyrad/server.py

@@ -286,15 +286,17 @@ def _ProcessInput(self, fd):
         :param  fd: socket to read packet from
         :type   fd: socket class instance
         """
-        if fd.fileno() in self._realauthfds:
+        if self.auth_enabled and fd.fileno() in self._realauthfds:
             pkt = self._GrabPacket(lambda data, s=self: s.CreateAuthPacket(packet=data), fd)
             self._HandleAuthPacket(pkt)
-        elif fd.fileno() in self._realacctfds:
+        elif self.acct_enabled and fd.fileno() in self._realacctfds:
             pkt = self._GrabPacket(lambda data, s=self: s.CreateAcctPacket(packet=data), fd)
             self._HandleAcctPacket(pkt)
-        else:
+        elif self.coa_enabled:
             pkt = self._GrabPacket(lambda data, s=self: s.CreateCoAPacket(packet=data), fd)
             self._HandleCoaPacket(pkt)
+        else:
+            raise ServerPacketError('Received packet for unknown handler')
 
     def Run(self):
         """Main loop.