Blame view

src/core/pyros_django/obsconfig/configpyros.py 39.5 KB
dd54dc29   Alexis Koralewski   Updating schemas,...
1
#!/usr/bin/env python3
6686d675   Alexis Koralewski   new version of ob...
2
import pykwalify.core
72519c93   Alexis Koralewski   Updating observat...
3
import yaml,sys,logging,os, pickle, time
6686d675   Alexis Koralewski   new version of ob...
4
5
from pykwalify.errors import PyKwalifyException,SchemaError

a2f47fb6   Alexis Koralewski   updating display ...
6
class ConfigPyros:
6686d675   Alexis Koralewski   new version of ob...
7
    # (AKo) : Config file path is checked on the settings file, if the file isn't valid (i.e not found) the error will be launched by the settings file when starting the application 
a2f47fb6   Alexis Koralewski   updating display ...
8
    devices_links = {}
ee2a5e47   Alexis Koralewski   New version of ob...
9
    current_file = None
472cb08c   Alexis Koralewski   Add new tests of ...
10
11
    COMPONENT_PATH = os.path.join(os.environ["DJANGO_PATH"],"../../../config/components/")
    GENERIC_DEVICES_PATH = os.path.join(os.environ["DJANGO_PATH"],"../../../config/devices/")
72519c93   Alexis Koralewski   Updating observat...
12
13
14
15
16
17
18
19
20
21
22
23
24
25
    pickle_file = "obsconfig.p"
    obs_config = None
    devices = None
    computers = None
    agents = None 
    def verify_if_pickle_needs_to_be_updated(self,observatory_config_file)->bool:
        """[summary]

        Args:
            observatory_config_file ([type]): [description]

        Returns:
            bool: [description]
        """
be09bdbc   Alexis Koralewski   Check if observat...
26
27
        self.CONFIG_PATH = os.path.dirname(observatory_config_file)+"/"
        if os.path.isfile(self.CONFIG_PATH+self.pickle_file) == False:
72519c93   Alexis Koralewski   Updating observat...
28
29
            return True
        else:
be09bdbc   Alexis Koralewski   Check if observat...
30
            pickle_file_mtime = os.path.getmtime(self.CONFIG_PATH+self.pickle_file)
72519c93   Alexis Koralewski   Updating observat...
31
32
33
34
35
            obs_config_mtime = os.path.getmtime(observatory_config_file)
            if obs_config_mtime > pickle_file_mtime:
                return True
            
            obs_config = self.read_and_check_config_file(observatory_config_file)
be09bdbc   Alexis Koralewski   Check if observat...
36
            if obs_config == None:
72519c93   Alexis Koralewski   Updating observat...
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
                print(f"Error when trying to read config file (path of config file : {observatory_config_file}")
                return -1
            self.obs_config = obs_config
            # check last date of modification for devices files
            for device in self.obs_config["OBSERVATORY"]["DEVICES"]:
                device_file = self.CONFIG_PATH+device["DEVICE"]["file"]
                device_file_mtime = os.path.getmtime(device_file)
                if device_file_mtime > pickle_file_mtime:
                    return True
                
            for computer in self.obs_config["OBSERVATORY"]["COMPUTERS"]:
                computer_file = self.CONFIG_PATH+computer["COMPUTER"]["file"]
                computer_file_mtime = os.path.getmtime(computer_file)
                if computer_file_mtime > pickle_file_mtime:
                    return True
        return False

    def load(self,observatory_config_file):
        does_pickle_needs_to_be_updated = self.verify_if_pickle_needs_to_be_updated(observatory_config_file)
be09bdbc   Alexis Koralewski   Check if observat...
56
        if os.path.isfile(self.CONFIG_PATH+self.pickle_file) and does_pickle_needs_to_be_updated == False:
72519c93   Alexis Koralewski   Updating observat...
57
58
59
60
            print("Reading pickle file")
            try:
                can_pickle_file_be_read = False
                while can_pickle_file_be_read != True:
be09bdbc   Alexis Koralewski   Check if observat...
61
62
                    if os.access(self.CONFIG_PATH+self.pickle_file, os.R_OK):
                        pickle_dict = pickle.load(open(self.CONFIG_PATH+self.pickle_file,"rb"))
72519c93   Alexis Koralewski   Updating observat...
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
                        can_pickle_file_be_read = True
                    else:
                        time.sleep(0.5)
            except IOError:
                print("Error when reading the pickle file")
                
            self.obs_config = pickle_dict["obs_config"]
            self.computers = pickle_dict["computers"]
            self.devices = pickle_dict["devices"]
            self.devices_links = pickle_dict["devices_links"]
        else:
            print("Pickle file needs to be created or updated")
            pickle_dict = {}
            
            self.obs_config = self.read_and_check_config_file(observatory_config_file) 
            pickle_dict["obs_config"] = self.obs_config
            pickle_dict["devices"] = self.get_devices()
            pickle_dict["computers"] = self.get_computers()
            pickle_dict["devices_links"] = self.devices_links
            print("Writing pickle file")
be09bdbc   Alexis Koralewski   Check if observat...
83
            pickle.dump(pickle_dict,open(self.CONFIG_PATH+self.pickle_file,"wb"))
6686d675   Alexis Koralewski   new version of ob...
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98

    def check_and_return_config(self,yaml_file:str,schema_file:str)->dict:
        """
        Check if yaml_file is valid for the schema_file and return an dictionary of the config file

        Args:
            yaml_file (str): Path to the config_file to be validated
            schema_file (str): Path to the schema file 

        Returns:
            dict: dictionary of the config file (with values)
        """
        # disable pykwalify error to clean the output
        logging.disable(logging.ERROR)
        try:
