Add a method named full_messages_for_ask to ChatAIStream.

Author: GeneralYadoc

README.md

@@ -170,6 +170,9 @@ Message broker between YouTube chat stream and ChatGPT.
 - Internal process will be terminated soon after.
 - No arguments required, nothing returns.
 
+### full_messages_for_ask()
+- Indicate whether the queue which spools messages to send ChatAI is full or not.
+
 And other [threading.Thread](https://docs.python.org/3/library/threading.html) public pethods are available.
 
 ## Callbacks

requirements.txt

@@ -1,2 +1,2 @@
-streamchat-agent==1.0.1
-chatai-agent==1.0.0
+streamchat-agent==1.0.2
+chatai-agent==1.1.0

setup.py

@@ -12,7 +12,7 @@ def _requires_from_file(filename):
 
 setup(
     name="chatai-stream",
-    version="0.0.3",
+    version="1.0.0",
     license="MIT",
     description="ChatGPT reacts YouTube chat messages.",
     author="General Yadoc",

src/ChatAIStream.py

@@ -15,31 +15,34 @@ class params():
   ai_params: aiParams
 
 class ChatAIStream(threading.Thread):
-  def my_pre_filter_cb(self, c):
+  def __my_pre_filter_cb(self, c):
     prefiltered_c = c
     if prefiltered_c and self.pre_filter_cb:
       prefiltered_c = self.pre_filter_cb(prefiltered_c)
     prefiltered_c.message = re.sub(r':[^:]+:', ".", prefiltered_c.message)
     prefiltered_c.message = re.sub(r'^[\.]+', "", prefiltered_c.message)
     return None if prefiltered_c.message == "" else prefiltered_c
 
-  def ask_stream_message_to_ai(self, c):
+  def __ask_stream_message_to_ai(self, c):
     if self.get_stream_message_cb:
       self.get_stream_message_cb(c)
     if self.ai_agent:
       self.ai_agent.put_message(ca.userMessage(message=c.message, extern=c))
 
   def __init__( self, params):
     self.get_stream_message_cb=params.stream_params.get_item_cb
-    params.stream_params.get_item_cb=self.ask_stream_message_to_ai
+    params.stream_params.get_item_cb=self.__ask_stream_message_to_ai
     self.pre_filter_cb=params.stream_params.pre_filter_cb
-    params.stream_params.pre_filter_cb=self.my_pre_filter_cb
+    params.stream_params.pre_filter_cb=self.__my_pre_filter_cb
 
     self.ai_agent = ca.ChatAIAgent( params.ai_params )
     self.stream_agent = sca.StreamChatAgent( params.stream_params )
 
     super(ChatAIStream, self).__init__(daemon=True)
 
+  def full_messages_for_ask(self):
+    return self.ai_agent.full_messages()
+
   def run(self):
     self.stream_agent.start()
     self.ai_agent.start()

src/__init__.py

@@ -1,3 +1,3 @@
 from .ChatAIStream import *
 
-__version__ = '0.0.3'
+__version__ = '1.0.0'