1

#!/usr/bin/env python

     2

# -*- coding: utf-8 -*-

     3

     4

#This file is part of Beremiz, a Integrated Development Environment for

     5

#programming IEC 61131-3 automates supporting plcopen standard and CanFestival. 

     6

#

     7

#Copyright (C) 2007: Edouard TISSERANT and Laurent BESSARD

     8

#

     9

#See COPYING file for copyrights details.

    10

#

    11

#This library is free software; you can redistribute it and/or

    12

#modify it under the terms of the GNU General Public

    13

#License as published by the Free Software Foundation; either

    14

#version 2.1 of the License, or (at your option) any later version.

    15

#

    16

#This library is distributed in the hope that it will be useful,

    17

#but WITHOUT ANY WARRANTY; without even the implied warranty of

    18

#MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

    19

#General Public License for more details.

    20

#

    21

#You should have received a copy of the GNU General Public

    22

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

    23

#Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

    24

    25

import os, sys, getopt

    26

from threading import Thread,Timer

    27

    28

def usage():

    29

    print """

    30

Usage of Beremiz PLC execution service :\n

    31

%s {[-n servicename] [-i IP] [-p port] [-x enabletaskbar] [-a autostart]|-h|--help} working_dir

    32

           -n        - zeroconf service name (default:disabled)

    33

           -i        - IP address of interface to bind to (default:localhost)

    34

           -p        - port number default:3000

    35

           -h        - print this help text and quit

    36

           -a        - autostart PLC (0:disable 1:enable) (default:0)

    37

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

    38

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

    39

    40

           working_dir - directory where are stored PLC files

    41

"""%sys.argv[0]

    42

    43

try:

    44

    opts, argv = getopt.getopt(sys.argv[1:], "i:p:n:x:t:a:h")

    45

except getopt.GetoptError, err:

    46

    # print help information and exit:

    47

    print str(err) # will print something like "option -a not recognized"

    48

    usage()

    49

    sys.exit(2)

    50

    51

# default values

    52

given_ip = None

    53

port = 3000

    54

servicename = None

    55

autostart = False

    56

enablewx = True

    57

havewx = False

    58

enabletwisted = True

    59

havetwisted = False

    60

    61

for o, a in opts:

    62

    if o == "-h":

    63

        usage()

    64

        sys.exit()

    65

    elif o == "-i":

    66

        if len(a.split(".")) == 4 or a == "localhost":

    67

            given_ip = a

    68

        else:

    69

            usage()

    70

            sys.exit()

    71

    elif o == "-p":

    72

        # port: port that the service runs on

    73

        port = int(a)

    74

    elif o == "-n":

    75

        servicename = a

    76

    elif o == "-x":

    77

        enablewx = int(a)

    78

    elif o == "-t":

    79

        enabletwisted = int(a)

    80

    elif o == "-a":

    81

        autostart = int(a)

    82

    else:

    83

        usage()

    84

        sys.exit()

    85

    86

if len(argv) > 1:

    87

    usage()

    88

    sys.exit()

    89

elif len(argv) == 1:

    90

    WorkingDir = argv[0]

    91

    os.chdir(WorkingDir)

    92

elif len(argv) == 0:

    93

    WorkingDir = os.getcwd()

    94

    argv=[WorkingDir]

    95

    96

import __builtin__

    97

if __name__ == '__main__':

    98

    __builtin__.__dict__['_'] = lambda x: x

    99

   100

