AuthRegistry Implementation (#139)

* Start of impl for AuthProviderRegistry
* Add authMode param to AuthProvider and AuthProviderRegistry
* Create test

extensions/auth/portability-auth-microsoft/src/main/java/org/dataportabilityproject/auth/microsoft/MicrosoftAuthServiceProvider.java

@@ -1,7 +1,10 @@
 package org.dataportabilityproject.auth.microsoft;
 
+import com.google.common.collect.ImmutableList;
+import java.util.List;
 import org.dataportabilityproject.spi.gateway.auth.AuthDataGenerator;
 import org.dataportabilityproject.spi.gateway.auth.AuthServiceProvider;
+import org.dataportabilityproject.spi.gateway.auth.AuthServiceProviderRegistry.AuthMode;
 
 /**
  *
@@ -17,8 +20,18 @@ public String getServiceId() {
         return "microsoft";
     }
 
-    public AuthDataGenerator getAuthDataGenerator(String transferDataType) {
+    public AuthDataGenerator getAuthDataGenerator(String transferDataType, AuthMode mode) {
         // TODO
         throw new UnsupportedOperationException();
     }
+
+    @Override
+    public List<String> getImportTypes() {
+        return ImmutableList.of();
+    }
+
+    @Override
+    public List<String> getExportTypes() {
+        return ImmutableList.of();
+    }
 }

portability-gateway/build.gradle

@@ -17,4 +17,7 @@
 dependencies {
     compile project(':portability-spi-cloud')
     compile project(':portability-spi-gateway')
+
+    testCompile("junit:junit:${junitVersion}")
+    testCompile("org.mockito:mockito-core:${mockitoVersion}")
 }

portability-gateway/src/main/java/org/dataportabilityproject/gateway/PortabilityAuthServiceProviderRegistry.java

@@ -0,0 +1,83 @@
+/*
+ * Copyright 2018 The Data-Portability Project Authors.
+ *
+ * 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
+ *
+ * https://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.dataportabilityproject.gateway;
+
+import com.google.common.base.Preconditions;
+import com.google.common.collect.ImmutableMap;
+import com.google.common.collect.ImmutableSet;
+import java.util.List;
+import java.util.Map;
+import org.dataportabilityproject.spi.gateway.auth.AuthDataGenerator;
+import org.dataportabilityproject.spi.gateway.auth.AuthServiceProvider;
+import org.dataportabilityproject.spi.gateway.auth.AuthServiceProviderRegistry;
+import org.dataportabilityproject.types.transfer.PortableType;
+
+public class PortabilityAuthServiceProviderRegistry implements AuthServiceProviderRegistry {
+
+  private final ImmutableMap<String, AuthServiceProvider> authServiceProviderMap;
+  private final ImmutableSet<String> supportedImportTypes;
+  private final ImmutableSet<String> supportedExportTypes;
+
+  // The parameters to the constructor are provided via dependency injection
+  public PortabilityAuthServiceProviderRegistry(List<String> enabledServices,
+      Map<String, AuthServiceProvider> serviceProviderMap){
+    ImmutableMap.Builder<String, AuthServiceProvider> serviceProviderBuilder = ImmutableMap
+        .builder();
+    ImmutableSet.Builder<String> supportedImportTypesBuilder = ImmutableSet.builder();
+    ImmutableSet.Builder<String> supportedExportTypesBuilder = ImmutableSet.builder();
+
+    for(String service : enabledServices){
+      AuthServiceProvider authServiceProvider = serviceProviderMap.get(service);
+      Preconditions.checkArgument(authServiceProvider != null, "AuthServiceProvider not found for [%s]", service);
+
+      List<String> importTypes = authServiceProvider.getImportTypes();
+      List<String> exportTypes = authServiceProvider.getExportTypes();
+
+      for (String type : importTypes) {
+        Preconditions.checkArgument(exportTypes.contains(type),
+            "TransferDataType [%s] is available for import but not export in [%s] AuthServiceProvider",
+            type, service);
+        supportedImportTypesBuilder.add(type);
+      }
+
+      supportedExportTypesBuilder.addAll(exportTypes);
+      serviceProviderBuilder.put(service, authServiceProvider);
+    }
+
+    authServiceProviderMap = serviceProviderBuilder.build();
+    supportedImportTypes = supportedImportTypesBuilder.build();
+    supportedExportTypes = supportedExportTypesBuilder.build();
+  }
+
+  @Override
+  public AuthDataGenerator getAuthDataGenerator(String serviceId, String transferDataType, AuthMode mode) {
+    AuthServiceProvider provider = authServiceProviderMap.get(serviceId);
+    Preconditions.checkArgument(provider!=null, "AuthServiceProvider not found for serviceId [%s]", serviceId);
+    switch(mode) {
+      case EXPORT:
+        Preconditions.checkArgument(supportedExportTypes.contains(transferDataType), "AuthMode [%s] not valid for TransferDataType [%s]", mode, transferDataType);
+        break;
+      case IMPORT:
+        Preconditions.checkArgument(supportedImportTypes.contains(transferDataType), "AuthMode [%s] not valid for TransferDataType [%s]", mode, transferDataType);
+        break;
+      default:
+        throw new IllegalArgumentException("AuthMode [" + mode + "] not supported");
+    }
+
+    return provider.getAuthDataGenerator(transferDataType, mode);
+  }
+}

portability-gateway/src/test/java/org/dataportabilityproject/spi/gateway/auth/PortabilityAuthServiceProviderRegistryTest.java

@@ -0,0 +1,63 @@
+/*
+ * Copyright 2018 The Data-Portability Project Authors.
+ *
+ * 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
+ *
+ * https://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.dataportabilityproject.spi.gateway.auth;
+
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+
+import com.google.common.collect.ImmutableList;
+import com.google.common.collect.ImmutableMap;
+import java.util.List;
+import org.dataportabilityproject.gateway.PortabilityAuthServiceProviderRegistry;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+
+public class PortabilityAuthServiceProviderRegistryTest {
+
+  @Rule
+  public ExpectedException thrown = ExpectedException.none();
+
+  @Test
+  public void requireImportAndExportTest(){
+    List<String> supportedImportTypes = ImmutableList.of("photos", "contacts");
+    List<String> supportedExportTypes = ImmutableList.of("contacts");
+
+    AuthServiceProvider mockAuthProvider = mock(AuthServiceProvider.class);
+    when(mockAuthProvider.getExportTypes()).thenReturn(supportedExportTypes);
+    when(mockAuthProvider.getImportTypes()).thenReturn(supportedImportTypes);
+    when(mockAuthProvider.getServiceId()).thenReturn("mockAuthProvider");
+    thrown.expect(IllegalArgumentException.class);
+    thrown.expectMessage("available for import but not export");
+
+    AuthServiceProviderRegistry registry = new PortabilityAuthServiceProviderRegistry(ImmutableList.of("mockServiceProvider"),
+        ImmutableMap.of("mockServiceProvider", mockAuthProvider));
+  }
+
+  @Test
+  public void serviceProviderNotFoundTest(){
+    AuthServiceProvider mockAuthProvider = mock(AuthServiceProvider.class);
+    when(mockAuthProvider.getServiceId()).thenReturn("mockAuthProvider");
+
+    thrown.expect(IllegalArgumentException.class);
+    thrown.expectMessage("AuthServiceProvider not found");
+
+    AuthServiceProviderRegistry registry = new PortabilityAuthServiceProviderRegistry(ImmutableList.of("ServiceDoesNotExist"),
+        ImmutableMap.of("mockServiceProvider", mockAuthProvider));
+  }
+
+}

portability-spi-gateway/src/main/java/org/dataportabilityproject/spi/gateway/auth/AuthServiceProvider.java

@@ -1,5 +1,8 @@
 package org.dataportabilityproject.spi.gateway.auth;
 
+import java.util.List;
+import org.dataportabilityproject.spi.gateway.auth.AuthServiceProviderRegistry.AuthMode;
+
 /**
  * Factory responsible for providing {@link AuthDataGenerator} implementations.
  *
@@ -17,5 +20,17 @@ public interface AuthServiceProvider {
      *
      * @param transferDataType the data type
      */
-    AuthDataGenerator getAuthDataGenerator(String transferDataType);
+    AuthDataGenerator getAuthDataGenerator(String transferDataType, AuthMode mode);
+
+    /**
+     * get supported import types
+     * @return The list of types that are supported for IMPORT AuthMode
+     */
+    List<String> getImportTypes();
+
+    /**
+     * get supported export types
+     * @return The list of types that are supported for EXPORT AuthMode
+     */
+    List<String> getExportTypes();
 }

