Synnefo » Pithos Android Client

<?xml version="1.0" encoding="UTF-8"?>

<classpath>

	<classpathentry kind="src" path="src"/>

	<classpathentry kind="src" path="gen"/>

	<classpathentry kind="con" path="com.android.ide.eclipse.adt.ANDROID_FRAMEWORK"/>

	<classpathentry kind="output" path="bin"/>

</classpath>

<?xml version="1.0" encoding="UTF-8"?>

<projectDescription>

	<name>android-rackspacecloud</name>

	<comment></comment>

	<projects>

	</projects>

	<buildSpec>

		<buildCommand>

			<name>com.android.ide.eclipse.adt.ResourceManagerBuilder</name>

			<arguments>

			</arguments>

		</buildCommand>

		<buildCommand>

			<name>com.android.ide.eclipse.adt.PreCompilerBuilder</name>

			<arguments>

			</arguments>

		</buildCommand>

		<buildCommand>

			<name>org.eclipse.jdt.core.javabuilder</name>

			<arguments>

			</arguments>

		</buildCommand>

		<buildCommand>

			<name>com.android.ide.eclipse.adt.ApkBuilder</name>

			<arguments>

			</arguments>

		</buildCommand>

	</buildSpec>

	<natures>

		<nature>com.android.ide.eclipse.adt.AndroidNature</nature>

		<nature>org.eclipse.jdt.core.javanature</nature>

	</natures>

</projectDescription>

<?xml version="1.0" encoding="utf-8"?>

<manifest xmlns:android="http://schemas.android.com/apk/res/android"

      package="com.rackspacecloud.android"

      android:versionCode="1"

      android:versionName="1.0">

    <application android:icon="@drawable/rackspace60" android:label="@string/app_name">

        <activity android:name=".RackspaceCloudActivity"

                  android:label="@string/app_name">

            <intent-filter>

                <action android:name="android.intent.action.MAIN" />

                <category android:name="android.intent.category.LAUNCHER" />

            </intent-filter>

        </activity>

        <activity android:name=".TabViewActivity" android:label="@string/app_name">

            <intent-filter>

                <action android:name="android.intent.action.MAIN"/>

                <category android:name="android.intent.category.APPLICATION"/>

            </intent-filter>

        </activity>

        <activity android:name=".ListServersActivity" android:label="@string/app_name">

            <intent-filter>

                <action android:name="android.intent.action.MAIN"/>

                <category android:name="android.intent.category.APPLICATION"/>

            </intent-filter>

        </activity>

    </application>

    <uses-sdk android:minSdkVersion="4" />

<uses-permission android:name="android.permission.INTERNET"></uses-permission>

</manifest> 

# This file is automatically generated by Android Tools.

# Do not modify this file -- YOUR CHANGES WILL BE ERASED!

# 

# This file must be checked in Version Control Systems.

# 

# To customize properties used by the Ant build system use,

# "build.properties", and override values to adapt the script to your

# project structure.

# Indicates whether an apk should be generated for each density.

split.density=false

# Project target.

target=android-7

target

# use glob syntax.

syntax: glob

.settings

.classpath

.project

jclouds-extensions-project.iml

jclouds-extensions-project.ipr

jclouds-extensions-project.iws

# use glob syntax.

syntax: glob

target

.settings

.classpath

.project

jclouds-apachehc.iml

jclouds-apachehc.ipr

jclouds-apachehc.iws

<?xml version="1.0" encoding="UTF-8"?>

<!--

    Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.

    ====================================================================

-->

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <parent>

        <artifactId>jclouds-extensions-project</artifactId>

        <groupId>org.jclouds</groupId>

        <version>1.0-SNAPSHOT</version>

    </parent>

    <artifactId>jclouds-apachehc</artifactId>

    <name>jclouds Apache Http Components Client</name>

    <packaging>jar</packaging>

    <description>Apache HttpComponents client</description>

    <scm>

        <connection>scm:svn:http://jclouds.googlecode.com/svn/trunk</connection>

        <developerConnection>scm:svn:https://jclouds.googlecode.com/svn/trunk</developerConnection>

        <url>http://jclouds.googlecode.com/svn/trunk</url>

    </scm>

    <dependencies>

        <dependency>

            <groupId>org.apache.httpcomponents</groupId>

            <artifactId>httpclient</artifactId>

            <version>4.0.1</version>

        </dependency>

        <dependency>

            <groupId>org.mortbay.jetty</groupId>

            <artifactId>jetty</artifactId>

            <scope>test</scope>

        </dependency>

    </dependencies>

