feat: support document metadata filter in article suggestion and smar…

…t reply model in human agent assistant PiperOrigin-RevId: 409190373 Source-Link: googleapis/googleapis@29bb98c Source-Link: googleapis/googleapis-gen@e90c22e Copy-Tag: eyJwIjoiYXBpcy9Hb29nbGUuQ2xvdWQuRGlhbG9nZmxvdy5WMi8uT3dsQm90LnlhbWwiLCJoIjoiZTkwYzIyZTkyNzViOTFhYWJjNmM4MjBhNzY3YWYyZmQ2OTU0ZjYyNCJ9
googleapis · Nov 12, 2021 · d033f77 · d033f77
1 parent aaeed36
commit d033f77
Show file tree

Hide file tree

Showing 4 changed files with 794 additions and 237 deletions.
diff --git a/...e.Cloud.Dialogflow.V2/Google.Cloud.Dialogflow.V2.Snippets/ParticipantsClientSnippets.g.cs b/...e.Cloud.Dialogflow.V2/Google.Cloud.Dialogflow.V2.Snippets/ParticipantsClientSnippets.g.cs
@@ -559,6 +559,7 @@ public void AnalyzeContentRequestObject()
                 TextInput = new TextInput(),
                 QueryParams = new QueryParameters(),
                 RequestId = "",
+                AssistQueryParams = new AssistQueryParameters(),
             };
             // Make the request
             AnalyzeContentResponse response = participantsClient.AnalyzeContent(request);
@@ -580,6 +581,7 @@ public async Task AnalyzeContentRequestObjectAsync()
                 TextInput = new TextInput(),
                 QueryParams = new QueryParameters(),
                 RequestId = "",
+                AssistQueryParams = new AssistQueryParameters(),
             };
             // Make the request
             AnalyzeContentResponse response = await participantsClient.AnalyzeContentAsync(request);
@@ -714,6 +716,7 @@ public void SuggestArticlesRequestObject()
                 ParentAsParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 LatestMessageAsMessageName = MessageName.FromProjectConversationMessage("[PROJECT]", "[CONVERSATION]", "[MESSAGE]"),
                 ContextSize = 0,
+                AssistQueryParams = new AssistQueryParameters(),
             };
             // Make the request
             SuggestArticlesResponse response = participantsClient.SuggestArticles(request);
@@ -733,6 +736,7 @@ public async Task SuggestArticlesRequestObjectAsync()
                 ParentAsParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 LatestMessageAsMessageName = MessageName.FromProjectConversationMessage("[PROJECT]", "[CONVERSATION]", "[MESSAGE]"),
                 ContextSize = 0,
+                AssistQueryParams = new AssistQueryParameters(),
             };
             // Make the request
             SuggestArticlesResponse response = await participantsClient.SuggestArticlesAsync(request);
@@ -805,6 +809,7 @@ public void SuggestFaqAnswersRequestObject()
                 ParentAsParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 LatestMessageAsMessageName = MessageName.FromProjectConversationMessage("[PROJECT]", "[CONVERSATION]", "[MESSAGE]"),
                 ContextSize = 0,
+                AssistQueryParams = new AssistQueryParameters(),
             };
             // Make the request
             SuggestFaqAnswersResponse response = participantsClient.SuggestFaqAnswers(request);
@@ -824,6 +829,7 @@ public async Task SuggestFaqAnswersRequestObjectAsync()
                 ParentAsParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 LatestMessageAsMessageName = MessageName.FromProjectConversationMessage("[PROJECT]", "[CONVERSATION]", "[MESSAGE]"),
                 ContextSize = 0,
+                AssistQueryParams = new AssistQueryParameters(),
             };
             // Make the request
             SuggestFaqAnswersResponse response = await participantsClient.SuggestFaqAnswersAsync(request);

