import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
/**
 * downloads a file and saves it in the bundle directory
 * @param uri = URI of the repository file
 * @param resource = bundle that should be downloaded
 * @param bundleDir = destination directory
 */
public static File downloadFile(String uri, Resource resource, File bundleDir) throws Exception {
	File localFile = new File(bundleDir,resource.getSymbolicName()+"-"+resource.getVersion()+".jar");

	FileOutputStream fos = null;
	ReadableByteChannel rbc = null;
	URL website = new URL(uri);
	rbc = Channels.newChannel(website.openStream());
	fos = new FileOutputStream(localFile);
	fos.getChannel().transferFrom(rbc, 0, 1 << 24);
	fos.close();
	rbc.close();
	return localFile;
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
/**
 * Deploys as OSGi resource to the runtime framework.
 *
 * @param repoAdmin the repository admin
 * @param r the repository resource to install
 */
private void deployResource(RepositoryAdmin repoAdmin, Resource r) {
    logger.debug("Attempting to install plugin: " + r.getSymbolicName());
    Resolver resolver = repoAdmin.resolver();
    resolver.add(r);
    if (resolver.resolve()) {
        resolver.deploy(Resolver.START);
    }
    logger.info("Plugin completed installation: " + r.getSymbolicName());
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
protected String buildRepoDescription(Resource resource) {
    String description = null;
    if (resource.getProperties() != null) {
        Object o = resource.getProperties().get("description");
        if (o != null) {
            description = o.toString();
        }
    }
    return description;
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
protected boolean isCorePlugin(Resource resource) {
    for (String c : resource.getCategories()) {
        if (c.contains("hobson-core-plugin")) {
            return true;
        }
    }
    return false;
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
protected boolean isPlugin(Resource resource) {
    for (String c : resource.getCategories()) {
        if (c.contains("hobson-plugin")) {
            return true;
        }
    }
    return false;
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
/**
 * Returns the first resource requirement associated with the Hobson API.
 *
 * @param resource the resource to analyze
 *
 * @return a Requirement instance (or null if the resource has no dependency on the Hobson API)
 */
protected Requirement getAPIRequirement(Resource resource) {
    // Note: This code grabs the first Hobson API package requirement.
    // The assumption being made here is that a plugin will never require different versions for
    // different packages within the Hobson API. While this is almost certainly a safe assumption,
    // it seemed worth making a note of :-)
    for (Requirement req : resource.getRequirements()) {
        if (req.getFilter().contains("(&(package=com.whizzosoftware.hobson.api")) {
            return req;
        }
    }
    return null;
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
@Test
public void testGetPluginsWithTwoDifferentVersions() {
    List<Resource> resources = new ArrayList<>();
    resources.add(new MockResource("foo", new Version(0, 1, 1)));
    resources.add(new MockResource("foo", new Version(0, 1, 0)));

    OSGIRepoPluginListSource pls = new OSGIRepoPluginListSource(null, null);
    Map<String,HobsonPluginDescriptor> pds = pls.getPlugins(resources.toArray(new Resource[resources.size()]));
    assertEquals(1, pds.size());
    assertNotNull(pds.get("foo"));
    HobsonPluginDescriptor pd = pds.get("foo");
    assertEquals("0.1.1", pd.getVersion());
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
public KonektiFelixResource(String id, Long bundleId, String symbolicName, String version,
		String presentationName, Repository repository, String url,
		Requirement[] requeriments, Capability[] capabilities, String[] categories,
		String licenseUrl, String description, String documentation,
		String copyright, String sourceUrl, String size, String[] keys, Resource resource,
		String bundleStatus, Bundle bundle) {
	super();
	this.id = id;
	this.bundleId = bundleId;
	this.symbolicName = symbolicName;
	this.version = version;
	this.presentationName = presentationName;
	this.repository = repository;
	this.url = url;
	this.requeriments = requeriments;
	this.capabilities = capabilities;
	this.categories = categories;
	this.licenseUrl = licenseUrl;
	this.description = description;
	this.documentation = documentation;
	this.copyright = copyright;
	this.sourceUrl = sourceUrl;
	this.size = size;
	this.keys = keys;
	this.resource = resource;
	this.bundleStatus = bundleStatus;
	this.bundle = bundle;
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
BundleUris(Repository repository) {
    for (Resource res : repository.getResources()) {
        bundleUri.put(getKey(res) , res.getURI());
    }
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
private String getKey(Resource res) {
    Version version = res.getVersion();
    Version simpleVersion = new Version(version.getMajor(), version.getMinor(), version.getMicro());
    return res.getSymbolicName() + ";" + simpleVersion.toString();
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
public boolean getAllPossibleValues(final List<Completion> completions,
        final Class<?> requiredType, final String originalUserInput,
        final String optionContext, final MethodTarget target) {
    boolean local = false;
    boolean obr = false;

    if ("".equals(optionContext)) {
        local = true;
    }

    if (optionContext.contains("local")) {
        local = true;
    }

    if (optionContext.contains("obr")) {
        obr = true;
    }

    if (local) {
        final Bundle[] bundles = context.getBundleContext().getBundles();
        if (bundles != null) {
            for (final Bundle bundle : bundles) {
                final String bsn = bundle.getSymbolicName();
                if (bsn != null && bsn.startsWith(originalUserInput)) {
                    completions.add(new Completion(bsn));
                }
            }
        }
    }

    if (obr) {
        final Repository[] repositories = repositoryAdmin
                .listRepositories();
        if (repositories != null) {
            for (final Repository repository : repositories) {
                final Resource[] resources = repository.getResources();
                if (resources != null) {
                    for (final Resource resource : resources) {
                        if (resource.getSymbolicName().startsWith(
                                originalUserInput)) {
                            completions.add(new Completion(resource
                                    .getSymbolicName()));
                        }
                    }
                }
            }
        }
    }

    return false;
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
protected Map<String,HobsonPluginDescriptor> getPlugins(Resource[] resources) {
    Capability[] apiCapabilities = getAPICapabilities();

    Map<String,HobsonPluginDescriptor> resultMap = new HashMap<>();

    for (Resource repoResource : resources) {
        String sname = repoResource.getSymbolicName();

        PluginType pluginType = PluginType.FRAMEWORK;
        if (isCorePlugin(repoResource)) {
            pluginType = PluginType.CORE;
        } else if (isPlugin(repoResource)) {
            pluginType = PluginType.PLUGIN;
        }

        // check that plugin requirements are satisfied by installed capabilities
        try {
            if (isSatisfied(getAPIRequirement(repoResource), apiCapabilities)) {
                // get the last processed version number for this plugin
                String lastVersionString = resultMap.get(sname) != null ? resultMap.get(sname).getVersion() : null;
                // if there was no last processed version number, get the currently installed version
                if (lastVersionString == null && installedPlugins != null) {
                    lastVersionString = installedPlugins.get(sname);
                }
                // only add the remote plugin to the result list if its version is newer than what is currently known
                if (lastVersionString == null || VersionUtil.versionCompare(lastVersionString, repoResource.getVersion().toString()) < 0) {
                    // see if there's an image associated with the plugin
                    String imageUrl = null;
                    for (Capability c : repoResource.getCapabilities()) {
                        if ("hobsonPlugin".equals(c.getName())) {
                            imageUrl = (String)c.getPropertiesAsMap().get("image");
                        }
                    }

                    HobsonPluginDescriptor pd = new HobsonPluginDescriptor(sname, pluginType, repoResource.getPresentationName(), buildRepoDescription(repoResource), repoResource.getVersion().toString(), PluginStatus.notInstalled(), imageUrl);
                    resultMap.put(sname, pd);
                }
            }
        } catch (InvalidSyntaxException ise) {
            logger.debug("Ignoring resource due to bad filter string", ise);
        }
    }

    return resultMap;
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
/**
 * @return the resource
 */
public Resource getResource() {
	return resource;
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
/**
 * @param resource the resource to set
 */
public void setResource(Resource resource) {
	this.resource = resource;
}
 

import org.apache.felix.bundlerepository.Resource; //导入依赖的package包/类
/**
 * Finds a Resource in a repository.
 *
 * @param repoAdmin the repository to search
 * @param pluginRef the plugin reference
 *
 * @return a Resource instance or null if not found
 *
 * @throws InvalidSyntaxException
 */
static private Resource findResource(RepositoryAdmin repoAdmin, PluginRef pluginRef) throws InvalidSyntaxException {
    Resource[] resources = repoAdmin.discoverResources("(symbolicname=" + pluginRef.symbolicName + ")");
    for (Resource r : resources) {
        if (pluginRef.symbolicName.equals(r.getSymbolicName()) && pluginRef.version.equals(r.getVersion().toString())) {
            return r;
        }
    }
    return null;
}