</project>

/**

 *

 * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.jclouds.http.apachehc;

import java.io.IOException;

import java.net.URI;

import java.util.concurrent.ExecutorService;

import javax.inject.Named;

import org.apache.http.HttpHost;

import org.apache.http.client.ClientProtocolException;

import org.apache.http.client.HttpClient;

import org.apache.http.client.methods.HttpUriRequest;

import org.jclouds.Constants;

import org.jclouds.http.HttpRequest;

import org.jclouds.http.HttpResponse;

import org.jclouds.http.handlers.DelegatingErrorHandler;

import org.jclouds.http.handlers.DelegatingRetryHandler;

import org.jclouds.http.internal.BaseHttpCommandExecutorService;

import org.jclouds.http.internal.HttpWire;

import com.google.inject.Inject;

/**

 * Simple implementation of a {@link HttpFutureCommandClient}, Apache Components HttpClient 4.x.

 * 

 * @author Sam Tunnicliffe

 * @author Adrian Cole

 */

public class ApacheHCHttpCommandExecutorService extends

         BaseHttpCommandExecutorService<HttpUriRequest> {

   private final HttpClient client;

   @Inject

   ApacheHCHttpCommandExecutorService(

            @Named(Constants.PROPERTY_IO_WORKER_THREADS) ExecutorService ioWorkerExecutor,

            DelegatingRetryHandler retryHandler, DelegatingErrorHandler errorHandler,

            HttpWire wire, HttpClient client) {

      super(ioWorkerExecutor, retryHandler, errorHandler, wire);

      this.client = client;

   }

   @Override

   protected HttpUriRequest convert(HttpRequest request) throws IOException {

      return ApacheHCUtils.convertToApacheRequest(request);

   }

   @Override

   protected HttpResponse invoke(HttpUriRequest nativeRequest) throws IOException {

      org.apache.http.HttpResponse nativeResponse = executeRequest(nativeRequest);

      return ApacheHCUtils.convertToJCloudsResponse(nativeResponse);

   }

   private org.apache.http.HttpResponse executeRequest(HttpUriRequest nativeRequest)

            throws IOException, ClientProtocolException {

      URI endpoint = URI.create(nativeRequest.getRequestLine().getUri());

      HttpHost host = new HttpHost(endpoint.getHost(), endpoint.getPort(), endpoint.getScheme());

      org.apache.http.HttpResponse nativeResponse = client.execute(host, nativeRequest);

      return nativeResponse;

   }

   @Override

   protected void cleanup(HttpUriRequest nativeResponse) {

      // No cleanup necessary

   }

}

/**

 *

 * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.jclouds.http.apachehc;

import java.io.File;

import java.io.FilterInputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.UnsupportedEncodingException;

import javax.inject.Singleton;

import javax.ws.rs.HttpMethod;

import javax.ws.rs.core.HttpHeaders;

import org.apache.http.Header;

import org.apache.http.HttpEntity;

import org.apache.http.HttpEntityEnclosingRequest;

import org.apache.http.client.methods.HttpDelete;

import org.apache.http.client.methods.HttpGet;

import org.apache.http.client.methods.HttpHead;

import org.apache.http.client.methods.HttpPost;

import org.apache.http.client.methods.HttpPut;

import org.apache.http.client.methods.HttpUriRequest;

import org.apache.http.entity.ByteArrayEntity;

import org.apache.http.entity.FileEntity;

import org.apache.http.entity.InputStreamEntity;

import org.apache.http.entity.StringEntity;

import org.jclouds.http.HttpRequest;

import org.jclouds.http.HttpResponse;

import org.jclouds.http.Payload;

/**

 * 

 * @author Adrian Cole

 */

@Singleton

public class ApacheHCUtils {

   public static final String USER_AGENT = "jclouds/1.0 httpclient/4.0.1";

