afonso/core-extra
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

removed old service config code

Browse source
This commit is contained in:
Blake Harnden 2019-11-27 12:20:00 -08:00
parent 5708dbd083
commit 354d227cb3
2 changed files with 0 additions and 122 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

37
coretk/coretk/data/todelete/servicefileconfig.py
View file

@ -1,37 +0,0 @@
"""
service file configuration
"""
class ServiceFileConfig:
def __init__(self):
# dict(node_id:dict(service:dict(filename, data)))
self.configurations = {}
# def set_service_configs(self, node_id, service_name, file_configs):
# """
# store file configs
#
# :param int node_id: node id
# :param str service_name: service name
# :param dict(str, str) file_configs: map of service file to its data
# :return: nothing
# """
# for key, value in file_configs.items():
# self.configurations[node_id][service_name][key] = value
def set_custom_service_file_config(self, node_id, service_name, file_name, data):
"""
store file config
:param int node_id: node id
:param str service_name: service name
:param str file_name: file name
:param str data: data
:return: nothing
"""
if node_id not in self.configurations:
self.configurations[node_id] = {}
if service_name not in self.configurations[node_id]:
self.configurations[node_id][service_name] = {}
self.configurations[node_id][service_name][file_name] = data

85
coretk/coretk/data/todelete/servicenodeconfig.py
View file

@ -1,85 +0,0 @@
"""
service node configuration
"""
import logging
from tkinter import messagebox
import grpc
class ServiceNodeConfig:
def __init__(self, app):
self.app = app
# dict(node_id:dict(service:node_service_config_proto))
# maps node to all of its service configuration
self.configurations = {}
# dict(node_id:set(str))
# maps node to current configurations
self.current_services = {}
self.default_services = {}
# todo rewrite, no need self.default services
def node_default_services_configuration(self, node_id, node_model):
"""
set the default configurations for the default services of a node
:param coretk.graph.CanvasNode canvas_node: canvas node object
:return: nothing
"""
session_id = self.app.core.session_id
client = self.app.core.client
if len(self.default_services) == 0:
response = client.get_service_defaults(session_id)
logging.info("session default services: %s", response)
for default in response.defaults:
self.default_services[default.node_type] = default.services
self.configurations[node_id] = {}
self.current_services[node_id] = set()
for default in self.default_services[node_model]:
response = client.get_node_service(session_id, node_id, default)
logging.info(
"servicenodeconfig.py get node service (%s), result: %s",
node_id,
response,
)
self.configurations[node_id][default] = response.service
self.current_services[node_id].add(default)
def node_new_service_configuration(self, node_id, service_name):
"""
store node's configuration if a new service is added from the GUI
:param int node_id: node id
:param str service_name: service name
:return: nothing
"""
try:
config = self.app.core.get_node_service(node_id, service_name)
except grpc.RpcError:
messagebox.showerror("Service problem", "Service not found")
return False
if node_id not in self.configurations:
self.configurations[node_id] = {}
if node_id not in self.current_services:
self.current_services[node_id] = set()
if service_name not in self.configurations[node_id]:
self.configurations[node_id][service_name] = config
self.current_services[node_id].add(service_name)
return True
def node_custom_service_configuration(self, node_id, service_name):
self.configurations[node_id][service_name] = self.app.core.get_node_service(
node_id, service_name
)
def node_service_custom_configuration(
self, node_id, service_name, startups, validates, shutdowns
):
self.app.core.set_node_service(
node_id, service_name, startups, validates, shutdowns
)
config = self.app.core.get_node_service(node_id, service_name)
self.configurations[node_id][service_name] = config