add basic annotation support using proxies (c4ea9568) · Commits · e / os / Android SingleSignOn

src/main/java/com/nextcloud/android/sso/aidl/ParcelFileDescriptorUtil.java

+0 −2

Original line number	Diff line number	Diff line
		@@ -7,8 +7,6 @@ import java.io.IOException;
		import java.io.InputStream;
		import java.io.OutputStream;

		import com.nextcloud.android.sso.aidl.IThreadListener;

		/**
		* Nextcloud SingleSignOn
		*

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

0 → 100644

+288 −0

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

		import android.support.annotation.Nullable;
		import android.util.Log;

		import com.nextcloud.android.sso.aidl.NextcloudRequest;
		import com.nextcloud.android.sso.helper.Okhttp3Helper;
		import com.nextcloud.android.sso.helper.Retrofit2Helper;

		import java.io.File;
		import java.lang.annotation.Annotation;
		import java.lang.reflect.Method;
		import java.lang.reflect.ParameterizedType;
		import java.lang.reflect.Type;
		import java.security.InvalidParameterException;
		import java.util.HashMap;
		import java.util.LinkedHashSet;
		import java.util.Map;
		import java.util.Set;
		import java.util.regex.Matcher;
		import java.util.regex.Pattern;

		import io.reactivex.Observable;
		import okhttp3.Headers;
		import okhttp3.MediaType;
		import okhttp3.ResponseBody;
		import retrofit2.Call;
		import retrofit2.http.DELETE;
		import retrofit2.http.FormUrlEncoded;
		import retrofit2.http.GET;
		import retrofit2.http.HEAD;
		import retrofit2.http.HTTP;
		import retrofit2.http.Multipart;
		import retrofit2.http.OPTIONS;
		import retrofit2.http.PATCH;
		import retrofit2.http.POST;
		import retrofit2.http.PUT;
		import retrofit2.http.Query;

		public class NextcloudRetrofitServiceMethod<T> {

		private static String TAG = NextcloudRetrofitServiceMethod.class.getCanonicalName();
		final Annotation[] methodAnnotations;
		final Annotation[][] parameterAnnotationsArray;
		final Type[] parameterTypes;


		// Upper and lower characters, digits, underscores, and hyphens, starting with a character.
		private static final String PARAM = "[a-zA-Z][a-zA-Z0-9_-]*";
		private static final Pattern PARAM_URL_REGEX = Pattern.compile("\\{(" + PARAM + ")\\}");
		private static final Pattern PARAM_NAME_REGEX = Pattern.compile(PARAM);


		private Method method;
		String httpMethod;
		private @Nullable String relativeUrl;
		private @Nullable Headers headers;
		private @Nullable MediaType contentType;
		private boolean hasBody;
		private boolean isFormEncoded;
		private boolean isMultipart;
		private NextcloudAPI nextcloudAPI;
		private Set<String> relativeUrlParamNames;
		private Type returnType;

		NextcloudRequest.Builder nextcloudRequest;

		private final String mApiEndpoint;


		public NextcloudRetrofitServiceMethod(String apiEndpoint, Method method) {
		this.returnType = method.getGenericReturnType();

		/*
		if(this.returnType instanceof ParameterizedType){
		ParameterizedType type = (ParameterizedType) returnType;
		Type[] typeArguments = type.getActualTypeArguments();
		for(Type typeArgument : typeArguments){
		Log.d(TAG, "NextcloudRetrofitServiceMethod() " + typeArgument);
		}
		}
		*/


		this.methodAnnotations = method.getAnnotations();
		this.parameterTypes = method.getGenericParameterTypes();
		this.parameterAnnotationsArray = method.getParameterAnnotations();
		for (Annotation annotation : methodAnnotations) {
		parseMethodAnnotation(annotation);
		}

		this.mApiEndpoint = apiEndpoint;




		nextcloudRequest = new NextcloudRequest.Builder()
		.setMethod(httpMethod)
		.setUrl(new File(this.mApiEndpoint,relativeUrl).toString());

		if(headers != null) {
		nextcloudRequest.setHeader(headers.toMultimap());
		}




		Log.d(TAG, "NextcloudRetrofitServiceMethod() called with: apiEndpoint = [" + apiEndpoint + "], method = [" + method + "]");

		}

		public T invoke(NextcloudAPI nextcloudAPI, Object[] args) throws Exception {

		Map<String, String> parameters = new HashMap<>();

		if(parameterAnnotationsArray.length != args.length) {
		throw new InvalidParameterException("Expected: " + parameterAnnotationsArray.length + " params - were: " + args.length);
		}

		for(int i = 0; i < parameterAnnotationsArray.length; i++) {
		Annotation annotation = parameterAnnotationsArray[i][0];

		if(annotation instanceof Query) {
		parameters.put(((Query)annotation).value(), args[i].toString());
		} else {
		throw new UnsupportedOperationException("don't know this type yet.. [" + annotation.toString() + "]");
		}
		}

		NextcloudRequest request = nextcloudRequest
		.setParameter(parameters)
		.build();

		if(this.returnType instanceof ParameterizedType){
		ParameterizedType type = (ParameterizedType) returnType;
		Type ownerType = type.getRawType();
		if(ownerType == Observable.class) {
		Type typeArgument = type.getActualTypeArguments()[0];
		Log.d(TAG, "invoke call to api using observable " + typeArgument);

		// Streaming
		if(typeArgument == ResponseBody.class) {
		return (T) Observable.just(Okhttp3Helper.getResponseBodyFromRequest(nextcloudAPI, request));
		} else {
		return (T) nextcloudAPI.performRequestObservable(typeArgument, request);
		}
		} else if(ownerType == Call.class) {
		Type typeArgument = type.getActualTypeArguments()[0];
		return (T) Retrofit2Helper.WrapInCall(nextcloudAPI, request, typeArgument);
		}
		}

		return nextcloudAPI.performRequest(this.returnType, request);

		}





		private void parseMethodAnnotation(Annotation annotation) {
		if (annotation instanceof DELETE) {
		parseHttpMethodAndPath("DELETE", ((DELETE) annotation).value(), false);
		} else if (annotation instanceof GET) {
		parseHttpMethodAndPath("GET", ((GET) annotation).value(), false);
		} else if (annotation instanceof HEAD) {
		parseHttpMethodAndPath("HEAD", ((HEAD) annotation).value(), false);
		} else if (annotation instanceof PATCH) {
		parseHttpMethodAndPath("PATCH", ((PATCH) annotation).value(), true);
		} else if (annotation instanceof POST) {
		parseHttpMethodAndPath("POST", ((POST) annotation).value(), true);
		} else if (annotation instanceof PUT) {
		parseHttpMethodAndPath("PUT", ((PUT) annotation).value(), true);
		} else if (annotation instanceof OPTIONS) {
		parseHttpMethodAndPath("OPTIONS", ((OPTIONS) annotation).value(), false);
		} else if (annotation instanceof HTTP) {
		HTTP http = (HTTP) annotation;
		parseHttpMethodAndPath(http.method(), http.path(), http.hasBody());
		} else if (annotation instanceof retrofit2.http.Headers) {
		String[] headersToParse = ((retrofit2.http.Headers) annotation).value();
		if (headersToParse.length == 0) {
		throw methodError(method, "@Headers annotation is empty.");
		}
		headers = parseHeaders(headersToParse);
		} else if (annotation instanceof Multipart) {
		if (isFormEncoded) {
		throw methodError(method, "Only one encoding annotation is allowed.");
		}
		isMultipart = true;
		} else if (annotation instanceof FormUrlEncoded) {
		if (isMultipart) {
		throw methodError(method, "Only one encoding annotation is allowed.");
		}
		isFormEncoded = true;
		}
		}

		private void parseHttpMethodAndPath(String httpMethod, String value, boolean hasBody) {
		if (this.httpMethod != null) {
		throw methodError(method, "Only one HTTP method is allowed. Found: %s and %s.",
		this.httpMethod, httpMethod);
		}
		this.httpMethod = httpMethod;
		this.hasBody = hasBody;

		if (value.isEmpty()) {
		return;
		}

		// Get the relative URL path and existing query string, if present.
		int question = value.indexOf('?');
		if (question != -1 && question < value.length() - 1) {
		// Ensure the query string does not have any named parameters.
		String queryParams = value.substring(question + 1);
		Matcher queryParamMatcher = PARAM_URL_REGEX.matcher(queryParams);
		if (queryParamMatcher.find()) {
		throw methodError(method, "URL query string \"%s\" must not have replace block. "
		+ "For dynamic query parameters use @Query.", queryParams);
		}
		}

		this.relativeUrl = value;
		this.relativeUrlParamNames = parsePathParameters(value);
		}

		private Headers parseHeaders(String[] headers) {
		Headers.Builder builder = new Headers.Builder();
		for (String header : headers) {
		int colon = header.indexOf(':');
		if (colon == -1 \|\| colon == 0 \|\| colon == header.length() - 1) {
		throw methodError(method,
		"@Headers value must be in the form \"Name: Value\". Found: \"%s\"", header);
		}
		String headerName = header.substring(0, colon);
		String headerValue = header.substring(colon + 1).trim();
		if ("Content-Type".equalsIgnoreCase(headerName)) {
		try {
		contentType = MediaType.parse(headerValue);
		} catch (IllegalArgumentException e) {
		throw methodError(method, e, "Malformed content type: %s", headerValue);
		}
		} else {
		builder.add(headerName, headerValue);
		}
		}
		return builder.build();
		}

		/**
		* Gets the set of unique path parameters used in the given URI. If a parameter is used twice
		* in the URI, it will only show up once in the set.
		*/
		static Set<String> parsePathParameters(String path) {
		Matcher m = PARAM_URL_REGEX.matcher(path);
		Set<String> patterns = new LinkedHashSet<>();
		while (m.find()) {
		patterns.add(m.group(1));
		}
		return patterns;
		}





		static RuntimeException methodError(Method method, String message, Object... args) {
		return methodError(method, null, message, args);
		}

		static RuntimeException methodError(Method method, @Nullable Throwable cause, String message,
		Object... args) {
		message = String.format(message, args);
		return new IllegalArgumentException(message
		+ "\n for method "
		+ method.getDeclaringClass().getSimpleName()
		+ "."
		+ method.getName(), cause);
		}

		static RuntimeException parameterError(Method method,
		Throwable cause, int p, String message, Object... args) {
		return methodError(method, cause, message + " (parameter #" + (p + 1) + ")", args);
		}

		static RuntimeException parameterError(Method method, int p, String message, Object... args) {
		return methodError(method, message + " (parameter #" + (p + 1) + ")", args);
		}
		}

