Upload 2 files

Updated algorithmics - candidate

WarClient.py

@@ -11,14 +11,18 @@ def getReply(message):
         message = message.rstrip(".")
 
     with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as client_socket:
-        client_socket.connect((HOST, PORT))
-        client_socket.sendall(message.encode())
-        print('Wait...')
-        data = client_socket.recv(1024)
         try:
-            return data.decode('utf-8')
-        except: #sometimes there is a problem with the decoding
-            print('decoding error, please try again')
-        finally:
-            client_socket.shutdown(socket.SHUT_RDWR)
-            client_socket.close()
+            client_socket.connect((HOST, PORT))
+            client_socket.sendall(message.encode())
+            print('Wait...')
+            data = client_socket.recv(1024)
+            try:
+                return data.decode('utf-8')
+            except: #sometimes there is a problem with the decoding
+                print('Decoding Error')
+                return ""
+            finally:
+                client_socket.shutdown(socket.SHUT_RDWR)
+                client_socket.close()
+        except:
+            return ""

WarOnline_Chat_test.py

@@ -26,11 +26,15 @@ password = 'naP2tion'
 # Start a session to persist the login cookie across requests
 session = requests.Session()
 
-
 def compare_pages(url1, url2):
     #Compares 2 pages and returns True if they are the same
     return urllib.urlopen(url1).geturl() == urllib.urlopen(url2).geturl()
 
+def remove_non_english_russian_chars(s):
+    # Regular expression to match all characters that are not in English or Russian
+    pattern = '[^0-9A-Za-zА-Яа-яЁё(),.:!;"\s-]'
+    # Replace all matched characters with an empty string
+    return re.sub(pattern, '', s)
 def login(username=username, password=password, thread_url=thread_url):
     # Log-In to the forum and redirect to thread
 
@@ -72,6 +76,7 @@ def post(message=message, thread_url=thread_url, post_url=post_url, quoted_by=""
 
     # Extract the _xfToken value from the hidden form field
     xf_token = soup.find('input', {'name': '_xfToken'}).get('value')
+    print(xf_token)
 
     # Construct the message data for the POST request
     message_data = {
@@ -170,49 +175,71 @@ def getMessages(thread_url=thread_url, quotedUser="", startingPage=1):
             lastPage = True
 
     return allquotes
+
+# Core Engine of the Client
 def WarOnlineBot():
-    # Get All Quotes by all users
-    allMessages = getMessages(thread_url=thread_url,  startingPage=1)
-    unrepliedMessages = []
+
+    login(username=username, password=password, thread_url=thread_url)
+    #print("logged in")
+
+    # All messages (with quotes) by ALL users:
+    allMessages = getMessages(thread_url=thread_url, quotedUser='', startingPage=1)
+
+    # IDs of the quoted messages, for messages posted by bot:
+    messages_by_bot_IDs = []
+
     for msg in allMessages:
-        if msg['messageID'].strip('-')[-1] != msg['quotedID'].strip(': ')[-1]:
-            unrepliedMessages.append(msg)
+        # Set a list of replied IDs
+        if msg['messengerName'] == username:
+            messages_by_bot_IDs.append(msg['quotedID'].split(': ')[-1])
+    # remove empty elements
+    messages_by_bot_IDs = [elem for elem in messages_by_bot_IDs if elem]
+
+    # All messages (with quotes) sent _FOR_ the Bot:
+    messagesForBot = getMessages(thread_url=thread_url, quotedUser=username, startingPage=1)
+
+    # IDs of the messages, quoting the bot:
+    messages_for_bot_IDs = []
+
+    for msg in messagesForBot:
+        # Set a list of posted message IDs
+        messages_for_bot_IDs.append(msg['messageID'].split('-')[-1])
+    # remove empty elements
+    messages_for_bot_IDs = [elem for elem in messages_for_bot_IDs if elem]
+
+    # Filter the unanswered messages
+    for msgID in messages_for_bot_IDs:
+        if msgID in messages_by_bot_IDs:
+            messages_for_bot_IDs.remove(msgID)
 
-    for quote in quotes:
-        pass
+    # print unanswered messages
+    for msg in messagesForBot:
+        if msg['messageID'].split('-')[-1] in messages_for_bot_IDs:
+
+            quote = remove_non_english_russian_chars(msg['reply'])
+            message = ""
 
-        message = ""
-        if not replies: # Meaning that there are no answers
             while not message:
-                message = WarClient.getReply(message=quote['reply'])
-            print('Quote: ', quote['reply'])
-            print('Reply: ',message)
-           # post(message=message, thread_url=thread_url, post_url=post_url, quoted_by=quote['messengerName'],
-           #      quote_text=quote['reply'], quote_source = quote['messageID'].split(":")[-1].strip())
-            print('posted the message to the forum')
-            time.sleep(5) # Standby time for server load release
+                message = WarClient.getReply(message=quote)
+
+            print('Quote: ', quote)
+            print('Reply: ', message)
+
+            login(username=username, password=password, thread_url=thread_url)
+            time.sleep(1)
+            #post(message=message, thread_url=thread_url, post_url=post_url, quoted_by=msg['messengerName'], quote_text=quote, quote_source=msg['messageID'])
+
+            time.sleep(200)  # Standby time for server load release
 
 if __name__ == '__main__':
     timeout = 2 # min
 
-    login(username=username, password=password, thread_url=thread_url)
-    print("logged in")
-
-    ### Disabled ###
-    #post(message=message, thread_url=thread_url, post_url=post_url, quoted_by='Василий Пупкин', quote_text='quoted message', quote_source='3926006')
+    WarOnlineBot()
 
-    #messagedByBot = getMessages(thread_url=thread_url, quotedUser='WarBot', startingPage=1)
-    allMessages = getMessages(thread_url=thread_url, quotedUser='', startingPage=1)
-    repliedMessagesIDs = []
+    #login(username=username, password=password, thread_url=thread_url)
+    #post(message=message, thread_url=thread_url, post_url=post_url, quoted_by='WarBot', quote_text='quoted message', quote_source='12345')
 
-    for msg in allMessages:
-        # Set a list of replied IDs
-        repliedMessagesIDs.append(msg['quotedID'].split(': ')[-1])
-        print(msg)
-    # remove empty elements
-    repliedMessagesIDs = [elem for elem in repliedMessagesIDs if elem]
 
-    print(repliedMessagesIDs)
     """
     # Start the scheduler
     while True: