-
Notifications
You must be signed in to change notification settings - Fork 595
/
participants.streaming_analyze_content.js
125 lines (115 loc) · 4.36 KB
/
participants.streaming_analyze_content.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
// Copyright 2022 Google LLC
//
// 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
//
// https://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.
//
// ** This file is automatically generated by gapic-generator-typescript. **
// ** https://github.com/googleapis/gapic-generator-typescript **
// ** All changes to this file may be overwritten. **
'use strict';
function main(participant) {
// [START dialogflow_v2_generated_Participants_StreamingAnalyzeContent_async]
/**
* This snippet has been automatically generated and should be regarded as a code template only.
* It will require modifications to work.
* It may require correct/in-range values for request initialization.
* TODO(developer): Uncomment these variables before running the sample.
*/
/**
* Required. The name of the participant this text comes from.
* Format: `projects/<Project ID>/locations/<Location
* ID>/conversations/<Conversation ID>/participants/<Participant ID>`.
*/
// const participant = 'abc123'
/**
* Instructs the speech recognizer how to process the speech audio.
*/
// const audioConfig = {}
/**
* The natural language text to be processed.
*/
// const textConfig = {}
/**
* Speech synthesis configuration.
* The speech synthesis settings for a virtual agent that may be configured
* for the associated conversation profile are not used when calling
* StreamingAnalyzeContent. If this configuration is not supplied, speech
* synthesis is disabled.
*/
// const replyAudioConfig = {}
/**
* The input audio content to be recognized. Must be sent if `audio_config`
* is set in the first message. The complete audio over all streaming
* messages must not exceed 1 minute.
*/
// const inputAudio = 'Buffer.from('string')'
/**
* The UTF-8 encoded natural language text to be processed. Must be sent if
* `text_config` is set in the first message. Text length must not exceed
* 256 bytes for virtual agent interactions. The `input_text` field can be
* only sent once.
*/
// const inputText = 'abc123'
/**
* The DTMF digits used to invoke intent and fill in parameter value.
* This input is ignored if the previous response indicated that DTMF input
* is not accepted.
*/
// const inputDtmf = {}
/**
* Parameters for a Dialogflow virtual-agent query.
*/
// const queryParams = {}
/**
* Parameters for a human assist query.
*/
// const assistQueryParams = {}
/**
* Additional parameters to be put into Dialogflow CX session parameters. To
* remove a parameter from the session, clients should explicitly set the
* parameter value to null.
* Note: this field should only be used if you are connecting to a Dialogflow
* CX agent.
*/
// const cxParameters = {}
/**
* Enable partial virtual agent responses. If this flag is not enabled,
* response stream still contains only one final response even if some
* `Fulfillment`s in Dialogflow virtual agent have been configured to return
* partial responses.
*/
// const enablePartialAutomatedAgentReply = true
// Imports the Dialogflow library
const {ParticipantsClient} = require('@google-cloud/dialogflow').v2;
// Instantiates a client
const dialogflowClient = new ParticipantsClient();
async function callStreamingAnalyzeContent() {
// Construct request
const request = {
participant,
};
// Run request
const stream = await dialogflowClient.streamingAnalyzeContent();
stream.on('data', (response) => { console.log(response) });
stream.on('error', (err) => { throw(err) });
stream.on('end', () => { /* API call completed */ });
stream.write(request);
stream.end();
}
callStreamingAnalyzeContent();
// [END dialogflow_v2_generated_Participants_StreamingAnalyzeContent_async]
}
process.on('unhandledRejection', err => {
console.error(err.message);
process.exitCode = 1;
});
main(...process.argv.slice(2));