72519c93   Alexis Koralewski   Updating observat...
99
100
101
102
103
104
105
106
            can_yaml_file_be_read = False
            while can_yaml_file_be_read != True:
                if os.access(yaml_file, os.R_OK):
                    can_yaml_file_be_read = True
                else:
                    print(f"{yaml_file} can't be accessed, waiting for availability")
                    time.sleep(0.5)
        
6686d675   Alexis Koralewski   new version of ob...
107
108
109
110
111
112
113
            c = pykwalify.core.Core(source_file=yaml_file, schema_files=[schema_file])
            return c.validate(raise_exception=True)
        except SchemaError:
            for error in c.errors:
                print("Error :",str(error).split(". Path")[0])
                print("Path to error :",error.path)
            return None
72519c93   Alexis Koralewski   Updating observat...
114
115
        except IOError:
            print("Error when reading the observatory config file")
6686d675   Alexis Koralewski   new version of ob...
116
117
118
119
120
121
122
123
124
125
126

    def read_and_check_config_file(self,yaml_file:str)->dict:
        """
        Read the schema key of the config file to retrieve schema name and proceed to the checking of that config file
        Call check_and_return_config function and print its return.

        Args:
            yaml_file (str): path to the config file
        Returns:
            dict: Dictionary of the config file (with values)
        """
ee2a5e47   Alexis Koralewski   New version of ob...
127
        self.current_file = yaml_file
6686d675   Alexis Koralewski   new version of ob...
128
        try:
72519c93   Alexis Koralewski   Updating observat...
129
130
131
132
133
134
135
136
            can_config_file_be_read = False
            while can_config_file_be_read != True:
                
                if os.access(yaml_file, os.R_OK):
                    can_config_file_be_read = True
                else:
                    print(f"{yaml_file} can't be accessed, waiting for availability")
                    time.sleep(0.5)
6686d675   Alexis Koralewski   new version of ob...
137
            with open(yaml_file, 'r') as stream:
72519c93   Alexis Koralewski   Updating observat...
138
                print(f"Reading {yaml_file}")
6686d675   Alexis Koralewski   new version of ob...
139
140
                config_file = yaml.safe_load(stream)

18ec3272   Alexis Koralewski   adding path to dj...
141
            self.SCHEMA_PATH = os.path.join(os.environ["DJANGO_PATH"],"../../../config/schemas/")
72519c93   Alexis Koralewski   Updating observat...
142
            self.CONFIG_PATH = os.path.dirname(yaml_file)+"/"
18ec3272   Alexis Koralewski   adding path to dj...
143
144
            #self.COMPONENT_PATH = os.path.join(os.path.abspath(os.path.dirname(yaml_file)),"../../../config/components/")
            #self.GENERIC_DEVICES_PATH = os.path.join(os.path.abspath(os.path.dirname(yaml_file)),"../../../config/devices/")
72519c93   Alexis Koralewski   Updating observat...
145
            result = self.check_and_return_config(yaml_file,self.SCHEMA_PATH+config_file["schema"])
be09bdbc   Alexis Koralewski   Check if observat...
146
            if result == None:
72519c93   Alexis Koralewski   Updating observat...
147
                print("Error when reading and validating config file, please check the errors right above")
be09bdbc   Alexis Koralewski   Check if observat...
148
                exit(1)
72519c93   Alexis Koralewski   Updating observat...
149
            return result
ee2a5e47   Alexis Koralewski   New version of ob...
150
151
152
153
154
155
156

        except yaml.YAMLError as exc:
            print(exc)
        except Exception as e:
            print(e)
            return None
    
72519c93   Alexis Koralewski   Updating observat...
157
    def read_generic_component_and_return_attributes(self,component_name:str)->dict:
ee2a5e47   Alexis Koralewski   New version of ob...
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
        file_path = self.COMPONENT_PATH + component_name + ".yml"
        try:
            with open(file_path, 'r') as stream:
                config_file = yaml.safe_load(stream)  
                
                attributes = {}
                for attribute in config_file:
                
                    attribute = attribute["attribute"]
                    attributes[attribute.pop("key")] = attribute
                return attributes
        except yaml.YAMLError as exc:
            print(exc)
        except Exception as e:
            print(e)
            return None
    
    def read_capability_of_device(self,capability:dict)->dict:
        """
b4d06c1f   Alexis Koralewski   Improving device ...
177
        Read capability of device and inherit attributes from generic component then overwrite attributes defined in device config
ee2a5e47   Alexis Koralewski   New version of ob...
178
179

        Args:
b4d06c1f   Alexis Koralewski   Improving device ...
180
            capability (dict): dictionary containing a capabilitiy (keys : component and attributes)
ee2a5e47   Alexis Koralewski   New version of ob...
181
182

        Returns:
b4d06c1f   Alexis Koralewski   Improving device ...
183
            dict: dictionary of capability inherited by generic component and overwritten his attributes by current attributes of capability
ee2a5e47   Alexis Koralewski   New version of ob...
184
185
        """
        
72519c93   Alexis Koralewski   Updating observat...
186
        component_attributes = self.read_generic_component_and_return_attributes(capability["component"])
ee2a5e47   Alexis Koralewski   New version of ob...
187
188
        
        attributes = {}
