HGKeeper

#!/usr/bin/env python

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

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

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

# See COPYING file for copyrights details.

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

# modify it under the terms of the GNU General Public License

# as published by the Free Software Foundation; either version 2

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

# This program 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, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.

import os

from nevow import rend, appserver, inevow, tags, loaders, athena

from nevow.page import renderer

from twisted.python import util

from twisted.internet import reactor

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

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.1//EN"

"http://www.w3.org/TR/xhtml11/DTD/xhtml11.dtd">

'''

WorkingDir = None

class PLCHMI(athena.LiveElement):

initialised = False

def HMIinitialised(self, result):

self.initialised = True

def HMIinitialisation(self):

self.HMIinitialised(None)

class DefaultPLCStartedHMI(PLCHMI):

docFactory = loaders.stan(tags.div(render=tags.directive('liveElement'))[

tags.h1["PLC IS NOW STARTED"],

])

class PLCStoppedHMI(PLCHMI):

docFactory = loaders.stan(tags.div(render=tags.directive('liveElement'))[

tags.h1["PLC IS STOPPED"],

])

class MainPage(athena.LiveElement):

jsClass = u"WebInterface.PLC"

docFactory = loaders.stan(tags.div(render=tags.directive('liveElement'))[

tags.div(id='content')[

tags.div(render = tags.directive('PLCElement')),

]])

def __init__(self, *a, **kw):

athena.LiveElement.__init__(self, *a, **kw)

self.pcl_state = False

self.HMI = None

self.resetPLCStartedHMI()

def setPLCState(self, state):

self.pcl_state = state

if self.HMI is not None:

self.callRemote('updateHMI')

def setPLCStartedHMI(self, hmi):

self.PLCStartedHMIClass = hmi

def resetPLCStartedHMI(self):

self.PLCStartedHMIClass = DefaultPLCStartedHMI

def getHMI(self):

return self.HMI

def HMIexec(self, function, *args, **kwargs):

if self.HMI is not None:

getattr(self.HMI, function, lambda:None)(*args, **kwargs)

athena.expose(HMIexec)

def resetHMI(self):

self.HMI = None

def PLCElement(self, ctx, data):

return self.getPLCElement()

renderer(PLCElement)

def getPLCElement(self):

self.detachFragmentChildren()

if self.pcl_state:

f = self.PLCStartedHMIClass()

else:

f = PLCStoppedHMI()

f.setFragmentParent(self)

self.HMI = f

return f

athena.expose(getPLCElement)

def detachFragmentChildren(self):

for child in self.liveFragmentChildren[:]:

child.detach()

class WebInterface(athena.LivePage):

docFactory = loaders.stan([tags.raw(xhtml_header),

tags.html(xmlns="http://www.w3.org/1999/xhtml")[

tags.head(render=tags.directive('liveglue')),

tags.body[

tags.div[

tags.div( render = tags.directive( "MainPage" ))

]]]])

MainPage = MainPage()

PLCHMI = PLCHMI

def __init__(self, plcState=False, *a, **kw):

super(WebInterface, self).__init__(*a, **kw)

self.jsModules.mapping[u'WebInterface'] = util.sibpath(__file__, 'webinterface.js')

self.plcState = plcState

self.MainPage.setPLCState(plcState)

def getHMI(self):

return self.MainPage.getHMI()

def LoadHMI(self, hmi, jsmodules):

for name, path in jsmodules.iteritems():

self.jsModules.mapping[name] = os.path.join(WorkingDir, path)

self.MainPage.setPLCStartedHMI(hmi)

def UnLoadHMI(self):

self.MainPage.resetPLCStartedHMI()

def PLCStarted(self):

self.plcState = True

self.MainPage.setPLCState(True)

def PLCStopped(self):

self.plcState = False

self.MainPage.setPLCState(False)

def renderHTTP(self, ctx):

"""

Force content type to fit with SVG

"""

req = inevow.IRequest(ctx)

req.setHeader('Content-type', 'application/xhtml+xml')

return super(WebInterface, self).renderHTTP(ctx)

def render_MainPage(self, ctx, data):

f = self.MainPage

f.setFragmentParent(self)

return ctx.tag[f]

def child_(self, ctx):

self.MainPage.detachFragmentChildren()

return WebInterface(plcState=self.plcState)

def beforeRender(self, ctx):

d = self.notifyOnDisconnect()

d.addErrback(self.disconnected)

def disconnected(self, reason):

self.MainPage.resetHMI()

#print reason

#print "We will be called back when the client disconnects"

def RegisterWebsite(port):

website = WebInterface()

site = appserver.NevowSite(website)

listening = False

reactor.listenTCP(port, site)

print _("HTTP interface port :"), port

return website

class statuslistener:

def __init__(self, site):

self.oldstate = None

self.site = site

def listen(self, state):

if state != self.oldstate:

action = {'Started': self.site.PLCStarted,

'Stopped': self.site.PLCStopped}.get(state, None)

if action is not None: action ()

self.oldstate = state

def website_statuslistener_factory(site):

return statuslistener(site).listen

beremiz