VenomousSteam81/python-talk
1
0
Fork 0
forked from Firepup650/python-talk
Code Pull requests Activity

Multiple small mistakes

Browse source
This commit is contained in:
Firepup Sixfifty 2024-07-16 19:24:17 +00:00
parent d5a01a9ee1
commit ef30250f30
Signed by: Firepup650
SSH key fingerprint: SHA256:U0Zp8EhEe3CMqFSrC79CqatzaEiL4sjta80/RSX2XrY
1 changed files with 13 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
server.py
View file

@ -238,7 +238,6 @@ Please note that this is not network level statistics.\n""".encode(
await writer.drain() await writer.drain()
G.msgs.append(log(f"{client} has connected from {sName}")) G.msgs.append(log(f"{client} has connected from {sName}"))
G.servers[sName][client.lower()] = False G.servers[sName][client.lower()] = False
G.clientsConnected[client.lower()] = sName
G.S2SLogs.append(("+", client, sName)) G.S2SLogs.append(("+", client, sName))
writer.write(f"{G.remoteID}\n".encode("utf8")) writer.write(f"{G.remoteID}\n".encode("utf8"))
await writer.drain() await writer.drain()
@ -251,9 +250,11 @@ Please note that this is not network level statistics.\n""".encode(
if G.clientsConnected[client] == G.remoteID: if G.clientsConnected[client] == G.remoteID:
G.killList[client] = True G.killList[client] = True
else: else:
G.servers[G.clientsConnected[client]] = True G.servers[G.clientsConnected[client]][client] = True
writer.write(f"END OF CLIENT LISTING FROM {G.remoteID}\n".encode("utf8")) writer.write(f"END OF CLIENT LISTING FROM {G.remoteID}\n".encode("utf8"))
await writer.drain() await writer.drain()
for client in G.servers[sName]:
G.clientsConnected[client] = sName
msgInd = len(G.S2SLogs) msgInd = len(G.S2SLogs)
while 1: while 1:
try: try:
@ -279,7 +280,7 @@ Please note that this is not network level statistics.\n""".encode(
writer.write(f"K {cName}\n".encode("utf8")) writer.write(f"K {cName}\n".encode("utf8"))
case "-": case "-":
cName = buffer[2:] cName = buffer[2:]
if G.clientsConnected.get(cName, None) == sName: if G.clientsConnected.get(cName.lower(), None) == sName:
G.msgs.append( G.msgs.append(
log(f"{cName} has disconnected from {sName}") log(f"{cName} has disconnected from {sName}")
) )
@ -289,7 +290,7 @@ Please note that this is not network level statistics.\n""".encode(
writer.write(b"I Mmm... Bananas\n") writer.write(b"I Mmm... Bananas\n")
else: else:
writer.write( writer.write(
f"Your server is LYING about who is connected to it. - {G.remoteID}, a fellow server\n".encode( f"S Your server is LYING about who is connected to it. - {G.remoteID}, a fellow server\n".encode(
"utf8" "utf8"
) )
) )
@ -324,6 +325,10 @@ Please note that this is not network level statistics.\n""".encode(
"utf8" "utf8"
) )
) )
log(
f"Recieved invalid message ({buffer}) from {sName}",
"WARN",
)
await writer.drain() await writer.drain()
except TimeoutError: except TimeoutError:
pass pass
@ -398,7 +403,7 @@ async def connectServer(hostname: str, port: int):
if G.clientsConnected[client] == G.remoteID: if G.clientsConnected[client] == G.remoteID:
G.killList[client] = True G.killList[client] = True
else: else:
G.servers[G.clientsConnected[client]] = True G.servers[G.clientsConnected[client]][client] = True
writer.write(f"END OF CLIENT LISTING FROM {G.remoteID}\n".encode("utf8")) writer.write(f"END OF CLIENT LISTING FROM {G.remoteID}\n".encode("utf8"))
await writer.drain() await writer.drain()
rID = raw((await reader.read(16)).decode("utf8")) rID = raw((await reader.read(16)).decode("utf8"))
@ -457,14 +462,14 @@ async def connectServer(hostname: str, port: int):
writer.write(f"K {cName}\n".encode("utf8")) writer.write(f"K {cName}\n".encode("utf8"))
case "-": case "-":
cName = buffer[2:] cName = buffer[2:]
if G.clientsConnected.get(cName, None) == rID: if G.clientsConnected.get(cName.lower(), None) == rID:
G.msgs.append(log(f"{cName} has disconnected from {rID}")) G.msgs.append(log(f"{cName} has disconnected from {rID}"))
del G.servers[rID][cName.lower()] del G.servers[rID][cName.lower()]
del G.clientsConnected[cName.lower()] del G.clientsConnected[cName.lower()]
G.S2SLogs.append(("-", cName, rID)) G.S2SLogs.append(("-", cName, rID))
else: else:
writer.write( writer.write(
f"Your server is LYING about who is connected to it. - {G.remoteID}, a fellow server\n".encode( f"S Your server is LYING about who is connected to it. - {G.remoteID}, a fellow server\n".encode(
"utf8" "utf8"
) )
) )
@ -499,6 +504,7 @@ async def connectServer(hostname: str, port: int):
"utf8" "utf8"
) )
) )
log(f"Recieved invalid message ({buffer}) from {sName}", "WARN")
await writer.drain() await writer.drain()
except TimeoutError: except TimeoutError:
pass pass