   public static HttpUriRequest convertToApacheRequest(HttpRequest request) {

      HttpUriRequest apacheRequest;

      if (request.getMethod().equals(HttpMethod.HEAD)) {

         apacheRequest = new HttpHead(request.getEndpoint());

      } else if (request.getMethod().equals(HttpMethod.GET)) {

         apacheRequest = new HttpGet(request.getEndpoint());

      } else if (request.getMethod().equals(HttpMethod.DELETE)) {

         apacheRequest = new HttpDelete(request.getEndpoint());

      } else if (request.getMethod().equals(HttpMethod.PUT)) {

         apacheRequest = new HttpPut(request.getEndpoint());

      } else if (request.getMethod().equals(HttpMethod.POST)) {

         apacheRequest = new HttpPost(request.getEndpoint());

      } else {

         throw new UnsupportedOperationException(request.getMethod());

      }

      Payload payload = request.getPayload();

      // Since we may remove headers, ensure they are added to the apache

      // request after this block

      if (apacheRequest instanceof HttpEntityEnclosingRequest) {

         if (payload != null) {

            String lengthString = request.getFirstHeaderOrNull(HttpHeaders.CONTENT_LENGTH);

            if (lengthString == null) {

               throw new IllegalStateException("no Content-Length header on request: "

                        + apacheRequest);

            }

            long contentLength = Long.parseLong(lengthString);

            String contentType = request.getFirstHeaderOrNull(HttpHeaders.CONTENT_TYPE);

            addEntityForContent(HttpEntityEnclosingRequest.class.cast(apacheRequest), payload

                     .getRawContent(), contentType, contentLength);

         }

      } else {

         apacheRequest.addHeader(HttpHeaders.CONTENT_LENGTH, "0");

      }

      for (String header : request.getHeaders().keySet()) {

         for (String value : request.getHeaders().get(header))

            // apache automatically tries to add content length header

            if (!header.equals(HttpHeaders.CONTENT_LENGTH))

               apacheRequest.addHeader(header, value);

      }

      apacheRequest.addHeader(HttpHeaders.USER_AGENT, USER_AGENT);

      return apacheRequest;

   }

   public static void addEntityForContent(HttpEntityEnclosingRequest apacheRequest, Object content,

            String contentType, long length) {

      if (content instanceof InputStream) {

         InputStream inputStream = (InputStream) content;

         if (length == -1)

            throw new IllegalArgumentException(

                     "you must specify size when content is an InputStream");

         InputStreamEntity Entity = new InputStreamEntity(inputStream, length);

         Entity.setContentType(contentType);

         apacheRequest.setEntity(Entity);

      } else if (content instanceof String) {

         StringEntity nStringEntity = null;

         try {

            nStringEntity = new StringEntity((String) content);

         } catch (UnsupportedEncodingException e) {

            throw new UnsupportedOperationException("Encoding not supported", e);

         }

         nStringEntity.setContentType(contentType);

         apacheRequest.setEntity(nStringEntity);

      } else if (content instanceof File) {

         apacheRequest.setEntity(new FileEntity((File) content, contentType));

      } else if (content instanceof byte[]) {

         ByteArrayEntity Entity = new ByteArrayEntity((byte[]) content);

         Entity.setContentType(contentType);

         apacheRequest.setEntity(Entity);

      } else {

         throw new UnsupportedOperationException("Content class not supported: "

                  + content.getClass().getName());

      }

      assert (apacheRequest.getEntity() != null);

   }

   public static HttpResponse convertToJCloudsResponse(org.apache.http.HttpResponse apacheResponse)

            throws IOException {

      HttpResponse response = new HttpResponse();

      if (apacheResponse.getEntity() != null) {

         // response.setContent(consumeOnClose(apacheResponse.getEntity()));

         response.setContent(apacheResponse.getEntity().getContent());

      }

      for (Header header : apacheResponse.getAllHeaders()) {

         response.getHeaders().put(header.getName(), header.getValue());

      }

      response.setStatusCode(apacheResponse.getStatusLine().getStatusCode());

      response.setMessage(apacheResponse.getStatusLine().getReasonPhrase());

      return response;

   }

   public static InputStream consumeOnClose(HttpEntity httpEntity) throws IllegalStateException,

            IOException {

      return new ConsumeOnCloseInputStream(httpEntity);

   }

   static class ConsumeOnCloseInputStream extends FilterInputStream {

      private final HttpEntity httpEntity;

      protected ConsumeOnCloseInputStream(HttpEntity httpEntity) throws IllegalStateException,

               IOException {

         super(httpEntity.getContent());

         this.httpEntity = httpEntity;

      }

      boolean closed;

      @Override

      public void close() throws IOException {

         try {

            if (!closed) {

               httpEntity.consumeContent();

            }

         } finally {

            closed = true;

            super.close();

         }

      }

   }

}