b4d06c1f   Alexis Koralewski   Improving device ...
189
        # get all attributes of device's capability
ee2a5e47   Alexis Koralewski   New version of ob...
190
191
192
193
194
        for attribute in capability["attributes"]:
            attribute = attribute["attribute"]
        
            attributes[attribute.pop("key")] = attribute
        
b4d06c1f   Alexis Koralewski   Improving device ...
195
        # for each attributes of generic component attributes
ee2a5e47   Alexis Koralewski   New version of ob...
196
        for attribute_name in attributes.keys():
72519c93   Alexis Koralewski   Updating observat...
197
            # merge attributes of general component with specified component in device config file
ee2a5e47   Alexis Koralewski   New version of ob...
198
            new_attributes = {**component_attributes[attribute_name],**attributes[attribute_name]}
282540c5   Alexis Koralewski   Config class: imp...
199
200
201
            if "is_enum" in component_attributes[attribute_name].keys():
                # make an intersection of both list of values
                new_attributes["value"] = list(set(attributes[attribute_name]["value"]) & set(component_attributes[attribute_name]["value"]))
3e86f19c   Alexis Koralewski   config class : im...
202
203
204
                if len(new_attributes["value"]) == 0:
                    print(f"Value of lastly read device's attribute '{attribute_name}' isn't one of the values of component configuration for this device (component configuration value(s): {component_attributes[attribute_name]['value']}) (actual value : {attributes[attribute_name]['value']})")
                    exit(1)
ee2a5e47   Alexis Koralewski   New version of ob...
205
206
            component_attributes[attribute_name] = new_attributes
        
b4d06c1f   Alexis Koralewski   Improving device ...
207
        # return inherited and overwritten attributes of capability
ee2a5e47   Alexis Koralewski   New version of ob...
208
209
210
211
212
        capability["attributes"] = component_attributes
        return capability



a2f47fb6   Alexis Koralewski   updating display ...
213
214
215
    def get_devices_names_and_file(self)->dict:
        """
        
b4d06c1f   Alexis Koralewski   Improving device ...
216
        Return a dictionary giving the device file name by the device name 
a2f47fb6   Alexis Koralewski   updating display ...
217
        Returns:
b4d06c1f   Alexis Koralewski   Improving device ...
218
            dict: key is device name, value is file name
a2f47fb6   Alexis Koralewski   updating display ...
219
220
        """
        devices_names_and_files = {}
72519c93   Alexis Koralewski   Updating observat...
221
        for device in self.obs_config["OBSERVATORY"]["DEVICES"]:
a2f47fb6   Alexis Koralewski   updating display ...
222
223
224
225
226
            device = device["DEVICE"]
            
            devices_names_and_files[device["name"]] = device["file"]
        return devices_names_and_files

72519c93   Alexis Koralewski   Updating observat...
227
    def read_device_config_file(self,config_file_name:str,is_generic=False)->dict:
ee2a5e47   Alexis Koralewski   New version of ob...
228
        """
b4d06c1f   Alexis Koralewski   Improving device ...
229
230
231
        Read the device config file, inherit generic device config if "generic" key is present in "DEVICE".
        Associate capabilities of attached_devices if this device has attached_devices.
        Inherit capabilities from generic component and overwritte attributes defined in the device config
ee2a5e47   Alexis Koralewski   New version of ob...
232
        Args:
b4d06c1f   Alexis Koralewski   Improving device ...
233
234
            config_file_name (str): file name to be read
            is_generic (bool, optional): tells if we're reading a generic configuration (is_generic =True) or not (is_generic = False). Defaults to False.
ee2a5e47   Alexis Koralewski   New version of ob...
235
236

        Returns:
b4d06c1f   Alexis Koralewski   Improving device ...
237
            dict: formatted device configuration (attributes, capabilities...)
ee2a5e47   Alexis Koralewski   New version of ob...
238
239
        """
        self.current_file = config_file_name
c132ba0f   Alexis Koralewski   Fixing TNC config...
240
241
242
243
244
245
246
247
248
249
        devices_name_and_file = self.get_devices_names_and_file()
        if not is_generic:
            # check if device config file is listed in observatory configuration
            current_device_name = [device for device,file_name in devices_name_and_file.items() if file_name in config_file_name[len(self.CONFIG_PATH):] ]
            if len(current_device_name) <= 0:
                print(f"Current file '{config_file_name[len(self.CONFIG_PATH):]}' isn't listed in observatory configuration")
                print("The devices names and files are: ")
                for device_name,file_name in devices_name_and_file.items():
                    print(f"device name: '{device_name}', device filename: '{file_name}'")
                exit(1)
72519c93   Alexis Koralewski   Updating observat...
250
        print(f"Reading {config_file_name}")
ee2a5e47   Alexis Koralewski   New version of ob...
251
252
253
        try:
            with open(config_file_name, 'r') as stream:
                config_file = yaml.safe_load(stream)
b4d06c1f   Alexis Koralewski   Improving device ...
254
                # if we're reading a generic device configuration, the path to get the schema is different than usual
72519c93   Alexis Koralewski   Updating observat...
255
                if is_generic:
472cb08c   Alexis Koralewski   Add new tests of ...
256
                    self.SCHEMA_PATH =os.path.join(os.environ["DJANGO_PATH"],"../../../config/schemas/")
72519c93   Alexis Koralewski   Updating observat...
257
                else:
472cb08c   Alexis Koralewski   Add new tests of ...
258
                    self.SCHEMA_PATH = os.path.join(os.environ["DJANGO_PATH"],"../../../config/schemas/")
