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
|
import re
from kombu import Connection
from pysite.constants import (
BOT_EVENT_QUEUE, BotEventTypes, CHANNEL_DEV_LOGS, DEBUG_MODE,
RMQ_HOST, RMQ_PASSWORD, RMQ_PORT, RMQ_USERNAME
)
from pysite.migrations.runner import run_migrations
from pysite.queues import QUEUES
from pysite.service_discovery import wait_for_rmq
STRIP_REGEX = re.compile(r"<[^<]+?>")
WIKI_TABLE = "wiki"
def when_ready(server=None):
_when_ready(server=server)
def _when_ready(server=None, output_func=None):
""" server hook that only runs when the gunicorn master process loads """
if server:
output = server.log.info
elif output_func:
output = output_func
else:
output = print
output("Creating tables...")
from pysite.database import RethinkDB
db = RethinkDB(loop_type=None)
db.conn = db.get_connection()
# Create any table that doesn't exist
created = db.create_tables()
if created:
tables = ", ".join([f"{table}" for table in created])
output(f"Created the following tables: {tables}")
run_migrations(db, output=output)
output("Waiting for RabbitMQ...")
has_rmq = wait_for_rmq()
if not has_rmq:
output("Timed out while waiting for RabbitMQ")
else:
output("RabbitMQ found, declaring RabbitMQ queues...")
try:
with Connection(hostname=RMQ_HOST, userid=RMQ_USERNAME, password=RMQ_PASSWORD, port=RMQ_PORT) as c:
with c.channel() as channel:
for name, queue in QUEUES.items():
queue.declare(channel=channel)
output(f"Queue declared: {name}")
if not DEBUG_MODE:
producer = c.Producer()
producer.publish(
{
"event": BotEventTypes.send_embed.value,
"data": {
"target": CHANNEL_DEV_LOGS,
"title": "Site Deployment",
"description": "The site has been deployed!"
}
},
routing_key=BOT_EVENT_QUEUE
)
except Exception as e:
output(f"Failed to declare RabbitMQ Queues: {e}")
|
