refactor listen
This commit is contained in:
		| @@ -12,10 +12,10 @@ from sanic.response import json, text | |||||||
| from sanic_prometheus import monitor | from sanic_prometheus import monitor | ||||||
|  |  | ||||||
| import kube | import kube | ||||||
| import slack | from slack import slack_app | ||||||
|  |  | ||||||
| app = Sanic(__name__) | app = Sanic(__name__) | ||||||
| slack.add_routes(app) | app.register_blueprint(slack_app) | ||||||
| monitor(app).expose_endpoint() | monitor(app).expose_endpoint() | ||||||
|  |  | ||||||
| # API key for godoor controllers authenticating to k-space:floor | # API key for godoor controllers authenticating to k-space:floor | ||||||
|   | |||||||
| @@ -3,15 +3,13 @@ import os | |||||||
| import requests | import requests | ||||||
| from pymongo.errors import PyMongoError | from pymongo.errors import PyMongoError | ||||||
| from requests.exceptions import RequestException | from requests.exceptions import RequestException | ||||||
|  | from sanic import Blueprint | ||||||
|  |  | ||||||
|  | slack_app = Blueprint("slack", __name__) | ||||||
|  |  | ||||||
| # webhook logs to private channel or "DEV" to print to console. | # webhook logs to private channel or "DEV" to print to console. | ||||||
| SLACK_DOORLOG_CALLBACK = os.environ["SLACK_DOORLOG_CALLBACK"] | SLACK_DOORLOG_CALLBACK = os.environ["SLACK_DOORLOG_CALLBACK"] | ||||||
|  |  | ||||||
|  |  | ||||||
| def add_routes(app): |  | ||||||
|     app.register_listener(slack_log, "after_server_start") |  | ||||||
|  |  | ||||||
|  |  | ||||||
| def slack_post(msg): | def slack_post(msg): | ||||||
|     if SLACK_DOORLOG_CALLBACK == "DEV": |     if SLACK_DOORLOG_CALLBACK == "DEV": | ||||||
|         print(f"[DEV SLACK]: {msg}") |         print(f"[DEV SLACK]: {msg}") | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user