72519c93   Alexis Koralewski   Updating observat...
259
                
b4d06c1f   Alexis Koralewski   Improving device ...
260
                # read and verify that the device configuration match the schema
ee2a5e47   Alexis Koralewski   New version of ob...
261
                result = self.check_and_return_config(config_file_name,self.SCHEMA_PATH+config_file["schema"])
b4d06c1f   Alexis Koralewski   Improving device ...
262
                # if the configuration didn't match the schema or had an error when reading the file
be09bdbc   Alexis Koralewski   Check if observat...
263
                if result == None:
ee2a5e47   Alexis Koralewski   New version of ob...
264
                    print("Error when reading and validating config file, please check the errors right above")
be09bdbc   Alexis Koralewski   Check if observat...
265
                    exit(-1)
ee2a5e47   Alexis Koralewski   New version of ob...
266
                else:
b4d06c1f   Alexis Koralewski   Improving device ...
267
268
                    # the configuration is valid
                    # storing DEVICE key in device (DEVICE can contains : attributes of device, capabilities, attached devices)
ee2a5e47   Alexis Koralewski   New version of ob...
269
                    device = result["DEVICE"]
b4d06c1f   Alexis Koralewski   Improving device ...
270
271
                    generic_device_config = None
                    # if the device is associated to an generic configuration, we'll read that generic configuration to inherit his attributes
72519c93   Alexis Koralewski   Updating observat...
272
                    if "generic" in device:
b4d06c1f   Alexis Koralewski   Improving device ...
273
                        # storing the whole current config
72519c93   Alexis Koralewski   Updating observat...
274
                        current_config = result
b4d06c1f   Alexis Koralewski   Improving device ...
275
276
277
                        # read and get the generic device config
                        generic_device_config = self.read_device_config_file(self.GENERIC_DEVICES_PATH+device["generic"],is_generic=True)
                        # merge whole device config but we need to merge capabilities differently after
72519c93   Alexis Koralewski   Updating observat...
278
                        new_config = {**generic_device_config["DEVICE"],**current_config["DEVICE"]}
72519c93   Alexis Koralewski   Updating observat...
279
280
                        result["DEVICE"] = new_config

b4d06c1f   Alexis Koralewski   Improving device ...
281
                    # device has capabilities
ee2a5e47   Alexis Koralewski   New version of ob...
282
283
                    if "CAPABILITIES" in device:
                        capabilities = []
b4d06c1f   Alexis Koralewski   Improving device ...
284
285
286
287
                        # if the device is associated to a generic device we need to associate his capabilities with the generic capabilities and overwrite them
                        if generic_device_config != None:
                            # we're making a copy of generic device config so we can remove items during loop
                            copy_generic_device_config = generic_device_config.copy()
282540c5   Alexis Koralewski   Config class: imp...
288
                            # We have to extend capabilities of generic device configuration
b4d06c1f   Alexis Koralewski   Improving device ...
289
290
291
292
                            for capability in current_config["DEVICE"]["CAPABILITIES"]:
                                is_capability_in_generic_config = False
                                current_config_capability = capability["CAPABILITY"]
                                current_config_component = current_config_capability["component"]
b4d06c1f   Alexis Koralewski   Improving device ...
293
294
295
296
297
298
                                # find if this component was defined in generic_device_config
                                for index,generic_config_capability in enumerate(generic_device_config["DEVICE"]["CAPABILITIES"]):
                                    # if the current capability is the capability of the component we're looking for
                                    if current_config_component == generic_config_capability["component"]:
                                        is_capability_in_generic_config = True
                                        # we're merging their attributes
3e86f19c   Alexis Koralewski   config class : im...
299
                                        new_attributes = generic_config_capability["attributes"].copy()
282540c5   Alexis Koralewski   Config class: imp...
300
301
302
303
304
305
306
307
308
309
310
311
312
                                        attributes = {}
                                        current_config_attributes = current_config_capability["attributes"]                                        
                                        generic_config_attributes = generic_config_capability["attributes"]
                                        for attribute in current_config_attributes:
                                            attribute = attribute["attribute"]
                                            attributes[attribute.pop("key")] = attribute
                                        # for each attributes of device component attributes
                                        for attribute_name in attributes.keys():
                                            # merge attributes of general component with specified component in device config file
                                            new_attributes[attribute_name] = {**generic_config_attributes[attribute_name],**attributes[attribute_name]}
                                            if "is_enum" in generic_config_attributes[attribute_name].keys():
                                                # make an intersection of both list of values
                                                new_attributes[attribute_name]["value"] = list(set(attributes[attribute_name]["value"]) & set(generic_config_attributes[attribute_name]["value"]))
3e86f19c   Alexis Koralewski   config class : im...
313
314
315
                                                if len(new_attributes[attribute_name]["value"]) == 0:
                                                    print(f"Value of device '{config_file_name}' for attribute '{attribute_name}' isn't one of the values of generic configuration for this device (generic value(s): {generic_config_attributes[attribute_name]['value']}) (actual value : {attributes[attribute_name]['value']})")
                                                    exit(1)
b4d06c1f   Alexis Koralewski   Improving device ...
316
317
                                        # removing this capability from generic device configuration
                                        generic_device_config["DEVICE"]["CAPABILITIES"].pop(index)
282540c5   Alexis Koralewski   Config class: imp...
318
                                        capabilities.append({"component": current_config_component,"attributes":new_attributes}) 