if enablewx:

   101

    try:

   102

        import wx, re

   103

        from threading import Thread, currentThread

   104

        from types import *

   105

        havewx = True

   106

    except:

   107

        print "Wx unavailable !"

   108

        havewx = False

   109

   110

    if havewx:

   111

        app=wx.App(redirect=False)

   112

   113

        # Import module for internationalization

   114

        import gettext

   115

   116

        CWD = os.path.split(os.path.realpath(__file__))[0]

   117

   118

        # Get folder containing translation files

   119

        localedir = os.path.join(CWD,"locale")

   120

        # Get the default language

   121

        langid = wx.LANGUAGE_DEFAULT

   122

        # Define translation domain (name of translation files)

   123

        domain = "Beremiz"

   124

   125

        # Define locale for wx

   126

        loc = __builtin__.__dict__.get('loc', None)

   127

        if loc is None:

   128

            loc = wx.Locale(langid)

   129

            __builtin__.__dict__['loc'] = loc

   130

        # Define location for searching translation files

   131

        loc.AddCatalogLookupPathPrefix(localedir)

   132

        # Define locale domain

   133

        loc.AddCatalog(domain)

   134

   135

        def unicode_translation(message):

   136

            return wx.GetTranslation(message).encode("utf-8")

   137

   138

        if __name__ == '__main__':

   139

            __builtin__.__dict__['_'] = wx.GetTranslation#unicode_translation

   140

   141

        try:

   142

            from wx.lib.embeddedimage import PyEmbeddedImage

   143

        except:

   144

            import cStringIO

   145

            import base64

   146

   147

            class PyEmbeddedImage:

   148

                def __init__(self, image_string):

   149

                    stream = cStringIO.StringIO(base64.b64decode(image_string))

   150

                    self.Image = wx.ImageFromStream(stream)

   151

                def GetImage(self):

   152

                    return self.Image

   153

   154

        defaulticon = PyEmbeddedImage(

   155

        "iVBORw0KGgoAAAANSUhEUgAAABgAAAAYCAYAAADgdz34AAAABHNCSVQICAgIfAhkiAAABc5J"

   156

        "REFUSIl9lW1MW9cZx3/n2vf6BQO2MZiXGBISILCVUEUlitYpjaKpXZJ1XZZ2kzJVY9r6IeLD"

   157

        "pGTaNG3KtGmNNGlbpW3VFhRp0l6aZCllpVUqtVNJtBFKE5QXLxCjpCYEY7DBr9hcm3vPPgQY"

   158

        "IQmPdKR7/vd5/v/n5dxzhZSSNeYBOoGDQGcoFPINDAyUDQ0NOUdGRmyGYSiBQGCpoaGhuGnT"

   159

        "psShQ4f6WltbewEBVAK3gCBgrjJKKZFSKlLKeillt5Ty40gkMnnw4MFFQG60ysrKZHd3dyoe"

   160

        "j//bNM0Le/fuPd/e3r5lmRMpJWK5ghrgFeBIT09P4/Hjx73pdFo47HaaNlfRutnJru0OKsoE"

   161

        "E3GVqaSNa6EUw1dvIKWkoqKCrVu3FoeHh9WamppfRiKRn6wUYAUcwE7g2e7u7vrTp09XGIZB"

   162

        "W1Mdv3qtmoBPrG0hHVsMhKLj6nqOqOWn/Pjnv2dgYIC5uTl1uSM71/pbgUbg6bNnz/rPnDnj"

   163

        "dzoddO0P8Oo+jY2suDDD1Zv9DA1dfghXVbVBCFEqpcwAKEDTxMSE58SJE8+oqsq3nq/l1X0a"

   164

        "QihYtNLHLqRET03wuYp7fO9r26mpKlsVUBSl0W63V6/shZTyyIEDB344Njb21JYaG7/5bgkA"

   165

        "Dm8zTS/+7bHZLy0mSN+7yNztt8nPjYHFwfvXDf1P70zZ0ok0LS0tZy9fvvxNAGswGFQnJyef"

   166

        "KnM5+NHLzuUDsrFZ7R68zS/hrGon1PcNMPI0BIzs9tcCNvNfDqxW64uqqvqKxWJc6e3trVVV"

   167

        "leaAk6ryJ5N/9tH3GXv7Je7/5xermN3diMPXCkDfgrkg3UU0txWLxeLw+/1fB1BGR0frbTYb"

   168

        "TXWWDbNeysUoZKbIRIZBPviOzKU8ejLMHyPFcMprrweQ7iUAXC7XPiGEak2lUk02m42mWn1D"

   169

        "gfrnTiKNIrbyzSAUjEKWCx+/Mf+HyELBrLBvBhAIKDdgGsrLy+sAv1UIUa1pGv7yxQ0FbGX1"

   170

        "D+0LQmHW7fVavE5Mo/gAFCCcoOs6NpvNA7gVRVGCmqYRz1hXg7NFU39rjshawjcuvs4P+o/y"

   171

        "24uvE1+I4VCdfGfXUb76+VdWfQQCkbJSKBQoFApJTdMsCvApQDSlAjCTN7I/y5CNllpq1wqE"

   172

        "YmPciIzwwdi7BKevreK7Gp5dfbYoFoozJrquo+v6rMViWbQCV4QQzGTsQJY3kzIhvFpgfYte"

   173

        "7jhCMp9kk7uep+ueWcWj6f8Xqioq8ck0xcIS6XT6vpRy3gqMqKpqRBfKLLNF1ZRV6YBiPDrw"

   174

        "vduefwTL6hl6b74FgFVR0T4rJTU3jcvlymcymal8Ph+z9vf3p7u6uv5y/vz5bw994ld2fmUH"

   175

        "7nYFRVG4Gb3Guv8FpmmQzCcIJ+5w8c5HRFL3UYRC+ZKX633j6LpObW3tDcMwrsODq4Jbt27V"

   176

        "HT58+N7o6KgCYHfY2f2lXfi+6CJbnsAwjUeyXzFFKLgdHqb+mmL8xh22bduWmJycfHN2dvbX"

   177

        "uVwuoQC0tbXlKisrYytBi/lFZsKzOErtTyQWCOxWO36ljvl/FLk+dJOSkhJTUZR35+fn+3K5"

   178

        "XAIeXNcASz6fbxzwrxDYVQdqpARvs498IYchDUxpogiBVVFxqE7U/5Zx4c8fEo/FKS0tlR0d"

   179

        "HZ8ODg6+l06nr6zwrAp4PJ6Qpmlf2L9/fywYDFaOXB0RI1dHaGpuoq29Fa1Uxe62YeZMInei"

   180

        "jAY/IRqNAtDZ2blUV1fXPzg4+F5VVdU/H6p0eYjqsWPHvnz37t0XwuHw7d27d4eTyeTvLl26"

   181

        "FJiamnpim6qrq9mzZ094fHz875FI5J3p6ekr631WBARgaWlpCezYsePeuXPnzFAo5Dp58uS+"

   182

        "dDp91GKxNBYKBW82m3Vomqa7XK7pbDYbnJmZuR2LxYL5fP79WCyWeeys1h/D9e97enqsp06d"

   183

        "8mWzWU+xWPTkcjmXaZpxwzDCsVhsbqNggP8BMJOU3UUUf+0AAAAASUVORK5CYII=")

   184

   185

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

   186

        starticon = PyEmbeddedImage(

   187

        "iVBORw0KGgoAAAANSUhEUgAAABgAAAAYCAYAAADgdz34AAAABHNCSVQICAgIfAhkiAAABbpJ"

   188

        "REFUSIl9lltsFNcdxn9nZnbHs15fd23j9TXYC0UCKzEhMQ+oIS2g1kQ1pbFStX0opFWsovSh"

   189

        "rUqp2pS2ioTUolaKFOGHqGkiJcKRuDhOaZRiZCsCXyBgCBBfMfbu+oa9s17wzuzl9MH24mDD"

   190

        "XzoPc/6fft+c72jOGSGlZEVlAU8D9cB20zQ9HR0duRcvXszq7e01EomEUlFREa+srLR8Pl+g"

   191

        "sbHx3zk5ORcAFfACA8Bt4CFUSomUUkgpS6SUB6SUH5umOXLgwIEHqqrKJfGao7S0VB49ejRo"

   192

        "2/YnUsrT+/fvb66pqSldYiKlRCytoBB4Gfjx6dOnq5qamjwTExOKqqqU+QrYUJFN7QY32Qbc"

   193

        "vSeYCGtcux1i5M5dAPx+P1VVVQvnzp0ziouLfx8MBt9cXoAGZABbgZ1HjhwpO378eEEymaSi"

   194

        "tIBjPy9lU5nKoyWExF2yjy+mN3HsH+/Q3d3NwMCAsZTI9pVaDXgK2Hr27Nn85ubmEpdh8IMX"

   195

        "ffxirwshVrGXHBQSC/dIRvoZGuz/WkvTtHIhhCGlXABQgI2Tk5P5hw8f3uZwOGj8VjGHXnoC"

   196

        "HJCpJFbkLtr8FXbX+XC79HRPVVW/qqre9LtIKX/S0NDwy76+vq1lhTr/fM2NAmTk+fHv/dea"

   197

        "BlZkDHP0PHODH2NHg1gykw8/X7Dfb7vjTNgJqqurT3R1db0GoF2/fl0fGhqqdWca/K7RhZLO"

   198

        "WSBU55oGGXlVZORVkeV7nsFPDqKL+9TWJCI3n9rojX2mYhjGj4QQv5FSziunTp0qdjqd4hvl"

   199

        "Lnz5j49lrPMNhv7zM6b63knPuQpryMj3A9A2L++nvDaZXheqqrrXrVu3D0C5detWudPpxO/T"

   200

        "Hk8HYnOD3J+8yr3bH6XnZNImHg3xfsgenfHo5QAyJwFAdnb2HiGEppmmWa3rOhtKrCcalNT9"

   201

        "llTSwvBsXISn4nRdbJ5/czRsWvlGhQAEYtFg0kl2dnYZUKgB5U6nk5L82BMNXIU1X3uOWFH5"

   202

        "eWIuy/YYWcjU4qQAxQ22bWMYhgfIU1RV/UrXdWaiDyOyUiLROktoJfDtC8fZfWQbb//v75ix"

   203

        "MDlGnvjVC3+gflNDWiMQKPMalmVh2/a8w+HQFKAHIBR2ABCOS+uN6cTMoFstXmlwZbSba7tv"

   204

        "8hfzT7z+7k+ZnZ0BoK5yR1qjCBV7MoVt29i2PaWqqq0BvUIIQqYORHlrKj6R9BoVj0b04oY9"

   205

        "nEt+yvz3Y5yR/+Xap3XsDb/EtvV1aY1DdTA7HsW2bCKRyLiUclYBelRVldNWAfPSm4oV5ZQJ"

   206

        "Vn/G9Zv2oWt6Ous7e4K81XiC1wNNBO6OIWKgB7Mwp000TYuFw+GxWCw2qbS2tk7k5uae/eDD"

   207

        "Fn594p6SFyxRCjKLUBWF8fBoegTNMVLLm/kwdMyGGON/nePLklv0dl/Cii3gdrtvAzdg8aig"

   208

        "vb296uDBgwMjIyMCwFvoZXv9NvRnIKqHSckUyQdJrtfexPqm5LGVAuNdVaofcCVywfpexLYD"

   209

        "CsDOnTvnioqKzGXdzNQMV9tvkJEyUITyeOAjpYyAc9gxYc/GWyK2HYDF4xog6fV6h1i8FwCo"

   210

        "LK/EncwhkWGxEH9AXLMXM2H1CpQBifI3yeapZ+70d43+cSo4+95yL23g8XiGFUWp3bVrV/Ty"

   211

        "5ctZnR2ddHZ08uxzz1K9eT1GRhJls1gFlsfieK+WpJ5e/3z7pcuXzmia1rJSs3xlOg8dOvTD"

   212

        "8fHx7wQCgb4tW7bMm6b55/Pnz+eGw+FFGJDT5iT1XRWlfxHMZ06+/Vz9dCAQeG9kZKR1x44d"

   213

        "nSdPnkyuZSAArbq6eqOiKAP9/f3xlpaWgra2tlei0eiryWSyKGKa2TcaL+muwcxU5aDf9Gi+"

   214

        "L0Oh0BehUOiaZVlnAoHAzFr7Ih75bVnVb2pqcvf09Phi0ei6+/rUC6lw1k0p5bSUctThcIwP"

   215

        "Dw/HnwT4P6CDl+TMvD0JAAAAAElFTkSuQmCC")

   216

   217

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

   218

        stopicon = PyEmbeddedImage(

   219

        "iVBORw0KGgoAAAANSUhEUgAAABgAAAAYCAYAAADgdz34AAAABHNCSVQICAgIfAhkiAAABPRJ"

   220

        "REFUSImdlllsVGUUx3/f/e4sd5iZLjNt6XSFdtgkjWFRePABDaCBGgjamIg81CU0aoxbRHww"

   221

        "+EDkhWjEB5rYGEMUxQTCJg8EoQ2BbgrFCNJWltplgC63naEzd+bO50NLLVAq4STfwz3nfP/f"

   222

        "PSf3O98VSikmmQ94HFgDLDdNM1BfX5955swZX0tLi5FKpbSSkpJkaWlpIhQKdVdVVX2XkZFx"

   223

        "EpBAEGgHLgH/iSqlUEoJpVSBUqpaKXXYNM0r1dXVt6WUajx5ylVYWKi2bdvWY1nWUaXUgQ0b"

   224

        "NtRWVFQUjmuilEKMV5ALvAhsPHDgQFlNTU2gr69Pk1JSFMphTomfRXO8+A243i/oG9I5f6mX"

   225

        "K1evAxAOhykrKxs9duyYkZ+f/0lPT8/2OwXogBtYDKzYunVr0c6dO3Ns26akMIcdbxQyv0hy"

   226

        "rwmh8Bas5/eb89nxRR1NTU20t7cb4x1ZPjlXB2YBiw8ePJhdW1tb4DEMXng6xJtrPQhxn/Y4"

   227

        "QSM12o89fJnOjst3hXRdLxZCGEqpUQANmBuJRLK3bNmy1OFwUPVMPm9VTiMOqLRNYvg6+shv"

   228

        "rFoWwutxTcSklGEpZXDiXZRSr6xbt+6dtra2xUW5Lr7c7EUD3Flhwmu/nRKQGO7CvHaCwY7D"

   229

        "WNEeEmoGe0+PWnuOXHWmrBTl5eW7GxsbNwPoFy5ccHV2di7yzjD4uMqDNtFngZDOKQHurDLc"

   230

        "WWX4Qk/ScfRVXCLGoorU8J+z5gbjxyWGYbwshPhQKTWi7d+/P9/pdIp5xR5C2Q9uS1fDp3T+"

   231

        "8jo32uomfJ7cCtzZYQCOjKhYOmgxI+hBSumdOXPmegDt4sWLxU6nk3BIf7A6EB/sIBY5R/+l"

   232

        "nyd8yrZIRnvZ02tduxVwFQOojBQAfr9/tRBC103TLHe5XMwpSEwLKFj2EWk7gRGYOyaeTtJ4"

   233

        "pnZk+7UhM5FtlAhAIMYAESd+v78IyNWBYqfTSUF2fFqAJ7firufhRFSdTg36rIDhQ6XHnAI0"

   234

        "L1iWhWEYASBLl1L+JaWcfSuqk+u3AUikRer4ADffg/w7gt80fs35r34k3BYh2xNAarooAJ4d"

   235

        "vsHgaP8EWMR17GiaVo8r0+Fw6DrQDDzXO+RgQSjBUFIlPh+wB0vLZD6TrLWrkWRXB29fGAK6"

   236

        "pql1rNXVmrCklJYGtAgh6DXHDsuuG8k+O9M5895tq+atpSwwZ9o2TjZlWTGl1IAGNEsp1c1E"

   237

        "DiMqmI7nZRQJ7j/G6xZWMS/vsYcGkEzG4vF4RDt06FBfZmbmwR/27uOD3f1aVk+BljMjD6lp"

   238

        "/DN07a4VTYw8tL4rrQZgbNixadOm90+dOvX82cZmcbaxmWBukOVrlvJudw1R1xDp8a+kuPM6"

   239

        "Gx8S4LXtCIwNO1asWDGYl5dn3gneunGLc7/+gTttoAntQRrTmgMmpimAHQwGOycnlBaX4rUz"

   240

        "8LszMRweXLr7kWB35oMdCAT+1jRt0cqVK6Otra2+hvoGGuobWPLEEsoXzkbPkLhvR4CBRwJY"

   241

        "Xq/3SGVlZbq7u7utsrJyxDTNz06cOJHZ0tRCS1MLAKuRwNQT9v8AyV27dn1fXl7eqmlae11d"

   242

        "XXLfvn0/+Xy+l6LR6Gu2befFYjFfzrk2FzeHp7mK7jdxz2/LffGamhpvc3NzyLKsbFd3z1PG"

   243

        "aHyBTKdjum0POGzbFAp7qo0xVOtJZdf/C/wRDnL5FYGSAAAAAElFTkSuQmCC")

   244

   245

        class ParamsEntryDialog(wx.TextEntryDialog):

   246

            if wx.VERSION < (2, 6, 0):

   247

                def Bind(self, event, function, id = None):

   248

                    if id is not None:

   249

                        event(self, id, function)

   250

                    else:

   251

                        event(self, function)

   252

   253

   254

            def __init__(self, parent, message, caption = "Please enter text", defaultValue = "", 

   255

                               style = wx.OK|wx.CANCEL|wx.CENTRE, pos = wx.DefaultPosition):

   256

                wx.TextEntryDialog.__init__(self, parent, message, caption, defaultValue, style, pos)

   257

   258

                self.Tests = []

   259

                if wx.VERSION >= (2, 8, 0):

   260

                    self.Bind(wx.EVT_BUTTON, self.OnOK, id=self.GetAffirmativeId())

   261

                elif wx.VERSION >= (2, 6, 0):

   262

                    self.Bind(wx.EVT_BUTTON, self.OnOK, id=self.GetSizer().GetItem(3).GetSizer().GetAffirmativeButton().GetId())

   263

                else:

   264

                    self.Bind(wx.EVT_BUTTON, self.OnOK, id=self.GetSizer().GetItem(3).GetSizer().GetChildren()[0].GetSizer().GetChildren()[0].GetWindow().GetId())

   265

   266

            def OnOK(self, event):

   267

                value = self.GetValue()

   268

                texts = {"value" : value}

   269

                for function, message in self.Tests:

   270

                    if not function(value):

   271

                        message = wx.MessageDialog(self, message%texts, _("Error"), wx.OK|wx.ICON_ERROR)

   272

                        message.ShowModal()

   273

                        message.Destroy()

   274

                        return

   275

                self.EndModal(wx.ID_OK)

   276

                event.Skip()

   277

   278

            def GetValue(self):

   279

                return self.GetSizer().GetItem(1).GetWindow().GetValue()

   280

   281

            def SetTests(self, tests):

   282

                self.Tests = tests

   283

   284

        class BeremizTaskBarIcon(wx.TaskBarIcon):

   285

            TBMENU_START = wx.NewId()

   286

            TBMENU_STOP = wx.NewId()

   287

            TBMENU_CHANGE_NAME = wx.NewId()

   288

            TBMENU_CHANGE_PORT = wx.NewId()

   289

            TBMENU_CHANGE_INTERFACE = wx.NewId()

   290

            TBMENU_LIVE_SHELL = wx.NewId()

   291

            TBMENU_WXINSPECTOR = wx.NewId()

   292

            TBMENU_CHANGE_WD = wx.NewId()

   293

            TBMENU_QUIT = wx.NewId()

   294

   295

            def __init__(self, pyroserver, level):

   296

                wx.TaskBarIcon.__init__(self)

   297

                self.pyroserver = pyroserver

   298

                # Set the image

   299

                self.UpdateIcon(None)

   300

                self.level = level

   301

   302

                # bind some events

   303

                self.Bind(wx.EVT_MENU, self.OnTaskBarStartPLC, id=self.TBMENU_START)

   304

                self.Bind(wx.EVT_MENU, self.OnTaskBarStopPLC, id=self.TBMENU_STOP)

   305

                self.Bind(wx.EVT_MENU, self.OnTaskBarChangeName, id=self.TBMENU_CHANGE_NAME)

   306

                self.Bind(wx.EVT_MENU, self.OnTaskBarChangeInterface, id=self.TBMENU_CHANGE_INTERFACE)

   307

                self.Bind(wx.EVT_MENU, self.OnTaskBarLiveShell, id=self.TBMENU_LIVE_SHELL)

   308

                self.Bind(wx.EVT_MENU, self.OnTaskBarWXInspector, id=self.TBMENU_WXINSPECTOR)

   309

                self.Bind(wx.EVT_MENU, self.OnTaskBarChangePort, id=self.TBMENU_CHANGE_PORT)

   310

                self.Bind(wx.EVT_MENU, self.OnTaskBarChangeWorkingDir, id=self.TBMENU_CHANGE_WD)

   311

                self.Bind(wx.EVT_MENU, self.OnTaskBarQuit, id=self.TBMENU_QUIT)

   312

   313

            def CreatePopupMenu(self):

   314

                """

   315

                This method is called by the base class when it needs to popup

   316

                the menu for the default EVT_RIGHT_DOWN event.  Just create

   317

                the menu how you want it and return it from this function,

   318

                the base class takes care of the rest.

   319

                """

   320

                menu = wx.Menu()

   321

                menu.Append(self.TBMENU_START, _("Start PLC"))

   322

                menu.Append(self.TBMENU_STOP, _("Stop PLC"))

   323

                if self.level==1:

   324

                    menu.AppendSeparator()

   325

                    menu.Append(self.TBMENU_CHANGE_NAME, _("Change Name"))

   326

                    menu.Append(self.TBMENU_CHANGE_INTERFACE, _("Change IP of interface to bind"))

   327

                    menu.Append(self.TBMENU_CHANGE_PORT, _("Change Port Number"))

   328

                    menu.Append(self.TBMENU_CHANGE_WD, _("Change working directory"))

   329

                    menu.AppendSeparator()

   330

                    menu.Append(self.TBMENU_LIVE_SHELL, _("Launch a live Python shell"))

   331

                    menu.Append(self.TBMENU_WXINSPECTOR, _("Launch WX GUI inspector"))

   332

                menu.AppendSeparator()

   333

                menu.Append(self.TBMENU_QUIT, _("Quit"))

   334

                return menu

   335

   336

            def MakeIcon(self, img):

   337

                """

   338

                The various platforms have different requirements for the

   339

                icon size...

   340

                """

   341

                if "wxMSW" in wx.PlatformInfo:

   342

                    img = img.Scale(16, 16)

   343

                elif "wxGTK" in wx.PlatformInfo:

   344

                    img = img.Scale(22, 22)

   345

                # wxMac can be any size upto 128x128, so leave the source img alone....

   346

                icon = wx.IconFromBitmap(img.ConvertToBitmap() )

   347

                return icon

   348

   349

            def OnTaskBarStartPLC(self, evt):

   350

                if self.pyroserver.plcobj is not None: 

   351

                    self.pyroserver.plcobj.StartPLC()

   352

                evt.Skip()

   353

   354

            def OnTaskBarStopPLC(self, evt):

   355

                if self.pyroserver.plcobj is not None:

   356

                    Thread(target=self.pyroserver.plcobj.StopPLC).start()

   357

                evt.Skip()

   358

   359

            def OnTaskBarChangeInterface(self, evt):

   360

                dlg = ParamsEntryDialog(None, _("Enter the IP of the interface to bind"), defaultValue=self.pyroserver.ip_addr)

   361

                dlg.SetTests([(re.compile('\d{1,3}(?:\.\d{1,3}){3}$').match, _("IP is not valid!")),

   362

                               ( lambda x :len([x for x in x.split(".") if 0 <= int(x) <= 255]) == 4, _("IP is not valid!"))

   363

                               ])

   364

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

   365

                    self.pyroserver.ip_addr = dlg.GetValue()

   366

                    self.pyroserver.Stop()

   367

                evt.Skip()

   368

   369

            def OnTaskBarChangePort(self, evt):

   370

                dlg = ParamsEntryDialog(None, _("Enter a port number "), defaultValue=str(self.pyroserver.port))

   371

                dlg.SetTests([(UnicodeType.isdigit, _("Port number must be an integer!")), (lambda port : 0 <= int(port) <= 65535 , _("Port number must be 0 <= port <= 65535!"))])

   372

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

   373

                    self.pyroserver.port = int(dlg.GetValue())

   374

                    self.pyroserver.Stop()

   375

                evt.Skip()

   376

   377

            def OnTaskBarChangeWorkingDir(self, evt):

   378

                dlg = wx.DirDialog(None, _("Choose a working directory "), self.pyroserver.workdir, wx.DD_NEW_DIR_BUTTON)

   379

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

   380

                    self.pyroserver.workdir = dlg.GetPath()

   381

                    self.pyroserver.Stop()

   382

                evt.Skip()

   383

   384

            def OnTaskBarChangeName(self, evt):

   385

                dlg = ParamsEntryDialog(None, _("Enter a name "), defaultValue=self.pyroserver.name)

   386

                dlg.SetTests([(lambda name : len(name) is not 0 , _("Name must not be null!"))])

   387

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

   388

                    self.pyroserver.name = dlg.GetValue()

   389

                    self.pyroserver.Restart()

   390

                evt.Skip()

   391

   392

            def OnTaskBarLiveShell(self, evt):

   393

                if self.pyroserver.plcobj is not None and self.pyroserver.plcobj.python_threads_vars is not None:

   394

                    from wx import py

   395

                    #frame = py.shell.ShellFrame(locals=self.pyroserver.plcobj.python_threads_vars)

   396

                    frame = py.crust.CrustFrame(locals=self.pyroserver.plcobj.python_threads_vars)

   397

                    frame.Show()

   398

                else:

   399

                    wx.MessageBox(_("No running PLC"), _("Error"))

   400

                evt.Skip()

   401

   402

            def OnTaskBarWXInspector(self, evt):

   403

                # Activate the widget inspection tool

   404

                from wx.lib.inspection import InspectionTool

   405

                if not InspectionTool().initialized:

   406

                    InspectionTool().Init(locals=self.pyroserver.plcobj.python_threads_vars)

   407

   408

                # Find a widget to be selected in the tree.  Use either the

   409

                # one under the cursor, if any, or this frame.

   410

                wnd = wx.FindWindowAtPointer()

   411

                if not wnd:

   412

                    wnd = wx.GetApp()

   413

                InspectionTool().Show(wnd, True)

   414

                evt.Skip()

   415

   416

            def OnTaskBarQuit(self, evt):

   417

                Thread(target=self.pyroserver.Quit).start()

   418

                self.RemoveIcon()

   419

                wx.CallAfter(wx.GetApp().Exit)

   420

                evt.Skip()

   421

   422

            def UpdateIcon(self, plcstatus):

   423

                if plcstatus is "Started" :

   424

                    currenticon = self.MakeIcon(starticon.GetImage())

   425

                elif plcstatus is "Stopped":

   426

                    currenticon = self.MakeIcon(stopicon.GetImage())

   427

                else:

   428

                    currenticon = self.MakeIcon(defaulticon.GetImage())

   429

                self.SetIcon(currenticon, "Beremiz Service")

   430

   431

