implement InterceptorPattern for NetworkRequest (641ff94e) · Commits · e / os / Android SingleSignOn

src/main/java/com/nextcloud/android/sso/api/AidlNetworkRequest.java

0 → 100644

+220 −0

Original line number	Diff line number	Diff line
		package com.nextcloud.android.sso.api;

		import android.content.ComponentName;
		import android.content.Context;
		import android.content.Intent;
		import android.content.ServiceConnection;
		import android.os.IBinder;
		import android.os.Looper;
		import android.os.NetworkOnMainThreadException;
		import android.os.ParcelFileDescriptor;
		import android.os.RemoteException;
		import android.util.Log;

		import com.nextcloud.android.sso.aidl.IInputStreamService;
		import com.nextcloud.android.sso.aidl.IThreadListener;
		import com.nextcloud.android.sso.aidl.NextcloudRequest;
		import com.nextcloud.android.sso.aidl.ParcelFileDescriptorUtil;
		import com.nextcloud.android.sso.exceptions.NextcloudApiNotRespondingException;
		import com.nextcloud.android.sso.model.SingleSignOnAccount;

		import java.io.ByteArrayInputStream;
		import java.io.ByteArrayOutputStream;
		import java.io.IOException;
		import java.io.InputStream;
		import java.io.ObjectInputStream;
		import java.io.ObjectOutputStream;
		import java.util.concurrent.atomic.AtomicBoolean;

		import static com.nextcloud.android.sso.exceptions.SSOException.parseNextcloudCustomException;

		public class AidlNetworkRequest extends NetworkRequest {
		private static final String TAG = AidlNetworkRequest.class.getCanonicalName();

		private IInputStreamService mService = null;
		private final AtomicBoolean mBound = new AtomicBoolean(false); // Flag indicating whether we have called bind on the service

		public AidlNetworkRequest(Context context, SingleSignOnAccount account, NextcloudAPI.ApiConnectedListener callback) {
		super(context, account, callback);
		}


		/**
		* Class for interacting with the main interface of the service.
		*/
		private ServiceConnection mConnection = new ServiceConnection() {
		public void onServiceConnected(ComponentName className, IBinder service) {
		Log.v(TAG, "Nextcloud Single sign-on: onServiceConnected [" + Thread.currentThread().getName() + "]");

		mService = IInputStreamService.Stub.asInterface(service);
		mBound.set(true);
		synchronized (mBound) {
		mBound.notifyAll();
		}
		mCallback.onConnected();
		}

		public void onServiceDisconnected(ComponentName className) {
		Log.e(TAG, "Nextcloud Single sign-on: ServiceDisconnected");
		// This is called when the connection with the service has been
		// unexpectedly disconnected -- that is, its process crashed.
		mService = null;
		mBound.set(false);

		if (!mDestroyed) {
		connectApiWithBackoff();
		}
		}
		};

		public void connect() {
		super.connect();

		// Disconnect if connected
		if (mBound.get()) {
		stop();
		}

		try {
		Intent intentService = new Intent();
		intentService.setComponent(new ComponentName("com.nextcloud.client",
		"com.owncloud.android.services.AccountManagerService"));
		if (!mContext.bindService(intentService, mConnection, Context.BIND_AUTO_CREATE)) {
		Log.d(TAG, "Binding to AccountManagerService returned false");
		throw new IllegalStateException("Binding to AccountManagerService returned false");
		}
		} catch (SecurityException e) {
		Log.e(TAG, "can't bind to AccountManagerService, check permission in Manifest");
		mCallback.onError(e);
		}
		}

		public void stop() {
		super.stop();

		// Unbind from the service
		if (mBound.get()) {
		if (mContext != null) {
		mContext.unbindService(mConnection);
		} else {
		Log.e(TAG, "Context was null, cannot unbind nextcloud single sign-on service connection!");
		}
		mBound.set(false);
		mContext = null;
		}
		}

		private void waitForApi() throws NextcloudApiNotRespondingException {
		synchronized (mBound) {
		// If service is not bound yet.. wait
		if(!mBound.get()) {
		Log.v(TAG, "[waitForApi] - api not ready yet.. waiting [" + Thread.currentThread().getName() + "]");
		try {
		mBound.wait(10000); // wait up to 10 seconds

		// If api is still not bound after 10 seconds.. throw an exception
		if(!mBound.get()) {
		throw new NextcloudApiNotRespondingException();
		}
		} catch (InterruptedException ex) {
		Log.e(TAG, "WaitForAPI failed", ex);
		}
		}
		}
		}

		/**
		* The InputStreams needs to be closed after reading from it
		*
		* @param request {@link NextcloudRequest} request to be executed on server via Files app
		* @param requestBodyInputStream inputstream to be sent to the server
		* @return InputStream answer from server as InputStream
		* @throws Exception or SSOException
		*/
		public InputStream performNetworkRequest(NextcloudRequest request, InputStream requestBodyInputStream) throws Exception {
		InputStream os = null;
		Exception exception;
		try {
		ParcelFileDescriptor output = performAidlNetworkRequest(request, requestBodyInputStream);
		os = new ParcelFileDescriptor.AutoCloseInputStream(output);
		exception = deserializeObject(os);
		} catch (ClassNotFoundException e) {
		//e.printStackTrace();
		exception = e;
		}

		// Handle Remote Exceptions
		if (exception != null) {
		if (exception.getMessage() != null) {
		exception = parseNextcloudCustomException(exception);
		}
		throw exception;
		}
		return os;
		}

		/**
		* DO NOT CALL THIS METHOD DIRECTLY - use @link(performNetworkRequest) instead
		*
		* @param request
		* @return
		* @throws IOException
		*/
		private ParcelFileDescriptor performAidlNetworkRequest(NextcloudRequest request, InputStream requestBodyInputStream)
		throws IOException, RemoteException, NextcloudApiNotRespondingException {

		// Check if we are on the main thread
		if(Looper.myLooper() == Looper.getMainLooper()) {
		throw new NetworkOnMainThreadException();
		}

		// Wait for api to be initialized
		waitForApi();

		// Log.d(TAG, request.url);
		request.setAccountName(getAccountName());
		request.setToken(getAccountToken());

		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		ObjectOutputStream oos = new ObjectOutputStream(baos);
		oos.writeObject(request);
		oos.close();
		baos.close();
		InputStream is = new ByteArrayInputStream(baos.toByteArray());

		ParcelFileDescriptor input = ParcelFileDescriptorUtil.pipeFrom(is,
		new IThreadListener() {
		@Override
		public void onThreadFinished(Thread thread) {
		Log.d(TAG, "copy data from service finished");
		}
		});

		ParcelFileDescriptor requestBodyParcelFileDescriptor = null;
		if(requestBodyInputStream != null) {
		requestBodyParcelFileDescriptor = ParcelFileDescriptorUtil.pipeFrom(requestBodyInputStream,
		new IThreadListener() {
		@Override
		public void onThreadFinished(Thread thread) {
		Log.d(TAG, "copy data from service finished");
		}
		});
		}

		ParcelFileDescriptor output;
		if(requestBodyParcelFileDescriptor != null) {
		output = mService.performNextcloudRequestAndBodyStream(input, requestBodyParcelFileDescriptor);
		} else {
		output = mService.performNextcloudRequest(input);
		}

		return output;
		}


		public static <T> T deserializeObject(InputStream is) throws IOException, ClassNotFoundException {
		ObjectInputStream ois = new ObjectInputStream(is);
		T result = (T) ois.readObject();
		return result;
		}
		}

