chore: auto-gen by protobufs

triggered by commit: instill-ai/protobufs@56f6036

Author: droplet-bot

app/app/v1alpha/app_public_service_pb2.py

@@ -102,6 +102,11 @@ def __init__(self, channel):
                 request_serializer=app_dot_app_dot_v1alpha_dot_app__pb2.RestartPlaygroundConversationRequest.SerializeToString,
                 response_deserializer=app_dot_app_dot_v1alpha_dot_app__pb2.RestartPlaygroundConversationResponse.FromString,
                 )
+        self.Chat = channel.unary_stream(
+                '/app.app.v1alpha.AppPublicService/Chat',
+                request_serializer=app_dot_app_dot_v1alpha_dot_conversation__pb2.ChatRequest.SerializeToString,
+                response_deserializer=app_dot_app_dot_v1alpha_dot_conversation__pb2.ChatResponse.FromString,
+                )
 
 
 class AppPublicServiceServicer(object):
@@ -237,6 +242,17 @@ def RestartPlaygroundConversation(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def Chat(self, request, context):
+        """Chat
+
+        Chat sends a message asynchronously and streams back the response.
+        This method is intended for real-time conversation with a chatbot
+        and the response needs to be processed incrementally.
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
 
 def add_AppPublicServiceServicer_to_server(servicer, server):
     rpc_method_handlers = {
@@ -325,6 +341,11 @@ def add_AppPublicServiceServicer_to_server(servicer, server):
                     request_deserializer=app_dot_app_dot_v1alpha_dot_app__pb2.RestartPlaygroundConversationRequest.FromString,
                     response_serializer=app_dot_app_dot_v1alpha_dot_app__pb2.RestartPlaygroundConversationResponse.SerializeToString,
             ),
+            'Chat': grpc.unary_stream_rpc_method_handler(
+                    servicer.Chat,
+                    request_deserializer=app_dot_app_dot_v1alpha_dot_conversation__pb2.ChatRequest.FromString,
+                    response_serializer=app_dot_app_dot_v1alpha_dot_conversation__pb2.ChatResponse.SerializeToString,
+            ),
     }
     generic_handler = grpc.method_handlers_generic_handler(
             'app.app.v1alpha.AppPublicService', rpc_method_handlers)
@@ -625,3 +646,20 @@ def RestartPlaygroundConversation(request,
             app_dot_app_dot_v1alpha_dot_app__pb2.RestartPlaygroundConversationResponse.FromString,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
+    @staticmethod
+    def Chat(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_stream(request, target, '/app.app.v1alpha.AppPublicService/Chat',
+            app_dot_app_dot_v1alpha_dot_conversation__pb2.ChatRequest.SerializeToString,
+            app_dot_app_dot_v1alpha_dot_conversation__pb2.ChatResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

app/app/v1alpha/app_public_service_pb2_grpc.py

@@ -122,6 +122,16 @@ class AppPublicServiceStub:
     create a new conversation and use the auth user uid as creator uid and auto
     generate a new conversation id on the behalf of auth user.
     """
+    Chat: grpc.UnaryStreamMultiCallable[
+        app.app.v1alpha.conversation_pb2.ChatRequest,
+        app.app.v1alpha.conversation_pb2.ChatResponse,
+    ]
+    """Chat
+
+    Chat sends a message asynchronously and streams back the response.
+    This method is intended for real-time conversation with a chatbot
+    and the response needs to be processed incrementally.
+    """
 
 class AppPublicServiceAsyncStub:
     """AppPublicService exposes the public endpoints that allow clients to
@@ -226,6 +236,16 @@ class AppPublicServiceAsyncStub:
     create a new conversation and use the auth user uid as creator uid and auto
     generate a new conversation id on the behalf of auth user.
     """
+    Chat: grpc.aio.UnaryStreamMultiCallable[
+        app.app.v1alpha.conversation_pb2.ChatRequest,
+        app.app.v1alpha.conversation_pb2.ChatResponse,
+    ]
+    """Chat
+
+    Chat sends a message asynchronously and streams back the response.
+    This method is intended for real-time conversation with a chatbot
+    and the response needs to be processed incrementally.
+    """
 
 class AppPublicServiceServicer(metaclass=abc.ABCMeta):
     """AppPublicService exposes the public endpoints that allow clients to
@@ -364,5 +384,17 @@ class AppPublicServiceServicer(metaclass=abc.ABCMeta):
         create a new conversation and use the auth user uid as creator uid and auto
         generate a new conversation id on the behalf of auth user.
         """
+    @abc.abstractmethod
+    def Chat(
+        self,
+        request: app.app.v1alpha.conversation_pb2.ChatRequest,
+        context: _ServicerContext,
+    ) -> typing.Union[collections.abc.Iterator[app.app.v1alpha.conversation_pb2.ChatResponse], collections.abc.AsyncIterator[app.app.v1alpha.conversation_pb2.ChatResponse]]:
+        """Chat
+
+        Chat sends a message asynchronously and streams back the response.
+        This method is intended for real-time conversation with a chatbot
+        and the response needs to be processed incrementally.
+        """
 
 def add_AppPublicServiceServicer_to_server(servicer: AppPublicServiceServicer, server: typing.Union[grpc.Server, grpc.aio.Server]) -> None: ...