b4d06c1f   Alexis Koralewski   Improving device ...
319
320
                                        break
                                if is_capability_in_generic_config == False:
282540c5   Alexis Koralewski   Config class: imp...
321
                                    current_config_capability = self.read_capability_of_device(current_config_capability)
b4d06c1f   Alexis Koralewski   Improving device ...
322
323
324
325
326
327
328
329
330
331
                                    # the component defined in the current_config isn't defined in generic config (should not happen but we'll deal with that case anyway) : we're simply adding this capability
                                    capabilities.append(current_config_capability)
                            # looping through generic device config's capabilities in order to add them to current device configuration
                            for generic_config_capability in generic_device_config["DEVICE"]["CAPABILITIES"]:
                                capabilities.append(generic_config_capability)
                        else:
                            # device not associated to a generic device configuration
                            for capability in device["CAPABILITIES"]:
                                capability = capability["CAPABILITY"]
                                capabilities.append(self.read_capability_of_device(capability))
ee2a5e47   Alexis Koralewski   New version of ob...
332
                        device["CAPABILITIES"] = capabilities
b4d06c1f   Alexis Koralewski   Improving device ...
333
334
                        # associate capabilities to final device configuration (stored in result variable)
                        result["DEVICE"]["CAPABILITIES"] = device["CAPABILITIES"]
ee2a5e47   Alexis Koralewski   New version of ob...
335
                    if "ATTACHED_DEVICES" in device.keys():
b4d06c1f   Alexis Koralewski   Improving device ...
336
                        # device has attached devices, we need to read their configuration in order to get their capabilities and add them to the current device
a2f47fb6   Alexis Koralewski   updating display ...
337
338
                        devices_name_and_file = self.get_devices_names_and_file()
                        active_devices = self.get_active_devices()
ee2a5e47   Alexis Koralewski   New version of ob...
339
                        for attached_device in device["ATTACHED_DEVICES"]:
a2f47fb6   Alexis Koralewski   updating display ...
340
                            is_attached_device_link_to_agent = False
b4d06c1f   Alexis Koralewski   Improving device ...
341
                            # we're looking for if the attached device is associated to an agent (i.e. the device is considered as 'active'). However an attached_device shoudn't be active
a2f47fb6   Alexis Koralewski   updating display ...
342
                            for active_device in active_devices:
a2f47fb6   Alexis Koralewski   updating display ...
343
                                if devices_name_and_file[active_device] == attached_device["file"]:
b4d06c1f   Alexis Koralewski   Improving device ...
344
                                    # the attached device is an active device (so it's linked to an agent)
a2f47fb6   Alexis Koralewski   updating display ...
345
346
                                    is_attached_device_link_to_agent = True
                                    break
a2f47fb6   Alexis Koralewski   updating display ...
347
                            if self.CONFIG_PATH+attached_device["file"] != config_file_name and not is_attached_device_link_to_agent:
b4d06c1f   Alexis Koralewski   Improving device ...
348
                            # if the attached device isn't the device itself and not active
72519c93   Alexis Koralewski   Updating observat...
349
                                
b4d06c1f   Alexis Koralewski   Improving device ...
350
                                # get configuration of attached device
a2f47fb6   Alexis Koralewski   updating display ...
351
                                config_of_attached_device = self.read_device_config_file(self.CONFIG_PATH+attached_device["file"])
a2f47fb6   Alexis Koralewski   updating display ...
352
353
354
                                capabilities_of_attached_device = None
                                if "CAPABILITIES" in config_of_attached_device["DEVICE"].keys():
                                    capabilities_of_attached_device = config_of_attached_device["DEVICE"]["CAPABILITIES"]
be09bdbc   Alexis Koralewski   Check if observat...
355
                                if capabilities_of_attached_device != None:
a2f47fb6   Alexis Koralewski   updating display ...
356
                                    # get name of device corresponding to the config file name
c132ba0f   Alexis Koralewski   Fixing TNC config...
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
                                    parent_device_name = [device for device,file_name in devices_name_and_file.items() if file_name == config_file_name[len(self.CONFIG_PATH):]]
                                    attached_device_name = [device for device,file_name in devices_name_and_file.items() if file_name == attached_device["file"]]
                                    if len(parent_device_name) > 0 :
                                        parent_device_name = parent_device_name[0]
                                    else:
                                        print(f"Attached device filename '{config_file_name[len(self.CONFIG_PATH):]}' is not listed in observatory devices files names")
                                        print("The devices names and files are: ")
                                        for device_name,file_name in devices_name_and_file.items():
                                            print(f"device name: '{device_name}', device filename: '{file_name}'")
                                        exit(1)
                                    if len(attached_device_name) > 0 :
                                        attached_device_name = attached_device_name[0]
                                    else:
                                        
                                        print(f"Attached device filename '{attached_device['file']}' is not listed in observatory devices files names")
                                        print("The devices names and files are: ")
                                        for device_name,file_name in devices_name_and_file.items():
                                            print(f"device name: '{device_name}', device filename: '{file_name}'")
                                        exit(1)
b4d06c1f   Alexis Koralewski   Improving device ...
376
                                    # associate attached device to his 'parent' device (parent device is the currently read device)
18ec3272   Alexis Koralewski   adding path to dj...
377
                                    print(self.devices_links)
a2f47fb6   Alexis Koralewski   updating display ...
378
379
                                    self.devices_links[attached_device_name] = parent_device_name
                                    for capability in capabilities_of_attached_device:
