You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
68 lines
2.3 KiB
68 lines
2.3 KiB
# functions about connections to other instances
|
|
# -------------------------------------------------------------------
|
|
"""
|
|
|
|
"""
|
|
import basic.program
|
|
import utils.config_tool
|
|
import basic.constants as B
|
|
import utils.data_const as D
|
|
|
|
|
|
def getConnection(comp, nr):
|
|
job = basic.program.Job.getInstance()
|
|
verify = job.getDebugLevel("conn_tool")
|
|
conn = {}
|
|
if job.conf.confs.get("tools").get("connsrc") == D.DFILE_TYPE_YML:
|
|
conn = utils.config_tool.getConfig("tool", "conn")
|
|
xtypes = None
|
|
if ("types" in conn["env"][comp]):
|
|
xtypes = conn["env"][comp]["types"]
|
|
instnr = "inst" + str(nr)
|
|
if conn["env"][comp][instnr]:
|
|
if (xtypes is not None):
|
|
conn["env"][comp][instnr]["types"] = xtypes
|
|
return conn["env"][comp][instnr]
|
|
else:
|
|
job.m.setFatal("Conn-Tool: Comp not configured " + comp + " " + str(nr))
|
|
elif job.conf.confs.get("tools").get("connsrc") == "flaskdb":
|
|
pass
|
|
elif job.conf.confs.get("tools").get("connsrc") == D.DFILE_TYPE_CSV:
|
|
pass
|
|
return None
|
|
|
|
|
|
def getConnections(comp):
|
|
job = basic.program.Job.getInstance()
|
|
verify = job.getDebugLevel("conn_tool")
|
|
msg = None
|
|
if hasattr(comp, "m") and comp.m is not None:
|
|
msg = comp.m
|
|
elif hasattr(job, "m") and job.m is not None:
|
|
msg = job.m
|
|
else:
|
|
raise Exception("message-object is missing")
|
|
msg.debug(verify, "getConnections " + comp)
|
|
conn = {}
|
|
conns = []
|
|
if job.conf.confs.get("tools").get("connsrc") == D.DFILE_TYPE_YML:
|
|
conn = utils.config_tool.getConfig("tool", "conn")
|
|
if not comp in conn["env"]:
|
|
job.m.setFatal("Conn-Tool: Comp not configured " + comp)
|
|
elif job.conf.confs.get("tools").get("connsrc") == "flaskdb":
|
|
pass
|
|
elif job.conf.confs.get("tools").get("connsrc") == D.DFILE_TYPE_CSV:
|
|
pass
|
|
#print(comp)
|
|
#print(conn["env"].keys())
|
|
#print(conn["env"][comp][B.SUBJECT_INST])
|
|
xtypes = None
|
|
if ("types" in conn["env"][comp]):
|
|
xtypes = conn["env"][comp]["types"]
|
|
for i in range(conn["env"][comp][B.SUBJECT_INST]):
|
|
print("range " + str(i + 1))
|
|
instnr = "inst" + str(i + 1)
|
|
if (xtypes is not None):
|
|
conn["env"][comp][instnr]["types"] = xtypes
|
|
conns.append(conn["env"][comp][instnr])
|
|
return conns
|
|
|