/**

 *

 * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.jclouds.http.apachehc.config;

import java.io.Closeable;

import java.io.IOException;

import java.net.ProxySelector;

import java.security.KeyManagementException;

import java.security.NoSuchAlgorithmException;

import javax.inject.Singleton;

import javax.net.ssl.SSLContext;

import org.apache.http.HttpVersion;

import org.apache.http.client.HttpClient;

import org.apache.http.conn.ClientConnectionManager;

import org.apache.http.conn.params.ConnManagerParams;

import org.apache.http.conn.params.ConnPerRoute;

import org.apache.http.conn.params.ConnPerRouteBean;

import org.apache.http.conn.scheme.PlainSocketFactory;

import org.apache.http.conn.scheme.Scheme;

import org.apache.http.conn.scheme.SchemeRegistry;

import org.apache.http.conn.ssl.SSLSocketFactory;

import org.apache.http.conn.ssl.X509HostnameVerifier;

import org.apache.http.impl.client.DefaultHttpClient;

import org.apache.http.impl.conn.ProxySelectorRoutePlanner;

import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager;

import org.apache.http.params.BasicHttpParams;

import org.apache.http.params.CoreConnectionPNames;

import org.apache.http.params.CoreProtocolPNames;

import org.apache.http.params.HttpParams;

import org.apache.http.params.HttpProtocolParams;

import org.jclouds.http.HttpCommandExecutorService;

import org.jclouds.http.HttpUtils;

import org.jclouds.http.TransformingHttpCommandExecutorService;

import org.jclouds.http.TransformingHttpCommandExecutorServiceImpl;

import org.jclouds.http.apachehc.ApacheHCHttpCommandExecutorService;

import org.jclouds.http.config.ConfiguresHttpCommandExecutorService;

import org.jclouds.lifecycle.Closer;

import com.google.inject.AbstractModule;

import com.google.inject.Provides;

import com.google.inject.Scopes;

/**

 * Configures {@link ApacheHCHttpCommandExecutorService}.

 * 

 * Note that this uses threads

 * 

 * @author Sam Tunnicliffe

 * @author Adrian Cole

 */

@ConfiguresHttpCommandExecutorService

public class ApacheHCHttpCommandExecutorServiceModule extends AbstractModule {

   @Override

   protected void configure() {

      bindClient();

   }

   @Singleton

   @Provides

   HttpParams newBasicHttpParams(HttpUtils utils) {

      BasicHttpParams params = new BasicHttpParams();

      params.setIntParameter(CoreConnectionPNames.SOCKET_BUFFER_SIZE, 8 * 1024)

               .setBooleanParameter(CoreConnectionPNames.STALE_CONNECTION_CHECK, true)

               .setBooleanParameter(CoreConnectionPNames.TCP_NODELAY, true).setParameter(

                        CoreProtocolPNames.ORIGIN_SERVER, "jclouds/1.0");

      if (utils.getConnectionTimeout() > 0) {

         params.setIntParameter(CoreConnectionPNames.CONNECTION_TIMEOUT, utils

                  .getConnectionTimeout());

      }

      if (utils.getSocketOpenTimeout() > 0) {

         params.setIntParameter(CoreConnectionPNames.SO_TIMEOUT, utils.getSocketOpenTimeout());

      }

      if (utils.getMaxConnections() > 0)

         ConnManagerParams.setMaxTotalConnections(params, utils.getMaxConnections());

      if (utils.getMaxConnectionsPerHost() > 0) {

         ConnPerRoute connectionsPerRoute = new ConnPerRouteBean(utils.getMaxConnectionsPerHost());

         ConnManagerParams.setMaxConnectionsPerRoute(params, connectionsPerRoute);

      }

      HttpProtocolParams.setVersion(params, HttpVersion.HTTP_1_1);

      return params;

   }

   @Singleton

   @Provides

   X509HostnameVerifier newHostnameVerifier(HttpUtils utils) {

      return utils.relaxHostname() ? SSLSocketFactory.ALLOW_ALL_HOSTNAME_VERIFIER

               : SSLSocketFactory.STRICT_HOSTNAME_VERIFIER;

   }

   @Singleton

   @Provides

   ClientConnectionManager newClientConnectionManager(HttpParams params,

            X509HostnameVerifier verifier, Closer closer) throws NoSuchAlgorithmException,

            KeyManagementException {

      SchemeRegistry schemeRegistry = new SchemeRegistry();

      Scheme http = new Scheme("http", PlainSocketFactory.getSocketFactory(), 80);

      SSLContext context = SSLContext.getInstance("TLS");

      context.init(null, null, null);

      SSLSocketFactory sf = new SSLSocketFactory(context);

      sf.setHostnameVerifier(verifier);

      Scheme https = new Scheme("https", sf, 443);

      SchemeRegistry sr = new SchemeRegistry();

      sr.register(http);

      sr.register(https);

      schemeRegistry.register(new Scheme("http", PlainSocketFactory.getSocketFactory(), 80));

      schemeRegistry.register(new Scheme("https", SSLSocketFactory.getSocketFactory(), 443));

      final ClientConnectionManager cm = new ThreadSafeClientConnManager(params, schemeRegistry);

      closer.addToClose(new Closeable() {

         @Override

         public void close() throws IOException {

            cm.shutdown();

         }

      });

      return cm;

   }

