/**
 * Copyright (C) FuseSource, Inc.
 * http://fusesource.com
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.fusesource.fabric.fab.osgi.commands.fab;

import org.fusesource.fabric.fab.DependencyTree;
import org.fusesource.fabric.fab.osgi.internal.Bundles;
import org.fusesource.fabric.fab.osgi.internal.FabClassPathResolver;
import org.osgi.framework.Bundle;
import org.osgi.service.packageadmin.ExportedPackage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Set;

/**
 * Base class which processes the transitive FAB bundles which are not being used by other bundles
 */
public abstract class ProcessUnusedBundles extends FabCommandSupport {
    private static final transient Logger LOG = LoggerFactory.getLogger(UninstallCommand.class);

    @Override
    protected void doExecute(Bundle bundle, FabClassPathResolver resolver) throws Exception {
        // lets process the bundles from the deepest dependencies first
        List<DependencyTree> sharedDependencies = resolver.getSharedDependencies();
        List<Bundle> bundles = new ArrayList<Bundle>();
        for (DependencyTree dependency : sharedDependencies) {
            addBundlesForDependency(dependency, bundles);
        }
        bundles.add(bundle);

        Set<Bundle> bundleSet = new HashSet<Bundle>(bundles);
        for (Bundle b : bundles) {
            if (!bundleUsedByOtherBundles(b, bundleSet)) {
                processBundle(b);
            }
        }
    }

    protected void addBundlesForDependency(DependencyTree dependency, List<Bundle> bundles) throws IOException {
        String name = dependency.getBundleSymbolicName();
        String version = dependency.getVersion();
        Bundle bundle = Bundles.findBundle(bundleContext, name, version);
        if (bundle != null) {
            bundles.add(bundle);
        } else {
            /*
            boolean found = false;
            Set<String> packages = dependency.getPackages();
            for (String packageName : packages) {
                ExportedPackage[] exportedPackages = getPackageAdmin().getExportedPackages(packageName);
                if (exportedPackages != null) {
                    for (ExportedPackage exportedPackage : exportedPackages) {
                        bundle = exportedPackage.getExportingBundle();
                        if (bundle != null) {
                            found = true;
                            if (!bundles.contains(bundle)) {
                                bundles.add(bundle);
                            }
                        }
                    }
                }
            }
            if (!found) {
                System.out.println("Warning could not find bundle: " + name + " version: " + version);
            }
            */
        }
    }

    protected boolean bundleUsedByOtherBundles(Bundle bundle, Set<Bundle> bundleSet) {
        ExportedPackage[] exportedPackages = getPackageAdmin().getExportedPackages(bundle);
        if (exportedPackages != null) {
            for (ExportedPackage exportedPackage : exportedPackages) {
                Bundle[] importingBundles = exportedPackage.getImportingBundles();
                if (importingBundles != null) {
                    for (Bundle importingBundle : importingBundles) {
                        if (!importingBundle.equals(bundle) && !bundleSet.contains(importingBundle)) {
                            System.out.println("Not processing bundle " + bundle + " as its used by " + importingBundle);
                            return true;
                        }
                    }
                }
            }
        }
        return false;
    }

    protected abstract void processBundle(Bundle bundle);
}