greg@262: #!/usr/bin/env python greg@262: # -*- coding: utf-8 -*- greg@262: greg@262: #This file is part of Beremiz, a Integrated Development Environment for greg@262: #programming IEC 61131-3 automates supporting plcopen standard and CanFestival. greg@262: # greg@262: #Copyright (C) 2007: Edouard TISSERANT and Laurent BESSARD greg@262: # greg@262: #See COPYING file for copyrights details. greg@262: # greg@262: #This library is free software; you can redistribute it and/or greg@262: #modify it under the terms of the GNU General Public greg@262: #License as published by the Free Software Foundation; either greg@262: #version 2.1 of the License, or (at your option) any later version. greg@262: # greg@262: #This library is distributed in the hope that it will be useful, greg@262: #but WITHOUT ANY WARRANTY; without even the implied warranty of greg@262: #MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU greg@262: #General Public License for more details. greg@262: # greg@262: #You should have received a copy of the GNU General Public greg@262: #License along with this library; if not, write to the Free Software greg@262: #Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA greg@262: greg@262: import os, sys, getopt greg@262: greg@262: def usage(): greg@262: print """ greg@262: Usage of Beremiz PLC execution service :\n greg@330: %s {[-n name] [-i ip] [-p port] [-x enabletaskbar] [-a autostart]|-h|--help} working_dir greg@262: -n - zeroconf service name greg@262: -i - ip of interface to bind to (x.x.x.x) greg@262: -p - port number greg@262: -h - print this help text and quit greg@330: -a - autostart PLC (0:disable 1:enable) greg@271: -x - enable/disable wxTaskbarIcon (0:disable 1:enable) greg@262: greg@262: working_dir - directory where are stored PLC files greg@262: """%sys.argv[0] greg@262: greg@262: try: greg@330: opts, argv = getopt.getopt(sys.argv[1:], "i:p:n:x:a:h") greg@262: except getopt.GetoptError, err: greg@262: # print help information and exit: greg@262: print str(err) # will print something like "option -a not recognized" greg@262: usage() greg@262: sys.exit(2) greg@262: greg@262: # default values greg@262: ip = "" greg@262: port = 3000 greg@262: name = os.environ[{ greg@262: "linux2":"USER", greg@262: "win32":"USERNAME", greg@262: }.get(sys.platform, "USER")] greg@330: autostart = False greg@271: enablewx = True greg@271: havewx = False greg@262: greg@262: for o, a in opts: greg@262: if o == "-h": greg@262: usage() greg@262: sys.exit() greg@262: elif o == "-i": greg@262: if len(a.split(".")) == 4 or a == "localhost": greg@262: ip = a greg@262: elif o == "-p": greg@262: # port: port that the service runs on greg@262: port = int(a) greg@262: elif o == "-n": greg@262: name = a greg@271: elif o == "-x": greg@271: enablewx = int(a) greg@330: elif o == "-a": greg@330: autostart = int(a) greg@262: else: greg@262: usage() greg@262: sys.exit() greg@262: etisserant@301: if len(argv) > 1: greg@262: usage() greg@262: sys.exit() etisserant@301: elif len(argv) == 1: etisserant@301: WorkingDir = argv[0] etisserant@301: elif len(argv) == 0: greg@262: WorkingDir = os.getcwd() etisserant@301: argv=[WorkingDir] greg@262: greg@271: if enablewx: greg@271: try: greg@271: import wx, re greg@330: from threading import Thread, currentThread greg@271: from types import * greg@271: havewx = True greg@271: except: greg@271: havewx = False greg@271: greg@271: if havewx: lbessard@294: try: lbessard@294: from wx.lib.embeddedimage import PyEmbeddedImage lbessard@294: except: lbessard@294: import cStringIO lbessard@294: import base64 lbessard@294: lbessard@294: class PyEmbeddedImage: lbessard@294: def __init__(self, image_string): lbessard@294: stream = cStringIO.StringIO(base64.b64decode(image_string)) lbessard@294: self.Image = wx.ImageFromStream(stream) lbessard@294: def GetImage(self): lbessard@294: return self.Image lbessard@294: greg@271: defaulticon = PyEmbeddedImage( greg@271: "iVBORw0KGgoAAAANSUhEUgAAABgAAAAYCAYAAADgdz34AAAABHNCSVQICAgIfAhkiAAABc5J" greg@271: "REFUSIl9lW1MW9cZx3/n2vf6BQO2MZiXGBISILCVUEUlitYpjaKpXZJ1XZZ2kzJVY9r6IeLD" greg@271: "pGTaNG3KtGmNNGlbpW3VFhRp0l6aZCllpVUqtVNJtBFKE5QXLxCjpCYEY7DBr9hcm3vPPgQY" greg@271: "IQmPdKR7/vd5/v/n5dxzhZSSNeYBOoGDQGcoFPINDAyUDQ0NOUdGRmyGYSiBQGCpoaGhuGnT" greg@271: "psShQ4f6WltbewEBVAK3gCBgrjJKKZFSKlLKeillt5Ty40gkMnnw4MFFQG60ysrKZHd3dyoe" greg@271: "j//bNM0Le/fuPd/e3r5lmRMpJWK5ghrgFeBIT09P4/Hjx73pdFo47HaaNlfRutnJru0OKsoE" greg@271: "E3GVqaSNa6EUw1dvIKWkoqKCrVu3FoeHh9WamppfRiKRn6wUYAUcwE7g2e7u7vrTp09XGIZB" greg@271: "W1Mdv3qtmoBPrG0hHVsMhKLj6nqOqOWn/Pjnv2dgYIC5uTl1uSM71/pbgUbg6bNnz/rPnDnj" greg@271: "dzoddO0P8Oo+jY2suDDD1Zv9DA1dfghXVbVBCFEqpcwAKEDTxMSE58SJE8+oqsq3nq/l1X0a" greg@271: "QihYtNLHLqRET03wuYp7fO9r26mpKlsVUBSl0W63V6/shZTyyIEDB344Njb21JYaG7/5bgkA" greg@271: "Dm8zTS/+7bHZLy0mSN+7yNztt8nPjYHFwfvXDf1P70zZ0ok0LS0tZy9fvvxNAGswGFQnJyef" greg@271: "KnM5+NHLzuUDsrFZ7R68zS/hrGon1PcNMPI0BIzs9tcCNvNfDqxW64uqqvqKxWJc6e3trVVV" greg@271: "leaAk6ryJ5N/9tH3GXv7Je7/5xermN3diMPXCkDfgrkg3UU0txWLxeLw+/1fB1BGR0frbTYb" greg@271: "TXWWDbNeysUoZKbIRIZBPviOzKU8ejLMHyPFcMprrweQ7iUAXC7XPiGEak2lUk02m42mWn1D" greg@271: "gfrnTiKNIrbyzSAUjEKWCx+/Mf+HyELBrLBvBhAIKDdgGsrLy+sAv1UIUa1pGv7yxQ0FbGX1" greg@271: "D+0LQmHW7fVavE5Mo/gAFCCcoOs6NpvNA7gVRVGCmqYRz1hXg7NFU39rjshawjcuvs4P+o/y" greg@271: "24uvE1+I4VCdfGfXUb76+VdWfQQCkbJSKBQoFApJTdMsCvApQDSlAjCTN7I/y5CNllpq1wqE" greg@271: "YmPciIzwwdi7BKevreK7Gp5dfbYoFoozJrquo+v6rMViWbQCV4QQzGTsQJY3kzIhvFpgfYte" greg@271: "7jhCMp9kk7uep+ueWcWj6f8Xqioq8ck0xcIS6XT6vpRy3gqMqKpqRBfKLLNF1ZRV6YBiPDrw" greg@271: "vduefwTL6hl6b74FgFVR0T4rJTU3jcvlymcymal8Ph+z9vf3p7u6uv5y/vz5bw994ld2fmUH" greg@271: "7nYFRVG4Gb3Guv8FpmmQzCcIJ+5w8c5HRFL3UYRC+ZKX633j6LpObW3tDcMwrsODq4Jbt27V" greg@271: "HT58+N7o6KgCYHfY2f2lXfi+6CJbnsAwjUeyXzFFKLgdHqb+mmL8xh22bduWmJycfHN2dvbX" greg@271: "uVwuoQC0tbXlKisrYytBi/lFZsKzOErtTyQWCOxWO36ljvl/FLk+dJOSkhJTUZR35+fn+3K5" greg@271: "XAIeXNcASz6fbxzwrxDYVQdqpARvs498IYchDUxpogiBVVFxqE7U/5Zx4c8fEo/FKS0tlR0d" greg@271: "HZ8ODg6+l06nr6zwrAp4PJ6Qpmlf2L9/fywYDFaOXB0RI1dHaGpuoq29Fa1Uxe62YeZMInei" greg@271: "jAY/IRqNAtDZ2blUV1fXPzg4+F5VVdU/H6p0eYjqsWPHvnz37t0XwuHw7d27d4eTyeTvLl26" greg@271: "FJiamnpim6qrq9mzZ094fHz875FI5J3p6ekr631WBARgaWlpCezYsePeuXPnzFAo5Dp58uS+" greg@271: "dDp91GKxNBYKBW82m3Vomqa7XK7pbDYbnJmZuR2LxYL5fP79WCyWeeys1h/D9e97enqsp06d" greg@271: "8mWzWU+xWPTkcjmXaZpxwzDCsVhsbqNggP8BMJOU3UUUf+0AAAAASUVORK5CYII=") greg@271: greg@271: #---------------------------------------------------------------------- greg@271: starticon = PyEmbeddedImage( greg@271: "iVBORw0KGgoAAAANSUhEUgAAABgAAAAYCAYAAADgdz34AAAABHNCSVQICAgIfAhkiAAABbpJ" greg@271: "REFUSIl9lltsFNcdxn9nZnbHs15fd23j9TXYC0UCKzEhMQ+oIS2g1kQ1pbFStX0opFWsovSh" greg@271: "rUqp2pS2ioTUolaKFOGHqGkiJcKRuDhOaZRiZCsCXyBgCBBfMfbu+oa9s17wzuzl9MH24mDD" greg@271: "XzoPc/6fft+c72jOGSGlZEVlAU8D9cB20zQ9HR0duRcvXszq7e01EomEUlFREa+srLR8Pl+g" greg@271: "sbHx3zk5ORcAFfACA8Bt4CFUSomUUkgpS6SUB6SUH5umOXLgwIEHqqrKJfGao7S0VB49ejRo" greg@271: "2/YnUsrT+/fvb66pqSldYiKlRCytoBB4Gfjx6dOnq5qamjwTExOKqqqU+QrYUJFN7QY32Qbc" greg@271: "vSeYCGtcux1i5M5dAPx+P1VVVQvnzp0ziouLfx8MBt9cXoAGZABbgZ1HjhwpO378eEEymaSi" greg@271: "tIBjPy9lU5nKoyWExF2yjy+mN3HsH+/Q3d3NwMCAsZTI9pVaDXgK2Hr27Nn85ubmEpdh8IMX" greg@271: "ffxirwshVrGXHBQSC/dIRvoZGuz/WkvTtHIhhCGlXABQgI2Tk5P5hw8f3uZwOGj8VjGHXnoC" greg@271: "HJCpJFbkLtr8FXbX+XC79HRPVVW/qqre9LtIKX/S0NDwy76+vq1lhTr/fM2NAmTk+fHv/dea" greg@271: "BlZkDHP0PHODH2NHg1gykw8/X7Dfb7vjTNgJqqurT3R1db0GoF2/fl0fGhqqdWca/K7RhZLO" greg@271: "WSBU55oGGXlVZORVkeV7nsFPDqKL+9TWJCI3n9rojX2mYhjGj4QQv5FSziunTp0qdjqd4hvl" greg@271: "Lnz5j49lrPMNhv7zM6b63knPuQpryMj3A9A2L++nvDaZXheqqrrXrVu3D0C5detWudPpxO/T" greg@271: "Hk8HYnOD3J+8yr3bH6XnZNImHg3xfsgenfHo5QAyJwFAdnb2HiGEppmmWa3rOhtKrCcalNT9" greg@271: "llTSwvBsXISn4nRdbJ5/czRsWvlGhQAEYtFg0kl2dnYZUKgB5U6nk5L82BMNXIU1X3uOWFH5" greg@271: "eWIuy/YYWcjU4qQAxQ22bWMYhgfIU1RV/UrXdWaiDyOyUiLROktoJfDtC8fZfWQbb//v75ix" greg@271: "MDlGnvjVC3+gflNDWiMQKPMalmVh2/a8w+HQFKAHIBR2ABCOS+uN6cTMoFstXmlwZbSba7tv" greg@271: "8hfzT7z+7k+ZnZ0BoK5yR1qjCBV7MoVt29i2PaWqqq0BvUIIQqYORHlrKj6R9BoVj0b04oY9" greg@271: "nEt+yvz3Y5yR/+Xap3XsDb/EtvV1aY1DdTA7HsW2bCKRyLiUclYBelRVldNWAfPSm4oV5ZQJ" greg@271: "Vn/G9Zv2oWt6Ous7e4K81XiC1wNNBO6OIWKgB7Mwp000TYuFw+GxWCw2qbS2tk7k5uae/eDD" greg@271: "Fn594p6SFyxRCjKLUBWF8fBoegTNMVLLm/kwdMyGGON/nePLklv0dl/Cii3gdrtvAzdg8aig" greg@271: "vb296uDBgwMjIyMCwFvoZXv9NvRnIKqHSckUyQdJrtfexPqm5LGVAuNdVaofcCVywfpexLYD" greg@271: "CsDOnTvnioqKzGXdzNQMV9tvkJEyUITyeOAjpYyAc9gxYc/GWyK2HYDF4xog6fV6h1i8FwCo" greg@271: "LK/EncwhkWGxEH9AXLMXM2H1CpQBifI3yeapZ+70d43+cSo4+95yL23g8XiGFUWp3bVrV/Ty" greg@271: "5ctZnR2ddHZ08uxzz1K9eT1GRhJls1gFlsfieK+WpJ5e/3z7pcuXzmia1rJSs3xlOg8dOvTD" greg@271: "8fHx7wQCgb4tW7bMm6b55/Pnz+eGw+FFGJDT5iT1XRWlfxHMZ06+/Vz9dCAQeG9kZKR1x44d" greg@271: "nSdPnkyuZSAArbq6eqOiKAP9/f3xlpaWgra2tlei0eiryWSyKGKa2TcaL+muwcxU5aDf9Gi+" greg@271: "L0Oh0BehUOiaZVlnAoHAzFr7Ih75bVnVb2pqcvf09Phi0ei6+/rUC6lw1k0p5bSUctThcIwP" greg@271: "Dw/HnwT4P6CDl+TMvD0JAAAAAElFTkSuQmCC") greg@271: greg@271: #---------------------------------------------------------------------- greg@271: stopicon = PyEmbeddedImage( greg@271: "iVBORw0KGgoAAAANSUhEUgAAABgAAAAYCAYAAADgdz34AAAABHNCSVQICAgIfAhkiAAABPRJ" greg@271: "REFUSImdlllsVGUUx3/f/e4sd5iZLjNt6XSFdtgkjWFRePABDaCBGgjamIg81CU0aoxbRHww" greg@271: "+EDkhWjEB5rYGEMUxQTCJg8EoQ2BbgrFCNJWltplgC63naEzd+bO50NLLVAq4STfwz3nfP/f" greg@271: "PSf3O98VSikmmQ94HFgDLDdNM1BfX5955swZX0tLi5FKpbSSkpJkaWlpIhQKdVdVVX2XkZFx" greg@271: "EpBAEGgHLgH/iSqlUEoJpVSBUqpaKXXYNM0r1dXVt6WUajx5ylVYWKi2bdvWY1nWUaXUgQ0b" greg@271: "NtRWVFQUjmuilEKMV5ALvAhsPHDgQFlNTU2gr69Pk1JSFMphTomfRXO8+A243i/oG9I5f6mX" greg@271: "K1evAxAOhykrKxs9duyYkZ+f/0lPT8/2OwXogBtYDKzYunVr0c6dO3Ns26akMIcdbxQyv0hy" greg@271: "rwmh8Bas5/eb89nxRR1NTU20t7cb4x1ZPjlXB2YBiw8ePJhdW1tb4DEMXng6xJtrPQhxn/Y4" greg@271: "QSM12o89fJnOjst3hXRdLxZCGEqpUQANmBuJRLK3bNmy1OFwUPVMPm9VTiMOqLRNYvg6+shv" greg@271: "rFoWwutxTcSklGEpZXDiXZRSr6xbt+6dtra2xUW5Lr7c7EUD3Flhwmu/nRKQGO7CvHaCwY7D" greg@271: "WNEeEmoGe0+PWnuOXHWmrBTl5eW7GxsbNwPoFy5ccHV2di7yzjD4uMqDNtFngZDOKQHurDLc" greg@271: "WWX4Qk/ScfRVXCLGoorU8J+z5gbjxyWGYbwshPhQKTWi7d+/P9/pdIp5xR5C2Q9uS1fDp3T+" greg@271: "8jo32uomfJ7cCtzZYQCOjKhYOmgxI+hBSumdOXPmegDt4sWLxU6nk3BIf7A6EB/sIBY5R/+l" greg@271: "nyd8yrZIRnvZ02tduxVwFQOojBQAfr9/tRBC103TLHe5XMwpSEwLKFj2EWk7gRGYOyaeTtJ4" greg@271: "pnZk+7UhM5FtlAhAIMYAESd+v78IyNWBYqfTSUF2fFqAJ7firufhRFSdTg36rIDhQ6XHnAI0" greg@271: "L1iWhWEYASBLl1L+JaWcfSuqk+u3AUikRer4ADffg/w7gt80fs35r34k3BYh2xNAarooAJ4d" greg@271: "vsHgaP8EWMR17GiaVo8r0+Fw6DrQDDzXO+RgQSjBUFIlPh+wB0vLZD6TrLWrkWRXB29fGAK6" greg@271: "pql1rNXVmrCklJYGtAgh6DXHDsuuG8k+O9M5895tq+atpSwwZ9o2TjZlWTGl1IAGNEsp1c1E" greg@271: "DiMqmI7nZRQJ7j/G6xZWMS/vsYcGkEzG4vF4RDt06FBfZmbmwR/27uOD3f1aVk+BljMjD6lp" greg@271: "/DN07a4VTYw8tL4rrQZgbNixadOm90+dOvX82cZmcbaxmWBukOVrlvJudw1R1xDp8a+kuPM6" greg@271: "Gx8S4LXtCIwNO1asWDGYl5dn3gneunGLc7/+gTttoAntQRrTmgMmpimAHQwGOycnlBaX4rUz" greg@271: "8LszMRweXLr7kWB35oMdCAT+1jRt0cqVK6Otra2+hvoGGuobWPLEEsoXzkbPkLhvR4CBRwJY" greg@271: "Xq/3SGVlZbq7u7utsrJyxDTNz06cOJHZ0tRCS1MLAKuRwNQT9v8AyV27dn1fXl7eqmlae11d" greg@271: "XXLfvn0/+Xy+l6LR6Gu2befFYjFfzrk2FzeHp7mK7jdxz2/LffGamhpvc3NzyLKsbFd3z1PG" greg@271: "aHyBTKdjum0POGzbFAp7qo0xVOtJZdf/C/wRDnL5FYGSAAAAAElFTkSuQmCC") greg@271: greg@271: class ParamsEntryDialog(wx.TextEntryDialog): greg@271: if wx.VERSION < (2, 6, 0): greg@271: def Bind(self, event, function, id = None): greg@271: if id is not None: greg@271: event(self, id, function) greg@271: else: greg@271: event(self, function) greg@271: greg@271: greg@271: def __init__(self, parent, message, caption = "Please enter text", defaultValue = "", greg@271: style = wx.OK|wx.CANCEL|wx.CENTRE, pos = wx.DefaultPosition): greg@271: wx.TextEntryDialog.__init__(self, parent, message, caption, defaultValue, style, pos) greg@271: greg@271: self.Tests = [] greg@271: if wx.VERSION >= (2, 8, 0): greg@271: self.Bind(wx.EVT_BUTTON, self.OnOK, id=self.GetAffirmativeId()) greg@271: elif wx.VERSION >= (2, 6, 0): greg@271: self.Bind(wx.EVT_BUTTON, self.OnOK, id=self.GetSizer().GetItem(3).GetSizer().GetAffirmativeButton().GetId()) greg@271: else: greg@271: self.Bind(wx.EVT_BUTTON, self.OnOK, id=self.GetSizer().GetItem(3).GetSizer().GetChildren()[0].GetSizer().GetChildren()[0].GetWindow().GetId()) greg@271: greg@271: def OnOK(self, event): greg@271: value = self.GetValue() greg@271: texts = {"value" : value} greg@271: for function, message in self.Tests: greg@271: if not function(value): greg@271: message = wx.MessageDialog(self, message%texts, "Error", wx.OK|wx.ICON_ERROR) greg@271: message.ShowModal() greg@271: message.Destroy() greg@271: return greg@271: self.EndModal(wx.ID_OK) etisserant@290: event.Skip() greg@271: greg@271: def GetValue(self): greg@271: return self.GetSizer().GetItem(1).GetWindow().GetValue() greg@271: greg@271: def SetTests(self, tests): greg@271: self.Tests = tests greg@271: etisserant@290: class BeremizTaskBarIcon(wx.TaskBarIcon): greg@330: TBMENU_START = wx.NewId() greg@330: TBMENU_STOP = wx.NewId() greg@271: TBMENU_CHANGE_NAME = wx.NewId() greg@271: TBMENU_CHANGE_PORT = wx.NewId() greg@271: TBMENU_CHANGE_INTERFACE = wx.NewId() etisserant@290: TBMENU_LIVE_SHELL = wx.NewId() etisserant@303: TBMENU_WXINSPECTOR = wx.NewId() greg@271: TBMENU_CHANGE_WD = wx.NewId() greg@271: TBMENU_QUIT = wx.NewId() greg@271: greg@271: def __init__(self, pyroserver): greg@271: wx.TaskBarIcon.__init__(self) etisserant@290: self.pyroserver = pyroserver greg@271: # Set the image greg@271: self.UpdateIcon(None) greg@271: greg@271: # bind some events greg@330: self.Bind(wx.EVT_MENU, self.OnTaskBarStartPLC, id=self.TBMENU_START) greg@330: self.Bind(wx.EVT_MENU, self.OnTaskBarStopPLC, id=self.TBMENU_STOP) greg@271: self.Bind(wx.EVT_MENU, self.OnTaskBarChangeName, id=self.TBMENU_CHANGE_NAME) greg@271: self.Bind(wx.EVT_MENU, self.OnTaskBarChangeInterface, id=self.TBMENU_CHANGE_INTERFACE) etisserant@290: self.Bind(wx.EVT_MENU, self.OnTaskBarLiveShell, id=self.TBMENU_LIVE_SHELL) etisserant@303: self.Bind(wx.EVT_MENU, self.OnTaskBarWXInspector, id=self.TBMENU_WXINSPECTOR) greg@271: self.Bind(wx.EVT_MENU, self.OnTaskBarChangePort, id=self.TBMENU_CHANGE_PORT) greg@271: self.Bind(wx.EVT_MENU, self.OnTaskBarChangeWorkingDir, id=self.TBMENU_CHANGE_WD) greg@271: self.Bind(wx.EVT_MENU, self.OnTaskBarQuit, id=self.TBMENU_QUIT) greg@271: greg@271: def CreatePopupMenu(self): greg@271: """ greg@271: This method is called by the base class when it needs to popup greg@271: the menu for the default EVT_RIGHT_DOWN event. Just create greg@271: the menu how you want it and return it from this function, greg@271: the base class takes care of the rest. greg@271: """ greg@271: menu = wx.Menu() greg@330: menu.Append(self.TBMENU_START, "Start PLC") greg@330: menu.Append(self.TBMENU_STOP, "Stop PLC") greg@271: menu.Append(self.TBMENU_CHANGE_NAME, "Change Name") greg@271: menu.Append(self.TBMENU_CHANGE_INTERFACE, "Change IP of interface to bind") etisserant@290: menu.Append(self.TBMENU_LIVE_SHELL, "Launch a live Python shell") etisserant@303: menu.Append(self.TBMENU_WXINSPECTOR, "Launch WX GUI inspector") greg@271: menu.Append(self.TBMENU_CHANGE_PORT, "Change Port Number") greg@271: menu.AppendSeparator() greg@271: menu.Append(self.TBMENU_CHANGE_WD, "Change working directory") greg@271: menu.Append(self.TBMENU_QUIT, "Quit") greg@271: return menu greg@271: greg@271: def MakeIcon(self, img): greg@271: """ greg@271: The various platforms have different requirements for the greg@271: icon size... greg@271: """ greg@271: if "wxMSW" in wx.PlatformInfo: greg@271: img = img.Scale(16, 16) greg@271: elif "wxGTK" in wx.PlatformInfo: greg@271: img = img.Scale(22, 22) greg@271: # wxMac can be any size upto 128x128, so leave the source img alone.... greg@271: icon = wx.IconFromBitmap(img.ConvertToBitmap() ) greg@271: return icon greg@271: greg@330: def OnTaskBarStartPLC(self, evt): greg@330: if self.pyroserver.plcobj is not None: greg@330: self.pyroserver.plcobj.StartPLC() greg@330: evt.Skip() greg@330: greg@330: def OnTaskBarStopPLC(self, evt): greg@330: if self.pyroserver.plcobj is not None: greg@330: self.pyroserver.plcobj.StopPLC() greg@330: evt.Skip() greg@330: greg@330: def OnTaskBarChangeInterface(self, evt): greg@330: dlg = ParamsEntryDialog(None, "Enter the ip of the interface to bind", defaultValue=self.pyroserver.ip) greg@271: dlg.SetTests([(re.compile('\d{1,3}(?:\.\d{1,3}){3}$').match, "Ip is not valid!"), greg@271: ( lambda ip :len([x for x in ip.split(".") if 0 <= int(x) <= 255]) == 4, "Ip is not valid!") greg@271: ]) greg@271: if dlg.ShowModal() == wx.ID_OK: etisserant@290: self.pyroserver.ip = dlg.GetValue() etisserant@290: self.pyroserver.Stop() etisserant@290: evt.Skip() greg@271: greg@330: def OnTaskBarChangePort(self, evt): greg@330: dlg = ParamsEntryDialog(None, "Enter a port number ", defaultValue=str(self.pyroserver.port)) greg@271: dlg.SetTests([(UnicodeType.isdigit, "Port number must be an integer!"), (lambda port : 0 <= int(port) <= 65535 , "Port number must be 0 <= port <= 65535!")]) greg@271: if dlg.ShowModal() == wx.ID_OK: etisserant@290: self.pyroserver.port = int(dlg.GetValue()) etisserant@290: self.pyroserver.Stop() etisserant@290: evt.Skip() greg@271: greg@330: def OnTaskBarChangeWorkingDir(self, evt): greg@330: dlg = wx.DirDialog(None, "Choose a working directory ", self.pyroserver.workdir, wx.DD_NEW_DIR_BUTTON) greg@271: if dlg.ShowModal() == wx.ID_OK: etisserant@290: self.pyroserver.workdir = dlg.GetPath() etisserant@290: self.pyroserver.Stop() etisserant@290: evt.Skip() greg@271: greg@330: def OnTaskBarChangeName(self, evt): greg@330: dlg = ParamsEntryDialog(None, "Enter a name ", defaultValue=self.pyroserver.name) greg@271: dlg.SetTests([(lambda name : len(name) is not 0 , "Name must not be null!")]) greg@271: if dlg.ShowModal() == wx.ID_OK: etisserant@290: self.pyroserver.name = dlg.GetValue() etisserant@290: self.pyroserver.Restart() etisserant@290: evt.Skip() etisserant@290: greg@330: def OnTaskBarLiveShell(self, evt): etisserant@290: if self.pyroserver.plcobj is not None and self.pyroserver.plcobj.python_threads_vars is not None: etisserant@290: from wx import py etisserant@303: #frame = py.shell.ShellFrame(locals=self.pyroserver.plcobj.python_threads_vars) etisserant@303: frame = py.crust.CrustFrame(locals=self.pyroserver.plcobj.python_threads_vars) etisserant@290: frame.Show() etisserant@290: else: etisserant@290: wx.MessageBox("No runnning PLC","Error") etisserant@290: evt.Skip() etisserant@290: etisserant@303: def OnTaskBarWXInspector(self, evt): etisserant@303: # Activate the widget inspection tool etisserant@303: from wx.lib.inspection import InspectionTool etisserant@303: if not InspectionTool().initialized: etisserant@303: InspectionTool().Init(locals=self.pyroserver.plcobj.python_threads_vars) etisserant@303: etisserant@303: # Find a widget to be selected in the tree. Use either the etisserant@303: # one under the cursor, if any, or this frame. etisserant@303: wnd = wx.FindWindowAtPointer() etisserant@303: if not wnd: etisserant@303: wnd = wx.GetApp() etisserant@303: InspectionTool().Show(wnd, True) etisserant@303: evt.Skip() etisserant@303: greg@330: def OnTaskBarQuit(self, evt): greg@330: self.pyroserver.Quit() greg@271: self.RemoveIcon() greg@330: wx.CallAfter(wx.GetApp().Exit) etisserant@290: evt.Skip() greg@271: greg@271: def UpdateIcon(self, plcstatus): greg@271: if plcstatus is "Started" : greg@271: currenticon = self.MakeIcon(starticon.GetImage()) greg@271: elif plcstatus is "Stopped": greg@271: currenticon = self.MakeIcon(stopicon.GetImage()) greg@271: else: greg@271: currenticon = self.MakeIcon(defaulticon.GetImage()) greg@271: self.SetIcon(currenticon, "Beremiz Service") greg@271: greg@262: from runtime import PLCObject, ServicePublisher greg@262: import Pyro.core as pyro greg@262: greg@262: if not os.path.isdir(WorkingDir): greg@262: os.mkdir(WorkingDir) greg@262: etisserant@319: def default_evaluator(callable, *args, **kwargs): etisserant@319: return callable(*args,**kwargs) etisserant@319: greg@262: class Server(): greg@330: def __init__(self, name, ip, port, workdir, argv, autostart=False, statuschange=None, evaluator=default_evaluator): greg@262: self.continueloop = True greg@262: self.daemon = None greg@262: self.name = name greg@262: self.ip = ip greg@262: self.port = port greg@262: self.workdir = workdir etisserant@301: self.argv = argv greg@262: self.plcobj = None greg@263: self.servicepublisher = None greg@330: self.autostart = autostart greg@269: self.statuschange = statuschange etisserant@301: self.evaluator = evaluator etisserant@301: etisserant@301: def Loop(self): greg@262: while self.continueloop: greg@262: self.Start() greg@262: greg@262: def Restart(self): greg@262: self.Stop() greg@262: greg@262: def Quit(self): greg@262: self.continueloop = False greg@262: self.Stop() greg@262: greg@262: def Start(self): greg@262: pyro.initServer() greg@262: self.daemon=pyro.Daemon(host=self.ip, port=self.port) etisserant@301: self.plcobj = PLCObject(self.workdir, self.daemon, self.argv, self.statuschange, self.evaluator) greg@262: uri = self.daemon.connect(self.plcobj,"PLCObject") greg@262: greg@262: print "The daemon runs on port :",self.port greg@262: print "The object's uri is :",uri greg@262: print "The working directory :",self.workdir greg@262: greg@262: # Configure and publish service greg@262: # Not publish service if localhost in address params greg@262: if self.ip != "localhost" and self.ip != "127.0.0.1": greg@263: print "Publish service on local network" greg@330: self.servicepublisher = ServicePublisher.ServicePublisher() greg@262: self.servicepublisher.RegisterService(self.name, self.ip, self.port) greg@262: greg@330: if self.autostart: greg@330: self.plcobj.StartPLC() greg@330: greg@262: sys.stdout.flush() greg@262: greg@262: self.daemon.requestLoop() greg@262: greg@262: def Stop(self): greg@330: self.plcobj.StopPLC() greg@263: if self.servicepublisher is not None: greg@263: self.servicepublisher.UnRegisterService() greg@263: del self.servicepublisher greg@262: self.daemon.shutdown(True) greg@269: greg@262: greg@262: if havewx: etisserant@301: from threading import Semaphore etisserant@301: wx_eval_lock = Semaphore(0) greg@262: app=wx.App(redirect=False) greg@330: mythread = currentThread() greg@330: greg@269: def statuschange(status): greg@269: wx.CallAfter(taskbar_instance.UpdateIcon,status) etisserant@301: etisserant@301: eval_res = None etisserant@301: def wx_evaluator(callable, *args, **kwargs): etisserant@301: global eval_res etisserant@301: eval_res=callable(*args,**kwargs) etisserant@301: #print eval_res etisserant@301: wx_eval_lock.release() etisserant@301: etisserant@301: def evaluator(callable, *args, **kwargs): greg@330: # call directly the callable function if call from the wx mainloop (avoid dead lock) greg@330: if(mythread == currentThread()): greg@330: callable(*args,**kwargs) greg@330: else: greg@330: wx.CallAfter(wx_evaluator,callable,*args,**kwargs) greg@330: wx_eval_lock.acquire() etisserant@301: return eval_res etisserant@301: greg@330: pyroserver = Server(name, ip, port, WorkingDir, argv, autostart, statuschange, evaluator) etisserant@301: taskbar_instance = BeremizTaskBarIcon(pyroserver) etisserant@301: etisserant@301: pyro_thread=Thread(target=pyroserver.Loop) greg@262: pyro_thread.start() greg@262: app.MainLoop() greg@262: else: greg@330: pyroserver = Server(name, ip, port, WorkingDir, argv, autostart) greg@262: pyroserver.Loop()