2ccab0d625
* fix: checkpoint the supported schemes for connectivity This PR implements a gateway + error that clearly hints the operator at a misconfigured system during runtime. Particularity, against the multiple library-provided ways of configuring redis connection strings (in python), this hard stops if an unsupported one is chosen by accident. * fix: remove unknown protocol --------- Co-authored-by: Ankush Menat <ankushmenat@gmail.com>
50 lines
1.2 KiB
Python
50 lines
1.2 KiB
Python
import socket
|
|
from urllib.parse import urlparse
|
|
|
|
from frappe import get_conf
|
|
from frappe.exceptions import UrlSchemeNotSupported
|
|
|
|
REDIS_KEYS = ("redis_cache", "redis_queue")
|
|
|
|
|
|
def is_open(scheme, hostname, port, timeout=10):
|
|
if scheme in ["redis", "postgres", "mariadb"]:
|
|
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
conn = (hostname, port)
|
|
else:
|
|
raise UrlSchemeNotSupported(scheme)
|
|
|
|
s.settimeout(timeout)
|
|
try:
|
|
s.connect(conn)
|
|
s.shutdown(socket.SHUT_RDWR)
|
|
return True
|
|
except OSError:
|
|
return False
|
|
finally:
|
|
s.close()
|
|
|
|
|
|
def check_database():
|
|
config = get_conf()
|
|
db_type = config.get("db_type", "mariadb")
|
|
db_host = config.get("db_host", "localhost")
|
|
db_port = config.get("db_port", 3306 if db_type == "mariadb" else 5432)
|
|
return {db_type: is_open(db_type, db_host, db_port)}
|
|
|
|
|
|
def check_redis(redis_services=None):
|
|
config = get_conf()
|
|
services = redis_services or REDIS_KEYS
|
|
status = {}
|
|
for srv in services:
|
|
url = urlparse(config[srv])
|
|
status[srv] = is_open(url.scheme, url.hostname, url.port)
|
|
return status
|
|
|
|
|
|
def check_connection(redis_services=None):
|
|
service_status = {}
|
|
service_status.update(check_database())
|
|
service_status.update(check_redis(redis_services))
|
|
return service_status
|