# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import os

import sys

import getopt

sys.path.append(extension_folder)

AddCatalog(os.path.join(extension_folder, "locale"))

AddBitmapFolder(os.path.join(extension_folder, "images"))

def CheckUpdates(self):

if self.updateinfo_url is not None:

def updateinfoproc():

try:

except Exception:

self.updateinfo = _("update info unavailable.")

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import os

import sys

import shutil

def _init_coll_FileMenu_Items(self, parent):

AppendMenu(parent, help='', id=wx.ID_NEW,

AppendMenu(parent, help='', id=wx.ID_OPEN,

parent.Append(ID_FILEMENURECENTPROJECTS, _("&Recent Projects"), self.RecentProjectsMenu)

parent.AppendSeparator()

parent.Append(wx.ID_ANY, _("&Tutorials and Examples"), self.TutorialsProjectsMenu)

project_list = sorted(os.listdir(exemples_dir))

for idx, dirname in enumerate(project_list):

item = self.TutorialsProjectsMenu.Append(wx.ID_ANY, text, '')

self.Bind(wx.EVT_MENU, OpenExemple, item)

parent.AppendSeparator()

AppendMenu(parent, help='', id=wx.ID_SAVE,

AppendMenu(parent, help='', id=wx.ID_SAVEAS,

AppendMenu(parent, help='', id=wx.ID_CLOSE,

AppendMenu(parent, help='', id=wx.ID_CLOSE_ALL,

parent.AppendSeparator()

AppendMenu(parent, help='', id=wx.ID_PAGE_SETUP,

AppendMenu(parent, help='', id=wx.ID_PREVIEW,

AppendMenu(parent, help='', id=wx.ID_PRINT,

parent.AppendSeparator()

AppendMenu(parent, help='', id=wx.ID_EXIT,

self.Bind(wx.EVT_MENU, self.OnNewProjectMenu, id=wx.ID_NEW)

self.Bind(wx.EVT_MENU, self.OnOpenProjectMenu, id=wx.ID_OPEN)

self.Bind(wx.EVT_MENU, self.OnPrintMenu, id=wx.ID_PRINT)

self.Bind(wx.EVT_MENU, self.OnQuitMenu, id=wx.ID_EXIT)

def _RecursiveAddMenuItems(self, menu, items):

for name, text, helpstr, children in items:

def handler(event):

return wx.MessageBox(

version.GetCommunityHelpMsg(),

wx.OK | wx.ICON_INFORMATION)

self.Bind(wx.EVT_MENU, handler, item)

parent.Append(wx.MenuItem(helpString='', id=wx.ID_ABOUT,

self.Bind(wx.EVT_MENU, self.OnAboutMenu, id=wx.ID_ABOUT)

def _init_coll_ConnectionStatusBar_Fields(self, parent):

elif answer == wx.ID_CANCEL:

return False

window = self.TabsOpened.GetPage(idx)

if not window.CheckSaveBeforeClosing():

return False

def RefreshRecentProjectsMenu(self):

try:

except Exception:

recent_projects = []

self.FileMenu.Enable(ID_FILEMENURECENTPROJECTS, len(recent_projects) > 0)

for idx, projectpath in enumerate(recent_projects):

item = self.RecentProjectsMenu.Append(wx.ID_ANY, text, '')

self.Bind(wx.EVT_MENU, self.GenerateOpenRecentProjectFunction(projectpath), item)

else:

panel = None

if panel != self.LastPanelSelected:

item = self.EditMenu.FindItemByPosition(self.EditMenuSize)

if item is not None:

if item.IsSeparator():

if panel is not None:

panel.RefreshConfNodeMenu(self.EditMenu)

else:

item = self.EditMenu.FindItemByPosition(i)

if item is not None:

if item.IsSeparator():

return cPickle.loads(str(self.Config.Read(entry_name, cPickle.dumps(default))))

def ResetConnectionStatusBar(self):

self.ConnectionStatusBar.SetStatusText('', field)

def ResetView(self):

def RefreshConfigRecentProjects(self, projectpath, err=False):

try:

except Exception:

recent_projects = []

if projectpath in recent_projects:

if not err:

recent_projects.insert(0, projectpath)

self.Config.Write("RecentProjects", cPickle.dumps(

self.Config.Flush()

def ResetPerspective(self):

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import os

import sys

import getopt

# Load extensions

for extention_file, extension_folder in extensions:

sys.path.append(extension_folder)

# Service name is used as an ID for stunnel's PSK

# Some extension may set 'servicename' to a computed ID or Serial Number

new_messages = []

if connector:

for level, count, prev in zip(

if count is not None and prev != count:

if prev is None:

dump_end = max(-1, count - 10)

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import os

import re

import traceback

- ... TODO : document

"""

import os

import traceback

import types

return LocationCFilesAndCFLAGS, LDFLAGS, extra_files

def IterChildren(self):

for CTNInstance in Children:

yield CTNInstance

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

if ordered:

ordered.sort()

else:

return []

"""

# reorganize self.CTNChildrenTypes tuples from (name, CTNClass, Help)

# to ( name, (CTNClass, Help)), an make a dict

# Check that adding this confnode is allowed

try:

CTNClass, CTNHelp = CTNChildrenTypes[CTNType]

def LoadXMLParams(self, CTNName=None):

methode_name = os.path.join(self.CTNPath(CTNName), "methods.py")

if os.path.isfile(methode_name):

ConfNodeName = CTNName if CTNName is not None else self.CTNName()

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import sys

import base64

from future.builtins import \

[

TITLE, EDITORTOOLBAR, FILEMENU, EDITMENU, DISPLAYMENU, PROJECTTREE,

POUINSTANCEVARIABLESPANEL, LIBRARYTREE, SCALING, PAGETITLES

def GetShortcutKeyCallbackFunction(viewer_function):

}

def _init_coll_MenuBar_Menus(self, parent):

def _init_coll_FileMenu_Items(self, parent):

pass

def _init_coll_AddMenu_Items(self, parent, add_config=True):

AppendMenu(parent, help='', id=ID_PLCOPENEDITOREDITMENUADDDATATYPE,

AppendMenu(parent, help='', id=ID_PLCOPENEDITOREDITMENUADDFUNCTION,

AppendMenu(parent, help='', id=ID_PLCOPENEDITOREDITMENUADDFUNCTIONBLOCK,

AppendMenu(parent, help='', id=ID_PLCOPENEDITOREDITMENUADDPROGRAM,

AppendMenu(parent, help='', id=ID_PLCOPENEDITOREDITMENUADDRESOURCE,

if add_config:

AppendMenu(parent, help='', id=ID_PLCOPENEDITOREDITMENUADDCONFIGURATION,

def _init_coll_EditMenu_Items(self, parent):

AppendMenu(parent, help='', id=wx.ID_UNDO,

AppendMenu(parent, help='', id=wx.ID_REDO,

parent.AppendSeparator()

AppendMenu(parent, help='', id=wx.ID_CUT,

AppendMenu(parent, help='', id=wx.ID_COPY,

AppendMenu(parent, help='', id=wx.ID_PASTE,

parent.AppendSeparator()

AppendMenu(parent, help='', id=wx.ID_FIND,

AppendMenu(parent, help='', id=ID_PLCOPENEDITOREDITMENUFINDNEXT,

AppendMenu(parent, help='', id=ID_PLCOPENEDITOREDITMENUFINDPREVIOUS,

parent.AppendSeparator()

AppendMenu(parent, help='', id=ID_PLCOPENEDITOREDITMENUSEARCHINPROJECT,

parent.AppendSeparator()

add_menu = wx.Menu(title='')

self._init_coll_AddMenu_Items(add_menu)

AppendMenu(parent, help='', id=wx.ID_SELECTALL,

AppendMenu(parent, help='', id=wx.ID_DELETE,

self.Bind(wx.EVT_MENU, self.OnUndoMenu, id=wx.ID_UNDO)

self.Bind(wx.EVT_MENU, self.OnRedoMenu, id=wx.ID_REDO)

# self.Bind(wx.EVT_MENU, self.OnEnableUndoRedoMenu, id=ID_PLCOPENEDITOREDITMENUENABLEUNDOREDO)

self.Bind(wx.EVT_MENU, self.OnSelectAllMenu, id=wx.ID_SELECTALL)

self.Bind(wx.EVT_MENU, self.OnDeleteMenu, id=wx.ID_DELETE)

None,

None,

def _init_coll_DisplayMenu_Items(self, parent):

AppendMenu(parent, help='', id=wx.ID_REFRESH,

if self.EnableDebug:

AppendMenu(parent, help='', id=wx.ID_CLEAR,

parent.AppendSeparator()

zoommenu = wx.Menu(title='')

parent.Append(wx.ID_ZOOM_FIT, _("Zoom"), zoommenu)

parent.AppendSeparator()

AppendMenu(parent, help='', id=ID_PLCOPENEDITORDISPLAYMENUSWITCHPERSPECTIVE,

self.Bind(wx.EVT_MENU, self.SwitchPerspective, id=ID_PLCOPENEDITORDISPLAYMENUSWITCHPERSPECTIVE)

AppendMenu(parent, help='', id=ID_PLCOPENEDITORDISPLAYMENUFULLSCREEN,

self.Bind(wx.EVT_MENU, self.SwitchFullScrMode, id=ID_PLCOPENEDITORDISPLAYMENUFULLSCREEN)

AppendMenu(parent, help='', id=ID_PLCOPENEDITORDISPLAYMENURESETPERSPECTIVE,

self.Bind(wx.EVT_MENU, self.OnResetPerspective, id=ID_PLCOPENEDITORDISPLAYMENURESETPERSPECTIVE)

self.Bind(wx.EVT_MENU, self.OnRefreshMenu, id=wx.ID_REFRESH)

# -------------------------------------------------------------------------------

def GetTabInfos(self, tab):

if page_ref == tab:

return ("main", page_name)

return None

pos = child.GetPosition()

tab = {"pos": (pos.x, pos.y), "pages": []}

tab_size = child.GetSize()

page = child.GetWindowFromIdx(page_idx)

if "size" not in tab:

tab["size"] = (tab_size[0], tab_size[1] + page.GetSize()[1])

self.AUIManager.LoadPerspective(self.DefaultPerspective["perspective"])

for notebook in [self.LeftNoteBook, self.BottomNoteBook, self.RightNoteBook]:

notebook.RemovePage(0)

notebooks = self.DefaultPerspective["notebooks"]

return self.DrawingMode

def RefreshScaling(self):

editor = self.TabsOpened.GetPage(i)

editor.RefreshScaling()

self.RefreshTabCtrlEvent()

def DeletePage(self, window):

if self.TabsOpened.GetPage(idx) == window:

self.TabsOpened.DeletePage(idx)

self.RefreshTabCtrlEvent()

"""Function that fix difference in deleting all tabs between

wx.Notebook and wx.aui.AUINotebook.

"""

self.TabsOpened.DeletePage(0)

self.RefreshTabCtrlEvent()

elif answer == wx.ID_CANCEL:

return False

window = self.TabsOpened.GetPage(idx)

if not window.CheckSaveBeforeClosing():

return False

window = self.TabsOpened.GetPage(selected)

data = wx.PrintDialogData(self.PrintData)

properties = self.Controler.GetProjectProperties(window.IsDebugging())

margins = (self.PageSetupData.GetMarginTopLeft(), self.PageSetupData.GetMarginBottomRight())

printout = GraphicPrintout(window, page_size, margins, True)

printout2 = GraphicPrintout(window, page_size, margins, True)

dialog_data = wx.PrintDialogData(self.PrintData)

dialog_data.SetToPage(1)

properties = self.Controler.GetProjectProperties(window.IsDebugging())

margins = (self.PageSetupData.GetMarginTopLeft(), self.PageSetupData.GetMarginBottomRight())

printer = wx.Printer(dialog_data)

printout = GraphicPrintout(window, page_size, margins)

self.EditMenu.Enable(wx.ID_DELETE, False)

def CloseTabsWithoutModel(self, refresh=True):

idxs.reverse()

for idx in idxs:

window = self.TabsOpened.GetPage(idx)

self._Refresh(FILEMENU, EDITMENU, DISPLAYMENU, EDITORTOOLBAR)

def RefreshEditorNames(self, old_tagname, new_tagname):

editor = self.TabsOpened.GetPage(i)

if editor.GetTagName() == old_tagname:

editor.SetTagName(new_tagname)

def IsOpened(self, tagname):

if self.TabsOpened.GetPage(idx).IsViewing(tagname):

return idx

return None

def RefreshPageTitles(self):

window = self.TabsOpened.GetPage(idx)

icon = window.GetIcon()

if icon is not None:

if root is not None and root.IsOk():

words = tagname.split("::")

result = self.RecursiveProjectTreeItemSelection(

return result

def RecursiveProjectTreeItemSelection(self, root, items):

if old_selected != openedidx:

if old_selected >= 0:

self.TabsOpened.GetPage(old_selected).ResetBuffer()

window = self.TabsOpened.GetPage(i)

if window == new_window:

self.TabsOpened.SetSelection(i)

def CloseObsoleteDebugTabs(self):

if self.EnableDebug:

idxs.reverse()

for idx in idxs:

editor = self.TabsOpened.GetPage(idx)

if highlight_type is None:

self.Highlights = {}

else:

self.RefreshProjectTree()

viewer = self.TabsOpened.GetPage(i)

viewer.ClearHighlights(highlight_type)

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import util.paths as paths

from POULibrary import SimplePOULibraryFactory

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

from copy import deepcopy

import os

import re

self.MinIndex = 0

self.MaxIndex = 0

# Initialising buffer with currentstate at the first place

if i == 0:

self.Buffer.append(currentstate)

else:

for _sectioname, blocktype in self.TotalTypesDict.get(typename, []):

if inputs is not None and inputs != "undefined":

block_inputs = tuple([var_type for _name, var_type, _modifier in blocktype["inputs"]])

return blocktype

else:

if result_blocktype:

if project is not None and words[0] in ["P", "T", "A"]:

name = words[1]

blocktypes = []

for _sectioname, block in blocks:

if block["type"] == "functionBlock":

blocktypes.append(block["name"])

result = project.getpou(typename)

if result is not None:

return result

result = standardlibrary.getpou(typename)

if result is not None:

return result

# Return Subrange types

def GetSubrangeBaseTypes(self, exclude, debug=False):

project = self.GetProject(debug)

if project is not None:

subrange_basetypes.extend(

new_pos[0] -= width // 2

new_pos[1] -= height // 2

else:

if scaling[0] != 0 and scaling[1] != 0:

minx = round(min_pos[0])

if int(min_pos[0]) == round(min_pos[0]):

minx += 1

self.ChangeEditedElementPouVar(tagname, old_type, old_name, new_type, new_name)

elif new_name != old_name:

self.ChangeEditedElementPouVar(tagname, old_type, old_name, new_type, new_name)

if param == "name":

if value != "":

block.setinstanceName(value)

variable = element.getinstance(id)

if variable is None:

return

if param == "name":

variable.setexpression(value)

elif param == "executionOrder" and variable.getexecutionOrderId() != value:

connection = element.getinstance(id)

if connection is None:

return

if param == "name":

connection.setname(value)

elif param == "height":

element = self.GetEditedElement(tagname)

if element is not None:

comment = element.getinstance(id)

if param == "content":

comment.setcontentText(value)

elif param == "height":

powerrail = element.getinstance(id)

if powerrail is None:

return

if param == "height":

powerrail.setheight(value)

elif param == "width":

contact = element.getinstance(id)

if contact is None:

return

if param == "name":

contact.setvariable(value)

elif param == "type":

coil = element.getinstance(id)

if coil is None:

return

if param == "name":

coil.setvariable(value)

elif param == "type":

step = element.getinstance(id)

if step is None:

return

if param == "name":

step.setname(value)

elif param == "initial":

transition = element.getinstance(id)

if transition is None:

return

if param == "type" and value != "connection":

transition.setconditionContent(value, infos["condition"])

elif param == "height":

divergence = element.getinstance(id)

if divergence is None:

return

if param == "height":

divergence.setheight(value)

elif param == "width":

jump = element.getinstance(id)

if jump is None:

return

if param == "target":

jump.settargetName(value)

elif param == "height":

actionBlock = element.getinstance(id)

if actionBlock is None:

return

if param == "actions":

actionBlock.setactions(value)

elif param == "height":

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import re

from functools import reduce

from six.moves import xrange

while lines[line_num][spaces] == " ":

spaces += 1

indent = ""

indent += " "

for line in lines:

if line != "":

# Generate a POU defined and used in text

def GeneratePouProgramInText(self, text):

model = re.compile("(?:^|[^0-9^A-Z])%s(?:$|[^0-9^A-Z])" % pou_name.upper())

if model.search(text) is not None:

self.GeneratePouProgram(pou_name)

if len(self.DatatypeComputed) > 0:

self.Program += [("TYPE\n", ())]

# Generate every data types defined

log("Generate Data Type %s"%datatype_name)

self.GenerateDataType(datatype_name)

self.Program += [("END_TYPE\n\n", ())]

# Generate every POUs defined

log("Generate POU %s"%pou_name)

self.GeneratePouProgram(pou_name)

if noconfig:

if connected is not None and connected not in self.ConnectionTypes:

for connection in self.ExtractRelatedConnections(connected):

self.ConnectionTypes[connection] = itype

related = []

for connection in connections:

connection_type = self.ConnectionTypes.get(connection)

def FactorizePaths(self, paths):

same_paths = {}

factorized_paths = []

for num, path in enumerate(paths):

if isinstance(path, list):

else:

factorized_paths.append(path)

uncomputed_index.remove(num)

if len(elements) > 1:

elements_paths = self.FactorizePaths([path for path, num in elements])

if len(elements_paths) > 1:

def GenerateSFCStep(self, step, pou):

step_name = step.getname()

if step.getinitialStep():

self.InitialSteps.append(step_name)

step_infos = {"id": step.getlocalId(),

instances.extend(self.ExtractConvergenceInputs(transition, pou))

for instance in instances:

self.GenerateSFCTransition(instance, pou)

target_info = (self.TagName, "transition", instance.getlocalId(), "to", step_infos["id"])

self.SFCNetworks["Transitions"][instance]["to"].append([(step_name, target_info)])

instances.extend(self.ExtractConvergenceInputs(transition, pou))

for instance in instances:

self.GenerateSFCTransition(instance, pou)

target_info = (self.TagName, "jump", jump.getlocalId(), "target")

self.SFCNetworks["Transitions"][instance]["to"].append([(jump_target, target_info)])

step = body.getcontentInstance(stepLocalId)

self.GenerateSFCStep(step, pou)

step_name = step.getname()

actions = actionBlock.getactions()

for i, action in enumerate(actions):

action_infos = {"id": actionBlock.getlocalId(),

self.SFCNetworks["Steps"][step_name]["actions"].append(action_infos)

def GenerateSFCAction(self, action_name, pou):

actionContent = pou.getaction(action_name)

if actionContent is not None:

previous_tagname = self.TagName

self.TagName = previous_tagname

def GenerateSFCTransition(self, transition, pou):

steps = []

connections = transition.connectionPointIn.getconnections()

if connections is not None and len(connections) == 1:

for step in steps:

self.GenerateSFCStep(step, pou)

step_name = step.getname()

transition_infos["from"].append([(step_name, (self.TagName, "transition", transition.getlocalId(), "from", step.getlocalId()))])

self.SFCNetworks["Steps"][step_name]["transitions"].append(transition)

def ComputeSFCStep(self, step_name):

step_infos = self.SFCNetworks["Steps"].pop(step_name)

self.Program += [(self.CurrentIndent, ())]

if step_infos["initial"]:

self.ComputeSFCTransition(transition)

def ComputeSFCAction(self, action_name):

action_content, action_info = self.SFCNetworks["Actions"].pop(action_name)

self.Program += [("%sACTION " % self.CurrentIndent, ()),

(action_name, action_info),

self.Program += [("%sEND_ACTION\n\n" % self.CurrentIndent, ())]

def ComputeSFCTransition(self, transition):

transition_infos = self.SFCNetworks["Transitions"].pop(transition)

self.Program += [("%sTRANSITION" % self.CurrentIndent, ())]

if transition_infos["priority"] is not None:

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import os

import sys

import getopt

def _init_coll_FileMenu_Items(self, parent):

AppendMenu(parent, help='', id=wx.ID_NEW,

AppendMenu(parent, help='', id=wx.ID_OPEN,

AppendMenu(parent, help='', id=wx.ID_CLOSE,

AppendMenu(parent, help='', id=wx.ID_CLOSE_ALL,

parent.AppendSeparator()

AppendMenu(parent, help='', id=wx.ID_SAVE,

AppendMenu(parent, help='', id=wx.ID_SAVEAS,

AppendMenu(parent, help='', id=ID_PLCOPENEDITORFILEMENUGENERATE,

AppendMenu(parent, help='', id=ID_PLCOPENEDITORFILEMENUGENERATEAS,

parent.AppendSeparator()

AppendMenu(parent, help='', id=wx.ID_PAGE_SETUP,

AppendMenu(parent, help='', id=wx.ID_PREVIEW,

AppendMenu(parent, help='', id=wx.ID_PRINT,

parent.AppendSeparator()

AppendMenu(parent, help='', id=wx.ID_PROPERTIES,

parent.AppendSeparator()

AppendMenu(parent, help='', id=wx.ID_EXIT,

self.Bind(wx.EVT_MENU, self.OnNewProjectMenu, id=wx.ID_NEW)

self.Bind(wx.EVT_MENU, self.OnOpenProjectMenu, id=wx.ID_OPEN)

self.Bind(wx.EVT_MENU, self.OnPropertiesMenu, id=wx.ID_PROPERTIES)

self.Bind(wx.EVT_MENU, self.OnQuitMenu, id=wx.ID_EXIT)

def _init_coll_HelpMenu_Items(self, parent):

AppendMenu(parent, help='', id=wx.ID_HELP,

# AppendMenu(parent, help='', id=wx.ID_HELP_CONTENTS,

# kind=wx.ITEM_NORMAL, text=u'PLCOpen\tF2')

# AppendMenu(parent, help='', id=wx.ID_HELP_CONTEXT,

def handler(event):

return wx.MessageBox(

version.GetCommunityHelpMsg(),

wx.OK | wx.ICON_INFORMATION)

self.Bind(wx.EVT_MENU, handler, menu_entry)

AppendMenu(parent, help='', id=wx.ID_ABOUT,

self.Bind(wx.EVT_MENU, self.OnPLCOpenEditorMenu, id=wx.ID_HELP)

# self.Bind(wx.EVT_MENU, self.OnPLCOpenMenu, id=wx.ID_HELP_CONTENTS)

self.Bind(wx.EVT_MENU, self.OnAboutMenu, id=wx.ID_ABOUT)

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

from weakref import ref

# Exception type for problems that user has to take action in order to fix

# See COPYING file for copyrights details.

import os

import time

import json

# PSK Management Data model :

# [[ID,Desc, LastKnownURI, LastConnect]]

def _pskpath(project_path):

"""

import os

import traceback

import time

from datetime import datetime

from weakref import WeakKeyDictionary

from functools import reduce

from distutils.dir_util import copy_tree

from six.moves import xrange

LocatedCCodeAndFlags.append(res[:2])

if len(res) > 2:

Extras.extend(res[2:])

# Update PLCOpenEditor ConfNode Block types from loaded confnodes

def RefreshConfNodesBlockLists(self):

_("Error : At least one configuration and one resource must be declared in PLC !\n"))

return False

# transform those base names to full names with path

# prepend beremiz include to configuration header

H_files = [fname for fname in result.splitlines() if fname[

-2:] == ".h" or fname[-2:] == ".H"]

H_files.remove("LOCATED_VARIABLES.h")

for H_file in H_files:

with open(H_file, 'r') as original:

data = original.read()

for line in ListGroup[0]:

# Split and Maps each field to dictionnary entries

attrs = dict(

# Truncate "C_path" to remove conf an resources names

attrs["C_path"] = '__'.join(

attrs["C_path"].split(".", 2)[1:])

for line in ListGroup[1]:

# Split and Maps each field to dictionnary entries

attrs = dict(

# Truncate "C_path" to remove conf an resources names

parts = attrs["C_path"].split(".", 2)

if len(parts) > 2:

"""

# filter location that are related to code that will be called

# in retreive, publish, init, cleanup

# Generate main, based on template

if not self.BeremizRoot.getDisable_Extensions():

"retrieve_calls": "\n ".join([

"__retrieve_%s();" % locstr for locstr in locstrs]),

"publish_calls": "\n ".join([ # Call publish in reverse order

"init_calls": "\n ".join([

"init_level=%d; " % (i + 1) +

"if((res = __init_%s(argc,argv))){" % locstr +

"return res;}" for i, locstr in enumerate(locstrs)]),

"cleanup_calls": "\n ".join([

"if(init_level >= %d) " % i +

}

else:

plc_main_code = targets.GetCode("plc_main_head.c") % {

if editor_name == "":

if len(editors) == 1:

elif len(editors) > 0:

dialog = wx.SingleChoiceDialog(

self.AppFrame,

_("Select an editor:"),

self._IECRawCodeView = None

if self._ProjectFilesView == view:

self._ProjectFilesView = None

self._FileEditors.pop(view.GetFilePath())

def _Clean(self):

allmethods = self.DefaultMethods.copy()

allmethods.update(

self.MethodsFromStatus.get(status, {}))

self.ShowMethod(method, active)

self.previous_plcstate = status

if self.AppFrame is not None:

debug_vars = UnpackDebugBuffer(

debug_buff, self.TracedIECTypes)

if debug_vars is not None:

self.TracedIECPath,

self.DebugValuesBuffers,

debug_vars):

buffers, self.DebugValuesBuffers = (self.DebugValuesBuffers,

ticks, self.DebugTicks = self.DebugTicks, []

self.TracedIECTypes = []

if self._connector is not None and self.debug_status != PlcStatus.Broken:

IECPathsToPop = []

WeakCallableDict, _data_log, _status, fvalue, _buffer_list = data_tuple

if len(WeakCallableDict) == 0:

# Callable Dict is empty.

if Idxs:

Idxs.sort()

self.TracedIECPath = IdxsT[3]

self.TracedIECTypes = IdxsT[1]

if res is not None and res > 0:

self.DebugToken = res

else:

else:

IECdebug_data[4] = reduce(

lambda x, y: x | y,

False)

self.AppendDebugUpdate()

if data_tuple is not None:

WeakCallableDict, _data_log, _status, _fvalue, buffer_list = data_tuple

# data_log.append((debug_tick, value))

function = getattr(weakcallable, function_name, None)

if function is not None:

# FIXME: apparently, despite of weak ref objects,

# This file is part of Beremiz.

# See COPYING file for copyrights details.

from lxml import etree

class XSLTransform(object):

extensions={("beremiz", name): call for name, call in xsltext})

def transform(self, root, profile_run=False, **kwargs):

# print(self.xslt.error_log)

return res

# used in safety-critical situations without a full and competent review.

from bacnet.bacnet import *

# This code is made available on the understanding that it will not be

# used in safety-critical situations without a full and competent review.

import os

from collections import Counter

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import wx.stc as stc

from controls.CustomStyledTextCtrl import faces

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

from c_ext.c_ext import *

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import os

from c_ext.CFileEditor import CFileEditor

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import wx

from networkeditortemplate import NetworkEditorTemplate

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import wx

from subindextable import EditingPanel

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

from canfestival.canfestival import *

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import os

import sys

import shutil

def GetVariableLocationTree(self):

current_location = self.GetCurrentLocation()

nodeindexes.sort()

children = []

children += [GetSlaveLocationTree(self.Manager.GetCurrentNodeCopy(),

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import os

import sys

import getopt

# Translation between IEC types and Can Open types

IECToCOType = {

VariableIncrement = 0x100

VariableStartIndex = {TPDO: 0x2000, RPDO: 0x4000}

VariableDirText = {TPDO: "__I", RPDO: "__Q"}

TrashVariables = [(1, 0x01), (8, 0x05), (16, 0x06), (32, 0x07), (64, 0x1B)]

"""

data = ("%" + str(size * 2) + "." + str(size * 2) + "X") % value

list_car.reverse()

return "".join([chr(int(car, 16)) for car in list_car])

# Dictionary of location informations classed by name

self.MasterMapping = {}

# List of COB IDs available

# Dictionary of mapping value where unexpected variables are stored

self.TrashVariables = {}

# Dictionary of pointed variables

values = self.NodeList.GetSlaveNodeEntry(nodeid, index + 0x200)

if values is not None and values[0] > 0:

# Check that all subindex upper than 0 equal 0 => configurable PDO

cobid = self.NodeList.GetSlaveNodeEntry(nodeid, index, 1)

# If no COB ID defined in PDO, generate a new one (not used)

if cobid == 0:

nodeid, index, subindex = loc[:3]

# Check Id is in slave node list

raise PDOmappingException(

_("Non existing node ID : {a1} (variable {a2})").

format(a1=nodeid, a2=name))

# Search for locations already mapped

# -------------------------------------------------------------------------------

node = self.NodeList.SlaveNodes[locationinfos["nodeid"]]["Node"]

# Search if slave has a PDO mapping this locations

cobid = self.NodeList.GetSlaveNodeEntry(locationinfos["nodeid"], index - 0x200, 1)

# Add PDO to MasterMapping

# Verify that PDO transmit type is conform to sync_TPDOs

transmittype = self.NodeList.GetSlaveNodeEntry(locationinfos["nodeid"], index - 0x200, 2)

if sync_TPDOs and transmittype != 0x01 or transmittype != 0xFF:

else:

# Add location to those that haven't been mapped yet

self.LocationsNotMapped[locationinfos["nodeid"]] = {TPDO: [], RPDO: []}

self.LocationsNotMapped[locationinfos["nodeid"]][locationinfos["pdotype"]].append((name, locationinfos))

# Build concise DCF for the others locations

# -------------------------------------------------------------------------------

node = self.NodeList.SlaveNodes[nodeid]["Node"]

# Initialize number of params and data to add to node DCF

# -------------------------------------------------------------------------------

# Generate Master's Configuration from informations stored in MasterMapping

# Get next PDO index in MasterNode for this PDO type

current_idx = self.CurrentPDOParamsIdx[pdo_infos["type"]]

continue

new_index = False

# If variable is an integer then variable is unexpected

self.MasterNode.SetEntry(current_idx + 0x200, subindex, self.TrashVariables[variable])

else:

# Extract workspace base folder

base_folder = sys.path[0]

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

# Add CanFestival folder to search pathes

sys.path.append(os.path.join(base_folder, "CanFestival-3", "objdictgen"))

# See COPYING file for copyrights details.

import hashlib

but using Pre Shared Keys instead of Certificates

"""

import socket

import re

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import traceback

from time import sleep

import copy

import PSKManagement as PSK

from connectors.PYRO.PSK_Adapter import setupPSKAdapter

from runtime import PlcStatus

def switch_pyro_adapter(use_ssl):

This is workaround for Pyro, because it doesn't work with SSL wrapper.

"""

# Pyro.config.PYRO_BROKEN_MSGWAITALL = use_ssl

if use_ssl:

setupPSKAdapter()

# See COPYING file for copyrights details.

from itertools import repeat, islice, chain

# See COPYING file for copyrights details.

from functools import partial

import wx

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import sys

import traceback

from functools import partial

# See COPYING file for copyrights details.

from itertools import repeat, islice, chain

# Package initialisation

import os

from os import listdir, path

from connectors.ConnectorBase import ConnectorBase

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import wx

import wx.adv

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import wx

import wx.grid

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import wx

import wx.lib.intctrl

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

from functools import reduce

import wx

import wx.stc

new_length = len(new)

common_length = min(old_length, new_length)

i = 0

if old[i] != new[i]:

break

if old_length < new_length:

x, _y = event.GetPosition()

margin_width = reduce(

lambda x, y: x + y,

0)

if x <= margin_width:

self.SetCursor(wx.Cursor(wx.CURSOR_ARROW))

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import wx

import wx.grid

if highlight_type is None:

self.Highlights = {}

else:

for col, col_highlights in row_items:

if highlight_type in col_highlights:

col_highlights.remove(highlight_type)

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import wx

from controls.CustomStyledTextCtrl import faces

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import wx

import wx.lib.agw.customtreectrl as CT

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

from time import time as gettime

from cycler import cycler

# Graph variable display type

# Canvas height

[SIZE_MINI, SIZE_MIDDLE, SIZE_MAXI] = [0, 100, 200]

"""

start_tick, end_tick = self.ParentWindow.GetRange()

cursor_tick = None

# Graph is orthogonal

if self.GraphType == GRAPH_ORTHOGONAL:

# parent

xw, yw = self.GetPosition()

self.ParentWindow.StartDragNDrop(

x + xw, y + yw, # Current mouse position

x + xw, y + yw) # Mouse position when button was clicked

if self.ParentWindow.IsDragging():

_width, height = self.GetSize()

xw, yw = self.GetPosition()

# Give mouse position in wx coordinate of parent

self.ParentWindow.StopDragNDrop(item.GetVariable(),

xw + event.x, yw + height - event.y)

# If mouse is over an item label,

if item_idx is not None:

self.PopupContextualButtons(

rect, menu_direction)

return

xw, yw = self.GetPosition()

self.ParentWindow.SetCursorTick(self.StartCursorTick)

self.ParentWindow.StartDragNDrop(

# Current mouse position

event.x + xw, height - event.y + yw,

# Mouse position when button was clicked

# Graph type is parallel or orthogonal in 3D

if self.GraphType == GRAPH_PARALLEL or self.Is3DCanvas():

num_item = len(self.Items)

# Get color from color cycle (black if only one item)

color = ('k' if num_item == 1 else

# Update position of items labels

if self.GraphType == GRAPH_PARALLEL or self.Is3DCanvas():

num_item = len(self.Items)

# In 3D graph items variable label are not displayed

if not self.Is3DCanvas():

# each variable

start_tick = max(start_tick, self.GetItemsMinCommonTick())

end_tick = max(end_tick, start_tick)

# Get data and range for first variable (X coordinate)

x_data, x_min, x_max = items[0].GetDataAndValueRange(

item.GetValue(self.CursorTick)

if self.CursorTick is not None

else (item.GetValue(), item.IsForced())) for item in self.Items]

# Get path of each variable displayed simplified using panel variable

# name mask

for item in self.Items]

# Get style for each variable according to

# Graph is orthogonal 3D, set variables path as 3D axis label

if self.Is3DCanvas():

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

from datetime import timedelta

import binascii

import numpy as np

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

from functools import reduce

import numpy as np

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import wx

gc = wx.GCDC(dc)

# Get first item

# Get item variable path masked according Debug Variable Panel mask

item_path = item.GetVariable(

@param event: wx.MouseEvent

"""

# Get first item

# Calculate item path bounding box

_width, height = self.GetSize()

@param event: wx.MouseEvent

"""

# Only numeric variables can be toggled to graph canvas

self.ParentWindow.ToggleViewerType(self)

def OnPaint(self, event):

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

from collections import OrderedDict

from functools import reduce

HIGHLIGHT_AFTER,

HIGHLIGHT_LEFT,

HIGHLIGHT_RIGHT,

# Viewer highlight styles

HIGHLIGHT = {

items = [] if items is None else items

self.ItemsDict = OrderedDict([(item.GetVariable(), item)

for item in items])

# Variable storing current highlight displayed in Viewer

self.Highlight = HIGHLIGHT_NONE

Return items displayed by Viewer

@return: List of items displayed in Viewer

"""

def AddItem(self, item):

"""

Function that unsubscribe and remove every item that store values of

a variable that doesn't exist in PLC anymore

"""

iec_path = item.GetVariable()

# Check that variablepath exist in PLC

"""

Function called when Force button is pressed

"""

def OnReleaseButton(self):

"""

Function called when Release button is pressed

"""

def OnMouseDragging(self, x, y):

"""

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import wx

from util.BitmapLibrary import GetBitmap

note: only when this function is called, is an O(size) performance hit incurred,

and this cost is amortized over the whole padding space

"""

self.buffer[:self.count] = self.view

self.cursor -= self.size

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

from controls.DebugVariablePanel.DebugVariablePanel import DebugVariablePanel

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.