index.js

// Copyright 2019, Google, Inc.
// 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
//
//    http://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.

'use strict';

// [START imports_asdk]
const {
  actionssdk,
  UpdatePermission,
  Suggestions,
} = require('actions-on-google');
// [END imports_asdk]

const functions = require('firebase-functions');

const app = actionssdk({debug: true});

const notification = (conv) => {
  conv.close('You got a push notification!');
};

const subscribeToNotifications = (conv) => {
  // [START subscribe_to_notifications_asdk]
  conv.ask(new UpdatePermission({
    intent: 'Notification',
  }));
  // [END subscribe_to_notifications_asdk]
};

app.intent('actions.intent.MAIN', (conv) => {
  if (!conv.screen) {
    return conv.close(`Hi! Welcome to Push Notifications! To learn ` +
      `about push notifications you will need to switch to a screened device.`);
  }
  if (conv.user.verification !== 'VERIFIED') {
    return conv.close('Hi! Welcome to Push Notifications! To learn ' +
      `about push notifications you'll need to be a verified user.`);
  }

  conv.ask('Hi! Welcome to Push Notifications!');
  // [START suggest_notifications_asdk]
  conv.ask(' I can send you push notifications. Would you like that?');
  conv.ask(new Suggestions('Send notifications'));
  // [END suggest_notifications_asdk]
});

app.intent('actions.intent.TEXT', (conv, input) => {
  if (input === 'Send notifications') {
    return subscribeToNotifications(conv);
  }
});

app.intent('Notification', (conv) => {
  return notification;
});

// [START confirm_notifications_subscription_asdk]
app.intent('actions.intent.PERMISSION', (conv) => {
  if (conv.arguments.get('PERMISSION')) {
    const updatesUserId = conv.arguments.get('UPDATES_USER_ID');
    // Store user ID in database for later use
    conv.close(`Ok, I'll start alerting you.`);
  } else {
    conv.close(`Ok, I won't alert you.`);
  }
});
// [END confirm_notifications_subscription_asdk]

// Paste your service account credentials here.
const serviceAccount = {
  // "type": "",
  // "project_id": "",
  // "private_key_id": "",
  // "private_key": "",
  // "client_email": "",
  // "client_id": "",
  // "auth_uri": "",
  // "token_uri": "",
  // "auth_provider_x509_cert_url": "",
  // "client_x509_cert_url": ""
};

// [START send_notification_asdk]
const {google} = require('googleapis');
const request = require('request');

const jwtClient = new google.auth.JWT(
  serviceAccount.client_email, null, serviceAccount.private_key,
  ['https://www.googleapis.com/auth/actions.fulfillment.conversation'],
  null
);

jwtClient.authorize((err, tokens) => {
  if (!err) {
    request.post('https://actions.googleapis.com/v2/conversations:send', {
      auth: {
        bearer: tokens.access_token,
      },
      json: true,
      body: {
        customPushMessage: {
          userNotification: {
            title: 'Push Notification Title',
          },
          target: {
            userId: '<UPDATES_ORDER_ID>',
            intent: 'Notification Intent',
          },
        },
        isInSandbox: true,
      },
    }, (err, httpResponse, body) => {
      console.log(`${httpResponse.statusCode}: ${httpResponse.statusMessage}`);
    });
  }
});
// [END send_notification_asdk]

exports.dialogflowFirebaseFulfillment = functions.https.onRequest(app);