1

#!/usr/bin/env python

     2

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

     3

     4

# This file is part of Beremiz

     5

# Copyright (C) 2019: Edouard TISSERANT

     6

# See COPYING file for copyrights details.

     7

     8

from __future__ import absolute_import

     9

    10

from twisted.web.server import Site

    11

from twisted.web.resource import Resource

    12

from twisted.internet import reactor

    13

from twisted.web.static import File

    14

    15

from autobahn.twisted.websocket import WebSocketServerFactory, WebSocketServerProtocol

    16

from autobahn.twisted.resource import  WebSocketResource

    17

    23

    24

class HMISession(object):

    25

    def __init__(self, protocol_instance):

    33

    34

        # TODO multiclient :

    36

        # get a unique bit index amont other svghmi_sessions,

    37

        # so that we can match flags passed by C->python callback

    38

    39

    def __del__(self):

    46

    47

    def onMessage(self, msg):

    48

        # TODO :  pass it to the C side recieve_message()

    49

        #    update HMITree

    50

        #        - values

    51

        #        - refresh rates / subsriptions

    52

    53

        # TODO multiclient : pass client index as well

    54

        pass

    55

    56

    57

class HMIProtocol(WebSocketServerProtocol):

    58

    59

    def __init__(self, *args, **kwargs):

    60

        self._hmi_session = None

    61

        WebSocketServerProtocol.__init__(self, *args, **kwargs)

    62

    63

    def onOpen(self):

    64

        self._hmi_session = HMISession(self)

    65

        print "open"

    66

    67

    def onClose(self, wasClean, code, reason):

    68

        del self._hmi_session

    69

        self._hmi_session = None

    70

        print "close"

    71

    72

    def onMessage(self, msg, isBinary):

    73

        self._hmi_session.onMessage(msg)

    74

        print msg

    75

        #self.sendMessage(msg, binary)

    76

    77

svghmi_root = None

    78

svghmi_listener = None

    79

    80

# Called by PLCObject at start

    81

def _runtime_svghmi0_start():

    82

    global svghmi_listener, svghmi_root

    83

    84

    svghmi_root = Resource()

    85

    86

    wsfactory = WebSocketServerFactory()

    87

    wsfactory.protocol = HMIProtocol

    88

    89

    # svghmi_root.putChild("",File(".svg"))

    90

    svghmi_root.putChild("ws",WebSocketResource(wsfactory))

    91

    92

    sitefactory = Site(svghmi_root)

    93

    94

    svghmi_listener = reactor.listenTCP(8008, sitefactory)

    95

    96

    # TODO

    97

    # start a thread that call the C part of SVGHMI

    98

    99

   100

# Called by PLCObject at stop

   101

def _runtime_svghmi0_stop():

   102

    global svghmi_listener

   103

    svghmi_listener.stopListening()