package org.opendaylight.bgpmanager.thrift.server.implementation;

import org.opendaylight.bgpmanager.BgpManager;
import org.opendaylight.bgpmanager.FibDSWriter;
import org.opendaylight.bgpmanager.thrift.gen.BgpUpdater;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

class BgpUpdateHandler implements BgpUpdater.Iface {

    private static final Logger logger = LoggerFactory.getLogger(BgpUpdateHandler.class);
    private BgpManager bgpManager;
    private FibDSWriter fibDSWriter;

    public BgpUpdateHandler(BgpManager bgpMgr, FibDSWriter dsWriter) {
        bgpManager = bgpMgr;
        fibDSWriter = dsWriter;

        //Test
        onUpdatePushRoute("5", "10.1.1.2", 32, "1.2.3.4", 200);
        onUpdatePushRoute("5", "10.1.1.3", 32, "1.2.3.5", 400);
        onUpdatePushRoute("10", "10.10.0.10", 32, "5.4.3.2", 600);
        onUpdateWithdrawRoute("5", "10.1.1.3", 32);


    }

    public void onUpdatePushRoute(String rd, String prefix, int plen,
                                String nexthop, int label) {

       logger.info("Route add ** " + rd + " ** " + prefix + "/" + plen
               + " ** " + nexthop + " ** " + label);
        //Write to FIB in Data Store
        fibDSWriter.addFibEntryToDS(rd, prefix + "/" + plen, nexthop, label);

   }

   public void onUpdateWithdrawRoute(String rd, String prefix, int plen) {
       logger.info("Route del ** " + rd + " ** " + prefix + "/" + plen);
       fibDSWriter.removeFibEntryFromDS(rd, prefix + "/" + plen);

   }

   public void onStartConfigResyncNotification() {
       logger.info("BGP (re)started");
       bgpManager.reInitConn();
   }

}