b4d06c1f   Alexis Koralewski   Improving device ...
380
                                        # add capabilities of attached device to current device
a2f47fb6   Alexis Koralewski   updating display ...
381
                                        result["DEVICE"]["CAPABILITIES"].append(capability)
6686d675   Alexis Koralewski   new version of ob...
382
383
384
                return result
        except yaml.YAMLError as exc:
            print(exc)
dd54dc29   Alexis Koralewski   Updating schemas,...
385
386
        except Exception as e:
            print(e)
c132ba0f   Alexis Koralewski   Fixing TNC config...
387
388
            exit(1)
            #return None
6686d675   Alexis Koralewski   new version of ob...
389

72519c93   Alexis Koralewski   Updating observat...
390
    def __init__(self,observatory_config_file:str) -> None:
6686d675   Alexis Koralewski   new version of ob...
391
392
393
394
395
396
397
        """
        Initiate class with the config file
        set content attribute to a dictionary containing all values from the config file

        Args:
            config_file_name (str): path to the config file
        """
72519c93   Alexis Koralewski   Updating observat...
398
        self.load(observatory_config_file)
6686d675   Alexis Koralewski   new version of ob...
399

6686d675   Alexis Koralewski   new version of ob...
400
401
402
403
404
405
406
407
   
    def get_obs_name(self)->str:
        """
        Return name of the observatory

        Returns:
            str: Name of the observatory
        """
72519c93   Alexis Koralewski   Updating observat...
408
        return self.obs_config["OBSERVATORY"]["name"]
6686d675   Alexis Koralewski   new version of ob...
409
410
411
412
413
414
415
416
417
418
419
420

    def get_channels(self,unit)->dict:
        """
        return dictionary of channels

        Returns:
            dict: [description]
        """
        channels = {}
        
        for channel_id in range(len(unit["TOPOLOGY"]["CHANNELS"])):
            channel = unit["TOPOLOGY"]["CHANNELS"][channel_id]["CHANNEL"]
ee2a5e47   Alexis Koralewski   New version of ob...
421
            channels[channel["name"]] = channel
6686d675   Alexis Koralewski   new version of ob...
422
423
424
425
426
427
428
429
430
        return channels
    
    def get_computers(self)->dict:
        """
        return dictionary of computers

        Returns:
            dict: [description]
        """
72519c93   Alexis Koralewski   Updating observat...
431
432
433
434
435
436
437
438
439
440
        if self.computers != None:
            return self.computers
        else:
            computers = {}
            for computer_id in range(len(self.obs_config["OBSERVATORY"]["COMPUTERS"])):
                computer = self.obs_config["OBSERVATORY"]["COMPUTERS"][computer_id]["COMPUTER"]
                if( "file" in computer.keys() ):
                    computer["computer_config"]= self.read_and_check_config_file(self.CONFIG_PATH+computer["file"])["COMPUTER"]
                computers[computer["name"]] = computer
            return computers
6686d675   Alexis Koralewski   new version of ob...
441
442
443
444
445
446
447
448
    
    def get_devices(self)->dict:
        """
        return dictionary of devices
        
        Returns:
            dict: [description]
        """
72519c93   Alexis Koralewski   Updating observat...
449
450
451
452
453
454
455
456
457
458
459
        if self.devices != None:
            return self.devices

        else:
            devices = {}
            for device_id in range(len(self.obs_config["OBSERVATORY"]["DEVICES"])):
                device = self.obs_config["OBSERVATORY"]["DEVICES"][device_id]["DEVICE"]
                if( "file" in device.keys() ):
                    device["device_config"] = self.read_device_config_file(self.CONFIG_PATH+device["file"])["DEVICE"]
                devices[device["name"]] = device
            return devices
6686d675   Alexis Koralewski   new version of ob...
460

c132ba0f   Alexis Koralewski   Fixing TNC config...
461
462
463
464
465
466
467
468
469
470
471
    def get_devices_names(self)->list:
        """Return the list of devices names of an observatory

        Returns:
            list: list of names of devices
        """
        devices_names = []
        for device in self.obs_config["OBSERVATORY"]["DEVICES"]:
            devices_names.append(device["DEVICE"]["name"])
        return devices_names

6686d675   Alexis Koralewski   new version of ob...
472
473
474
475
476
477
478
    def get_agents(self,unit)->dict:
        """
        return dictionary of agents 

        Returns:
            dict: dictionary of agents. For each agents tell the name, computer, device, protocole, etc...
        """
72519c93   Alexis Koralewski   Updating observat...
479
480
481
482
483
484
485
486
487
488
489
490
        if self.agents != None:
            return self.agents
        else:
            agents = {}
            
            
            for agent_id in range(len(unit["AGENTS"])):
                # Agents is a list containing dictionary that have only one key
                key = list(unit["AGENTS"][agent_id].keys())[0]
                agent = unit["AGENTS"][agent_id][key]
                agents[agent["name"]] = agent
            return agents
6686d675   Alexis Koralewski   new version of ob...
491
492
493
494
495
496
497
498
499
500
501

    def get_channel_groups(self,unit:dict)->dict:
        """
        Return dictionary of channel groups, tell the logic between groups of channels and within a group of channels

        Args:
            unit (dict): dictonary contaning all values of a unit
        Returns:
            dict: dictionary of channel groups (tell the logic and groups of channels)
        """
        info = {}
ee2a5e47   Alexis Koralewski   New version of ob...
502
        info["global_groups_logic"] = unit["TOPOLOGY"]["CHANNEL_GROUPS"]["logic"]
