[falcon.py] continue_falcon safetychecks added (they are necessary)

falcon.py

@@ -74,30 +74,36 @@ async def try_falcon(interaction, prompt):
         #await thread.send(f"{e} cc <@811235357663297546> (falconprivate error)") 
 #------------------------------------------------------------------------------------------------------------------------------------- 
 async def continue_falcon(message):
-    try:
-        global instructions
-        global threadid_conversation
-        await message.add_reaction('🔁') 
-        chathistory = threadid_conversation[message.channel.id]
-        prompt = message.content
-        # generation
-        job = falconclient.submit(prompt, chathistory, instructions, 0.8, 0.9, fn_index=1)  # This is not blocking, similar to run_in_executor (but better)
-        while job.done() == False: 
-            status = job.status() 
-            #print(status)
-        else:
-            file_paths = job.outputs()
-            full_generation = file_paths[-1] # tmp12345678.json
-        with open(full_generation, 'r') as file:
-            data = json.load(file)
-            output_text = data[-1][-1] # we output this as the bot
-
-        threadid_conversation[message.channel.id] = full_generation # overwrite the old file
-        falcon_userid_threadid_dictionary[message.channel.id] = message.author.id
-        
-        print(output_text)
-        await message.reply(f"{output_text}")  
-        await message.remove_reaction('🔁', client.user) # test=🔁  hf=🔁  
+    try
+        if not message.author.bot:
+            global falcon_userid_threadid_dictionary # tracks userid-thread existence
+            if message.channel.id in falcon_userid_threadid_dictionary: # is this a valid thread?
+                 if falcon_userid_threadid_dictionary[message.channel.id] == message.author.id: # more than that - is this specifically the right user for this thread?
+                    # call job for falcon 
+                    global instructions
+                    global threadid_conversation
+                     
+                    await message.add_reaction('🔁') 
+                    chathistory = threadid_conversation[message.channel.id]
+                    prompt = message.content
+                    # generation
+                    job = falconclient.submit(prompt, chathistory, instructions, 0.8, 0.9, fn_index=1)  # This is not blocking, similar to run_in_executor (but better)
+                    while job.done() == False: 
+                        status = job.status() 
+                        #print(status)
+                    else:
+                        file_paths = job.outputs()
+                        full_generation = file_paths[-1] # tmp12345678.json
+                    with open(full_generation, 'r') as file:
+                        data = json.load(file)
+                        output_text = data[-1][-1] # we output this as the bot
+            
+                    threadid_conversation[message.channel.id] = full_generation # overwrite the old file
+                    falcon_userid_threadid_dictionary[message.channel.id] = message.author.id
+            
+            print(output_text)
+            await message.reply(f"{output_text}")  
+            await message.remove_reaction('🔁', client.user) # test=🔁  hf=🔁  
 
     except Exception as e:
         print(f"Error: {e}")