ITEM_RESOURCE, \

ITEM_CONFNODE

from IDEFrame import \

TITLE,\

else:

return IDEFrame.LoadTab(self, notebook, page_infos)

def TryCloseFrame(self):

if self.CTR is None or self.CheckSaveBeforeClosing(_("Close Application")):

if self.CTR is not None:

self.SaveLastState()

Thing()

return True

return False

-x enable/disable wxTaskbarIcon (0:disable 1:enable) (default:1)

-t enable/disable Twisted web interface (0:disable 1:enable) (default:1)

-w web server port or "off" to disable web server (default:8009)

-e python extension (absolute path .py)

working_dir - directory where are stored PLC files

port = 3000

webport = 8009

PSKpath = None

wampconf = None

servicename = None

autostart = False

elif o == "-w":

webport = None if a == "off" else int(a)

elif o == "-c":

elif o == "-s":

elif o == "-e":

fnameanddirname = list(os.path.split(os.path.realpath(a)))

fnameanddirname.reverse()

if havewamp:

try:

WC.RegisterWebSettings(NS)

except Exception:

LogMessageAndException(_("WAMP client startup failed. "))

import fake_wx

from LocalRuntimeMixin import LocalRuntimeMixin

from runtime.loglevels import LogLevelsCount, LogLevels

def finish(self):

self._Disconnect()

if not self.session.keep:

self.KillLocalRuntime()

dataForID[COL_URI] = URI

# FIXME : could store time instead os a string and use DVC model's cmp

# then date display could be smarter, etc - sortable sting hack for now

if _is_new_ID:

data.append(dataForID)

SaveData(project_path, data)

def ExportIDs(project_path, export_zip):

with ZipFile(export_zip, 'w') as zf:

for d in self.StatusMethods:

if d["method"] == method and d.get("enabled", True) and d.get("shown", True):

getattr(self, method)()

try:

if ID:

# load PSK from project

else:

transport = erpc.transport.TCPTransport(host, port, False)

clientManager = erpc.client.ClientManager(transport, erpc.basic_codec.BasicCodec)

from threading import Thread, Event

from twisted.internet import reactor, threads

from autobahn.twisted import wamp

from autobahn.twisted.websocket import WampWebSocketClientFactory, connectWS

from autobahn.wamp.exception import TransportLost

from autobahn.wamp.serializer import MsgPackSerializer

_WampSession = None

_WampConnection = None

class WampSession(wamp.ApplicationSession):

def onJoin(self, details):

global _WampSession

_WampSession = self

_WampSession = None

print('WAMP session left')

def _WAMP_connector_factory(cls, uri, confnodesroot):

