1

"""

     2

Base definitions for beremiz plugins

     3

"""

     4

     5

import os,sys,traceback

     6

import time

     7

import plugins

     8

import types

     9

import shutil

    10

from xml.dom import minidom

    11

import wx

    12

    13

#Quick hack to be able to find Beremiz IEC tools. Should be config params.

    14

base_folder = os.path.split(sys.path[0])[0]

    15

    16

from xmlclass import GenerateClassesFromXSDstring

    17

from wxPopen import ProcessLogger

    18

    19

from PLCControler import PLCControler, LOCATION_PLUGIN, LOCATION_MODULE, LOCATION_GROUP, LOCATION_VAR_INPUT, LOCATION_VAR_OUTPUT, LOCATION_VAR_MEMORY

    20

    21

_BaseParamsClass = GenerateClassesFromXSDstring("""<?xml version="1.0" encoding="ISO-8859-1" ?>

    22

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

    23

          <xsd:element name="BaseParams">

    24

            <xsd:complexType>

    25

              <xsd:attribute name="Name" type="xsd:string" use="optional" default="__unnamed__"/>

    26

              <xsd:attribute name="IEC_Channel" type="xsd:integer" use="required"/>

    27

              <xsd:attribute name="Enabled" type="xsd:boolean" use="optional" default="true"/>

    28

            </xsd:complexType>

    29

          </xsd:element>

    30

        </xsd:schema>""")["BaseParams"]

    31

    32

NameTypeSeparator = '@'

    33

    34

class MiniTextControler:

    35

    36

    def __init__(self, filepath):

    37

        self.FilePath = filepath

    38

    39

    def SetEditedElementText(self, tagname, text):

    40

        file = open(self.FilePath, "w")

    41

        file.write(text)

    42

        file.close()

    43

    44

    def GetEditedElementText(self, tagname, debug = False):

    45

        if os.path.isfile(self.FilePath):

    46

            file = open(self.FilePath, "r")

    47

            text = file.read()

    48

            file.close()

    49

            return text

    50

        return ""

    51

    52

    def GetEditedElementInterfaceVars(self, tagname, debug = False):

    53

        return []

    54

    55

    def GetEditedElementType(self, tagname, debug = False):

    56

        return "program"

    57

    58

    def GetBlockTypes(self, tagname = "", debug = False):

    59

        return []

    60

    61

    def GetDataTypes(self, tagname = "", basetypes = True, only_locatables = False, debug = False):

    62

        return []

    63

    64

    def GetEnumeratedDataValues(self, debug = False):

    65

        return []

    66

    67

    def StartBuffering(self):

    68

        pass

    69

    70

    def EndBuffering(self):

    71

        pass

    72

    73

    def BufferProject(self):

    74

        pass

    75

    76

# helper func to get path to images

    77

def opjimg(imgname):

    78

    return os.path.join(base_folder, "beremiz", "images",imgname)

    79

    80

# helper func to check path write permission

    81

def CheckPathPerm(path):

    82

    if path is None or not os.path.isdir(path):

    83

        return False

    84

    for root, dirs, files in os.walk(path):

    85

         for name in files:

    86

             if os.access(root, os.W_OK) is not True or os.access(os.path.join(root, name), os.W_OK) is not True:

    87

                 return False

    88

    return True

    89

    90

