import java.util.*;
import java.net.*;

import ru.bitel.bgbilling.kernel.network.radius.*;
import ru.bitel.bgbilling.modules.inet.api.common.bean.*;
import ru.bitel.bgbilling.modules.inet.radius.*;

deviceParams = device.getConfigParameterMap();

nasHost = deviceParams.get( "nas.radius.host", device.getHost() );
nasHost = InetAddress.getByName( nasHost );
nasHostBytes = nasHost.getAddress();
nasPort = deviceParams.getInt( "nas.radius.port", 0 );

nasIdentifier = deviceParams.get( "nas.identifier", null );
nasSecret = deviceParams.get( "nas.secret", device.getSecret() ).getBytes();

nasCoaFixedAttributeSet = deviceParams.get( "nas.radius.coa.attributes", null );
if( Utils.notBlankString( nasCoaFixedAttributeSet ) )
{
   nasCoaFixedAttributeSet = RadiusAttributeSet.newRadiusAttributeSet( nasCoaFixedAttributeSet );
}
else
{
   nasCoaFixedAttributeSet = null;
}

nasPodFixedAttributeSet = deviceParams.get( "nas.radius.pod.attributes", null );
if( Utils.notBlankString( nasPodFixedAttributeSet ) )
{
   nasPodFixedAttributeSet = RadiusAttributeSet.newRadiusAttributeSet( nasPodFixedAttributeSet );
}
else
{
   nasPodFixedAttributeSet = null;
}

pod = new PodSupport( nasHost, nasPort, nasSecret );

public void finalize()
{
   if( pod != null )
   {
      pod.destroy();
   }
}

public void init() {}
public void destroy() {}

public Object serviceCreate( service )
{
}

public Object serviceModify( service )
{
   session = service.getSession();
   if( session == null )
   {
      return true;
   }

   oldContractServ = service.getOldContractServ();
   newContractServ = service.getNewContractServ();

   if( service.newState == InetContractServ.STATE_DISABLE )
   {
      return sessionKill( session );
   }

   optionsToAdd = event.getOptionsToAdd();
   optionsToRemove = event.getOptionsToRemove();

   if( optionsToAdd.size() > 0 || optionsToRemove.size() > 0 )
   {
      return sessionModify( session, service.serviceSessions, optionsToRemove, optionsToAdd );
   }

   return true;
}

public Object serviceCancel( service )
{
   session = service.getSession();
   if( session == null )
   {
      return true;
   }

   return sessionKill( session );
}

void preparePacket( packet, session )
{
   packet.setIntAttribute( -1, RadiusDictionary.NAS_Port, session.getDevicePort() );
   packet.setStringAttribute( -1, RadiusDictionary.Acct_Session_Id, session.getAcctSessionId() );
   packet.setStringAttribute( -1, RadiusDictionary.User_Name, session.getUsername() );
   packet.setAttribute( new RadiusAttribute.RadiusAttributeIpAddr( -1, RadiusDictionary.Framed_IP_Address, Utils.convertBytesToInt( session.getInetAddressBytes() ) ) );
   packet.setAttribute( new RadiusAttribute.RadiusAttributeIpAddr( -1, RadiusDictionary.NAS_IP_Address, Utils.convertBytesToInt( nasHostBytes ) ) );
   packet.setStringAttribute( -1, RadiusDictionary.NAS_Identifier, nasIdentifier );
}

Object sessionKill( session )
{
   packet = pod.createDisconnectRequest();
   preparePacket( packet, session )

   if( nasPodFixedAttributeSet != null )
   {
      packet.addAttributes( nasPodFixedAttributeSet );
   }

   return pod.send( packet );
}

Object sessionModify( session, serviceSessions, optionsToRemove, optionsToAdd )
{
   packet = pod.createModifyRequest();
   preparePacket( packet, session )

   for( Integer option : optionsToRemove )
   {
      // TODO:
   }

   for( Integer option : optionsToAdd )
   {
      // TODO:       
   }

   if( nasCoaFixedAttributeSet != null )
   {
      packet.addAttributes( nasCoaFixedAttributeSet );
   }

   return pod.send( packet );
}