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
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
|
#!/usr/bin/python3
## Global Modules
import threading, time, json, syslog
LOG_AUTH=syslog.LOG_AUTH
## Semi-local modules
from websock import WebSocketServer, WebSocket
## Local Modules
from utils import stdout, now, clients, debug
from consts import MAX_CLIENTS, PACKET_ACK
import protocol, security, traceback
###############################################################
# Configuration
f=open("pass.json", "r")
p=json.load(f)
f.close()
PORT=p["PORT"]
SECURE=p["SSL"]
###############################################################
# Main Class
class WebSocketConn(WebSocket):
def handle(self):
global clients
"""
Called when websocket frame is received.
To access the frame data call self.data.
i.e. The client sent us a message \o/
If the frame is Text then self.data is a unicode object.
If the frame is Binary then self.data is a bytearray object.
"""
print("Message received from %s - %s" % (self.address[0], self.data))
try:
r=protocol.parse(self.data, self)
print("Status: %s" % str(r[0]))
print("Reply: %s" % r[1])
if r[0] < PACKET_ACK:
stdout("%s - %s" % (self.address[0], r[1]))
syslog.syslog(LOG_AUTH, "%s - %s" % (self.address[0], r[1]))
self.send_message("NACK\n")
# FIXME: Parse the packet error score
security.score(self, 5)
else:
self.send_message(r[1])
except:
traceback.print_exc()
self.send_message("ERROR\n")
print("Message sent")
#stdout(self.address[0] + u' - %s' % (self.data))
#self.send_message('ACK')
def connected(self):
global clients, blacklist
"""
Called when a websocket client connects to the server.
"""
#print(self.address, 'connected')
#for client in clients:
# print(repr(client))
# client.send_message(self.address[0] + u' - connected')
stdout(self.address[0] + u' - connected')
# Blacklisted
if (security.is_banned(self.address[0])):
stdout("Found in K-Line, connection was dropped.")
self.close(self, status=1000, reason="K-Lined")
return
# TODO: Drop OLD connections when same IP tries to connect
# TODO: Either auto-ban or limit to <= 3 connections from same IP at once
# By last, keep a "sane" amount of clients connected
# This program must not, under any circumstances, interfer
# on the operation of Moubootaur Legends, which has total priority
# over the VM resources
if (len(clients) > MAX_CLIENTS):
self.close(self, status=1000, reason='Server is full')
else:
clients.append(self)
# Extend self class
self.MS_score = 0
self.MS_auth = False
self.token = "0"
self.userid = 0
def handle_close(self):
global clients
"""
Called when a websocket server gets a Close frame from a client.
"""
clients.remove(self)
print(self.address, 'closed')
#for client in clients:
# client.send_message(self.address[0] + u' - disconnected')
stdout(self.address[0] + u' - disconnected')
# TODO: if self.token != "0": try: player.clear(self.token)
##########################
# Useful functions:
# send_message()
# send_fragment_start() / send_fragment() / send_fragment_end()
#
##########################
def MainWebsocket():
if SECURE:
server = WebSocketServer('', PORT, WebSocketConn,
certfile="certificate.pem", keyfile="key.pem")
print("Begin Secure Websocket at %d" % PORT)
else:
server = WebSocketServer('', PORT, WebSocketConn)
print("Begin UNENCRYPTED Websocket at %d" % PORT)
t = threading.Thread(target=server.serve_forever)
t.daemon = True # Main server should not be a daemon?
t.start()
return
#while True:
# time.sleep(86400)
# Broadcast function
def sendmsg(m, t="raw"):
global clients
# Format message according to type
if t == "ping":
msg="pong"
else:
msg=u"%s" % m
# Send message
for c in clients:
c.send_message(msg)
return
###############################################################
# Begin stuff
stdout("Starting at: T-%d" % (now()))
syslog.openlog()
MainWebsocket()
try:
print("Serving at port %d" % PORT)
while True:
command=str(input("> "))
# No command inserted? Do nothing
if command == "":
continue
# We have a command, prepare it for processing
stdout("CONSOLE: %s" % command)
cmd=command.split(' ')[0].lower()
com=" ".join(command.split(' ')[1:])
# Parse the command
if cmd in ["broadcast", "global", "msg", "say"]:
sendmsg("NOTICE:" + com)
elif cmd in ["ban", "block", "nuke"]:
security.ban_ip(com)
elif cmd in ["exit", "quit", "close", "term", "end"]:
stdout("Preparing to close server...")
sendmsg("NOTICE:Server is going down for scheduled maintenance. Please close, wait five minutes, and then re-open the app.")
break
elif cmd in ["dbg", "debug"]:
debug = not debug
stdout("Changed debug mode to %s" % str(debug))
elif cmd in ["raw", "eval", "exec"] and debug:
try:
print(eval(com))
except:
traceback.print_exc()
print("[RAW] Error.")
# TODO: Disconnect a client, disconnect all unauthed client,
# disconnect & ban all unauthed clients - all these are measures
# to manually fight a DoS
# Also, "permaban" an IP - open("K-Line.txt", "a")
else:
stdout("ERROR: Unknown command.")
except:
stdout("Abrupt error: Terminating!")
traceback.print_exc()
# TODO: Cleanup here
time.sleep(0.5)
for c in clients:
c.close(reason="Server is shutting down")
print("Server finished.")
|