src/main/java/com/nextcloud/android/sso/api/NetworkRequest.java

0 → 100644

+63 −0

Original line number	Diff line number	Diff line
		package com.nextcloud.android.sso.api;

		import android.content.Context;
		import android.os.Looper;
		import android.util.Log;

		import com.nextcloud.android.sso.aidl.NextcloudRequest;
		import com.nextcloud.android.sso.helper.ExponentialBackoff;
		import com.nextcloud.android.sso.model.SingleSignOnAccount;

		import java.io.InputStream;

		public abstract class NetworkRequest {

		private static final String TAG = NetworkRequest.class.getCanonicalName();

		private SingleSignOnAccount mAccount;
		Context mContext;
		NextcloudAPI.ApiConnectedListener mCallback;
		boolean mDestroyed = false; // Flag indicating if API is destroyed


		protected NetworkRequest(Context context, SingleSignOnAccount account, NextcloudAPI.ApiConnectedListener callback) {
		this.mContext = context;
		this.mAccount = account;
		this.mCallback = callback;
		}


		void connect() {
		Log.v(TAG, "Nextcloud Single sign-on connect() called [" + Thread.currentThread().getName() + "]");
		if (mDestroyed) {
		throw new IllegalStateException("API already destroyed! You cannot reuse a stopped API instance");
		}
		}

		protected abstract InputStream performNetworkRequest(NextcloudRequest request, InputStream requestBodyInputStream) throws Exception;

		void connectApiWithBackoff() {
		new ExponentialBackoff(1000, 10000, 2, 5, Looper.getMainLooper(), new Runnable() {
		@Override
		public void run() {
		connect();
		}
		}).start();
		}

		void stop() {
		mCallback = null;
		mAccount = null;
		mDestroyed = true;
		}


		String getAccountName() {
		return mAccount.name;
		}

		String getAccountToken() {
		return mAccount.token;
		}

		}

