Merge branch 'master' into wsh/standard-guestbook-sans-objectify

Author: wsh

appengine/cloudsql/pom.xml

@@ -44,7 +44,7 @@
     <dependency>
       <groupId>mysql</groupId>
       <artifactId>mysql-connector-java</artifactId>
-      <version>6.0.4</version>
+      <version>6.0.5</version>
     </dependency>
     <!-- Parent POM defines ${appengine.sdk.version} (updates frequently). -->
     <dependency>

appengine/endpoints-frameworks-v2/backend/pom.xml

@@ -31,8 +31,8 @@
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 
-        <endpoints.framework.version>2.0.0-beta.7</endpoints.framework.version>
-        <endpoints.management.version>1.0.0-beta.7</endpoints.management.version>
+        <endpoints.framework.version>2.0.0-beta.8</endpoints.framework.version>
+        <endpoints.management.version>1.0.0-beta.10</endpoints.management.version>
 
         <endpoints.project.id>YOUR_PROJECT_ID</endpoints.project.id>
     </properties>

appengine/firebase-event-proxy/gae-firebase-event-proxy/pom.xml

@@ -62,12 +62,12 @@
         <dependency>
           <groupId>com.fasterxml.jackson.core</groupId>
           <artifactId>jackson-core</artifactId>
-          <version>2.8.3</version>
+          <version>2.8.4</version>
         </dependency>
         <dependency>
           <groupId>com.fasterxml.jackson.core</groupId>
           <artifactId>jackson-databind</artifactId>
-          <version>2.8.3</version>
+          <version>2.8.4</version>
         </dependency>
 
         <!-- Test Dependencies -->

appengine/firebase-tictactoe/pom.xml

@@ -18,7 +18,7 @@
     <packaging>war</packaging>
     <version>1.0-SNAPSHOT</version>
     <groupId>com.example.appengine</groupId>
-    <artifactId>appengine-firebase</artifactId>
+    <artifactId>appengine-firebase-tictactoe</artifactId>
     <parent>
         <groupId>com.google.cloud</groupId>
         <artifactId>doc-samples</artifactId>

appengine/firebase-tictactoe/src/main/java/com/example/appengine/firetactoe/DeleteServlet.java

@@ -41,6 +41,7 @@ public void doPost(HttpServletRequest request, HttpServletResponse response)
     UserService userService = UserServiceFactory.getUserService();
     String currentUserId = userService.getCurrentUser().getUserId();
 
+    // TODO(you): In practice, first validate that the user has permission to delete the Game
     game.deleteChannel(currentUserId);
   }
 }

appengine/firebase-tictactoe/src/main/java/com/example/appengine/firetactoe/FirebaseChannel.java

@@ -16,6 +16,7 @@
 
 package com.example.appengine.firetactoe;
 
+import com.google.api.client.auth.oauth2.Credential;
 import com.google.api.client.extensions.appengine.http.UrlFetchTransport;
 import com.google.api.client.googleapis.auth.oauth2.GoogleCredential;
 import com.google.api.client.http.ByteArrayContent;
@@ -31,6 +32,7 @@
 
 import java.io.FileInputStream;
 import java.io.IOException;
+import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.nio.charset.StandardCharsets;
 import java.util.Arrays;