diff --git a/apis/Google.Cloud.Dialogflow.V2/Google.Cloud.Dialogflow.V2.Tests/ParticipantsClientTest.g.cs b/apis/Google.Cloud.Dialogflow.V2/Google.Cloud.Dialogflow.V2.Tests/ParticipantsClientTest.g.cs
@@ -41,6 +41,13 @@ public void CreateParticipantRequestObject()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.CreateParticipant(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -63,6 +70,13 @@ public void CreateParticipantRequestObject()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.CreateParticipantAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Participant>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -87,6 +101,13 @@ public void CreateParticipant()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.CreateParticipant(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -109,6 +130,13 @@ public void CreateParticipant()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.CreateParticipantAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Participant>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -133,6 +161,13 @@ public void CreateParticipantResourceNames()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.CreateParticipant(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -155,6 +190,13 @@ public void CreateParticipantResourceNames()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.CreateParticipantAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Participant>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -178,6 +220,13 @@ public void GetParticipantRequestObject()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.GetParticipant(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -199,6 +248,13 @@ public void GetParticipantRequestObject()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.GetParticipantAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Participant>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -222,6 +278,13 @@ public void GetParticipant()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.GetParticipant(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -243,6 +306,13 @@ public void GetParticipant()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.GetParticipantAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Participant>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -266,6 +336,13 @@ public void GetParticipantResourceNames()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.GetParticipant(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -287,6 +364,13 @@ public void GetParticipantResourceNames()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.GetParticipantAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Participant>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -311,6 +395,13 @@ public void UpdateParticipantRequestObject()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.UpdateParticipant(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -333,6 +424,13 @@ public void UpdateParticipantRequestObject()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.UpdateParticipantAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Participant>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -357,6 +455,13 @@ public void UpdateParticipant()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.UpdateParticipant(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -379,6 +484,13 @@ public void UpdateParticipant()
                 ParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 Role = Participant.Types.Role.HumanAgent,
                 SipRecordingMediaLabel = "sip_recording_media_labela9ddfd5d",
+                DocumentsMetadataFilters =
+                {
+                    {
+                        "key8a0b6e3c",
+                        "value60c16320"
+                    },
+                },
             };
             mockGrpcClient.Setup(x => x.UpdateParticipantAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<Participant>(stt::Task.FromResult(expectedResponse), null, null, null, null));
             ParticipantsClient client = new ParticipantsClientImpl(mockGrpcClient.Object, null);
@@ -401,6 +513,7 @@ public void AnalyzeContentRequestObject()
                 EventInput = new EventInput(),
                 QueryParams = new QueryParameters(),
                 RequestId = "request_id362c8df6",
+                AssistQueryParams = new AssistQueryParameters(),
             };
             AnalyzeContentResponse expectedResponse = new AnalyzeContentResponse
             {
@@ -437,6 +550,7 @@ public void AnalyzeContentRequestObject()
                 EventInput = new EventInput(),
                 QueryParams = new QueryParameters(),
                 RequestId = "request_id362c8df6",
+                AssistQueryParams = new AssistQueryParameters(),
             };
             AnalyzeContentResponse expectedResponse = new AnalyzeContentResponse
             {
@@ -736,6 +850,7 @@ public void SuggestArticlesRequestObject()
                 ParentAsParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 LatestMessageAsMessageName = MessageName.FromProjectConversationMessage("[PROJECT]", "[CONVERSATION]", "[MESSAGE]"),
                 ContextSize = 1799545581,
+                AssistQueryParams = new AssistQueryParameters(),
             };
             SuggestArticlesResponse expectedResponse = new SuggestArticlesResponse
             {
@@ -762,6 +877,7 @@ public void SuggestArticlesRequestObject()
                 ParentAsParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 LatestMessageAsMessageName = MessageName.FromProjectConversationMessage("[PROJECT]", "[CONVERSATION]", "[MESSAGE]"),
                 ContextSize = 1799545581,
+                AssistQueryParams = new AssistQueryParameters(),
             };
             SuggestArticlesResponse expectedResponse = new SuggestArticlesResponse
             {
@@ -890,6 +1006,7 @@ public void SuggestFaqAnswersRequestObject()
                 ParentAsParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 LatestMessageAsMessageName = MessageName.FromProjectConversationMessage("[PROJECT]", "[CONVERSATION]", "[MESSAGE]"),
                 ContextSize = 1799545581,
+                AssistQueryParams = new AssistQueryParameters(),
             };
             SuggestFaqAnswersResponse expectedResponse = new SuggestFaqAnswersResponse
             {
@@ -913,6 +1030,7 @@ public void SuggestFaqAnswersRequestObject()
                 ParentAsParticipantName = ParticipantName.FromProjectConversationParticipant("[PROJECT]", "[CONVERSATION]", "[PARTICIPANT]"),
                 LatestMessageAsMessageName = MessageName.FromProjectConversationMessage("[PROJECT]", "[CONVERSATION]", "[MESSAGE]"),
                 ContextSize = 1799545581,
+                AssistQueryParams = new AssistQueryParameters(),
             };
             SuggestFaqAnswersResponse expectedResponse = new SuggestFaqAnswersResponse
             {