   @Provides

   @Singleton

   HttpClient newDefaultHttpClient(HttpUtils utils, BasicHttpParams params,

            ClientConnectionManager cm) {

      DefaultHttpClient client = new DefaultHttpClient(cm, params);

      if (utils.useSystemProxies()) {

         ProxySelectorRoutePlanner routePlanner = new ProxySelectorRoutePlanner(client

                  .getConnectionManager().getSchemeRegistry(), ProxySelector.getDefault());

         client.setRoutePlanner(routePlanner);

      }

      return client;

   }

   protected void bindClient() {

      bind(HttpCommandExecutorService.class).to(ApacheHCHttpCommandExecutorService.class).in(

               Scopes.SINGLETON);

      bind(TransformingHttpCommandExecutorService.class).to(

               TransformingHttpCommandExecutorServiceImpl.class).in(Scopes.SINGLETON);

   }

}

/**

 *

 * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.jclouds.http.apachehc;

import static org.jclouds.Constants.PROPERTY_IO_WORKER_THREADS;

import static org.jclouds.Constants.*;

import static org.jclouds.Constants.PROPERTY_MAX_CONNECTIONS_PER_HOST;

import static org.jclouds.Constants.PROPERTY_USER_THREADS;

import java.util.Properties;

import org.jclouds.http.BaseHttpCommandExecutorServiceIntegrationTest;

import org.jclouds.http.apachehc.config.ApacheHCHttpCommandExecutorServiceModule;

import org.testng.annotations.Test;

import com.google.inject.Module;

/**

 * Tests the functionality of the {@link ApacheHCHttpCommandExecutorService}

 * 

 * @author Adrian Cole

 */

@Test

public class ApacheHCHttpCommandExecutorServiceTest extends BaseHttpCommandExecutorServiceIntegrationTest {

   static {

      System.setProperty("http.conn-manager.timeout", 1000 + "");

   }

   protected Module createConnectionModule() {

      return new ApacheHCHttpCommandExecutorServiceModule();

   }

   protected void addConnectionProperties(Properties props) {

      props.setProperty(PROPERTY_MAX_CONNECTIONS_PER_CONTEXT, 20 + "");

      props.setProperty(PROPERTY_MAX_CONNECTIONS_PER_HOST, 0 + "");

      props.setProperty(PROPERTY_CONNECTION_TIMEOUT, 100 + "");

      props.setProperty(PROPERTY_SO_TIMEOUT, 100 + "");

      props.setProperty(PROPERTY_IO_WORKER_THREADS, 3 + "");

      props.setProperty(PROPERTY_USER_THREADS, 0 + "");

   }

}

# use glob syntax.

syntax: glob

target

.settings

.classpath

.project

jclouds-bouncycastle.iml

jclouds-bouncycastle.ipr

jclouds-bouncycastle.iws

====

    Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.

    ====================================================================

====

#

# An extension to use the Bouncy Castle Crypto API (http://www.bouncycastle.org/) 

# as an encryption library in jclouds.

#

# TODO: Usage example.

<?xml version="1.0" encoding="UTF-8"?>

<!--

    Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.

    ====================================================================

-->

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <parent>

        <groupId>org.jclouds</groupId>

        <artifactId>jclouds-extensions-project</artifactId>

        <version>1.0-SNAPSHOT</version>

    </parent>

    <artifactId>jclouds-bouncycastle</artifactId>

    <name>jclouds bouncycastle EncryptionService Module</name>

    <description>jclouds bouncycastle EncryptionService Module</description>

    <dependencies>

        <dependency>

            <groupId>org.bouncycastle</groupId>

            <artifactId>bcprov-jdk15</artifactId>

            <version>1.44</version>

        </dependency>

    </dependencies>

</project>

