-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathircserv2.2.py
115 lines (92 loc) · 2.74 KB
/
ircserv2.2.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
import threading
import socket
import os
import time
import sys
log=''
users={}
names={'server':'god'}#both dicctionary have address as key,as each will have different address
class nclient:
def __init__(self,csock,cad,cname):
self.sock=csock
self.ad=cad
self.name=cname
global users,names
users[cad]=csock
names[cad]=cname
data=cname+":Connected!"
print(data)
self.sendll(data)
data=cad[0]
csock.send(data.encode())
data=str(names)
csock.send(data.encode())
self.sendll(data)
self.rthread=threading.Thread(target=self.recieve)
self.rthread.start()
def recieve(self):
global users,log
while True:
try:
data=self.sock.recv(1024).decode()
except:
data=self.name+":Disconnected!"
self.sock.close()
print(data)
self.sendll(data)
del users[self.ad]
del names[self.ad]
break
index=0
if data=='123abc':
self.sendll(data)
data=self.sock.recv(512).decode()
for d in data:
if d=='>':
break
index=index+1
try:
tempdata=data[index+1:]
if tempdata[:13]=='changed name:':
#data=self.name+" changed name to:"+tempdata[13:]
self.name=tempdata[13:]
names[self.ad]=self.name
except:
pass
data=data
print(data)
self.sendll(data)
def sendll(self,data):
global users,log
log=log+'\n'+data
for nad,cs in users.items():
if nad==self.ad:
continue
cs.send(data.encode())
open('server_log.dat','w').write(log)
def createconn(c,addr,nam):
clt=nclient(c,addr,nam)
def nserver():
s=socket.socket()
k=input("Listen on ip?\n1.localhost\n2."+socket.gethostname()+"\n")
if k=='1':
adr='127.0.0.1'
print("Listening on ",adr)
else:
if k=='2':
adr=socket.gethostname()
print("Listening on ",adr)
else :
print("Invalid Choice! Listening on localhost!")
adr='127.0.0.1'
port=5000
s.bind((adr,port))
s.listen(5)
while True:
c,addr=s.accept()
na=c.recv(512).decode()
print("connected to",addr)
createconn(c,addr,na)
sevrth=threading.Thread(target=nserver)
sevrth.start()
sevrth.join()