1 files changed, 128 insertions, 0 deletions
diff --git a/sandbox/mobile-android/android-jdk-classes/src/org/apache/tuscany/sca/android/DexURLConnection.java b/sandbox/mobile-android/android-jdk-classes/src/org/apache/tuscany/sca/android/DexURLConnection.java
new file mode 100644
index 0000000000..af0e93b043
--- /dev/null
+++ b/sandbox/mobile-android/android-jdk-classes/src/org/apache/tuscany/sca/android/DexURLConnection.java
@@ -0,0 +1,128 @@
+package org.apache.tuscany.sca.android;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.lang.reflect.Field;
+import java.net.URL;
+import java.net.URLConnection;
+import java.net.UnknownServiceException;
+
+import android.content.Context;
+
+public class DexURLConnection extends URLConnection {
+
+	private InputStream input;
+
+	protected DexURLConnection(URL url) {
+		super(url);
+		setAllowUserInteraction(false);
+		setUseCaches(false);
+		setDefaultUseCaches(false);
+		setConnectTimeout(0);
+		setReadTimeout(0);
+		setDoInput(true);
+		setDoOutput(false);
+
+	}
+
+	public InputStream getInputStream() throws IOException {
+
+		if (input == null) {
+			connect();
+		}
+
+		return input;
+
+	}
+	
+	private String guessContentTypeFromInput() {
+		
+		if (!connected) {
+			
+			try {
+				connect();
+			} catch (IOException e) {
+				return null;
+			}
+			
+		}
+		
+		try {
+			return guessContentTypeFromStream(input);
+		} catch (IOException e) {
+			return null;
+		}
+		
+	}
+	
+	@Override
+	public String getContentType() {
+		
+		if (DexResource.getFolder(url.getPath()) == null || DexResource.getFile(url.getPath()) == null) {
+			return "application/x-dex";
+		}
+		
+		return guessContentTypeFromInput();
+		
+	}
+
+	public OutputStream getOutputStream() throws IOException {
+		throw new UnknownServiceException("Output not supported!");
+	}
+
+	public void connect() throws IOException {
+		
+		if (!connected) {
+			String host = url.getHost();
+			Context[] contexts = ContextRegistry.getContexts(host);
+			
+			if (contexts.length == 0) {
+				throw new IOException("Android context not found!");
+			}
+			
+			Context context = contexts[0];
+			
+			if ("".equals(host)) {
+				throw new IOException("not valid host name: \"\"");
+			}
+			
+			String path = url.getPath();
+			String file = DexResource.getFile(path);
+			String folder = DexResource.getFolder(path);
+			
+			if (file == null) {
+				return;
+			}
+			
+			file = file.replace('.', '_');
+			
+			try {
+				
+				StringBuffer sb = new StringBuffer(context.getPackageName());
+				sb.append('.').append('R').append('$').append(folder);
+				
+				Class clazz = getClass().getClassLoader().loadClass(sb.toString());
+				Field field = clazz.getDeclaredField(file);
+				
+				int id = field.getInt(null);
+				input = context.getResources().openRawResource(id);
+				connected = true;
+				
+			} catch (ClassNotFoundException e) {
+				throw new IOException(e.getMessage());
+			} catch (SecurityException e) {
+				throw new IOException(e.getMessage());
+			} catch (NoSuchFieldException e) {
+				throw new IOException(e.getMessage());
+			} catch (IllegalArgumentException e) {
+				throw new IOException(e.getMessage());
+			} catch (IllegalAccessException e) {
+				throw new IOException(e.getMessage());
+			}
+			
+		}
+
+	}
+
+}