from runtime import PLCObject, PLCprint, ServicePublisher

   432

import Pyro.core as pyro

   433

   434

if not os.path.isdir(WorkingDir):

   435

    os.mkdir(WorkingDir)

   436

   437

def default_evaluator(tocall, *args, **kwargs):

   438

    try:

   439

        res=(tocall(*args,**kwargs), None)

   440

    except Exception,exp:

   441

        res=(None, exp)

   442

    return res

   443

   444

class Server():

   445

    def __init__(self, servicename, ip_addr, port, workdir, argv, autostart=False, statuschange=None, evaluator=default_evaluator, website=None):

   446

        self.continueloop = True

   447

        self.daemon = None

   448

        self.servicename = servicename

   449

        self.ip_addr = ip_addr

   450

        self.port = port

   451

        self.workdir = workdir

   452

        self.argv = argv

   453

        self.plcobj = None

   454

        self.servicepublisher = None

   455

        self.autostart = autostart

   456

        self.statuschange = statuschange

   457

        self.evaluator = evaluator

   458

        self.website = website

   459

   460

    def Loop(self):

   461

        while self.continueloop:

   462

            self.Start()

   463

   464

    def Restart(self):

   465

        self.Stop()

   466

   467

    def Quit(self):

   468

        self.continueloop = False

   469

        self.Stop()

   470

   471

    def Start(self):

   472

        pyro.initServer()

   473

        self.daemon=pyro.Daemon(host=self.ip_addr, port=self.port)

   474

        self.plcobj = PLCObject(self.workdir, self.daemon, self.argv, self.statuschange, self.evaluator, self.website)

   475

        uri = self.daemon.connect(self.plcobj,"PLCObject")

   476

   477

        print "Pyro port :",self.port

   478

        print "Pyro object's uri :",uri

   479

        print "Current working directory :",self.workdir

   480

   481

        # Configure and publish service

   482

        # Not publish service if localhost in address params

   483

        if (self.servicename is not None and 

   484

            self.ip_addr is not None and 

   485

            self.ip_addr != "localhost" and 

   486

            self.ip_addr != "127.0.0.1"):

   487

            print "Publishing service on local network"

   488

            self.servicepublisher = ServicePublisher.ServicePublisher()

   489

            self.servicepublisher.RegisterService(self.servicename, self.ip_addr, self.port)

   490

   491

        if self.autostart:

   492

            self.plcobj.StartPLC()

   493

   494

        sys.stdout.flush()