/**

 *

 * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.jclouds.encryption.bouncycastle;

import java.io.ByteArrayOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.security.InvalidKeyException;

import java.security.NoSuchAlgorithmException;

import java.security.NoSuchProviderException;

import javax.inject.Singleton;

import org.bouncycastle.crypto.Digest;

import org.bouncycastle.crypto.digests.MD5Digest;

import org.bouncycastle.crypto.digests.SHA1Digest;

import org.bouncycastle.crypto.digests.SHA256Digest;

import org.bouncycastle.crypto.io.DigestOutputStream;

import org.bouncycastle.crypto.macs.HMac;

import org.bouncycastle.crypto.params.KeyParameter;

import org.bouncycastle.util.encoders.Base64;

import org.jclouds.encryption.internal.BaseEncryptionService;

import org.jclouds.util.Utils;

import com.google.common.io.Closeables;

/**

 * 

 * @author Adrian Cole

 */

@Singleton

public class BouncyCastleEncryptionService extends BaseEncryptionService {

   public String hmacSha256Base64(String toEncode, byte[] key) throws NoSuchAlgorithmException,

            NoSuchProviderException, InvalidKeyException {

      Digest digest = new SHA256Digest();

      return hmacBase64(toEncode, key, digest);

   }

   private String hmacBase64(String toEncode, byte[] key, Digest digest) {

      byte[] resBuf = hmac(toEncode, key, digest);

      return toBase64String(resBuf);

   }

   public byte[] hmac(String toEncode, byte[] key, Digest digest) {

      HMac hmac = new HMac(digest);

      byte[] resBuf = new byte[hmac.getMacSize()];

      byte[] plainBytes = Utils.encodeString(toEncode);

      byte[] keyBytes = key;

      hmac.init(new KeyParameter(keyBytes));

      hmac.update(plainBytes, 0, plainBytes.length);

      hmac.doFinal(resBuf, 0);

      return resBuf;

   }

   public String hmacSha1Base64(String toEncode, byte[] key) throws NoSuchAlgorithmException,

            NoSuchProviderException, InvalidKeyException {

      Digest digest = new SHA1Digest();

      return hmacBase64(toEncode, key, digest);

   }

   public byte[] md5(byte[] plainBytes) {

      MD5Digest eTag = new MD5Digest();

      byte[] resBuf = new byte[eTag.getDigestSize()];

      eTag.update(plainBytes, 0, plainBytes.length);

      eTag.doFinal(resBuf, 0);

      return resBuf;

   }

   public byte[] md5(InputStream toEncode) {

      MD5Digest eTag = new MD5Digest();

      byte[] resBuf = new byte[eTag.getDigestSize()];

      byte[] buffer = new byte[1024];

      int numRead = -1;

      try {

         do {

            numRead = toEncode.read(buffer);

            if (numRead > 0) {

               eTag.update(buffer, 0, numRead);

            }

         } while (numRead != -1);

      } catch (IOException e) {

         throw new RuntimeException(e);

      } finally {

         Closeables.closeQuietly(toEncode);

      }

      eTag.doFinal(resBuf, 0);

      return resBuf;

   }

   public String toBase64String(byte[] resBuf) {

      return new String(Base64.encode(resBuf));

   }

   public MD5InputStreamResult generateMD5Result(InputStream toEncode) {

      MD5Digest eTag = new MD5Digest();

      byte[] resBuf = new byte[eTag.getDigestSize()];

      byte[] buffer = new byte[1024];

      ByteArrayOutputStream out = new ByteArrayOutputStream();

      long length = 0;

      int numRead = -1;

      try {

         do {

            numRead = toEncode.read(buffer);

            if (numRead > 0) {

               length += numRead;

               eTag.update(buffer, 0, numRead);

               out.write(buffer, 0, numRead);

            }

         } while (numRead != -1);

      } catch (IOException e) {

         throw new RuntimeException(e);

      } finally {

         Closeables.closeQuietly(out);

         Closeables.closeQuietly(toEncode);

      }

      eTag.doFinal(resBuf, 0);

      return new MD5InputStreamResult(out.toByteArray(), resBuf, length);

   }

   public byte[] fromBase64String(String encoded) {

      return Base64.decode(encoded);

   }

   @Override

   public MD5OutputStream md5OutputStream(OutputStream out) {

      return new BouncyCastleMD5OutputStream(out);

   }

   public static class BouncyCastleMD5OutputStream extends MD5OutputStream {

      public BouncyCastleMD5OutputStream(OutputStream out) {

         super(new DigestOutputStream(out, new MD5Digest()));

      }

      @Override

      public byte[] getMD5() {

         MD5Digest digest = (MD5Digest) ((DigestOutputStream) out).getDigest();

         byte[] resBuf = new byte[digest.getDigestSize()];

         digest.doFinal(resBuf, 0);

         return resBuf;

      }

   }

}

