-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathserver.py
178 lines (149 loc) · 6.96 KB
/
server.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
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
import argparse,random,os,time,cherrypy,threading,redis,requests,urllib2,json
from datetime import datetime
from pytz import timezone
#from bs4 import BeautifulSoup
from threading import Thread
from ws4py.server.cherrypyserver import WebSocketPlugin, WebSocketTool
from ws4py.websocket import WebSocket
from ws4py.messaging import TextMessage
#Stock parser
#Move to separate folder
###############################################################################
class StockParser:
def __init__(self,url):
self.hdr = {'User-Agent': 'Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.11 (KHTML, like Gecko) Chrome/23.0.1271.64 Safari/537.11',
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8',
'Accept-Charset': 'ISO-8859-1,utf-8;q=0.7,*;q=0.3',
'Accept-Encoding': 'none',
'Accept-Language': 'en-US,en;q=0.8',
'Connection': 'keep-alive'}
self.url = url
def getResults(self):
req = urllib2.Request(self.url,headers=self.hdr)
opener = urllib2.build_opener()
f = opener.open(req)
jsonData = json.loads(f.read())
return jsonData
###############################################################################
class RedisResultSender(Thread):
def __init__(self,threadName):
Thread.__init__(self)
self.DB = redis.StrictRedis(host='localhost', port=6379, db=0)
self.name = threadName
self.count = 0
url = "https://www.nseindia.com/live_market/dynaContent/live_analysis/gainers/niftyGainers1.json"
self.StockParser = StockParser(url)
#cherrypy.engine.publish('websocket-broadcast', "Thread instance created init method")
def run(self):
cherrypy.log("Thread started")
#cherrypy.engine.publish('websocket-broadcast', "Thread run method")
while True:
if (self.DB.get('newData') == '1'):
results = self.StockParser.getResults()
latestData = json.dumps(results)
self.DB.set('nifty50',latestData)
self.DB.set('newData','0')
cherrypy.engine.publish('websocket-broadcast', json.dumps(results))
# CHECK WHETHER IT IS BETWEEN MONDAY TO FRIDAY
#SLEEP TIME CODE CHECK
# lastResultTime = results['time']
# cherrypy.log('Last result time '+ lastResultTime)
# LastHours=latestData[13]+latestData[14]
# LastMinutes=latestData[16]+latestData[17]
# LastSeconds=latestData[19]+latestData[20]
# console.log("Last hours "+ LastHours + "Last minutes "+ LastMinutes + " Last seconds "+ LastSeconds)
# india = timezone('Asia/Kolkata')
# currentTime = datetime.now(india).strftime('%H-%M-%S')
# SLEEP FOR SAT AND SUNDAY MINUTES
# pause for 2 and half minutes to update new data
self.DB.set('newData','1')
cherrypy.log('waiting')
time.sleep(130) # CALCULATE THE TIME
cherrypy.log('wait over, new request')
###############################################################################
class ChatWebSocketHandler(WebSocket):
def opened(self):
#ack = "you are connected"
#cherrypy.engine.publish('websocket-broadcast', ack)
pass
def received_message(self, m):
pass
#cherrypy.engine.publish('websocket-broadcast', "Thread started")
def closed(self, code, reason="A client left the room without a proper explanation."):
cherrypy.engine.publish('websocket-broadcast', "Closing the server")
cherrypy.engine.publish('websocket-broadcast', TextMessage(reason))
###############################################################################
root = os.path.dirname(os.path.abspath(__file__))
def CORS():
cherrypy.response.headers["Access-Control-Allow-Origin"] = "http://0.0.0.0:9000" #"http://127.0.0.1:9000"
###############################################################################
class WS(object):
@cherrypy.expose
def ws(self):
handler=cherrypy.request.ws_handler
# TODO: Put it in routes folder
class Static(object):
@cherrypy.expose
def index(self):
pass
class Api(object):
@cherrypy.expose
def get_latest_data(self):
cherrypy.log("Requested")
DB = redis.StrictRedis(host='localhost', port=6379, db=0)
results = DB.get('nifty50')
return results
###############################################################################
###############################################################################
# TODO : Add in config file and import from there
wsConfig = {
'/ws': {
'tools.websocket.on': True,
'tools.websocket.handler_cls': ChatWebSocketHandler,
'tools.log_headers.on': False,
'tools.log_tracebacks.on': False
}
}
apiConfig = {
'/get_latest_results': {
'tools.CORS.on': True
}
}
# TODO : Add in config file and import from there
staticConfig = {
'/' : {
'tools.staticdir.on': True,
'tools.staticdir.dir': root + '/public/',
'tools.staticdir.index': root + '/public/index.html',
'tools.log_headers.on': False,
'tools.log_tracebacks.on':False,
'tools.CORS.on': True
}
}
###############################################################################
###############################################################################
#for CORS requests
cherrypy.tools.CORS = cherrypy.Tool('before_handler', CORS)
#Mounting static files directories
cherrypy.tree.mount(Static(),"/",staticConfig)
#Mounting the WebSocket Class with reqd conf
cherrypy.tree.mount(WS(),"/sock",wsConfig)
#Mount the api
cherrypy.tree.mount(Api(),"/api",apiConfig)
###############################################################################
###############################################################################
WebSocketPlugin(cherrypy.engine).subscribe()
cherrypy.tools.websocket = WebSocketTool()
cherrypy.config.update({ 'server.socket_host': "0.0.0.0",
'server.socket_port':9000})
###############################################################################
count = 1
###############################################################################
#Starting cherrypy server
cherrypy.engine.start()
###############################################################################
# Start redis thread
redisThread = RedisResultSender(count)
redisThread.start()
###############################################################################
cherrypy.engine.block()