6686d675   Alexis Koralewski   new version of ob...
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
        info["groups"] = {}
        for group_id in range(len(unit["TOPOLOGY"]["CHANNEL_GROUPS"]["GROUPS"])):
            group = unit["TOPOLOGY"]["CHANNEL_GROUPS"]["GROUPS"][group_id]["GROUP"]
            info["groups"][group_id] = group
        return info

    def get_channel_information(self,unit:dict,channel_name:str)->dict:
        """
        Return information of the given channel name of a unit

        Args:
            unit (dict): dictionary representing the unit 
            channel_name (str): name of the channel

        Returns:
            dict: dictionary containing all values that define this channel
        """
        channels = self.get_channels(unit)
        return channels[channel_name]

    def get_topology(self,unit:dict)->dict:
        """
        Return dictionary of the topology of the observatory

        Args:
            unit (dict): dictionary representing the unit
        Returns:
            dict: dictionary representing the topology of an unit (security, mount, channels, channel_groups)
        """
        topology = {}
        for key in unit["TOPOLOGY"].keys():
            branch = unit["TOPOLOGY"][key]
            if key == "CHANNELS":
                topology[key] = self.get_channels(unit)
            elif key == "CHANNEL_GROUPS":
                topology[key] = self.get_channel_groups(unit)
            else:
                topology[key] = branch
        return topology

    def get_active_agents(self,unit:dict)->list:
        """
        Return the list of active agents (i.e. agents that have an association with a device)

        Args:
            unit (dict): dictionary representing the unit

        Returns:
            list: kist of the name of active agents
        """
        return list(self.get_agents(unit).keys())

    def get_units(self)->dict:
        """
        Return all units sort by name defined in the config file

        Returns:
            dict: dictionary giving for a unit_name, his content (name,database,topology,agents,...)
        """
        result = {}
72519c93   Alexis Koralewski   Updating observat...
563
        units = self.obs_config["OBSERVATORY"]["UNITS"]
6686d675   Alexis Koralewski   new version of ob...
564
565
        for unit in units:
            unit = unit["UNIT"]
ee2a5e47   Alexis Koralewski   New version of ob...
566
            result[unit["name"]] = unit
6686d675   Alexis Koralewski   new version of ob...
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
        return result

    def get_components_agents(self,unit:dict)->dict:
        """
        Return dictionary of component_agents of the given unit

        Args:
            unit (dict): dictionary representing the unit

        Returns:
            dict: dictionary sort by component name giving the associated agent (agent name)
        """
        components_agents = {}
        topology = self.get_topology(unit)
        for element in topology:
            if element in ("SECURITY","MOUNT","CHANNELS"):
                if(element != "CHANNELS"):
                    for component_agent in topology[element]["COMPONENT_AGENTS"]:
                        component_name = list(component_agent.keys())[0]
                        components_agents[component_name] = component_agent[component_name]
                else:
                    for channel in topology[element]:
                        for component_agent in topology[element][channel]["COMPONENT_AGENTS"]:
                            component_name = list(component_agent.keys())[0]
                            components_agents[component_name] = component_agent[component_name]
        return components_agents

    def get_units_name(self)->list:
        """
        Return list of units names 

        Returns:
            [list]: names of units
        """
        return list(self.get_units().keys())

    def get_unit_by_name(self,name:str)->dict:
        """
        Return dictionary containing definition of the unit that match the given name

        Args:
            name (str): name of the unit

        Returns:
            dict: dictonary representing the unit
        """
        return self.get_units()[name]
    
    def get_agents_per_computer(self,unit:dict)->dict:
        """
        Return dictionary that give for each computer, what are the associated agents to it as a list

        Args:
            unit (dict): dictonary representing the unit

        Returns:
            dict:  dictionary that give for each computer, what are the associated agents to it as a list

        """
        agents_per_computer = {}
        agents = self.get_agents(unit)
        for agent in agents:
ee2a5e47   Alexis Koralewski   New version of ob...
629
630
            computer_name = agents[agent]["computer"]
            if(agents[agent]["computer"] not in agents_per_computer.keys()):
6686d675   Alexis Koralewski   new version of ob...
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
                agents_per_computer[computer_name] = [agent]
            else:
                agents_per_computer[computer_name].append(agent)
        return agents_per_computer


    def get_agents_per_device(self,unit:dict)->dict:
        """
        Return dictionary that give for each device, what are the associated agents to it as a list

        Args:
            unit (dict): dictonary representing the unit

        Returns:
            dict:  dictionary that give for each device, what are the associated agents to it as a list

        """
        agents_per_device = {}
        agents = self.get_agents(unit)
        for agent in agents:
ee2a5e47   Alexis Koralewski   New version of ob...
651
652
            if("device" in agents[agent].keys()):
                device_name = agents[agent]["device"]
c132ba0f   Alexis Koralewski   Fixing TNC config...
653
654
655
656
657
                if device_name in self.get_devices_names():
                    if(agents[agent]["device"] not in agents_per_device.keys()):
                        agents_per_device[device_name] = [agent]
                    else:
                        agents_per_device[device_name].append(agent)
6686d675   Alexis Koralewski   new version of ob...
658
                else:
c132ba0f   Alexis Koralewski   Fixing TNC config...
659
660
                    print(f"Error: device name '{device_name}' for agent '{agent}' is not known in the configuration file. The device name must match one of the names defined in the DEVICES section")
                    exit(1)
