1 # opcua/client.py

     2 

     3 from __future__ import absolute_import

     4 

     5 import os

     6 

     7 from editors.ConfTreeNodeEditor import ConfTreeNodeEditor

     8 from .opcua_client_maker import OPCUAClientPanel, OPCUAClientModel

     9 

    10 import util.paths as paths

    11 

    12 # Paths to open62541 assume that 

    13 # - open62541 directory is aside beremiz directory

    14 # - open62541 was just built (not installed)

    15 

    16 Open62541Path = paths.ThirdPartyPath("open62541")

    17 Open62541LibraryPath = os.path.join(Open62541Path,"build","bin") 

    18 Open62541IncludePaths = [os.path.join(Open62541Path, *dirs) for dirs in [

    19     ("plugins","include"),

    20     ("build","src_generated"),

    21     ("include",),

    22     ("arch",)]]

    23 

    24 class OPCUAClientEditor(ConfTreeNodeEditor):

    25     CONFNODEEDITOR_TABS = [

    26         (_("OPC-UA Client"), "CreateOPCUAClient_UI")]

    27 

    28     def Log(self, msg):

    29         self.Controler.GetCTRoot().logger.write(msg)

    30 

    31     def UriGetter(self):

    32         return self.Controler.GetServerURI() 

    33 

    34     def CreateOPCUAClient_UI(self, parent):

    35         return OPCUAClientPanel(parent, self.Controler.GetModelData(), self.Log, self.UriGetter)

    36 

    37 class OPCUAClient(object):

    38     XSD = """<?xml version="1.0" encoding="ISO-8859-1" ?>

    39     <xsd:schema xmlns:xsd="http://www.w3.org/2001/XMLSchema">

    40       <xsd:element name="OPCUAClient">

    41         <xsd:complexType>

    42           <xsd:attribute name="Server_URI" type="xsd:string" use="optional" default="opc.tcp://localhost:4840"/>

    43         </xsd:complexType>

    44       </xsd:element>

    45     </xsd:schema>

    46     """

    47 

    48     EditorType = OPCUAClientEditor

    49 

    50     def __init__(self):

    51         self.modeldata = OPCUAClientModel()

    52 

    53         filepath = self.GetFileName()

    54         if os.path.isfile(filepath):

    55             self.modeldata.LoadCSV(filepath)

    56 

    57     def GetModelData(self):

    58         return self.modeldata

    59     

    60     def GetServerURI(self):

    61         return self.GetParamsAttributes("OPCUAClient.Server_URI")["value"]

    62 

    63     def GetFileName(self):

    64         return os.path.join(self.CTNPath(), 'selected.csv')

    65 

    66     def OnCTNSave(self, from_project_path=None):

    67         self.modeldata.SaveCSV(self.GetFileName())

    68         return True

    69 

    70     def CTNGenerate_C(self, buildpath, locations):

    71         current_location = self.GetCurrentLocation()

    72         locstr = "_".join(map(str, current_location))

    73         c_path = os.path.join(buildpath, "opcua_client__%s.c" % locstr)

    74 

    75         c_code = self.modeldata.GenerateC(c_path, locstr, 

    76             self.GetParamsAttributes("OPCUAClient.Server_URI")["value"])

    77 

    78         with open(c_path, 'wb') as c_file:

    79             c_file.write(c_code)

    80 

    81         LDFLAGS = [' "' + os.path.join(Open62541LibraryPath, "libopen62541.a") + '"']

    82 

    83         CFLAGS = ' '.join(['-I"' + path + '"' for path in Open62541IncludePaths])

    84 

    85         return [(c_path, CFLAGS)], LDFLAGS, True

    86