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

    18

# TODO multiclient :

    19

# session list lock

    20

# svghmi_sessions = []

    21

    22

svghmi_session = None

    23

    24

svghmi_send_collect = PLCBinary.svghmi_send_collect

    25

svghmi_send_collect.restype = ctypes.c_int # error or 0

    26

svghmi_send_collect.argtypes = [

    27

    ctypes.POINTER(ctypes.c_uint32),  # size

    28

    ctypes.POINTER(ctypes.c_void_p)]  # data ptr

    29

# TODO multiclient : switch to arrays

    30

    31

svghmi_recv_dispatch = PLCBinary.svghmi_recv_dispatch

    32

svghmi_recv_dispatch.restype = ctypes.c_int # error or 0

    33

svghmi_recv_dispatch.argtypes = [

    35

    ctypes.POINTER(ctypes.c_void_p)]  # data ptr

    36

# TODO multiclient : switch to arrays

    37

    38

def SendThreadProc():

    39

   assert(svghmi_session)

    40

   size = ctypes.c_uint32()

    41

   ptr = ctypes.c_void_p()

    47

    49

    50

class HMISession(object):

    51

    def __init__(self, protocol_instance):

    52

        global svghmi_session

    54

        # TODO: kill existing session for robustness

    55

        assert(svghmi_session is None)

    56

    57

        svghmi_session = self

    58

        self.protocol_instance = protocol_instance

    59

    60

        # TODO multiclient :

    61

        # svghmi_sessions.append(self)

    62

        # get a unique bit index amont other svghmi_sessions,

    63

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

    65

    def __del__(self):

    66

        global svghmi_session

    67

        assert(svghmi_session)

    68

        svghmi_session = None

    69

    70

        # TODO multiclient :

    71

        # svghmi_sessions.remove(self)

    72

    73

    def onMessage(self, msg):

    74

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

    75

        #    update HMITree

    76

        #        - values

    77

        #        - refresh rates / subsriptions

    78

    79

        # TODO multiclient : pass client index as well

    80

        pass

    82

    def sendMessage(self, msg):

    83

        self.sendMessage(msg, True)

    84

    85

class HMIProtocol(WebSocketServerProtocol):

    86

    87

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

    88

        self._hmi_session = None

    89

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

    90

    91

    def onOpen(self):

    92

        self._hmi_session = HMISession(self)

    93

        print "open"

    94

    95

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

    96

        del self._hmi_session

    97

        self._hmi_session = None

    98

        print "close"

    99

   100

    def onMessage(self, msg, isBinary):

   101

        self._hmi_session.onMessage(msg)

   102

        print msg

   103

        #self.sendMessage(msg, binary)

   105

svghmi_root = None

   106

svghmi_listener = None

   109

   110

# Called by PLCObject at start

   111

def _runtime_svghmi0_start():

   113

   114

    svghmi_root = Resource()

   115

   116

    wsfactory = WebSocketServerFactory()

   117

    wsfactory.protocol = HMIProtocol

   118

   120

   121

    sitefactory = Site(svghmi_root)

   122

   123

    svghmi_listener = reactor.listenTCP(8008, sitefactory)

   124

   125

    # start a thread that call the C part of SVGHMI

   128

   129

   130

# Called by PLCObject at stop

   131

def _runtime_svghmi0_stop():

   135

    svghmi_listener.stopListening()