6686d675   Alexis Koralewski   new version of ob...
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
        return agents_per_device

    def get_active_devices(self)->list:
        """
        Return a list of active device names

        Returns:
            list: list of active device names
        """
        active_devices = []
        for unit_name in self.get_units():
            unit = self.get_unit_by_name(unit_name)
            for device in self.get_agents_per_device(unit):
                active_devices.append(device)
        return active_devices

    def get_active_computers(self)->list:
        """
        Return a list of active computer names

        Returns:
            list: list of active computer names
        """
        active_computers = []
        for unit_name in self.get_units():
            unit = self.get_unit_by_name(unit_name)
            for computer in self.get_agents_per_computer(unit):
                active_computers.append(computer)
        return active_computers

    def get_agent_information(self,unit:dict,agent_name:str)->dict:
        """
        Give the dictionary of attributes of the agent for an unit.

        Args:
            unit (dict): dictonary representing the unit
            agent_name (str): agent name

        Returns:
            dict: dictionary containing attributes of the agent
        """
        return self.get_agents(unit)[agent_name]

    def get_device_information(self,device_name:str)->dict:
        """
        Give the dictionary of the attributes of the device 

        Args:
            device_name (str): device name

        Returns:
            dict: dictionary containing attributes of the device
        """
        return self.get_devices()[device_name]

    def get_database_for_unit(self,unit_name:str)->dict:
        """
        Return dictionary of attributes of the database for an unit

        Args:
            unit_name (str): unit name

        Returns:
            dict: dictionary of attributes of the database for an unit
        """
        return self.get_unit_by_name(unit_name)["DATABASE"]

    def get_device_for_agent(self,unit:dict,agent_name:str)->str:
        """
        Return device name associated to the agent

        Args:
            unit (dict): dictonary representing the unit
            agent_name (str): agent name

        Returns:
            str: device name associated to this agent
        """
        agents_per_device = self.get_agents_per_device(unit)
        for device in agents_per_device:
            if agent_name in agents_per_device[device]:
                return self.get_device_information(device)
    def get_unit_of_computer(self,computer_name:str)->str:
        """
        Return the name of the unit where the computer is used

        Args:
            computer_name (str): computer name

        Returns:
            str: unit name
        """
        for unit_name in self.get_units():
            unit = self.get_unit_by_name(unit_name)
            if(computer_name in self.get_agents_per_computer(unit)):
                return unit_name

    def get_unit_of_device(self,device_name:str)->str:
        """
        Return the name of the unit where the device is used

        Args:
            device_name (str): device name

        Returns:
            str: unit name
        """
        for unit_name in self.get_units():
            unit = self.get_unit_by_name(unit_name)
            if(device_name in self.get_agents_per_device(unit)):
                return unit_name

    def get_device_power(self,device_name:str)->dict:
        """
        Return dictionary that contains informations about power if this information is present in the device config file

        Return None if this information isn't stored in device's config file
        Args:
            device_name (str): name of the device

        Returns:
            dict: informations about power of device
        """
ee2a5e47   Alexis Koralewski   New version of ob...
784
        return self.get_devices()[device_name]["device_config"].get("power")
6686d675   Alexis Koralewski   new version of ob...
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799


    def get_device_capabilities(self,device_name:str)->list:
        """
        Return dictionary that contains informations about capabilities if this information is present in the device config file

        Return empty list if this information isn't stored in device's config file
        Args:
            device_name (str): name of the device

        Returns:
            list: list of capabilities of device
        """
        list_of_capabilities = []
        capabilities = self.get_devices()[device_name]["device_config"].get("CAPABILITIES")
ee2a5e47   Alexis Koralewski   New version of ob...
800
        return capabilities
6686d675   Alexis Koralewski   new version of ob...
801
802
803
804
805
806
807
808
809
810
811
812

    def get_device_connector(self,device_name:str)->dict:
        """
        Return dictionary that contains informations about connector if this information is present in the device config file

        Return None if this information isn't stored in device's config file
        Args:
            device_name (str): name of the device

        Returns:
            dict: informations about connector of device
        """
ee2a5e47   Alexis Koralewski   New version of ob...
813
        return self.get_devices()[device_name]["device_config"].get("connector")
6686d675   Alexis Koralewski   new version of ob...
814
815
816
817
818
819
820
821
822
823
824
825

    def get_computer_power(self,computer_name:str)->dict:
        """
        Return dictionary that contains informations about power if this information is present in the device config file

        Return None if this information isn't stored in device's config file
        Args:
            device_name (str): name of the device

        Returns:
            dict: informations about connector of device
        """
ee2a5e47   Alexis Koralewski   New version of ob...
826
        return self.get_computers()[computer_name]["computer_config"].get("power")
dd54dc29   Alexis Koralewski   Updating schemas,...
827
828
829


def main():
18ec3272   Alexis Koralewski   adding path to dj...
830
831
832
833
834
    config = ConfigPyros("../../../../privatedev/config/tnc/observatory_tnc.yml")
    #print(config.get_devices()["FLI-Kepler4040"]["device_config"])
    #print(config.get_devices()["FLI-Kepler4040"]["device_config"]["CAPABILITIES"][1]["attributes"]["manufacturer"])
    #print(config.get_devices()["FLI-Kepler4040"]["device_config"]["CAPABILITIES"])
    #print(config.get_devices()["AstroMecCA-TM350"]["device_config"]["CAPABILITIES"])
dd54dc29   Alexis Koralewski   Updating schemas,...
835
836
837
if __name__ == "__main__": 

    main()