google-assistant-sdk: add support for new conversation

- reset conversation on startup

Bug: 69230966
Change-Id: I4005798dace021d51f9d78f5ad97f38a107f829c

Author: proppy

google-assistant-sdk/googlesamples/assistant/grpc/pushtotalk.py

@@ -88,6 +88,8 @@ def __init__(self, language_code, device_model_id, device_id,
         # This value, along with MicrophoneMode, supports a more natural
         # "conversation" with the Assistant.
         self.conversation_state = None
+        # Force reset of first conversation.
+        self.is_new_conversation = True
 
         # Create Google Assistant API gRPC client.
         self.assistant = embedded_assistant_pb2_grpc.EmbeddedAssistantStub(
@@ -185,13 +187,6 @@ def iter_log_assist_requests():
     def gen_assist_requests(self):
         """Yields: AssistRequest messages to send to the API."""
 
-        dialog_state_in = embedded_assistant_pb2.DialogStateIn(
-                language_code=self.language_code,
-                conversation_state=b''
-            )
-        if self.conversation_state:
-            logging.debug('Sending conversation state.')
-            dialog_state_in.conversation_state = self.conversation_state
         config = embedded_assistant_pb2.AssistConfig(
             audio_in_config=embedded_assistant_pb2.AudioInConfig(
                 encoding='LINEAR16',
@@ -202,15 +197,20 @@ def gen_assist_requests(self):
                 sample_rate_hertz=self.conversation_stream.sample_rate,
                 volume_percentage=self.conversation_stream.volume_percentage,
             ),
-            dialog_state_in=dialog_state_in,
+            dialog_state_in=embedded_assistant_pb2.DialogStateIn(
+                language_code=self.language_code,
+                conversation_state=self.conversation_state,
+                is_new_conversation=self.is_new_conversation,
+            ),
             device_config=embedded_assistant_pb2.DeviceConfig(
                 device_id=self.device_id,
                 device_model_id=self.device_model_id,
             )
         )
         if self.display:
             config.screen_out_config.screen_mode = PLAYING
-
+        # Continue current conversation with later requests.
+        self.is_new_conversation = False
         # The first AssistRequest must contain the AssistConfig
         # and no audio data.
         yield embedded_assistant_pb2.AssistRequest(config=config)

google-assistant-sdk/googlesamples/assistant/grpc/textinput.py

@@ -62,6 +62,8 @@ def __init__(self, language_code, device_model_id, device_id,
         self.device_model_id = device_model_id
         self.device_id = device_id
         self.conversation_state = None
+        # Force reset of first conversation.
+        self.is_new_conversation = True
         self.display = display
         self.assistant = embedded_assistant_pb2_grpc.EmbeddedAssistantStub(
             channel
@@ -79,25 +81,25 @@ def assist(self, text_query):
         """Send a text request to the Assistant and playback the response.
         """
         def iter_assist_requests():
-            dialog_state_in = embedded_assistant_pb2.DialogStateIn(
-                language_code=self.language_code,
-                conversation_state=b''
-            )
-            if self.conversation_state:
-                dialog_state_in.conversation_state = self.conversation_state
             config = embedded_assistant_pb2.AssistConfig(
                 audio_out_config=embedded_assistant_pb2.AudioOutConfig(
                     encoding='LINEAR16',
                     sample_rate_hertz=16000,
                     volume_percentage=0,
                 ),
-                dialog_state_in=dialog_state_in,
+                dialog_state_in=embedded_assistant_pb2.DialogStateIn(
+                    language_code=self.language_code,
+                    conversation_state=self.conversation_state,
+                    is_new_conversation=self.is_new_conversation,
+                ),
                 device_config=embedded_assistant_pb2.DeviceConfig(
                     device_id=self.device_id,
                     device_model_id=self.device_model_id,
                 ),
                 text_query=text_query,
             )
+            # Continue current conversation with later requests.
+            self.is_new_conversation = False
             if self.display:
                 config.screen_out_config.screen_mode = PLAYING
             req = embedded_assistant_pb2.AssistRequest(config=config)