# -*- coding: utf-8 -*- version = "3.6" # # This file is part of EventGhost. # Copyright (C) 2005-2009 Lars-Peter Voss # # EventGhost is free software; you can redistribute it and/or modify it under # the terms of the GNU General Public License version 2 as published by the # Free Software Foundation; # # EventGhost is distributed in the hope that it will be useful, but WITHOUT ANY # WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR # A PARTICULAR PURPOSE. See the GNU General Public License for more details. # # You should have received a copy of the GNU General Public License # along with this program. If not, see . # # # Changelog (in reverse chronological order): # ------------------------------------------- # 3.6 by Pako 2015-03-02 09:41 UTC+1 # - message can now include the word Ping # 3.5 by krambriw 2014-02-26 # - Added support for client initiated high level ping/pong # - Detecting 'WebSocket Protocol Error' and 'Masked frame from server' errors in handle_one_request function # to improve session keep alive # 3.4 by Pako 2014-12-28 11:30 UTC+1 # - WebSocket client actions added # 3.3 by Pako 2014-11-30 06:57 UTC+1 # - bugfix ("Send event to another EventGhost" feature failed since 3.0) # 3.2 by Sem;colon 2014-11-22 10:00 UTC+1 # - ExecuteScript now raises exceptions in EventGhost Log # 3.1 by Pako 2014-11-20 06:25 UTC+1 # - added support of temporary and persistent variables when rendering page # - bugfixes # 3.0 by Pako 2014-11-16 15:46 UTC+1 # - added WebSocket support and actions (Tornado webserver compatible) # 2.1 by Pako 2014-02-14 11:14 UTC+1 # - added option to serve with secured protocol (https://) # 2.0 by Sem;colon 2014-01-04 22:15 UTC+1 # - fixed bug (eventghost crashes if submitting the Set (persistent) value configuration window) # - removed decoding of the return value for the SendEventExt action (could cause problems sometimes) # the code must now be decoded in a script manually (if decoding is needed) # 1.9 by Pako 2013-12-04 14:36 UTC+1 # - added option to disable parsing of strings (Sem;colon's solutions) # 1.8 by Sem;colon 2013-11-06 20:10 UTC+1 # - added menue entries (plugin configuration) to customize the join strings in the do_POST Enhancement by Sem;colon # - improved handling of some returned datatypes in the do_POST Enhancement by Sem;colon # - fixed bug in end_request # 1.7 by Pako 2013-09-15 08:58 UTC+1 # - added Autosave option (when a persistent value changed) # - added do_POST (Ajax/JSON) method "GetGlobalValue" # - fixed do_POST (Ajax/JSON) methods "Set(Persistent)Value" # 1.6 by Sem;colon 2013-09-07 22:00 UTC+1 # - edited the POST enhancement by Sem;colon: # -changed the function "request=" to GetGlobalValue # -added loop for GetValue requests to be able to request multible values at once # -fixed bug: GetValue didn't return a value # - changed "author" line, so that it showes up correctly under "Special Thanks" # 1.5 by Sem;colon 2013-08-31 09:32 UTC+1 # - extended the POST enhancement by Sem;colon # to match the functionality of the AJAX JSON POST # 1.4 by Pako 2013-08-09 11:02 UTC+1 # - bugfixes # 1.3 by Pako 2013-08-05 20:30 UTC+1 # - bugfixes # - class text added to SendEventExt action # 1.2 by Pako 2013-08-02 14:57 UTC+1 # - added url support link to forum # - added support of variables (temporary and persistent) # - added actions Get/Set (Persistent) Value and Set Clients Flags # - do_POST method "TriggerEvent" can now use another prefixes too # - new methods for do_POST: Get/Set (Persistent) Value, Get All Values, ... # - ... Get Changed Values, Execute Script (return a result !) # - do_POST is no longer limited to JSON Request (author: Sem;colon) # - new action SendEventExt (author: Sem;colon) import eg eg.RegisterPlugin( name = "Webserver", author = "Bitmonster & Pako & Sem;colon & krambriw", version = version, guid = "{E4305D8E-A3D3-4672-B06E-4EA1F0F6C673}", description = ur''' Implements a small webserver, that you can use to generate events through HTML-pages and WebSocket. Implementation of WebSocket support was made possible through the article_, published on the SevenWatt_ web.. Plugin version: %s .. _article: http://www.sevenwatt.com/main/websocket-html-webserver-python/ .. _SevenWatt: http://www.sevenwatt.com/main/ ''' % version, createMacrosOnAdd = True, canMultiLoad = True, icon = ( "iVBORw0KGgoAAAANSUhEUgAAABAAAAAQCAYAAAAf8/9hAAAABmJLR0QA/wD/AP+gvaeT" "AAAACXBIWXMAAA3XAAAN1wFCKJt4AAAAB3RJTUUH1gEECzsZ7j1DbAAAAu1JREFUOMul" "kztsW3UUxn////Xb1684NXbzsOskA6UiklWCCOmCCiKwsCDBjBShThVCDICYgCIxMHgC" "BhYYkbJAhaIoIBCKKvUBhArHGLexaar4/bj2ffjey0CboagTZ/l0jo5+Ovp0PvifJR4c" "5F64NOMX7kcoyrppOwmBwOcRHTGZXBk7YuPW5bfrDwWcWv/gdSFlcWEp55mZyxCJhBGA" "ruvcqd+lXKpOsMxLpW/ffe8/gNz6h6/FYuFP184VlNO5E8yfTJEKu2QSQbojk51rt7nx" "Z4Pr124Sks7HP3918S0ACfDJlz+ueBRZfPaZJ5R3Xinw3HKKx7MRCgtTzCaDRAMKwjJo" "N1qcWX6Uu93xm/nn358/Bmzt7r+RX8wG4kGFdm+MGo3h93lojaCnO5RrbZpjQXYmSSrq" "Y2EpJ7zC/QLAA1Ctt5568lxeDHULTYaYQtLUwCOh3dX47Osr9EcG0qOgjUzyi1lq1drK" "MWBs2ul4LMLiXJxkSHLQNvB5PWiWzfZuid5wjGnZGMMxXr+faFTFmNihY4DANXyK9L28" "NkejM6J5NET4VSa2jaqGkIrEtWxsx0EfaAC47r/my3vN3mg4sAcjk0wyTLvR4vL31zls" "9FG8Pp5eXWZm9hEmtoMQgn5/iILbPr4AIbaq1b+Xd/ZmQ/WDO5QPWmSmIzQ6A8aWjTY2" "SSdVMoVTBFSVq7/XXOHY3wEoAPGl8+VWq3fBDai+W0ea2K8c0hxa5OdPoOAQUCRnl6bZ" "eKnASLf49ZdSM51OvvrH7mZXAeiWtweR3FrvqNF7Mb8wh5QSfzjEYVujdtRnYtuczk4x" "HQ3gdQwrEZxs39j6fKdSqbSU+5/Y++uHsieateuHg9VYPCpTqSSp6QSJmIqhm+z9VnJu" "V6o9Jv2beq++WywWf3IcZ/hgmNKh9JnVk4+d31CCyRXDljEAx9T6zrC+dzYrribCcn9z" "c/ObTqdzALjiIQmNArF76gcMYAB0gT7g3l/+ByWIP9hU8ktfAAAAAElFTkSuQmCC" ), url = "http://www.eventghost.net/forum/viewtopic.php?f=9&t=1663", ) import wx import socket from os import curdir, pardir from sys import getwindowsversion, path as syspath from ssl import wrap_socket, CERT_NONE from posixpath import splitext, normpath from time import sleep, strftime from datetime import datetime as dt from urllib import unquote, unquote_plus from urllib2 import urlopen, Request as urlRequest from httplib import HTTPResponse from jinja2 import BaseLoader, TemplateNotFound, Environment from copy import deepcopy as cpy from json import dumps, loads from re import IGNORECASE, compile as re_compile from struct import pack, unpack from base64 import b64encode, encodestring as b64_encStr from hashlib import sha1 from threading import Thread, Event from BaseHTTPServer import HTTPServer from SimpleHTTPServer import SimpleHTTPRequestHandler from SocketServer import ThreadingMixIn from os.path import getmtime, isfile, isdir, join, exists, splitdrive, split from wx.lib.mixins.listctrl import TextEditMixin #mod_pth = abspath(split(__file__)[0]) #syspath.append(mod_pth + "\\lib") from websocket import WebSocketApp SYS_VSCROLL_X = wx.SystemSettings.GetMetric(wx.SYS_VSCROLL_X) true = True false = False METHODS = ( "SetValue", "SetPersistentValue", "ExecuteScript", "TriggerEvent", "GetGlobalValue", "GetValue", "GetPersistentValue", "GetAllValues", "GetChangedValues", "TriggerEnduringEvent", "RepeatEnduringEvent", "EndLastEvent", "Ping" ) #=============================================================================== def ClientChoice(evt, text, panel, id3, id4, cl_ip, cl_port, size2, rBMC): middleSizer = panel.sizer.GetItem(0).GetSizer() dynamicSizer = middleSizer.GetItem(2).GetSizer() dynamicSizer.Clear(True) middleSizer.Detach(dynamicSizer) dynamicSizer.Destroy() dynamicSizer = wx.GridBagSizer(2, 10) dynamicSizer.SetMinSize(size2) middleSizer.Add(dynamicSizer,1, wx.EXPAND) mode = rBMC.GetSelection() portCtrl = None if mode == 1: if evt: evt.Skip() return txtLabel = wx.StaticText(panel,-1,text.host) txtCtrl = wx.TextCtrl(panel, id3, cl_ip) dynamicSizer.Add(txtLabel,(0,0),(1,1)) dynamicSizer.Add(txtCtrl,(1,0),(1,1),flag = wx.EXPAND) portLabel = wx.StaticText(panel,-1,text.port) portCtrl = wx.TextCtrl(panel, id4, cl_port) dynamicSizer.Add(portLabel,(2,0),(1,1),flag = wx.TOP, border = 10) dynamicSizer.Add(portCtrl,(3,0),(1,1)) panel.sizer.Layout() if evt: evt.Skip() #=============================================================================== class WebSocketClient(WebSocketApp): def __init__(self, title, url, login, password, noCert, plugin): kwargs = { 'on_open' : plugin.on_open, 'on_message' : plugin.on_message, 'on_error' : self.on_error, 'on_close' : self.on_close, } if login is not None: password = password if password is not None else "" kwargs['header']=["Authorization:Basic " + b64encode(login+":"+password)] WebSocketApp.__init__(self, url, **kwargs) self.url = url self.conTime = None self.title = title self.noCert = noCert self.plugin = plugin def on_error(self, _, error): eg.PrintError(self.plugin.text.wsConError % self.title) eg.PrintError(u"[Error %i] %s" % ( error.args[0], error.args[1].decode(eg.systemEncoding) )) #try: # del self.plugin.wsServers[self.title] #except: # pass try: self.close() except: pass def on_close(self, _): try: del self.plugin.wsServers[self.title] except: pass self.plugin.TriggerEvent( "%s.%s" % (self.plugin.text.wsServerDisconn, self.title), payload = self.title ) def start(self): if self.noCert: self.run_forever(sslopt={"cert_reqs": CERT_NONE}) else: self.run_forever() #=============================================================================== class Table(wx.ListCtrl): def __init__(self, parent, header, minRows): wx.ListCtrl.__init__( self, parent, -1, style=wx.LC_REPORT|wx.VSCROLL|wx.HSCROLL|wx.LC_HRULES|wx.LC_VRULES, ) for i, colLabel in enumerate(header): self.InsertColumn( i, colLabel, format = wx.LIST_FORMAT_LEFT ) self.InsertStringItem(0, "dummy") rect = self.GetItemRect(0, wx.LIST_RECT_BOUNDS) self.minHeight = 4 + rect[1] + minRows * rect[3] self.DeleteAllItems() #=============================================================================== class VarTable(wx.ListCtrl, TextEditMixin): def __init__(self, parent, txt, edit): wx.ListCtrl.__init__( self, parent, -1, style = wx.LC_REPORT|wx.LC_HRULES|wx.LC_VRULES|wx.LC_EDIT_LABELS, ) self.edit = edit self.edCell = None self.Show(False) TextEditMixin.__init__(self) self.editor.SetBackgroundColour(wx.Colour(135, 206, 255)) self.InsertColumn(0, txt.vrbl) self.InsertColumn(1, txt.defVal, wx.LIST_FORMAT_LEFT) self.SetColumnWidth(0, wx.LIST_AUTOSIZE_USEHEADER) self.SetColumnWidth(1, wx.LIST_AUTOSIZE_USEHEADER) self.InsertStringItem(0, "dummy") rect = self.GetItemRect(0, wx.LIST_RECT_BOUNDS) hh = rect[1] #header height hi = rect[3] #item height self.DeleteAllItems() self.w0 = self.GetColumnWidth(0) self.w1 = self.GetColumnWidth(1) self.wk = SYS_VSCROLL_X+self.GetWindowBorderSize()[0]+self.w0 + self.w1 width = self.wk rows = 10 self.SetMinSize((max(width, 200), 2 + hh + rows * hi)) self.Bind(wx.EVT_SIZE, self.OnSize) self.Show(True) def SetWidth(self): w = (self.GetSize().width - self.wk) w0_ = w/2 + self.w0 w1_ = w/2 + self.w1 self.SetColumnWidth(0, w0_) self.SetColumnWidth(1, w1_) def OnSize(self, event): wx.CallAfter(self.SetWidth) event.Skip() def FillData(self, data): self.DeleteAllItems() cnt = len(data) i = 0 for key, value in data.iteritems(): self.InsertStringItem(i, key) self.SetStringItem(i, 1, value) i += 1 self.Enable(i > 0) def OpenEditor(self, col, row): #Hack of default method if self.edit: self.edCell = (row, col, self.GetItem(row, col).GetText()) #Remember pos and value!!! TextEditMixin.OpenEditor(self, col, row) def CloseEditor(self, event = None): #Hack of default method TextEditMixin.CloseEditor(self, event) if not event: self.SetStringItem(*self.edCell) #WORKAROUND !!! elif isinstance(event, wx.CommandEvent): row, col, oldVal = self.edCell newVal = self.GetItem(row, col).GetText() evt = eg.ValueChangedEvent(self.GetId(), value = (row, col, newVal)) wx.PostEvent(self, evt) def DeleteSelectedItems(self): item = self.GetFirstSelected() selits = [] while item != -1: selits.append(item) item = self.GetNextSelected(item) selits.reverse() for item in selits: self.DeleteItem(item) def GetData(self): data = {} for row in range(self.GetItemCount()): data[self.GetItemText(row)] = self.GetItem(row, 1).GetText() return data #=============================================================================== class KeysAsAttrs: def __init__(self, pairSet): self._pairSet = pairSet def __getattr__(self, key): try: return self._pairSet[key] except KeyError,err: raise AttributeError(key) #=============================================================================== class VariableDialog(wx.Frame): def __init__(self, parent, plugin, pers=False): wx.Frame.__init__( self, parent, -1, style = wx.DEFAULT_DIALOG_STYLE | wx.TAB_TRAVERSAL|wx.RESIZE_BORDER, name="Variable manager/viewer" ) self.panel = parent self.plugin = plugin self.text = plugin.text self.SetIcon(self.plugin.info.icon.GetWxIcon()) self.pers = pers def ShowVariableDialog(self, title): self.panel.Enable(False) self.panel.dialog.buttonRow.cancelButton.Enable(False) self.panel.EnableButtons(False) self.SetTitle(title) text = self.plugin.text panel = wx.Panel(self) varTable = VarTable(panel, self.text, self.pers) varTable.FillData(self.plugin.pubPerVars) sizer = wx.BoxSizer(wx.VERTICAL) panel.SetSizer(sizer) intSizer = wx.BoxSizer(wx.VERTICAL) intSizer.Add(varTable,1,wx.EXPAND|wx.BOTTOM, 5) sizer.Add(intSizer,1,wx.EXPAND|wx.TOP|wx.LEFT|wx.RIGHT,10) if self.pers: # Persistent variable manager varTable.FillData(self.plugin.pubPerVars) btn3 = wx.Button(panel, -1, self.text.delete) btn3.Enable(False) btn4 = wx.Button(panel, -1, self.text.clear) delSizer = wx.BoxSizer(wx.HORIZONTAL) delSizer.Add(btn3) delSizer.Add(btn4,0,wx.LEFT,10) intSizer.Add(delSizer) def onDelete(evt): varTable.DeleteSelectedItems() btn3.Enable(False) evt.Skip() btn3.Bind(wx.EVT_BUTTON, onDelete) def onClear(evt): varTable.DeleteAllItems() evt.Skip() btn4.Bind(wx.EVT_BUTTON, onClear) def OnItemSelected(event): selCnt = varTable.GetSelectedItemCount() btn3.Enable(selCnt>0) varTable.GetSelectedItemCount() event.Skip() varTable.Bind(wx.EVT_LIST_ITEM_SELECTED, OnItemSelected) varTable.Bind(wx.EVT_LIST_ITEM_DESELECTED, OnItemSelected) btn1 = wx.Button(panel, wx.ID_OK) btn1.SetLabel(text.ok) btn1.SetDefault() def onOK(evt): flag = False data = varTable.GetData() pubPerVars = self.plugin.pubPerVars old = list(pubPerVars.iterkeys()) new = list(data.iterkeys()) deleted = list(set(old)-set(new)) #renamed = list(set(new)-set(old)) for key in deleted: self.plugin.DelPersistentValue(key) for key, value in data.iteritems(): if key not in pubPerVars or value != pubPerVars[key]: pubPerVars[key] = value flag = True if flag or len(deleted): wx.CallAfter(self.plugin.SetDocIsDirty) self.Close() btn1.Bind(wx.EVT_BUTTON,onOK) line = wx.StaticLine( panel, -1, size = (20,-1), style = wx.LI_HORIZONTAL ) sizer.Add(line, 0, wx.EXPAND|wx.ALIGN_CENTER|wx.TOP|wx.BOTTOM,5) else: # Temporary variable viewer varTable.FillData(self.plugin.pubVars) btn2 = wx.Button(panel, wx.ID_CANCEL) btn2.SetLabel(text.cancel) btnsizer = wx.StdDialogButtonSizer() if self.pers: btnsizer.AddButton(btn1) btnsizer.AddButton(btn2) btnsizer.Realize() sizer.Add(btnsizer, 0, wx.EXPAND|wx.RIGHT, 10) sizer.Add((1,6)) sizer.Fit(self) def onClose(evt): self.MakeModal(False) self.panel.Enable(True) self.panel.dialog.buttonRow.cancelButton.Enable(True) self.panel.EnableButtons(True) self.GetParent().GetParent().Raise() self.Destroy() self.Bind(wx.EVT_CLOSE, onClose) def onCancel(evt): self.Close() btn2.Bind(wx.EVT_BUTTON, onCancel) self.SetSize((500, -1)) self.SetMinSize((500, -1)) sizer.Layout() self.Raise() self.MakeModal(True) self.Show() #=============================================================================== class ClientsDialog(wx.Frame): def __init__(self, parent, plugin): wx.Frame.__init__( self, parent, -1, style = wx.DEFAULT_DIALOG_STYLE | wx.TAB_TRAVERSAL|wx.RESIZE_BORDER, name="WebSocket clients" ) self.panel = parent self.plugin = plugin self.text = plugin.text self.SetIcon(self.plugin.info.icon.GetWxIcon()) def ShowClientsDialog(self): text = self.plugin.text self.SetTitle(text.wsServers) self.panel.Enable(False) self.panel.dialog.buttonRow.cancelButton.Enable(False) self.panel.EnableButtons(False) panel = wx.Panel(self) sizer = wx.BoxSizer(wx.VERTICAL) panel.SetSizer(sizer) cliSizer = wx.GridBagSizer(5, 5) cliSizer.AddGrowableRow(0) cliSizer.AddGrowableCol(2) clientListCtrl = Table( panel, text.colLabelsCli, 3 ) #setting cols width clientListCtrl.InsertStringItem(0, " 255.255.255.255") clientListCtrl.SetStringItem(0, 1, "HHHHHHH") clientListCtrl.SetStringItem(0, 2, "0000-00-00 00:00:00") width_c = SYS_VSCROLL_X + clientListCtrl.GetWindowBorderSize()[0] for i in range(3): clientListCtrl.SetColumnWidth(i, wx.LIST_AUTOSIZE_USEHEADER) width_c += clientListCtrl.GetColumnWidth(i) clientListCtrl.SetMinSize((width_c, clientListCtrl.minHeight)) #buttons abCli_Id = wx.NewId() abAllCli_Id = wx.NewId() self.buttonIds = (abCli_Id, abAllCli_Id) abortButtonCli = wx.Button(panel, abCli_Id, text.abort) abortAllButtonCli = wx.Button(panel, abAllCli_Id, text.abortAll) refreshButtonCli = wx.Button(panel, -1, text.refresh) cliSizer.Add(clientListCtrl, (0, 0), (1, 4), flag = wx.EXPAND) cliSizer.Add(abortButtonCli, (1, 0), flag = wx.LEFT, border = 10) cliSizer.Add(abortAllButtonCli, (1, 1)) cliSizer.Add(refreshButtonCli, (1, 2)) sizer.Add(cliSizer, 1, wx.EXPAND) def onDelete(evt): item = clientListCtrl.GetFirstSelected() while item != -1: ip = clientListCtrl.GetItem(item, 0).GetText() port = clientListCtrl.GetItem(item, 1).GetText() self.plugin.wsClients[(str(ip), int(port))].on_ws_closed() item = clientListCtrl.GetNextSelected(item) self.RefreshTable() abortButtonCli.Enable(False) evt.Skip() abortButtonCli.Bind(wx.EVT_BUTTON, onDelete) def onClear(evt): clnts = list(self.plugin.wsClients.iterkeys()) for clnt in clnts: self.plugin.wsClients[clnt].on_ws_closed() self.RefreshTable() evt.Skip() abortAllButtonCli.Bind(wx.EVT_BUTTON, onClear) def onRefresh(evt): self.RefreshTable() evt.Skip() refreshButtonCli.Bind(wx.EVT_BUTTON, onRefresh) def OnItemSelected(event): selCnt = clientListCtrl.GetSelectedItemCount() abortButtonCli.Enable(selCnt>0) clientListCtrl.GetSelectedItemCount() event.Skip() clientListCtrl.Bind(wx.EVT_LIST_ITEM_SELECTED, OnItemSelected) clientListCtrl.Bind(wx.EVT_LIST_ITEM_DESELECTED, OnItemSelected) btn1 = wx.Button(panel, wx.ID_OK) btn1.SetLabel(text.ok) btn1.SetDefault() def onOK(evt): self.Close() btn1.Bind(wx.EVT_BUTTON, onOK) line = wx.StaticLine( panel, -1, size = (20,-1), style = wx.LI_HORIZONTAL ) sizer.Add(line, 0, wx.EXPAND|wx.ALIGN_CENTER|wx.TOP|wx.BOTTOM,5) btn2 = wx.Button(panel, wx.ID_CANCEL) btn2.SetLabel(text.cancel) btnsizer = wx.StdDialogButtonSizer() btnsizer.AddButton(btn1) btnsizer.AddButton(btn2) btnsizer.Realize() sizer.Add(btnsizer, 0, wx.EXPAND|wx.RIGHT, 10) sizer.Add((1,6)) sizer.Fit(self) self.table = clientListCtrl self.RefreshTable() abortButtonCli.Enable(False) def onClose(evt): self.MakeModal(False) self.panel.Enable(True) self.panel.dialog.buttonRow.cancelButton.Enable(True) self.panel.EnableButtons(True) self.GetParent().GetParent().Raise() self.Destroy() self.Bind(wx.EVT_CLOSE, onClose) def onCancel(evt): self.Close() btn2.Bind(wx.EVT_BUTTON, onCancel) self.SetMinSize(self.GetSize()) sizer.Layout() self.Raise() self.MakeModal(True) self.Show() def RefreshTable(self): table = self.table table.DeleteAllItems() for i, clnt in enumerate(list(self.plugin.wsClients.iterkeys())): table.InsertStringItem(i, clnt[0]) table.SetStringItem(i, 1, str(clnt[1])) table.SetStringItem(i, 2, dt.fromtimestamp( self.plugin.wsClientsTime[clnt] ).strftime('%Y-%m-%d %H:%M:%S')) cnt = table.GetItemCount() abortAllButtonCli = wx.FindWindowById(self.buttonIds[1]) abortAllButtonCli.Enable(cnt > 0) #=============================================================================== class ServersDialog(wx.Frame): def __init__(self, parent, plugin): wx.Frame.__init__( self, parent, -1, style = wx.DEFAULT_DIALOG_STYLE | wx.TAB_TRAVERSAL|wx.RESIZE_BORDER, name="WebSocket servers" ) self.panel = parent self.plugin = plugin self.text = plugin.text self.SetIcon(self.plugin.info.icon.GetWxIcon()) def ShowServersDialog(self): text = self.plugin.text self.SetTitle(text.wsServers) self.panel.Enable(False) self.panel.dialog.buttonRow.cancelButton.Enable(False) self.panel.EnableButtons(False) panel = wx.Panel(self) sizer = wx.BoxSizer(wx.VERTICAL) panel.SetSizer(sizer) srvSizer = wx.GridBagSizer(5, 5) srvSizer.AddGrowableRow(0) srvSizer.AddGrowableCol(2) serverListCtrl = Table( panel, text.colLabelsSrvr, 3 ) #setting cols width serverListCtrl.InsertStringItem(0, 16*"H") serverListCtrl.SetStringItem(0, 1, 24*"H") serverListCtrl.SetStringItem(0, 2, "0000-00-00 00:00:00") width_c = SYS_VSCROLL_X + serverListCtrl.GetWindowBorderSize()[0] for i in range(3): serverListCtrl.SetColumnWidth(i, wx.LIST_AUTOSIZE_USEHEADER) width_c += serverListCtrl.GetColumnWidth(i) serverListCtrl.SetMinSize((width_c, serverListCtrl.minHeight)) #buttons abSrv_Id = wx.NewId() abAllSrv_Id = wx.NewId() self.buttonIds = (abSrv_Id, abAllSrv_Id) abortButtonSrv = wx.Button(panel, abSrv_Id, text.abort) abortAllButtonSrv = wx.Button(panel, abAllSrv_Id, text.abortAll) refreshButtonSrv = wx.Button(panel, -1, text.refresh) srvSizer.Add(serverListCtrl, (0, 0), (1, 4), flag = wx.EXPAND) srvSizer.Add(abortButtonSrv, (1, 0), flag = wx.LEFT, border = 10) srvSizer.Add(abortAllButtonSrv, (1, 1)) srvSizer.Add(refreshButtonSrv, (1, 2)) sizer.Add(srvSizer, 1, wx.EXPAND) def onDelete(evt): item = serverListCtrl.GetFirstSelected() while item != -1: title = serverListCtrl.GetItem(item, 0).GetText() #url = serverListCtrl.GetItem(item, 1).GetText() self.plugin.wsServers[title].close() item = serverListCtrl.GetNextSelected(item) self.RefreshTable() abortButtonSrv.Enable(False) evt.Skip() abortButtonSrv.Bind(wx.EVT_BUTTON, onDelete) def onClear(evt): srvrs = list(self.plugin.wsServers.iterkeys()) for srvr in srvrs: self.plugin.wsServers[srvr].close() self.RefreshTable() evt.Skip() abortAllButtonSrv.Bind(wx.EVT_BUTTON, onClear) def onRefresh(evt): self.RefreshTable() evt.Skip() refreshButtonSrv.Bind(wx.EVT_BUTTON, onRefresh) def OnItemSelected(event): selCnt = serverListCtrl.GetSelectedItemCount() abortButtonSrv.Enable(selCnt>0) serverListCtrl.GetSelectedItemCount() event.Skip() serverListCtrl.Bind(wx.EVT_LIST_ITEM_SELECTED, OnItemSelected) serverListCtrl.Bind(wx.EVT_LIST_ITEM_DESELECTED, OnItemSelected) btn1 = wx.Button(panel, wx.ID_OK) btn1.SetLabel(text.ok) btn1.SetDefault() def onOK(evt): self.Close() btn1.Bind(wx.EVT_BUTTON, onOK) line = wx.StaticLine( panel, -1, size = (20,-1), style = wx.LI_HORIZONTAL ) sizer.Add(line, 0, wx.EXPAND|wx.ALIGN_CENTER|wx.TOP|wx.BOTTOM,5) btn2 = wx.Button(panel, wx.ID_CANCEL) btn2.SetLabel(text.cancel) btnsizer = wx.StdDialogButtonSizer() btnsizer.AddButton(btn1) btnsizer.AddButton(btn2) btnsizer.Realize() sizer.Add(btnsizer, 0, wx.EXPAND|wx.RIGHT, 10) sizer.Add((1,6)) sizer.Fit(self) self.table = serverListCtrl self.RefreshTable() abortButtonSrv.Enable(False) def onClose(evt): self.MakeModal(False) self.panel.Enable(True) self.panel.dialog.buttonRow.cancelButton.Enable(True) self.panel.EnableButtons(True) self.GetParent().GetParent().Raise() self.Destroy() self.Bind(wx.EVT_CLOSE, onClose) def onCancel(evt): self.Close() btn2.Bind(wx.EVT_BUTTON, onCancel) self.SetMinSize(self.GetSize()) sizer.Layout() self.Raise() self.MakeModal(True) self.Show() def RefreshTable(self): table = self.table table.DeleteAllItems() for i, srvr in enumerate(list(self.plugin.wsServers.iterkeys())): server = self.plugin.wsServers[srvr] table.InsertStringItem(i, server.title) table.SetStringItem(i, 1, str(server.url)) ts = dt.fromtimestamp( server.conTime ).strftime('%Y-%m-%d %H:%M:%S') if server.conTime else "" table.SetStringItem(i, 2, ts) cnt = table.GetItemCount() abortAllButtonSrv = wx.FindWindowById(self.buttonIds[1]) abortAllButtonSrv.Enable(cnt > 0) #=============================================================================== class FileLoader(BaseLoader): """Loads templates from the file system.""" def get_source(self, environment, filename): try: sourceFile = open(filename, "rb") except IOError: raise TemplateNotFound(filename) try: contents = sourceFile.read().decode("utf-8") finally: sourceFile.close() mtime = getmtime(filename) def uptodate(): try: return getmtime(filename) == mtime except OSError: return False return contents, filename, uptodate class MyServer(ThreadingMixIn, HTTPServer): address_family = getattr(socket, 'AF_INET6', None) def __init__(self, requestHandler, port, certfile, keyfile): self.httpdThread = None self.abort = False for res in socket.getaddrinfo(None, port, socket.AF_UNSPEC, socket.SOCK_STREAM, 0, socket.AI_PASSIVE): self.address_family = res[0] self.socket_type = res[1] address = res[4] break HTTPServer.__init__(self, address, requestHandler) if isfile(certfile) and isfile(keyfile): self.socket = wrap_socket( self.socket, certfile = certfile, keyfile = keyfile, server_side = True ) def server_bind(self): """Called by constructor to bind the socket.""" if socket.has_ipv6 and getwindowsversion()[0] > 5: # make it a dual-stack socket if OS is Vista/Win7 IPPROTO_IPV6 = 41 self.socket.setsockopt(IPPROTO_IPV6, socket.IPV6_V6ONLY, 0) HTTPServer.server_bind(self) def Start(self): """Starts the HTTP server thread""" self.httpdThread = Thread(name="WebserverThread", target = self.Run) self.httpdThread.start() def Run(self): try: # Handle one request at a time until stopped while not self.abort: self.handle_request() finally: self.httpdThread = None def Stop(self): """Stops the HTTP server thread""" if self.httpdThread: self.abort = True # closing the socket will awake the underlying select.select() call # so the handle_request() loop will notice the abort flag # immediately self.socket.close() self.RequestHandlerClass.repeatTimer.Stop() #=============================================================================== class MyHTTPRequestHandler(SimpleHTTPRequestHandler): extensions_map = SimpleHTTPRequestHandler.extensions_map.copy() extensions_map['.ico'] = 'image/x-icon' extensions_map['.svg'] = 'image/svg+xml' extensions_map['.manifest'] = 'text/cache-manifest' handshake_done = False clAddr = None magic = '258EAFA5-E914-47DA-95CA-C5AB0DC85B11' # these class attributes will be set by the plugin: authString = None authRealm = None basepath = None repeatTimer = None environment = None plugin = None def getClientAddress(self): ip = self.client_address return (ip[0].replace('::ffff:', ''), ip[1]) def on_ws_message(self, message): try: message = message.decode("utf-8") except: pass try: data = loads(message) except: if message.find('WebSocket Protocol Error') > -1: eg.PrintNotice('message: '+message) self.on_ws_closed() elif message.find('Masked frame from server') > -1: eg.PrintNotice('message: '+message) self.on_ws_closed() else: self.plugin.TriggerEvent( u"ClientMessage.%s" % message, payload = (self.clAddr, message) ) return # JSON request if not isinstance(data, dict) or "method" not in data.iterkeys(): self.plugin.TriggerEvent( "ClientMessage", payload = (self.clAddr, data) ) else: methodName = data["method"] if methodName in METHODS: if methodName == "Ping": id = data["id"] if "id" in data else -1 content = dumps({ "method":"Pong", "id":id, "client_address":self.clAddr }) self.plugin.ServerSendMessage(self.clAddr, content) return try: args = data.get("args", []) kwargs = data.get("kwargs", {}) result = self.plugin.ProcessTheArguments( self, methodName, args, kwargs ) content = dumps(result) self.plugin.ServerSendMessage(self.clAddr, content) except: pass else: self.plugin.TriggerEvent( methodName, payload = (self.clAddr, data) ) def on_ws_closed(self): self.handshake_done = False if self.clAddr in self.plugin.wsClients and self.close_connection == 0: self.send_close() self.close_connection = 1 self.plugin.TriggerEvent( self.plugin.text.wsClientDisconn, payload = [self.clAddr] ) del self.plugin.wsClients[self.clAddr] del self.plugin.wsClientsTime[self.clAddr] def send_close(self): msg = bytearray() msg.append(0x88) msg.append(0x00) try: self.request.send(msg) except: pass def handle_one_request(self): if not self.handshake_done: try: SimpleHTTPRequestHandler.handle_one_request(self) except Exception, exc: eg.PrintError( "Webserver: Exception on handle_one_request:", unicode(exc) ) #SimpleHTTPRequestHandler.handle_one_request(self) else: # WebSocket read next message try: opcode = self.rfile.read(1) if not opcode: return # ?????????? except Exception, exc: if exc.args[0] in (10053, 10054, 10060): return self.on_ws_closed() else: eg.PrintTraceback() # debugging ... length = ord(self.rfile.read(1)) & 127 if length == 126: length = unpack(">H", self.rfile.read(2))[0] elif length == 127: length = unpack(">Q", self.rfile.read(8))[0] masks = [ord(byte) for byte in self.rfile.read(4)] decoded = "" for char in self.rfile.read(length): decoded += chr(ord(char) ^ masks[len(decoded) % 4]) _stream = 0x0 _text = 0x1 _binary = 0x2 _close = 0x8 _ping = 0x9 _pong = 0xa opcode = ord(opcode) & 0x0F ### krambriw #if decoded.find('Ping') > -1: # opcode = _ping #if decoded.find('WebSocket Protocol Error') > -1: # opcode = _close # eg.PrintNotice('decoded: '+decoded) # decoded = 'WebSocket Protocol Error' #if decoded.find('Masked frame from server') > -1: # opcode = _close # eg.PrintNotice('decoded: '+decoded) # decoded = 'Masked frame from server' # close if opcode == _close: eg.PrintNotice('closing: '+decoded) self.on_ws_closed() # ping elif opcode == _ping: #print 'ping' resp = ['Pong', self.client_address] self.write_message(repr(resp)) # pong elif opcode == _pong: pass # data elif opcode == _stream or opcode == _text or opcode == _binary: self.on_ws_message(decoded) ### def write_message(self, message): self.request.send(chr(129)) length = len(message) if length <= 125: self.request.send(chr(length)) elif length >= 126 and length <= 65535: self.request.send(chr(126)) self.request.send(pack(">H", length)) else: self.request.send(chr(127)) self.request.send(pack(">Q", length)) self.request.send(message) def handshake(self): headers=self.headers if headers.get("Upgrade", None) != "websocket": return key = headers['Sec-WebSocket-Key'] try: digest = b64encode(sha1(key + self.magic).hexdigest().decode('hex')) except: eg.PrintTraceback() self.send_response(101, 'Switching Protocols') self.send_header('Upgrade', 'websocket') self.send_header('Connection', 'Upgrade') self.send_header('Sec-WebSocket-Accept', str(digest)) self.end_headers() self.handshake_done = True self.close_connection = 0 # ws_connected self.plugin.wsClients[self.clAddr] = self self.plugin.wsClientsTime[self.clAddr] = eg.Utils.time.time() try: # ######################################################################## zrusit ??? self.plugin.TriggerEvent( self.plugin.text.wsClientConn, payload = [self.clAddr] ) except: eg.PrintTraceback() def version_string(self): """Return the server software version string.""" return "EventGhost/" + eg.Version.string def Authenticate(self): # only authenticate, if set if self.authString is None: return True # do Basic HTTP-Authentication authHeader = self.headers.get('authorization') if authHeader is not None: authType, authString = authHeader.split(' ', 2) if authType.lower() == 'basic' and authString == self.authString: return True self.send_response(401) self.send_header('WWW-Authenticate','Basic realm="%s"' % self.authRealm) self.send_header('Content-type', 'text/html') self.end_headers() return False def SendContent(self, path): fsPath = self.translate_path(path) if isdir(fsPath): if not path.endswith('/'): # redirect browser - doing basically what apache does self.send_response(301) self.send_header("Location", path + "/") self.end_headers() return None for index in ("index.html", "index.htm"): index = join(fsPath, index) if exists(index): fsPath = index break else: return self.list_directory(path) extension = splitext(fsPath)[1].lower() if extension not in (".htm", ".html"): f = self.send_head() if f: self.wfile.write(f.read()) f.close() return try: template = self.environment.get_template(fsPath) except TemplateNotFound: self.send_error(404, "File not found") return kwargs = cpy(self.plugin.pubVars) kwargs.update(self.plugin.pubPerVars) content = template.render(**kwargs) self.end_request(content) def end_request(self, content, case = 'text/html'): content=content.encode("UTF-8") self.send_response(200) self.send_header("Content-type", case) self.send_header("Content-Length", len(content)) self.end_headers() self.wfile.write(content) self.wfile.close() def do_POST(self): """Serve a POST request.""" # First do Basic HTTP-Authentication, if set if not self.Authenticate(): return self.clAddr = self.getClientAddress() contentLength = int(self.headers.get('content-length')) content = self.rfile.read(contentLength) plugin = self.plugin try: data = loads(content) except: # Enhancement by Sem;colon - START data=content.split("&") if data[0]=="request": self.SendContent(self.path) if len(data)>1: plugin.TriggerEvent(data[1], data[2:]) else: content = "" i=1 if data[0]=="GetGlobalValue": while i2: data[2]=data[2].replace("suffix=","") if len(data)>3: data[3]=data[3].replace("payload=","") eg.TriggerEvent(prefix=data[1][7:], suffix=data[2], payload=data[3:]) else: plugin.TriggerEvent(data[1], data[2:]) else: plugin.TriggerEvent(data[0], data[1:]) self.end_request(content) # Enhancement by Sem;colon - END else: # JSON request methodName = data["method"] args = data.get("args", []) kwargs = data.get("kwargs", {}) result = self.plugin.ProcessTheArguments( self, methodName, args, kwargs ) content = dumps(result) self.end_request(content, 'application/json; charset=UTF-8') def do_GET(self): """Serve a GET request.""" self.clAddr = self.getClientAddress() if self.plugin.noAutWs: # First test, if WebSocket connection if self.headers.get("Upgrade", None) == "websocket": return self.handshake() #switch to WebSocket ! if not self.Authenticate(): return else: # First do Basic HTTP-Authentication, if set if not self.Authenticate(): return if self.headers.get("Upgrade", None) == "websocket": return self.handshake() #switch to WebSocket ! path, dummy, remaining = self.path.partition("?") if remaining: queries = remaining.split("#", 1)[0].split("&") #print "queries =",queries queries = [unquote_plus(part).decode("latin1") for part in queries] if len(queries) > 0: event = queries.pop(0).strip() if "withoutRelease" in queries: queries.remove("withoutRelease") event = self.plugin.TriggerEnduringEvent(event, queries) while not event.isEnded: sleep(0.05) elif event == "ButtonReleased": self.plugin.EndLastEvent() else: event = self.plugin.TriggerEvent(event, queries) while not event.isEnded: sleep(0.05) try: self.SendContent(path) except Exception, exc: self.plugin.EndLastEvent() eg.PrintError("Webserver error", self.path) eg.PrintError("Exception", unicode(exc)) if exc.args[0] == 10053: # Software caused connection abort pass elif exc.args[0] == 10054: # Connection reset by peer pass else: raise def log_message(self, format, *args): pass def copyfile(self, src, dst): dst.write(src.read()) def translate_path(self, path): """Translate a /-separated PATH to the local filename syntax. Components that mean special things to the local file system (e.g. drive or directory names) are ignored. (XXX They should probably be diagnosed.) """ # stolen from SimpleHTTPServer.SimpleHTTPRequestHandler # but changed to handle files from a defined basepath instead # of os.getcwd() path = path.split('?', 1)[0] path = path.split('#', 1)[0] path = normpath(unquote(path)) words = [word for word in path.split('/') if word] path = self.basepath for word in words: drive, word = splitdrive(word) head, word = split(word) if word in (curdir, pardir): continue path = join(path, word) return path #=============================================================================== class WsSendMessage(eg.ActionBase): class text: mess = "Message to be sent:" def __call__( self, message = "", cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, pars = False ): if not pars: message = self.plugin.EvalString(message) client = eg.event.payload[0] if modeClient else ( eg.ParseString(cl_ip), int(eg.ParseString(cl_port)) ) return self.plugin.ServerSendMessage( client, message, ) def GetLabel(self, message, cl_ip, cl_port, modeClient, pars): if modeClient: client = "{eg.event.payload[0]}" return "%s: %s: %s" % (self.name, client, message) else: return "%s: %s:%s: %s" % (self.name, cl_ip, cl_port, message) def Configure( self, message = "", cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, pars = False ): text = self.text panel = eg.ConfigPanel() id2 = wx.NewId() id3 = wx.NewId() id4 = wx.NewId() radioBoxModeClient = wx.RadioBox( panel, -1, self.plugin.text.modeClientChoiceLabel, choices = self.plugin.text.modeClientChoice, style=wx.RA_SPECIFY_ROWS ) radioBoxModeClient.SetSelection(modeClient) staticBox = wx.StaticBox(panel, -1, "") tmpSizer = wx.GridBagSizer(2, 10) txtLabel = wx.StaticText(panel,-1,self.plugin.text.host) txtCtrl = wx.TextCtrl(panel,id3,"") portLabel = wx.StaticText(panel,-1,self.plugin.text.port) portCtrl = wx.TextCtrl(panel,id2,"") tmpSizer.Add(txtLabel,(0,0),(1,1)) tmpSizer.Add(txtCtrl,(1,0),(1,1),flag = wx.EXPAND) tmpSizer.Add(portLabel,(2,0),(1,1),flag = wx.TOP, border = 10) tmpSizer.Add(portCtrl,(3,0),(1,1)) middleSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) middleSizer.Add(radioBoxModeClient,0,wx.LEFT|wx.EXPAND) middleSizer.Add((20,-1),0,wx.LEFT|wx.EXPAND) middleSizer.Add(tmpSizer,0,wx.LEFT|wx.EXPAND) panel.sizer.Add(middleSizer, 0, wx.TOP|wx.EXPAND, 8) panel.sizer.Layout() size2 = (-1, tmpSizer.GetMinSize()[1]) def OnClientChoice(evt = None): ClientChoice( evt, self.plugin.text, panel, id3, id4, cl_ip, cl_port, size2, radioBoxModeClient ) radioBoxModeClient.Bind(wx.EVT_RADIOBOX, OnClientChoice) OnClientChoice() messCtrl = wx.TextCtrl(panel, -1, message) messSizer = wx.StaticBoxSizer( wx.StaticBox(panel, -1, text.mess), wx.VERTICAL ) parsCtrl = wx.CheckBox(panel, -1, self.plugin.text.parsing) parsCtrl.SetValue(pars) panel.sizer.Add(messSizer, 0, wx.EXPAND|wx.TOP, 8) messSizer.Add(messCtrl, 0, wx.EXPAND) messSizer.Add(parsCtrl, 0, wx.EXPAND|wx.TOP, 3) while panel.Affirmed(): modeClient = radioBoxModeClient.GetSelection() if not modeClient: cl_ip = wx.FindWindowById(id3).GetValue() cl_port = wx.FindWindowById(id4).GetValue() panel.SetResult( messCtrl.GetValue(), cl_ip, cl_port, modeClient, parsCtrl.GetValue() ) #=============================================================================== class WsSendValue(eg.ActionBase): class text: varnames = "Variable name or list of variables (separated by commas):" def __call__( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, varnames = "", ): try: keys = varnames.replace(" ", "") keys = keys.split(",") except: eg.PrintError(self.text.err % str(varnames)) return try: vals = {} for key in keys: k = self.plugin.EvalString(key) vals[k] = self.plugin.GetValue(k) except: eg.PrintError(self.text.err % str(varnames)) client = eg.event.payload[0] if modeClient else ( eg.ParseString(cl_ip), int(eg.ParseString(cl_port)) ) return self.plugin.ServerSendMessage( client, dumps({'method':'Values', 'kwargs':vals}), ) def GetLabel(self, cl_ip, cl_port, modeClient, varnames): if modeClient: client = "{eg.event.payload[0]}" return "%s: %s: %s" % (self.name, client, varnames) else: return "%s: %s:%s: %s" % (self.name, cl_ip, cl_port, varnames) def Configure( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, varnames = "", ): text = self.text panel = eg.ConfigPanel() id2 = wx.NewId() id3 = wx.NewId() id4 = wx.NewId() radioBoxModeClient = wx.RadioBox( panel, -1, self.plugin.text.modeClientChoiceLabel, choices = self.plugin.text.modeClientChoice, style=wx.RA_SPECIFY_ROWS ) radioBoxModeClient.SetSelection(modeClient) staticBox = wx.StaticBox(panel, -1, "") tmpSizer = wx.GridBagSizer(2, 10) txtLabel = wx.StaticText(panel,-1,self.plugin.text.host) txtCtrl = wx.TextCtrl(panel,id3,"") portLabel = wx.StaticText(panel,-1,self.plugin.text.port) portCtrl = wx.TextCtrl(panel,id2,"") tmpSizer.Add(txtLabel,(0,0),(1,1)) tmpSizer.Add(txtCtrl,(1,0),(1,1),flag = wx.EXPAND) tmpSizer.Add(portLabel,(2,0),(1,1),flag = wx.TOP, border = 10) tmpSizer.Add(portCtrl,(3,0),(1,1)) middleSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) middleSizer.Add(radioBoxModeClient,0,wx.LEFT|wx.EXPAND) middleSizer.Add((20,-1),0,wx.LEFT|wx.EXPAND) middleSizer.Add(tmpSizer,0,wx.LEFT|wx.EXPAND) panel.sizer.Add(middleSizer, 0, wx.TOP|wx.EXPAND, 8) panel.sizer.Layout() size2 = (-1, tmpSizer.GetMinSize()[1]) def OnClientChoice(evt = None): ClientChoice( evt, self.plugin.text, panel, id3, id4, cl_ip, cl_port, size2, radioBoxModeClient ) radioBoxModeClient.Bind(wx.EVT_RADIOBOX, OnClientChoice) OnClientChoice() varnamesCtrl = panel.TextCtrl(varnames) mainSizer = wx.BoxSizer(wx.VERTICAL) varnamesLbl = panel.StaticText(self.text.varnames) mainSizer.Add(varnamesLbl) mainSizer.Add(varnamesCtrl, 0, wx.EXPAND|wx.TOP, 1) panel.sizer.Add(mainSizer, 0, wx.EXPAND|wx.ALL, 10) while panel.Affirmed(): modeClient = radioBoxModeClient.GetSelection() if not modeClient: cl_ip = wx.FindWindowById(id3).GetValue() cl_port = wx.FindWindowById(id4).GetValue() panel.SetResult( cl_ip, cl_port, modeClient, varnamesCtrl.GetValue(), ) #=============================================================================== class WsBroadcastAllValues(eg.ActionBase): def __call__(self): values = self.plugin.GetAllValues() return self.plugin.BroadcastMessage( #dumps({'method':'Values', 'kwargs':values}) dumps(values) ) #=============================================================================== class WsSendAllValues(eg.ActionBase): def __call__( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1 ): values = self.plugin.GetAllValues() client = eg.event.payload[0] if modeClient else ( eg.ParseString(cl_ip), int(eg.ParseString(cl_port)) ) return self.plugin.ServerSendMessage( client, dumps({'method':'Values', 'kwargs':values}), ) def GetLabel(self, cl_ip, cl_port, modeClient): if modeClient: client = "{eg.event.payload[0]}" return "%s: %s" % (self.name, client) else: return "%s: %s:%s" % (self.name, cl_ip, cl_port) def Configure( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1 ): panel = eg.ConfigPanel() id2 = wx.NewId() id3 = wx.NewId() id4 = wx.NewId() radioBoxModeClient = wx.RadioBox( panel, -1, self.plugin.text.modeClientChoiceLabel, choices = self.plugin.text.modeClientChoice, style=wx.RA_SPECIFY_ROWS ) radioBoxModeClient.SetSelection(modeClient) staticBox = wx.StaticBox(panel, -1, "") tmpSizer = wx.GridBagSizer(2, 10) txtLabel = wx.StaticText(panel,-1,self.plugin.text.host) txtCtrl = wx.TextCtrl(panel,id3,"") portLabel = wx.StaticText(panel,-1,self.plugin.text.port) portCtrl = wx.TextCtrl(panel,id2,"") tmpSizer.Add(txtLabel,(0,0),(1,1)) tmpSizer.Add(txtCtrl,(1,0),(1,1),flag = wx.EXPAND) tmpSizer.Add(portLabel,(2,0),(1,1),flag = wx.TOP, border = 10) tmpSizer.Add(portCtrl,(3,0),(1,1)) middleSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) middleSizer.Add(radioBoxModeClient,0,wx.LEFT|wx.EXPAND) middleSizer.Add((20,-1),0,wx.LEFT|wx.EXPAND) middleSizer.Add(tmpSizer,0,wx.LEFT|wx.EXPAND) panel.sizer.Add(middleSizer, 0, wx.TOP|wx.EXPAND, 8) panel.sizer.Layout() size2 = (-1, tmpSizer.GetMinSize()[1]) def OnClientChoice(evt = None): ClientChoice( evt, self.plugin.text, panel, id3, id4, cl_ip, cl_port, size2, radioBoxModeClient ) radioBoxModeClient.Bind(wx.EVT_RADIOBOX, OnClientChoice) OnClientChoice() while panel.Affirmed(): modeClient = radioBoxModeClient.GetSelection() if not modeClient: cl_ip = wx.FindWindowById(id3).GetValue() cl_port = wx.FindWindowById(id4).GetValue() panel.SetResult( cl_ip, cl_port, modeClient, ) #=============================================================================== class WsBroadcastData(eg.ActionBase): class text: dataName = "Data name:" data2send = "Data for broadcast (python expression):" onlyChange = "Data send only if it has been changed" cond = "Condition for data sending (python expression):" period = "Sending period [s]:" def Task(self, plugin, dataName): if self.plugin.info.isStarted: self.task = eg.scheduler.AddTask( self.period, self.Task, self.plugin, dataName ) data = self.plugin.EvalString(self.data2send) cond = self.plugin.EvalString(self.cond) if self.cond != "" else True if cond: if data != self.data or not self.onlyChange: self.plugin.BroadcastMessage( dumps( {'method' :'Data', 'dataName':dataName, 'data':data} ) ) self.data=data def __call__( self, dataName="", data2send="", cond="", onlyChange=True, period=5.0 ): self.data2send=data2send self.onlyChange=onlyChange self.cond=cond self.period=period self.data = None if self.value: self.Task(self.plugin, dataName) else: data = self.plugin.EvalString(data2send) cond = self.plugin.EvalString(cond) if cond != "" else True if cond: self.plugin.BroadcastMessage( dumps( {'method' :'Data', 'dataName':dataName, 'data':data} ) ) def Configure( self, dataName="", data2send="", cond="", onlyChange=True, period=5.0 ): panel = eg.ConfigPanel(self) text = self.text nameLabel = wx.StaticText(panel, -1, text.dataName) sendLabel = wx.StaticText(panel, -1, text.data2send) condLabel = wx.StaticText(panel, -1, text.cond) nameCtrl = wx.TextCtrl(panel, -1, dataName) sendCtrl = wx.TextCtrl(panel, -1, data2send) condCtrl = wx.TextCtrl(panel, -1, cond) mainSizer = wx.BoxSizer(wx.VERTICAL) mainSizer.Add(nameLabel) mainSizer.Add(nameCtrl,0,wx.EXPAND|wx.TOP,2) mainSizer.Add(sendLabel,0,wx.TOP,10) mainSizer.Add(sendCtrl,0,wx.EXPAND|wx.TOP,2) mainSizer.Add(condLabel,0,wx.TOP,10) mainSizer.Add(condCtrl,0,wx.EXPAND|wx.TOP,2) panel.sizer.Add(mainSizer,0,wx.ALL|wx.EXPAND,10) if self.value: periodLabel = wx.StaticText(panel, -1, text.period) changeCtrl = wx.CheckBox(panel, -1, text.onlyChange) changeCtrl.SetValue(onlyChange) periodCtrl = eg.SpinNumCtrl( panel, -1, period, integerWidth = 5, fractionWidth = 1, allowNegative = False, min = 0.1, increment = 0.1, ) perSizer = wx.BoxSizer(wx.HORIZONTAL) perSizer.Add(periodLabel,0,wx.TOP,3) perSizer.Add(periodCtrl,0,wx.LEFT,1) perSizer.Add((-1,-1),1,wx.EXPAND) perSizer.Add(changeCtrl,0,wx.TOP,4) mainSizer.Add(perSizer,0,wx.EXPAND|wx.TOP,10) while panel.Affirmed(): change = changeCtrl.GetValue() if self.value else None period = periodCtrl.GetValue() if self.value else None panel.SetResult( nameCtrl.GetValue(), sendCtrl.GetValue(), condCtrl.GetValue(), change, period ) #=============================================================================== class WsPeriodicallySendData(eg.ActionBase): class text: dataName = "Data name:" data2send = "Data for broadcast (python expression):" cond = "Condition for data sending (python expression):" onlyChange = "Data send only if it has been changed" period = "Sending period [s]:" def Task(self, plugin, client, dataName): if self.plugin.info.isStarted: self.task = eg.scheduler.AddTask( self.period, self.Task, self.plugin, client, dataName ) data = self.plugin.EvalString(self.data2send) cond = self.plugin.EvalString(self.cond) if self.cond != "" else True if cond: if data != self.data or not self.onlyChange: self.plugin.ServerSendMessage( client, dumps({ 'method':'Data', 'dataName':dataName, 'data':data }), ) self.data=data def __call__( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, dataName="", data2send="", onlyChange=True, cond="", period=5.0 ): #self.cl_ip = cl_ip #self.cl_port = cl_port #self.modeClient = modeClient self.data2send=data2send self.onlyChange=onlyChange self.cond=cond self.period=period self.data = None client = eg.event.payload[0] if modeClient else ( eg.ParseString(cl_ip), int(eg.ParseString(cl_port)) ) if self.value: self.Task(self.plugin, client, dataName) else: data = self.plugin.EvalString(data2send) cond = self.plugin.EvalString(cond) if cond != "" else True if cond: self.plugin.ServerSendMessage( client, dumps({ 'method':'Data', 'dataName':dataName, 'data':data }), ) def GetLabel( self, cl_ip, cl_port, modeClient, dataName, data2send, onlyChange, cond, period ): if modeClient: client = "{eg.event.payload[0]}" return "%s: %s: %s" % (self.name, client, dataName) else: return "%s: %s:%s: %s" % (self.name, cl_ip, cl_port, dataName) def Configure( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, dataName="", data2send="", onlyChange=True, cond="", period=5.0 ): text = self.text panel = eg.ConfigPanel() id2 = wx.NewId() id3 = wx.NewId() id4 = wx.NewId() radioBoxModeClient = wx.RadioBox( panel, -1, self.plugin.text.modeClientChoiceLabel, choices = self.plugin.text.modeClientChoice, style=wx.RA_SPECIFY_ROWS ) radioBoxModeClient.SetSelection(modeClient) staticBox = wx.StaticBox(panel, -1, "") tmpSizer = wx.GridBagSizer(2, 10) txtLabel = wx.StaticText(panel,-1,self.plugin.text.host) txtCtrl = wx.TextCtrl(panel,id3,"") portLabel = wx.StaticText(panel,-1,self.plugin.text.port) portCtrl = wx.TextCtrl(panel,id2,"") tmpSizer.Add(txtLabel,(0,0),(1,1)) tmpSizer.Add(txtCtrl,(1,0),(1,1),flag = wx.EXPAND) tmpSizer.Add(portLabel,(2,0),(1,1),flag = wx.TOP, border = 10) tmpSizer.Add(portCtrl,(3,0),(1,1)) middleSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) middleSizer.Add(radioBoxModeClient,0,wx.LEFT|wx.EXPAND) middleSizer.Add((20,-1),0,wx.LEFT|wx.EXPAND) middleSizer.Add(tmpSizer,0,wx.LEFT|wx.EXPAND) panel.sizer.Add(middleSizer, 0, wx.TOP|wx.EXPAND, 8) nameLabel = wx.StaticText(panel, -1, text.dataName) sendLabel = wx.StaticText(panel, -1, text.data2send) condLabel = wx.StaticText(panel, -1, text.cond) nameCtrl = wx.TextCtrl(panel, -1, dataName) sendCtrl = wx.TextCtrl(panel, -1, data2send) condCtrl = wx.TextCtrl(panel, -1, cond) mainSizer = wx.BoxSizer(wx.VERTICAL) mainSizer.Add(nameLabel) mainSizer.Add(nameCtrl,0,wx.EXPAND|wx.TOP,2) mainSizer.Add(sendLabel,0,wx.TOP,10) mainSizer.Add(sendCtrl,0,wx.EXPAND|wx.TOP,2) mainSizer.Add(condLabel,0,wx.TOP,10) mainSizer.Add(condCtrl,0,wx.EXPAND|wx.TOP,2) panel.sizer.Add(mainSizer,0,wx.ALL|wx.EXPAND,10) if self.value: periodLabel = wx.StaticText(panel, -1, text.period) periodCtrl = eg.SpinNumCtrl( panel, -1, period, integerWidth = 5, fractionWidth = 1, allowNegative = False, min = 0.1, increment = 0.1, ) changeCtrl = wx.CheckBox(panel, -1, text.onlyChange) changeCtrl.SetValue(onlyChange) perSizer = wx.BoxSizer(wx.HORIZONTAL) perSizer.Add(periodLabel,0,wx.TOP,3) perSizer.Add(periodCtrl,0,wx.LEFT,1) perSizer.Add((-1,-1),1,wx.EXPAND) perSizer.Add(changeCtrl,0,wx.TOP,4) mainSizer.Add(perSizer,0,wx.EXPAND|wx.TOP,10) panel.sizer.Layout() size2 = (-1, tmpSizer.GetMinSize()[1]) def OnClientChoice(evt = None): ClientChoice( evt, self.plugin.text, panel, id3, id4, cl_ip, cl_port, size2, radioBoxModeClient ) radioBoxModeClient.Bind(wx.EVT_RADIOBOX, OnClientChoice) OnClientChoice() while panel.Affirmed(): modeClient = radioBoxModeClient.GetSelection() if not modeClient: cl_ip = wx.FindWindowById(id3).GetValue() cl_port = wx.FindWindowById(id4).GetValue() change = changeCtrl.GetValue() if self.value else None period = periodCtrl.GetValue() if self.value else None panel.SetResult( cl_ip, cl_port, modeClient, nameCtrl.GetValue(), sendCtrl.GetValue(), change, condCtrl.GetValue(), period, ) #=============================================================================== class WsSendCommand(eg.ActionBase): class text: cond = "Condition:" cmdName = "Command name:" arg1 = "Argument 1:" arg2 = "Argument 2:" arg3 = "Argument 3:" othArgs = "Arguments:" kwArgs = "Keyw. arguments:" onlyChange = "Data send only if it has been changed" period = "Sending period [s]:" def Task(self, plugin, client, cmdName): if self.plugin.info.isStarted: self.task = eg.scheduler.AddTask( self.period, self.Task, self.plugin, client, cmdName ) args = [self.plugin.EvalString(self.arg1)] if self.arg1 != "" else [] if self.arg2 != "": args.append(self.plugin.EvalString(self.arg2)) if self.arg3 != "": args.append(self.plugin.EvalString(self.arg3)) if self.othArgs != "": try: othArgs = list(self.plugin.EvalString(self.othArgs)) args.extend(othArgs) except: pass kwargs = {} if kwArgs != "": try: kwargs = dict(self.plugin.EvalString(kwArgs, False)) except: pass cond = self.plugin.EvalString(self.cond) if self.cond != "" else True if cond: if args != self.args or kwargs != self.kwargs or not self.onlyChange: self.plugin.ServerSendMessage( client, dumps( { 'method' :'Command', 'cmdName':cmdName, 'args':args, 'kwargs':kwargs } ), ) self.args=args self.kwargs=kwargs def __call__( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, cmdName="", cond="", arg1="", arg2="", arg3="", othArgs="", kwArgs ="", onlyChange=True, period=5.0 ): cmdName = self.plugin.EvalString(cmdName) client = eg.event.payload[0] if modeClient else ( eg.ParseString(cl_ip), int(eg.ParseString(cl_port)) ) if self.value: self.cond=cond self.arg1=arg1 self.arg2=arg2 self.arg3=arg3 self.othArgs=othArgs self.kwArgs=kwArgs self.onlyChange=onlyChange self.period=period self.Task(self.plugin, client, cmdName) else: args = [self.plugin.EvalString(arg1)] if arg1 != "" else [] if arg2 != "": args.append(self.plugin.EvalString(arg2)) if arg3 != "": args.append(self.plugin.EvalString(arg3)) if othArgs != "": try: othArgs = list(self.plugin.EvalString(othArgs)) args.extend(othArgs) except: pass kwargs = {} if kwArgs != "": try: kwargs = dict(self.plugin.EvalString(kwArgs, False)) except: pass cond = self.plugin.EvalString(cond) if cond != "" else True if cond: #client = eg.event.payload[0] if modeClient else ( # eg.ParseString(cl_ip), # int(eg.ParseString(cl_port)) #) self.plugin.ServerSendMessage( client, dumps( { 'method' :'Command', 'cmdName':cmdName, 'args':args, 'kwargs':kwargs } ), ) def GetLabel( self, cl_ip, cl_port, modeClient, cmdName, cond, arg1, arg2, arg3, othArgs, kwArgs, onlyChange, period ): if modeClient: client = "{eg.event.payload[0]}" return "%s: %s: %s: (%s, %s)" % ( self.name, client, cmdName, arg1, arg2 ) else: return "%s: %s:%s: %s: (%s, %s)" % ( self.name, cl_ip, cl_port, cmdName, arg1, arg2 ) def Configure( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, cmdName="", cond="", arg1="", arg2="", arg3="", othArgs="", kwArgs ="", onlyChange=True, period=5.0 ): panel = eg.ConfigPanel(self) text = self.text id2 = wx.NewId() id3 = wx.NewId() id4 = wx.NewId() radioBoxModeClient = wx.RadioBox( panel, -1, self.plugin.text.modeClientChoiceLabel, choices = self.plugin.text.modeClientChoice, style=wx.RA_SPECIFY_ROWS ) radioBoxModeClient.SetSelection(modeClient) staticBox = wx.StaticBox(panel, -1, "") tmpSizer = wx.GridBagSizer(2, 10) txtLabel = wx.StaticText(panel,-1,self.plugin.text.host) txtCtrl = wx.TextCtrl(panel,id3,"") portLabel = wx.StaticText(panel,-1,self.plugin.text.port) portCtrl = wx.TextCtrl(panel,id2,"") tmpSizer.Add(txtLabel,(0,0),(1,1)) tmpSizer.Add(txtCtrl,(1,0),(1,1),flag = wx.EXPAND) tmpSizer.Add(portLabel,(2,0),(1,1),flag = wx.TOP, border = 10) tmpSizer.Add(portCtrl,(3,0),(1,1)) middleSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) middleSizer.Add(radioBoxModeClient,0,wx.LEFT|wx.EXPAND) middleSizer.Add((20,-1),0,wx.LEFT|wx.EXPAND) middleSizer.Add(tmpSizer,0,wx.LEFT|wx.EXPAND) panel.sizer.Add(middleSizer, 0, wx.TOP|wx.LEFT|wx.RIGHT|wx.EXPAND, 8) panel.sizer.Layout() size2 = (-1, tmpSizer.GetMinSize()[1]) def OnClientChoice(evt = None): ClientChoice( evt, self.plugin.text, panel, id3, id4, cl_ip, cl_port, size2, radioBoxModeClient ) radioBoxModeClient.Bind(wx.EVT_RADIOBOX, OnClientChoice) OnClientChoice() nameLabel = wx.StaticText(panel, -1, text.cmdName) condLabel = wx.StaticText(panel, -1, text.cond) arg1Label = wx.StaticText(panel, -1, text.arg1) arg2Label = wx.StaticText(panel, -1, text.arg2) arg3Label = wx.StaticText(panel, -1, text.arg3) othLabel = wx.StaticText(panel, -1, text.othArgs) kwLabel = wx.StaticText(panel, -1, text.kwArgs) nameCtrl = wx.TextCtrl(panel, -1, cmdName) condCtrl = wx.TextCtrl(panel, -1, cond) arg1Ctrl = wx.TextCtrl(panel, -1, arg1) arg2Ctrl = wx.TextCtrl(panel, -1, arg2) arg3Ctrl = wx.TextCtrl(panel, -1, arg3) othCtrl = wx.TextCtrl(panel, -1, othArgs) kwCtrl = wx.TextCtrl(panel, -1, kwArgs) mainSizer = wx.FlexGridSizer(7, 2, 2, 10) mainSizer.AddGrowableCol(1) mainSizer.Add(nameLabel,0, wx.TOP,3) mainSizer.Add(nameCtrl,0,wx.EXPAND) mainSizer.Add(arg1Label,0, wx.TOP,3) mainSizer.Add(arg1Ctrl,0,wx.EXPAND) mainSizer.Add(arg2Label,0, wx.TOP,3) mainSizer.Add(arg2Ctrl,0,wx.EXPAND) mainSizer.Add(arg3Label,0, wx.TOP,3) mainSizer.Add(arg3Ctrl,0,wx.EXPAND) mainSizer.Add(othLabel,0, wx.TOP,3) mainSizer.Add(othCtrl,0,wx.EXPAND) mainSizer.Add(kwLabel,0, wx.TOP,3) mainSizer.Add(kwCtrl,0,wx.EXPAND) mainSizer.Add(condLabel,0, wx.TOP,3) mainSizer.Add(condCtrl,0,wx.EXPAND) if self.value: periodLabel = wx.StaticText(panel, -1, text.period) periodCtrl = eg.SpinNumCtrl( panel, -1, period, integerWidth = 5, fractionWidth = 1, allowNegative = False, min = 0.1, increment = 0.1, ) changeCtrl = wx.CheckBox(panel, -1, text.onlyChange) changeCtrl.SetValue(onlyChange) perSizer = wx.BoxSizer(wx.HORIZONTAL) mainSizer.Add(periodLabel,0,wx.TOP,3) perSizer.Add(periodCtrl,0,wx.LEFT,1) perSizer.Add((-1,-1),1,wx.EXPAND) perSizer.Add(changeCtrl,0,wx.TOP,4) mainSizer.Add(perSizer,0,wx.EXPAND) panel.sizer.Add(mainSizer,0,wx.ALL|wx.EXPAND,8) while panel.Affirmed(): modeClient = radioBoxModeClient.GetSelection() if not modeClient: cl_ip = wx.FindWindowById(id3).GetValue() cl_port = wx.FindWindowById(id4).GetValue() change = changeCtrl.GetValue() if self.value else None period = periodCtrl.GetValue() if self.value else None panel.SetResult( cl_ip, cl_port, modeClient, nameCtrl.GetValue(), condCtrl.GetValue(), arg1Ctrl.GetValue(), arg2Ctrl.GetValue(), arg3Ctrl.GetValue(), othCtrl.GetValue(), kwCtrl.GetValue(), change, period ) #=============================================================================== class WsSendUniversal(eg.ActionBase): class text: cond = "Condition:" method = "Method:" othArgs = "Arguments:" kwArgs = "Keyw. arguments:" onlyChange = "Data send only if it has been changed" period = "Sending period [s]:" def Task(self, plugin, client, method): if plugin.info.isStarted: self.task = eg.scheduler.AddTask( self.period, self.Task, plugin, client, method ) args = [] if self.othArgs != "": try: args = list(self.plugin.EvalString(self.othArgs)) except: pass kwargs = {} if self.kwArgs != "": try: kwargs = dict(self.plugin.EvalString(self.kwArgs, False)) except: pass cond = self.plugin.EvalString(self.cond) if self.cond != "" else True if cond: if args != self.args or kwargs != self.kwargs or not self.onlyChange: self.plugin.ServerSendMessage( client, dumps( { 'method' :method, 'args':args, 'kwargs':kwargs } ) ) self.args = args self.kwargs = kwargs def __call__( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, method="", cond="", othArgs="", kwArgs ="", onlyChange=True, period=5.0 ): client = eg.event.payload[0] if modeClient else ( eg.ParseString(cl_ip), int(eg.ParseString(cl_port)) ) if self.value: self.cond=cond self.othArgs=othArgs self.kwArgs=kwArgs self.onlyChange=onlyChange self.period=period self.Task(self.plugin, client, method) else: args = [] if othArgs != "": try: args = list(self.plugin.EvalString(othArgs)) except: pass kwargs = {} if kwArgs != "": try: kwargs = dict(self.plugin.EvalString(kwArgs, False)) except: pass cond = self.plugin.EvalString(cond) if cond != "" else True if cond: self.plugin.ServerSendMessage( client, dumps( { 'method' :method, 'args':args, 'kwargs':kwargs } ), ) def GetLabel( self, cl_ip, cl_port, modeClient, method, cond, othArgs, kwArgs, onlyChange, period ): if modeClient: client = "{eg.event.payload[0]}" return "%s: %s: %s" % ( self.name, client, method, ) else: return "%s: %s:%s: %s" % ( self.name, cl_ip, cl_port, method ) def Configure( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, method="", cond="", othArgs="", kwArgs ="", onlyChange=True, period=5.0 ): panel = eg.ConfigPanel(self) text = self.text id2 = wx.NewId() id3 = wx.NewId() id4 = wx.NewId() radioBoxModeClient = wx.RadioBox( panel, -1, self.plugin.text.modeClientChoiceLabel, choices = self.plugin.text.modeClientChoice, style=wx.RA_SPECIFY_ROWS ) radioBoxModeClient.SetSelection(modeClient) staticBox = wx.StaticBox(panel, -1, "") tmpSizer = wx.GridBagSizer(2, 10) txtLabel = wx.StaticText(panel,-1,self.plugin.text.host) txtCtrl = wx.TextCtrl(panel,id3,"") portLabel = wx.StaticText(panel,-1,self.plugin.text.port) portCtrl = wx.TextCtrl(panel,id2,"") tmpSizer.Add(txtLabel,(0,0),(1,1)) tmpSizer.Add(txtCtrl,(1,0),(1,1),flag = wx.EXPAND) tmpSizer.Add(portLabel,(2,0),(1,1),flag = wx.TOP, border = 10) tmpSizer.Add(portCtrl,(3,0),(1,1)) middleSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) middleSizer.Add(radioBoxModeClient,0,wx.LEFT|wx.EXPAND) middleSizer.Add((20,-1),0,wx.LEFT|wx.EXPAND) middleSizer.Add(tmpSizer,0,wx.LEFT|wx.EXPAND) panel.sizer.Add(middleSizer, 0, wx.TOP|wx.LEFT|wx.RIGHT|wx.EXPAND, 8) panel.sizer.Layout() size2 = (-1, tmpSizer.GetMinSize()[1]) def OnClientChoice(evt = None): ClientChoice( evt, self.plugin.text, panel, id3, id4, cl_ip, cl_port, size2, radioBoxModeClient ) radioBoxModeClient.Bind(wx.EVT_RADIOBOX, OnClientChoice) OnClientChoice() methodLabel = wx.StaticText(panel, -1, text.method) condLabel = wx.StaticText(panel, -1, text.cond) othLabel = wx.StaticText(panel, -1, text.othArgs) kwLabel = wx.StaticText(panel, -1, text.kwArgs) methodCtrl = wx.ComboBox( panel, -1, choices = METHODS[:8], style = wx.CB_DROPDOWN ) methodCtrl.SetValue(method) condCtrl = wx.TextCtrl(panel, -1, cond) othCtrl = wx.TextCtrl(panel, -1, othArgs) kwCtrl = wx.TextCtrl(panel, -1, kwArgs) mainSizer = wx.FlexGridSizer(7, 2, 2, 10) mainSizer.AddGrowableCol(1) mainSizer.Add(methodLabel,0, wx.TOP,3) mainSizer.Add(methodCtrl,0,wx.EXPAND) mainSizer.Add(othLabel,0, wx.TOP,3) mainSizer.Add(othCtrl,0,wx.EXPAND) mainSizer.Add(kwLabel,0, wx.TOP,3) mainSizer.Add(kwCtrl,0,wx.EXPAND) mainSizer.Add(condLabel,0, wx.TOP,3) mainSizer.Add(condCtrl,0,wx.EXPAND) if self.value: periodLabel = wx.StaticText(panel, -1, text.period) periodCtrl = eg.SpinNumCtrl( panel, -1, period, integerWidth = 5, fractionWidth = 1, allowNegative = False, min = 0.1, increment = 0.1, ) changeCtrl = wx.CheckBox(panel, -1, text.onlyChange) changeCtrl.SetValue(onlyChange) perSizer = wx.BoxSizer(wx.HORIZONTAL) mainSizer.Add(periodLabel,0,wx.TOP,3) perSizer.Add(periodCtrl,0,wx.LEFT,1) perSizer.Add((-1,-1),1,wx.EXPAND) perSizer.Add(changeCtrl,0,wx.TOP,4) mainSizer.Add(perSizer,0,wx.EXPAND) panel.sizer.Add(mainSizer,0,wx.ALL|wx.EXPAND,8) while panel.Affirmed(): modeClient = radioBoxModeClient.GetSelection() if not modeClient: cl_ip = wx.FindWindowById(id3).GetValue() cl_port = wx.FindWindowById(id4).GetValue() change = changeCtrl.GetValue() if self.value else None period = periodCtrl.GetValue() if self.value else None panel.SetResult( cl_ip, cl_port, modeClient, methodCtrl.GetValue(), condCtrl.GetValue(), othCtrl.GetValue(), kwCtrl.GetValue(), change, period ) #=============================================================================== class WsBroadcastUniversal(eg.ActionBase): class text: cond = "Condition:" method = "Method:" othArgs = "Arguments:" kwArgs = "Keyw. arguments:" onlyChange = "Data send only if it has been changed" period = "Sending period [s]:" def Task(self, plugin, method): if plugin.info.isStarted: self.task = eg.scheduler.AddTask( self.period, self.Task, plugin, #client, method ) args = [] if self.othArgs != "": try: args = list(self.plugin.EvalString(self.othArgs)) except: pass kwargs = {} if self.kwArgs != "": try: kwargs = dict(self.plugin.EvalString(self.kwArgs, False)) except: pass cond = self.plugin.EvalString(self.cond) if self.cond != "" else True if cond: if args != self.args or kwargs != self.kwargs or not self.onlyChange: self.plugin.BroadcastMessage( dumps( { 'method' :method, 'args':args, 'kwargs':kwargs } ) ) self.args = args self.kwargs = kwargs def __call__( self, method="", cond="", othArgs="", kwArgs ="", onlyChange=True, period=5.0 ): args = [] if othArgs != "": try: args = list(self.plugin.EvalString(othArgs)) except: pass kwargs = {} if kwArgs != "": try: kwargs = dict(self.plugin.EvalString(kwArgs, False)) except: pass if self.value: self.cond=cond self.othArgs=othArgs self.kwArgs=kwArgs self.onlyChange=onlyChange self.period=period self.args = args self.kwargs = kwargs self.Task(self.plugin, method) else: cond = self.plugin.EvalString(cond) if cond != "" else True if cond: self.plugin.BroadcastMessage( dumps( { 'method' :method, 'args':args, 'kwargs':kwargs } ), ) def GetLabel( self, method, cond, othArgs, kwArgs, onlyChange, period ): return "%s: %s" % (self.name, method) def Configure( self, method="", cond="", othArgs="", kwArgs ="", onlyChange=True, period=5.0 ): panel = eg.ConfigPanel(self) text = self.text staticBox = wx.StaticBox(panel, -1, "") methodLabel = wx.StaticText(panel, -1, text.method) condLabel = wx.StaticText(panel, -1, text.cond) othLabel = wx.StaticText(panel, -1, text.othArgs) kwLabel = wx.StaticText(panel, -1, text.kwArgs) methodCtrl = wx.ComboBox( panel, -1, choices = METHODS[:8], style = wx.CB_DROPDOWN ) methodCtrl.SetValue(method) condCtrl = wx.TextCtrl(panel, -1, cond) othCtrl = wx.TextCtrl(panel, -1, othArgs) kwCtrl = wx.TextCtrl(panel, -1, kwArgs) mainSizer = wx.FlexGridSizer(5, 2, 8, 10) mainSizer.AddGrowableCol(1) mainSizer.Add(methodLabel,0, wx.TOP,3) mainSizer.Add(methodCtrl,0,wx.EXPAND) mainSizer.Add(othLabel,0, wx.TOP,3) mainSizer.Add(othCtrl,0,wx.EXPAND) mainSizer.Add(kwLabel,0, wx.TOP,3) mainSizer.Add(kwCtrl,0,wx.EXPAND) mainSizer.Add(condLabel,0, wx.TOP,3) mainSizer.Add(condCtrl,0,wx.EXPAND) if self.value: periodLabel = wx.StaticText(panel, -1, text.period) periodCtrl = eg.SpinNumCtrl( panel, -1, period, integerWidth = 5, fractionWidth = 1, allowNegative = False, min = 0.1, increment = 0.1, ) changeCtrl = wx.CheckBox(panel, -1, text.onlyChange) changeCtrl.SetValue(onlyChange) perSizer = wx.BoxSizer(wx.HORIZONTAL) mainSizer.Add(periodLabel,0,wx.TOP,3) perSizer.Add(periodCtrl,0,wx.LEFT,1) perSizer.Add((-1,-1),1,wx.EXPAND) perSizer.Add(changeCtrl,0,wx.TOP,4) mainSizer.Add(perSizer,0,wx.EXPAND) panel.sizer.Add(mainSizer,0,wx.ALL|wx.EXPAND,8) while panel.Affirmed(): change = changeCtrl.GetValue() if self.value else None period = periodCtrl.GetValue() if self.value else None panel.SetResult( methodCtrl.GetValue(), condCtrl.GetValue(), othCtrl.GetValue(), kwCtrl.GetValue(), change, period ) #=============================================================================== class WsBroadcastCommand(eg.ActionBase): class text: cond = "Condition:" cmdName = "Command name:" arg1 = "Argument 1:" arg2 = "Argument 2:" arg3 = "Argument 3:" othArgs = "Arguments:" kwArgs = "Keyw. arguments:" onlyChange = "Data send only if it has been changed" period = "Sending period [s]:" def Task(self, plugin, cmdName): if self.plugin.info.isStarted: self.task = eg.scheduler.AddTask( self.period, self.Task, plugin, cmdName ) args = [self.plugin.EvalString(self.arg1)] if self.arg1 != "" else [] if self.arg2 != "": args.append(self.plugin.EvalString(self.arg2)) if self.arg3 != "": args.append(self.plugin.EvalString(self.arg3)) if self.othArgs != "": try: othArgs = list(self.plugin.EvalString(self.othArgs)) args.extend(othArgs) except: pass kwargs = {} if self.kwArgs != "": try: kwargs = dict(self.plugin.EvalString(self.kwArgs, False)) except: pass cond = self.plugin.EvalString(self.cond) if self.cond != "" else True if cond: if args != self.args or kwargs != self.kwargs or not self.onlyChange: self.plugin.BroadcastMessage( dumps( { 'method' :'Command', 'cmdName':cmdName, 'args':args, 'kwargs':kwargs } ) ) self.args=args self.kwargs=kwargs def __call__( self, cmdName="", cond="", arg1="", arg2="", arg3="", othArgs="", kwArgs ="", onlyChange=True, period=5.0 ): cmdName = self.plugin.EvalString(cmdName) if self.value: self.arg1 = arg1 self.arg2 = arg2 self.arg3 = arg3 self.othArgs=othArgs self.kwArgs =kwArgs self.onlyChange=onlyChange self.period=period self.cond = cond self.args = None self.kwargs = None self.Task(self.plugin, cmdName) else: args = [self.plugin.EvalString(arg1)] if arg1 != "" else [] if arg2 != "": args.append(self.plugin.EvalString(arg2)) if arg3 != "": args.append(self.plugin.EvalString(arg3)) if othArgs != "": try: othArgs = list(self.plugin.EvalString(othArgs)) args.extend(othArgs) except: pass kwargs = {} if kwArgs != "": try: kwargs = dict(self.plugin.EvalString(kwArgs, False)) except: pass cond = self.plugin.EvalString(cond) if cond != "" else True if cond: self.plugin.BroadcastMessage( dumps( { 'method' :'Command', 'cmdName':cmdName, 'args':args, 'kwargs':kwargs } ) ) def Configure( self, cmdName="", cond="", arg1="", arg2="", arg3="", othArgs="", kwArgs ="", onlyChange=True, period=5.0 ): panel = eg.ConfigPanel(self) text = self.text nameLabel = wx.StaticText(panel, -1, text.cmdName) condLabel = wx.StaticText(panel, -1, text.cond) arg1Label = wx.StaticText(panel, -1, text.arg1) arg2Label = wx.StaticText(panel, -1, text.arg2) arg3Label = wx.StaticText(panel, -1, text.arg3) othLabel = wx.StaticText(panel, -1, text.othArgs) kwLabel = wx.StaticText(panel, -1, text.kwArgs) nameCtrl = wx.TextCtrl(panel, -1, cmdName) condCtrl = wx.TextCtrl(panel, -1, cond) arg1Ctrl = wx.TextCtrl(panel, -1, arg1) arg2Ctrl = wx.TextCtrl(panel, -1, arg2) arg3Ctrl = wx.TextCtrl(panel, -1, arg3) othCtrl = wx.TextCtrl(panel, -1, othArgs) kwCtrl = wx.TextCtrl(panel, -1, kwArgs) mainSizer = wx.FlexGridSizer(7, 2, 2, 10) mainSizer.AddGrowableCol(1) mainSizer.Add(nameLabel,0, wx.TOP,3) mainSizer.Add(nameCtrl,0,wx.EXPAND) mainSizer.Add(arg1Label,0, wx.TOP,3) mainSizer.Add(arg1Ctrl,0,wx.EXPAND) mainSizer.Add(arg2Label,0, wx.TOP,3) mainSizer.Add(arg2Ctrl,0,wx.EXPAND) mainSizer.Add(arg3Label,0, wx.TOP,3) mainSizer.Add(arg3Ctrl,0,wx.EXPAND) mainSizer.Add(othLabel,0, wx.TOP,3) mainSizer.Add(othCtrl,0,wx.EXPAND) mainSizer.Add(kwLabel,0, wx.TOP,3) mainSizer.Add(kwCtrl,0,wx.EXPAND) mainSizer.Add(condLabel,0, wx.TOP,3) mainSizer.Add(condCtrl,0,wx.EXPAND) panel.sizer.Add(mainSizer,0,wx.LEFT|wx.RIGHT|wx.EXPAND,10) if self.value: periodLabel = wx.StaticText(panel, -1, text.period) periodCtrl = eg.SpinNumCtrl( panel, -1, period, integerWidth = 5, fractionWidth = 1, allowNegative = False, min = 0.1, increment = 0.1, ) changeCtrl = wx.CheckBox(panel, -1, text.onlyChange) changeCtrl.SetValue(onlyChange) perSizer = wx.BoxSizer(wx.HORIZONTAL) perSizer.Add(periodCtrl,0,wx.LEFT,1) perSizer.Add((-1,-1),1,wx.EXPAND) perSizer.Add(changeCtrl,0,wx.TOP,4) mainSizer.Add(periodLabel,0,wx.TOP,3) mainSizer.Add(perSizer,0,wx.EXPAND) while panel.Affirmed(): change = changeCtrl.GetValue() if self.value else None period = periodCtrl.GetValue() if self.value else None panel.SetResult( nameCtrl.GetValue(), condCtrl.GetValue(), arg1Ctrl.GetValue(), arg2Ctrl.GetValue(), arg3Ctrl.GetValue(), othCtrl.GetValue(), kwCtrl.GetValue(), change, period ) #=============================================================================== class WsBroadcastMessage(eg.ActionBase): class text: mess = "Message for broadcast:" def __call__(self, message = "", pars = False): if not pars: message = self.plugin.EvalString(message) return self.plugin.BroadcastMessage(message) def Configure(self, message = "", pars = False): text = self.text panel = eg.ConfigPanel() messCtrl = wx.TextCtrl(panel, -1, message) parsCtrl = wx.CheckBox(panel, -1, self.plugin.text.parsing) parsCtrl.SetValue(pars) messSizer = wx.StaticBoxSizer( wx.StaticBox(panel, -1, text.mess), wx.VERTICAL ) panel.sizer.Add(messSizer, 0, wx.EXPAND|wx.TOP, 15) messSizer.Add(messCtrl, 0, wx.EXPAND) messSizer.Add(parsCtrl, 0, wx.EXPAND|wx.TOP, 3) while panel.Affirmed(): panel.SetResult( messCtrl.GetValue(), parsCtrl.GetValue() ) #=============================================================================== class WsBroadcastValue(eg.ActionBase): class text: varnames = "Variable name or list of variables (separated by commas):" err = 'Error in action "Websocket broadcast values(%s)"' def __call__(self, varnames = ""): try: keys = varnames.replace(" ", "") keys = keys.split(",") except: eg.PrintError(self.text.err % str(varnames)) return try: vals = {} for key in keys: k = self.plugin.EvalString(key) vals[k] = self.plugin.GetValue(k) except: eg.PrintError(self.text.err % str(varnames)) return self.plugin.BroadcastMessage( dumps({'method' :'Values', 'kwargs':vals}) ) def Configure(self, varnames = ""): panel = eg.ConfigPanel(self) varnamesCtrl = panel.TextCtrl(varnames) mainSizer = wx.BoxSizer(wx.VERTICAL) varnamesLbl = panel.StaticText(self.text.varnames) mainSizer.Add(varnamesLbl) mainSizer.Add(varnamesCtrl, 0, wx.EXPAND|wx.TOP, 1) panel.sizer.Add(mainSizer, 0, wx.EXPAND|wx.ALL, 10) while panel.Affirmed(): panel.SetResult( varnamesCtrl.GetValue(), ) #=============================================================================== class WsStopClientPeriodicTasks(eg.ActionBase): class text: label = "Data or command name (empty = all client's tasks):" def __call__( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, taskName = "" ): client = eg.event.payload[0] if modeClient else ( eg.ParseString(cl_ip), int(eg.ParseString(cl_port)) ) self.plugin.StopClientPeriodicTasks(client, taskName) def GetLabel(self, cl_ip, cl_port, modeClient, taskName): if modeClient: client = "{eg.event.payload[0]}" return "%s: %s: %s" % (self.name, client, taskName) else: return "%s: %s:%s: %s" % (self.name, cl_ip, cl_port, taskName) def Configure( self, cl_ip="127.0.0.1", cl_port = "1234", modeClient = 1, taskName = "" ): text = self.text panel = eg.ConfigPanel() label = wx.StaticText(panel,-1,self.text.label) taskCtrl = wx.TextCtrl(panel,-1,taskName) id2 = wx.NewId() id3 = wx.NewId() id4 = wx.NewId() radioBoxModeClient = wx.RadioBox( panel, -1, self.plugin.text.modeClientChoiceLabel, choices = self.plugin.text.modeClientChoice, style=wx.RA_SPECIFY_ROWS ) radioBoxModeClient.SetSelection(modeClient) staticBox = wx.StaticBox(panel, -1, "") tmpSizer = wx.GridBagSizer(2, 10) txtLabel = wx.StaticText(panel,-1,self.plugin.text.host) txtCtrl = wx.TextCtrl(panel,id3,"") portLabel = wx.StaticText(panel,-1,self.plugin.text.port) portCtrl = wx.TextCtrl(panel,id2,"") tmpSizer.Add(txtLabel,(0,0),(1,1)) tmpSizer.Add(txtCtrl,(1,0),(1,1),flag = wx.EXPAND) tmpSizer.Add(portLabel,(2,0),(1,1),flag = wx.TOP, border = 10) tmpSizer.Add(portCtrl,(3,0),(1,1)) middleSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) middleSizer.Add(radioBoxModeClient,0,wx.LEFT|wx.EXPAND) middleSizer.Add((20,-1),0,wx.LEFT|wx.EXPAND) middleSizer.Add(tmpSizer,0,wx.LEFT|wx.EXPAND) panel.sizer.Add(middleSizer, 0, wx.TOP|wx.EXPAND, 8) panel.sizer.Layout() size2 = (-1, tmpSizer.GetMinSize()[1]) def OnClientChoice(evt = None): ClientChoice( evt, self.plugin.text, panel, id3, id4, cl_ip, cl_port, size2, radioBoxModeClient ) radioBoxModeClient.Bind(wx.EVT_RADIOBOX, OnClientChoice) OnClientChoice() panel.sizer.Add(label, 0, wx.TOP,8) panel.sizer.Add(taskCtrl, 0, wx.EXPAND|wx.TOP,2) while panel.Affirmed(): modeClient = radioBoxModeClient.GetSelection() if not modeClient: cl_ip = wx.FindWindowById(id3).GetValue() cl_port = wx.FindWindowById(id4).GetValue() panel.SetResult( cl_ip, cl_port, modeClient, taskCtrl.GetValue() ) #=============================================================================== class WsStopPeriodicTasks(eg.ActionBase): class text: label = "Data or command name (empty = all broadcast tasks):" def __call__(self, taskName = ""): self.plugin.StopPeriodicTasks(self.value, taskName) def Configure(self, taskName = ""): panel = eg.ConfigPanel() taskCtrl = wx.TextCtrl(panel,-1,taskName) if self.value: taskCtrl.Show(False) panel.dialog.buttonRow.applyButton.Enable(False) panel.dialog.buttonRow.testButton.Show(False) label = panel.StaticText( eg.text.General.noOptionsAction, style=wx.ALIGN_CENTRE|wx.ST_NO_AUTORESIZE ) panel.sizer.Add((0, 0), 1, wx.EXPAND) panel.sizer.Add(label, 0, wx.ALIGN_CENTRE) panel.sizer.Add((0, 0), 1, wx.EXPAND) else: label = wx.StaticText(panel,-1,self.text.label) mainSizer = wx.BoxSizer(wx.VERTICAL) mainSizer.Add(label) mainSizer.Add(taskCtrl,0,wx.EXPAND) panel.sizer.Add(mainSizer,1,wx.EXPAND|wx.ALL, 10) while panel.Affirmed(): panel.SetResult(taskCtrl.GetValue(),) #=============================================================================== class SetClientsFlags(eg.ActionBase): class text: varname = "Dummy variable name:" err = 'Error in action "Set clients flags(%s)"' def __call__(self, varname = "", pars = False): try: key = eg.ParseString(varname) if not pars else varname self.plugin.SetClientsFlags(key) except: eg.PrintError(self.text.err % str(varname)) def Configure(self, varname = "", pars = False): panel = eg.ConfigPanel(self) varnameCtrl = panel.TextCtrl(varname) parsCtrl = wx.CheckBox(panel, -1, self.plugin.text.parsing) parsCtrl.SetValue(pars) mainSizer = wx.BoxSizer(wx.VERTICAL) varnameLbl = panel.StaticText(self.text.varname) mainSizer.Add(varnameLbl) mainSizer.Add(varnameCtrl, 0, wx.EXPAND|wx.TOP, 1) mainSizer.Add(parsCtrl, 0, wx.TOP, 4) panel.sizer.Add(mainSizer, 0, wx.EXPAND|wx.ALL, 10) while panel.Affirmed(): panel.SetResult( varnameCtrl.GetValue(), parsCtrl.GetValue() ) #=============================================================================== class GetValue(eg.ActionBase): class text: varname = "Variable name:" err = 'Error in action "Get temporary value(%s)"' def __call__(self, varname = "", pars = False): try: key = eg.ParseString(varname) if not pars else varname return self.plugin.GetValue(key) except: eg.PrintError(self.text.err % str(varname)) def Configure(self, varname = "", pars = False): panel = eg.ConfigPanel(self) varnameCtrl = panel.TextCtrl(varname) parsCtrl = wx.CheckBox(panel, -1, self.plugin.text.parsing) parsCtrl.SetValue(pars) mainSizer = wx.BoxSizer(wx.VERTICAL) varnameLbl = panel.StaticText(self.text.varname) mainSizer.Add(varnameLbl) mainSizer.Add(varnameCtrl, 0, wx.EXPAND|wx.TOP, 1) mainSizer.Add(parsCtrl, 0, wx.TOP, 4) panel.sizer.Add(mainSizer, 0, wx.EXPAND|wx.ALL, 10) while panel.Affirmed(): panel.SetResult( varnameCtrl.GetValue(), parsCtrl.GetValue() ) #=============================================================================== class GetPersistentValue(GetValue): class text: varname = "Persistent variable name:" err = 'Error in action "Get persistent value(%s)"' def __call__(self, varname = "", pars = False): try: key = eg.ParseString(varname) if not pars else varname return self.plugin.GetPersistentValue(key) except: eg.PrintError(self.text.err % str(varname)) #=============================================================================== class SetValue(eg.ActionBase): class text: varname = "Variable name:" value = "Value:" err = 'Error in action "Set temporary value(%s, %s)"' def __call__( self, varname = "", value = "{eg.event.payload}", pars1 = False, pars2 = False, ): try: key = eg.ParseString(varname) if not pars1 else varname val = eg.ParseString(value) if not pars2 else value self.plugin.SetValue(key, val) except: eg.PrintError(self.text.err % (str(varname), str(value))) def GetLabel(self, varname, value, pars1, pars2): return "%s: %s: %s" % (self.name, varname, value) def Configure( self, varname = "", value = "{eg.event.payload}", pars1 = False, pars2 = False, ): panel = eg.ConfigPanel(self) varnameCtrl = panel.TextCtrl(varname) pars1Ctrl = wx.CheckBox(panel, -1, self.plugin.text.parsing) pars1Ctrl.SetValue(pars1) valueCtrl = panel.TextCtrl(value) pars2Ctrl = wx.CheckBox(panel, -1, self.plugin.text.parsing) pars2Ctrl.SetValue(pars2) mainSizer = wx.BoxSizer(wx.VERTICAL) varnameLbl = panel.StaticText(self.text.varname) valueLbl = panel.StaticText(self.text.value) mainSizer.Add(varnameLbl) mainSizer.Add(varnameCtrl, 0, wx.EXPAND|wx.TOP, 1) mainSizer.Add(pars1Ctrl, 0, wx.EXPAND|wx.TOP, 4) mainSizer.Add(valueLbl, 0, wx.EXPAND|wx.TOP, 20) mainSizer.Add(valueCtrl, 0, wx.EXPAND|wx.TOP, 1) mainSizer.Add(pars2Ctrl, 0, wx.EXPAND|wx.TOP, 4) panel.sizer.Add(mainSizer, 0, wx.EXPAND|wx.ALL, 10) while panel.Affirmed(): panel.SetResult( varnameCtrl.GetValue(), valueCtrl.GetValue(), pars1Ctrl.GetValue(), pars2Ctrl.GetValue(), ) #=============================================================================== class SetPersistentValue(SetValue): class text: varname = "Persistent variable name:" value = "Value:" err = 'Error in action "Set persistent value(%s, %s)"' def __call__( self, varname = "", value = "{eg.event.payload}", pars1 = False, pars2 = False, ): try: key = eg.ParseString(varname) if not pars1 else varname val = eg.ParseString(value) if not pars2 else value self.plugin.SetPersistentValue(key, val) except: eg.PrintError(self.text.err % (str(varname), str(value))) #=============================================================================== class SendEvent(eg.ActionBase): class text: event = "Event:" host = "Host:" port ="Port:" username = "Username:" password = "Password:" errmsg = "Target server returned status %s" def __call__( self, event="", host="", port=80, user="", password="", pars = False ): text = self.text def Request(methodName, *args, **kwargs): data = {"method": methodName} if len(args): data["args"] = args if len(kwargs): data["kwargs"] = kwargs content = dumps(data) authString = b64_encStr(user + ':' + password).strip() sock = None for af, socktype, proto, canonname, sa in socket.getaddrinfo( host, port, socket.AF_UNSPEC, socket.SOCK_STREAM ): try: sock = socket.socket(af, socktype, proto) except socket.error: sock = None continue sock.settimeout(2) try: sock.connect(sa) except socket.error: sock.close() sock = None continue break data = [ "POST %s HTTP/1.0" % "/", "Host: %sock:%d" % (host, port), "User-Agent: EventGhost/%s" % eg.Version.string, "Authorization: Basic %s" % authString, "Content-Length: %d" % len(content), "Content-Type: application/json; charset=UTF-8", "", content ] sock.send("\r\n".join(data)) response = HTTPResponse(sock) response.begin() content = response.read() response.close() sock.close() if response.status != 200: raise Exception( text.errmsg % response.status ) return loads(content) event = eg.ParseString(event) if not pars else event Request("TriggerEnduringEvent", event) stopEvent = Event() eg.event.AddUpFunc(stopEvent.set) def RepeatLoop(): while True: stopEvent.wait(1.0) if stopEvent.isSet(): break Request("RepeatEnduringEvent", event) Request("EndLastEvent") Thread(target=RepeatLoop).start() def Configure( self, event="", host="", port=80, user="", password="", pars = False ): text = self.text panel = eg.ConfigPanel(self) eventCtrl = panel.TextCtrl(event) parsCtrl = wx.CheckBox(panel, -1, self.plugin.text.parsing) parsCtrl.SetValue(pars) hostCtrl = panel.TextCtrl(host) portCtrl = panel.SpinIntCtrl(port, min=1, max=65535) userCtrl = panel.TextCtrl(user) passwordCtrl = panel.TextCtrl(password) fl = wx.EXPAND|wx.TOP box=wx.GridBagSizer(2, 5) box.AddGrowableCol(1) box.Add(panel.StaticText(text.event), (0, 0), flag = wx.TOP, border=12) box.Add(eventCtrl, (0, 1), flag = fl, border=9) box.Add(parsCtrl, (1, 0), (1, 2)) box.Add(panel.StaticText(text.host), (2, 0), flag = wx.TOP, border=12) box.Add(hostCtrl, (2, 1), flag = fl, border=9) box.Add(panel.StaticText(text.port), (3, 0), flag = wx.TOP, border=12) box.Add(portCtrl, (3, 1), flag = wx.TOP, border=9) box.Add(panel.StaticText(text.username), (4, 0), flag=wx.TOP, border=12) box.Add(userCtrl, (4, 1), flag = fl, border=9) box.Add(panel.StaticText(text.password), (5, 0), flag=wx.TOP, border=12) box.Add(passwordCtrl, (5, 1), flag = fl, border=9) panel.sizer.Add(box, 0, wx.EXPAND|wx.LEFT|wx.RIGHT, 10) while panel.Affirmed(): panel.SetResult( eventCtrl.GetValue(), hostCtrl.GetValue(), portCtrl.GetValue(), userCtrl.GetValue(), passwordCtrl.GetValue(), parsCtrl.GetValue() ) #=============================================================================== # Enhancement by Sem;colon - START class SendEventExt(eg.ActionBase): class text: url = "Url: (like you would put it into a webbrowser)" event = "Event:" username = "Username:" password = "Password:" msg1 = "This page isn't protected by authentication." msg2 = 'But we failed for another reason.' msg3 = 'A 401 error without an authentication response header - very weird.' msg4 = 'The authentication line is badly formed.' msg5 = 'This example only works with BASIC authentication.' msg6 = "url, username or password is wrong." def __call__(self, event="", host="", user="", password=""): text = self.text req = urlRequest(host, event) try: handle = urlopen(req) except IOError, e: # If we fail then the page could be protected if not hasattr(e, 'code') or e.code != 401: # we got an error - but not a 401 error print text.msg1 print text.msg2 authline = e.headers.get('www-authenticate', '') # this gets the www-authenticat line from the headers - which has the authentication scheme and realm in it if not authline: print text.msg3 authobj = re_compile(r'''(?:\s*www-authenticate\s*:)?\s*(\w*)\s+realm=['"](\w+)['"]''', IGNORECASE) # this regular expression is used to extract scheme and realm matchobj = authobj.match(authline) if not matchobj: # if the authline isn't matched by the regular expression then something is wrong print text.msg4 scheme = matchobj.group(1) realm = matchobj.group(2) if scheme.lower() != 'basic': print text.msg5 base64string = b64_encStr('%s:%s' % (user, password))[:-1] authheader = "Basic %s" % base64string req.add_header("Authorization", authheader) try: handle = urlopen(req) except IOError, e: print text.msg6 #else: # If we don't fail then the page isn't protected #print "This page isn't protected by authentication." thepage = unquote(handle.read()) # handle.read() return thepage def Configure(self, event="", host="http://127.0.0.1:80", user="", password=""): text = self.text panel = eg.ConfigPanel(self) eventCtrl = panel.TextCtrl(event) hostCtrl = panel.TextCtrl(host) userCtrl = panel.TextCtrl(user) passwordCtrl = panel.TextCtrl(password) panel.sizer.AddMany([ panel.StaticText(text.event), eventCtrl, panel.StaticText(text.url), hostCtrl, panel.StaticText(text.username), userCtrl, panel.StaticText(text.password), passwordCtrl, ]) while panel.Affirmed(): panel.SetResult( eventCtrl.GetValue(), hostCtrl.GetValue(), userCtrl.GetValue(), passwordCtrl.GetValue(), ) # Enhancement by Sem;colon - END #=============================================================================== class Webserver(eg.PluginBase): wsClients = {} wsClientsTime = {} knowlClients = {} pubPerClients = {} pubVars = {} pubPerVars = {} wsServers = {} class text: generalBox = "General Settings" port = "TCP/IP port:" documentRoot = "HTML documents root:" eventPrefix = "Event prefix:" authBox = "Basic Authentication" serverTitle = "Server title" authRealm = "Realm:" authUsername = "Username:" authPassword = "Password:" dialogPers = "Persistent variables" dialogTemp = "Temporary variables" ok = "OK" cancel = "Cancel" vrbl = "Variable name" defVal = "Variable value" delete = "Delete selected variables" clear = "Clear all variables" autosave = "Automatically save the document when the value of a persistent variable is changed" nonAjaxBox = "Additional settings for non-AJAX POST requests" listSplitter = "String between list items:" valueSplitter = "String between returned values:" parsing = "disable parsing of string" certfile = "SSL certificate" keyfile = "SSL private key" sslTool = "Select the appropriate file if you want to use a secure "\ "protocol (https).\n If this field remains blank, the server will use an "\ "unsecure protocol (http). " cMask = ( "crt files (*.crt)|*.crt" "|pem files (*.pem)|*.pem" "|All files (*.*)|*.*" ) kMask = ( "key files (*.key)|*.key" "|pem files (*.pem)|*.pem" "|All files (*.*)|*.*" ) modeClientChoiceLabel = 'Client address to specify as' modeClientChoice = ( 'Explicitly (or Python expression)', 'From eg.event.payload[0]', ) host = "TCP/IP address:" wsClientDisconn = "WsClientDisconnected" wsClientConn = "WsClientConnected" wsServerDisconn = "WsServerDisconnected" wsServerConn = "WsServerConnected" started = "Webserver started as %s on port %i" secur = ( "secured (https://)", "unsecured (http://)", ) stopped = "Webserver on port %i stopped" forcDel = "WebSocket client %s force deleted" keyErr = "KeyError (non existent client): %s" noAutWs = "Basic Authentication is not required when WebSocket connections from clients" sendFail = 'Send a message to the server "%s" failed' noConn = 'Connection to the server "%s" is not created or has been interrupted.' srvrExists = 'Server named "%s" is already connected' #wsConClosed = 'WebSocket connection to the server "%s" closed' wsConError = 'Error on the WebSocket connection to the server "%s"' wsClients = "Websocket clients" wsServers = "Websocket servers" #headerCli = "Websocket clients" colLabelsCli = ( "Client IP address", "Client TCP/IP port", "Connected since ...", ) colLabelsSrvr = ( "Server title", "Server URL", "Connected since ...", ) abort = "Disconnect" abortAll = "Disconnect all" refresh = "Refresh" def __init__(self): self.AddEvents() self.AddActionsFromList(ACTIONS) self.running = False def __start__( self, prefix=None, port = 80, basepath = None, authRealm = "Eventghost", authUsername = "", authPassword = "", pubPerVars = {}, autosave = False, listSplitter =",", valueSplitter =";;", certfile = "", keyfile = "", noAutWs = False ): self.port = port self.info.eventPrefix = prefix if authUsername or authPassword: authString = b64encode(authUsername + ':' + authPassword) else: authString = None self.knowlClients = {} self.pubPerClients = {} self.pubVars = {} self.wsClients = {} self.wsClientsTime = {} self.knowlClients = {} self.pubPerClients = {} self.pubVars = {} self.tv = KeysAsAttrs(self.pubVars) self.pubPerVars = pubPerVars self.pv = KeysAsAttrs(self.pubPerVars) self.wsServers = {} self.autosave = autosave self.listSplitter = unicode(listSplitter) self.valueSplitter = unicode(valueSplitter) self.noAutWs = noAutWs for key in self.pubPerVars.iterkeys(): self.pubPerClients[key] = [] class RequestHandler(MyHTTPRequestHandler): plugin = self environment = Environment(loader=FileLoader()) environment.globals = eg.globals.__dict__ repeatTimer = eg.ResettableTimer(self.EndLastEvent) RequestHandler.basepath = basepath RequestHandler.authRealm = authRealm RequestHandler.authString = authString self.server = MyServer(RequestHandler, port, certfile, keyfile) self.server.Start() sr = int(not (isfile(certfile) and isfile(keyfile))) print self.text.started % (self.text.secur[sr], port) eg.PrintNotice("Persistent values: " + repr(self.pubPerVars)) def __stop__(self): self.server.Stop() print self.text.stopped % self.port self.StopAllClients() def GetValue(self, key, client = None): if key in self.pubVars: if client: tmp = self.knowlClients[key] if not client in tmp: tmp.append(client) return self.pubVars[key] else: return self.pubVars[key] def DelPersistentValue(self, key): if key in self.pubPerVars: del self.pubPerVars[key] wx.CallAfter(self.SetDocIsDirty) if key in self.pubPerClients: del self.pubPerClients[key] def ClearPersistentValues(self): tmpLst = list(self.pubPerVars.iterkeys()) for key in tmpLst: del self.pubPerVars[key] self.pubPerClients = {} wx.CallAfter(self.SetDocIsDirty) def GetPersistentValue(self, key, client = None): if key in self.pubPerVars: if client: tmp = self.pubPerClients[key] if not client in tmp: tmp.append(client) return self.pubPerVars[key] else: return self.pubPerVars[key] def SetValue(self, key, value): if key not in self.pubPerVars: if key not in self.pubVars or value != self.pubVars[key]: self.pubVars[key] = unicode(value) self.knowlClients[key] = [] def SetPersistentValue(self, key, value): if key not in self.pubVars: if key not in self.pubPerVars or value != self.pubPerVars[key]: self.pubPerVars[key] = unicode(value) self.pubPerClients[key] = [] wx.CallAfter(self.SetDocIsDirty) def SetClientsFlags(self, key): if key not in self.pubVars: self.pubVars[key] = "dummy" self.knowlClients[key] = [] def GetChangedValues(self, client): tmpDict = {} for key, value in self.pubVars.iteritems(): if not client in self.knowlClients[key]: tmpDict[key] = value self.knowlClients[key].append(client) for key, value in self.pubPerVars.iteritems(): if not client in self.pubPerClients[key]: tmpDict[key] = value self.pubPerClients[key].append(client) return {"method":"Values","kwargs":tmpDict} def GetAllValues(self, client = None): try: tmpDict = {} for key, value in self.pubVars.iteritems(): if client: if not client in self.knowlClients[key]: self.knowlClients[key].append(client) tmpDict[key] = value for key, value in self.pubPerVars.iteritems(): if client: if not client in self.pubPerClients[key]: self.pubPerClients[key].append(client) tmpDict[key] = value return {"method":"Values","kwargs":tmpDict} except: eg.PrintTraceback() def BroadcastMessage(self, message): tmp = list(self.wsClients.iteritems()) for key, client in tmp: try: client.write_message(message) except Exception, exc: if exc.args[0] in (10053, 10054, 10060): del self.wsClients[client] del self.wsClientsTime[client] eg.PrintNotice(self.text.forcDel % repr(client)) self.TriggerEvent( self.text.wsClientDisconn, payload = [client] ) else: eg.PrintTraceback() # debugging ... def StopPeriodicTasks(self, all, taskName = ""): for t in eg.scheduler.__dict__['heap']: try: if len(t[2]) > 1 and t[2][0] == self: if all: eg.scheduler.CancelTask(t) #elif len(t[2]) == 2: # if taskName == "" or taskName == t[2][1]: # eg.scheduler.CancelTask(t) elif len(t[2]) > 2: if taskName == "" or taskName == t[2][1]: eg.scheduler.CancelTask(t) except: pass def StopClientPeriodicTasks(self, client, taskName = ""): for t in eg.scheduler.__dict__['heap']: try: if len(t[2]) > 2 and t[2][0] == self and t[2][1] == client: if taskName == "" or taskName == t[2][2]: eg.scheduler.CancelTask(t) except: pass def ProcessTheArguments( self, handler, methodName, args, kwargs, ): sender = handler.clAddr[0] result = None if methodName == "GetGlobalValue": if len(args): try: result = unicode(handler.environment.globals[args[0]]) except: pass elif methodName == "GetValue": if len(args): try: result = self.GetValue(args[0], sender) except: pass elif methodName == "GetPersistentValue": if len(args): try: result = self.GetPersistentValue( args[0], sender ) except: result = None elif methodName == "SetValue": if len(args): try: self.SetValue(args[0], args[1]) result = True except: result = False elif methodName == "SetPersistentValue": if len(args): try: self.SetPersistentValue(args[0], args[1]) result = True except: result = False elif methodName == "GetAllValues": result = self.GetAllValues(sender) elif methodName == "GetChangedValues": result = self.GetChangedValues(sender) elif methodName == "ExecuteScript": try: result = eval(args[0]) except: print "ExecuteScript Error: args[0] = ",args[0] result = None raise elif methodName == "TriggerEvent": if 'payload' in kwargs and kwargs['payload'] == 'client_address': kwargs['payload'] = [handler.clAddr] if 'prefix' in kwargs: eg.TriggerEvent(*args, **kwargs) else: self.TriggerEvent(*args, **kwargs) elif methodName == "TriggerEnduringEvent": self.TriggerEnduringEvent(*args, **kwargs) handler.repeatTimer.Reset(2000) elif methodName == "RepeatEnduringEvent": handler.repeatTimer.Reset(2000) elif methodName == "EndLastEvent": handler.repeatTimer.Reset(None) self.EndLastEvent() return result def ProcessTheArguments_C_S( self, title, methodName, args, kwargs, ): result = None if methodName == "GetGlobalValue": if len(args): try: result = unicode(eg.globals.__dict__[args[0]]) except: pass elif methodName == "GetValue": if len(args): try: result = self.GetValue(args[0]) except: pass elif methodName == "GetPersistentValue": if len(args): try: result = self.GetPersistentValue(args[0]) except: result = None elif methodName == "SetValue": if len(args): try: self.SetValue(args[0], args[1]) result = True except: result = False elif methodName == "SetPersistentValue": if len(args): try: self.SetPersistentValue(args[0], args[1]) result = True except: result = False elif methodName == "GetAllValues": result = self.GetAllValues() #elif methodName == "GetChangedValues": # result = self.GetChangedValues(sender) elif methodName == "ExecuteScript": try: result = eval(args[0]) except: print "ExecuteScript Error: args[0] = ",args[0] result = None raise elif methodName == "TriggerEvent": if 'payload' in kwargs and kwargs['payload'] == 'server_title': kwargs['payload'] = [title] if 'prefix' in kwargs: eg.TriggerEvent(*args, **kwargs) else: self.TriggerEvent(*args, **kwargs) #elif methodName == "TriggerEnduringEvent": # plugin.TriggerEnduringEvent(*args, **kwargs) # handler.repeatTimer.Reset(2000) #elif methodName == "RepeatEnduringEvent": # handler.repeatTimer.Reset(2000) #elif methodName == "EndLastEvent": # handler.repeatTimer.Reset(None) # plugin.EndLastEvent() return result def SetDocIsDirty(self): eg.document.SetIsDirty() if self.autosave: eg.document.Save() def EvalString(self, strng, remBrac = True): try: strng = eg.ParseString(strng) except: if remBrac and strng.startswith("{") and strng.endswith("}"): strng = strng[1:-1] tv = self.tv pv = self.pv try: strng = eval(strng) except: pass return strng # def ServerSendMessage(self, message, cl_ip, cl_port, modeClient): def ServerSendMessage(self, client, message): #client = eg.event.payload[0] if modeClient else ( # eg.ParseString(cl_ip), # int(eg.ParseString(cl_port)) #) if client in self.wsClients: try: self.wsClients[client].write_message(message) except Exception, exc: if exc.args[0] in (10053, 10054, 10060): del self.wsClients[client] del self.wsClientsTime[client] eg.PrintNotice(self.text.forcDel % repr(client)) self.TriggerEvent( self.text.wsClientDisconn, payload = [client] ) else: eg.PrintTraceback() # debugging ... else: eg.PrintNotice(self.text.keyErr % repr(client)) def StartClient( self, title, url, login, password, noCert ): wsC = WebSocketClient(title, url, login, password, noCert, self) if not title in self.wsServers.iterkeys(): self.wsServers[title] = wsC ct = Thread(target = wsC.start) ct.start() else: eg.PrintError(self.text.srvrExists % title) def StopClient(self, title): if title in self.wsServers: self.wsServers[title].close() del self.wsServers[title] def StopAllClients(self): clients = list(self.wsServers.iteritems()) for title, client in clients: client.close() del self.wsServers[title] def on_open(self, server): server.conTime = eg.Utils.time.time() self.TriggerEvent( "%s.%s" % (self.text.wsServerConn, server.title), payload = server.title ) def on_message(self, server, message): try: message = message.decode('utf-8') except: pass try: data = loads(message) except: self.TriggerEvent( u"ServerMessage.%s" % message, payload=(server.title, message) ) return # JSON request try: methodName = data["method"] except: self.TriggerEvent("ServerMessage", payload = (server.title, data)) else: if methodName in METHODS[:8]: try: args = data.get("args", []) kwargs = data.get("kwargs", {}) result = self.ProcessTheArguments_C_S( server.title, methodName, args, kwargs ) content = dumps(result) try: self.ClientSendMessage(server.title, content) except: eg.PrintTraceback() except: eg.PrintTraceback() else: self.TriggerEvent( methodName, payload = (server.title, data) ) def ClientSendMessage(self, title, message): if title in self.wsServers: try: self.wsServers[title].send(message.encode("utf-8")) except: eg.PrintError(self.text.sendFail % title) else: eg.PrintError(self.text.noConn % title) #def close_ws(self, client): # client.close() def GetActions(self, id, action = None): def Traverse(item): if item.__class__ == eg.document.ActionItem: if hasattr(item.executable, 'actionId'): #if item.executable.name == actName and\ if item.executable.actionId == id and\ item.executable.plugin.name == self.name and\ item.executable != action and item.args: actions.append(item) elif item and item.childs: for child in item.childs: Traverse(child) actions = [] Traverse(eg.document.__dict__['root']) return actions def Configure( self, prefix="HTTP", port = 80, basepath="", authRealm="EventGhost", authUsername="", authPassword="", pubPerVars = {}, autosave = False, listSplitter =",", valueSplitter =";;", certfile = "", keyfile = "", noAutWs = False ): text = self.text panel = eg.ConfigPanel() portCtrl = panel.SpinIntCtrl(port, min=1, max=65535) filepathCtrl = panel.DirBrowseButton(basepath) certfileCtrl = eg.FileBrowseButton( panel, -1, toolTip = text.sslTool, dialogTitle = text.certfile, buttonText = eg.text.General.browse, startDirectory = "", initialValue = certfile, fileMask = text.cMask, ) keyfileCtrl = eg.FileBrowseButton( panel, -1, toolTip = text.sslTool, dialogTitle = text.keyfile, buttonText = eg.text.General.browse, startDirectory = "", initialValue = keyfile, fileMask = text.kMask, ) editCtrl = panel.TextCtrl(prefix) authRealmCtrl = panel.TextCtrl(authRealm) authUsernameCtrl = panel.TextCtrl(authUsername) authPasswordCtrl = panel.TextCtrl(authPassword) listSplitterCtrl = panel.TextCtrl(listSplitter) valueSplitterCtrl = panel.TextCtrl(valueSplitter) labels = ( panel.StaticText(text.port), panel.StaticText(text.documentRoot), panel.StaticText(text.eventPrefix), panel.StaticText(text.authRealm), panel.StaticText(text.authUsername), panel.StaticText(text.authPassword), panel.StaticText(text.listSplitter), panel.StaticText(text.valueSplitter), panel.StaticText(text.certfile + ":"), panel.StaticText(text.keyfile + ":") ) eg.EqualizeWidths(labels) labels[8].SetToolTipString(text.sslTool) labels[9].SetToolTipString(text.sslTool) noAutWsCtrl = wx.CheckBox(panel, -1, self.text.noAutWs) noAutWsCtrl.SetValue(noAutWs) acv = wx.ALIGN_CENTER_VERTICAL sizer = wx.FlexGridSizer(5, 2, 5, 5) sizer.AddGrowableCol(1) sizer.Add(labels[0], 0, acv) sizer.Add(portCtrl) sizer.Add(labels[1], 0, acv) sizer.Add(filepathCtrl, 0, wx.EXPAND) sizer.Add(labels[8], 0, acv) sizer.Add(certfileCtrl, 0, wx.EXPAND) sizer.Add(labels[9], 0, acv) sizer.Add(keyfileCtrl, 0, wx.EXPAND) sizer.Add(labels[2], 0, acv) sizer.Add(editCtrl) staticBox = wx.StaticBox(panel, label=text.generalBox) staticBoxSizer = wx.StaticBoxSizer(staticBox, wx.VERTICAL) staticBoxSizer.Add(sizer, 0, wx.LEFT|wx.RIGHT|wx.BOTTOM|wx.EXPAND, 5) panel.sizer.Add(staticBoxSizer, 0, wx.EXPAND) sizer = wx.FlexGridSizer(3, 2, 5, 5) sizer.Add(labels[3], 0, acv) sizer.Add(authRealmCtrl) sizer.Add(labels[4], 0, acv) sizer.Add(authUsernameCtrl) sizer.Add(labels[5], 0, acv) sizer.Add(authPasswordCtrl) staticBox = wx.StaticBox(panel, label=text.authBox) staticBoxSizer = wx.StaticBoxSizer(staticBox, wx.VERTICAL) staticBoxSizer.Add(sizer, 0, wx.LEFT|wx.RIGHT, 5) staticBoxSizer.Add(noAutWsCtrl,0,wx.LEFT|wx.TOP|wx.BOTTOM,5) panel.sizer.Add(staticBoxSizer, 0, wx.EXPAND|wx.TOP, 10) sizer = wx.FlexGridSizer(3, 2, 5, 5) sizer.Add(labels[6], 0, acv) sizer.Add(listSplitterCtrl) sizer.Add(labels[7], 0, acv) sizer.Add(valueSplitterCtrl) staticBox = wx.StaticBox(panel, label=text.nonAjaxBox) staticBoxSizer = wx.StaticBoxSizer(staticBox, wx.VERTICAL) staticBoxSizer.Add(sizer, 0, wx.LEFT|wx.RIGHT|wx.BOTTOM, 5) panel.sizer.Add(staticBoxSizer, 0, wx.EXPAND|wx.TOP, 10) # def ConfigureTargets(event): # dialog = ConfigureTargetsDialog(panel, []) # dialog.ShowModal() # dialog.Destroy() # configureTargetsButton = panel.Button("Configure Targets") # configureTargetsButton.Bind(wx.EVT_BUTTON, ConfigureTargets) # panel.sizer.Add(configureTargetsButton) aSaveCtrl = wx.CheckBox(panel, -1, self.text.autosave) aSaveCtrl.SetValue(autosave) dialogButton = wx.Button(panel,-1,self.text.dialogPers) dialogButton2 = wx.Button(panel,-1,self.text.dialogTemp) dialogButton3 = wx.Button(panel,-1,self.text.wsClients) dialogButton4 = wx.Button(panel,-1,self.text.wsServers) dialogSizer = wx.BoxSizer(wx.HORIZONTAL) dialogSizer.Add(dialogButton) dialogSizer.Add(dialogButton2,0,wx.LEFT,15) dialogSizer.Add(dialogButton3,0,wx.LEFT,15) dialogSizer.Add(dialogButton4,0,wx.LEFT,15) panel.sizer.Add(aSaveCtrl,0,wx.TOP,5) panel.sizer.Add(dialogSizer,0,wx.TOP,5) def OnDialogBtn(evt): dlg = VariableDialog( parent = panel, plugin = self, pers = True ) dlg.Centre() wx.CallAfter( dlg.ShowVariableDialog, self.text.dialogPers, ) evt.Skip() dialogButton.Bind(wx.EVT_BUTTON, OnDialogBtn) def OnDialog2Btn(evt): dlg = VariableDialog( parent = panel, plugin = self, ) dlg.Centre() wx.CallAfter( dlg.ShowVariableDialog, self.text.dialogTemp, ) evt.Skip() dialogButton2.Bind(wx.EVT_BUTTON, OnDialog2Btn) def OnDialog3Btn(evt): dlg = ClientsDialog( parent = panel, plugin = self, ) dlg.Centre() wx.CallAfter(dlg.ShowClientsDialog) evt.Skip() dialogButton3.Bind(wx.EVT_BUTTON, OnDialog3Btn) def OnDialog4Btn(evt): dlg = ServersDialog( parent = panel, plugin = self, ) dlg.Centre() wx.CallAfter(dlg.ShowServersDialog) evt.Skip() dialogButton4.Bind(wx.EVT_BUTTON, OnDialog4Btn) while panel.Affirmed(): panel.SetResult( editCtrl.GetValue(), portCtrl.GetValue(), filepathCtrl.GetValue(), authRealmCtrl.GetValue(), authUsernameCtrl.GetValue(), authPasswordCtrl.GetValue(), self.pubPerVars, aSaveCtrl.GetValue(), listSplitterCtrl.GetValue(), valueSplitterCtrl.GetValue(), certfileCtrl.GetValue(), keyfileCtrl.GetValue(), noAutWsCtrl.GetValue() ) #=============================================================================== class ConfigureTargetsDialog(eg.Dialog): def __init__(self, parent, targets): self.selectedItem = None eg.Dialog.__init__( self, parent, -1, "Configure Targets", style=wx.DEFAULT_DIALOG_STYLE|wx.RESIZE_BORDER ) self.listCtrl = wx.ListCtrl(self, style=wx.LC_REPORT, size=(200, 200)) self.listCtrl.Bind(wx.EVT_LIST_ITEM_SELECTED, self.OnSelectItem) self.listCtrl.Bind(wx.EVT_LIST_ITEM_DESELECTED, self.OnDeselectItem) self.listCtrl.InsertColumn(0, "Target") for i in range(10): self.listCtrl.InsertStringItem(i, "Test %d" % i) addButton = self.Button("Add") editButton = self.Button("Edit") deleteButton = self.Button("Remove") deleteButton.Bind(wx.EVT_BUTTON, self.OnDelete) okButton = self.Button("OK") cancelButton = self.Button("Cancel") sizer = wx.BoxSizer(wx.VERTICAL) sizer.Add(self.listCtrl, 1, wx.EXPAND|wx.ALL, 5) sizer.Add(addButton) sizer.Add(editButton) sizer.Add(deleteButton) sizer.Add(okButton) sizer.Add(cancelButton) self.SetSizer(sizer) self.SetAutoLayout(True) sizer.Fit(self) self.SetMinSize(self.GetSize()) def OnSelectItem(self, event): self.selectedItem = event.GetItem().GetId() def OnDeselectItem(self, event): self.selectedItem = None def OnDelete(self, event): if self.selectedItem is not None: self.listCtrl.DeleteItem(self.selectedItem) #=============================================================================== class StartClient(eg.ActionBase): actionId = "StartClient" class text: noCert = "Do not require the server certificate when secured connection" serverUrl = "Server URL" uniq = "The title must be unique !" def __call__( self, title = "Server", url = "ws://echo.websocket.org", login = "", password = "", noCert = False ): title = eg.ParseString(title) url = eg.ParseString(url) login = eg.ParseString(login) password = eg.ParseString(password) self.plugin.StartClient(title, url, login, password, noCert) def Configure( self, title = "Server", url = "ws://echo.websocket.org", login = "", password = "", noCert = False ): text = self.text pext = self.plugin.text panel = eg.ConfigPanel() titleCtrl = wx.TextCtrl(panel,-1,title) titleCtrl.SetToolTipString(text.uniq) titleSizer = wx.StaticBoxSizer( wx.StaticBox(panel, -1, pext.serverTitle), wx.HORIZONTAL ) titleSizer.Add(titleCtrl, 1, wx.EXPAND) urlCtrl = wx.TextCtrl(panel,-1,url) urlSizer = wx.StaticBoxSizer( wx.StaticBox(panel, -1, text.serverUrl), wx.HORIZONTAL ) urlSizer.Add(urlCtrl, 1, wx.EXPAND) loginLabel = wx.StaticText(panel,-1,pext.authUsername) passwordLabel = wx.StaticText(panel,-1,pext.authPassword) loginCtrl = wx.TextCtrl(panel,-1,login) passwordCtrl = wx.TextCtrl(panel,-1,password) noCertCtrl = wx.CheckBox(panel, -1, text.noCert) noCertCtrl.SetValue(noCert) credSizer = wx.GridBagSizer(10, 8) credSizer.AddGrowableCol(1) topSizer = wx.StaticBoxSizer( wx.StaticBox(panel, -1, pext.authBox), wx.HORIZONTAL ) credSizer.Add(loginLabel,(1,0),(1,1),flag = wx.TOP, border = 3) credSizer.Add(loginCtrl,(1,1),(1,1), flag = wx.EXPAND) credSizer.Add(passwordLabel,(0,0),(1,1),flag = wx.TOP, border = 3) credSizer.Add(passwordCtrl,(0,1),(1,1), flag = wx.EXPAND) topSizer.Add(credSizer, 1, wx.EXPAND) panel.sizer.Add(titleSizer, 0, wx.EXPAND) panel.sizer.Add(urlSizer, 0, wx.EXPAND|wx.TOP,8) panel.sizer.Add(topSizer, 0, wx.EXPAND|wx.TOP,8) panel.sizer.Add(noCertCtrl, 0, wx.TOP,8) def onTitleCtrl(evt): title = evt.GetString() actions = self.plugin.GetActions(StartClient.actionId, self) ts = [actn.args[0] for actn in actions] panel.EnableButtons(title != "" and title not in ts) evt.Skip() titleCtrl.Bind(wx.EVT_TEXT, onTitleCtrl) while panel.Affirmed(): panel.SetResult( titleCtrl.GetValue(), urlCtrl.GetValue(), loginCtrl.GetValue(), passwordCtrl.GetValue(), noCertCtrl.GetValue() ) #=============================================================================== class StopClient(eg.ActionBase): def __call__(self, title): title = eg.ParseString(title) self.plugin.StopClient(title) def Configure(self, title = ""): text = self.plugin.text panel = eg.ConfigPanel() actions = self.plugin.GetActions(StartClient.actionId) ts = [actn.args[0] for actn in actions] titleCtrl = wx.ComboBox(panel, -1, choices = ts, style = wx.CB_DROPDOWN) if title: titleCtrl.SetValue(title) elif len(ts): titleCtrl.SetSelection(0) staticBox = wx.StaticBox(panel, -1, text.serverTitle) topSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) topSizer.Add(titleCtrl,1,wx.LEFT|wx.EXPAND) panel.sizer.Add(topSizer, 0, wx.LEFT|wx.EXPAND) while panel.Affirmed(): panel.SetResult( titleCtrl.GetValue(), ) #=============================================================================== class StopAllClients(eg.ActionBase): def __call__(self): self.plugin.StopAllClients() #=============================================================================== class ClSendMessage(eg.ActionBase): class text: mess = "Message to be sent" def __call__( self, title = "", message = "", pars = False ): title = eg.ParseString(title) if not pars: message = self.plugin.EvalString(message) self.plugin.ClientSendMessage( title, message, ) def GetLabel(self, title, message, pars): return "%s: %s: %s" % (self.name, title, message[:24]) def Configure( self, title="", message = "", pars = False ): pext = self.plugin.text panel = eg.ConfigPanel() actions = self.plugin.GetActions(StartClient.actionId) ts = [actn.args[0] for actn in actions] titleCtrl = wx.ComboBox(panel, -1, choices = ts, style = wx.CB_DROPDOWN) if title: titleCtrl.SetValue(title) elif len(ts): titleCtrl.SetSelection(0) staticBox = wx.StaticBox(panel, -1, pext.serverTitle) topSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) topSizer.Add(titleCtrl,1,wx.LEFT|wx.EXPAND) messCtrl = wx.TextCtrl(panel, -1, message) messSizer = wx.StaticBoxSizer( wx.StaticBox(panel, -1, self.text.mess), wx.VERTICAL ) parsCtrl = wx.CheckBox(panel, -1, pext.parsing) parsCtrl.SetValue(pars) messSizer.Add(messCtrl, 0, wx.EXPAND) messSizer.Add(parsCtrl, 0, wx.EXPAND|wx.TOP, 3) panel.sizer.Add(topSizer, 0, wx.LEFT|wx.EXPAND) panel.sizer.Add(messSizer, 0, wx.EXPAND|wx.TOP, 8) while panel.Affirmed(): panel.SetResult( titleCtrl.GetValue(), messCtrl.GetValue(), parsCtrl.GetValue() ) #=============================================================================== class ClSendValue(eg.ActionBase): class text: varnames = "Variable name or list of variables (separated by commas):" def __call__( self, title="", varnames = "", ): try: keys = varnames.replace(" ", "") keys = keys.split(",") except: eg.PrintError(self.text.err % str(varnames)) return try: vals = {} for key in keys: k = self.plugin.EvalString(key) vals[k] = self.plugin.GetValue(k) except: eg.PrintError(self.text.err % str(varnames)) return self.plugin.ClientSendMessage( eg.ParseString(title), dumps({'method':'Values', 'kwargs':vals}), ) def GetLabel(self, title, varnames): return "%s: %s: %s" % (self.name, title, varnames) def Configure( self, title="", varnames = "", ): pext = self.plugin.text panel = eg.ConfigPanel() actions = self.plugin.GetActions(StartClient.actionId) ts = [actn.args[0] for actn in actions] titleCtrl = wx.ComboBox(panel, -1, choices = ts, style = wx.CB_DROPDOWN) if title: titleCtrl.SetValue(title) elif len(ts): titleCtrl.SetSelection(0) staticBox = wx.StaticBox(panel, -1, pext.serverTitle) topSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) topSizer.Add(titleCtrl,1,wx.LEFT|wx.EXPAND) varnamesCtrl = panel.TextCtrl(varnames) messSizer = wx.StaticBoxSizer( wx.StaticBox(panel, -1, self.text.varnames), wx.VERTICAL ) messSizer.Add(varnamesCtrl, 0, wx.EXPAND) panel.sizer.Add(topSizer, 0, wx.LEFT|wx.EXPAND) panel.sizer.Add(messSizer, 0, wx.EXPAND|wx.TOP, 8) while panel.Affirmed(): panel.SetResult( titleCtrl.GetValue(), varnamesCtrl.GetValue(), ) #=============================================================================== class ClSendAllValues(eg.ActionBase): def __call__( self, title = "", ): values = self.plugin.GetAllValues() self.plugin.ClientSendMessage( eg.ParseString(title), dumps({'method':'Values', 'kwargs':values}) ) def Configure( self, title="", ): pext = self.plugin.text panel = eg.ConfigPanel() actions = self.plugin.GetActions(StartClient.actionId) ts = [actn.args[0] for actn in actions] titleCtrl = wx.ComboBox(panel, -1, choices = ts, style = wx.CB_DROPDOWN) if title: titleCtrl.SetValue(title) elif len(ts): titleCtrl.SetSelection(0) staticBox = wx.StaticBox(panel, -1, pext.serverTitle) topSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) topSizer.Add(titleCtrl,1,wx.LEFT|wx.EXPAND) panel.sizer.Add(topSizer, 0, wx.LEFT|wx.EXPAND) while panel.Affirmed(): panel.SetResult( titleCtrl.GetValue(), ) #=============================================================================== class ClSendData(eg.ActionBase): class text: dataName = "Data name:" data2send = "Data for broadcast (python expression):" cond = "Condition for data sending (python expression):" def __call__( self, title = "", dataName="", data2send="", cond="", ): data = self.plugin.EvalString(data2send) cond = self.plugin.EvalString(cond) if cond != "" else True if cond: self.plugin.ClientSendMessage( eg.ParseString(title), dumps({ 'method':'Data', 'dataName':dataName, 'data':data }) ) def GetLabel(self, title, dataName, data2send, cond): return "%s: %s: %s" % (self.name, title, dataName) def Configure( self, title = "", dataName="", data2send="", cond="", ): pext = self.plugin.text text = self.text panel = eg.ConfigPanel() actions = self.plugin.GetActions(StartClient.actionId) ts = [actn.args[0] for actn in actions] titleCtrl = wx.ComboBox(panel, -1, choices = ts, style = wx.CB_DROPDOWN) if title: titleCtrl.SetValue(title) elif len(ts): titleCtrl.SetSelection(0) staticBox = wx.StaticBox(panel, -1, pext.serverTitle) topSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) topSizer.Add(titleCtrl,1,wx.LEFT|wx.EXPAND) panel.sizer.Add(topSizer, 0, wx.LEFT|wx.EXPAND) nameLabel = wx.StaticText(panel, -1, text.dataName) sendLabel = wx.StaticText(panel, -1, text.data2send) condLabel = wx.StaticText(panel, -1, text.cond) nameCtrl = wx.TextCtrl(panel, -1, dataName) sendCtrl = wx.TextCtrl(panel, -1, data2send) condCtrl = wx.TextCtrl(panel, -1, cond) mainSizer = wx.StaticBoxSizer( wx.StaticBox(panel, -1, ""), wx.VERTICAL ) mainSizer.Add(nameLabel) mainSizer.Add(nameCtrl,0,wx.EXPAND|wx.TOP,2) mainSizer.Add(sendLabel,0,wx.TOP,10) mainSizer.Add(sendCtrl,0,wx.EXPAND|wx.TOP,2) mainSizer.Add(condLabel,0,wx.TOP,10) mainSizer.Add(condCtrl,0,wx.EXPAND|wx.TOP,2) panel.sizer.Add(mainSizer,0,wx.TOP|wx.BOTTOM|wx.EXPAND,5) while panel.Affirmed(): panel.SetResult( titleCtrl.GetValue(), nameCtrl.GetValue(), sendCtrl.GetValue(), condCtrl.GetValue(), ) #=============================================================================== class ClSendCommand(eg.ActionBase): class text: cond = "Condition:" cmdName = "Command name:" arg1 = "Argument 1:" arg2 = "Argument 2:" arg3 = "Argument 3:" othArgs = "Arguments:" kwArgs = "Keyw. arguments:" onlyChange = "Data send only if it has been changed" period = "Sending period [s]:" def __call__( self, title = "", cmdName="", cond="", arg1="", arg2="", arg3="", othArgs="", kwArgs ="", ): cmdName = self.plugin.EvalString(cmdName) args = [self.plugin.EvalString(arg1)] if arg1 != "" else [] if arg2 != "": args.append(self.plugin.EvalString(arg2)) if arg3 != "": args.append(self.plugin.EvalString(arg3)) if othArgs != "": try: othArgs = list(self.plugin.EvalString(othArgs)) args.extend(othArgs) except: pass kwargs = {} if kwArgs != "": try: kwargs = dict(self.plugin.EvalString(kwArgs, False)) except: pass cond = self.plugin.EvalString(cond) if cond != "" else True if cond: self.plugin.ClientSendMessage( eg.ParseString(title), dumps( { 'method' :'Command', 'cmdName':cmdName, 'args':args, 'kwargs':kwargs } ) ) def GetLabel( self, title, cmdName, cond, arg1, arg2, arg3, othArgs, kwArgs ): return "%s: %s: %s" % ( self.name, title, cmdName ) def Configure( self, title="", cmdName="", cond="", arg1="", arg2="", arg3="", othArgs="", kwArgs ="", ): panel = eg.ConfigPanel(self) pext = self.plugin.text text = self.text actions = self.plugin.GetActions(StartClient.actionId) ts = [actn.args[0] for actn in actions] titleCtrl = wx.ComboBox(panel, -1, choices = ts, style = wx.CB_DROPDOWN) if title: titleCtrl.SetValue(title) elif len(ts): titleCtrl.SetSelection(0) staticBox = wx.StaticBox(panel, -1, pext.serverTitle) topSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) topSizer.Add(titleCtrl,1,wx.LEFT|wx.EXPAND) panel.sizer.Add(topSizer, 0, wx.LEFT|wx.EXPAND) nameLabel = wx.StaticText(panel, -1, text.cmdName) condLabel = wx.StaticText(panel, -1, text.cond) arg1Label = wx.StaticText(panel, -1, text.arg1) arg2Label = wx.StaticText(panel, -1, text.arg2) arg3Label = wx.StaticText(panel, -1, text.arg3) othLabel = wx.StaticText(panel, -1, text.othArgs) kwLabel = wx.StaticText(panel, -1, text.kwArgs) nameCtrl = wx.TextCtrl(panel, -1, cmdName) condCtrl = wx.TextCtrl(panel, -1, cond) arg1Ctrl = wx.TextCtrl(panel, -1, arg1) arg2Ctrl = wx.TextCtrl(panel, -1, arg2) arg3Ctrl = wx.TextCtrl(panel, -1, arg3) othCtrl = wx.TextCtrl(panel, -1, othArgs) kwCtrl = wx.TextCtrl(panel, -1, kwArgs) mainSizer = wx.FlexGridSizer(7, 2, 2, 10) mainSizer.AddGrowableCol(1) mainSizer.Add(nameLabel,0, wx.TOP,3) mainSizer.Add(nameCtrl,0,wx.EXPAND) mainSizer.Add(arg1Label,0, wx.TOP,3) mainSizer.Add(arg1Ctrl,0,wx.EXPAND) mainSizer.Add(arg2Label,0, wx.TOP,3) mainSizer.Add(arg2Ctrl,0,wx.EXPAND) mainSizer.Add(arg3Label,0, wx.TOP,3) mainSizer.Add(arg3Ctrl,0,wx.EXPAND) mainSizer.Add(othLabel,0, wx.TOP,3) mainSizer.Add(othCtrl,0,wx.EXPAND) mainSizer.Add(kwLabel,0, wx.TOP,3) mainSizer.Add(kwCtrl,0,wx.EXPAND) mainSizer.Add(condLabel,0, wx.TOP,3) mainSizer.Add(condCtrl,0,wx.EXPAND) messSizer = wx.StaticBoxSizer( wx.StaticBox(panel, -1, ""), wx.VERTICAL ) messSizer.Add(mainSizer,0,wx.EXPAND) panel.sizer.Add(messSizer,0,wx.TOP|wx.BOTTOM|wx.EXPAND,5) while panel.Affirmed(): panel.SetResult( titleCtrl.GetValue(), nameCtrl.GetValue(), condCtrl.GetValue(), arg1Ctrl.GetValue(), arg2Ctrl.GetValue(), arg3Ctrl.GetValue(), othCtrl.GetValue(), kwCtrl.GetValue() ) #=============================================================================== class ClSendUniversal(eg.ActionBase): class text: cond = "Condition:" method = "Method:" othArgs = "Arguments:" kwArgs = "Keyw. arguments:" onlyChange = "Data send only if it has been changed" period = "Sending period [s]:" def __call__( self, title="", method="", cond="", othArgs="", kwArgs ="" ): args = [] if othArgs != "": try: args = list(self.plugin.EvalString(othArgs)) except: pass kwargs = {} if kwArgs != "": try: kwargs = dict(self.plugin.EvalString(kwArgs, False)) except: pass cond = self.plugin.EvalString(cond) if cond != "" else True if cond: self.plugin.ClientSendMessage( eg.ParseString(title), dumps( { 'method' :method, 'args':args, 'kwargs':kwargs } ), ) def GetLabel( self, title, method, cond, othArgs, kwArgs ): return "%s: %s: %s" % (self.name, title, method) def Configure( self, title="", method="", cond="", othArgs="", kwArgs ="" ): panel = eg.ConfigPanel(self) pext = self.plugin.text text = self.text actions = self.plugin.GetActions(StartClient.actionId) ts = [actn.args[0] for actn in actions] titleCtrl = wx.ComboBox(panel, -1, choices = ts, style = wx.CB_DROPDOWN) if title: titleCtrl.SetValue(title) elif len(ts): titleCtrl.SetSelection(0) staticBox = wx.StaticBox(panel, -1, pext.serverTitle) topSizer = wx.StaticBoxSizer(staticBox, wx.HORIZONTAL) topSizer.Add(titleCtrl,1,wx.LEFT|wx.EXPAND) panel.sizer.Add(topSizer, 0, wx.LEFT|wx.EXPAND) staticBox = wx.StaticBox(panel, -1, "") methodLabel = wx.StaticText(panel, -1, text.method) condLabel = wx.StaticText(panel, -1, text.cond) othLabel = wx.StaticText(panel, -1, text.othArgs) kwLabel = wx.StaticText(panel, -1, text.kwArgs) methodCtrl = wx.ComboBox( panel, -1, choices = METHODS[:8], style = wx.CB_DROPDOWN ) methodCtrl.SetValue(method) condCtrl = wx.TextCtrl(panel, -1, cond) othCtrl = wx.TextCtrl(panel, -1, othArgs) kwCtrl = wx.TextCtrl(panel, -1, kwArgs) mainSizer = wx.FlexGridSizer(5, 2, 8, 10) mainSizer.AddGrowableCol(1) mainSizer.Add(methodLabel,0, wx.TOP,3) mainSizer.Add(methodCtrl,0,wx.EXPAND) mainSizer.Add(othLabel,0, wx.TOP,3) mainSizer.Add(othCtrl,0,wx.EXPAND) mainSizer.Add(kwLabel,0, wx.TOP,3) mainSizer.Add(kwCtrl,0,wx.EXPAND) mainSizer.Add(condLabel,0, wx.TOP,3) mainSizer.Add(condCtrl,0,wx.EXPAND) messSizer = wx.StaticBoxSizer( wx.StaticBox(panel, -1, ""), wx.VERTICAL ) messSizer.Add(mainSizer, 0, wx.TOP|wx.BOTTOM|wx.EXPAND, 5) panel.sizer.Add(messSizer, 0, wx.TOP|wx.BOTTOM|wx.EXPAND, 5) while panel.Affirmed(): panel.SetResult( titleCtrl.GetValue(), methodCtrl.GetValue(), condCtrl.GetValue(), othCtrl.GetValue(), kwCtrl.GetValue() ) #=============================================================================== ACTIONS = ( (SendEvent, "SendEvent", "Send event to another EventGhost", "Sends event to another EventGhost webserver.", None ), (SendEventExt, "SendEventExt", "Send event to another webserver", "Sends event to another webserver.", None ), (eg.ActionGroup, 'VariableActions', 'Variable actions', 'Variable actions', ( (GetValue, "GetValue", "Get temporary value", "Gets value of temporary variable.", None ), (GetPersistentValue, "GetPersistentValue", "Get persistent value", "Gets value of persistent variable.", None ), (SetValue, "SetValue", "Set temporary value", "Sets value of temporary variable.", None ), (SetPersistentValue, "SetPersistentValue", "Set persistent value", "Sets value of persistent variable.", None ), (SetClientsFlags, "SetClientsFlags", "Set clients flags", "Sets clients flags of dummy variable.", None ), )), (eg.ActionGroup, 'WebsocketActions', 'Websocket actions server-client', 'Websocket actions server-client', ( (WsBroadcastMessage, 'BroadcastMessage', 'Broadcast message', '''Broadcasts a message to all WebSocket clients. Following (optional) evaluation, message is sent as is (no JSON formatting).''', None ), (WsBroadcastValue, 'BroadcastValue', 'Broadcast values', '''Broadcasts a value(-s) of a variable(-s) (temporary or persistent) to all WebSocket clients. Specify name of a variable or list of variables (separated by commas, without parentheses).
Following the evaluation, a message is formatted as a JSON object.
A client receives a message in the following form:
{'method': 'Values', 'kwargs': {key1: value1, key2: value2, ...}},
where keyX is variable name and valueX is the value of this variable.''', None ), (WsBroadcastAllValues, 'BroadcastAllValues', 'Broadcast all values', '''Broadcasts the values of all variables (temporary and persistent) to all WebSocket clients. A message is formatted as a JSON object. A client receives a message in the following form: {'method': 'Values', 'kwargs': {key1: value1, key2: value2, ...}}, where keyX is variable name and valueX is the value of this variable.''', None ), (WsBroadcastData, 'WsBroadcastData', 'Broadcast data', '''Broadcasts some data to all WebSocket clients. Data can be obtained for example by evaluating Python expression. Sending may be conditional upon the fulfillment (optional) conditions. The condition may also be a Python expression. A message is formatted as a JSON object. A client receives a message in the following form: {'method': 'Data', 'dataName': dataName, 'data': data}.''', False ), (WsBroadcastCommand, 'WsBroadcastCmd', 'Broadcast command', '''Broadcasts a command to all WebSocket clients. This action allows you to specify more complex set of data into a single message.
Data sending may be conditional upon the fulfillment (optional) conditions. The condition can be a Python expression.
A message is formatted as a JSON object.
A client receives a message in the following form:
{'method' :'Command', 'cmdName':cmdName, 'args':args, 'kwargs':kwargs},
where args are the arguments of the lines Argument 1 to 3 and/or argument of line Arguments and kwargs is argument from the line Keyw. arguments.
"args" is a Python list, while "kwargs" is a Python dictionary.''', False ), (WsBroadcastUniversal, 'WsBroadcastUniversal', 'Broadcast universal packet', '''Broadcasts a universal packet to all WebSocket clients. This action allows you to specify a universal data packet.
Data sending may be conditional upon the fulfillment (optional) conditions. The condition can be a Python expression.
A message is formatted as a JSON object.
A client receives a message in the following form:
{'method' :method, 'args':args, 'kwargs':kwargs},
where method is the selected method,
args is argument from the line Arguments
and kwargs is argument from the line Keyw. arguments.
Note: args is a Python list, while kwargs is a Python dictionary.''', False ), (WsSendMessage, 'SendMessage', 'Send message', '''Sends a message to one WebSocket client. Following (optional) evaluation, message is sent as is (no JSON formatting).''', None ), (WsSendValue, 'SendValue', 'Send values', '''Sends a value(-s) of a variable(-s) (temporary or persistent) to one WebSocket client. Specify name of a variable or list of variables (separated by commas, without parentheses).
Following the evaluation, a message is formatted as a JSON object.
A client receives a message in the following form:
{'method': 'Values', 'kwargs': {key1: value1, key2: value2, ...}},
where keyX is variable name and valueX is the value of this variable.''', None ), (WsSendAllValues, 'SendAllValues', 'Send all values', '''Sends the values of all variables (temporary and persistent) to one WebSocket client. A message is formatted as a JSON object. A client receives a message in the following form: {'method': 'Values', 'kwargs': {key1: value1, key2: value2, ...}}, where keyX is variable name and valueX is the value of this variable.''', None ), (WsPeriodicallySendData, 'WsSendData', 'Send data', '''Sends some data to one WebSocket client. Data can be obtained for example by evaluating Python expression. Sending may be conditional upon the fulfillment (optional) conditions. The condition may also be a Python expression. A message is formatted as a JSON object. A client receives a message in the following form: {'method': 'Data', 'dataName': dataName, 'data': data}.''', False ), (WsSendCommand, 'WsSendCmd', 'Send command', '''Sends a command to one WebSocket client. This action allows you to specify more complex set of data into a single message.
Data sending may be conditional upon the fulfillment (optional) conditions. The condition can be a Python expression.
A message is formatted as a JSON object.
A client receives a message in the following form:
{'method' :'Command', 'cmdName':cmdName, 'args':args, 'kwargs':kwargs},
where args are the arguments of the lines Argument 1 to 3 and/or argument of line Arguments and kwargs is argument from the line Keyw. arguments.
"args" is a Python list, while "kwargs" is a Python dictionary.''', False ), (WsSendUniversal, 'WsSendUniversal', 'Send universal packet', '''Sends a universal packet to one WebSocket client. This action allows you to specify a universal data packet.
Data sending may be conditional upon the fulfillment (optional) conditions. The condition can be a Python expression.
A message is formatted as a JSON object.
A client receives a message in the following form:
{'method' :method, 'args':args, 'kwargs':kwargs},
where method is the selected method,
args is argument from the line Arguments
and kwargs is argument from the line Keyw. arguments.
Note: args is a Python list, while kwargs is a Python dictionary.''', False ), (eg.ActionGroup, 'PeriodicActions', 'Periodically repeated actions', 'Periodically repeated actions', ( (WsBroadcastData, 'WsPeriodicallyBroadcastData', 'Periodically broadcast data', '''Periodically broadcasts data to all WebSocket clients. Same as "Broadcast data" action, but the broadcasting is automatically repeated periodically after a predetermined time.''', True ), (WsBroadcastCommand, 'WsPeriodicallyBroadcastCmd', 'Periodically broadcast command', '''Periodically broadcasts command to all WebSocket clients. Same as "Broadcast command" action, but the broadcasting is automatically repeated periodically after a predetermined time.''', True ), (WsBroadcastUniversal, 'WsPeriodicallyBroadcastUniversal', 'Periodically broadcast universal packet', '''Periodically broadcasts universal packet to all WebSocket clients. Same as "Broadcast universal packet" action, but the broadcasting is automatically repeated periodically after a predetermined time.''', True ), (WsPeriodicallySendData, 'WsPeriodicallySendData', 'Periodically send data', '''Periodically sends data to one WebSocket client. Same as Send data action, but the sending is automatically repeated periodically after a predetermined time.''', True ), (WsSendCommand, 'WsPeriodicallySendCmd', 'Periodically send command', '''Periodically sends command to one WebSocket client. Same as "Send command" action, but the sending is automatically repeated periodically after a predetermined time.''', True ), (WsSendUniversal, 'WsPeriodicallySendUniversal', 'Periodically send universal packet', '''Periodically sends a universal packet to one WebSocket client. Same as "Send universal packet" action, but the sending is automatically repeated periodically after a predetermined time.''', True ), (WsStopPeriodicTasks, 'WsStopAllPeriodicTasks', 'Stop all periodic tasks', 'Stops all periodic tasks.', True ), (WsStopPeriodicTasks, 'WsStopBroadcastPeriodicTasks', 'Stop periodic tasks (broadcast)', 'Stops periodic tasks (broadcast).', False ), (WsStopClientPeriodicTasks, 'WsStopClientPeriodicTasks', 'Stop periodic tasks (one client)', 'Stops periodic tasks (one client).', None ), )), )), ( eg.ActionGroup, 'ClientActions', 'Websocket actions client-server', 'Websocket actions client-server',( (StartClient, 'StartClient', 'Start client', 'Starts client.', None), (StopClient, 'StopClient', 'Stop client', 'Stops client.', None), (StopAllClients, 'StopAllClients', 'Stop all clients', 'Stops all clients.', None), (ClSendMessage, 'ClSendMessage', 'Send message to server', '''Sends a message to WebSocket server. Following (optional) evaluation, message is sent as is (no JSON formatting).''', None ), (ClSendValue, 'ClSendValue', 'Send values to server', '''Sends a value(-s) of a variable(-s) (temporary or persistent) to WebSocket server. Specify name of a variable or list of variables (separated by commas, without parentheses).
Following the evaluation, a message is formatted as a JSON object.
A server receives a message in the following form:
{'method': 'Values', 'kwargs': {key1: value1, key2: value2, ...}},
where keyX is variable name and valueX is the value of this variable.''', None ), (ClSendAllValues, 'ClSendAllValues', 'Send all values to server', '''Sends the values of all variables (temporary and persistent) to WebSocket server. A message is formatted as a JSON object. A server receives a message in the following form: {'method': 'Values', 'kwargs': {key1: value1, key2: value2, ...}}, where keyX is variable name and valueX is the value of this variable.''', None ), (ClSendData, 'ClSendData', 'Send data to server', '''Sends some data to WebSocket server. Data can be obtained for example by evaluating Python expression. Sending may be conditional upon the fulfillment (optional) conditions. The condition may also be a Python expression. A message is formatted as a JSON object. A server receives a message in the following form: {'method': 'Data', 'dataName': dataName, 'data': data}.''', False ), (ClSendCommand, 'ClSendCmd', 'Send command to server', '''Sends a command to WebSocket server. This action allows you to specify more complex set of data into a single message.
Data sending may be conditional upon the fulfillment (optional) conditions. The condition can be a Python expression.
A message is formatted as a JSON object.
A server receives a message in the following form:
{'method' :'Command', 'cmdName':cmdName, 'args':args, 'kwargs':kwargs},
where args are the arguments of the lines Argument 1 to 3 and/or argument of line Arguments and kwargs is argument from the line Keyw. arguments.
"args" is a Python list, while "kwargs" is a Python dictionary.''', False ), (ClSendUniversal, 'ClSendUniversal', 'Send universal packet to server', '''Sends a universal packet to WebSocket server. This action allows you to specify a universal data packet.
Data sending may be conditional upon the fulfillment (optional) conditions. The condition can be a Python expression.
A message is formatted as a JSON object.
A server receives a message in the following form:
{'method' :method, 'args':args, 'kwargs':kwargs},
where method is the selected method,
args is argument from the line Arguments
and kwargs is argument from the line Keyw. arguments.
Note: args is a Python list, while kwargs is a Python dictionary.''', False ), )), )