import getopt

import threading

from threading import Thread, Semaphore, Lock, currentThread

from builtins import str as text

from past.builtins import execfile

from six.moves import builtins

# Define PLCOpenEditor FileMenu extra items id

[

ID_PLCOPENEDITORFILEMENUGENERATE,

beremiz_dir = paths.AbsDir(__file__)

kind=wx.ITEM_NORMAL, text=_(u'Save As...') + '\tCTRL+SHIFT+S')

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

kind=wx.ITEM_NORMAL, text=_(u'Generate Program') + '\tCTRL+G')

parent.AppendSeparator()

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

kind=wx.ITEM_NORMAL, text=_(u'Page Setup') + '\tCTRL+ALT+P')

self.Bind(wx.EVT_MENU, self.OnSaveProjectAsMenu, id=wx.ID_SAVEAS)

self.Bind(wx.EVT_MENU, self.OnGenerateProgramMenu,

id=ID_PLCOPENEDITORFILEMENUGENERATE)

self.Bind(wx.EVT_MENU, self.OnPageSetupMenu, id=wx.ID_PAGE_SETUP)

self.Bind(wx.EVT_MENU, self.OnPreviewMenu, id=wx.ID_PREVIEW)

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

(wx.ID_OPEN, "open", _(u'Open'), None),

(wx.ID_SAVE, "save", _(u'Save'), None),

(wx.ID_SAVEAS, "saveas", _(u'Save As...'), None),

def _init_coll_HelpMenu_Items(self, parent):

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

self.FileMenu.Enable(wx.ID_SAVEAS, True)

MenuToolBar.EnableTool(wx.ID_SAVEAS, True)

self.FileMenu.Enable(ID_PLCOPENEDITORFILEMENUGENERATE, True)

else:

self.FileMenu.Enable(wx.ID_CLOSE, False)

self.FileMenu.Enable(wx.ID_PAGE_SETUP, False)

self.FileMenu.Enable(wx.ID_SAVEAS, False)

MenuToolBar.EnableTool(wx.ID_SAVEAS, False)

self.FileMenu.Enable(ID_PLCOPENEDITORFILEMENUGENERATE, False)

def OnNewProjectMenu(self, event):

if self.Controler is not None and not self.CheckSaveBeforeClosing():

self.SaveProjectAs()

def OnGenerateProgramMenu(self, event):

dialog = wx.FileDialog(self, _("Choose a file"), os.getcwd(), os.path.basename(self.Controler.GetProgramFilePath()), _("ST files (*.st)|*.st|All files|*.*"), wx.SAVE | wx.CHANGE_DIR)

if dialog.ShowModal() == wx.ID_OK:

else:

def OnPLCOpenEditorMenu(self, event):

wx.MessageBox(_("No documentation available.\nComing soon."))

sudo apt-get install python-nevow python-matplotlib python-lxml python-zeroconf python-cycler

sudo apt-get install python-autobahn python-u-msgpack

* Prepare

mkdir ~/Beremiz

cd ~/Beremiz

svn checkout https://svn.code.sf.net/p/bacnet/code/trunk/bacnet-stack/ BACnet

cd BACnet

* Launch Beremiz IDE

# See COPYING file for copyrights details.

from __future__ import absolute_import

class ConnectorBase(object):

chuncksize = 1024*1024

def BlobFromFile(self, filepath, seed):

s.update(seed)

blobID = self.SeedBlob(seed)

with open(filepath, "rb") as f:

from __future__ import absolute_import

from __future__ import print_function

import socket

import re

import sslpsk

import Pyro

from Pyro.core import PyroURI

from Pyro.protocol import _connect_socket, TCPConnection, PYROAdapter

from Pyro.util import Log

class PYROPSKAdapter(PYROAdapter):

def bindToURI(self, URI):

with self.lock: # only 1 thread at a time can bind the URI

try:

# receive the authentication challenge string, and use that to build the actual identification string.

try:

authChallenge = self.recvAuthChallenge(conn)

# check if we were denied

if hasattr(x, "partialMsg") and x.partialMsg[:len(self.denyMSG)] == self.denyMSG:

raise ConnectionDeniedError(Pyro.constants.deniedReasons[int(x.partialMsg[-1])])

return _getProtocolAdapter(protocol)

_processStringURI = Pyro.core.processStringURI

return _processStringURI(URI)

from Pyro.errors import PyroError

import PSKManagement as PSK

from runtime import PlcStatus

def PYRO_connector_factory(uri, confnodesroot):

confnodesroot.logger.write(_("PYRO connecting to URI : %s\n") % uri)

scheme, location = uri.split("://")

schemename = "PYROLOCPSK"

url, ID = location.split('#') # TODO fix exception when # not found

# load PSK from project

# Try to get the proxy object

try:

RemotePLCObjectProxy = Pyro.core.getAttrProxyForURI(schemename + "://" + location + "/PLCObject")