portability-spi-gateway/src/main/java/org/dataportabilityproject/spi/gateway/auth/AuthServiceProviderRegistry.java

@@ -4,11 +4,25 @@
  * Manages {@link AuthServiceProvider}s registered in the system.
  */
 public interface AuthServiceProviderRegistry {
+  /**
+   * Lookup the @code{AuthDataGenerator} corresponding to the serviceId, transferType and AuthMode
+   * specified
+   *
+   * @param serviceId the AuthServiceProvider to use
+   * @param transferDataType The TransferdataType to authorize for
+   * @param mode The authorization mode
+   * @return An AuthDataGenerator from the specified AuthServiceProvider for the type and mode
+   * requested.
+   */
+  AuthDataGenerator getAuthDataGenerator(String serviceId, String transferDataType, AuthMode mode);
 
-    /**
-     * Returns the provider that supports the service id.
-     *
-     * @param serviceId the service id
-     */
-    AuthServiceProvider getServiceProvider(String serviceId);
+  /**
+   * The AuthorizationMode to use for lookups.
+   * IMPORT specifies an authorization that allows you to import a type (implying read-write permissions)
+   * EXPORT specifies an authorization that allows you to export a type (implying read-only permissions)
+   */
+  enum AuthMode {
+    IMPORT,
+    EXPORT
   }
+}