swee/IRCat
swee/IRCat
1
0
Fork 0
Code Issues Pull requests Activity

Update server.py
All checks were successful
Check syntax / check (push) Successful in 26s

Browse source
This commit is contained in:
Nova Cat 2024-12-27 20:10:42 -08:00
parent e40a59cc56
commit fb511d28f8
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
server.py
View file

@ -97,7 +97,7 @@ def pinger(nick, connection):
connection.shutdown(socket.SHUT_WR) connection.shutdown(socket.SHUT_WR)
connection.close() connection.close()
break break
def session(connection, client): def session(connection, client, ip_to):
global property_list global property_list
pending = "*" # The nickname of the client pending = "*" # The nickname of the client
already_set = False # If the client gave the server a NICK packet already_set = False # If the client gave the server a NICK packet
@ -198,6 +198,8 @@ def session(connection, client):
channels = text.split(" ")[1] channels = text.split(" ")[1]
for channelt in channels.split(","): for channelt in channels.split(","):
channel = channelt.strip() channel = channelt.strip()
if channel.lower() in lower_chans:
channel = lower_chans[channel.lower()]
success = True success = True
if channel in channels_list: if channel in channels_list:
if pending in channels_list[channel]: if pending in channels_list[channel]:
@ -209,6 +211,7 @@ def session(connection, client):
channels_list[channel].append(pending) channels_list[channel].append(pending)
else: else:
channels_list[channel] = [pending] channels_list[channel] = [pending]
lower_chans[channel.lower()] = channel
except: except:
connection.sendall(bytes(f":{server} NOTICE * :*** Could not join {channel}\r\n","UTF-8")) connection.sendall(bytes(f":{server} NOTICE * :*** Could not join {channel}\r\n","UTF-8"))
print(channels_list) print(channels_list)
@ -565,7 +568,8 @@ try:
while opened: while opened:
print("Waiting for connection...") print("Waiting for connection...")
connection, client = tcp_socket.accept() connection, client = tcp_socket.accept()
threading.Thread(target=session, daemon=True, args=[connection, client]).start() ip_to = restrict_ip
threading.Thread(target=session, daemon=True, args=[connection, client, ip_to]).start()
except: except:
print("Shutting down...") print("Shutting down...")
time.sleep(2) time.sleep(2)