src/main/java/com/nextcloud/android/sso/helper/Okhttp3Helper.java

+5 −0

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

		import android.util.Log;

		import com.nextcloud.android.sso.aidl.NextcloudRequest;
		import com.nextcloud.android.sso.api.NextcloudAPI;

		@@ -28,6 +30,8 @@ import okhttp3.ResponseBody;

		public final class Okhttp3Helper {

		private static String TAG = Okhttp3Helper.class.getCanonicalName();

		private Okhttp3Helper() { }

		public static ResponseBody getResponseBodyFromRequest(NextcloudAPI nextcloudAPI, NextcloudRequest request) {
		@@ -35,6 +39,7 @@ public final class Okhttp3Helper {
		InputStream os = nextcloudAPI.performNetworkRequest(request);
		return ResponseBody.create(null, 0, new BufferedSourceSSO(os));
		} catch (Exception e) {
		Log.e(TAG, "[getResponseBodyFromRequest] encountered a problem", e);
		e.printStackTrace();
		}
		return ResponseBody.create(null, "");

src/main/java/retrofit2/NextcloudRetrofitApiBuilder.java

0 → 100644

+55 −0

Original line number	Diff line number	Diff line
		package retrofit2;

		import com.nextcloud.android.sso.api.NextcloudAPI;
		import com.nextcloud.android.sso.api.NextcloudRetrofitServiceMethod;

		import java.lang.reflect.InvocationHandler;
		import java.lang.reflect.Method;
		import java.lang.reflect.Proxy;
		import java.util.Map;
		import java.util.concurrent.ConcurrentHashMap;


		public class NextcloudRetrofitApiBuilder {

		private final Map<Method, NextcloudRetrofitServiceMethod<?>> serviceMethodCache = new ConcurrentHashMap<>();

		private final NextcloudAPI mNextcloudAPI;
		private final String mApiEndpoint;

		public NextcloudRetrofitApiBuilder(NextcloudAPI nextcloudAPI, String apiEndpoint) {
		this.mNextcloudAPI = nextcloudAPI;
		this.mApiEndpoint = apiEndpoint;
		}

		@SuppressWarnings("unchecked") // Single-interface proxy creation guarded by parameter safety.
		public <T> T create(final Class<T> service) {
		retrofit2.Utils.validateServiceInterface(service);
		return (T) Proxy.newProxyInstance(
		service.getClassLoader(),
		new Class<?>[]{service},
		new InvocationHandler() {
		@Override
		public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
		return loadServiceMethod(method).invoke(mNextcloudAPI, args != null ? args : new Object[0]);
		}
		});
		}

		NextcloudRetrofitServiceMethod<?> loadServiceMethod(Method method) {
		NextcloudRetrofitServiceMethod<?> result = serviceMethodCache.get(method);
		if (result != null) return result;

		synchronized (serviceMethodCache) {
		result = serviceMethodCache.get(method);
		if (result == null) {
		result = new NextcloudRetrofitServiceMethod(mApiEndpoint, method);
		serviceMethodCache.put(method, result);
		}
		}
		return result;
		}



		}