Esplora in Dialogflow
Fai clic su Continua per importare il nostro esempio di notifiche in Dialogflow. Quindi, segui questi passaggi per eseguire il deployment e testare l'esempio:
- Inserisci il nome di un agente e crea un nuovo agente Dialogflow per l'esempio.
- Al termine dell'importazione dell'agente, fai clic su Vai all'agente.
- Nel menu di navigazione principale, vai ad Fulfillment.
- Attiva l'editor incorporato, quindi fai clic su Esegui il deployment. L'editor contiene il codice di esempio.
- Nel menu di navigazione principale, vai a Integrazioni, quindi fai clic su Assistente Google.
- Nella finestra modale visualizzata, attiva Anteprima automatica delle modifiche e fai clic su Test per aprire il simulatore di azioni.
- Nel simulatore, inserisci
Talk to my test appper testare il campione.
L'Azione può inviare notifiche push agli utenti ogni volta che è pertinente, ad esempio l'invio di un promemoria in prossimità della data di scadenza di un'attività.
In questa guida, utilizziamo l'esempio di suggerimenti di Actions on Google come riferimento per mostrare come configurare le notifiche push per l'Azione. Quando gli utenti richiamano questa Azione, viene chiesto se vogliono ricevere un suggerimento sullo sviluppo della propria Azione. Gli utenti possono scegliere una categoria specifica o selezionata in modo casuale per il suggerimento oppure possono scegliere di ascoltare il suggerimento più recente.
Piattaforme supportate
Le notifiche push sono disponibili su dispositivi Android e iOS (per poter ricevere le notifiche push sui dispositivi iOS è necessario installare l'app Assistente Google). Al momento non sono supportate su speaker ad attivazione vocale, smart display o altre piattaforme.
Prerequisiti
Almeno una delle azioni nel progetto Actions deve essere configurata come intent di attivazione che verrà richiamato quando l'utente tocca una notifica ricevuta dall'assistente.
Non è possibile configurare le azioni per attivare l'intent di benvenuto predefinito da una notifica push.
Configurazione della console
Per aggiungere il supporto delle notifiche push all'Azione:
Vai alla console di Actions e vai a Crea > Azioni.
Fai clic sull'Azione che corrisponde all'intent di attivazione aggiuntivo per cui vuoi abilitare le notifiche push.
Per l'esempio di suggerimenti di Actions on Google, devi selezionare "tell_latest_tip".
Scorri verso il basso fino alla sezione Coinvolgimento degli utenti e attiva l'opzione Vuoi inviare notifiche push.
Inserisci un Titolo contenuti.
Per l'esempio di suggerimenti di Actions on Google, il titolo potrebbe essere "Nuovo suggerimento aggiunto".
Fai clic su Salva.
Importazioni
Ai fini delle sezioni successive, dovrai dichiarare le seguenti importazioni nel codice di distribuzione:
const {
dialogflow,
UpdatePermission,
Suggestions,
} = require('actions-on-google');
const {
actionssdk,
UpdatePermission,
Suggestions,
} = require('actions-on-google');
Utenti che hanno attivato la funzionalità
Prima di poter inviare notifiche push agli utenti, devi chiedere loro di attivarle. Per farlo, mostra un chip di suggerimento con cui chiedere l'autorizzazione. Quando l'utente concede l'autorizzazione, ricevi un ID utente aggiornato per inviargli notifiche push.
Mostra chip di suggerimenti per l'attivazione
Prima che gli utenti possano ricevere notifiche push dall'Azione, devi mostrare loro un chip di suggerimenti per invitarli ad attivare le notifiche push.
Lo snippet di codice riportato di seguito invia all'utente un chip di suggerimento "Avvisami in caso di nuovi suggerimenti" insieme a una risposta testuale.
conv.ask('I can send you push notifications. Would you like that?');
conv.ask(new Suggestions('Send notifications'));
conv.ask(' I can send you push notifications. Would you like that?');
conv.ask(new Suggestions('Send notifications'));
responseBuilder
.add("I can send you push notifications. Would you like that?")
.addSuggestions(new String[] {
"Send notifications"
});
responseBuilder
.add("I can send you push notifications. Would you like that?")
.addSuggestions(new String[] {
"Send notifications"
});
Tieni presente che il JSON di seguito descrive una risposta webhook.
{
"payload": {
"google": {
"expectUserResponse": true,
"richResponse": {
"items": [
{
"simpleResponse": {
"textToSpeech": "Hi! Welcome to Push Notifications!"
}
},
{
"simpleResponse": {
"textToSpeech": "I can send you push notifications. Would you like that?"
}
}
],
"suggestions": [
{
"title": "Send notifications"
}
]
}
}
}
}
Tieni presente che il JSON di seguito descrive una risposta webhook.
{
"expectUserResponse": true,
"expectedInputs": [
{
"possibleIntents": [
{
"intent": "actions.intent.TEXT"
}
],
"inputPrompt": {
"richInitialPrompt": {
"items": [
{
"simpleResponse": {
"textToSpeech": "Hi! Welcome to Push Notifications!"
}
},
{
"simpleResponse": {
"textToSpeech": " I can send you push notifications. Would you like that?"
}
}
],
"suggestions": [
{
"title": "Send notifications"
}
]
}
}
}
]
}
Dopo aver toccato il chip, devi chiedere l'autorizzazione UPDATE.
Il codice seguente mostra come eseguire questa operazione con la funzione askForUpdatePermission della libreria client Node.js.
- Apri l'agente nella console di Dialogflow e seleziona l'intent che stai configurando per gli aggiornamenti.
- Scorri verso il basso fino a Risposta e apri la scheda Assistente Google.
- Fai clic su Aggiungi contenuti del messaggio e seleziona Chip di suggerimenti.
- Imposta il testo del chip su un elemento che inviti l'utente all'attivazione. Nell'esempio di suggerimenti di Actions on Google, impostiamo il chip su Avvisami in caso di nuovi suggerimenti.
- Aggiungi un altro intent Dialogflow, chiamato ad esempio setup_push, e imposta un'azione corrispondente, ad esempio setup.push. L'espressione utente di questo intent deve corrispondere al testo del chip di attivazione, nel nostro esempio Avvisami in caso di nuovi suggerimenti.
app.intent('Subscribe to Notifications', (conv) => {
conv.ask(new UpdatePermission({
intent: 'Notification',
}));
});
Devi configurare la tua soluzione NLU in modo che attivi una funzione che richiede l'autorizzazione se l'espressione utente corrisponde al valore della richiesta di attivazione delle notifiche push. Di seguito è riportato un esempio molto basilare basato sulla corrispondenza delle stringhe:
conv.ask(new UpdatePermission({
intent: 'Notification',
}));
- Apri l'agente nella console di Dialogflow e seleziona l'intent che stai configurando per gli aggiornamenti.
- Scorri verso il basso fino a Risposta e apri la scheda Assistente Google.
- Fai clic su Aggiungi contenuti del messaggio e seleziona Chip di suggerimenti.
- Imposta il testo del chip su un elemento che inviti l'utente all'attivazione. Nell'esempio di suggerimenti di Actions on Google, impostiamo il chip su Avvisami in caso di nuovi suggerimenti.
- Aggiungi un altro intent Dialogflow, chiamato ad esempio setup_push, e imposta un'azione corrispondente, ad esempio setup.push. L'espressione utente di questo intent deve corrispondere al testo del chip di attivazione, nel nostro esempio Avvisami in caso di nuovi suggerimenti.
@ForIntent("Subscribe to Notifications")
public ActionResponse subscribeToNotifications(ActionRequest request) {
ResponseBuilder responseBuilder = getResponseBuilder(request);
responseBuilder.add(new UpdatePermission().setIntent("Notification"));
return responseBuilder.build();
}
Devi configurare la tua soluzione NLU in modo che attivi una funzione che richiede l'autorizzazione se l'espressione utente corrisponde al valore della richiesta di attivazione delle notifiche push. Di seguito è riportato un esempio molto basilare basato sulla corrispondenza delle stringhe:
ResponseBuilder responseBuilder = getResponseBuilder(request);
responseBuilder.add(new UpdatePermission().setIntent("Notification"));
return responseBuilder.build();
Tieni presente che il codice JSON riportato di seguito descrive una risposta webhook utilizzando Dialogflow.
{
"payload": {
"google": {
"expectUserResponse": true,
"systemIntent": {
"intent": "actions.intent.PERMISSION",
"data": {
"@type": "type.googleapis.com/google.actions.v2.PermissionValueSpec",
"permissions": [
"UPDATE"
],
"updatePermissionValueSpec": {
"intent": "tell_latest_tip"
}
}
}
}
}
}
Tieni presente che il JSON di seguito descrive una risposta webhook che utilizza l'SDK Actions.
{
"expectUserResponse": true,
"expectedInputs": [
{
"possibleIntents": [
{
"intent": "actions.intent.PERMISSION",
"inputValueData": {
"@type": "type.googleapis.com/google.actions.v2.PermissionValueSpec",
"permissions": [
"UPDATE"
],
"updatePermissionValueSpec": {
"intent": "tell_latest_tip"
}
}
}
]
}
]
}
Finalizza l'abbonamento
Per finalizzare l'abbonamento dal webhook Node.js, devi salvare l'ID notifiche dell'utente e l'intent selezionato. Entrambi vengono trasmessi come argomenti se l'utente concede l'autorizzazione.
Se l'azione è creata con Dialogflow, devi:
- Aggiungi un intent che gestisca
actions_intent_PERMISSION. - Specifica il nome Azione dell'intent in modo che possa essere filtrato in un secondo momento dal webhook.
Il codice seguente mostra come gestire un intent di Dialogflow con un intent denominato finish_push_setup e con un nome azione finish.push.setup:
app.intent('Confirm Notifications Subscription', (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.`);
}
});
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.`);
}
});
@ForIntent("Confirm Notifications Subscription")
public ActionResponse confirmNotificationsSubscription(ActionRequest request) {
// Verify the user has subscribed for push notifications
ResponseBuilder responseBuilder = getResponseBuilder(request);
if (request.isPermissionGranted()) {
Argument userId = request.getArgument(ConstantsKt.ARG_UPDATES_USER_ID);
if (userId != null) {
// Store the user's ID in the database
}
responseBuilder.add("Ok, I'll start alerting you.");
} else {
responseBuilder.add("Ok, I won't alert you.");
}
responseBuilder.endConversation();
return responseBuilder.build();
}
@ForIntent("actions.intent.PERMISSION")
public ActionResponse confirmNotificationsSubscription(ActionRequest request) {
// Verify the user has subscribed for push notifications
ResponseBuilder responseBuilder = getResponseBuilder(request);
if (request.isPermissionGranted()) {
Argument userId = request.getArgument(ConstantsKt.ARG_UPDATES_USER_ID);
if (userId != null) {
// Store the user's ID in the database
}
responseBuilder.add("Ok, I'll start alerting you.");
} else {
responseBuilder.add("Ok, I won't alert you.");
}
responseBuilder.endConversation();
return responseBuilder.build();
}
Tieni presente che il JSON di seguito descrive una richiesta al webhook.
{
"responseId": "ee9e7ed5-fa1a-48c6-aac7-f9fbe94f1f58-712767ed",
"queryResult": {
"queryText": "actions_intent_PERMISSION",
"action": "confirm.subscription",
"parameters": {},
"allRequiredParamsPresent": true,
"fulfillmentMessages": [
{
"text": {
"text": [
""
]
}
}
],
"outputContexts": [
{
"name": "projects/PROJECT_ID/agent/sessions/ABwppHGIgmmU3zBcYMF_vWoHaM4JUo3wniYBHdbUF25l63G7EQWjRnlne8Ar7AOcRHWn1lrEKGy8qdP0UXLcWDBq93k/contexts/actions_capability_screen_output"
},
{
"name": "projects/PROJECT_ID/agent/sessions/ABwppHGIgmmU3zBcYMF_vWoHaM4JUo3wniYBHdbUF25l63G7EQWjRnlne8Ar7AOcRHWn1lrEKGy8qdP0UXLcWDBq93k/contexts/actions_capability_account_linking"
},
{
"name": "projects/PROJECT_ID/agent/sessions/ABwppHGIgmmU3zBcYMF_vWoHaM4JUo3wniYBHdbUF25l63G7EQWjRnlne8Ar7AOcRHWn1lrEKGy8qdP0UXLcWDBq93k/contexts/actions_capability_media_response_audio"
},
{
"name": "projects/PROJECT_ID/agent/sessions/ABwppHGIgmmU3zBcYMF_vWoHaM4JUo3wniYBHdbUF25l63G7EQWjRnlne8Ar7AOcRHWn1lrEKGy8qdP0UXLcWDBq93k/contexts/actions_capability_audio_output"
},
{
"name": "projects/PROJECT_ID/agent/sessions/ABwppHGIgmmU3zBcYMF_vWoHaM4JUo3wniYBHdbUF25l63G7EQWjRnlne8Ar7AOcRHWn1lrEKGy8qdP0UXLcWDBq93k/contexts/actions_capability_web_browser"
},
{
"name": "projects/PROJECT_ID/agent/sessions/ABwppHGIgmmU3zBcYMF_vWoHaM4JUo3wniYBHdbUF25l63G7EQWjRnlne8Ar7AOcRHWn1lrEKGy8qdP0UXLcWDBq93k/contexts/google_assistant_input_type_keyboard"
},
{
"name": "projects/PROJECT_ID/agent/sessions/ABwppHGIgmmU3zBcYMF_vWoHaM4JUo3wniYBHdbUF25l63G7EQWjRnlne8Ar7AOcRHWn1lrEKGy8qdP0UXLcWDBq93k/contexts/actions_intent_permission",
"parameters": {
"PERMISSION": true,
"text": "yes",
"UPDATES_USER_ID": "ABwppHHssyPbvEBF1mgN7Ddwb7mkhiVohW9PZ--I_svqy7zFElA4DHkf9pn04UBd5gwZo26_RfXCQ8otcztyIfe6MCQ"
}
}
],
"intent": {
"name": "projects/PROJECT_ID/agent/intents/c7f7b30b-5b88-4bb5-b0b8-1cd0862d1dd2",
"displayName": "Confirm Notifications Subscription"
},
"intentDetectionConfidence": 1,
"languageCode": "en"
},
"originalDetectIntentRequest": {
"source": "google",
"version": "2",
"payload": {
"user": {
"permissions": [
"UPDATE"
],
"locale": "en-US",
"userVerificationStatus": "VERIFIED"
},
"conversation": {
"conversationId": "ABwppHGIgmmU3zBcYMF_vWoHaM4JUo3wniYBHdbUF25l63G7EQWjRnlne8Ar7AOcRHWn1lrEKGy8qdP0UXLcWDBq93k",
"type": "ACTIVE",
"conversationToken": "[]"
},
"inputs": [
{
"intent": "actions.intent.PERMISSION",
"rawInputs": [
{
"inputType": "KEYBOARD",
"query": "yes"
}
],
"arguments": [
{
"name": "PERMISSION",
"boolValue": true,
"textValue": "true"
},
{
"name": "text",
"rawText": "yes",
"textValue": "yes"
},
{
"name": "UPDATES_USER_ID",
"textValue": "ABwppHHssyPbvEBF1mgN7Ddwb7mkhiVohW9PZ--I_svqy7zFElA4DHkf9pn04UBd5gwZo26_RfXCQ8otcztyIfe6MCQ"
}
]
}
],
"surface": {
"capabilities": [
{
"name": "actions.capability.SCREEN_OUTPUT"
},
{
"name": "actions.capability.ACCOUNT_LINKING"
},
{
"name": "actions.capability.MEDIA_RESPONSE_AUDIO"
},
{
"name": "actions.capability.AUDIO_OUTPUT"
},
{
"name": "actions.capability.WEB_BROWSER"
}
]
},
"availableSurfaces": [
{
"capabilities": [
{
"name": "actions.capability.AUDIO_OUTPUT"
},
{
"name": "actions.capability.SCREEN_OUTPUT"
},
{
"name": "actions.capability.WEB_BROWSER"
}
]
}
]
}
},
"session": "projects/PROJECT_ID/agent/sessions/ABwppHGIgmmU3zBcYMF_vWoHaM4JUo3wniYBHdbUF25l63G7EQWjRnlne8Ar7AOcRHWn1lrEKGy8qdP0UXLcWDBq93k"
}
Tieni presente che il JSON di seguito descrive una richiesta al webhook.
{
"user": {
"permissions": [
"UPDATE"
],
"locale": "en-US",
"userVerificationStatus": "VERIFIED"
},
"conversation": {
"conversationId": "ABwppHEP6OAFZHkSGEiZ5HYM9qrlk8YtIH1DQmJ52cxXELSPvM-kSc_tMJ_5O6ITbgVJlY9i2FIsKWjE_HXLke48",
"type": "NEW"
},
"inputs": [
{
"intent": "actions.intent.PERMISSION",
"rawInputs": [
{
"inputType": "KEYBOARD",
"query": "yes"
}
],
"arguments": [
{
"name": "PERMISSION",
"boolValue": true,
"textValue": "true"
},
{
"name": "text",
"rawText": "yes",
"textValue": "yes"
},
{
"name": "UPDATES_USER_ID",
"textValue": "ABwppHFvBKC-tMYUsUjJkm3YECgZvd6A3sOc7KuQvO4ZdQX3bGLmyoQ41dh4Zmtlzv_kaOKBt1Sf6eRpNbayynrl"
}
]
}
],
"surface": {
"capabilities": [
{
"name": "actions.capability.AUDIO_OUTPUT"
},
{
"name": "actions.capability.WEB_BROWSER"
},
{
"name": "actions.capability.SCREEN_OUTPUT"
},
{
"name": "actions.capability.ACCOUNT_LINKING"
},
{
"name": "actions.capability.MEDIA_RESPONSE_AUDIO"
}
]
},
"availableSurfaces": [
{
"capabilities": [
{
"name": "actions.capability.AUDIO_OUTPUT"
},
{
"name": "actions.capability.SCREEN_OUTPUT"
},
{
"name": "actions.capability.WEB_BROWSER"
}
]
}
]
}
Invia notifiche
Puoi inviare notifiche push agli utenti utilizzando l'API Actions. Per utilizzare questa API, devi attivare l'API nel tuo progetto Google Cloud e configurare e scaricare una chiave dell'account di servizio JSON. Vedi il passaggio 8 delle istruzioni nell'esempio di codice qui.
Puoi quindi utilizzare la libreria client OAuth2 di Google per scambiare la chiave dell'account di servizio con un token di accesso e utilizzare il token per autenticare le tue richieste all'API Actions.
Generazione di una chiave dell'account di servizio
- Vai a questo URL sostituendo "example-project-1" alla fine con il tuo ID progetto nella console di Actions: https://console.developers.google.com/apis/api/actions.googleapis.com/overview?project=example-project-1
- Se vedi il pulsante Attiva, fai clic su di esso. In caso contrario, vai al passaggio 3.
- Vai a questo URL, sostituendo "example-project-1" alla fine con il tuo ID progetto nella console di Actions: https://console.developers.google.com/apis/credentials?project=example-project-1
- Fai clic su Crea credenziali > Chiave account di servizio.
- Fai clic sulla casella Seleziona in Account di servizio, quindi su Nuovo account di servizio.
- Assegna all'account di servizio un nome, ad esempio "notifications" e il Ruolo di Proprietario progetto.
- Seleziona il tipo di chiave JSON e fai clic su Crea. Una chiave JSON dell'account di servizio viene scaricata sulla tua macchina locale.
Scambia la chiave con un token di accesso e invia una notifica
Per inviare una notifica tramite l'API Actions, devi scambiare la chiave dell'account di servizio con un token di accesso. A questo scopo, consigliamo di utilizzare una libreria client API di Google. Nella serie di snippet di codice che seguono, utilizziamo la libreria client Node.js dell'API di Google.
- Installa la libreria client dell'API di Google e richiedi:
npm install googleapis request --save - Utilizza il codice seguente per ottenere un token di accesso dalla chiave dell'account di servizio e inviare una notifica push:
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_USER_ID>',
intent: 'Notification Intent',
},
},
isInSandbox: true,
},
}, (err, httpResponse, body) => {
console.log(`${httpResponse.statusCode}: ${httpResponse.statusMessage}`);
});
}
});
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}`);
});
}
});
final class Notification {
private final String title;
Notification(String title) {
this.title = title;
}
String getTitle() {
return title;
}
}
final class Target {
private final String userId;
private final String intent;
private final String locale;
Target(String userId, String intent, String locale) {
this.userId = userId;
this.intent = intent;
this.locale = locale;
}
String getUserId() {
return userId;
}
String getIntent() {
return intent;
}
String getLocale() {
return locale;
}
}
final class PushMessage {
private final Notification userNotification;
private final Target target;
PushMessage(Notification userNotification, Target target) {
this.userNotification = userNotification;
this.target = target;
}
Notification getUserNotification() {
return userNotification;
}
Target getTarget() {
return target;
}
}
final class PushNotification {
private final PushMessage customPushMessage;
private boolean isInSandbox;
PushNotification(PushMessage customPushMessage, boolean isInSandbox) {
this.customPushMessage = customPushMessage;
this.isInSandbox = isInSandbox;
}
PushMessage getCustomPushMessage() {
return customPushMessage;
}
boolean getIsInSandbox() {
return isInSandbox;
}
}
private PushNotification createNotification(String title, String userId, String intent, String locale) {
Notification notification = new Notification(title);
Target target = new Target(userId, intent, locale);
PushMessage message = new PushMessage(notification, target);
boolean isInSandbox = true;
return new PushNotification(message, isInSandbox);
}
private ServiceAccountCredentials loadCredentials() throws IOException {
String actionsApiServiceAccountFile =
this.getClass().getClassLoader().getResource("service-account.json").getFile();
InputStream actionsApiServiceAccount = new FileInputStream(actionsApiServiceAccountFile);
ServiceAccountCredentials serviceAccountCredentials =
ServiceAccountCredentials.fromStream(actionsApiServiceAccount);
return (ServiceAccountCredentials)
serviceAccountCredentials.createScoped(
Collections.singleton(
"https://www.googleapis.com/auth/actions.fulfillment.conversation"));
}
private String getAccessToken() throws IOException {
AccessToken token = loadCredentials().refreshAccessToken();
return token.getTokenValue();
}
public void sendNotification(String title, String userId, String intent, String locale) throws IOException {
Preconditions.checkNotNull(title, "title cannot be null.");
Preconditions.checkNotNull(userId, "userId cannot be null.");
Preconditions.checkNotNull(intent, "intent cannot be null.");
Preconditions.checkNotNull(locale, "locale cannot be null");
PushNotification notification = createNotification(title, userId, intent, locale);
HttpPost request = new HttpPost("https://actions.googleapis.com/v2/conversations:send");
String token = getAccessToken();
request.setHeader("Content-type", "application/json");
request.setHeader("Authorization", "Bearer " + token);
StringEntity entity = new StringEntity(new Gson().toJson(notification));
entity.setContentType(ContentType.APPLICATION_JSON.getMimeType());
request.setEntity(entity);
HttpClient httpClient = HttpClientBuilder.create().build();
httpClient.execute(request);
}
final class Notification {
private final String title;
Notification(String title) {
this.title = title;
}
String getTitle() {
return title;
}
}
final class Target {
private final String userId;
private final String intent;
Target(String userId, String intent) {
this.userId = userId;
this.intent = intent;
}
String getUserId() {
return userId;
}
String getIntent() {
return intent;
}
}
final class PushMessage {
private final Notification userNotification;
private final Target target;
PushMessage(Notification userNotification, Target target) {
this.userNotification = userNotification;
this.target = target;
}
Notification getUserNotification() {
return userNotification;
}
Target getTarget() {
return target;
}
}
final class PushNotification {
private final PushMessage customPushMessage;
private boolean isInSandbox;
PushNotification(PushMessage customPushMessage, boolean isInSandbox) {
this.customPushMessage = customPushMessage;
this.isInSandbox = isInSandbox;
}
PushMessage getCustomPushMessage() {
return customPushMessage;
}
boolean getIsInSandbox() {
return isInSandbox;
}
}
private PushNotification createNotification(String title, String userId, String intent) {
Notification notification = new Notification(title);
Target target = new Target(userId, intent);
PushMessage message = new PushMessage(notification, target);
boolean isInSandbox = true;
return new PushNotification(message, isInSandbox);
}
private ServiceAccountCredentials loadCredentials() throws IOException {
String actionsApiServiceAccountFile =
this.getClass().getClassLoader().getResource("service-account.json").getFile();
InputStream actionsApiServiceAccount = new FileInputStream(actionsApiServiceAccountFile);
ServiceAccountCredentials serviceAccountCredentials =
ServiceAccountCredentials.fromStream(actionsApiServiceAccount);
return (ServiceAccountCredentials)
serviceAccountCredentials.createScoped(
Collections.singleton(
"https://www.googleapis.com/auth/actions.fulfillment.conversation"));
}
private String getAccessToken() throws IOException {
AccessToken token = loadCredentials().refreshAccessToken();
return token.getTokenValue();
}
public void sendNotification(String title, String userId, String intent) throws IOException {
Preconditions.checkNotNull(title, "title cannot be null.");
Preconditions.checkNotNull(userId, "userId cannot be null.");
Preconditions.checkNotNull(intent, "intent cannot be null.");
PushNotification notification = createNotification(title, userId, intent);
HttpPost request = new HttpPost("https://actions.googleapis.com/v2/conversations:send");
String token = getAccessToken();
request.setHeader("Content-type", "application/json");
request.setHeader("Authorization", "Bearer " + token);
StringEntity entity = new StringEntity(new Gson().toJson(notification));
entity.setContentType(ContentType.APPLICATION_JSON.getMimeType());
request.setEntity(entity);
HttpClient httpClient = HttpClientBuilder.create().build();
httpClient.execute(request);
}