src/main/java/com/nextcloud/android/sso/api/NextcloudAPI.java

+13 −242

Original line number	Diff line number	Diff line
		@@ -19,47 +19,27 @@

		package com.nextcloud.android.sso.api;

		import android.content.ComponentName;
		import android.content.Context;
		import android.content.Intent;
		import android.content.ServiceConnection;
		import android.os.IBinder;
		import android.os.Looper;
		import android.os.NetworkOnMainThreadException;
		import android.os.ParcelFileDescriptor;
		import android.os.RemoteException;
		import android.util.Log;

		import com.google.gson.Gson;
		import com.nextcloud.android.sso.aidl.IInputStreamService;
		import com.nextcloud.android.sso.aidl.IThreadListener;
		import com.nextcloud.android.sso.aidl.NextcloudRequest;
		import com.nextcloud.android.sso.aidl.ParcelFileDescriptorUtil;
		import com.nextcloud.android.sso.exceptions.NextcloudApiNotRespondingException;
		import com.nextcloud.android.sso.helper.ExponentialBackoff;
		import com.nextcloud.android.sso.model.SingleSignOnAccount;

		import org.reactivestreams.Publisher;
		import org.reactivestreams.Subscriber;

		import java.io.ByteArrayInputStream;
		import java.io.ByteArrayOutputStream;
		import java.io.IOException;
		import java.io.InputStream;
		import java.io.InputStreamReader;
		import java.io.ObjectInputStream;
		import java.io.ObjectOutputStream;
		import java.io.Reader;
		import java.lang.annotation.Documented;
		import java.lang.annotation.Retention;
		import java.lang.annotation.Target;
		import java.lang.reflect.Type;
		import java.util.concurrent.atomic.AtomicBoolean;

		import io.reactivex.Observable;
		import io.reactivex.annotations.NonNull;

		import static com.nextcloud.android.sso.exceptions.SSOException.parseNextcloudCustomException;
		import static java.lang.annotation.ElementType.METHOD;
		import static java.lang.annotation.RetentionPolicy.RUNTIME;

		@@ -67,149 +47,34 @@ public class NextcloudAPI {

		private static final String TAG = NextcloudAPI.class.getCanonicalName();

		private NetworkRequest networkRequest;
		private Gson gson;
		private IInputStreamService mService = null;
		private final AtomicBoolean mBound = new AtomicBoolean(false); // Flag indicating whether we have called bind on the service
		private boolean mDestroyed = false; // Flag indicating if API is destroyed
		private SingleSignOnAccount mAccount;
		private ApiConnectedListener mCallback;
		private Context mContext;


		@Documented
		@Target(METHOD)
		@Retention(RUNTIME)
		public @interface FollowRedirects{

		}
		public @interface FollowRedirects { }

		public interface ApiConnectedListener {
		void onConnected();
		void onError(Exception ex);
		}

		public NextcloudAPI(Context context, SingleSignOnAccount account, Gson gson, ApiConnectedListener callback) {
		this.mContext = context;
		this.mAccount = account;
		this.gson = gson;
		this.mCallback = callback;

		new Thread()
		{
		public void run() {
		Log.d(TAG, "run() called " + Thread.currentThread().getName());
		connectApiWithBackoff();
		}
		}.start();
		//connectApiWithBackoff();
		}

		private String getAccountName() {
		return mAccount.name;
		}

		private String getAccountToken() {
		return mAccount.token;
		}

		private void connectApiWithBackoff() {
		new ExponentialBackoff(1000, 10000, 2, 5, Looper.getMainLooper(), new Runnable() {
		@Override
		public void run() {
		connect();
		}
		}).start();
		}

		private void connect() {
		Log.v(TAG, "Nextcloud Single sign-on connect() called [" + Thread.currentThread().getName() + "]");
		if (mDestroyed) {
		throw new IllegalStateException("API already destroyed! You cannot reuse a stopped API instance");
		}

		// Disconnect if connected
		if (mBound.get()) {
		stop();
		public NextcloudAPI(Context context, SingleSignOnAccount account, Gson gson, ApiConnectedListener callback) {
		this(gson, new AidlNetworkRequest(context, account, callback));
		}

		try {
		Intent intentService = new Intent();
		intentService.setComponent(new ComponentName("com.nextcloud.client",
		"com.owncloud.android.services.AccountManagerService"));
		if (!mContext.bindService(intentService, mConnection, Context.BIND_AUTO_CREATE)) {
		Log.d(TAG, "Binding to AccountManagerService returned false");
		throw new IllegalStateException("Binding to AccountManagerService returned false");
		}
		} catch (SecurityException e) {
		Log.e(TAG, "can't bind to AccountManagerService, check permission in Manifest");
		mCallback.onError(e);
		}
		public NextcloudAPI(Gson gson, NetworkRequest networkRequest) {
		this.gson = gson;
		this.networkRequest = networkRequest;
		this.networkRequest.connect();
		}


		public void stop() {
		gson = null;
		mDestroyed = true;
		mAccount = null;
		mCallback = null;

		// Unbind from the service
		if (mBound.get()) {
		if (mContext != null) {
		mContext.unbindService(mConnection);
		} else {
		Log.e(TAG, "Context was null, cannot unbind nextcloud single sign-on service connection!");
		}
		mBound.set(false);
		mContext = null;
		}
		}


		/**
		* Class for interacting with the main interface of the service.
		*/
		private ServiceConnection mConnection = new ServiceConnection() {
		public void onServiceConnected(ComponentName className, IBinder service) {
		Log.v(TAG, "Nextcloud Single sign-on: onServiceConnected [" + Thread.currentThread().getName() + "]");

		mService = IInputStreamService.Stub.asInterface(service);
		mBound.set(true);
		synchronized (mBound) {
		mBound.notifyAll();
		}
		mCallback.onConnected();
		}

		public void onServiceDisconnected(ComponentName className) {
		Log.e(TAG, "Nextcloud Single sign-on: ServiceDisconnected");
		// This is called when the connection with the service has been
		// unexpectedly disconnected -- that is, its process crashed.
		mService = null;
		mBound.set(false);

		if (!mDestroyed) {
		connectApiWithBackoff();
		}
		}
		};

		private void waitForApi() throws NextcloudApiNotRespondingException {
		synchronized (mBound) {
		// If service is not bound yet.. wait
		if(!mBound.get()) {
		Log.v(TAG, "[waitForApi] - api not ready yet.. waiting [" + Thread.currentThread().getName() + "]");
		try {
		mBound.wait(10000); // wait up to 10 seconds

		// If api is still not bound after 10 seconds.. throw an exception
		if(!mBound.get()) {
		throw new NextcloudApiNotRespondingException();
		}
		} catch (InterruptedException ex) {
		Log.e(TAG, "WaitForAPI failed", ex);
		}
		}
		}
		networkRequest.stop();
		}

		public <T> Observable<T> performRequestObservable(final Type type, final NextcloudRequest request) {
		@@ -247,12 +112,6 @@ public class NextcloudAPI {
		}


		public static <T> T deserializeObject(InputStream is) throws IOException, ClassNotFoundException {
		ObjectInputStream ois = new ObjectInputStream(is);
		T result = (T) ois.readObject();
		return result;
		}

		/**
		* The InputStreams needs to be closed after reading from it
		*
		@@ -261,99 +120,10 @@ public class NextcloudAPI {
		* @throws Exception or SSOException
		*/
		public InputStream performNetworkRequest(NextcloudRequest request) throws Exception {
		return performNetworkRequest(request, null);
		return networkRequest.performNetworkRequest(request, null);
		}

		/**
		* The InputStreams needs to be closed after reading from it
		*
		* @param request {@link NextcloudRequest} request to be executed on server via Files app
		* @param requestBodyInputStream inputstream to be sent to the server
		* @return InputStream answer from server as InputStream
		* @throws Exception or SSOException
		*/
		public InputStream performNetworkRequest(NextcloudRequest request, InputStream requestBodyInputStream) throws Exception {
		InputStream os = null;
		Exception exception;
		try {
		ParcelFileDescriptor output = performAidlNetworkRequest(request, requestBodyInputStream);
		os = new ParcelFileDescriptor.AutoCloseInputStream(output);
		exception = deserializeObject(os);
		} catch (ClassNotFoundException e) {
		//e.printStackTrace();
		exception = e;
		}

		// Handle Remote Exceptions
		if (exception != null) {
		if (exception.getMessage() != null) {
		exception = parseNextcloudCustomException(exception);
		}
		throw exception;
		}
		return os;
		}


		/**
		* DO NOT CALL THIS METHOD DIRECTLY - use @link(performNetworkRequest) instead
		*
		* @param request
		* @return
		* @throws IOException
		*/
		private ParcelFileDescriptor performAidlNetworkRequest(NextcloudRequest request, InputStream requestBodyInputStream)
		throws IOException, RemoteException, NextcloudApiNotRespondingException {

		// Check if we are on the main thread
		if(Looper.myLooper() == Looper.getMainLooper()) {
		throw new NetworkOnMainThreadException();
		}

		// Wait for api to be initialized
		waitForApi();

		// Log.d(TAG, request.url);
		request.setAccountName(getAccountName());
		request.setToken(getAccountToken());

		ByteArrayOutputStream baos = new ByteArrayOutputStream();
		ObjectOutputStream oos = new ObjectOutputStream(baos);
		oos.writeObject(request);
		oos.close();
		baos.close();
		InputStream is = new ByteArrayInputStream(baos.toByteArray());

		ParcelFileDescriptor input = ParcelFileDescriptorUtil.pipeFrom(is,
		new IThreadListener() {
		@Override
		public void onThreadFinished(Thread thread) {
		Log.d(TAG, "copy data from service finished");
		}
		});

		ParcelFileDescriptor requestBodyParcelFileDescriptor = null;
		if(requestBodyInputStream != null) {
		requestBodyParcelFileDescriptor = ParcelFileDescriptorUtil.pipeFrom(requestBodyInputStream,
		new IThreadListener() {
		@Override
		public void onThreadFinished(Thread thread) {
		Log.d(TAG, "copy data from service finished");
		}
		});
		}

		ParcelFileDescriptor output;
		if(requestBodyParcelFileDescriptor != null) {
		output = mService.performNextcloudRequestAndBodyStream(input, requestBodyParcelFileDescriptor);
		} else {
		output = mService.performNextcloudRequest(input);
		}

		return output;
		}


		/*
		public static <T> T deserializeObjectAndCloseStream(InputStream is) throws IOException, ClassNotFoundException {
		ObjectInputStream ois = new ObjectInputStream(is);
		T result = (T) ois.readObject();
		@@ -361,6 +131,7 @@ public class NextcloudAPI {
		ois.close();
		return result;
		}
		*/

		protected Gson getGson() {
		return gson;