/*
 * Copyright (c) 2016 Ericsson India Global Services Pvt Ltd. and others.  All rights reserved.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
 * and is available at http://www.eclipse.org/legal/epl-v10.html
 */

package org.opendaylight.vpnservice.elan.cli.l2gw;

import java.util.concurrent.ConcurrentMap;

import org.apache.karaf.shell.commands.Command;
import org.apache.karaf.shell.commands.Option;
import org.apache.karaf.shell.console.OsgiCommandSupport;
import org.opendaylight.elanmanager.utils.ElanL2GwCacheUtils;
import org.opendaylight.vpnservice.neutronvpn.api.l2gw.L2GatewayDevice;
import org.opendaylight.vpnservice.neutronvpn.api.l2gw.utils.L2GatewayCacheUtils;
import org.opendaylight.vpnservice.utils.cache.CacheUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@Command(scope = "l2gw", name = "show-cache", description = "display l2gateways cache")
public class L2GwUtilsCacheCli extends OsgiCommandSupport {
    private static final Logger logger = LoggerFactory.getLogger(L2GwUtilsCacheCli.class);

    private static final String DEMARCATION = "=================================";

    @Option(name = "-cache", aliases = {"--cache"}, description = "cache name",
            required = false, multiValued = false)
    String cacheName = null;

    @Option(name = "-elan", aliases = {"--elan"}, description = "elan name",
            required = false, multiValued = false)
    String elanName;

    @Override
    protected Object doExecute() {
        try {
            if (cacheName == null) {
                System.out.println("Available caches");
                System.out.println(ElanL2GwCacheUtils.L2GATEWAY_CONN_CACHE_NAME);
                System.out.println(L2GatewayCacheUtils.L2GATEWAY_CACHE_NAME);
                return null;
            }
            switch (cacheName) {
            case ElanL2GwCacheUtils.L2GATEWAY_CONN_CACHE_NAME:
                dumpElanL2GwCache();
                break;
            case L2GatewayCacheUtils.L2GATEWAY_CACHE_NAME:
                dumpL2GwCache();
                break;
            }
        } catch (Exception e) {
        }

        return null;
    }

    private void dumpL2GwCache() {
        ConcurrentMap<String, L2GatewayDevice> devices = (ConcurrentMap<String, L2GatewayDevice>) CacheUtil
                .getCache(L2GatewayCacheUtils.L2GATEWAY_CACHE_NAME);
        if (devices == null) {
            System.out.println("no devices are present in cache");
            return;
        }
        for (String deviceName : devices.keySet()) {
            System.out.println("device "+ devices.get(deviceName));
        }
    }

    private void dumpElanL2GwCache() {
        if (elanName == null) {
            ConcurrentMap<String, ConcurrentMap<String, L2GatewayDevice>> cache =
                    (ConcurrentMap<String, ConcurrentMap<String, L2GatewayDevice>>) CacheUtil.getCache(
                            cacheName);
            if (cache == null) {
                System.out.println("no devices are present in elan cache");
            }
            for (String elan : cache.keySet()) {
                print(elan, cache.get(elan));
                System.out.println(DEMARCATION);
                System.out.println(DEMARCATION);
            }
            return;
        }
        ConcurrentMap<String, L2GatewayDevice> elanDevices = ElanL2GwCacheUtils
                .getAllElanL2GatewayDevicesFromCache(elanName);
        print(elanName, elanDevices);
    }

    private void print(String elan,
            ConcurrentMap<String, L2GatewayDevice> devices) {
        System.out.println("Elan name : "+elan);
        System.out.println("No of devices in elan "+devices.keySet().size());
        for (String deviceName : devices.keySet()) {
            System.out.println("device "+ devices.get(deviceName));
        }
    }
}