/*
    * The contents of this file are subject to the terms of the Common Development and
    * Distribution License (the License). You may not use this file except in compliance with the
    * License.
    *
    * You can obtain a copy of the License at legal/CDDLv1.0.txt. See the License for the
    * specific language governing permission and limitations under the License.
    *
    * When distributing Covered Software, include this CDDL Header Notice in each file and include
   * the License file at legal/CDDLv1.0.txt. If applicable, add the following below the CDDL
   * Header, with the fields enclosed by brackets [] replaced by your own identifying
   * information: "Portions copyright [year] [name of copyright owner]".
   *
   * Copyright 2015 ForgeRock AS.
   */
  
  package org.forgerock.selfservice.example;
  
  import static org.forgerock.http.routing.RouteMatchers.requestUriMatcher;
  import static org.forgerock.json.resource.ResourcePath.resourcePath;
  import static org.forgerock.json.resource.Resources.newInternalConnectionFactory;
  import static org.forgerock.json.resource.Router.uriTemplate;
  
  import com.fasterxml.jackson.databind.ObjectMapper;
  import org.forgerock.http.Client;
  import org.forgerock.http.Handler;
  import org.forgerock.http.HttpApplication;
  import org.forgerock.http.HttpApplicationException;
  import org.forgerock.http.handler.HttpClientHandler;
  import org.forgerock.http.io.Buffer;
  import org.forgerock.http.routing.RoutingMode;
  import org.forgerock.json.JsonPointer;
  import org.forgerock.json.JsonValue;
  import org.forgerock.json.resource.ConnectionFactory;
  import org.forgerock.json.resource.MemoryBackend;
  import org.forgerock.json.resource.RequestHandler;
  import org.forgerock.json.resource.ResourceException;
  import org.forgerock.json.resource.Resources;
  import org.forgerock.json.resource.Router;
  import org.forgerock.json.resource.http.CrestHttp;
  import org.forgerock.selfservice.core.UserUpdateService;
  import org.forgerock.selfservice.json.JsonAnonymousProcessServiceBuilder;
  import org.forgerock.util.Factory;
  
  import java.util.Map;
  
  /**
   * Basic http application which initialises the user self service service.
   *
   * @since 0.1.0
   */
  public final class ExampleSelfServiceApplication implements HttpApplication {
  
      private ConnectionFactory crestConnectionFactory;
      private Router crestRouter;
      private JsonValue appConfig;
      private Client httpClient;
  
      @Override
      public Handler start() throws HttpApplicationException {
          try {
  
              appConfig = JsonReader.jsonFileToJsonValue("/config.json");
              httpClient = new Client(new HttpClientHandler());
  
              crestRouter = new Router();
              crestConnectionFactory = newInternalConnectionFactory(crestRouter);
  
              registerCRESTServices();
  
              org.forgerock.http.routing.Router chfRouter = new org.forgerock.http.routing.Router();
              chfRouter.addRoute(requestUriMatcher(RoutingMode.STARTS_WITH, "internal"),
                      CrestHttp.newHttpHandler(crestConnectionFactory));
              chfRouter.addRoute(requestUriMatcher(RoutingMode.STARTS_WITH, "reset"), registerResetHandler());
              chfRouter.addRoute(requestUriMatcher(RoutingMode.STARTS_WITH, "username"), registerUsernameHandler());
              chfRouter.addRoute(requestUriMatcher(RoutingMode.STARTS_WITH, "registration"),
                      registerRegistrationHandler());
              chfRouter.addRoute(requestUriMatcher(RoutingMode.STARTS_WITH, "user"), registerUserKBAUpdateHandler());
              return chfRouter;
          } catch (Exception e) {
              throw new HttpApplicationException("Some error starting", e);
          }
      }
  
      private void registerCRESTServices() throws ResourceException {
          crestRouter.addRoute(uriTemplate("users"), new MemoryBackend());
          crestRouter.addRoute(uriTemplate("email"), new ExampleEmailService(appConfig.get("mailserver")));
      }
  
      private Handler buildHandler(String configResource) throws Exception {
          ObjectMapper mapper = new ObjectMapper();
          JsonValue json = new JsonValue(mapper.readValue(getClass().getResource(configResource), Map.class));
  
          RequestHandler service = JsonAnonymousProcessServiceBuilder.newBuilder()
                  .withJsonConfig(json)
                  .withProgressStageProvider(new ExampleProgressStageProvider(crestConnectionFactory, httpClient))
                  .withTokenHandlerFactory(new ExampleTokenHandlerFactory())
                  .withProcessStore(new SimpleInMemoryStore())
                  .build();
 
         return CrestHttp.newHttpHandler(Resources.newInternalConnectionFactory(service));
     }
 
     private Handler registerResetHandler() throws Exception {
         return buildHandler("/reset.json");
     }
 
     private Handler registerUsernameHandler() throws Exception {
         return buildHandler("/username.json");
     }
 
     private Handler registerRegistrationHandler() throws Exception {
         return buildHandler("/registration.json");
     }
 
     private Handler registerUserKBAUpdateHandler() {
         return CrestHttp.newHttpHandler(Resources.newInternalConnectionFactory(Resources.newCollection(
                 new UserUpdateService(crestConnectionFactory, resourcePath("users"), new JsonPointer("kbaInfo")))));
     }
 
     @Override
     public Factory<Buffer> getBufferFactory() {
         // Do nothing
         return null;
     }
 
     @Override
     public void stop() {
         // Do nothing
     }
 
 }