/**

 *

 * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.jclouds.encryption.bouncycastle.config;

import org.jclouds.encryption.EncryptionService;

import org.jclouds.encryption.bouncycastle.BouncyCastleEncryptionService;

import com.google.inject.AbstractModule;

/**

 * Configures EncryptionService of type {@link BouncyCastleEncryptionService}

 * 

 * @author Adrian Cole

 * 

 */

public class BouncyCastleEncryptionServiceModule extends AbstractModule {

   @Override

   protected void configure() {

      bind(EncryptionService.class).to(BouncyCastleEncryptionService.class);

   }

}

/**

 *

 * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.jclouds.encryption.bouncycastle;

import org.jclouds.encryption.EncryptionService;

import org.jclouds.encryption.EncryptionServiceTest;

import org.jclouds.encryption.bouncycastle.config.BouncyCastleEncryptionServiceModule;

import org.testng.annotations.BeforeTest;

import org.testng.annotations.Test;

import com.google.inject.Guice;

import com.google.inject.Injector;

/**

 * This tests the performance of Digest commands.

 * 

 * @author Adrian Cole

 */

@Test(groups = "performance", sequential = true, testName = "jclouds.BouncyCastleEncryptionServiceTest")

public class BouncyCastleEncryptionServiceTest extends EncryptionServiceTest {

   @BeforeTest

   protected void createEncryptionService() {

      Injector i = Guice.createInjector(new BouncyCastleEncryptionServiceModule());

      encryptionService = i.getInstance(EncryptionService.class);

      assert encryptionService instanceof BouncyCastleEncryptionService;

   }

}

# use glob syntax.

syntax: glob

target

.settings

.classpath

.project

jclouds-enterprise.iml

jclouds-enterprise.ipr

jclouds-enterprise.iws

====

    Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.

    ====================================================================

====

#

# Sets up most commonly requested options for enterprise java support

#

# TODO: Usage example.

<?xml version="1.0" encoding="UTF-8"?>

<!--

    Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.

    ====================================================================

-->

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <parent>

        <groupId>org.jclouds</groupId>

        <artifactId>jclouds-extensions-project</artifactId>

        <version>1.0-SNAPSHOT</version>

    </parent>

    <artifactId>jclouds-enterprise</artifactId>

    <name>jclouds enterprise Module</name>

    <description>jclouds enterprise configuration</description>

    <dependencies>

        <dependency>

            <groupId>${project.groupId}</groupId>

            <artifactId>jclouds-joda</artifactId>

            <version>${project.version}</version>

        </dependency>

        <dependency>

            <groupId>${project.groupId}</groupId> 

            <artifactId>jclouds-bouncycastle</artifactId>

            <version>${project.version}</version>

        </dependency>

        <dependency>

            <groupId>org.mortbay.jetty</groupId>

            <artifactId>jetty</artifactId>

            <scope>test</scope>

        </dependency>

    </dependencies>

    <build>

        <finalName>${project.artifactId}</finalName>

        <plugins>

            <plugin>

                <artifactId>maven-assembly-plugin</artifactId>

                <executions>

                    <execution>

                        <phase>package</phase>

                        <goals>

                            <goal>single</goal>

                        </goals>

                        <configuration>

                            <descriptorRefs>

                                <descriptorRef>jar-with-dependencies</descriptorRef>

                            </descriptorRefs>

                        </configuration>

                    </execution>

                </executions>

            </plugin>

        </plugins>

    </build>

</project>

/**

 *

 * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.jclouds.enterprise.config;

import java.util.concurrent.ExecutorService;

import org.jclouds.concurrent.config.ConfiguresExecutorService;

import org.jclouds.concurrent.config.ExecutorServiceModule;

import org.jclouds.date.joda.config.JodaDateServiceModule;

import org.jclouds.encryption.bouncycastle.config.BouncyCastleEncryptionServiceModule;

/**

 * Configures Enterprise-grade components

 * 

 * @author Adrian Cole

 * 

 */

@ConfiguresExecutorService

public class EnterpriseConfigurationModule extends ExecutorServiceModule {

   public EnterpriseConfigurationModule(ExecutorService userThreads, ExecutorService ioThreads) {

      super(userThreads, ioThreads);

   }

   public EnterpriseConfigurationModule() {

      super();

   }

   @Override

   protected void configure() {

      install(new BouncyCastleEncryptionServiceModule());

      install(new JodaDateServiceModule());

   }

}

