Updating remaning samples to 0.5.0

Change-Id: I88fc399339d16fe6d48a6e80dd7f47f576090f5c

Author: Nicolas Garnier

bigquery-import/README.md

@@ -26,5 +26,5 @@ As an example we'll be using a simple logs database structure:
 Set the `bigquery.datasetName` and `bigquery.tableName` Google Cloud environment variables to match the Dataset name and the Table name where you want the logs written to. For this use:
 
 ```bash
-firebase env:set bigquery.datasetName="bar" bigquery.tableName="baz"
+firebase functions:config:set bigquery.datasetName="bar" bigquery.tableName="baz"
 ```

bigquery-import/functions/index.js

@@ -21,11 +21,11 @@ const bigquery = require('@google-cloud/bigquery');
 /**
  * Writes all logs from the Realtime Database into bigquery.
  */
-exports.addtobigquery = functions.database().path('/logs/$logid').onWrite(event => {
+exports.addtobigquery = functions.database.ref('/logs/$logid').onWrite(event => {
   // TODO: Make sure you set the `bigquery.datasetName` Google Cloud environment variable.
-  const dataset = bigquery.dataset(functions.env.bigquery.datasetname);
+  const dataset = bigquery.dataset(functions.config().bigquery.datasetname);
   // TODO: Make sure you set the `bigquery.tableName` Google Cloud environment variable.
-  const table = dataset.table(functions.env.bigquery.tablename);
+  const table = dataset.table(functions.config().bigquery.tablename);
 
   return table.insert({
     ID: event.data.key,

bigquery-import/functions/package.json

@@ -3,7 +3,7 @@
   "description": "Import data to BigQuery Firebase Functions sample",
   "dependencies": {
     "@google-cloud/bigquery": "^0.6.0",
-    "firebase": "^3.6",
-    "firebase-functions": "https://storage.googleapis.com/firebase-preview-drop/node/firebase-functions/firebase-functions-preview.latest.tar.gz",
+    "firebase-admin": "^4.1.1",
+    "firebase-functions": "https://storage.googleapis.com/firebase-preview-drop/node/firebase-functions/firebase-functions-preview.latest.tar.gz"
   }
 }

child-count/functions/index.js

@@ -15,9 +15,11 @@
  */
 'use strict';
 
-var functions = require('firebase-functions');
+const functions = require('firebase-functions');
+const admin = require('firebase-admin');
+admin.initializeApp(functions.config().firebase);
 
 // Keeps track of the length of the 'likes' child list in a separate attribute.
-exports.countlikes = functions.database().path('/posts/$postid/likes').onWrite(event => {
-  return event.adminRef.parent().child('likes_count').set(event.data.numChildren());
+exports.countlikes = functions.database.ref('/posts/$postid/likes').onWrite(event => {
+  return event.data.ref.parent().child('likes_count').set(event.data.numChildren());
 });

child-count/functions/package.json

@@ -2,7 +2,7 @@
   "name": "child-count-functions",
   "description": "Count Child nodes Firebase Functions sample",
   "dependencies": {
-    "firebase": "^3.6",
+    "firebase-admin": "^4.1.1",
     "firebase-functions": "https://storage.googleapis.com/firebase-preview-drop/node/firebase-functions/firebase-functions-preview.latest.tar.gz"
   }
 }

convert-images/functions/index.js

@@ -28,8 +28,9 @@ const JPEG_EXTENSION = 'jpg';
  * When an image is uploaded in the Storage bucket it is converted to JPEG automatically using
  * ImageMagick.
  */
-exports.imageToJPG = functions.storage().onChange(event => {
-  const filePath = event.data.name;
+exports.imageToJPG = functions.storage.object().onChange(event => {
+  const object = event.data;
+  const filePath = object.name;
   const filePathSplit = filePath.split('/');
   const fileName = filePathSplit.pop();
   const fileNameSplit = fileName.split('.');
@@ -42,27 +43,27 @@ exports.imageToJPG = functions.storage().onChange(event => {
   const tempLocalJPEGFile = `${LOCAL_TMP_FOLDER}${JPEGFilePath}`;//
 
   // Exit if this is triggered on a file that is not an image.
-  if (!event.data.contentType.startsWith('image/')) {
+  if (!object.contentType.startsWith('image/')) {
     console.log('This is not an image.');
     return;
   }
 
   // Exit if the image is already a JPEG.
-  if (event.data.contentType.startsWith('image/jpeg')) {
+  if (object.contentType.startsWith('image/jpeg')) {
     console.log('Already a JPEG.');
     return;
   }
 
   // Exit if this is a move or deletion event.
-  if (event.data.resourceState === 'not_exists') {
+  if (object.resourceState === 'not_exists') {
     console.log('This is a deletion event.');
     return;
   }
 
   // Create the temp directory where the storage file will be downloaded.
   return mkdirp(tempLocalDir).then(() => {
     // Download file from bucket.
-    const bucket = gcs.bucket(event.data.bucket);
+    const bucket = gcs.bucket(object.bucket);
     return bucket.file(filePath).download({
       destination: tempLocalFile
     }).then(() => {

convert-images/functions/package.json

@@ -4,7 +4,7 @@
   "dependencies": {
     "@google-cloud/storage": "^0.4.0",
     "child-process-promise": "^2.2.0",
-    "firebase": "^3.6",
+    "firebase-admin": "^4.1.1",
     "firebase-functions": "https://storage.googleapis.com/firebase-preview-drop/node/firebase-functions/firebase-functions-preview.latest.tar.gz",
     "mkdirp": "^0.5.1",
     "mkdirp-promise": "^4.0.0"

delete-unused-accounts-cron/functions/index.js

@@ -29,7 +29,7 @@ const MAX_CONCURRENT = 3;
  * The request needs to be authorized by passing a 'key' query parameter in the URL. This key must
  * match a key set as an environment variable using `firebase functions:config:set cron.key="YOUR_KEY"`.
  */
-exports.accountcleanup = functions.https().onRequest((req, res) => {
+exports.accountcleanup = functions.https.onRequest((req, res) => {
   const key = req.query.key;
 
   // Exit if the keys don't match
@@ -88,9 +88,9 @@ function getUsers(userIds = [], nextPageToken, accessToken) {
         return userIds;
       }
       if (resp.nextPageToken) {
-        return getUsers(resp.users, resp.nextPageToken, accessToken);
+        return getUsers(userIds.concat(resp.users), resp.nextPageToken, accessToken);
       }
-      return resp.users;
+      return userIds.concat(resp.users);
     });
   });
 }

email-confirmation/README.md

@@ -37,7 +37,7 @@ The function triggers on changes to `/users/$uid` and exits if there are no chan
 Set the `gmail.email` and `gmail.password` Google Cloud environment variables to match the email and password of the Gmail account used to send emails. For this use:
 
 ```bash
-firebase env:set gmail.email="[email protected]" gmail.password="secretpassword"
+firebase functions:config:set gmail.email="[email protected]" gmail.password="secretpassword"
 ```
 
 This sample comes with a web-based UI for testing the function. To set it up:

email-confirmation/functions/index.js

@@ -19,18 +19,20 @@ const functions = require('firebase-functions');
 const nodemailer = require('nodemailer');
 
 // Sends an email confirmation when a user changes his mailing list subscription.
-exports.sendEmailConfirmation = functions.database().path('/users/{uid}').onWrite(event => {
+exports.sendEmailConfirmation = functions.database.ref('/users/{uid}').onWrite(event => {
   // Configure the email transport using the default SMTP transport and a GMail account.
   // See: https://nodemailer.com/
   // For other types of transports (Amazon SES, Sendgrid...) see https://nodemailer.com/2-0-0-beta/setup-transporter/
   // TODO: Make sure you configure the `gmail.email` and `gmail.password` Google Cloud environment variables.
+  const gmailEmail = encodeURIComponent(functions.config().gmail.email);
+  const gmailPassword = encodeURIComponent(functions.config().gmail.password);
   const mailTransport = nodemailer.createTransport(
-      `smtps://${encodeURIComponent(functions.env.gmail.email)}:${encodeURIComponent(functions.env.gmail.password)}@smtp.gmail.com`);
+      `smtps://${gmailEmail}:${gmailPassword}@smtp.gmail.com`);
 
-  const data = event.data;
-  const val = data.val();
+  const snapshot = event.data;
+  const val = snapshot.val();
 
-  if (!data.changed('subscribedToMailingList')) {
+  if (!snapshot.changed('subscribedToMailingList')) {
     return;
   }
 

email-confirmation/functions/package.json

@@ -3,7 +3,7 @@
   "description": "Send Email confirmation upon sign up to a Mailing list Firebase Functions sample",
   "dependencies": {
     "nodemailer": "^2.4.1",
-    "firebase": "^3.6",
+    "firebase-admin": "^4.1.1",
     "firebase-functions": "https://storage.googleapis.com/firebase-preview-drop/node/firebase-functions/firebase-functions-preview.latest.tar.gz"
   }
 }

exif-images/functions/index.js

@@ -16,6 +16,8 @@
 'use strict';
 
 const functions = require('firebase-functions');
+const admin = require('firebase-admin');
+admin.initializeApp(functions.config().firebase);
 const gcs = require('@google-cloud/storage')();
 const exec = require('child-process-promise').exec;
 const LOCAL_TMP_FOLDER = '/tmp/';
@@ -24,35 +26,34 @@ const LOCAL_TMP_FOLDER = '/tmp/';
  * When an image is uploaded in the Storage bucket the information and metadata of the image (the
  * output of ImageMagick's `identify -verbose`) is saved in the Realtime Database.
  */
-exports.metadata = functions.storage().onChange(event => {
-  console.log(event);
-
-  const filePath = event.data.name;
+exports.metadata = functions.storage.object().onChange(event => {
+  const object = event.data;
+  const filePath = object.name;
   const fileName = filePath.split('/').pop();
   const tempLocalFile = `${LOCAL_TMP_FOLDER}${fileName}`;
 
   // Exit if this is triggered on a file that is not an image.
-  if (!event.data.contentType.startsWith('image/')) {
+  if (!object.contentType.startsWith('image/')) {
     console.log('This is not an image.');
     return;
   }
 
   // Exit if this is a move or deletion event.
-  if (event.data.resourceState === 'not_exists') {
+  if (object.resourceState === 'not_exists') {
     console.log('This is a deletion event.');
     return;
   }
 
   // Download file from bucket.
-  const bucket = gcs.bucket(event.data.bucket);
+  const bucket = gcs.bucket(object.bucket);
   return bucket.file(filePath).download({
     destination: tempLocalFile
   }).then(() => {
     // Get Metadata from image.
     return exec(`identify -verbose "${tempLocalFile}"`).then(result => {
       const metadata = imageMagickOutputToObject(result.stdout);
       // Save metadata to realtime datastore.
-      return functions.app.database().ref(makeKeyFirebaseCompatible(filePath)).set(metadata).then(() => {
+      return admin.database().ref(makeKeyFirebaseCompatible(filePath)).set(metadata).then(() => {
         console.log('Wrote to:', filePath, 'data:', metadata);
       });
     });

exif-images/functions/package.json

@@ -4,7 +4,7 @@
   "dependencies": {
     "@google-cloud/storage": "^0.4.0",
     "child-process-promise": "^2.2.0",
-    "firebase": "^3.6",
+    "firebase-admin": "^4.1.1",
     "firebase-functions": "https://storage.googleapis.com/firebase-preview-drop/node/firebase-functions/firebase-functions-preview.latest.tar.gz"
   }
 }

fcm-notifications/functions/index.js

@@ -16,21 +16,16 @@
 'use strict';
 
 const functions = require('firebase-functions');
-const firebaseAdmin = require('firebase-admin');
-const serviceAccount = require('./service-account.json');
-firebaseAdmin.initializeApp({
-  credential: firebaseAdmin.credential.cert(serviceAccount),
-  databaseURL: `https://${serviceAccount.project_id}.firebaseio.com`
-});
-const rp = require('request-promise-native');
+const admin = require('firebase-admin');
+admin.initializeApp(functions.config().firebase);
 
 /**
  * Triggers when a user gets a new follower and sends a notification.
  *
- * Followers add a flag to `followers/{followedUid}/{followerUid}`.
- * Users save their device notification tokens to `users/{followedUid}/notificationTokens/{notificationToken}`.
+ * Followers add a flag to `/followers/{followedUid}/{followerUid}`.
+ * Users save their device notification tokens to `/users/{followedUid}/notificationTokens/{notificationToken}`.
  */
-exports.sendFollowerNotification = functions.database().path('followers/{followedUid}/{followerUid}').onWrite(event => {
+exports.sendFollowerNotification = functions.database.ref('/followers/{followedUid}/{followerUid}').onWrite(event => {
   const followerUid = event.params.followerUid;
   const followedUid = event.params.followedUid;
   // If un-follow we exit the function.
@@ -40,10 +35,10 @@ exports.sendFollowerNotification = functions.database().path('followers/{followe
   console.log('We have a new follower UID:', followerUid, 'for user:', followerUid);
 
   // Get the list of device notification tokens.
-  const getNotificationTokensPromise = firebaseAdmin.database().ref(`users/${followedUid}/notificationTokens`).once('value');
+  const getNotificationTokensPromise = admin.database().ref(`/users/${followedUid}/notificationTokens`).once('value');
 
   // Get the follower profile.
-  const getFollowerProfilePromise = firebaseAdmin.auth().getUser(followerUid);
+  const getFollowerProfilePromise = admin.auth().getUser(followerUid);
 
   return Promise.all([getNotificationTokensPromise, getFollowerProfilePromise]).then(results => {
     const tokensSnapshot = results[0];
@@ -55,56 +50,33 @@ exports.sendFollowerNotification = functions.database().path('followers/{followe
     }
     console.log('There are', tokensSnapshot.numChildren(), 'tokens to send notifications to.');
     console.log('Fetched follower profile', follower);
-    const displayName = follower.displayName;
-    const profilePic = follower.photoURL;
-
-    // Sends notifications to all tokens.
-    const notificationPromises = [];
-    tokensSnapshot.forEach(tokenSnapshot => {
-      const token = tokenSnapshot.key;
-      const notificationPromise = sendNotification(displayName, token, followedUid, profilePic);
-      notificationPromises.push(notificationPromise);
-    });
-
-    return Promise.all(notificationPromises).then(() => {
-      console.log('Marked notification as sent.');
-      console.log('Finished sending notifications.');
-    });
-  });
-});
 
-/**
- * Sends a "New follower" notification to the given `token`.
- * Removes/cleans up the token from the database if they are not registered anymore.
- */
-function sendNotification(displayName, token, followedUid, profilePic) {
-  // Prepare the REST request to the Firebase Cloud Messaging API.
-  var options = {
-    method: 'POST',
-    uri: 'https://fcm.googleapis.com/fcm/send',
-    headers: {
-      Authorization: `key=${functions.env.firebase.apiKey}`
-    },
-    body: {
+    // Notification details.
+    const payload = {
       notification: {
         title: 'You have a new follower!',
-        body: `${displayName} is now following you.`,
-        icon: profilePic || 'https://ssl.gstatic.com/images/icons/material/product/1x/avatar_square_blue_120dp.png'
-      },
-      to: token
-    },
-    json: true
-  };
+        body: `${follower.displayName} is now following you.`,
+        icon: follower.photoURL
+      }
+    };
 
-  // Send the REST request to the Firebase Cloud Messaging API.
-  return rp(options).then(resp => {
-    console.log('Sent a notification.', resp.success ? 'Success' : 'Failure');
+    // Listing all tokens.
+    const tokens = Object.keys(tokensSnapshot.val());
 
-    // Cleanup the tokens who are not registered anymore.
-    if (resp.failure && resp.results[0].error === 'NotRegistered') {
-      return firebaseAdmin.database().ref(`users/${followedUid}/notificationTokens/${token}`).remove().then(() => {
-        console.log('Removed unregistered token.');
+    // Send notifications to all tokens.
+    return admin.messaging().sendToDevice(tokens, payload).then(response => {
+      // For each message check if there was an error.
+      response.results.forEach((result, index) => {
+        const error = result.error;
+        if (error) {
+          console.error('Failure sending notification to', tokens[index], error);
+          // Cleanup the tokens who are not registered anymore.
+          if (error.code === 'messaging/invalid-registration-token' ||
+              error.code === 'messaging/registration-token-not-registered') {
+            return tokensSnapshot.ref.child(tokens[index]).remove();
+          }
+        }
       });
-    }
+    });
   });
-}
+});

fcm-notifications/functions/package.json

@@ -2,10 +2,7 @@
   "name": "fcm-notifications-functions",
   "description": "Send FCM notifications Firebase Functions sample",
   "dependencies": {
-    "firebase": "^3.6",
-    "firebase-admin": "^4.0.1",
+    "firebase-admin": "^4.1.1",
     "firebase-functions": "https://storage.googleapis.com/firebase-preview-drop/node/firebase-functions/firebase-functions-preview.latest.tar.gz",
-    "request": "^2.78.0",
-    "request-promise-native": "^1.0.3"
   }
 }

fcm-notifications/functions/service-account.json

@@ -45,5 +45,5 @@ Create an Algolia account at [www.algolia.com](https://www.algolia.com/)
 Set the `algolia.key` and `algolia.password` Google Cloud environment variables to match the Algolia Key and Secret of your account. For this use:
 
 ```bash
-firebase env:set algolia.key="mykey" algolia.secret="secret"
+firebase functions:config:set algolia.key="mykey" algolia.secret="secret"
 ```