class PlugTemplate:

    91

    """

    92

    This class is the one that define plugins.

    93

    """

    94

    95

    XSD = None

    96

    PlugChildsTypes = []

    97

    PlugMaxCount = None

    98

    PluginMethods = []

    99

    LibraryControler = None

   100

    EditorType = None

   101

   102

    def _AddParamsMembers(self):

   103

        self.PlugParams = None

   104

        if self.XSD:

   105

            self.Classes = GenerateClassesFromXSDstring(self.XSD)

   106

            Classes = [(name, XSDclass) for name, XSDclass in self.Classes.items() if XSDclass.IsBaseClass]

   107

            if len(Classes) == 1:

   108

                name, XSDclass = Classes[0]

   109

                obj = XSDclass()

   110

                self.PlugParams = (name, obj)

   111

                setattr(self, name, obj)

   112

   113

    def __init__(self):

   114

        # Create BaseParam 

   115

        self.BaseParams = _BaseParamsClass()

   116

        self.MandatoryParams = ("BaseParams", self.BaseParams)

   117

        self._AddParamsMembers()

   118

        self.PluggedChilds = {}

   119

        self._View = None

   120

        # copy PluginMethods so that it can be later customized

   121

        self.PluginMethods = [dic.copy() for dic in self.PluginMethods]

   122

        self.LoadSTLibrary()

   123

   124

    def PluginBaseXmlFilePath(self, PlugName=None):

   125

        return os.path.join(self.PlugPath(PlugName), "baseplugin.xml")

   126

   127

    def PluginXmlFilePath(self, PlugName=None):

   128

        return os.path.join(self.PlugPath(PlugName), "plugin.xml")

   129

   130

    def PluginLibraryFilePath(self):

   131

        return os.path.join(self.PluginPath(), "pous.xml")

   132

   133

    def PluginPath(self):

   134

        return os.path.join(self.PlugParent.PluginPath(), self.PlugType)

   135

   136

    def PlugPath(self,PlugName=None):

   137

        if not PlugName:

   138

            PlugName = self.PlugName()

   139

        return os.path.join(self.PlugParent.PlugPath(),

   140

                            PlugName + NameTypeSeparator + self.PlugType)

   141

   142

    def PlugName(self):

   143

        return self.BaseParams.getName()

   144

   145

    def PlugEnabled(self):

   146

        return self.BaseParams.getEnabled()

   147

   148

    def PlugFullName(self):

   149

        parent = self.PlugParent.PlugFullName()

   150

        if parent != "":

   151

            return parent + "." + self.PlugName()

   152

        return self.BaseParams.getName()

   153

   154

    def GetIconPath(self, name):

   155

        return opjimg(name)

   156

   157

    def PlugTestModified(self):

   158

        return self.ChangesToSave

   159

   160

    def ProjectTestModified(self):

   161

        """

   162

        recursively check modified status

   163

        """

   164

        if self.PlugTestModified():

   165

            return True

   166

   167

        for PlugChild in self.IterChilds():

   168

            if PlugChild.ProjectTestModified():

   169

                return True

   170

   171

        return False

   172

   173

    def RemoteExec(self, script, **kwargs):

   174

        return self.PlugParent.RemoteExec(script, **kwargs)

   175

   176

    def OnPlugSave(self):

   177

        #Default, do nothing and return success

   178

        return True

   179

   180

    def GetParamsAttributes(self, path = None):

   181

        if path:

   182

            parts = path.split(".", 1)

   183

            if self.MandatoryParams and parts[0] == self.MandatoryParams[0]:

   184

                return self.MandatoryParams[1].getElementInfos(parts[0], parts[1])

   185

            elif self.PlugParams and parts[0] == self.PlugParams[0]:

   186

                return self.PlugParams[1].getElementInfos(parts[0], parts[1])

   187

        else:

   188

            params = []

   189

            if wx.VERSION < (2, 8, 0) and self.MandatoryParams:

   190

                params.append(self.MandatoryParams[1].getElementInfos(self.MandatoryParams[0]))

   191

            if self.PlugParams:

   192

                params.append(self.PlugParams[1].getElementInfos(self.PlugParams[0]))

   193

            return params

   194

   195

    def SetParamsAttribute(self, path, value):

   196

        self.ChangesToSave = True

   197

        # Filter IEC_Channel and Name, that have specific behavior

   198

        if path == "BaseParams.IEC_Channel":

   199

            old_leading = ".".join(map(str, self.GetCurrentLocation()))

   200

            new_value = self.FindNewIEC_Channel(value)

   201

            new_leading = ".".join(map(str, self.PlugParent.GetCurrentLocation() + (new_value,)))

   202

            self.GetPlugRoot().UpdateProjectVariableLocation(old_leading, new_leading)

   203

            return new_value, True

   204

        elif path == "BaseParams.Name":

   205

            res = self.FindNewName(value)

   206

            self.PlugRequestSave()

   207

            return res, True

   208

   209

        parts = path.split(".", 1)

   210

        if self.MandatoryParams and parts[0] == self.MandatoryParams[0]:

   211

            self.MandatoryParams[1].setElementValue(parts[1], value)

   212

        elif self.PlugParams and parts[0] == self.PlugParams[0]:

   213

            self.PlugParams[1].setElementValue(parts[1], value)

   214

        return value, False

   215

   216

    def PlugMakeDir(self):

   217

        os.mkdir(self.PlugPath())

   218

   219

    def PlugRequestSave(self):

   220

        if self.GetPlugRoot().CheckProjectPathPerm(False):

   221

            # If plugin do not have corresponding directory

   222

            plugpath = self.PlugPath()

   223

            if not os.path.isdir(plugpath):

   224

                # Create it

   225

                os.mkdir(plugpath)

   226

   227

            # generate XML for base XML parameters controller of the plugin

   228

            if self.MandatoryParams:

   229

                BaseXMLFile = open(self.PluginBaseXmlFilePath(),'w')

   230

                BaseXMLFile.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n")

   231

                BaseXMLFile.write(self.MandatoryParams[1].generateXMLText(self.MandatoryParams[0], 0).encode("utf-8"))

   232

                BaseXMLFile.close()

   233

   234

            # generate XML for XML parameters controller of the plugin

   235

            if self.PlugParams:

   236

                XMLFile = open(self.PluginXmlFilePath(),'w')

   237

                XMLFile.write("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n")

   238

                XMLFile.write(self.PlugParams[1].generateXMLText(self.PlugParams[0], 0).encode("utf-8"))

   239

                XMLFile.close()

   240

   241

            # Call the plugin specific OnPlugSave method

   242

            result = self.OnPlugSave()

   243

            if not result:

   244

                return _("Error while saving \"%s\"\n")%self.PlugPath()

   245

   246

            # mark plugin as saved

   247

            self.ChangesToSave = False

   248

            # go through all childs and do the same

   249

            for PlugChild in self.IterChilds():

   250

                result = PlugChild.PlugRequestSave()

   251

                if result:

   252

                    return result

   253

        return None

   254

   255

    def PlugImport(self, src_PlugPath):

   256

        shutil.copytree(src_PlugPath, self.PlugPath)

   257

        return True

   258

   259

    def PlugGenerate_C(self, buildpath, locations):

   260

        """

   261

        Generate C code

   262

        @param locations: List of complete variables locations \

   263

            [{"IEC_TYPE" : the IEC type (i.e. "INT", "STRING", ...)

   264

            "NAME" : name of the variable (generally "__IW0_1_2" style)

   265

            "DIR" : direction "Q","I" or "M"

   266

            "SIZE" : size "X", "B", "W", "D", "L"

   267

            "LOC" : tuple of interger for IEC location (0,1,2,...)

   268

            }, ...]

   269

        @return: [(C_file_name, CFLAGS),...] , LDFLAGS_TO_APPEND

   270

        """

   271

        self.GetPlugRoot().logger.write_warning(".".join(map(lambda x:str(x), self.GetCurrentLocation())) + " -> Nothing to do\n")

   272

        return [],"",False

   273

   274

    def _Generate_C(self, buildpath, locations):

   275

        # Generate plugins [(Cfiles, CFLAGS)], LDFLAGS, DoCalls, extra_files

   276

        # extra_files = [(fname,fobject), ...]

   277

        gen_result = self.PlugGenerate_C(buildpath, locations)

   278

        PlugCFilesAndCFLAGS, PlugLDFLAGS, DoCalls = gen_result[:3]

   279

        extra_files = gen_result[3:]

   280

        # if some files have been generated put them in the list with their location

   281

        if PlugCFilesAndCFLAGS:

   282

            LocationCFilesAndCFLAGS = [(self.GetCurrentLocation(), PlugCFilesAndCFLAGS, DoCalls)]

   283

        else:

   284

            LocationCFilesAndCFLAGS = []

   285

   286

        # plugin asks for some LDFLAGS

   287

        if PlugLDFLAGS:

   288

            # LDFLAGS can be either string

   289

            if type(PlugLDFLAGS)==type(str()):

   290

                LDFLAGS=[PlugLDFLAGS]

   291

            #or list of strings

   292

            elif type(PlugLDFLAGS)==type(list()):

   293

                LDFLAGS=PlugLDFLAGS[:]

   294

        else:

   295

            LDFLAGS=[]

   296

   297

        # recurse through all childs, and stack their results

   298

        for PlugChild in self.IECSortedChilds():

   299

            new_location = PlugChild.GetCurrentLocation()

   300

            # How deep are we in the tree ?

   301

            depth=len(new_location)

   302

            _LocationCFilesAndCFLAGS, _LDFLAGS, _extra_files = \

   303

                PlugChild._Generate_C(

   304

                    #keep the same path

   305

                    buildpath,

   306

                    # filter locations that start with current IEC location

   307

                    [loc for loc in locations if loc["LOC"][0:depth] == new_location ])

   308

            # stack the result

   309

            LocationCFilesAndCFLAGS += _LocationCFilesAndCFLAGS

   310

            LDFLAGS += _LDFLAGS

   311

            extra_files += _extra_files

   312

   313

        return LocationCFilesAndCFLAGS, LDFLAGS, extra_files

   314

   315

    def PluginTypesFactory(self):

   316

        if self.LibraryControler is not None:

   317

            return [{"name" : self.PlugType, "types": self.LibraryControler.Project}]

   318

        return []

   319

   320

    def ParentsTypesFactory(self):

   321

        return self.PlugParent.ParentsTypesFactory() + self.PluginTypesFactory()

   322

   323

    def PluginsTypesFactory(self):

   324

        list = self.PluginTypesFactory()

   325

        for PlugChild in self.IterChilds():

   326

            list += PlugChild.PluginsTypesFactory()

   327

        return list

   328

   329

    def STLibraryFactory(self):

   330

        if self.LibraryControler is not None:

   331

            program, errors, warnings = self.LibraryControler.GenerateProgram()

   332

            return program + "\n"

   333

        return ""

   334

   335

    def PluginsSTLibraryFactory(self):

   336

        program = self.STLibraryFactory()

   337

        for PlugChild in self.IECSortedChilds():

   338

            program += PlugChild.PluginsSTLibraryFactory()

   339

        return program

   340

   341

    def IterChilds(self):

   342

        for PlugType, PluggedChilds in self.PluggedChilds.items():

   343

            for PlugInstance in PluggedChilds:

   344

                yield PlugInstance

   345

   346

    def IECSortedChilds(self):

   347

        # reorder childs by IEC_channels

   348

        ordered = [(chld.BaseParams.getIEC_Channel(),chld) for chld in self.IterChilds()]

   349

        if ordered:

   350

            ordered.sort()

   351

            return zip(*ordered)[1]

   352

        else:

   353

            return []

   354

   355

    def _GetChildBySomething(self, something, toks):

   356

        for PlugInstance in self.IterChilds():

   357

            # if match component of the name

   358

            if getattr(PlugInstance.BaseParams, something) == toks[0]:

   359

                # if Name have other components

   360

                if len(toks) >= 2:

   361

                    # Recurse in order to find the latest object

   362

                    return PlugInstance._GetChildBySomething( something, toks[1:])

   363

                # No sub name -> found

   364

                return PlugInstance

   365

        # Not found

   366

        return None

   367

   368

    def GetChildByName(self, Name):

   369

        if Name:

   370

            toks = Name.split('.')

   371

            return self._GetChildBySomething("Name", toks)

   372

        else:

   373

            return self

   374

   375

    def GetChildByIECLocation(self, Location):

   376

        if Location:

   377

            return self._GetChildBySomething("IEC_Channel", Location)

   378

        else:

   379

            return self

   380

   381

    def GetCurrentLocation(self):

   382

        """

   383

        @return:  Tupple containing plugin IEC location of current plugin : %I0.0.4.5 => (0,0,4,5)

   384

        """

   385

        return self.PlugParent.GetCurrentLocation() + (self.BaseParams.getIEC_Channel(),)

   386

   387

    def GetCurrentName(self):

   388

        """

   389

        @return:  String "ParentParentName.ParentName.Name"

   390

        """

   391

        return  self.PlugParent._GetCurrentName() + self.BaseParams.getName()

   392

   393

    def _GetCurrentName(self):

   394

        """

   395

        @return:  String "ParentParentName.ParentName.Name."

   396

        """

   397

        return  self.PlugParent._GetCurrentName() + self.BaseParams.getName() + "."

   398

   399

    def GetPlugRoot(self):

   400

        return self.PlugParent.GetPlugRoot()

   401

   402

    def GetFullIEC_Channel(self):

   403

        return ".".join([str(i) for i in self.GetCurrentLocation()]) + ".x"

   404

   405

    def GetLocations(self):

   406

        location = self.GetCurrentLocation()

   407

        return [loc for loc in self.PlugParent.GetLocations() if loc["LOC"][0:len(location)] == location]

   408

   409

    def GetVariableLocationTree(self):

   410

        '''

   411

        This function is meant to be overridden by plugins.

   412

   413

        It should returns an list of dictionaries

   414

   415

        - IEC_type is an IEC type like BOOL/BYTE/SINT/...

   416

        - location is a string of this variable's location, like "%IX0.0.0"

   417

        '''

   418

        children = []

   419

        for child in self.IECSortedChilds():

   420

            children.append(child.GetVariableLocationTree())

   421

        return {"name": self.BaseParams.getName(),

   422

                "type": LOCATION_PLUGIN,

   423

                "location": self.GetFullIEC_Channel(),

   424

                "children": children}

   425

   426

    def FindNewName(self, DesiredName):

   427

        """

   428

        Changes Name to DesiredName if available, Name-N if not.

   429

        @param DesiredName: The desired Name (string)

   430

        """

   431

        # Get Current Name

   432

        CurrentName = self.BaseParams.getName()

   433

        # Do nothing if no change

   434

        #if CurrentName == DesiredName: return CurrentName

   435

        # Build a list of used Name out of parent's PluggedChilds

   436

        AllNames=[]

   437

        for PlugInstance in self.PlugParent.IterChilds():

   438

            if PlugInstance != self:

   439

                AllNames.append(PlugInstance.BaseParams.getName())

   440

   441

        # Find a free name, eventually appending digit

   442

        res = DesiredName

   443

        suffix = 1

   444

        while res in AllNames:

   445

            res = "%s-%d"%(DesiredName, suffix)

   446

            suffix += 1

   447

   448

        # Get old path

   449

        oldname = self.PlugPath()

   450

        # Check previous plugin existance

   451

        dontexist = self.BaseParams.getName() == "__unnamed__"

   452

        # Set the new name

   453

        self.BaseParams.setName(res)

   454

        # Rename plugin dir if exist

   455

        if not dontexist:

   456

            shutil.move(oldname, self.PlugPath())

   457

        # warn user he has two left hands

   458

        if DesiredName != res:

   459

            self.GetPlugRoot().logger.write_warning(_("A child names \"%s\" already exist -> \"%s\"\n")%(DesiredName,res))

   460

        return res

   461

   462

    def GetAllChannels(self):

   463

        AllChannels=[]

   464

        for PlugInstance in self.PlugParent.IterChilds():

   465

            if PlugInstance != self:

   466

                AllChannels.append(PlugInstance.BaseParams.getIEC_Channel())

   467

        AllChannels.sort()

   468

        return AllChannels

   469

   470

    def FindNewIEC_Channel(self, DesiredChannel):

   471

        """

   472

        Changes IEC Channel number to DesiredChannel if available, nearest available if not.

   473

        @param DesiredChannel: The desired IEC channel (int)

   474

        """

   475

        # Get Current IEC channel

   476

        CurrentChannel = self.BaseParams.getIEC_Channel()

   477

        # Do nothing if no change

   478

        #if CurrentChannel == DesiredChannel: return CurrentChannel

   479

        # Build a list of used Channels out of parent's PluggedChilds

   480

        AllChannels = self.GetAllChannels()

   481

   482

        # Now, try to guess the nearest available channel

   483

        res = DesiredChannel

   484

        while res in AllChannels: # While channel not free

   485

            if res < CurrentChannel: # Want to go down ?

   486

                res -=  1 # Test for n-1