159 lines
6.9 KiB
Python
159 lines
6.9 KiB
Python
from collections import OrderedDict
|
|
|
|
|
|
class fHDHR_Cluster():
|
|
|
|
def __init__(self, fhdhr, ssdp):
|
|
self.fhdhr = fhdhr
|
|
|
|
self.ssdp = ssdp
|
|
|
|
self.friendlyname = self.fhdhr.config.dict["fhdhr"]["friendlyname"]
|
|
|
|
if self.fhdhr.config.dict["fhdhr"]["discovery_address"]:
|
|
self.startup_sync()
|
|
|
|
def cluster(self):
|
|
return self.fhdhr.db.get_fhdhr_value("cluster", "dict") or self.default_cluster()
|
|
|
|
def get_cluster_dicts_web(self):
|
|
fhdhr_list = self.cluster()
|
|
locations = []
|
|
for location in list(fhdhr_list.keys()):
|
|
item_dict = {
|
|
"base_url": fhdhr_list[location]["base_url"],
|
|
"name": fhdhr_list[location]["name"]
|
|
}
|
|
if item_dict["base_url"] != self.fhdhr.api.base:
|
|
locations.append(item_dict)
|
|
if len(locations):
|
|
locations = sorted(locations, key=lambda i: i['name'])
|
|
return locations
|
|
else:
|
|
return None
|
|
|
|
def get_list(self):
|
|
cluster = self.fhdhr.db.get_fhdhr_value("cluster", "dict") or self.default_cluster()
|
|
return_dict = {}
|
|
for location in list(cluster.keys()):
|
|
if location != self.fhdhr.api.base:
|
|
return_dict[location] = {
|
|
"Joined": True
|
|
}
|
|
|
|
detected_list = self.ssdp.detect_method.get()
|
|
for location in detected_list:
|
|
if location not in list(cluster.keys()):
|
|
return_dict[location] = {
|
|
"Joined": False
|
|
}
|
|
return_dict = OrderedDict(sorted(return_dict.items()))
|
|
return return_dict
|
|
|
|
def default_cluster(self):
|
|
defdict = {}
|
|
defdict[self.fhdhr.api.base] = {
|
|
"base_url": self.fhdhr.api.base,
|
|
"name": self.friendlyname
|
|
}
|
|
return defdict
|
|
|
|
def startup_sync(self):
|
|
self.fhdhr.logger.info("Syncronizing with Cluster.")
|
|
cluster = self.fhdhr.db.get_fhdhr_value("cluster", "dict") or self.default_cluster()
|
|
if not len(list(cluster.keys())):
|
|
self.fhdhr.logger.info("No Cluster Found.")
|
|
else:
|
|
self.fhdhr.logger.info("Found %s clustered services." % str(len(list(cluster.keys()))))
|
|
for location in list(cluster.keys()):
|
|
if location != self.fhdhr.api.base:
|
|
self.fhdhr.logger.debug("Checking Cluster Syncronization information from %s." % location)
|
|
sync_url = location + "/api/cluster?method=get"
|
|
try:
|
|
sync_open = self.fhdhr.web.session.get(sync_url)
|
|
retrieved_cluster = sync_open.json()
|
|
if self.fhdhr.api.base not in list(retrieved_cluster.keys()):
|
|
return self.leave()
|
|
except self.fhdhr.web.exceptions.ConnectionError:
|
|
self.fhdhr.logger.error("Unreachable: " + location)
|
|
|
|
def leave(self):
|
|
self.fhdhr.logger.info("Leaving cluster.")
|
|
self.fhdhr.db.set_fhdhr_value("cluster", "dict", self.default_cluster())
|
|
|
|
def disconnect(self):
|
|
cluster = self.fhdhr.db.get_fhdhr_value("cluster", "dict") or self.default_cluster()
|
|
for location in list(cluster.keys()):
|
|
if location != self.fhdhr.api.base:
|
|
self.fhdhr.logger.info("Informing %s that I am departing the Cluster." % location)
|
|
sync_url = location + "/api/cluster?method=del&location=" + self.fhdhr.api.base
|
|
try:
|
|
self.fhdhr.web.session.get(sync_url)
|
|
except self.fhdhr.web.exceptions.ConnectionError:
|
|
self.fhdhr.logger.error("Unreachable: " + location)
|
|
self.leave()
|
|
|
|
def sync(self, location):
|
|
sync_url = location + "/api/cluster?method=get"
|
|
try:
|
|
sync_open = self.fhdhr.web.session.get(sync_url)
|
|
self.fhdhr.db.set_fhdhr_value("cluster", "dict", sync_open.json())
|
|
except self.fhdhr.web.exceptions.ConnectionError:
|
|
self.fhdhr.logger.error("Unreachable: " + location)
|
|
|
|
def push_sync(self):
|
|
cluster = self.fhdhr.db.get_fhdhr_value("cluster", "dict") or self.default_cluster()
|
|
for location in list(cluster.keys()):
|
|
if location != self.fhdhr.api.base:
|
|
sync_url = location + "/api/cluster?method=sync&location=" + self.fhdhr.api.base_quoted
|
|
try:
|
|
self.fhdhr.web.session.get(sync_url)
|
|
except self.fhdhr.web.exceptions.ConnectionError:
|
|
self.fhdhr.logger.error("Unreachable: " + location)
|
|
|
|
def add(self, location):
|
|
cluster = self.fhdhr.db.get_fhdhr_value("cluster", "dict") or self.default_cluster()
|
|
if location not in list(cluster.keys()):
|
|
self.fhdhr.logger.info("Adding %s to cluster." % location)
|
|
cluster[location] = {"base_url": location}
|
|
|
|
location_info_url = "%s/hdhr/discover.json" % location
|
|
try:
|
|
location_info_req = self.fhdhr.web.session.get(location_info_url)
|
|
except self.fhdhr.web.exceptions.ConnectionError:
|
|
self.fhdhr.logger.error("Unreachable: " + location)
|
|
del cluster[location]
|
|
self.fhdhr.db.set_fhdhr_value("cluster", "dict", cluster)
|
|
return
|
|
location_info = location_info_req.json()
|
|
cluster[location]["name"] = location_info["FriendlyName"]
|
|
|
|
cluster_info_url = location + "/api/cluster?method=get"
|
|
try:
|
|
cluster_info_req = self.fhdhr.web.session.get(cluster_info_url)
|
|
except self.fhdhr.web.exceptions.ConnectionError:
|
|
self.fhdhr.logger.error("Unreachable: " + location)
|
|
del cluster[location]
|
|
self.fhdhr.db.set_fhdhr_value("cluster", "dict", cluster)
|
|
return
|
|
cluster_info = cluster_info_req.json()
|
|
for cluster_key in list(cluster_info.keys()):
|
|
if cluster_key not in list(cluster.keys()):
|
|
cluster[cluster_key] = cluster_info[cluster_key]
|
|
|
|
self.fhdhr.db.set_fhdhr_value("cluster", "dict", cluster)
|
|
self.push_sync()
|
|
|
|
def remove(self, location):
|
|
cluster = self.fhdhr.db.get_fhdhr_value("cluster", "dict") or self.default_cluster()
|
|
if location in list(cluster.keys()):
|
|
self.fhdhr.logger.info("Removing %s from cluster." % location)
|
|
del cluster[location]
|
|
sync_url = location + "/api/cluster?method=leave"
|
|
try:
|
|
self.fhdhr.web.session.get(sync_url)
|
|
except self.fhdhr.web.exceptions.ConnectionError:
|
|
self.fhdhr.logger.error("Unreachable: " + location)
|
|
self.push_sync()
|
|
self.fhdhr.db.set_fhdhr_value("cluster", "dict", cluster)
|