"""

"WAMPS": "wss"}[scheme]

url = urlprefix+"://"+urlpath

def RegisterWampClient():

# start logging to console

# create a WAMP application session factory

component_config = types.ComponentConfig(

realm=str(realm),

session_factory = wamp.ApplicationSessionFactory(

config=component_config)

session_factory.session = cls

url=url,

serializers=[MsgPackSerializer()])

# start the client from a Twisted endpoint

confnodesroot.logger.write(_("WAMP connecting to URL : %s\n") % url)

return conn

def ThreadProc():

global _WampConnection

_WampConnection = RegisterWampClient()

reactor.run(installSignalHandlers=False)

def __init__(self):

global _WampConnection

if not reactor.running:

from dialogs.IDMergeDialog import IDMergeDialog

def __init__(self, project_path, columncount):

self.project_path = project_path

self.columncount = columncount

self.data = PSK.GetData(project_path)

def _saveData(self):

PSK.SaveData(self.project_path, self.data)

dialect = csv.Sniffer().sniff(csvfile.read(1024))

csvfile.seek(0)

reader = csv.reader(csvfile, dialect)

data.append(first_row)

col_headers = OrderedDict([(name, index+1) for index, name

in enumerate(first_row[1:])])

aiofiles==24.1.0

asyncua @ git+https://github.com/FreeOpcUa/opcua-asyncio.git@98a64897a2d171653353de2f36d33085aef65e82

Automat==24.8.1

Brotli==1.1.0

cffi==1.17.1

constantly==23.10.4

contourpy==1.3.1

cycler==0.12.1

erpc @ git+https://git@github.com/beremiz/erpc.git@d8fff72b15274b5f2a8f7895d9bc5c91eef584ec#subdirectory=erpc_python

hyperlink==21.0.0

idna==3.10

ifaddr==0.2.0

incremental==24.7.2

msgpack==1.1.0

Nevow @ git+https://git@github.com/beremiz/nevow-py3.git@81c2eaeaaa20022540a98a3106f72e0199fbcc1b

packaging==24.2

pycountry==24.6.1

pycparser==2.22

python-dateutil==2.9.0.post0

six==1.17.0

sortedcontainers==2.4.0

sslpsk @ git+https://git@github.com/beremiz/sslpsk.git@9cb31986629b382f7427eec29ddc168ad21c7d7c

Twisted==24.11.0

txaio==23.1.1

typing_extensions==4.12.2

wxPython==4.2.2

zope.interface==7.2

matplotlib

msgpack

Nevow @ git+https://git@github.com/beremiz/nevow-py3.git@81c2eaeaaa20022540a98a3106f72e0199fbcc1b

pycountry

# pyserial

sslpsk @ git+https://git@github.com/beremiz/sslpsk.git@9cb31986629b382f7427eec29ddc168ad21c7d7c

self._RegisterDebugVariable = self.PLClibraryHandle.RegisterDebugVariable

self._RegisterDebugVariable.restype = ctypes.c_int

self._FreeDebugData = self.PLClibraryHandle.FreeDebugData

self._FreeDebugData.restype = None

@RunInMain

def GetPLCID(self):

def _init_blobs(self):

self.blobs = {} # dict of list

secret = os.urandom(192) # int(256/1.3333)

secretstring = b2a_base64(secret)

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

f.write(PSKstring)

restartStunnel()

PSKgen(ID, PSKpath)

if _PSKpath is not None:

if not os.path.exists(_PSKpath):

'Error: Pre-Shared-Key Secret in %s is missing!\n' % _PSKpath)

ID, _sep, PSK = open(_PSKpath).read().partition(':')

PSK = PSK.rstrip('\n\r')

return (ID, PSK)

import json

import os

import re

from autobahn.twisted import wamp

from autobahn.twisted.websocket import WampWebSocketClientFactory, connectWS

from autobahn.wamp import types, auth

from autobahn.wamp.serializer import MsgPackSerializer

from twisted.internet.protocol import ReconnectingClientFactory

from twisted.python.components import registerAdapter

from formless import annotate, webform

import formless

from nevow import tags, url, static

from runtime import GetPLCObjectSingleton

mandatoryConfigItems = ["ID", "active", "realm", "url"]

# Find pre-existing project WAMP config file

_WampConf = None

_WampSecret = None

ExposedCalls = [

("StartPLC", {}),

("MatchMD5", {}),

("SetTraceVariablesList", {}),

("GetTraceVariables", {}),

("GetLogMessage", {}),

]

# de-activated dumb wamp config

defaultWampConfig = {

"active": False,

"realm": "Automation",

"url": "ws://127.0.0.1:8888",

"protocolOptions": {

"autoPingInterval": 10,

"autoPingTimeout": 5

}

# Those two lists are meant to be filled by customized runtime

class WampSession(wamp.ApplicationSession):

def onConnect(self):

def onChallenge(self, challenge):

if challenge.method == "wampcra":

else:

else:

def onJoin(self, details):

global _WampSession

def onLeave(self, details):

global _WampSession, _transportFactory

_WampSession = None

_transportFactory = None

def publishWithOwnID(self, eventID, value):

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

WampClientConf = None

if os.path.exists(_WampConf):

WampClientConf = json.load(open(_WampConf))

UpdateWithDefault(WampClientConf, defaultWampConfig)

except ValueError:

return WampClientConf

def SetConfiguration(WampClientConf):

global lastKnownConfig

return re.match(r'wss?://[^\s?:#-]+(:[0-9]+)?(/[^\s]*)?$', uri) is not None

# set config file path only if not already set

if _WampConf is None:

_WampSecret = wampsecret

if _WampSecret is not None:

else:

if not WampClientConf["active"]:

print(_("WAMP deactivated in configuration"))

# start the client from a Twisted endpoint

if _transportFactory:

print(_("WAMP client connecting to :"), WampClientConf["url"])

return True

else:

print(_("WAMP client can not connect to :"), WampClientConf["url"])

return False

def StopReconnectWampClient():

if _transportFactory is not None:

# WEB CONFIGURATION INTERFACE

WAMP_SECRET_URL = "secret"

webExposedConfigItems = [

'active', 'url', 'ID',

"clientFactoryOptions.maxDelay",

"protocolOptions.autoPingInterval",

]

if secretfile_field is not None:

secretfile = getattr(secretfile_field, "file", None)

if secretfile is not None:

newConfig = lastKnownConfig.copy()

for argname in webExposedConfigItems:

child(lastKnownConfig["ID"] + ".secret")

webFormInterface = [

("status",

annotate.String(label=_("Current status"),

default=wampConfigDefault)),

("protocolOptions.autoPingTimeout",

annotate.Integer(label=_("Auto ping timeout (s)"),

]

def deliverWampSecret(ctx, segments):

secret = LoadWampSecret(_WampSecret)

return static.Data(secret, 'application/octet-stream'), ()

def RegisterWebSettings(NS):

wampConfig)

WebSettings.addCustomURL(WAMP_SECRET_URL, deliverWampSecret)

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

<TargetType/>

</BeremizRoot>

RUN virtualenv ~/beremizenv

COPY requirements.txt /home/$UNAME

RUN ~/beremizenv/bin/pip install -r /home/$UNAME/requirements.txt

RUN set -xe && \

cd /home/$UNAME && mkdir tessdata && \

wget -q https://github.com/tesseract-ocr/tessdata/archive/refs/tags/4.1.0.tar.gz \

# Points to python binary that test will use

ENV BEREMIZPYTHONPATH /home/$UNAME/beremizenv/bin/python