/**

 *

 * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.jclouds.enterprise.config;

import static org.jclouds.Constants.PROPERTY_IO_WORKER_THREADS;

import static org.jclouds.Constants.PROPERTY_MAX_CONNECTIONS_PER_CONTEXT;

import static org.jclouds.Constants.PROPERTY_MAX_CONNECTIONS_PER_HOST;

import static org.jclouds.Constants.PROPERTY_USER_THREADS;

import java.util.Properties;

import org.jclouds.http.BaseHttpCommandExecutorServiceIntegrationTest;

import org.testng.annotations.Test;

import com.google.inject.Module;

/**

 * Tests the functionality of the {@link EnterpriseConfigurationModule}

 * 

 * @author Adrian Cole

 */

@Test

public class EnterpriseConfigurationModuleTest extends BaseHttpCommandExecutorServiceIntegrationTest {

   protected Module createConnectionModule() {

      return new EnterpriseConfigurationModule();

   }

   protected void addConnectionProperties(Properties props) {

      props.setProperty(PROPERTY_MAX_CONNECTIONS_PER_CONTEXT, 50 + "");

      props.setProperty(PROPERTY_MAX_CONNECTIONS_PER_HOST, 50 + "");

      // IO workers not used in this executor

      props.setProperty(PROPERTY_IO_WORKER_THREADS, 0 + "");

      props.setProperty(PROPERTY_USER_THREADS, 5 + "");

   }

}

# use glob syntax.

syntax: glob

target

.settings

.classpath

.project

jclouds-gae.iml

jclouds-gae.ipr

jclouds-gae.iws

====

    Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.

    ====================================================================

====

#

# An extension to run jclouds on Google App Engine (http://code.google.com/appengine/).

#

# TODO: Usage example.

<?xml version="1.0" encoding="UTF-8"?>

    <!--

        Copyright (C) 2009 Cloud Conscious, LLC.

        <info@cloudconscious.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.

        ====================================================================

    -->

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <parent>

        <groupId>org.jclouds</groupId>

        <artifactId>jclouds-extensions-project</artifactId>

        <version>1.0-SNAPSHOT</version>

    </parent>

    <groupId>org.jclouds</groupId>

    <artifactId>jclouds-gae</artifactId>

    <name>jclouds Google App Engine Components</name>

    <description>Google App Engine Components</description>

    <scm>

        <connection>scm:svn:http://jclouds.googlecode.com/svn/trunk</connection>

        <developerConnection>scm:svn:https://jclouds.googlecode.com/svn/trunk</developerConnection>

        <url>http://jclouds.googlecode.com/svn/trunk</url>

    </scm>

    <dependencies>

        <dependency>

            <groupId>${project.groupId}</groupId>

            <artifactId>jclouds-joda</artifactId>

            <version>${project.version}</version>

        </dependency>

        <dependency>

            <groupId>${project.groupId}</groupId> 

            <artifactId>jclouds-bouncycastle</artifactId>

            <version>${project.version}</version>

        </dependency>

        <dependency>

            <groupId>com.google.appengine</groupId>

            <artifactId>appengine-api</artifactId>

            <version>1.3.0</version>

        </dependency>

        <dependency>

            <groupId>com.google.appengine</groupId>

            <artifactId>appengine-api-stubs</artifactId>

            <version>1.3.0</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>com.google.appengine</groupId>

            <artifactId>appengine-local-runtime</artifactId>

            <version>1.3.0</version>

            <scope>test</scope>

        </dependency>

        <dependency>

            <groupId>${project.groupId}</groupId>

            <artifactId>jclouds-core</artifactId>

            <version>${project.version}</version>

            <type>test-jar</type>

            <scope>test</scope>

            <!--

                <exclusions> <exclusion>

                <groupId>org.mortbay.jetty</groupId>

                <artifactId>jetty</artifactId> </exclusion>

                </exclusions>

            -->

        </dependency>

        <dependency>

            <groupId>org.apache.geronimo.specs</groupId>

            <artifactId>geronimo-servlet_2.5_spec</artifactId>

            <version>1.2</version>

            <scope>test</scope>

        </dependency>

    </dependencies>

</project>

/**

 *

 * Copyright (C) 2009 Cloud Conscious, LLC. <info@cloudconscious.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.jclouds.gae;

import static com.google.appengine.api.urlfetch.FetchOptions.Builder.disallowTruncate;

import java.io.ByteArrayInputStream;

import java.io.IOException;

import java.io.InputStream;

import java.net.URL;

import java.util.concurrent.ExecutorService;

import javax.inject.Inject;

import javax.inject.Named;

import javax.inject.Singleton;

import javax.ws.rs.core.HttpHeaders;