@@ -46,16 +48,18 @@
  */
 public class FirebaseChannel {
   private static final String FIREBASE_SNIPPET_PATH = "WEB-INF/view/firebase_config.jspf";
+  static InputStream firebaseConfigStream = null;
   private static final Collection FIREBASE_SCOPES = Arrays.asList(
       "https://www.googleapis.com/auth/firebase.database",
       "https://www.googleapis.com/auth/userinfo.email"
   );
   private static final String IDENTITY_ENDPOINT =
       "https://identitytoolkit.googleapis.com/google.identity.identitytoolkit.v1.IdentityToolkit";
-  static final HttpTransport HTTP_TRANSPORT = new UrlFetchTransport();
 
   private String firebaseDbUrl;
   private GoogleCredential credential;
+  // Keep this a package-private member variable, so that it can be mocked for unit tests
+  HttpTransport httpTransport;
 
   private static FirebaseChannel instance;
 
@@ -79,11 +83,17 @@ public static FirebaseChannel getInstance() {
    */
   private FirebaseChannel() {
     try {
+      // This variables exist primarily so it can be stubbed out in unit tests.
+      if (null == firebaseConfigStream) {
+        firebaseConfigStream = new FileInputStream(FIREBASE_SNIPPET_PATH);
+      }
+
       String firebaseSnippet = CharStreams.toString(new InputStreamReader(
-          new FileInputStream(FIREBASE_SNIPPET_PATH), StandardCharsets.UTF_8));
+          firebaseConfigStream, StandardCharsets.UTF_8));
       firebaseDbUrl = parseFirebaseUrl(firebaseSnippet);
 
       credential = GoogleCredential.getApplicationDefault().createScoped(FIREBASE_SCOPES);
+      httpTransport = UrlFetchTransport.getDefaultInstance();
     } catch (IOException e) {
       throw new RuntimeException(e);
     }
@@ -109,7 +119,7 @@ private static String parseFirebaseUrl(String firebaseSnippet) {
   public void sendFirebaseMessage(String channelKey, Game game)
       throws IOException {
     // Make requests auth'ed using Application Default Credentials
-    HttpRequestFactory requestFactory = HTTP_TRANSPORT.createRequestFactory(credential);
+    HttpRequestFactory requestFactory = httpTransport.createRequestFactory(credential);
     GenericUrl url = new GenericUrl(
         String.format("%s/channels/%s.json", firebaseDbUrl, channelKey));
     HttpResponse response = null;
@@ -163,4 +173,63 @@ public String createFirebaseToken(Game game, String userId) {
     AppIdentityService.SigningResult result = appIdentity.signForApp(toSign.getBytes());
     return String.format("%s.%s", toSign, base64.encode(result.getSignature()));
   }
+
+  // The following methods are to illustrate making various calls to Firebase from App Engine
+  // Standard
+
+  public HttpResponse firebasePut(String path, Object object) throws IOException {
+    // Make requests auth'ed using Application Default Credentials
+    Credential credential = GoogleCredential.getApplicationDefault().createScoped(FIREBASE_SCOPES);
+    HttpRequestFactory requestFactory = httpTransport.createRequestFactory(credential);
+
+    String json = new Gson().toJson(object);
+    GenericUrl url = new GenericUrl(path);
+
+    return requestFactory.buildPutRequest(
+        url, new ByteArrayContent("application/json", json.getBytes())).execute();
+  }
+
+  public HttpResponse firebasePatch(String path, Object object) throws IOException {
+    // Make requests auth'ed using Application Default Credentials
+    Credential credential = GoogleCredential.getApplicationDefault().createScoped(FIREBASE_SCOPES);
+    HttpRequestFactory requestFactory = httpTransport.createRequestFactory(credential);
+
+    String json = new Gson().toJson(object);
+    GenericUrl url = new GenericUrl(path);
+
+    return requestFactory.buildPatchRequest(
+        url, new ByteArrayContent("application/json", json.getBytes())).execute();
+  }
+
+  public HttpResponse firebasePost(String path, Object object) throws IOException {
+    // Make requests auth'ed using Application Default Credentials
+    Credential credential = GoogleCredential.getApplicationDefault().createScoped(FIREBASE_SCOPES);
+    HttpRequestFactory requestFactory = httpTransport.createRequestFactory(credential);
+
+    String json = new Gson().toJson(object);
+    GenericUrl url = new GenericUrl(path);
+
+    return requestFactory.buildPostRequest(
+        url, new ByteArrayContent("application/json", json.getBytes())).execute();
+  }
+
+  public HttpResponse firebaseGet(String path) throws IOException {
+    // Make requests auth'ed using Application Default Credentials
+    Credential credential = GoogleCredential.getApplicationDefault().createScoped(FIREBASE_SCOPES);
+    HttpRequestFactory requestFactory = httpTransport.createRequestFactory(credential);
+
+    GenericUrl url = new GenericUrl(path);
+
+    return requestFactory.buildGetRequest(url).execute();
+  }
+
+  public HttpResponse firebaseDelete(String path) throws IOException {
+    // Make requests auth'ed using Application Default Credentials
+    Credential credential = GoogleCredential.getApplicationDefault().createScoped(FIREBASE_SCOPES);
+    HttpRequestFactory requestFactory = httpTransport.createRequestFactory(credential);
+
+    GenericUrl url = new GenericUrl(path);
+
+    return requestFactory.buildDeleteRequest(url).execute();
+  }
 }

appengine/firebase-tictactoe/src/main/java/com/example/appengine/firetactoe/Game.java

@@ -104,7 +104,7 @@ public void setMoveX(boolean moveX) {
     this.moveX = moveX;
   }
 
-  //[START send_updates]
+  // [START send_updates]
   public String getChannelKey(String userId) {
     return userId + id;
   }
@@ -130,7 +130,7 @@ public void sendUpdateToClients()
     sendUpdateToUser(userX);
     sendUpdateToUser(userO);
   }
-  //[END send_updates]
+  // [END send_updates]
 
   public void checkWin() {
     final Pattern[] wins;
@@ -152,7 +152,6 @@ public void checkWin() {
     }
   }
 
-  //[START make_move]
   public boolean makeMove(int position, String userId) {
     String currentMovePlayer;
     char value;
@@ -181,5 +180,4 @@ public boolean makeMove(int position, String userId) {
 
     return false;
   }
-  //[END make_move]
 }

appengine/firebase-tictactoe/src/main/java/com/example/appengine/firetactoe/MoveServlet.java

@@ -44,7 +44,7 @@ public void doPost(HttpServletRequest request, HttpServletResponse response)
 
     int cell = new Integer(request.getParameter("cell"));
     if (!game.makeMove(cell, currentUserId)) {
-      response.setStatus(HttpServletResponse.SC_FORBIDDEN);
+      response.sendError(HttpServletResponse.SC_FORBIDDEN);
     } else {
       ofy.save().entity(game).now();
     }

appengine/firebase-tictactoe/src/main/java/com/example/appengine/firetactoe/OpenedServlet.java

@@ -16,7 +16,6 @@
 
 package com.example.appengine.firetactoe;
 
-import com.googlecode.objectify.NotFoundException;
 import com.googlecode.objectify.Objectify;
 import com.googlecode.objectify.ObjectifyService;
 
@@ -32,19 +31,10 @@ public class OpenedServlet extends HttpServlet {
   @Override
   public void doPost(HttpServletRequest request, HttpServletResponse response)
       throws IOException {
+    // TODO(you): In practice, you should validate the user has permission to post to the given Game
     String gameId = request.getParameter("gameKey");
     Objectify ofy = ObjectifyService.ofy();
-    try {
-      Game game = ofy.load().type(Game.class).id(gameId).safe();
-      if (gameId != null && request.getUserPrincipal() != null) {
-        game.sendUpdateToClients();
-        response.setContentType("text/plain");
-        response.getWriter().println("ok");
-      } else {
-        response.setStatus(HttpServletResponse.SC_UNAUTHORIZED);
-      }
-    } catch (NotFoundException e) {
-      response.setStatus(HttpServletResponse.SC_NOT_FOUND);
-    }
+    Game game = ofy.load().type(Game.class).id(gameId).safe();
+    game.sendUpdateToClients();
   }
 }

appengine/firebase-tictactoe/src/main/java/com/example/appengine/firetactoe/TicTacToeServlet.java

@@ -16,7 +16,6 @@
 
 package com.example.appengine.firetactoe;
 
-import com.google.appengine.api.users.UserService;
 import com.google.appengine.api.users.UserServiceFactory;
 import com.google.gson.Gson;
 import com.googlecode.objectify.Objectify;
@@ -60,20 +59,18 @@ private String getGameUriWithGameParam(HttpServletRequest request, String gameKe
   @Override
   public void doGet(HttpServletRequest request, HttpServletResponse response)
       throws ServletException, IOException {
-    final UserService userService = UserServiceFactory.getUserService();
     String gameKey = request.getParameter("gameKey");
-    if (userService.getCurrentUser() == null) {
-      response.getWriter().println("<p>Please <a href=\"" + userService.createLoginURL(
-          getGameUriWithGameParam(request, gameKey)) + "\">sign in</a>.</p>");
-      return;
-    }
 
     // 1. Create or fetch a Game object from the datastore
     Objectify ofy = ObjectifyService.ofy();
     Game game = null;
-    String userId = userService.getCurrentUser().getUserId();
+    String userId = UserServiceFactory.getUserService().getCurrentUser().getUserId();
     if (gameKey != null) {
-      game = ofy.load().type(Game.class).id(gameKey).safe();
+      game = ofy.load().type(Game.class).id(gameKey).now();
+      if (null == game) {
+        response.sendError(HttpServletResponse.SC_NOT_FOUND);
+        return;
+      }
       if (game.getUserO() == null && !userId.equals(game.getUserX())) {
         game.setUserO(userId);
       }
@@ -91,6 +88,7 @@ public void doGet(HttpServletRequest request, HttpServletResponse response)
 
     // 3. Inject a secure token into the client, so it can get game updates
 
+    // [START pass_token]
     // The 'Game' object exposes a method which creates a unique string based on the game's key
     // and the user's id.
     String token = FirebaseChannel.getInstance().createFirebaseToken(game, userId);
@@ -102,6 +100,7 @@ public void doGet(HttpServletRequest request, HttpServletResponse response)
     request.setAttribute("channel_id", game.getChannelKey(userId));
     request.setAttribute("initial_message", new Gson().toJson(game));
     request.setAttribute("game_link", getGameUriWithGameParam(request, gameKey));
-    getServletContext().getRequestDispatcher("/WEB-INF/view/index.jsp").forward(request, response);
+    request.getRequestDispatcher("/WEB-INF/view/index.jsp").forward(request, response);
+    // [END pass_token]
   }
 }