confnodesroot.logger.write_error(

_("Connection to {loc} failed with exception {ex}\n").format(

return None

RemotePLCObjectProxy.adapter.setTimeout(60)

from __future__ import absolute_import

from itertools import repeat, islice, chain

from connectors.SchemeEditor import SchemeEditor

self.txtctrls[tag] = txtctrl

for win, flag in [

(wx.StaticText(self, label=label),

(txtctrl, wx.GROW)]:

self.fieldsizer.AddWindow(win, flag=flag)

self, parent.ctr,

# use a callafter, as editor can be deleted by calling SetURI

partial(wx.CallAfter, parent.SetURI),

self.mainsizer.AddWindow(self.idselector)

self.SetSizer(self.mainsizer)

else:

from __future__ import absolute_import

from os import listdir, path

from connectors.ConnectorBase import ConnectorBase

connectors_packages = ["PYRO", "WAMP"]

return None

# new class inheriting from generic and specific connector base classes

def EditorClassFromScheme(scheme):

args(_("Last URI"), COL_URI, width=300 if big else 80),

args(_("Description"), COL_DESC, width=300 if big else 200,

mode=dv.DATAVIEW_CELL_EDITABLE

args(_("Last connection"), COL_LAST, width=120),

]

import os

import sys

import traceback

from time import time

from six.moves import xrange

from past.builtins import execfile

from runtime.typemapping import TypeTranslator

from runtime.loglevels import LogLevelsDefault, LogLevelsCount

@RunInMain

def SeedBlob(self, seed):

_fobj, _path, md5sum = blob

md5sum.update(seed)

newBlobID = md5sum.digest()

@RunInMain

def GetTraceVariables(self, DebugToken):

return self.PLCStatus, self._TracesSwap()

return PlcStatus.Broken, []

from __future__ import absolute_import

import os

from binascii import b2a_hqx

try:

_PSKpath = None

def PSKgen(ID, PSKpath):

# b2a_hqx output len is 4/3 input len

PSKstring = ID+":"+secretstring

with open(PSKpath, 'w') as f:

f.write(PSKstring)

def ensurePSK(ID, PSKpath):

self.register(GetCallee(name), u'.'.join((ID, name)), registerOptions)

for name in SubscribedEvents:

for func in DoOnJoin:

func(self)

def publishWithOwnID(self, eventID, value):

ID = self.config.extra["ID"]

class ReconnectingWampWebSocketClientFactory(WampWebSocketClientFactory, ReconnectingClientFactory):

def PublishEvent(eventID, value):

if getWampStatus() == "Attached":

def PublishEventWithOwnID(eventID, value):

if getWampStatus() == "Attached":

# WEB CONFIGURATION INTERFACE

from __future__ import absolute_import

import sys

from threading import Lock, Condition

import six

class job(object):

self.free = Condition(self.mutex)

self.job = None

def runloop(self, *args, **kwargs):

"""

meant to be called by worker thread (blocking)

"""

self.mutex.acquire()

if args or kwargs:

_job = job(*args, **kwargs)

_job.do()

while not self._finish:

self.todo.wait()

_job = job(*args, **kwargs)

# if caller is worker thread execute immediately

_job.do()

else:

if _job.success:

return _job.result

else:

def quit(self):

"""

# subset of subprocess built-in module using posix_spawn rather than fork.

from __future__ import absolute_import

import os

import signal

<?xml version='1.0' encoding='utf-8'?>

<project xmlns:ns1="http://www.plcopen.org/xml/tc6_0201" xmlns:xhtml="http://www.w3.org/1999/xhtml" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns="http://www.plcopen.org/xml/tc6_0201">

<fileHeader companyName="Beremiz" productName="Beremiz" productVersion="1" creationDateTime="2016-10-24T18:09:22"/>

<coordinateInfo>

<fbd>

<scaling x="0" y="0"/>

<INT/>

</type>

</variable>

</localVars>

<externalVars constant="true">

<variable name="ResetCounterValue">

<relPosition x="85" y="15"/>

</connectionPointOutAction>

</step>

<position x="154" y="191"/>

<connectionPointIn>

<relPosition x="0" y="15"/>

</ST>

</inline>

</action>

<action localId="0">

<relPosition x="0" y="0"/>

<inline>

</action>

</actionBlock>

<selectionConvergence localId="10" height="1" width="431">

<connectionPointIn>

<relPosition x="0" y="0"/>

<connection refLocalId="13">

<position x="70" y="244"/>

</connection>

</connectionPointIn>

<connectionPointIn>

<relPosition x="431" y="0"/>

<connection refLocalId="14">

<position x="501" y="250"/>

</connection>

</connectionPointIn>

</connectionPointOut>

</selectionConvergence>

<jumpStep localId="12" targetName="Start" height="13" width="12">

<connectionPointIn>

<relPosition x="6" y="0"/>

<connection refLocalId="10">

</connection>

</connectionPointIn>

</jumpStep>

<relPosition x="10" y="0"/>

<connection refLocalId="7">

<position x="70" y="242"/>

</connection>

</connectionPointIn>

<connectionPointOut>

</variable>

</inputVars>

<outputVars>

<variable name="Out">

<type>

<INT/>

# remove compiled Python files

find . -name '*.pyc' -exec rm -f {} \;

# echo $i

python3 -m py_compile $i

if [ $? -ne 0 ]; then

echo "No files to check"

exit 0;

fi

}