// ndppd - NDP Proxy Daemon
// Copyright (C) 2011  Daniel Adolfsson <daniel.adolfsson@tuhox.com>
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.
#include <algorithm>

#include "ndppd.h"
#include "proxy.h"
#include "iface.h"
#include "session.h"

__NDPPD_NS_BEGIN

std::list<weak_ptr<session> > session::_sessions;

void session::update_all(int elapsed_time)
{
   for(std::list<weak_ptr<session> >::iterator it = _sessions.begin();
       it != _sessions.end(); )
   {
      strong_ptr<session> se = *it++;

      if((se->_ttl -= elapsed_time) >= 0)
         continue;

      switch(se->_status)
      {
      case session::WAITING:
         DBG("session is now invalid");
         se->_status = session::INVALID;
         se->_ttl    = se->_pr->ttl();
         break;

      default:
         se->_pr->remove_session(se);
      }
   }
}

session::~session()
{
   DBG("session::~session() this=%x", this);

   _sessions.remove(_ptr);

   for(std::list<strong_ptr<iface> >::iterator it = _ifaces.begin();
       it != _ifaces.end(); it++)
   {
      (*it)->remove_session(_ptr);
   }
}

strong_ptr<session> session::create(const strong_ptr<proxy>& pr, const address& saddr,
   const address& daddr, const address& taddr)
{
   strong_ptr<session> se(new session());

   se->_ptr   = se;
   se->_pr    = pr;
   se->_saddr = saddr;
   se->_taddr = taddr;
   se->_daddr = daddr;
   se->_ttl   = pr->timeout();

   _sessions.push_back(se);

   DBG("session::create() pr=%x, saddr=%s, daddr=%s, taddr=%s, =%x",
      (proxy *)pr, saddr.to_string().c_str(), daddr.to_string().c_str(),
      taddr.to_string().c_str(), (session *)se);

   return se;
}

void session::add_iface(const strong_ptr<iface>& ifa)
{
   if(std::find(_ifaces.begin(), _ifaces.end(), ifa) != _ifaces.end())
      return;

   ifa->add_session(_ptr);
   _ifaces.push_back(ifa);
}

void session::send_solicit()
{
   DBG("session::send_solicit() (%d)", _ifaces.size());

   for(std::list<strong_ptr<iface> >::iterator it = _ifaces.begin();
       it != _ifaces.end(); it++)
   {
      DBG(" - %s", (*it)->name().c_str());
      (*it)->write_solicit(_taddr);
   }
}

void session::send_advert()
{
   _pr->ifa()->write_advert(_saddr, _taddr, _pr->router());
}

void session::handle_advert()
{
   _status = VALID;
   _ttl    = _pr->ttl();

   send_advert();
}

const address& session::taddr() const
{
   return _taddr;
}

const address& session::saddr() const
{
   return _saddr;
}

const address& session::daddr() const
{
   return _daddr;
}

int session::status() const
{
   return _status;
}

void session::status(int val)
{
   _status = val;
}

__NDPPD_NS_END