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
|
import os
import time
from . import acmespb
from flask import Flask, render_template
from flask_socketio import SocketIO, emit
socketio = SocketIO()
def create_app(test_config=None):
app = Flask(__name__, instance_relative_config=True)
app.config.from_mapping(
SECRET_KEY='dev',
DATABASE=os.path.join(app.instance_path, 'app.sqlite'),
)
if test_config is None:
# load the instance config, if it exists, when not testing
app.config.from_pyfile('config.py', silent=True)
else:
# load the test config if passed in
app.config.from_mapping(test_config)
# ensure the instance folder exists
try:
os.makedirs(app.instance_path)
except OSError:
pass
socketio.init_app(app)
@app.route('/')
def hello():
return render_template('index.html')
@socketio.on('get_hints')
def handle_get_hints_event(q):
print('[get_hints] id=%d, query=%s' % (q['id'], q['query']))
if len(q['query']) < 3:
response = {
'id': q['id'],
'error': "query is too short"
}
emit('hints', response)
return
results = acmespb.search(q['query'])
response = {
'id': q['id'],
'response': results
}
emit('hints', response)
@socketio.on('get_offers')
def handle_get_offers_event(q):
print('[get_offers] id=%d, query=%s' % (q['id'], q['query']))
target_url, trade_names = acmespb.trade_names(q['query'])
if trade_names:
response = {
'id': q['id'],
"response": trade_names
}
emit('hints', response)
return
page = 1
pages = 0
target_url = None
while pages == 0 or page <= pages:
target_url, pages, offers = acmespb.offers(q['query'], page=page, target_url=target_url)
print("[%d] pages=%d, target_url=%s" % (page, pages, target_url))
response = {
'id': q['id'],
'offers': [offer.as_dict() for offer in offers],
'page': page,
'pages': pages
}
emit('offers', response)
time.sleep(0.5)
page += 1
response = {
'id': q['id'],
'end': True
}
emit('offers', response)
# TODO empty response
return app
|
