java/src/main/com/google/appengine/tools/remoteapi/RemoteApiDelegate.java

   1 // Copyright 2010 Google Inc. All Rights Reserved.
   2
   3 package com.google.appengine.tools.remoteapi;
   4
   5 import com.google.apphosting.api.ApiProxy.Delegate;
   6 import com.google.apphosting.api.ApiProxy.Environment;
   7
   8 /**
   9  * Handles App Engine API calls by making HTTP requests to a remote server.
  10  * The exact mechanism by which the requests are made is an implementation
  11  * detail of subclasses.  Users of this class are expected to call
  12  * {@link #shutdown()} when they are done with an instance.
  13  *
  14  * <p>This class and its subclasses are thread-safe.
  15  *
  16  */
  17 abstract class RemoteApiDelegate implements Delegate<Environment> {
  18   private final RemoteRpc remoteRpc;
  19   private final RemoteDatastore remoteDatastore;
  20
  21   /**
  22    * Factory method.
  23    */
  24   public static RemoteApiDelegate newInstance(RemoteRpc remoteRpc, RemoteApiOptions options, Delegate<Environment> containerDelegate) {
  25     return containerDelegate != null ?
  26         new HostedRemoteApiDelegate(remoteRpc, options, containerDelegate) :
  27         new StandaloneRemoteApiDelegate(remoteRpc, options);
  28   }
  29
  30   /**
  31    * Do not call directly, use
  32    * {@link #newInstance(RemoteRpc, RemoteApiOptions, Delegate)} instead.
  33    */
  34   RemoteApiDelegate(RemoteRpc rpc, RemoteApiOptions options) {
  35     this.remoteRpc = rpc;
  36     this.remoteDatastore =
  37         new RemoteDatastore(remoteRpc.getClient().getAppId(), remoteRpc, options);
  38   }
  39
  40   void resetRpcCount() {
  41     remoteRpc.resetRpcCount();
  42   }
  43
  44   int getRpcCount() {
  45     return remoteRpc.getRpcCount();
  46   }
  47
  48   final byte[] makeDefaultSyncCall(
  49       String serviceName, String methodName, byte[] request) {
  50     if (serviceName.equals(RemoteDatastore.DATASTORE_SERVICE)
  51         && !Boolean.getBoolean("com.google.appengine.devappserver2")) {
  52       return remoteDatastore.handleDatastoreCall(methodName, request);
  53     } else {
  54       return remoteRpc.call(serviceName, methodName, "", request);
  55     }
  56   }
  57
  58   /**
  59    * Perform any necessary clean up and shut down.
  60    */
  61   public abstract void shutdown();
  62 }