# curved.py
#
# Copyright 2002 Wichert Akkerman <wichert@wiggy.net>

"""Twisted integration code

"""

__docformat__	= "epytext en"

from twisted.internet import protocol, reactor
from twisted.python import log
import sys

import dictionary, host, packet

class PacketError(Exception):
	"""Exception class for bogus packets
	
	PacketError exceptions are only used inside the Server class to 
	abort processing of a packet.
	"""


class RADIUS(host.Host, protocol.DatagramProtocol):
	def __init__(self, hosts={}, dict=dictionary.Dictionary()):
		host.Host.__init__(self, dict=dict)
		self.hosts=hosts


	def processPacket(self, pkt):
		pass


	def createPacket(self, **kwargs):
		raise NotImplementedError, "Attempted to use a pure base class"


	def datagramReceived(self, datagram, (host, port)):
		try:
			pkt=self.CreatePacket(packet=datagram)
		except packet.PacketError, err:
			log.msg("Dropping invalid packet: " + str(err))
			return

		if not self.hosts.has_key(host):
			log.msg("Dropping packet from unknown host " + host)
			return
		
		pkt.source=(host, port)
		try:
			self.processPacket(pkt)
		except PacketError, err:
			log.msg("Dropping packet from %s: %s" % (host, str(err)))



class RADIUSAccess(RADIUS):
	def createPacket(self, **kwargs):
		self.CreateAuthPacket(**kwargs)


	def processPacket(self, pkt):
		if pkt.code!=packet.AccessRequest:
			raise PacketError, "non-AccessRequest packet on authentication socket"


class RADIUSAccounting(RADIUS):
	def createPacket(self, **kwargs):
		self.CreateAcctPacket(**kwargs)


	def processPacket(self, pkt):
		if pkt.code!=packet.AccountingRequest:
			raise PacketError, "non-AccountingRequest packet on authentication socket"

if __name__=="__main__":
	log.startLogging(sys.stdout, 0)
	reactor.listenUDP(1812, RADIUSAccess())
	reactor.listenUDP(1813, RADIUSAccounting())
	reactor.run()